};
template <typename ImageCtxT>
-class C_CacheRead : public Context {
+class C_ObjectCacheRead : public Context {
public:
- explicit C_CacheRead(ImageCtxT &ictx, AioObjectRead<ImageCtxT> *req)
+ explicit C_ObjectCacheRead(ImageCtxT &ictx, AioObjectRead<ImageCtxT> *req)
: m_image_ctx(ictx), m_req(req), m_enqueued(false) {}
virtual void complete(int r) {
req_comp->set_req(req);
if (image_ctx.object_cacher) {
- C_CacheRead<I> *cache_comp = new C_CacheRead<I>(image_ctx, req);
+ C_ObjectCacheRead<I> *cache_comp = new C_ObjectCacheRead<I>(image_ctx,
+ req);
image_ctx.aio_read_from_cache(extent.oid, extent.objectno,
&req->data(), extent.length,
extent.offset, cache_comp, m_op_flags);
if (!object_extents.empty()) {
uint64_t journal_tid = 0;
aio_comp->set_request_count(
- object_extents.size() + get_cache_request_count(journaling));
+ object_extents.size() + get_object_cache_request_count(journaling));
AioObjectRequests requests;
send_object_requests(object_extents, snapc,
}
if (image_ctx.object_cacher != NULL) {
- send_cache_requests(object_extents, journal_tid);
+ send_object_cache_requests(object_extents, journal_tid);
}
} else {
// no IO to perform -- fire completion
}
template <typename I>
-void AioImageWrite<I>::send_cache_requests(const ObjectExtents &object_extents,
- uint64_t journal_tid) {
+void AioImageWrite<I>::send_object_cache_requests(const ObjectExtents &object_extents,
+ uint64_t journal_tid) {
I &image_ctx = this->m_image_ctx;
for (auto p = object_extents.begin(); p != object_extents.end(); ++p) {
const ObjectExtent &object_extent = *p;
}
template <typename I>
-uint32_t AioImageDiscard<I>::get_cache_request_count(bool journaling) const {
+uint32_t AioImageDiscard<I>::get_object_cache_request_count(bool journaling) const {
// extra completion request is required for tracking journal commit
I &image_ctx = this->m_image_ctx;
return (image_ctx.object_cacher != nullptr && journaling ? 1 : 0);
}
template <typename I>
-void AioImageDiscard<I>::send_cache_requests(const ObjectExtents &object_extents,
- uint64_t journal_tid) {
+void AioImageDiscard<I>::send_object_cache_requests(const ObjectExtents &object_extents,
+ uint64_t journal_tid) {
I &image_ctx = this->m_image_ctx;
if (journal_tid == 0) {
Mutex::Locker cache_locker(image_ctx.cache_lock);
virtual void prune_object_extents(ObjectExtents &object_extents) {
}
- virtual uint32_t get_cache_request_count(bool journaling) const {
+ virtual uint32_t get_object_cache_request_count(bool journaling) const {
return 0;
}
- virtual void send_cache_requests(const ObjectExtents &object_extents,
- uint64_t journal_tid) = 0;
+ virtual void send_object_cache_requests(const ObjectExtents &object_extents,
+ uint64_t journal_tid) = 0;
virtual void send_object_requests(const ObjectExtents &object_extents,
const ::SnapContext &snapc,
virtual void send_image_cache_request() override;
- virtual void send_cache_requests(const ObjectExtents &object_extents,
- uint64_t journal_tid);
+ virtual void send_object_cache_requests(const ObjectExtents &object_extents,
+ uint64_t journal_tid);
virtual void send_object_requests(const ObjectExtents &object_extents,
const ::SnapContext &snapc,
virtual void send_image_cache_request() override;
- virtual uint32_t get_cache_request_count(bool journaling) const override;
- virtual void send_cache_requests(const ObjectExtents &object_extents,
- uint64_t journal_tid);
+ virtual uint32_t get_object_cache_request_count(bool journaling) const override;
+ virtual void send_object_cache_requests(const ObjectExtents &object_extents,
+ uint64_t journal_tid);
virtual AioObjectRequestHandle *create_object_request(
const ObjectExtent &object_extent, const ::SnapContext &snapc,