19 #ifndef __XRD_CL_IN_QUEUE_HH__
20 #define __XRD_CL_IN_QUEUE_HH__
42 bool AddMessage( std::shared_ptr<Message> msg );
105 typedef std::map<uint16_t, std::shared_ptr<Message>>
MessageMap;
112 #endif // __XRD_CL_IN_QUEUE_HH__
Definition: XrdSysPthread.hh:241
The message representation used throughout the system.
Definition: XrdClMessage.hh:29
bool DiscardMessage(Message &msg, uint16_t &sid) const
void AddMessageHandler(MsgHandler *handler, time_t expires, bool &rmMsg)
std::pair< MsgHandler *, time_t > HandlerAndExpire
Definition: XrdClInQueue.hh:103
Message handler.
Definition: XrdClPostMasterInterfaces.hh:50
void ReportStreamEvent(MsgHandler::StreamEvent event, XRootDStatus status)
Report an event to the handlers.
StreamEvent
Events that may have occurred to the stream.
Definition: XrdClPostMasterInterfaces.hh:78
void ReportTimeout(time_t now=0)
Timeout handlers.
HandlerMap pHandlers
Definition: XrdClInQueue.hh:107
MessageMap pMessages
Definition: XrdClInQueue.hh:106
bool AddMessage(std::shared_ptr< Message > msg)
Add a fully reconstructed message to the queue.
Request status.
Definition: XrdClXRootDResponses.hh:218
A synchronize queue for incoming data.
Definition: XrdClInQueue.hh:36
MsgHandler * GetHandlerForMessage(std::shared_ptr< Message > &msg, time_t &expires, uint16_t &action)
void RemoveMessageHandler(MsgHandler *handler)
Remove a listener.
std::map< uint16_t, HandlerAndExpire > HandlerMap
Definition: XrdClInQueue.hh:104
std::map< uint16_t, std::shared_ptr< Message > > MessageMap
Definition: XrdClInQueue.hh:105
XrdSysRecMutex pMutex
Definition: XrdClInQueue.hh:108
void ReAddMessageHandler(MsgHandler *handler, time_t expires)
Re-insert the handler without scanning the cached messages.