/libuv/docs/code/tcp-echo-server/ |
H A D | main.c | 81 int r = uv_listen((uv_stream_t*) &server, DEFAULT_BACKLOG, on_new_connection); in main() local 82 if (r) { in main() 83 fprintf(stderr, "Listen error %s\n", uv_strerror(r)); in main()
|
/libuv/docs/code/dns/ |
H A D | main.c | 73 int r = uv_getaddrinfo(loop, &resolver, on_resolved, "irc.libera.chat", "6667", &hints); in main() local 75 if (r) { in main() 76 fprintf(stderr, "getaddrinfo call error %s\n", uv_err_name(r)); in main()
|
/libuv/test/ |
H A D | test-tcp-alloc-cb-fail.c | 65 int r; in connect_cb() local 72 r = uv_write(&write_req, req->handle, &buf, 1, write_cb); in connect_cb() 73 ASSERT_OK(r); in connect_cb()
|
H A D | test-tcp-write-queue-order.c | 66 int r; in connect_cb() local 76 r = uv_write(&write_requests[i], in connect_cb() 81 ASSERT_OK(r); in connect_cb()
|
H A D | runner-win.c | 222 int fd, r; in process_copy_output() local 228 r = _lseek(fd, 0, SEEK_SET); in process_copy_output() 229 if (r < 0) in process_copy_output() 232 while ((r = _read(fd, buf, sizeof(buf))) != 0) in process_copy_output() 233 print_lines(buf, r, stream); in process_copy_output()
|
H A D | test-poll-close.c | 52 int r = WSAStartup(MAKEWORD(2, 2), &wsa_data); in TEST_IMPL() local 53 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-ref.c | 407 int r; in TEST_IMPL() local 412 r = uv_exepath(exepath, &exepath_size); in TEST_IMPL() 413 ASSERT_OK(r); in TEST_IMPL() 420 r = uv_spawn(uv_default_loop(), &h, &options); in TEST_IMPL() 421 ASSERT_OK(r); in TEST_IMPL() 426 r = uv_process_kill(&h, /* SIGTERM */ 15); in TEST_IMPL() 427 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-ip6-addr.c | 52 int r; in TEST_IMPL() local 84 r = uv_if_indextoiid(iface_index, interface_id, &interface_id_len); in TEST_IMPL() 85 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-poll-multiple-handles.c | 53 int r = WSAStartup(MAKEWORD(2, 2), &wsa_data); in TEST_IMPL() local 54 ASSERT_OK(r); in TEST_IMPL()
|
H A D | benchmark-loop-count.c | 45 int r = uv_loop_alive(handle->loop); in idle_alive_cb() local 46 if (r == 0) in idle_alive_cb()
|
H A D | runner.c | 353 int r; in run_test_part() local 358 r = task->main(); in run_test_part() 359 return r; in run_test_part()
|
/libuv/docs/code/multi-echo-server/ |
H A D | main.c | 108 int r; in main() local 109 if ((r = uv_listen((uv_stream_t*) &server, 128, on_new_connection))) { in main() 110 fprintf(stderr, "Listen error %s\n", uv_err_name(r)); in main()
|
/libuv/src/unix/ |
H A D | kqueue.c | 569 int r; in uv_fs_event_start() local 573 r = uv__fsevents_init(handle); in uv_fs_event_start() 574 if (r == 0) { in uv_fs_event_start() 580 return r; in uv_fs_event_start() 594 int r; in uv_fs_event_stop() local 595 r = 0; in uv_fs_event_stop() 606 r = uv__fsevents_close(handle); in uv_fs_event_stop() 618 return r; in uv_fs_event_stop()
|
H A D | aix.c | 1126 r = 0; in uv_interface_addresses() 1131 r = UV__ERR(errno); in uv_interface_addresses() 1136 r = UV__ERR(errno); in uv_interface_addresses() 1141 r = UV__ERR(errno); in uv_interface_addresses() 1147 r = UV_ENOMEM; in uv_interface_addresses() 1152 r = UV__ERR(errno); in uv_interface_addresses() 1187 r = UV_ENOMEM; in uv_interface_addresses() 1223 if (r == UV_E2BIG) in uv_interface_addresses() 1225 r = 0; in uv_interface_addresses() 1272 r = UV_ENOSYS; in uv_interface_addresses() [all …]
|
H A D | sunos.c | 456 int r; in uv__fs_event_read() local 474 r = port_getn(loop->fs_fd, &pe, 1, &n, &timeout); in uv__fs_event_read() 476 while (r == -1 && errno == EINTR); in uv__fs_event_read() 478 if ((r == -1 && errno == ETIME) || n == 0) in uv__fs_event_read() 482 assert((r == 0) && "unexpected port_get() error"); in uv__fs_event_read() 500 r = uv__fs_event_rearm(handle); in uv__fs_event_read() 501 if (r != 0) in uv__fs_event_read() 502 handle->cb(handle, NULL, 0, r); in uv__fs_event_read()
|
H A D | freebsd.c | 166 int r; in uv_uptime() local 168 r = clock_gettime(CLOCK_MONOTONIC, &sp); in uv_uptime() 169 if (r) in uv_uptime()
|
H A D | ibmi.c | 376 int r = sscanf(mac_addr, "%02x%02x%02x%02x%02x%02x", in get_ibmi_physical_address() local 379 if (r == ARRAY_SIZE(c)) { in get_ibmi_physical_address() 397 int inet6, r = 0; in uv_interface_addresses() local 496 return r; in uv_interface_addresses()
|
H A D | posix-poll.c | 78 static void uv__pollfds_swap(uv_loop_t* loop, size_t l, size_t r) { in uv__pollfds_swap() argument 81 loop->poll_fds[l] = loop->poll_fds[r]; in uv__pollfds_swap() 82 loop->poll_fds[r] = pfd; in uv__pollfds_swap()
|
H A D | process.c | 856 ssize_t r; in uv__spawn_and_init_child() local 924 r = read(signal_pipe[0], &exec_errorno, sizeof(exec_errorno)); in uv__spawn_and_init_child() 925 while (r == -1 && errno == EINTR); in uv__spawn_and_init_child() 927 if (r == 0) in uv__spawn_and_init_child() 929 else if (r == sizeof(exec_errorno)) { in uv__spawn_and_init_child() 935 } else if (r == -1 && errno == EPIPE) { in uv__spawn_and_init_child()
|
H A D | stream.c | 124 int r; in uv__stream_osx_interrupt_select() local 135 r = write(s->fake_fd, "x", 1); in uv__stream_osx_interrupt_select() 136 while (r == -1 && errno == EINTR); in uv__stream_osx_interrupt_select() 138 assert(r == 1); in uv__stream_osx_interrupt_select() 152 int r; in uv__stream_osx_select() local 180 r = select(max_fd + 1, s->sread, s->swrite, NULL, NULL); in uv__stream_osx_select() 181 if (r == -1) { in uv__stream_osx_select() 190 if (r == 0) in uv__stream_osx_select() 196 r = read(s->int_fd, buf, sizeof(buf)); in uv__stream_osx_select() 198 if (r == sizeof(buf)) in uv__stream_osx_select() [all …]
|
/libuv/src/win/ |
H A D | process.c | 604 int r; in env_strncmp() local 617 r = CompareStringOrdinal(a, na, b, nb, /*case insensitive*/TRUE); in env_strncmp() 618 return r - CSTR_EQUAL; in env_strncmp() 863 BOOL r = UnregisterWaitEx(handle->wait_handle, INVALID_HANDLE_VALUE); in uv__process_close() local 864 if (!r) { in uv__process_close() 952 DWORD cwd_len, r; in uv_spawn() local 966 r = GetCurrentDirectoryW(cwd_len, cwd); in uv_spawn() 967 if (r == 0 || r >= cwd_len) { in uv_spawn() 976 DWORD path_len, r; in uv_spawn() local 987 r = GetEnvironmentVariableW(L"PATH", path, path_len); in uv_spawn() [all …]
|
H A D | thread.c | 390 DWORD r = WaitForSingleObject(*sem, 0); in uv_sem_trywait() local 392 if (r == WAIT_OBJECT_0) in uv_sem_trywait() 395 if (r == WAIT_TIMEOUT) in uv_sem_trywait()
|
/libuv/docs/src/ |
H A D | migration_010_100.rst | 58 r = uv_listen((uv_stream_t*) server, 511, NULL); 59 if (r == -1) { 69 r = uv_listen((uv_stream_t*) server, 511, NULL); 70 if (r < 0) { 71 /* r contains UV_EADDRINUSE */
|
/libuv/docs/code/uvwget/ |
H A D | main.c | 23 int r = uv_poll_init_socket(loop, &context->poll_handle, sockfd); in create_curl_context() local 24 assert(r == 0); in create_curl_context()
|
/libuv/.github/workflows/ |
H A D | CI-docs.yml | 19 - run: pip install -r docs/requirements.txt
|