blob: b0a37c4b89a70d1bb01b1b40975c229fe106fdd3 (
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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#ifndef LIBRBD_IO_ASYNC_OPERATION_H
#define LIBRBD_IO_ASYNC_OPERATION_H
#include "include/ceph_assert.h"
#include "include/xlist.h"
#include <list>
class Context;
namespace librbd {
class ImageCtx;
namespace io {
class AsyncOperation {
public:
AsyncOperation()
: m_image_ctx(NULL), m_xlist_item(this)
{
}
~AsyncOperation()
{
ceph_assert(!m_xlist_item.is_on_list());
}
inline bool started() const {
return m_xlist_item.is_on_list();
}
void start_op(ImageCtx &image_ctx);
void finish_op();
void flush(Context *on_finish);
private:
ImageCtx *m_image_ctx;
xlist<AsyncOperation *>::item m_xlist_item;
std::list<Context *> m_flush_contexts;
};
} // namespace io
} // namespace librbd
#endif // LIBRBD_IO_ASYNC_OPERATION_H
|
