Lines Matching refs:ASSERT
50 ASSERT(0 == status); in socket_cb()
52 ASSERT(UV_READABLE == (events & UV_READABLE)); in socket_cb()
55 ASSERT(cnt == socket_cb_read_size); in socket_cb()
69 ASSERT(0 == uv_timer_init(loop, &timer_handle)); in run_timer_loop_once()
70 ASSERT(0 == uv_timer_start(&timer_handle, timer_cb, 1, 0)); in run_timer_loop_once()
71 ASSERT(0 == uv_run(loop, UV_RUN_DEFAULT)); in run_timer_loop_once()
72 ASSERT(1 == timer_cb_called); in run_timer_loop_once()
85 ASSERT(child_pid == waited_pid); in assert_wait_child()
86 ASSERT(WIFEXITED(child_stat)); /* Clean exit, not a signal. */ in assert_wait_child()
87 ASSERT(!WIFSIGNALED(child_stat)); in assert_wait_child()
88 ASSERT(0 == WEXITSTATUS(child_stat)); in assert_wait_child()
103 ASSERT(child_pid != -1); in TEST_IMPL()
110 ASSERT(0 == uv_loop_fork(uv_default_loop())); in TEST_IMPL()
129 ASSERT(0 == socketpair(AF_UNIX, SOCK_STREAM, 0, socket_fds)); in TEST_IMPL()
132 ASSERT(0 == uv_poll_init(uv_default_loop(), &poll_handle, socket_fds[0])); in TEST_IMPL()
135 ASSERT(child_pid != -1); in TEST_IMPL()
139 ASSERT(3 == send(socket_fds[1], "hi\n", 3, 0)); in TEST_IMPL()
143 ASSERT(0 == uv_loop_fork(uv_default_loop())); in TEST_IMPL()
144 ASSERT(0 == socket_cb_called); in TEST_IMPL()
145 ASSERT(0 == uv_poll_start(&poll_handle, UV_READABLE, socket_cb)); in TEST_IMPL()
147 ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL()
148 ASSERT(1 == socket_cb_called); in TEST_IMPL()
166 ASSERT(0 == pipe(sync_pipe)); in TEST_IMPL()
171 ASSERT(0 == socketpair(AF_UNIX, SOCK_STREAM, 0, socket_fds)); in TEST_IMPL()
174 ASSERT(0 == uv_poll_init(uv_default_loop(), &poll_handle, socket_fds[0])); in TEST_IMPL()
175 ASSERT(0 == uv_poll_start(&poll_handle, UV_READABLE, socket_cb)); in TEST_IMPL()
181 ASSERT(1 == uv_run(uv_default_loop(), UV_RUN_NOWAIT)); in TEST_IMPL()
184 ASSERT(child_pid != -1); in TEST_IMPL()
188 ASSERT(0 == uv_poll_stop(&poll_handle)); in TEST_IMPL()
190 ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL()
191 ASSERT(0 == socket_cb_called); in TEST_IMPL()
192 ASSERT(1 == write(sync_pipe[1], "1", 1)); /* alert child */ in TEST_IMPL()
193 ASSERT(3 == send(socket_fds[1], "hi\n", 3, 0)); in TEST_IMPL()
195 ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL()
196 ASSERT(0 == socket_cb_called); in TEST_IMPL()
202 ASSERT(1 == read(sync_pipe[0], sync_buf, 1)); /* wait for parent */ in TEST_IMPL()
203 ASSERT(0 == uv_loop_fork(uv_default_loop())); in TEST_IMPL()
204 ASSERT(0 == socket_cb_called); in TEST_IMPL()
209 ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL()
210 ASSERT(1 == socket_cb_called); in TEST_IMPL()
212 ASSERT(0 == strcmp("hi\n", socket_cb_read_buf)); in TEST_IMPL()
239 ASSERT(0 == pipe(sync_pipe)); in TEST_IMPL()
244 ASSERT(0 == uv_signal_init(uv_default_loop(), &signal_handle)); in TEST_IMPL()
245 ASSERT(0 == uv_signal_start(&signal_handle, fork_signal_to_child_cb, SIGUSR1)); in TEST_IMPL()
248 ASSERT(child_pid != -1); in TEST_IMPL()
252 ASSERT(1 == read(sync_pipe[0], sync_buf, 1)); /* wait for child */ in TEST_IMPL()
253 ASSERT(0 == kill(child_pid, SIGUSR1)); in TEST_IMPL()
257 ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_NOWAIT)); in TEST_IMPL()
258 ASSERT(0 == fork_signal_cb_called); in TEST_IMPL()
263 ASSERT(0 == uv_loop_fork(uv_default_loop())); in TEST_IMPL()
264 ASSERT(1 == write(sync_pipe[1], "1", 1)); /* alert parent */ in TEST_IMPL()
266 ASSERT(0 != uv_loop_alive(uv_default_loop())); in TEST_IMPL()
268 ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_ONCE)); in TEST_IMPL()
269 ASSERT(SIGUSR1 == fork_signal_cb_called); in TEST_IMPL()
290 ASSERT(0 == pipe(sync_pipe)); in TEST_IMPL()
291 ASSERT(0 == pipe(sync_pipe2)); in TEST_IMPL()
296 ASSERT(0 == uv_signal_init(uv_default_loop(), &signal_handle)); in TEST_IMPL()
297 ASSERT(0 == uv_signal_start(&signal_handle, fork_signal_to_child_cb, SIGUSR1)); in TEST_IMPL()
300 ASSERT(child_pid != -1); in TEST_IMPL()
305 ASSERT(1 == read(sync_pipe[0], sync_buf, 1)); /* wait for child */ in TEST_IMPL()
307 ASSERT(0 == kill(child_pid, SIGUSR1)); in TEST_IMPL()
314 ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_ONCE)); in TEST_IMPL()
316 ASSERT(0 == fork_signal_cb_called); in TEST_IMPL()
317 ASSERT(1 == write(sync_pipe2[1], "1", 1)); /* alert child */ in TEST_IMPL()
322 ASSERT(0 == uv_loop_fork(uv_default_loop())); in TEST_IMPL()
324 ASSERT(0 != uv_loop_alive(uv_default_loop())); in TEST_IMPL()
326 ASSERT(1 == write(sync_pipe[1], "1", 1)); /* alert parent */ in TEST_IMPL()
333 ASSERT(-1 <= r && r <= 1); in TEST_IMPL()
334 ASSERT(0 == fork_signal_cb_called); in TEST_IMPL()
356 ASSERT(r >= 0); in create_file()
360 ASSERT(r == 0); in create_file()
372 ASSERT(r >= 0); in touch_file()
378 ASSERT(r >= 0); in touch_file()
382 ASSERT(r == 0); in touch_file()
402 ASSERT(fs_event_cb_called == 0); in fs_event_cb_file_current_dir()
404 ASSERT(status == 0); in fs_event_cb_file_current_dir()
406 ASSERT(strcmp(filename, "watch_file") == 0); in fs_event_cb_file_current_dir()
408 ASSERT(filename == NULL || strcmp(filename, "watch_file") == 0); in fs_event_cb_file_current_dir()
424 ASSERT(r == 0); in assert_watch_file_current_dir()
431 ASSERT(r == 0); in assert_watch_file_current_dir()
434 ASSERT(r == 0); in assert_watch_file_current_dir()
437 ASSERT(r == 0); in assert_watch_file_current_dir()
439 ASSERT(timer_cb_touch_called == 0); in assert_watch_file_current_dir()
440 ASSERT(fs_event_cb_called == 0); in assert_watch_file_current_dir()
444 ASSERT(timer_cb_touch_called == 1); in assert_watch_file_current_dir()
445 ASSERT(fs_event_cb_called == 1); in assert_watch_file_current_dir()
466 ASSERT(child_pid != -1); in _do_fork_fs_events_child()
482 ASSERT(0 == uv_loop_close(&loop)); in _do_fork_fs_events_child()
485 ASSERT(0 == uv_loop_fork(uv_default_loop())); in _do_fork_fs_events_child()
498 ASSERT(0 == uv_loop_close(uv_default_loop())); in _do_fork_fs_events_child()
561 ASSERT(r == 0); in TEST_IMPL()
566 ASSERT(r == 0); in TEST_IMPL()
569 ASSERT(r == 0); in TEST_IMPL()
572 ASSERT(child_pid != -1); in TEST_IMPL()
579 ASSERT(0 == uv_loop_fork(loop)); in TEST_IMPL()
582 ASSERT(r == 0); in TEST_IMPL()
584 ASSERT(timer_cb_touch_called == 0); in TEST_IMPL()
585 ASSERT(fs_event_cb_called == 0); in TEST_IMPL()
589 ASSERT(timer_cb_touch_called == 1); in TEST_IMPL()
590 ASSERT(fs_event_cb_called == 1); in TEST_IMPL()
616 ASSERT(status == 0); in after_work_cb()
625 ASSERT(work_cb_count == 0); in assert_run_work()
626 ASSERT(after_work_cb_count == 0); in assert_run_work()
629 ASSERT(r == 0); in assert_run_work()
633 ASSERT(work_cb_count == 1); in assert_run_work()
634 ASSERT(after_work_cb_count == 1); in assert_run_work()
653 ASSERT(child_pid != -1); in TEST_IMPL()
668 ASSERT(0 == uv_loop_fork(uv_default_loop())); in TEST_IMPL()