#define DIO_CLOSED 1u // channel has been closed
#define DIO_STOPPED 2u // channel has been stopped (implies closed)
-DISPATCH_DECL_INTERNAL(dispatch_operation);
-DISPATCH_DECL_INTERNAL(dispatch_disk);
+DISPATCH_INTERNAL_CLASS_DECL(operation);
+DISPATCH_INTERNAL_CLASS_DECL(disk);
struct dispatch_stream_s {
dispatch_queue_t dq;
mode_t mode;
};
-DISPATCH_CLASS_DECL(disk);
struct dispatch_disk_s {
- DISPATCH_STRUCT_HEADER(disk);
+ DISPATCH_OBJECT_HEADER(disk);
TAILQ_HEAD(dispatch_disk_operations_s, dispatch_operation_s) operations;
dispatch_operation_t cur_rq;
dispatch_queue_t pick_queue;
unsigned long interval_flags;
} dispatch_io_param_s;
-DISPATCH_CLASS_DECL(operation);
struct dispatch_operation_s {
- DISPATCH_STRUCT_HEADER(operation);
+ DISPATCH_OBJECT_HEADER(operation);
dispatch_queue_t op_q;
dispatch_op_direction_t direction; // READ OR WRITE
dispatch_io_param_s params;
DISPATCH_CLASS_DECL(io);
struct dispatch_io_s {
- DISPATCH_STRUCT_HEADER(io);
+ DISPATCH_OBJECT_HEADER(io);
dispatch_queue_t queue, barrier_queue;
dispatch_group_t barrier_group;
dispatch_io_param_s params;
void _dispatch_io_set_target_queue(dispatch_io_t channel, dispatch_queue_t dq);
size_t _dispatch_io_debug(dispatch_io_t channel, char* buf, size_t bufsiz);
-void _dispatch_io_dispose(dispatch_io_t channel);
+void _dispatch_io_dispose(dispatch_io_t channel, bool *allow_free);
size_t _dispatch_operation_debug(dispatch_operation_t op, char* buf,
size_t bufsiz);
-void _dispatch_operation_dispose(dispatch_operation_t operation);
-void _dispatch_disk_dispose(dispatch_disk_t disk);
+void _dispatch_operation_dispose(dispatch_operation_t operation,
+ bool *allow_free);
+void _dispatch_disk_dispose(dispatch_disk_t disk, bool *allow_free);
#endif // __DISPATCH_IO_INTERNAL__