xrootd
|
A synchronized queue for the outgoing data. More...
#include <XrdClOutQueue.hh>
Classes | |
struct | MsgHelper |
Public Member Functions | |
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) |
void | PopFront () |
Remove a message from the front. More... | |
void | Report (XRootDStatus status) |
Report status to all the handlers. More... | |
bool | IsEmpty () const |
Check if the queue is empty. More... | |
uint64_t | GetSize () const |
uint64_t | GetSizeStateless () const |
Return the size of the queue counting only the stateless messages. More... | |
void | GrabExpired (OutQueue &queue, time_t exp=0) |
void | GrabStateful (OutQueue &queue) |
void | GrabItems (OutQueue &queue) |
Private Types | |
typedef std::list< MsgHelper > | MessageList |
Private Attributes | |
MessageList | pMessages |
A synchronized queue for the outgoing data.
|
private |
|
inline |
References pMessages.
uint64_t XrdCl::OutQueue::GetSizeStateless | ( | ) | const |
Return the size of the queue counting only the stateless messages.
void XrdCl::OutQueue::GrabExpired | ( | OutQueue & | queue, |
time_t | exp = 0 |
||
) |
Remove all the expired messages from the queue and put them in this one
queue | queue to take the message from |
exp | expiration timestamp |
void XrdCl::OutQueue::GrabItems | ( | OutQueue & | queue | ) |
Take all the items from the queue and put them in this one
queue | queue to take the message |
void XrdCl::OutQueue::GrabStateful | ( | OutQueue & | queue | ) |
Remove all the stateful messages from the queue and put them in this one
queue | the queue to take the messages from |
|
inline |
Check if the queue is empty.
References pMessages.
void XrdCl::OutQueue::PopFront | ( | ) |
Remove a message from the front.
Message* XrdCl::OutQueue::PopMessage | ( | OutgoingMsgHandler *& | handler, |
time_t & | expires, | ||
bool & | stateful | ||
) |
Pop a message from the front of the queue
void XrdCl::OutQueue::PushBack | ( | Message * | msg, |
OutgoingMsgHandler * | handler, | ||
time_t | expires, | ||
bool | stateful | ||
) |
Add a message to the back the queue
msg | message to be sent |
handler | handler to be notified about the status of the operation |
expires | timeout |
stateful | if true a disconnection will cause an error and removing from the queue, otherwise sending wil be re-attempted |
void XrdCl::OutQueue::PushFront | ( | Message * | msg, |
OutgoingMsgHandler * | handler, | ||
time_t | expires, | ||
bool | stateful | ||
) |
Add a message to the front the queue
msg | message to be sent |
handler | handler to be notified about the status of the operation |
expires | timeout |
stateful | if true a disconnection will cause an error and removing from the queue, otherwise sending wil be re-attempted |
void XrdCl::OutQueue::Report | ( | XRootDStatus | status | ) |
Report status to all the handlers.
|
private |