/libuv/test/ |
H A D | test-fs-open-flags.c | 67 ASSERT(rmdir_req.result == 0 || rmdir_req.result == UV_ENOENT); in setup() 72 ASSERT_OK(mkdir_req.result); in setup() 84 ASSERT(unlink_req.result == 0 || unlink_req.result == UV_ENOENT); in refresh() 93 ASSERT_GE(open_req.result, 0); in refresh() 98 ASSERT_OK(close_req.result); in refresh() 118 ASSERT_OK(close_req.result); in refresh() 177 ASSERT_OK(close_req.result); in writeExpect() 195 ASSERT_OK(close_req.result); in writeExpect() 220 ASSERT_OK(close_req.result); in writeFail() 240 ASSERT_OK(close_req.result); in readExpect() [all …]
|
H A D | test-fs.c | 310 ASSERT(req->result == 0 || req->result == UV_EPERM); in chown_root_cb() 1426 file = req.result; in TEST_IMPL() 3480 ASSERT_EQ(lseek(open_req1.result, write_req.result, SEEK_SET), in fs_write_alotof_bufs() 3713 ssize_t result; in thread_main() local 3725 ASSERT(result > 0 && result <= nbytes); in thread_main() 3729 size -= result; in thread_main() 3730 data += result; in thread_main() 3795 int result; in test_fs_partial() local 3809 int result; in test_fs_partial() local 3811 ASSERT_EQ(write_req.result, result); in test_fs_partial() [all …]
|
H A D | test-fs-readdir.c | 52 ASSERT_OK(req->result); in empty_closedir_cb() 63 ASSERT_OK(req->result); in empty_readdir_cb() 79 ASSERT_OK(req->result); in empty_opendir_cb() 120 ASSERT_OK(opendir_req.result); in TEST_IMPL() 139 ASSERT_OK(closedir_req.result); in TEST_IMPL() 277 ASSERT_OK(req->result); in non_empty_closedir_cb() 289 if (req->result == 0) { in non_empty_readdir_cb() 297 ASSERT_EQ(1, req->result); in non_empty_readdir_cb() 328 ASSERT_OK(req->result); in non_empty_opendir_cb() 402 ASSERT_OK(opendir_req.result); in TEST_IMPL() [all …]
|
H A D | runner-win.c | 81 DWORD result; in process_start() local 119 result = GetModuleFileNameW(NULL, in process_start() 122 if (result == 0 || result == sizeof(image)) in process_start() 182 DWORD timeout_api, result; in process_wait() local 199 result = WaitForMultipleObjects(n, handles, TRUE, timeout_api); in process_wait() 201 if (result < WAIT_OBJECT_0 + n) { in process_wait() 205 if (result == WAIT_TIMEOUT) { in process_wait()
|
H A D | runner.c | 113 const char* result; in log_tap_result() local 120 result = "ok"; in log_tap_result() 124 result = "ok"; in log_tap_result() 128 result = "not ok"; in log_tap_result() 141 fprintf(stdout, "%s %d - %s%s%s\n", result, test_count, test, directive, reason); in log_tap_result() 155 int result; in run_test() local 251 result = process_wait(main_proc, 1, task->timeout * timeout_multiplier); in run_test() 252 if (result == -1) { in run_test() 254 } else if (result == -2) { in run_test()
|
H A D | benchmark-queue-work.c | 27 static unsigned result; variable 36 req->data = &result; in work_cb()
|
H A D | test-metrics.c | 174 ASSERT_EQ(req->result, sizeof(test_buf)); in write_cb() 181 fs_reqs.open_req.result, in write_cb() 192 ASSERT_GE(req->result, 0); in create_cb() 200 req->result, in create_cb()
|
H A D | test-fs-copyfile.c | 54 ASSERT_OK(req->result); in handle_result() 122 ASSERT_EQ(req.result, UV_ENOENT); in TEST_IMPL() 223 ASSERT_EQ(req.result, UV_EACCES); in TEST_IMPL()
|
/libuv/docs/code/uvcat/ |
H A D | main.c | 17 if (req->result < 0) { in on_write() 18 fprintf(stderr, "Write error: %s\n", uv_strerror((int)req->result)); in on_write() 26 if (req->result < 0) { in on_read() 27 fprintf(stderr, "Read error: %s\n", uv_strerror(req->result)); in on_read() 29 else if (req->result == 0) { in on_read() 32 uv_fs_close(uv_default_loop(), &close_req, open_req.result, NULL); in on_read() 34 else if (req->result > 0) { in on_read() 35 iov.len = req->result; in on_read() 44 if (req->result >= 0) { in on_open() 46 uv_fs_read(uv_default_loop(), &read_req, req->result, in on_open() [all …]
|
/libuv/docs/code/idle-compute/ |
H A D | main.c | 21 if (stdin_watcher.result > 0) { in on_type() 22 buffer[stdin_watcher.result] = '\0'; in on_type() 29 else if (stdin_watcher.result < 0) { in on_type() 30 fprintf(stderr, "error opening file: %s\n", uv_strerror(req->result)); in on_type()
|
/libuv/src/win/ |
H A D | process.c | 235 return result; in search_path_join_test() 238 uv__free(result); in search_path_join_test() 253 WCHAR* result; in path_search_walk_ext() local 262 return result; in path_search_walk_ext() 271 if (result != NULL) { in path_search_walk_ext() 272 return result; in path_search_walk_ext() 280 if (result != NULL) { in path_search_walk_ext() 281 return result; in path_search_walk_ext() 440 return result; in search_path() 896 BOOL result; in uv_spawn() local [all …]
|
H A D | fs.c | 370 req->result = 0; in uv__fs_req_init() 635 int result; in fs__close() local 649 result = 0; in fs__close() 654 if (result == -1) { in fs__close() 788 int result; in fs__read() local 994 int result; in fs__write() local 1066 if (result == -1) in fs__rmdir() 1946 int result; in fs__sync_impl() local 2100 result = -1; in fs__sendfile() 2119 result += n; in fs__sendfile() [all …]
|
H A D | req-inl.h | 69 #define UV_SUCCEEDED_WITHOUT_IOCP(result) \ argument 70 ((result) && (handle->flags & UV_HANDLE_SYNC_BYPASS_IOCP)) 72 #define UV_SUCCEEDED_WITH_IOCP(result) \ argument 73 ((result) || (GetLastError() == ERROR_IO_PENDING))
|
H A D | poll.c | 80 int result; in uv__fast_poll_submit_poll_req() local 127 result = uv__msafd_poll((SOCKET) handle->peer_socket, in uv__fast_poll_submit_poll_req() 131 if (result != 0 && WSAGetLastError() != WSA_IO_PENDING) { in uv__fast_poll_submit_poll_req() 540 int result; in uv__poll_close() local 563 result = uv__msafd_poll(handle->socket, in uv__poll_close() 568 if (result == SOCKET_ERROR) { in uv__poll_close()
|
H A D | core.c | 762 int result; in uv__getsockpeername() local 765 result = uv_fileno(handle, &fd); in uv__getsockpeername() 766 if (result != 0) in uv__getsockpeername() 767 return result; in uv__getsockpeername() 772 result = func((SOCKET) fd, name, namelen); in uv__getsockpeername() 773 if (result != 0) in uv__getsockpeername()
|
H A D | udp.c | 266 int result; in uv__udp_queue_recv() local 280 result = handle->func_wsarecv(handle->socket, in uv__udp_queue_recv() 288 if (UV_SUCCEEDED_WITHOUT_IOCP(result == 0)) { in uv__udp_queue_recv() 294 } else if (UV_SUCCEEDED_WITH_IOCP(result == 0)) { in uv__udp_queue_recv() 356 DWORD result, bytes; in uv__send() local 363 result = WSASendTo(handle->socket, in uv__send() 373 if (UV_SUCCEEDED_WITHOUT_IOCP(result == 0)) { in uv__send() 381 } else if (UV_SUCCEEDED_WITH_IOCP(result == 0)) { in uv__send()
|
H A D | pipe.c | 590 DWORD result; in uv__pipe_shutdown() local 630 if (!result) { in uv__pipe_shutdown() 1316 int result; in uv_pipe_writefile_thread_proc() local 1326 result = WriteFile(handle->handle, in uv_pipe_writefile_thread_proc() 1332 if (!result) { in uv_pipe_writefile_thread_proc() 1381 int result; in uv__pipe_queue_read() local 1587 int result; in uv__pipe_write_data() local 1630 result = in uv__pipe_write_data() 1633 if (!result) { in uv__pipe_write_data() 1671 if (result) { in uv__pipe_write_data() [all …]
|
H A D | tcp.c | 474 int result; in uv__tcp_queue_read() local 495 result = WSARecv(handle->socket, in uv__tcp_queue_read() 506 if (UV_SUCCEEDED_WITHOUT_IOCP(result == 0)) { in uv__tcp_queue_read() 510 } else if (UV_SUCCEEDED_WITH_IOCP(result == 0)) { in uv__tcp_queue_read() 891 int result; in uv__tcp_write() local 909 result = WSASend(handle->socket, in uv__tcp_write() 917 if (UV_SUCCEEDED_WITHOUT_IOCP(result == 0)) { in uv__tcp_write() 924 } else if (UV_SUCCEEDED_WITH_IOCP(result == 0)) { in uv__tcp_write() 955 int result; in uv__tcp_try_write() local 961 result = WSASend(handle->socket, in uv__tcp_try_write() [all …]
|
H A D | winsock.c | 43 int result; in uv__get_extension_function() local 46 result = WSAIoctl(socket, in uv__get_extension_function() 56 if (result == SOCKET_ERROR) { in uv__get_extension_function()
|
/libuv/src/unix/ |
H A D | tty.c | 83 int result; in uv__tty_is_slave() local 87 result = ioctl(fd, TIOCGPTN, &dummy) != 0; in uv__tty_is_slave() 91 result = ioctl(fd, TIOCPTYGNAME, &dummy) != 0; in uv__tty_is_slave() 127 result = (pts == major(sb.st_rdev)); in uv__tty_is_slave() 131 result = ptsname(fd) == NULL; in uv__tty_is_slave() 133 return result; in uv__tty_is_slave()
|
H A D | fs.c | 1238 int result; in uv__fs_copyfile() local 1398 result = err; in uv__fs_copyfile() 1400 result = 0; in uv__fs_copyfile() 1407 result = err; in uv__fs_copyfile() 1415 result = err; in uv__fs_copyfile() 1418 if (result != 0) { in uv__fs_copyfile() 1425 if (result == 0) in uv__fs_copyfile() 1637 ssize_t result; in uv__fs_write_all() local 1653 if (result <= 0) { in uv__fs_write_all() 1665 total += result; in uv__fs_write_all() [all …]
|
H A D | aix.c | 381 if (result == -1) { in uv_get_free_memory() 391 if (result == -1) { in uv_get_total_memory() 410 int result = perfstat_cpu_total(NULL, &ps_total, sizeof(ps_total), 1); in uv_loadavg() local 411 if (result == -1) { in uv_loadavg() 1065 int result, ncpus, idx = 0; in uv_cpu_info() local 1067 result = perfstat_cpu_total(NULL, &ps_total, sizeof(ps_total), 1); in uv_cpu_info() 1068 if (result == -1) { in uv_cpu_info() 1072 ncpus = result = perfstat_cpu(NULL, NULL, sizeof(perfstat_cpu_t), 0); in uv_cpu_info() 1073 if (result == -1) { in uv_cpu_info() 1084 result = perfstat_cpu(&cpu_id, ps_cpus, sizeof(perfstat_cpu_t), ncpus); in uv_cpu_info() [all …]
|
/libuv/docs/src/ |
H A D | dns.rst | 19 Callback which will be called with the getaddrinfo request result once 29 Callback which will be called with the getnameinfo request result once 44 Pointer to a `struct addrinfo` containing the result. Must be freed by the user 82 callback will get called sometime in the future with the lookup result, 102 callback will get called sometime in the future with the lookup result.
|
/libuv/src/ |
H A D | fs-poll.c | 197 if (req->result != 0) { in poll_cb() 198 if (ctx->busy_polling != req->result) { in poll_cb() 200 req->result, in poll_cb() 203 ctx->busy_polling = req->result; in poll_cb()
|
H A D | uv-common.c | 693 if (req->result >= 0) { in uv__fs_scandir_cleanup() 701 n = (unsigned int) req->result; in uv__fs_scandir_cleanup() 717 if (req->result < 0) in uv_fs_scandir_next() 718 return req->result; in uv_fs_scandir_next() 734 if (*nbufs == (unsigned int) req->result) { in uv_fs_scandir_next() 799 for (i = 0; i < req->result; ++i) { in uv__fs_readdir_cleanup()
|