![]() |
XRootD
|
A synchronized queue for the outgoing data. More...
#include <XrdClOutQueue.hh>
Classes | |
struct | MsgHelper |
Public Member Functions | |
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 | GrabItems (OutQueue &queue) |
void | GrabStateful (OutQueue &queue) |
bool | IsEmpty () const |
Check if the queue is empty. More... | |
void | PopFront () |
Remove a message from the front. More... | |
Message * | PopMessage (MsgHandler *&handler, time_t &expires, bool &stateful) |
Get a message from the front of the queue. More... | |
void | PushBack (Message *msg, MsgHandler *handler, time_t expires, bool stateful) |
void | PushFront (Message *msg, MsgHandler *handler, time_t expires, bool stateful) |
void | Report (XRootDStatus status) |
Report status to all the handlers. More... | |
A synchronized queue for the outgoing data.
Definition at line 34 of file XrdClOutQueue.hh.
|
inline |
Definition at line 99 of file XrdClOutQueue.hh.
uint64_t XrdCl::OutQueue::GetSizeStateless | ( | ) | const |
Return the size of the queue counting only the stateless messages.
Definition at line 85 of file XrdClOutQueue.cc.
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 |
Definition at line 99 of file XrdClOutQueue.cc.
Referenced by XrdCl::Stream::Tick().
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 |
Definition at line 136 of file XrdClOutQueue.cc.
Referenced by XrdCl::Stream::ForceError().
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 |
Definition at line 118 of file XrdClOutQueue.cc.
Referenced by XrdCl::Stream::OnError().
|
inline |
Check if the queue is empty.
Definition at line 91 of file XrdClOutQueue.hh.
void XrdCl::OutQueue::PopFront | ( | ) |
Remove a message from the front.
Definition at line 67 of file XrdClOutQueue.cc.
Message * XrdCl::OutQueue::PopMessage | ( | MsgHandler *& | handler, |
time_t & | expires, | ||
bool & | stateful | ||
) |
Get a message from the front of the queue.
Pop a message from the front of the queue
Definition at line 49 of file XrdClOutQueue.cc.
References XrdCl::OutQueue::MsgHelper::expires, XrdCl::OutQueue::MsgHelper::handler, XrdCl::OutQueue::MsgHelper::msg, and XrdCl::OutQueue::MsgHelper::stateful.
void XrdCl::OutQueue::PushBack | ( | Message * | msg, |
MsgHandler * | 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 |
Definition at line 27 of file XrdClOutQueue.cc.
void XrdCl::OutQueue::PushFront | ( | Message * | msg, |
MsgHandler * | 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 |
Definition at line 38 of file XrdClOutQueue.cc.
void XrdCl::OutQueue::Report | ( | XRootDStatus | status | ) |
Report status to all the handlers.
Definition at line 75 of file XrdClOutQueue.cc.
Referenced by XrdCl::Stream::ForceError(), XrdCl::Stream::OnError(), and XrdCl::Stream::Tick().