blob: b4f492c19e49ea1210c2bee89c42ae3754b199ef (
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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#ifndef RBD_MIRROR_IMAGE_REPLAYER_JOURNAL_SYNC_POINT_HANDLER_H
#define RBD_MIRROR_IMAGE_REPLAYER_JOURNAL_SYNC_POINT_HANDLER_H
#include "tools/rbd_mirror/image_sync/Types.h"
#include "librbd/journal/Types.h"
struct Context;
namespace librbd { struct ImageCtx; }
namespace rbd {
namespace mirror {
namespace image_replayer {
namespace journal {
template <typename> class StateBuilder;
template <typename ImageCtxT>
class SyncPointHandler : public image_sync::SyncPointHandler {
public:
using SyncPoint = image_sync::SyncPoint;
using SyncPoints = image_sync::SyncPoints;
static SyncPointHandler* create(StateBuilder<ImageCtxT>* state_builder) {
return new SyncPointHandler(state_builder);
}
SyncPointHandler(StateBuilder<ImageCtxT>* state_builder);
SyncPoints get_sync_points() const override;
librbd::SnapSeqs get_snap_seqs() const override;
void update_sync_points(const librbd::SnapSeqs& snap_seqs,
const SyncPoints& sync_points,
bool sync_complete,
Context* on_finish) override;
private:
StateBuilder<ImageCtxT>* m_state_builder;
librbd::journal::MirrorPeerClientMeta m_client_meta_copy;
void handle_update_sync_points(int r, Context* on_finish);
};
} // namespace journal
} // namespace image_sync
} // namespace mirror
} // namespace rbd
extern template class rbd::mirror::image_replayer::journal::SyncPointHandler<librbd::ImageCtx>;
#endif // RBD_MIRROR_IMAGE_REPLAYER_JOURNAL_SYNC_POINT_HANDLER_H
|
