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 |
Referenced by XrdEc::StrmWriter::DequeueBuff().
|
inline |
|
inline |
|
inline |
Referenced by XrdEc::StrmWriter::EnqueueBuff().
|
inline |
Referenced by XrdEc::StrmWriter::~StrmWriter().
|
private |
|
private |
|
private |
|
private |