]>
Commit | Line | Data |
---|---|---|
7c9e5276 PB |
1 | #ifndef PR_MANAGER_H |
2 | #define PR_MANAGER_H | |
3 | ||
4 | #include "qom/object.h" | |
7c9e5276 PB |
5 | #include "qapi/visitor.h" |
6 | #include "qom/object_interfaces.h" | |
7 | #include "block/aio.h" | |
2f3a7ab3 | 8 | #include "qemu/coroutine.h" |
7c9e5276 PB |
9 | |
10 | #define TYPE_PR_MANAGER "pr-manager" | |
11 | ||
db1015e9 EH |
12 | typedef struct PRManager PRManager; |
13 | typedef struct PRManagerClass PRManagerClass; | |
7c9e5276 PB |
14 | #define PR_MANAGER_CLASS(klass) \ |
15 | OBJECT_CLASS_CHECK(PRManagerClass, (klass), TYPE_PR_MANAGER) | |
16 | #define PR_MANAGER_GET_CLASS(obj) \ | |
17 | OBJECT_GET_CLASS(PRManagerClass, (obj), TYPE_PR_MANAGER) | |
18 | #define PR_MANAGER(obj) \ | |
19 | OBJECT_CHECK(PRManager, (obj), TYPE_PR_MANAGER) | |
20 | ||
21 | struct sg_io_hdr; | |
22 | ||
db1015e9 | 23 | struct PRManager { |
7c9e5276 PB |
24 | /* <private> */ |
25 | Object parent; | |
db1015e9 | 26 | }; |
7c9e5276 PB |
27 | |
28 | /** | |
29 | * PRManagerClass: | |
30 | * @parent_class: the base class | |
31 | * @run: callback invoked in thread pool context | |
32 | */ | |
db1015e9 | 33 | struct PRManagerClass { |
7c9e5276 PB |
34 | /* <private> */ |
35 | ObjectClass parent_class; | |
36 | ||
37 | /* <public> */ | |
38 | int (*run)(PRManager *pr_mgr, int fd, struct sg_io_hdr *hdr); | |
5f640894 | 39 | bool (*is_connected)(PRManager *pr_mgr); |
db1015e9 | 40 | }; |
7c9e5276 | 41 | |
5f640894 | 42 | bool pr_manager_is_connected(PRManager *pr_mgr); |
2f3a7ab3 KW |
43 | int coroutine_fn pr_manager_execute(PRManager *pr_mgr, AioContext *ctx, int fd, |
44 | struct sg_io_hdr *hdr); | |
7c9e5276 | 45 | |
7c9e5276 | 46 | PRManager *pr_manager_lookup(const char *id, Error **errp); |
7c9e5276 PB |
47 | |
48 | #endif |