RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-21 18:17:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

librbd: C_ImageCacheRead bridge from Context to AioCompletion

Browse Source 
Signed-off-by: Jason Dillaman <dillaman@redhat.com>
This commit is contained in:
Jason Dillaman 2016-08-26 11:04:03 -04:00
parent bc0921870b
commit 6beb353c1a
1 changed files with 38 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/librbd/AioImageRequest.cc
View File

@ -118,6 +118,44 @@ private:
AioObjectRead<ImageCtxT> *m_req;
};
template <typename ImageCtxT>
class C_ImageCacheRead : public C_AioRequest {
public:
typedef std::vector<std::pair<uint64_t,uint64_t> > Extents;
C_ImageCacheRead(AioCompletion *completion, const Extents &image_extents)
: C_AioRequest(completion), m_image_extents(image_extents) {
}
inline bufferlist &get_data() {
return m_bl;
}
protected:
virtual void finish(int r) {
CephContext *cct = m_completion->ictx->cct;
ldout(cct, 10) << "C_ImageCacheRead::finish() " << this << ": r=" << r
<< dendl;
if (r >= 0) {
size_t length = 0;
for (auto &image_extent : m_image_extents) {
length += image_extent.second;
}
assert(length == m_bl.length());
m_completion->lock.Lock();
m_completion->destriper.add_partial_result(cct, m_bl, m_image_extents);
m_completion->lock.Unlock();
r = length;
}
C_AioRequest::finish(r);
}
private:
bufferlist m_bl;
Extents m_image_extents;
};
template <typename ImageCtxT>
class C_ObjectCacheRead : public Context {
public: