Lines Matching defs:work
93 w->work(w);
107 static void uv__queue_work_info(struct uv__statistic_work *work) {
124 uv__queue_insert_head(&dump_queue, &work->info->wq);
129 static void uv__update_work_info(struct uv__statistic_work *work) {
131 if (work != NULL && work->info != NULL) {
132 work->info->state = work->state;
133 switch (work->state) {
135 work->info->queue_time = work->time;
138 work->info->execute_start_time = work->time;
141 work->info->execute_end_time = work->time;
144 work->info->done_start_time = work->time;
147 work->info->done_end_time = work->time;
174 dump_work->work = uv__update_work_info;
217 info->work = w;
228 dump_work->work = uv__queue_work_info;
354 /* Keep waiting while either no work is present or only slow I/O
373 uv__queue_init(q); /* Signal uv_cancel() that the work req is executing. */
378 other work in the queue is done. */
384 /* If we encountered a request to run slow I/O work but there is none
396 /* If there is more slow I/O work, schedule it to be run as well. */
414 w->work(w);
419 w->work = NULL; /* Signal uv_cancel() that the work req is done
558 * as the work queue.
574 void (*work)(struct uv__work* w),
578 w->work = work;
586 static void uv__task_done_wrapper(void* work, int status) {
587 struct uv__work* w = (struct uv__work*)work;
609 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL;
617 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL
627 w->work = uv__cancelled;
637 int status = (w->work == uv__cancelled) ? UV_ECANCELED : 0;
691 err = (w->work == uv__cancelled) ? UV_ECANCELED : 0;
700 dump_work->work = uv__update_work_info;
769 w->work(w);
782 w->work = NULL; /* Signal uv_cancel() that the work req is done executing. */
785 int status = (w->work == uv__cancelled) ? UV_ECANCELED : 0;
801 /* init uv work statics queue */
814 void (*work)(struct uv__work *w),
832 UV_LOGI("Unknown work kind");
838 w->work = work;
852 void (*work)(struct uv__work *w),
860 w->work = work;