/libuv/test/ |
H A D | test-idna.c | 28 const char* p; in TEST_IMPL() local 33 p = b; in TEST_IMPL() 41 p = b; in TEST_IMPL() 49 p = b; in TEST_IMPL() 57 p = b; in TEST_IMPL() 65 p = b; in TEST_IMPL() 73 p = b; in TEST_IMPL() 81 p = b; in TEST_IMPL() 89 p = b; in TEST_IMPL() 106 p = b; in TEST_IMPL() [all …]
|
H A D | runner-unix.c | 135 p->terminated = 0; in process_start() 136 p->status = 0; in process_start() 163 p->pid = pid; in process_start() 207 process_info_t* p; in dowait() local 210 p = &args->vec[i]; in dowait() 212 r = waitpid(p->pid, &p->status, 0); in dowait() 217 p->terminated = 1; in dowait() 240 process_info_t* p; in process_wait() local 336 p = &vec[i]; in process_wait() 422 return p->name; in process_get_name() [all …]
|
H A D | benchmark-pound.c | 143 printf("read_cb %d\n", p->i); in read_cb() 168 printf("close_cb %d\n", p->i); in close_cb() 172 p->make_connect(p); in close_cb() 200 tp = (tcp_conn_rec*) p; in tcp_make_connect() 217 printf("make connect %d\n", p->i); in tcp_make_connect() 220 p->conn_req.data = p; in tcp_make_connect() 221 p->write_req.data = p; in tcp_make_connect() 222 p->stream.data = p; in tcp_make_connect() 241 p->conn_req.data = p; in pipe_make_connect() 242 p->write_req.data = p; in pipe_make_connect() [all …]
|
H A D | runner-win.c | 160 p->stdio_in = nul; in process_start() 161 p->stdio_out = file; in process_start() 162 p->process = pi.hProcess; in process_start() 163 p->name = part; in process_start() 250 size = GetFileSize(p->stdio_out, NULL); in process_read_last_line() 282 return p->name; in process_get_name() 287 if (!TerminateProcess(p->process, 1)) in process_terminate() 293 int process_reap(process_info_t *p) { in process_reap() argument 301 void process_cleanup(process_info_t *p) { in process_cleanup() argument 302 CloseHandle(p->process); in process_cleanup() [all …]
|
H A D | runner.h | 139 int process_start(char *name, char* part, process_info_t *p, int is_helper); 147 long int process_output_size(process_info_t *p); 150 int process_copy_output(process_info_t* p, FILE* stream); 153 int process_read_last_line(process_info_t *p, 158 char* process_get_name(process_info_t *p); 161 int process_terminate(process_info_t *p); 164 int process_reap(process_info_t *p); 167 void process_cleanup(process_info_t *p);
|
H A D | test-pipe-sendmsg.c | 76 uv_pipe_t* p; in read_cb() local 81 p = (uv_pipe_t*) handle; in read_cb() 84 while (uv_pipe_pending_count(p) != 0) { in read_cb() 85 pending = uv_pipe_pending_type(p); in read_cb() 90 ASSERT_OK(uv_pipe_init(p->loop, inc, 0)); in read_cb() 97 ASSERT_OK(uv_read_stop((uv_stream_t*) p)); in read_cb() 98 uv_close((uv_handle_t*) p, close_cb); in read_cb() 108 uv_pipe_t p; in TEST_IMPL() local 122 ASSERT_OK(uv_pipe_init(uv_default_loop(), &p, 1)); in TEST_IMPL() 123 ASSERT_OK(uv_pipe_open(&p, fds[1])); in TEST_IMPL() [all …]
|
H A D | test-tcp-connect6-error.c | 80 uv_interface_address_t* p; in TEST_IMPL() local 100 for (p = ifs; p < &ifs[n]; p++) in TEST_IMPL() 101 if (p->address.address6.sin6_family == AF_INET6) in TEST_IMPL() 102 if (!memcmp(&p->address.address6.sin6_addr, "\xfe\x80", 2)) in TEST_IMPL() 104 ok = (p < &ifs[n]); in TEST_IMPL()
|
H A D | test-env-vars.c | 155 char* p; in TEST_IMPL() local 160 p = malloc(size); in TEST_IMPL() 161 ASSERT_NOT_NULL(p); in TEST_IMPL() 163 memset(p, 'x', n); in TEST_IMPL() 164 p[n] = '\0'; in TEST_IMPL() 166 ASSERT_OK(uv_os_setenv(name, p)); in TEST_IMPL() 167 ASSERT_OK(uv_os_getenv(name, p, &size)); in TEST_IMPL() 171 ASSERT_EQ('x', p[n]); in TEST_IMPL() 174 free(p); in TEST_IMPL()
|
H A D | test-embed.c | 64 struct pollfd p; in TEST_IMPL() 65 p.fd = uv_backend_fd(loop); in TEST_IMPL() 66 p.events = POLLIN; in TEST_IMPL() 67 p.revents = 0; in TEST_IMPL() 68 rc = poll(&p, 1, uv_backend_timeout(loop)); in TEST_IMPL()
|
H A D | runner.c | 42 char* p; in fmt() local 44 p = &(*buf)[32]; in fmt() 47 *--p = '\0'; in fmt() 50 *--p = '0'; in fmt() 53 if (v) *--p = '0' + (v % 10), v /= 10; in fmt() 54 if (v) *--p = '0' + (v % 10), v /= 10; in fmt() 55 if (v) *--p = '0' + (v % 10), v /= 10; in fmt() 56 if (v) *--p = ','; in fmt() 59 return p; in fmt()
|
/libuv/src/unix/ |
H A D | aix.c | 519 for (p = tmp + 1; *p; p++) { in uv__makedir_p() 521 *p = 0; in uv__makedir_p() 538 char *p; in uv__make_subdirs_p() local 634 *p = strchr(*p, '\n'); in uv__skip_lines() 635 if (!p) in uv__skip_lines() 638 (*p)++; in uv__skip_lines() 656 char *p; in uv__parse_data() local 659 p = buf; in uv__parse_data() 725 char *p; in uv__ahafs_event() local 762 p++; in uv__ahafs_event() [all …]
|
H A D | random-sysctl-linux.c | 47 char* p; in uv__random_sysctl() local 51 p = buf; in uv__random_sysctl() 52 pe = p + buflen; in uv__random_sysctl() 54 while (p < pe) { in uv__random_sysctl() 90 n = pe - p; in uv__random_sysctl() 94 memcpy(p, uuid, n); in uv__random_sysctl() 95 p += n; in uv__random_sysctl()
|
H A D | os390.c | 287 __net_ifconf6entry_t* p; in uv__interface_addresses_v6() local 322 p = ifr; in uv__interface_addresses_v6() 352 p = ifr; in uv__interface_addresses_v6() 410 struct ifreq* p; in uv_interface_addresses() local 456 #define ADDR_SIZE(p) MAX((p).sa_len, sizeof(p)) in uv_interface_addresses() argument 461 p = ifr; in uv_interface_addresses() 515 p = ifr; in uv_interface_addresses() 611 struct pollfd p[1]; in uv__io_check_fd() local 614 p[0].fd = fd; in uv__io_check_fd() 615 p[0].events = POLLIN; in uv__io_check_fd() [all …]
|
H A D | linux.c | 1725 char* p; in uv_cpu_info() local 2016 char* p; in uv__read_proc_meminfo() local 2088 char* p; in uv__cgroup1_find_memory_controller() local 2092 while (p != NULL && strncmp(p, ":memory:", 8)) { in uv__cgroup1_find_memory_controller() 2093 p = strchr(p, '\n'); in uv__cgroup1_find_memory_controller() 2095 p = strchr(p, ':'); in uv__cgroup1_find_memory_controller() 2100 p = p + strlen(":memory:/"); in uv__cgroup1_find_memory_controller() 2110 char* p; in uv__get_cgroup1_memory_limits() local 2150 char* p; in uv__get_cgroup2_memory_limits() local 2193 char* p; in uv__get_cgroup1_current_memory() local [all …]
|
H A D | posix-poll.c | 58 struct pollfd* p; in uv__pollfds_maybe_resize() local 64 p = uv__reallocf(loop->poll_fds, n * sizeof(*loop->poll_fds)); in uv__pollfds_maybe_resize() 65 if (p == NULL) in uv__pollfds_maybe_resize() 68 loop->poll_fds = p; in uv__pollfds_maybe_resize() 368 struct pollfd p[1]; in uv__io_check_fd() local 371 p[0].fd = fd; in uv__io_check_fd() 372 p[0].events = POLLIN; in uv__io_check_fd() 375 rv = poll(p, 1, 0); in uv__io_check_fd() 381 if (p[0].revents & POLLNVAL) in uv__io_check_fd()
|
H A D | tcp.c | 298 struct ifaddrs* p; in uv__ipv6_link_local_scope_id() local 303 for (p = ifa; p != NULL; p = p->ifa_next) in uv__ipv6_link_local_scope_id() 304 if (p->ifa_addr != NULL) in uv__ipv6_link_local_scope_id() 305 if (uv__is_ipv6_link_local(p->ifa_addr)) in uv__ipv6_link_local_scope_id() 309 if (p != NULL) { in uv__ipv6_link_local_scope_id() 310 a6 = (struct sockaddr_in6*) p->ifa_addr; in uv__ipv6_link_local_scope_id()
|
H A D | process.c | 668 const char *p; in uv__spawn_resolve_and_spawn() local 719 for (p = path;; p = z) { in uv__spawn_resolve_and_spawn() 723 z = strchr(p, ':'); in uv__spawn_resolve_and_spawn() 725 z = p + strlen(p); in uv__spawn_resolve_and_spawn() 726 if ((size_t)(z - p) >= l) { in uv__spawn_resolve_and_spawn() 732 memcpy(b, p, z - p); in uv__spawn_resolve_and_spawn() 733 b[z - p] = '/'; in uv__spawn_resolve_and_spawn() 734 memcpy(b + (z - p) + (z > p), options->file, k + 1); in uv__spawn_resolve_and_spawn()
|
H A D | netbsd.c | 246 unsigned char* p; in uv__random_sysctl() local 248 p = buf; in uv__random_sysctl() 253 if (sysctl(name, ARRAY_SIZE(name), p, &count, NULL, 0) == -1) in uv__random_sysctl() 259 p += count; in uv__random_sysctl()
|
H A D | udp.c | 335 struct mmsghdr* p; in uv__udp_sendmsg_many() local 347 p = &h[pkts]; in uv__udp_sendmsg_many() 348 memset(p, 0, sizeof(*p)); in uv__udp_sendmsg_many() 350 p->msg_hdr.msg_name = NULL; in uv__udp_sendmsg_many() 351 p->msg_hdr.msg_namelen = 0; in uv__udp_sendmsg_many() 353 p->msg_hdr.msg_name = &req->addr; in uv__udp_sendmsg_many() 355 p->msg_hdr.msg_namelen = sizeof(struct sockaddr_in6); in uv__udp_sendmsg_many() 357 p->msg_hdr.msg_namelen = sizeof(struct sockaddr_in); in uv__udp_sendmsg_many() 359 p->msg_hdr.msg_namelen = sizeof(struct sockaddr_un); in uv__udp_sendmsg_many()
|
/libuv/src/ |
H A D | idna.c | 71 static unsigned uv__utf8_decode1_slow(const char** p, in uv__utf8_decode1_slow() argument 82 switch (pe - *p) { in uv__utf8_decode1_slow() 87 b = (unsigned char) *(*p)++; in uv__utf8_decode1_slow() 88 c = (unsigned char) *(*p)++; in uv__utf8_decode1_slow() 89 d = (unsigned char) *(*p)++; in uv__utf8_decode1_slow() 97 c = (unsigned char) *(*p)++; in uv__utf8_decode1_slow() 98 d = (unsigned char) *(*p)++; in uv__utf8_decode1_slow() 108 d = (unsigned char) *(*p)++; in uv__utf8_decode1_slow() 141 assert(*p < pe); in uv__utf8_decode1() 143 a = (unsigned char) *(*p)++; in uv__utf8_decode1() [all …]
|
H A D | inet.c | 155 char tmp[UV__INET6_ADDRSTRLEN], *s, *p; in uv_inet_pton() local 157 p = strchr(src, '%'); in uv_inet_pton() 158 if (p != NULL) { in uv_inet_pton() 160 len = p - src; in uv_inet_pton()
|
H A D | uv-common.h | 69 #define uv__exchange_int_relaxed(p, v) \ argument 70 InterlockedExchangeNoFence((LONG volatile*)(p), v) 72 #define uv__exchange_int_relaxed(p, v) \ argument 73 atomic_exchange_explicit((_Atomic int*)(p), v, memory_order_relaxed)
|
H A D | idna.h | 23 unsigned uv__utf8_decode1(const char** p, const char* pe);
|
/libuv/docs/src/sphinx-plugins/ |
H A D | manpage.py | 32 p = re.compile("([a-zA-Z0-9_\.-_]+)\((\d)\)") 33 m = p.match(text)
|
/libuv/src/win/ |
H A D | util.c | 145 WCHAR* p; in uv__cwd() local 155 p = uv__malloc(t * sizeof(*p)); in uv__cwd() 156 if (p == NULL) in uv__cwd() 164 n = GetCurrentDirectoryW(t, p); in uv__cwd() 169 uv__free(p); in uv__cwd() 177 if (p[t] == L'\\' && !(n == 3 && p[1] == L':')) { in uv__cwd() 178 p[t] = L'\0'; in uv__cwd() 182 *buf = p; in uv__cwd()
|