summaryrefslogtreecommitdiffstats
path: root/src/librbd/cache/pwl/rwl/Request.h
blob: 0a5c610d6912536b30b1a941bb7cdb6d2718c86a (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab

#ifndef CEPH_LIBRBD_CACHE_RWL_REQUEST_H
#define CEPH_LIBRBD_CACHE_RWL_REQUEST_H

#include "librbd/cache/pwl/Request.h"

namespace librbd {
class BlockGuardCell;

namespace cache {
namespace pwl {
namespace rwl {

template <typename T>
class C_WriteRequest : public pwl::C_WriteRequest<T> {
public:
  C_WriteRequest(
      T &pwl, const utime_t arrived, io::Extents &&image_extents,
      bufferlist&& cmp_bl, bufferlist&& bl, uint64_t *mismatch_offset,
      const int fadvise_flags, ceph::mutex &lock,
      PerfCounters *perfcounter, Context *user_req)
    : pwl::C_WriteRequest<T>(
        pwl, arrived, std::move(image_extents), std::move(cmp_bl),
        std::move(bl), mismatch_offset, fadvise_flags,
        lock, perfcounter, user_req) {}

  C_WriteRequest(
      T &pwl, const utime_t arrived, io::Extents &&image_extents,
      bufferlist&& bl, const int fadvise_flags, ceph::mutex &lock,
      PerfCounters *perfcounter, Context *user_req)
    : pwl::C_WriteRequest<T>(
        pwl, arrived, std::move(image_extents), std::move(bl),
        fadvise_flags, lock, perfcounter, user_req) {}
protected:
  //Plain writes will allocate one buffer per request extent
  void setup_buffer_resources(
      uint64_t *bytes_cached, uint64_t *bytes_dirtied,
      uint64_t *bytes_allocated, uint64_t *number_lanes,
      uint64_t *number_log_entries,
      uint64_t *number_unpublished_reserves) override;
};

template <typename T>
class C_CompAndWriteRequest : public C_WriteRequest<T> {
public:
  C_CompAndWriteRequest(
      T &pwl, const utime_t arrived, io::Extents &&image_extents,
      bufferlist&& cmp_bl, bufferlist&& bl, uint64_t *mismatch_offset,
      const int fadvise_flags, ceph::mutex &lock,
      PerfCounters *perfcounter, Context *user_req)
    : C_WriteRequest<T>(
        pwl, arrived, std::move(image_extents), std::move(cmp_bl),
        std::move(bl), mismatch_offset, fadvise_flags,
        lock, perfcounter, user_req) {}

  const char *get_name() const override {
    return "C_CompAndWriteRequest";
  }
  template <typename U>
  friend std::ostream &operator<<(std::ostream &os,
                                  const C_CompAndWriteRequest<U> &req);
};

template <typename T>
class C_WriteSameRequest : public pwl::C_WriteSameRequest<T> {
public:
  C_WriteSameRequest(
      T &pwl, const utime_t arrived, io::Extents &&image_extents,
      bufferlist&& bl, const int fadvise_flags, ceph::mutex &lock,
      PerfCounters *perfcounter, Context *user_req)
    : pwl::C_WriteSameRequest<T>(
        pwl, arrived, std::move(image_extents), std::move(bl), fadvise_flags,
        lock, perfcounter, user_req) {}

  void setup_buffer_resources(
      uint64_t *bytes_cached, uint64_t *bytes_dirtied,
      uint64_t *bytes_allocated, uint64_t *number_lanes,
      uint64_t *number_log_entries,
      uint64_t *number_unpublished_reserves) override;

};

} // namespace rwl
} // namespace pwl
} // namespace cache
} // namespace librbd

#endif // CEPH_LIBRBD_CACHE_RWL_REQUEST_H