19#ifndef __XRD_CL_IN_QUEUE_HH__
20#define __XRD_CL_IN_QUEUE_HH__
A synchronize queue for incoming data.
Definition XrdClInQueue.hh:37
void ReportTimeout(time_t now=0)
Timeout handlers.
void RemoveMessageHandler(MsgHandler *handler)
Remove a listener.
void ReAddMessageHandler(MsgHandler *handler, time_t expires)
Re-insert the handler without scanning the cached messages.
void ReportStreamEvent(MsgHandler::StreamEvent event, XRootDStatus status)
Report an event to the handlers.
std::map< uint16_t, HandlerAndExpire > HandlerMap
Definition XrdClInQueue.hh:99
MsgHandler * GetHandlerForMessage(std::shared_ptr< Message > &msg, time_t &expires, uint16_t &action)
std::pair< MsgHandler *, time_t > HandlerAndExpire
Definition XrdClInQueue.hh:98
bool DiscardMessage(Message &msg, uint16_t &sid) const
XrdSysRecMutex pMutex
Definition XrdClInQueue.hh:101
void AddMessageHandler(MsgHandler *handler, time_t expires, bool &rmMsg)
HandlerMap pHandlers
Definition XrdClInQueue.hh:100
The message representation used throughout the system.
Definition XrdClMessage.hh:30
Message handler.
Definition XrdClPostMasterInterfaces.hh:51
StreamEvent
Events that may have occurred to the stream.
Definition XrdClPostMasterInterfaces.hh:79
Request status.
Definition XrdClXRootDResponses.hh:219
Definition XrdSysPthread.hh:242
Definition XrdClAction.hh:34