A hub for dispatching and receiving messages.
More...
#include <XrdClPostMaster.hh>
|
| PostMaster () |
| Constructor. More...
|
|
virtual | ~PostMaster () |
| Destructor. More...
|
|
bool | Initialize () |
| Initializer. More...
|
|
bool | Finalize () |
| Finalizer. More...
|
|
bool | Start () |
| Start the post master. More...
|
|
bool | Stop () |
| Stop the postmaster. More...
|
|
bool | Reinitialize () |
| Reinitialize after fork. More...
|
|
Status | Send (const URL &url, Message *msg, bool stateful, time_t expires) |
|
Status | Send (const URL &url, Message *msg, OutgoingMsgHandler *handler, bool stateful, time_t expires) |
|
Status | Receive (const URL &url, Message *&msg, MessageFilter *filter, time_t expires) |
|
Status | Receive (const URL &url, IncomingMsgHandler *handler, time_t expires) |
|
Status | QueryTransport (const URL &url, uint16_t query, AnyObject &result) |
|
Status | RegisterEventHandler (const URL &url, ChannelEventHandler *handler) |
| Register channel event handler. More...
|
|
Status | RemoveEventHandler (const URL &url, ChannelEventHandler *handler) |
| Remove a channel event handler. More...
|
|
TaskManager * | GetTaskManager () |
| Get the task manager object user by the post master. More...
|
|
JobManager * | GetJobManager () |
| Get the job manager object user by the post master. More...
|
|
|
typedef std::map< std::string, Channel * > | ChannelMap |
|
A hub for dispatching and receiving messages.
◆ ChannelMap
◆ PostMaster()
XrdCl::PostMaster::PostMaster |
( |
| ) |
|
◆ ~PostMaster()
virtual XrdCl::PostMaster::~PostMaster |
( |
| ) |
|
|
virtual |
◆ Finalize()
bool XrdCl::PostMaster::Finalize |
( |
| ) |
|
◆ GetChannel()
Channel* XrdCl::PostMaster::GetChannel |
( |
const URL & |
url | ) |
|
|
private |
◆ GetJobManager()
JobManager* XrdCl::PostMaster::GetJobManager |
( |
| ) |
|
|
inline |
◆ GetTaskManager()
TaskManager* XrdCl::PostMaster::GetTaskManager |
( |
| ) |
|
|
inline |
Get the task manager object user by the post master.
References pTaskManager.
◆ Initialize()
bool XrdCl::PostMaster::Initialize |
( |
| ) |
|
◆ QueryTransport()
Status XrdCl::PostMaster::QueryTransport |
( |
const URL & |
url, |
|
|
uint16_t |
query, |
|
|
AnyObject & |
result |
|
) |
| |
Query the transport handler for a given URL
- Parameters
-
url | the channel to be queried |
query | the query as defined in the TransportQuery struct or others that may be recognized by the protocol transport |
result | the result of the query |
- Returns
- status of the query
◆ Receive() [1/2]
Synchronously receive a message - blocks until a message matching a filter is found in the incoming queue or the timeout passes
- Parameters
-
url | sender of the message |
msg | reference to a message pointer, the pointer will point to the received message |
filter | filter object defining what to look for |
expires | expiration timestamp |
- Returns
- success when the message has been received successfully, failure otherwise
◆ Receive() [2/2]
Listen to incoming messages, the listener is notified when a new message arrives and when the timeout passes
- Parameters
-
url | sender of the message |
handler | handler to be notified about new messages |
expires | expiration timestamp |
- Returns
- success when the listener has been inserted correctly
◆ RegisterEventHandler()
Register channel event handler.
◆ Reinitialize()
bool XrdCl::PostMaster::Reinitialize |
( |
| ) |
|
◆ RemoveEventHandler()
Remove a channel event handler.
◆ Send() [1/2]
Status XrdCl::PostMaster::Send |
( |
const URL & |
url, |
|
|
Message * |
msg, |
|
|
bool |
stateful, |
|
|
time_t |
expires |
|
) |
| |
Send a message synchronously - synchronously means that it will block until the message is written to a socket
DEADLOCK WARNING: no lock should be taken while calling this method that are used in the callback as well.
- Parameters
-
url | recipient of the message |
msg | message to be sent |
stateful | physical stream disconnection causes an error |
expires | unix timestamp after which a failure should be reported if sending was unsuccessful |
- Returns
- success if the message has been pushed through the wire, failure otherwise
◆ Send() [2/2]
Send the message asynchronously - the message is inserted into the send queue and a listener is called when the message is succesfsully pushed through the wire or when the timeout elapses
DEADLOCK WARNING: no lock should be taken while calling this method that are used in the callback as well.
- Parameters
-
url | recipient of the message |
msg | message to be sent |
expires | unix timestamp after which a failure is reported to the handler |
handler | handler will be notified about the status |
stateful | physical stream disconnection causes an error |
- Returns
- success if the message was successfully inserted into the send queues, failure otherwise
◆ Start()
bool XrdCl::PostMaster::Start |
( |
| ) |
|
◆ Stop()
bool XrdCl::PostMaster::Stop |
( |
| ) |
|
◆ pChannelMap
◆ pChannelMapMutex
◆ pInitialized
bool XrdCl::PostMaster::pInitialized |
|
private |
◆ pJobManager
JobManager* XrdCl::PostMaster::pJobManager |
|
private |
◆ pPoller
Poller* XrdCl::PostMaster::pPoller |
|
private |
◆ pTaskManager
TaskManager* XrdCl::PostMaster::pTaskManager |
|
private |
The documentation for this class was generated from the following file: