Lines Matching defs:req
57 static void work_cb(uv_work_t* req) {
58 uv_sem_wait(pause_sems + (req - pause_reqs));
62 static void done_cb(uv_work_t* req, int status) {
63 uv_sem_destroy(pause_sems + (req - pause_reqs));
94 static int known_broken(uv_req_t* req) {
95 if (req->type != UV_FS)
100 switch (((uv_fs_t*) req)->fs_type) {
125 static void fs_cb(uv_fs_t* req) {
126 ASSERT_NE(known_broken((uv_req_t*) req) || \
127 req->result == UV_ECANCELED, 0);
128 uv_fs_req_cleanup(req);
133 static void getaddrinfo_cb(uv_getaddrinfo_t* req,
152 static void work2_cb(uv_work_t* req) {
157 static void done2_cb(uv_work_t* req, int status) {
165 uv_req_t* req;
171 req = (uv_req_t*) ((char*) ci->reqs + i * ci->stride);
172 ASSERT(known_broken(req) || 0 == uv_cancel(req));
181 static void nop_done_cb(uv_work_t* req, int status) {
187 static void nop_random_cb(uv_random_t* req, int status, void* buf, size_t len) {
190 ri = container_of(req, struct random_info, random_req);
270 struct random_info req;
276 &req.random_req,
277 &req.buf,
278 sizeof(req.buf),
281 ASSERT_OK(uv_cancel((uv_req_t*) &req));
372 uv_work_t req;
376 ASSERT_OK(uv_queue_work(loop, &req, (uv_work_cb) abort, nop_done_cb));
377 ASSERT_OK(uv_cancel((uv_req_t*) &req));
388 static void after_busy_cb(uv_work_t* req, int status) {
393 static void busy_cb(uv_work_t* req) {
394 uv_sem_post((uv_sem_t*) req->data);
401 uv_work_t req;
403 req.data = &sem_lock;
406 ASSERT_OK(uv_queue_work(uv_default_loop(), &req, busy_cb, after_busy_cb));
410 ASSERT_EQ(uv_cancel((uv_req_t*) &req), UV_EBUSY);