Go to the documentation of this file.
19 #ifndef __XRD_CL_POST_MASTER_HH__
20 #define __XRD_CL_POST_MASTER_HH__
233 #endif // __XRD_CL_POST_MASTER_HH__
TaskManager * pTaskManager
Definition: XrdClPostMaster.hh:224
void SetOnConnectHandler(const URL &url, Job *onConnJob)
Set the on-connect handler for data streams.
Message status handler.
Definition: XrdClPostMasterInterfaces.hh:168
Definition: XrdSysPthread.hh:166
Status ForceDisconnect(const URL &url)
Shut down a channel.
bool Initialize()
Initializer.
Channel * GetChannel(const URL &url)
JobManager * pJobManager
Definition: XrdClPostMaster.hh:229
virtual ~PostMaster()
Destructor.
Interface for socket pollers.
Definition: XrdClPoller.hh:87
Status Send(const URL &url, Message *msg, OutgoingMsgHandler *handler, bool stateful, time_t expires)
std::map< std::string, Channel * > ChannelMap
Definition: XrdClPostMaster.hh:222
Poller * pPoller
Definition: XrdClPostMaster.hh:223
bool pInitialized
Definition: XrdClPostMaster.hh:228
A synchronized queue.
Definition: XrdClJobManager.hh:51
Definition: XrdSysPthread.hh:296
uint16_t NbConnectedStrm(const URL &url)
Get the number of connected data streams.
Status RemoveEventHandler(const URL &url, ChannelEventHandler *handler)
Remove a channel event handler.
The message representation used throughout the system.
Definition: XrdClMessage.hh:30
Status Redirect(const URL &url, Message *msg, IncomingMsgHandler *handler)
Status Receive(const URL &url, Message *&msg, MessageFilter *filter, time_t expires)
bool Finalize()
Finalizer.
Status QueryTransport(const URL &url, uint16_t query, AnyObject &result)
XrdSysMutex pChannelMapMutex
Definition: XrdClPostMaster.hh:226
bool Reinitialize()
Reinitialize after fork.
Definition: XrdClTaskManager.hh:76
Message filter.
Definition: XrdClPostMasterInterfaces.hh:47
bool Stop()
Stop the postmaster.
Message handler.
Definition: XrdClPostMasterInterfaces.hh:69
A communication channel between the client and the server.
Definition: XrdClChannel.hh:49
XrdSysRWLock pDisconnectLock
Definition: XrdClPostMaster.hh:227
Status Send(const URL &url, Message *msg, bool stateful, time_t expires)
Definition: XrdClAnyObject.hh:26
Status RegisterEventHandler(const URL &url, ChannelEventHandler *handler)
Register channel event handler.
Status Receive(const URL &url, IncomingMsgHandler *handler, time_t expires)
TaskManager * GetTaskManager()
Get the task manager object user by the post master.
Definition: XrdClPostMaster.hh:190
Procedure execution status.
Definition: XrdClStatus.hh:110
URL representation.
Definition: XrdClURL.hh:31
Interface for a job to be run by the job manager.
Definition: XrdClJobManager.hh:34
ChannelMap pChannelMap
Definition: XrdClPostMaster.hh:225
bool Start()
Start the post master.
Channel event handler.
Definition: XrdClPostMasterInterfaces.hh:221
JobManager * GetJobManager()
Get the job manager object user by the post master.
Definition: XrdClPostMaster.hh:198
Definition: XrdClAnyObject.hh:33
A hub for dispatching and receiving messages.
Definition: XrdClPostMaster.hh:45