19 #ifndef __XRD_CL_OUT_QUEUE_HH__ 20 #define __XRD_CL_OUT_QUEUE_HH__ 159 #endif // __XRD_CL_OUT_QUEUE_HH__ void Reset()
Definition: XrdClOutQueue.hh:141
bool stateful
Definition: XrdClOutQueue.hh:149
std::list< MsgHelper > MessageList
Definition: XrdClOutQueue.hh:154
The message representation used throughout the system.
Definition: XrdClMessage.hh:29
void GrabItems(OutQueue &queue)
uint64_t GetSize() const
Definition: XrdClOutQueue.hh:99
Message handler.
Definition: XrdClPostMasterInterfaces.hh:49
void Report(XRootDStatus status)
Report status to all the handlers.
time_t expires
Definition: XrdClOutQueue.hh:148
Message * msg
Definition: XrdClOutQueue.hh:146
Message * PopMessage(MsgHandler *&handler, time_t &expires, bool &stateful)
void PushFront(Message *msg, MsgHandler *handler, time_t expires, bool stateful)
uint64_t GetSizeStateless() const
Return the size of the queue counting only the stateless messages.
void GrabExpired(OutQueue &queue, time_t exp=0)
void GrabStateful(OutQueue &queue)
Request status.
Definition: XrdClXRootDResponses.hh:218
Definition: XrdClAnyObject.hh:25
A synchronized queue for the outgoing data.
Definition: XrdClOutQueue.hh:34
MessageList pMessages
Definition: XrdClOutQueue.hh:155
MsgHandler * handler
Definition: XrdClOutQueue.hh:147
void PushBack(Message *msg, MsgHandler *handler, time_t expires, bool stateful)
Definition: XrdClOutQueue.hh:136
MsgHelper(Message *m=nullptr, MsgHandler *h=nullptr, time_t r=0, bool s=false)
Definition: XrdClOutQueue.hh:138
void PopFront()
Remove a message from the front.
bool IsEmpty() const
Check if the queue is empty.
Definition: XrdClOutQueue.hh:91