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

template<typename Element>

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

inline

Member Function Documentation

template<typename Element>

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

inline

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

template<typename Element>

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

inline

template<typename Element>

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

inline

template<typename Element>

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

inline

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

template<typename Element>

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

inline

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

Member Data Documentation

template<typename Element>

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

private

Referenced by XrdEc::sync_queue< std::future< WrtBuff * > >::dequeue(), XrdEc::sync_queue< std::future< WrtBuff * > >::enqueue(), and XrdEc::sync_queue< std::future< WrtBuff * > >::interrupt().

template<typename Element>

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

private

Referenced by XrdEc::sync_queue< std::future< WrtBuff * > >::dequeue(), XrdEc::sync_queue< std::future< WrtBuff * > >::empty(), and XrdEc::sync_queue< std::future< WrtBuff * > >::enqueue().

template<typename Element>

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

private

Referenced by XrdEc::sync_queue< std::future< WrtBuff * > >::dequeue(), and XrdEc::sync_queue< std::future< WrtBuff * > >::interrupt().

template<typename Element>

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

private

Referenced by XrdEc::sync_queue< std::future< WrtBuff * > >::dequeue(), XrdEc::sync_queue< std::future< WrtBuff * > >::empty(), and XrdEc::sync_queue< std::future< WrtBuff * > >::enqueue().

---

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

• XrdEcUtilities.hh