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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#ifndef CEPH_LIBRBD_IMAGECTX_H
#define CEPH_LIBRBD_IMAGECTX_H
#include "include/types.h"
#include "include/rbd_types.h"
#include <inttypes.h>
#include <map>
#include <set>
#include <string>
#include <vector>
#include "include/buffer.h"
#include "include/rbd/librbd.hpp"
#include "common/Mutex.h"
#include "common/snap_types.h"
#include "osdc/ObjectCacher.h"
#include "cls/rbd/cls_rbd_client.h"
#include "LibrbdWriteback.h"
#include "SnapInfo.h"
#include "parent_types.h"
class CephContext;
class PerfCounters;
namespace librbd {
class WatchCtx;
struct ImageCtx {
CephContext *cct;
PerfCounters *perfcounter;
struct rbd_obj_header_ondisk header;
::SnapContext snapc;
std::vector<librados::snap_t> snaps; // this mirrors snapc.snaps, but is in
// a format librados can understand
std::map<std::string, SnapInfo> snaps_by_name;
uint64_t snap_id;
bool snap_exists; // false if our snap_id was deleted
std::map<rados::cls::lock::locker_id_t,
rados::cls::lock::locker_info_t> lockers;
bool exclusive_locked;
std::string lock_tag;
std::string name;
std::string snap_name;
IoCtx data_ctx, md_ctx;
WatchCtx *wctx;
int refresh_seq; ///< sequence for refresh requests
int last_refresh; ///< last completed refresh
uint64_t last_header_version; ///< last version of the header object
///< read from librados
/**
* Lock ordering:
* md_lock, cache_lock, snap_lock, parent_lock, refresh_lock
*/
Mutex md_lock; // protects access to the mutable image metadata that
// isn't guarded by other locks below
// (size, features, image locks, etc)
Mutex cache_lock; // used as client_lock for the ObjectCacher
Mutex snap_lock; // protects snapshot-related member variables:
Mutex parent_lock; // protects parent_md and parent
Mutex refresh_lock; // protects refresh_seq and last_refresh
bool old_format;
uint8_t order;
uint64_t size;
uint64_t features;
std::string object_prefix;
char *format_string;
std::string header_oid;
std::string id; // only used for new-format images
parent_info parent_md;
ImageCtx *parent;
uint64_t stripe_unit, stripe_count;
ceph_file_layout layout;
ObjectCacher *object_cacher;
LibrbdWriteback *writeback_handler;
ObjectCacher::ObjectSet *object_set;
/**
* Either image_name or image_id must be set.
* If id is not known, pass the empty std::string,
* and init() will look it up.
*/
ImageCtx(const std::string &image_name, const std::string &image_id,
const char *snap, IoCtx& p);
~ImageCtx();
int init();
void init_layout();
void perf_start(std::string name);
void perf_stop();
int snap_set(std::string in_snap_name);
void snap_unset();
librados::snap_t get_snap_id(std::string in_snap_name) const;
int get_snap_name(snapid_t snap_id, std::string *out_snap_name) const;
int get_parent_spec(snapid_t snap_id, parent_spec *pspec);
int get_snap_size(std::string in_snap_name, uint64_t *out_size) const;
int is_snap_protected(string in_snap_name, bool *is_protected) const;
uint64_t get_current_size() const;
uint64_t get_object_size() const;
string get_object_name(uint64_t num) const;
uint64_t get_num_objects() const;
uint64_t get_stripe_unit() const;
uint64_t get_stripe_count() const;
uint64_t get_stripe_period() const;
void add_snap(std::string in_snap_name, librados::snap_t id,
uint64_t in_size, uint64_t features,
parent_info parent, uint8_t protection_status);
uint64_t get_image_size(librados::snap_t in_snap_id) const;
int get_features(librados::snap_t in_snap_id,
uint64_t *out_features) const;
int64_t get_parent_pool_id(librados::snap_t in_snap_id) const;
std::string get_parent_image_id(librados::snap_t in_snap_id) const;
uint64_t get_parent_snap_id(librados::snap_t in_snap_id) const;
int get_parent_overlap(librados::snap_t in_snap_id,
uint64_t *overlap) const;
void aio_read_from_cache(object_t o, bufferlist *bl, size_t len,
uint64_t off, Context *onfinish);
void write_to_cache(object_t o, bufferlist& bl, size_t len, uint64_t off);
int read_from_cache(object_t o, bufferlist *bl, size_t len, uint64_t off);
int flush_cache();
void shutdown_cache();
void invalidate_cache();
int register_watch();
void unregister_watch();
size_t parent_io_len(uint64_t offset, size_t length,
librados::snap_t in_snap_id);
uint64_t prune_parent_extents(vector<pair<uint64_t,uint64_t> >& objectx,
uint64_t overlap);
};
}
#endif
|
