.fatal_error = _corosync_public_exit_error,
.shutdown_request = corosync_shutdown_request,
.state_dump = corosync_state_dump,
- .poll_handle_get = corosync_poll_handle_get
+ .poll_handle_get = corosync_poll_handle_get,
+ .poll_dispatch_add = poll_dispatch_add,
+ .poll_dispatch_delete = poll_dispatch_delete
};
void apidef_init (struct objdb_iface_ver0 *objdb) {
*/
hdb_handle_t (*poll_handle_get) (void);
-
int (*object_key_create_typed) (
hdb_handle_t object_handle,
const char *key_name,
hdb_handle_t *handle,
int (schedwrk_fn) (const void *),
const void *context);
+
+ int (*poll_dispatch_add) (hdb_handle_t handle,
+ int fd,
+ int events,
+ void *data,
+
+ int (*dispatch_fn) (hdb_handle_t handle,
+ int fd,
+ int revents,
+ void *data));
+
+
+ int (*poll_dispatch_delete) (
+ hdb_handle_t handle,
+ int fd);
+
};
#define SERVICE_ID_MAKE(a,b) ( ((a)<<16) | (b) )
static int confdb_exec_exit_fn(void)
{
- poll_dispatch_delete(api->poll_handle_get(), notify_pipe[0]);
+ api->poll_dispatch_delete(api->poll_handle_get(), notify_pipe[0]);
close(notify_pipe[0]);
close(notify_pipe[1]);
return 0;
}
}
- return poll_dispatch_add(api->poll_handle_get(), notify_pipe[0],
+ return api->poll_dispatch_add(api->poll_handle_get(), notify_pipe[0],
POLLIN, NULL, objdb_notify_dispatch);
}