| #ifndef PR_MANAGER_H | |
| #define PR_MANAGER_H | |
| #include "qom/object.h" | |
| #include "qapi/visitor.h" | |
| #include "qom/object_interfaces.h" | |
| #include "qemu/aio.h" | |
| #define TYPE_PR_MANAGER "pr-manager" | |
| OBJECT_DECLARE_TYPE(PRManager, PRManagerClass, | |
| PR_MANAGER) | |
| struct sg_io_hdr; | |
| struct PRManager { | |
| /* <private> */ | |
| Object parent; | |
| }; | |
| /** | |
| * PRManagerClass: | |
| * @parent_class: the base class | |
| * @run: callback invoked in thread pool context | |
| */ | |
| struct PRManagerClass { | |
| /* <private> */ | |
| ObjectClass parent_class; | |
| /* <public> */ | |
| int (*run)(PRManager *pr_mgr, int fd, struct sg_io_hdr *hdr); | |
| bool (*is_connected)(PRManager *pr_mgr); | |
| }; | |
| bool pr_manager_is_connected(PRManager *pr_mgr); | |
| int coroutine_fn pr_manager_execute(PRManager *pr_mgr, AioContext *ctx, int fd, | |
| struct sg_io_hdr *hdr); | |
| PRManager *pr_manager_lookup(const char *id, Error **errp); | |
| #endif |