OpenGrok

46   ASSERT(0 == uv_async_send(&ctx->main_async));
58   ASSERT(0 == uv_async_send(&ctx->worker_async));
69   ASSERT(0 == uv_async_send(&ctx->main_async));
70   ASSERT(0 == uv_run(&ctx->loop, UV_RUN_DEFAULT));
87     ASSERT(0 == uv_loop_init(&ctx->loop));
88     ASSERT(0 == uv_async_init(&ctx->loop, &ctx->worker_async, worker_async_cb));
89     ASSERT(0 == uv_async_init(uv_default_loop(),
92     ASSERT(0 == uv_thread_create(&ctx->thread, worker, ctx));
97   ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_DEFAULT));
100     ASSERT(0 == uv_thread_join(&threads[i].thread));
106     ASSERT(ctx->worker_sent == NUM_PINGS);
107     ASSERT(ctx->worker_seen == NUM_PINGS);
108     ASSERT(ctx->main_sent == (unsigned int) NUM_PINGS);
109     ASSERT(ctx->main_seen == (unsigned int) NUM_PINGS);

Indexes created Mon Aug 03 00:25:36 UTC 2026