XrdEc::sync_queue< Element > Struct Template Reference

#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

Constructor & Destructor Documentation

sync_queue()

template<typename Element >

XrdEc::sync_queue< Element >::sync_queue ( )

inline

Member Function Documentation

dequeue() [1/2]

template<typename Element >

Element XrdEc::sync_queue< Element >::dequeue ( )

inline

References XrdEc::sync_queue< Element >::cv, XrdEc::sync_queue< Element >::elements, XrdEc::sync_queue< Element >::interrupted, and XrdEc::sync_queue< Element >::mtx.

Referenced by XrdEc::StrmWriter::DequeueBuff().

dequeue() [2/2]

template<typename Element >

bool XrdEc::sync_queue< Element >::dequeue ( Element &  e )

inline

References XrdEc::sync_queue< Element >::elements, and XrdEc::sync_queue< Element >::mtx.

empty()

template<typename Element >

bool XrdEc::sync_queue< Element >::empty ( )

inline

References XrdEc::sync_queue< Element >::elements, and XrdEc::sync_queue< Element >::mtx.

enqueue()

template<typename Element >

void XrdEc::sync_queue< Element >::enqueue ( Element &&  element )

inline

References XrdEc::sync_queue< Element >::cv, XrdEc::sync_queue< Element >::elements, and XrdEc::sync_queue< Element >::mtx.

Referenced by XrdEc::StrmWriter::EnqueueBuff().

interrupt()

template<typename Element >

void XrdEc::sync_queue< Element >::interrupt ( )

inline

References XrdEc::sync_queue< Element >::cv, and XrdEc::sync_queue< Element >::interrupted.

Referenced by XrdEc::StrmWriter::~StrmWriter().

Member Data Documentation

cv

template<typename Element >

std::condition_variable XrdEc::sync_queue< Element >::cv

private

Referenced by XrdEc::sync_queue< Element >::dequeue(), XrdEc::sync_queue< Element >::enqueue(), and XrdEc::sync_queue< Element >::interrupt().

elements

template<typename Element >

std::queue<Element> XrdEc::sync_queue< Element >::elements

private

Referenced by XrdEc::sync_queue< Element >::dequeue(), XrdEc::sync_queue< Element >::dequeue(), XrdEc::sync_queue< Element >::empty(), and XrdEc::sync_queue< Element >::enqueue().

interrupted

template<typename Element >

std::atomic<bool> XrdEc::sync_queue< Element >::interrupted

private

Referenced by XrdEc::sync_queue< Element >::dequeue(), and XrdEc::sync_queue< Element >::interrupt().

mtx

template<typename Element >

std::mutex XrdEc::sync_queue< Element >::mtx

private

Referenced by XrdEc::sync_queue< Element >::dequeue(), XrdEc::sync_queue< Element >::dequeue(), XrdEc::sync_queue< Element >::empty(), and XrdEc::sync_queue< Element >::enqueue().

---

The documentation for this struct was generated from the following file:

• XrdEcUtilities.hh