luo980/libuv
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

benchmark: async_pummel should not call uv_async_send on closed handle

Browse Source 
This fixes an assertion that triggered in debug builds on Windows.
This commit is contained in:
Bert Belder 2012-10-24 21:36:02 +02:00
parent a54b9e2921
commit 0dbab84529
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
test/benchmark-async-pummel.c
View File

@ -32,14 +32,27 @@ static volatile int done;
static void async_cb(uv_async_t* handle, int status) {
if (++callbacks == NUM_PINGS)
if (++callbacks == NUM_PINGS) {
/* Tell the pummel thread to stop. */
handle->data = (void*) (intptr_t) 1;
/* Wait for for the pummel thread to acknowledge that it has stoppped. */
while (*(volatile intptr_t*) &handle->data < 2)
uv_sleep(0);
uv_close((uv_handle_t*) handle, NULL);
}
}
static void pummel(void* arg) {
while (!done)
uv_async_send((uv_async_t*) arg);
uv_async_t* handle = (uv_async_t*) arg;
while (*(volatile intptr_t*) &handle->data == 0)
uv_async_send(handle);
/* Acknowledge that we've seen handle->data change. */
handle->data = (void*) (intptr_t) 2;
}
@ -53,6 +66,7 @@ static int test_async_pummel(int nthreads) {
ASSERT(tids != NULL);
ASSERT(0 == uv_async_init(uv_default_loop(), &handle, async_cb));
handle.data = NULL;
for (i = 0; i < nthreads; i++)
ASSERT(0 == uv_thread_create(tids + i, pummel, &handle));