19 #ifndef __XRD_CL_OUT_QUEUE_HH__
20 #define __XRD_CL_OUT_QUEUE_HH__
93 return pMessages.empty();
101 return pMessages.size();
154 typedef std::list<MsgHelper> MessageList;
155 MessageList pMessages;
The message representation used throughout the system.
A synchronized queue for the outgoing data.
void PushFront(Message *msg, MsgHandler *handler, time_t expires, bool stateful)
bool IsEmpty() const
Check if the queue is empty.
void GrabStateful(OutQueue &queue)
void PopFront()
Remove a message from the front.
void GrabExpired(OutQueue &queue, time_t exp=0)
void GrabItems(OutQueue &queue)
Message * PopMessage(MsgHandler *&handler, time_t &expires, bool &stateful)
Get a message from the front of the queue.
void PushBack(Message *msg, MsgHandler *handler, time_t expires, bool stateful)
void Report(XRootDStatus status)
Report status to all the handlers.
uint64_t GetSizeStateless() const
Return the size of the queue counting only the stateless messages.
MsgHelper(Message *m=nullptr, MsgHandler *h=nullptr, time_t r=0, bool s=false)