1 #ifndef __CEPH_IO_ADAPTER_AIORAW_HH__
2 #define __CEPH_IO_ADAPTER_AIORAW_HH__
12 #include <sys/types.h>
20 #include <condition_variable>
74 virtual ssize_t
write(off64_t offset,
size_t count)
override;
86 virtual ssize_t
read(off64_t offset,
size_t count)
override;
93 std::atomic< long> m_stats_read_timer{0}, m_stats_write_timer{0};
94 std::atomic< long> m_stats_read_bytes{0}, m_stats_write_bytes{0};
95 std::atomic< long> m_stats_read_req{0}, m_stats_write_req{0};
96 long m_stats_read_longest{0}, m_stats_write_longest{0};
virtual void doneWrite() override
virtual void Recycle() override
std::unique_lock< std::mutex > m_lock
std::condition_variable m_condVar
virtual void doneRead() override
Implements a non-async read and write to ceph via aio ceph_posix calls Using the standard ceph_posix_...
virtual ssize_t read(off64_t offset, size_t count) override
Issue a ceph_posix_pread to read to the buffer data from file offset and len count....
virtual ssize_t write(off64_t offset, size_t count) override
Take the data in the buffer and write to ceph at given offset Issues a ceph_posix_pwrite for data in ...
virtual ~CephIOAdapterAIORaw()
CephIOAdapterAIORaw(IXrdCephBufferData *bufferdata, int fd)
Manage the actual IO operations that read and write the data into Ceph via librados striper....
Interface to the Buffer's physical representation. Allow an interface to encapsulate the requirements...
is a simple implementation of IXrdCephBufferData using std::vector<char> representation for the buffe...