version 1.29.10.2, 2022/11/28 23:29:59
|
version 1.30, 2022/11/29 20:15:18
|
Line 202 struct sched_Task {
|
Line 202 struct sched_Task {
|
#define TASK_DATA(x) (x)->task_data.iov_base |
#define TASK_DATA(x) (x)->task_data.iov_base |
#define TASK_DATLEN(x) (x)->task_data.iov_len |
#define TASK_DATLEN(x) (x)->task_data.iov_len |
|
|
void *task_harg; | unsigned long task_harg; |
#define TASK_HARG(x) (x)->task_harg |
#define TASK_HARG(x) (x)->task_harg |
|
|
TAILQ_ENTRY(sched_Task) task_node; |
TAILQ_ENTRY(sched_Task) task_node; |
Line 406 sched_task_t *schedReadExt(sched_root_task_t * __restr
|
Line 406 sched_task_t *schedReadExt(sched_root_task_t * __restr
|
sched_task_t *schedRead(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
sched_task_t *schedRead(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
int fd, void *opt_data, size_t opt_dlen); |
int fd, void *opt_data, size_t opt_dlen); |
#define schedReadSelf(x) schedReadExt(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
#define schedReadSelf(x) schedReadExt(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
TASK_FD((x)), TASK_DATA((x)), TASK_DATLEN((x)), TASK_MASK((x))) | TASK_FD((x)), TASK_DATA((x)), TASK_DATLEN((x)), TASK_HARG((x))) |
/* |
/* |
|
* schedWriteExt() - Add WRITE I/O task to scheduler queue with custom event mask |
|
* |
|
* @root = root task |
|
* @func = task execution function |
|
* @arg = 1st func argument |
|
* @fd = fd handle |
|
* @opt_data = Optional data |
|
* @opt_dlen = Optional data length |
|
* @mask = Event mask |
|
* return: NULL error or !=NULL new queued task |
|
*/ |
|
sched_task_t *schedWriteExt(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
|
int fd, void *opt_data, size_t opt_dlen, unsigned long mask); |
|
/* |
* schedWrite() - Add WRITE I/O task to scheduler queue |
* schedWrite() - Add WRITE I/O task to scheduler queue |
* |
* |
* @root = root task |
* @root = root task |
Line 420 sched_task_t *schedRead(sched_root_task_t * __restrict
|
Line 434 sched_task_t *schedRead(sched_root_task_t * __restrict
|
*/ |
*/ |
sched_task_t *schedWrite(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
sched_task_t *schedWrite(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
int fd, void *opt_data, size_t opt_dlen); |
int fd, void *opt_data, size_t opt_dlen); |
#define schedWriteSelf(x) schedWrite(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ | #define schedWriteSelf(x) schedWriteExt(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
TASK_FD((x)), TASK_DATA((x)), TASK_DATLEN((x))) | TASK_FD((x)), TASK_DATA((x)), TASK_DATLEN((x)), TASK_HARG((x))) |
/* |
/* |
* schedAlarm() - Add ALARM task to scheduler queue |
* schedAlarm() - Add ALARM task to scheduler queue |
* |
* |