Lines Matching defs:req
373 uv__queue_init(q); /* Signal uv_cancel() that the work req is executing. */
411 uv_work_t* req = container_of(w, uv_work_t, work_req);
412 LibuvSetStackId((uint64_t)req->reserved[3]);
419 w->work = NULL; /* Signal uv_cancel() that the work req is done
596 static int uv__work_cancel(uv_loop_t* loop, uv_req_t* req, struct uv__work* w) {
618 && ffrt_executor_task_cancel(w, (ffrt_qos_t)(intptr_t)req->reserved[0]);
634 int qos = (ffrt_qos_t)(intptr_t)req->reserved[0];
703 uv_work_t* req = container_of(w, uv_work_t, work_req);
704 LibuvSetStackId((uint64_t)req->reserved[3]);
733 uv_work_t* req = container_of(w, uv_work_t, work_req);
735 req->work_cb(req);
740 uv_work_t* req;
747 req = container_of(w, uv_work_t, work_req);
748 uv__req_unregister(req->loop, req);
750 if (req->after_work_cb == NULL)
753 req->after_work_cb(req, err);
765 uv_work_t* req = container_of(w, uv_work_t, work_req);
767 LibuvSetStackId((uint64_t)req->reserved[3]);
777 (size_t)loop, loop->magic, req->work_cb, req->after_work_cb);
782 w->work = NULL; /* Signal uv_cancel() that the work req is done executing. */
811 uv_req_t* req,
841 req->reserved[0] = (void *)(intptr_t)ffrt_task_attr_get_qos(&attr);
849 uv_req_t* req,
863 req->reserved[0] = (void *)(intptr_t)ffrt_task_attr_get_qos(&attr);
871 uv_work_t* req,
877 uv__req_init(loop, req, UV_WORK);
878 req->loop = loop;
879 req->work_cb = work_cb;
880 req->after_work_cb = after_work_cb;
887 uv_init_dump_info(info, &req->work_req);
891 (req->work_req).info = info;
894 req->reserved[3] = (void*)LibuvCollectAsyncStack();
898 (uv_req_t*)req,
900 &req->work_req,
913 uv_work_t* req,
929 uv__req_init(loop, req, UV_WORK);
930 req->loop = loop;
931 req->work_cb = work_cb;
932 req->after_work_cb = after_work_cb;
938 uv_init_dump_info(info, &req->work_req);
942 (req->work_req).info = info;
945 (uv_req_t*)req,
946 &req->work_req,
955 return uv_queue_work(loop, req, work_cb, after_work_cb);
960 int uv_cancel(uv_req_t* req) {
964 switch (req->type) {
966 loop = ((uv_fs_t*) req)->loop;
967 wreq = &((uv_fs_t*) req)->work_req;
970 loop = ((uv_getaddrinfo_t*) req)->loop;
971 wreq = &((uv_getaddrinfo_t*) req)->work_req;
974 loop = ((uv_getnameinfo_t*) req)->loop;
975 wreq = &((uv_getnameinfo_t*) req)->work_req;
978 loop = ((uv_random_t*) req)->loop;
979 wreq = &((uv_random_t*) req)->work_req;
982 loop = ((uv_work_t*) req)->loop;
983 wreq = &((uv_work_t*) req)->work_req;
989 return uv__work_cancel(loop, req, wreq);