/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 | 311 ASSERT(req->result == 0 || req->result == UV_EPERM); in chown_root_cb() 1471 file = req.result; in TEST_IMPL() 3525 ASSERT_EQ(lseek(open_req1.result, write_req.result, SEEK_SET), in fs_write_alotof_bufs() 3758 ssize_t result; in thread_main() local 3770 ASSERT(result > 0 && result <= nbytes); in thread_main() 3774 size -= result; in thread_main() 3775 data += result; in thread_main() 3840 int result; in test_fs_partial() local 3854 int result; in test_fs_partial() local 3856 ASSERT_EQ(write_req.result, result); in test_fs_partial() [all …]
|
H A D | test-fs-readdir.c | 53 ASSERT_OK(req->result); in empty_closedir_cb() 64 ASSERT_OK(req->result); in empty_readdir_cb() 80 ASSERT_OK(req->result); in empty_opendir_cb() 121 ASSERT_OK(opendir_req.result); in TEST_IMPL() 140 ASSERT_OK(closedir_req.result); in TEST_IMPL() 278 ASSERT_OK(req->result); in non_empty_closedir_cb() 290 if (req->result == 0) { in non_empty_readdir_cb() 298 ASSERT_EQ(1, req->result); in non_empty_readdir_cb() 329 ASSERT_OK(req->result); in non_empty_opendir_cb() 472 if (req->result == 0) { in readdir_symlink_readdir_cb() [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 | 392 req->result = 0; in uv__fs_req_init() 657 int result; in fs__close() local 671 result = 0; in fs__close() 676 if (result == -1) { in fs__close() 810 int result; in fs__read() local 1016 int result; in fs__write() local 2089 int result; in fs__sync_impl() local 2231 int n, result = 0; in fs__sendfile() local 2243 result = -1; in fs__sendfile() 2262 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 | 272 int result; in uv__udp_queue_recv() local 286 result = handle->func_wsarecv(handle->socket, in uv__udp_queue_recv() 294 if (UV_SUCCEEDED_WITHOUT_IOCP(result == 0)) { in uv__udp_queue_recv() 300 } else if (UV_SUCCEEDED_WITH_IOCP(result == 0)) { in uv__udp_queue_recv() 362 DWORD result, bytes; in uv__send() local 369 result = WSASendTo(handle->socket, in uv__send() 379 if (UV_SUCCEEDED_WITHOUT_IOCP(result == 0)) { in uv__send() 387 } else if (UV_SUCCEEDED_WITH_IOCP(result == 0)) { in uv__send()
|
H A D | pipe.c | 595 DWORD result; in uv__pipe_shutdown() local 635 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 1586 int result; in uv__pipe_write_data() local 1629 result = in uv__pipe_write_data() 1632 if (!result) { in uv__pipe_write_data() 1670 if (result) { in uv__pipe_write_data() [all …]
|
H A D | tcp.c | 480 int result; in uv__tcp_queue_read() local 501 result = WSARecv(handle->socket, in uv__tcp_queue_read() 512 if (UV_SUCCEEDED_WITHOUT_IOCP(result == 0)) { in uv__tcp_queue_read() 516 } else if (UV_SUCCEEDED_WITH_IOCP(result == 0)) { in uv__tcp_queue_read() 897 int result; in uv__tcp_write() local 915 result = WSASend(handle->socket, in uv__tcp_write() 923 if (UV_SUCCEEDED_WITHOUT_IOCP(result == 0)) { in uv__tcp_write() 930 } else if (UV_SUCCEEDED_WITH_IOCP(result == 0)) { in uv__tcp_write() 961 int result; in uv__tcp_try_write() local 967 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 | 1249 int result; in uv__fs_copyfile() local 1415 result = err; in uv__fs_copyfile() 1417 result = 0; in uv__fs_copyfile() 1424 result = err; in uv__fs_copyfile() 1432 result = err; in uv__fs_copyfile() 1435 if (result != 0) { in uv__fs_copyfile() 1442 if (result == 0) in uv__fs_copyfile() 1654 ssize_t result; in uv__fs_write_all() local 1670 if (result <= 0) { in uv__fs_write_all() 1682 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()
|