Source Code (Use browser search to find items of interest.)

Class Index

kdelibs'FlowSystem_stub (./kdelibs/arts/mcop/core.h:564)

class FlowSystem_stub : virtual public FlowSystem_base, virtual public Object_stub {
protected:
	FlowSystem_stub();

public:
	FlowSystem_stub(Connection *connection, long objectID);

	void startObject(Object node);
	void stopObject(Object node);
	void connectObject(Object sourceObject, const std::string& sourcePort, Object destObject, const std::string& destPort);
	void disconnectObject(Object sourceObject, const std::string& sourcePort, Object destObject, const std::string& destPort);
	AttributeType queryFlags(Object node, const std::string& port);
	FlowSystemReceiver createReceiver(Object destObject, const std::string& destPort, FlowSystemSender sender);
};


kdelibs'FlowSystem_stub::FlowSystem_stub() (./kdelibs/arts/mcop/core.cc:1222)

FlowSystem_stub::FlowSystem_stub()
{
	// constructor for subclasses (don't use directly)
}


kdelibs'FlowSystem_stub::FlowSystem_stub() (./kdelibs/arts/mcop/core.cc:1227)

FlowSystem_stub::FlowSystem_stub(Connection *connection, long objectID)
	: Object_stub(connection, objectID)
{
	// constructor to create a stub for an object
}


kdelibs'FlowSystem_stub::startObject() (./kdelibs/arts/mcop/core.cc:1233)

void FlowSystem_stub::startObject(Object node)
{
	long methodID = _lookupMethodFast("method:0c00000073746172744f626a6563740005000000766f6964000200000001000000070000006f626a65637400050000006e6f646500");
	long requestID;
	Buffer *request, *result;
	request = Dispatcher::the()->createRequest(requestID,_objectID,methodID);
	writeObject(*request,node._base());
	request->patchLength();
	_connection->qSendBuffer(request);

	result = Dispatcher::the()->waitForResult(requestID,_connection);
	if(result) delete result;
}


kdelibs'FlowSystem_stub::stopObject() (./kdelibs/arts/mcop/core.cc:1247)

void FlowSystem_stub::stopObject(Object node)
{
	long methodID = _lookupMethodFast("method:0b00000073746f704f626a6563740005000000766f6964000200000001000000070000006f626a65637400050000006e6f646500");
	long requestID;
	Buffer *request, *result;
	request = Dispatcher::the()->createRequest(requestID,_objectID,methodID);
	writeObject(*request,node._base());
	request->patchLength();
	_connection->qSendBuffer(request);

	result = Dispatcher::the()->waitForResult(requestID,_connection);
	if(result) delete result;
}


kdelibs'FlowSystem_stub::connectObject() (./kdelibs/arts/mcop/core.cc:1261)

void FlowSystem_stub::connectObject(Object sourceObject, const std::string& sourcePort, Object destObject, const std::string& destPort)
{
	long methodID = _lookupMethodFast("method:0e000000636f6e6e6563744f626a6563740005000000766f6964000200000004000000070000006f626a656374000d000000736f757263654f626a6563740007000000737472696e67000b000000736f75726365506f727400070000006f626a656374000b000000646573744f626a6563740007000000737472696e67000900000064657374506f727400");
	long requestID;
	Buffer *request, *result;
	request = Dispatcher::the()->createRequest(requestID,_objectID,methodID);
	writeObject(*request,sourceObject._base());
	request->writeString(sourcePort);
	writeObject(*request,destObject._base());
	request->writeString(destPort);
	request->patchLength();
	_connection->qSendBuffer(request);

	result = Dispatcher::the()->waitForResult(requestID,_connection);
	if(result) delete result;
}


kdelibs'FlowSystem_stub::disconnectObject() (./kdelibs/arts/mcop/core.cc:1278)

void FlowSystem_stub::disconnectObject(Object sourceObject, const std::string& sourcePort, Object destObject, const std::string& destPort)
{
	long methodID = _lookupMethodFast("method:11000000646973636f6e6e6563744f626a6563740005000000766f6964000200000004000000070000006f626a656374000d000000736f757263654f626a6563740007000000737472696e67000b000000736f75726365506f727400070000006f626a656374000b000000646573744f626a6563740007000000737472696e67000900000064657374506f727400");
	long requestID;
	Buffer *request, *result;
	request = Dispatcher::the()->createRequest(requestID,_objectID,methodID);
	writeObject(*request,sourceObject._base());
	request->writeString(sourcePort);
	writeObject(*request,destObject._base());
	request->writeString(destPort);
	request->patchLength();
	_connection->qSendBuffer(request);

	result = Dispatcher::the()->waitForResult(requestID,_connection);
	if(result) delete result;
}


kdelibs'FlowSystem_stub::queryFlags() (./kdelibs/arts/mcop/core.cc:1295)

AttributeType FlowSystem_stub::queryFlags(Object node, const std::string& port)
{
	long methodID = _lookupMethodFast("method:0b0000007175657279466c616773000e00000041747472696275746554797065000200000002000000070000006f626a65637400050000006e6f64650007000000737472696e670005000000706f727400");
	long requestID;
	Buffer *request, *result;
	request = Dispatcher::the()->createRequest(requestID,_objectID,methodID);
	writeObject(*request,node._base());
	request->writeString(port);
	request->patchLength();
	_connection->qSendBuffer(request);

	result = Dispatcher::the()->waitForResult(requestID,_connection);
	if(!result) return (AttributeType)0; // error occured
	AttributeType returnCode = (AttributeType)result->readLong();
	delete result;
	return returnCode;
}


kdelibs'FlowSystem_stub::createReceiver() (./kdelibs/arts/mcop/core.cc:1313)

FlowSystemReceiver FlowSystem_stub::createReceiver(Object destObject, const std::string& destPort, FlowSystemSender sender)
{
	long methodID = _lookupMethodFast("method:0f00000063726561746552656365697665720013000000466c6f7753797374656d5265636569766572000200000003000000070000006f626a656374000b000000646573744f626a6563740007000000737472696e67000900000064657374506f72740011000000466c6f7753797374656d53656e646572000700000073656e64657200");
	long requestID;
	Buffer *request, *result;
	request = Dispatcher::the()->createRequest(requestID,_objectID,methodID);
	writeObject(*request,destObject._base());
	request->writeString(destPort);
	writeObject(*request,sender._base());
	request->patchLength();
	_connection->qSendBuffer(request);

	result = Dispatcher::the()->waitForResult(requestID,_connection);
	if(!result) return 0; // error occured
	FlowSystemReceiver_base* returnCode;
	readObject(*result,returnCode);
	delete result;
	return FlowSystemReceiver(returnCode);
}

std::string FlowSystem_skel::_interfaceName()
{
	return "FlowSystem";
}

std::string FlowSystem_skel::_interfaceNameSkel()
{
	return "FlowSystem";
}

// startObject