XRootD
Public Member Functions | Public Attributes | Protected Attributes | List of all members
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.

34  : m_lock(m_mutex)
35 {
36 }
XrdCephBuffer::CephBufSfsAio::m_lock
std::unique_lock< std::mutex > m_lock
Definition: CephIOAdapterAIORaw.hh:44

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 }
XrdCephBuffer::CephBufSfsAio::m_condVar
std::condition_variable m_condVar
Definition: CephIOAdapterAIORaw.hh:45

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

Definition at line 45 of file CephIOAdapterAIORaw.hh.

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

◆ m_dataOpDone

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

Definition at line 49 of file CephIOAdapterAIORaw.hh.

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

◆ m_lock

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

Definition at line 44 of file CephIOAdapterAIORaw.hh.

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

◆ m_mutex

std::mutex XrdCephBuffer::CephBufSfsAio::m_mutex

Definition at line 43 of file CephIOAdapterAIORaw.hh.

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