xrootd
|
#include <XrdEcUtilities.hh>
Classes | |
struct | wait_interrupted |
Public Member Functions | |
sync_queue () | |
void | enqueue (Element &&element) |
Element | dequeue () |
bool | dequeue (Element &e) |
bool | empty () |
void | interrupt () |
Private Attributes | |
std::queue< Element > | elements |
std::mutex | mtx |
std::condition_variable | cv |
std::atomic< bool > | interrupted |
|
inline |
|
inline |
|
inline |
References XrdEc::sync_queue< Element >::elements, and XrdEc::sync_queue< Element >::mtx.
|
inline |
References XrdEc::sync_queue< Element >::elements, and XrdEc::sync_queue< Element >::mtx.
|
inline |
References XrdEc::sync_queue< Element >::cv, XrdEc::sync_queue< Element >::elements, and XrdEc::sync_queue< Element >::mtx.
Referenced by XrdEc::StrmWriter::EnqueueBuff().
|
inline |
References XrdEc::sync_queue< Element >::cv, and XrdEc::sync_queue< Element >::interrupted.
Referenced by XrdEc::StrmWriter::~StrmWriter().
|
private |
|
private |
|
private |
Referenced by XrdEc::sync_queue< Element >::dequeue(), and XrdEc::sync_queue< Element >::interrupt().
|
private |