view release on metacpan or  search on metacpan

libuv-1.49.2/test/test-threadpool-cancel.c  view on Meta::CPAN

  uv_loop_t* loop;

  saturate_threadpool();
  loop = uv_default_loop();
  ASSERT_OK(uv_random(loop,
                      &req.random_req,
                      &req.buf,
                      sizeof(req.buf),
                      0,
                      nop_random_cb));
  ASSERT_OK(uv_cancel((uv_req_t*) &req));
  ASSERT_OK(done_cb_called);
  unblock_threadpool();
  ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT));
  ASSERT_EQ(1, done_cb_called);

  MAKE_VALGRIND_HAPPY(loop);
  return 0;
}


TEST_IMPL(threadpool_cancel_work) {
  struct cancel_info ci;
  uv_work_t reqs[16];
  uv_loop_t* loop;
  unsigned i;

  INIT_CANCEL_INFO(&ci, reqs);
  loop = uv_default_loop();
  saturate_threadpool();

  for (i = 0; i < ARRAY_SIZE(reqs); i++)
    ASSERT_OK(uv_queue_work(loop, reqs + i, work2_cb, done2_cb));

  ASSERT_OK(uv_timer_init(loop, &ci.timer_handle));
  ASSERT_OK(uv_timer_start(&ci.timer_handle, timer_cb, 10, 0));
  ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT));
  ASSERT_EQ(1, timer_cb_called);
  ASSERT_EQ(ARRAY_SIZE(reqs), done2_cb_called);

  MAKE_VALGRIND_HAPPY(loop);
  return 0;
}


TEST_IMPL(threadpool_cancel_fs) {
  struct cancel_info ci;
  uv_fs_t reqs[26];
  uv_loop_t* loop;
  unsigned n;
  uv_buf_t iov;

  INIT_CANCEL_INFO(&ci, reqs);
  loop = uv_default_loop();
  saturate_threadpool();
  iov = uv_buf_init(NULL, 0);

  /* Needs to match ARRAY_SIZE(fs_reqs). */
  n = 0;
  ASSERT_OK(uv_fs_chmod(loop, reqs + n++, "/", 0, fs_cb));
  ASSERT_OK(uv_fs_chown(loop, reqs + n++, "/", 0, 0, fs_cb));
  ASSERT_OK(uv_fs_close(loop, reqs + n++, 0, fs_cb));
  ASSERT_OK(uv_fs_fchmod(loop, reqs + n++, 0, 0, fs_cb));
  ASSERT_OK(uv_fs_fchown(loop, reqs + n++, 0, 0, 0, fs_cb));
  ASSERT_OK(uv_fs_fdatasync(loop, reqs + n++, 0, fs_cb));
  ASSERT_OK(uv_fs_fstat(loop, reqs + n++, 0, fs_cb));
  ASSERT_OK(uv_fs_fsync(loop, reqs + n++, 0, fs_cb));
  ASSERT_OK(uv_fs_ftruncate(loop, reqs + n++, 0, 0, fs_cb));
  ASSERT_OK(uv_fs_futime(loop, reqs + n++, 0, 0, 0, fs_cb));
  ASSERT_OK(uv_fs_link(loop, reqs + n++, "/", "/", fs_cb));
  ASSERT_OK(uv_fs_lstat(loop, reqs + n++, "/", fs_cb));
  ASSERT_OK(uv_fs_mkdir(loop, reqs + n++, "/", 0, fs_cb));
  ASSERT_OK(uv_fs_open(loop, reqs + n++, "/", 0, 0, fs_cb));
  ASSERT_OK(uv_fs_read(loop, reqs + n++, -1, &iov, 1, 0, fs_cb));
  ASSERT_OK(uv_fs_scandir(loop, reqs + n++, "/", 0, fs_cb));
  ASSERT_OK(uv_fs_readlink(loop, reqs + n++, "/", fs_cb));
  ASSERT_OK(uv_fs_realpath(loop, reqs + n++, "/", fs_cb));
  ASSERT_OK(uv_fs_rename(loop, reqs + n++, "/", "/", fs_cb));
  ASSERT_OK(uv_fs_mkdir(loop, reqs + n++, "/", 0, fs_cb));
  ASSERT_OK(uv_fs_sendfile(loop, reqs + n++, 0, 0, 0, 0, fs_cb));
  ASSERT_OK(uv_fs_stat(loop, reqs + n++, "/", fs_cb));
  ASSERT_OK(uv_fs_symlink(loop, reqs + n++, "/", "/", 0, fs_cb));
  ASSERT_OK(uv_fs_unlink(loop, reqs + n++, "/", fs_cb));
  ASSERT_OK(uv_fs_utime(loop, reqs + n++, "/", 0, 0, fs_cb));
  ASSERT_OK(uv_fs_write(loop, reqs + n++, -1, &iov, 1, 0, fs_cb));
  ASSERT_EQ(n, ARRAY_SIZE(reqs));

  ASSERT_OK(uv_timer_init(loop, &ci.timer_handle));
  ASSERT_OK(uv_timer_start(&ci.timer_handle, timer_cb, 10, 0));
  ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT));
  ASSERT_EQ(n, fs_cb_called);
  ASSERT_EQ(1, timer_cb_called);


  MAKE_VALGRIND_HAPPY(loop);
  return 0;
}


TEST_IMPL(threadpool_cancel_single) {
  uv_loop_t* loop;
  uv_work_t req;

  saturate_threadpool();
  loop = uv_default_loop();
  ASSERT_OK(uv_queue_work(loop, &req, (uv_work_cb) abort, nop_done_cb));
  ASSERT_OK(uv_cancel((uv_req_t*) &req));
  ASSERT_OK(done_cb_called);
  unblock_threadpool();
  ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT));
  ASSERT_EQ(1, done_cb_called);

  MAKE_VALGRIND_HAPPY(loop);
  return 0;
}


static void after_busy_cb(uv_work_t* req, int status) {
  ASSERT_OK(status);
  done_cb_called++;
}

static void busy_cb(uv_work_t* req) {
  uv_sem_post((uv_sem_t*) req->data);