@@ -278,7 +278,7 @@ index bbe56e176db17a502d7f3864ba529212f553590a..b0da9d1cddc69428e9fb3379d1338cf8
278
278
- static void thread_main(void* arg) {
279
279
- ASSERT_LE(0, uv_barrier_wait(&barrier));
280
280
- uv_sleep(250);
281
- - ASSERT_EQ(0, uv_async_send(&async));
281
+ - ASSERT_OK( uv_async_send(&async));
282
282
- }
283
283
+ static uv_timer_t main_timer;
284
284
+ static int main_timer_called;
@@ -333,9 +333,9 @@ index bbe56e176db17a502d7f3864ba529212f553590a..b0da9d1cddc69428e9fb3379d1338cf8
333
333
- uv_loop_t* loop;
334
334
-
335
335
- loop = uv_default_loop();
336
- - ASSERT_EQ(0, uv_async_init(loop, &async, async_cb));
337
- - ASSERT_EQ(0, uv_barrier_init(&barrier, 2));
338
- - ASSERT_EQ(0, uv_thread_create(&thread, thread_main, NULL));
336
+ - ASSERT_OK( uv_async_init(loop, &async, async_cb));
337
+ - ASSERT_OK( uv_barrier_init(&barrier, 2));
338
+ - ASSERT_OK( uv_thread_create(&thread, thread_main, NULL));
339
339
- ASSERT_LE(0, uv_barrier_wait(&barrier));
340
340
-
341
341
- while (uv_loop_alive(loop)) {
@@ -457,7 +457,7 @@ index bbe56e176db17a502d7f3864ba529212f553590a..b0da9d1cddc69428e9fb3379d1338cf8
457
457
+ uv_timer_init(&external_loop, &external_timer);
458
458
+ uv_timer_start(&external_timer, external_timer_cb, 100, 0);
459
459
460
- - ASSERT_EQ(0, uv_thread_join(&thread));
460
+ - ASSERT_OK( uv_thread_join(&thread));
461
461
- uv_barrier_destroy(&barrier);
462
462
+ run_loop();
463
463
+ ASSERT_EQ(main_timer_called, 1);
0 commit comments