XRootD
Loading...
Searching...
No Matches
XrdCephBuffer::CephBufSfsAio Class Reference

#include <CephIOAdapterAIORaw.hh>

+ Inheritance diagram for XrdCephBuffer::CephBufSfsAio:
+ Collaboration diagram for XrdCephBuffer::CephBufSfsAio:

Public Member Functions

 CephBufSfsAio ()
 
virtual void doneRead () override
 
virtual void doneWrite () override
 
bool isDone ()
 
virtual void Recycle () override
 
- Public Member Functions inherited from XrdSfsAio
 XrdSfsAio ()
 
virtual ~XrdSfsAio ()
 

Public Attributes

std::condition_variable m_condVar
 
std::unique_lock< std::mutex > m_lock
 
std::mutex m_mutex
 
- Public Attributes inherited from XrdSfsAio
uint32_t * cksVec
 
ssize_t Result
 
struct aiocb sfsAio
 
const char * TIdent
 

Protected Attributes

bool m_dataOpDone {false}
 

Detailed Description

Definition at line 28 of file CephIOAdapterAIORaw.hh.

Constructor & Destructor Documentation

◆ CephBufSfsAio()

CephBufSfsAio::CephBufSfsAio ( )

Definition at line 34 of file CephIOAdapterAIORaw.cc.

35{
36}
std::unique_lock< std::mutex > m_lock

References m_lock, and m_mutex.

Member Function Documentation

◆ doneRead()

void CephBufSfsAio::doneRead ( )
overridevirtual

Implements XrdSfsAio.

Definition at line 38 of file CephIOAdapterAIORaw.cc.

39{
40 //BUFLOG("DoneRead");
41 m_dataOpDone = true;
42 m_lock.unlock();
43 m_condVar.notify_all();
44}
std::condition_variable m_condVar

References m_condVar, m_dataOpDone, and m_lock.

◆ doneWrite()

void CephBufSfsAio::doneWrite ( )
overridevirtual

Implements XrdSfsAio.

Definition at line 46 of file CephIOAdapterAIORaw.cc.

47{
48 //BUFLOG("DoneWrite");
49 m_dataOpDone = true;
50 m_lock.unlock();
51 m_condVar.notify_all();
52}

References m_condVar, m_dataOpDone, and m_lock.

◆ isDone()

bool XrdCephBuffer::CephBufSfsAio::isDone ( )
inline

Definition at line 46 of file CephIOAdapterAIORaw.hh.

46{return m_dataOpDone;}

References m_dataOpDone.

Referenced by XrdCephBuffer::CephIOAdapterAIORaw::read(), and XrdCephBuffer::CephIOAdapterAIORaw::write().

+ Here is the caller graph for this function:

◆ Recycle()

virtual void XrdCephBuffer::CephBufSfsAio::Recycle ( )
inlineoverridevirtual

Implements XrdSfsAio.

Definition at line 42 of file CephIOAdapterAIORaw.hh.

42{};

Member Data Documentation

◆ m_condVar

std::condition_variable XrdCephBuffer::CephBufSfsAio::m_condVar

◆ m_dataOpDone

bool XrdCephBuffer::CephBufSfsAio::m_dataOpDone {false}
protected

Definition at line 49 of file CephIOAdapterAIORaw.hh.

49{false};

Referenced by doneRead(), doneWrite(), and isDone().

◆ m_lock

std::unique_lock<std::mutex> XrdCephBuffer::CephBufSfsAio::m_lock

◆ m_mutex

std::mutex XrdCephBuffer::CephBufSfsAio::m_mutex

Definition at line 43 of file CephIOAdapterAIORaw.hh.

Referenced by CephBufSfsAio().


The documentation for this class was generated from the following files: