19 #ifndef __XRD_CL_OUT_QUEUE_HH__
20 #define __XRD_CL_OUT_QUEUE_HH__
31 class OutgoingMsgHandler;
142 msg( m ), handler( h ), expires( r ), stateful( s ) {}
157 #endif // __XRD_CL_OUT_QUEUE_HH__
void Report(Status status)
Report status to all the handlers.
void PushBack(Message *msg, OutgoingMsgHandler *handler, time_t expires, bool stateful)
void PushFront(Message *msg, OutgoingMsgHandler *handler, time_t expires, bool stateful)
Message * PopMessage(OutgoingMsgHandler *&handler, time_t &expires, bool &stateful)
bool stateful
Definition: XrdClOutQueue.hh:147
std::list< MsgHelper > MessageList
Definition: XrdClOutQueue.hh:150
The message representation used throughout the system.
Definition: XrdClMessage.hh:29
void GrabItems(OutQueue &queue)
time_t expires
Definition: XrdClOutQueue.hh:146
Procedure execution status.
Definition: XrdClStatus.hh:109
XrdSysMutex pMutex
Definition: XrdClOutQueue.hh:152
Message * msg
Definition: XrdClOutQueue.hh:144
Definition: XrdSysPthread.hh:165
void GrabExpired(OutQueue &queue, time_t exp=0)
uint64_t GetSizeStateless() const
Return the size of the queue counting only the stateless messages.
void GrabStateful(OutQueue &queue)
OutgoingMsgHandler * handler
Definition: XrdClOutQueue.hh:145
A synchronized queue for the outgoing data.
Definition: XrdClOutQueue.hh:36
MessageList pMessages
Definition: XrdClOutQueue.hh:151
uint64_t GetSize() const
Definition: XrdClOutQueue.hh:101
Definition: XrdClOutQueue.hh:139
bool IsEmpty() const
Check if the queue is empty.
Definition: XrdClOutQueue.hh:93
Message status handler.
Definition: XrdClPostMasterInterfaces.hh:167
void PopFront()
Remove a message from the front.
MsgHelper(Message *m, OutgoingMsgHandler *h, time_t r, bool s)
Definition: XrdClOutQueue.hh:141