19 #ifndef __XRD_CL_IN_QUEUE_HH__
20 #define __XRD_CL_IN_QUEUE_HH__
96 bool DiscardMessage(
Message& msg, uint16_t& sid)
const;
98 typedef std::pair<MsgHandler *, time_t> HandlerAndExpire;
99 typedef std::map<uint16_t, HandlerAndExpire> HandlerMap;
100 HandlerMap pHandlers;
A synchronize queue for incoming data.
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.
MsgHandler * GetHandlerForMessage(std::shared_ptr< Message > &msg, time_t &expires, uint16_t &action)
void AddMessageHandler(MsgHandler *handler, time_t expires, bool &rmMsg)
The message representation used throughout the system.
StreamEvent
Events that may have occurred to the stream.