Go to the documentation of this file.
19 #ifndef __XRD_CL_IN_QUEUE_HH__
20 #define __XRD_CL_IN_QUEUE_HH__
109 #endif // __XRD_CL_IN_QUEUE_HH__
void AddMessageHandler(IncomingMsgHandler *handler, time_t expires)
StreamEvent
Events that may have occurred to the stream.
Definition: XrdClPostMasterInterfaces.hh:99
The message representation used throughout the system.
Definition: XrdClMessage.hh:30
bool AddMessage(Message *msg)
Add a fully reconstructed message to the queue.
void ReAddMessageHandler(IncomingMsgHandler *handler, time_t expires)
Re-insert the handler without scanning the cached messages.
Request status.
Definition: XrdClXRootDResponses.hh:215
IncomingMsgHandler * GetHandlerForMessage(Message *msg, time_t &expires, uint16_t &action)
A synchronize queue for incoming data.
Definition: XrdClInQueue.hh:36
Definition: XrdSysPthread.hh:242
std::map< uint16_t, HandlerAndExpire > HandlerMap
Definition: XrdClInQueue.hh:101
Message handler.
Definition: XrdClPostMasterInterfaces.hh:72
XrdSysRecMutex pMutex
Definition: XrdClInQueue.hh:105
Definition: XrdClAnyObject.hh:26
std::pair< IncomingMsgHandler *, time_t > HandlerAndExpire
Definition: XrdClInQueue.hh:100
void ReportTimeout(time_t now=0)
Timeout handlers.
void ReportStreamEvent(IncomingMsgHandler::StreamEvent event, XRootDStatus status)
Report an event to the handlers.
HandlerMap pHandlers
Definition: XrdClInQueue.hh:104
MessageMap pMessages
Definition: XrdClInQueue.hh:103
std::map< uint16_t, Message * > MessageMap
Definition: XrdClInQueue.hh:102
void RemoveMessageHandler(IncomingMsgHandler *handler)
Remove a listener.
bool DiscardMessage(Message *msg, uint16_t &sid) const