class Dispatcher

Public Types

• enum StartServer { noServer = 0, startUnixServer = 1, startTCPServer = 2, noAuthentication = 4 }

Public Methods

•  Dispatcher (IOManager *ioManager = 0, StartServer startServer = noServer)
•  ~Dispatcher ()
• inline IOManager * ioManager ()
• InterfaceRepo  interfaceRepo ()
• FlowSystem_impl * flowSystem ()
• GlobalComm  globalComm ()
• void  setFlowSystem (FlowSystem_impl *fs)
• void  refillRequestIDs ()
• Buffer * waitForResult (long requestID,Connection *connection)
• Buffer * createRequest (long& requestID, long objectID, long methodID)
• Buffer * createOnewayRequest (long objectID, long methodID)
• void  handle (Connection *conn, Buffer *buffer, long messageType)
• void  handleCorrupt (Connection *conn)
• long  addObject (Object_skel *object)
• void  removeObject (long objectID)
• void * connectObjectLocal (ObjectReference& reference, std::string interface)
• Connection * connectObjectRemote (ObjectReference& reference)
• std::string  objectToString (long objectID)
• bool  stringToObjectReference (ObjectReference& r, std::string s)
• void  run ()
• void  terminate ()
• void  initiateConnection (Connection *connection)
• void  handleConnectionClose (Connection *connection)
• Connection * activeConnection ()
• Connection * loopbackConnection ()
• DelayedReturn * delayReturn ()
• void  reloadTraderData ()

Public Static Methods

• static Dispatcher * the ()
• static void  lock ()
• static void  unlock ()
• static void  wakeUp ()

Protected Methods

• void  generateServerID ()
• Connection * connectUrl (const std::string& url)

Protected Members

• static Dispatcher *_instance
• Pool<Buffer> requestResultPool
• Pool<Object_skel> objectPool
• std::list<Connection *> connections
• std::string serverID
• bool deleteIOManagerOnExit
• TCPServer *tcpServer
• UnixServer *unixServer
• IOManager *_ioManager
• FlowSystem_impl *_flowSystem
• ObjectManager *objectManager
• ReferenceClean *referenceClean
• NotificationManager *notificationManager
• mcop_sighandler orig_sigpipe
• Connection *_activeConnection

Detailed Description

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

[protected]

connects to a given URL

Returns: a valid connection, or a 0 pointer on error

[static]

object registration

do not call manually, this is used by the Object_skel constructor to register itself

object deregistration

do not call manually, this is called by the Object_skel destructor as soon as the object is deleted

connects to a local object, returning a readily casted "interface" * if success, or NULL if this object is not local

connects to a remote object, establishing a connection if necessary

returns NULL if connecting fails or object isn't present or whatever else could go wrong

stringification of objects (only used by the object implementations, which in turn provide a _toString method)

destringification of objects (mainly used by the object implementations, which in turn provide a _fromString method)

main loop

this function quits the main loop (it must be running, of course) and causes the run() function to return.

Is called by the transport services as soon as a new connection is created - this will send authentication request, etc.

Is called by the Connection as soon as the connection goes down, which may happen due to a normal cause (client exits), and may happen if an error occurs as well (network down)

[static]

Locks the dispatcher. Whenever you want to do anything with any kind of aRts object, you will hold a lock on Arts::Dispatcher. There is only one exception to the rule, and that is: you don't have to lock the dispatcher when the lock is already held.

Generally, that is very often the case. Typical situations where you don't need to lock() the Dispatcher are:

• you receive a callback from the IOManager (timer or fd)
• you get call due to some MCOP request
• you are called from the NotificationManager
• you are called from the FlowSystem (calculateBlock)

[static]

Unlocks the dispatcher. Do this to release a lock you hold on the Arts::Dispatcher.

[static]

Wakes the dispatcher - normally, the dispatcher will go to sleep in it's event loop, when nothing is to be done. If you change things from another thread, like: add a new Timer, write something to a connection, and so on, the dispatcher will not notice it. To wake the dispatcher up, this call is provided.

- internal usage only -

this will return the Connection the last request came from

- internal usage only -

this will return a loopback Connection for sending requests to myself

- internal usage only -

this will cause a function to return from a request later

See also: DelayedReturn

reloads the trader data (do this if things have been added/changed there)