]>
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 | ||
12 | #define PR_MANAGER_CLASS(klass) \ | |
13 | OBJECT_CLASS_CHECK(PRManagerClass, (klass), TYPE_PR_MANAGER) | |
14 | #define PR_MANAGER_GET_CLASS(obj) \ | |
15 | OBJECT_GET_CLASS(PRManagerClass, (obj), TYPE_PR_MANAGER) | |
16 | #define PR_MANAGER(obj) \ | |
17 | OBJECT_CHECK(PRManager, (obj), TYPE_PR_MANAGER) | |
18 | ||
19 | struct sg_io_hdr; | |
20 | ||
21 | typedef struct PRManager { | |
22 | /* <private> */ | |
23 | Object parent; | |
24 | } PRManager; | |
25 | ||
26 | /** | |
27 | * PRManagerClass: | |
28 | * @parent_class: the base class | |
29 | * @run: callback invoked in thread pool context | |
30 | */ | |
31 | typedef struct PRManagerClass { | |
32 | /* <private> */ | |
33 | ObjectClass parent_class; | |
34 | ||
35 | /* <public> */ | |
36 | int (*run)(PRManager *pr_mgr, int fd, struct sg_io_hdr *hdr); | |
5f640894 | 37 | bool (*is_connected)(PRManager *pr_mgr); |
7c9e5276 PB |
38 | } PRManagerClass; |
39 | ||
5f640894 | 40 | bool pr_manager_is_connected(PRManager *pr_mgr); |
2f3a7ab3 KW |
41 | int coroutine_fn pr_manager_execute(PRManager *pr_mgr, AioContext *ctx, int fd, |
42 | struct sg_io_hdr *hdr); | |
7c9e5276 | 43 | |
7c9e5276 | 44 | PRManager *pr_manager_lookup(const char *id, Error **errp); |
7c9e5276 PB |
45 | |
46 | #endif |