/unit/src/ |
H A D | nxt_http_route_addr.c | 34 if (addr.length > 0 && addr.start[0] == '!') { in nxt_http_route_addr_pattern_parse() 50 if (addr.start[0] == '*' && addr.start[1] == ':') { in nxt_http_route_addr_pattern_parse() 72 end = addr.start + addr.length; in nxt_http_route_addr_pattern_parse() 79 addr.length = port.start - addr.start; in nxt_http_route_addr_pattern_parse() 86 delim = nxt_memchr(addr.start, '-', addr.length); in nxt_http_route_addr_pattern_parse() 98 len = addr.start + addr.length - delim - 1; in nxt_http_route_addr_pattern_parse() 127 addr.length = delim - addr.start; in nxt_http_route_addr_pattern_parse() 194 delim = nxt_memchr(addr.start, ':', addr.length); in nxt_http_route_addr_pattern_parse() 198 addr.length = delim - addr.start; in nxt_http_route_addr_pattern_parse() 203 delim = nxt_memchr(addr.start, '-', addr.length); in nxt_http_route_addr_pattern_parse() [all …]
|
H A D | nxt_sockaddr.c | 535 if (addr[i] == 0 && addr[i + 1] == 0) { in nxt_inet6_ntop() 568 || (zero_groups == 7 && addr[14] != 0 && addr[15] != 1)) in nxt_inet6_ntop() 594 addr[12], addr[13], addr[14], addr[15]); in nxt_inet6_ntop() 636 } else if (addr->start[0] == '[' || nxt_inet6_probe(addr)) { in nxt_sockaddr_parse_optport() 745 end = addr->start + addr->length; in nxt_sockaddr_inet6_parse() 805 p = nxt_memchr(addr->start, ':', addr->length); in nxt_sockaddr_inet_parse() 828 length = (addr->start + addr->length) - p; in nxt_sockaddr_inet_parse() 987 addr = jbs->addr.start + 1; in nxt_job_sockaddr_inet6_parse() 1195 addr = 0; in nxt_inet_addr() 1214 addr = (addr << 8) + octet; in nxt_inet_addr() [all …]
|
H A D | nxt_mem_map.c | 11 nxt_mem_mmap(void *addr, size_t len, nxt_uint_t protection, nxt_uint_t flags, in nxt_mem_mmap() argument 16 p = mmap(addr, len, protection, flags, fd, offset); in nxt_mem_mmap() 20 addr, len, protection, flags, fd, offset, p); in nxt_mem_mmap() 24 addr, len, protection, flags, fd, offset, nxt_errno); in nxt_mem_mmap() 32 nxt_mem_munmap(void *addr, size_t len) in nxt_mem_munmap() argument 34 if (nxt_fast_path(munmap(addr, len) == 0)) { in nxt_mem_munmap() 35 nxt_thread_log_debug("munmap(%p, %uz)", addr, len); in nxt_mem_munmap() 38 nxt_thread_log_alert("munmap(%p, %uz) failed %E", addr, len, nxt_errno); in nxt_mem_munmap()
|
H A D | nxt_mem_map.h | 49 #define nxt_mem_map(addr, ctx, len, protection, flags, fd, offset) \ argument 50 nxt_mem_mmap(addr, len, protection, flags, fd, offset) 53 #define nxt_mem_unmap(addr, ctx, len) \ argument 54 nxt_mem_munmap(addr, len) 57 NXT_EXPORT void *nxt_mem_mmap(void *addr, size_t len, nxt_uint_t protection, 59 NXT_EXPORT void nxt_mem_munmap(void *addr, size_t len);
|
H A D | nxt_sockaddr.h | 63 nxt_str_t addr; member 93 NXT_EXPORT nxt_sockaddr_t *nxt_sockaddr_parse(nxt_mp_t *mp, nxt_str_t *addr); 95 nxt_str_t *addr); 102 NXT_EXPORT nxt_bool_t nxt_inet6_probe(nxt_str_t *addr);
|
H A D | nxt_stream_module.c | 38 up->addr = rt->upstream; in nxt_stream_connection_init() 41 nxt_str_set(&up->addr, "127.0.0.1:8080"); in nxt_stream_connection_init()
|
H A D | nxt_http_route_addr.h | 66 } addr; member
|
H A D | nxt_test_build.c | 48 accept4(int sockfd, struct sockaddr *addr, socklen_t *addrlen, int flags) in accept4() argument
|
H A D | nxt_http_route.c | 1739 match = (nxt_memcmp(&sin->sin_addr, &p->addr.v4.start, in nxt_http_route_addr_pattern_match() 1745 match = (nxt_memcmp(&sin->sin_addr, &p->addr.v4.start, in nxt_http_route_addr_pattern_match() 1747 && nxt_memcmp(&sin->sin_addr, &p->addr.v4.end, in nxt_http_route_addr_pattern_match() 1752 match = ((sin->sin_addr.s_addr & p->addr.v4.end) in nxt_http_route_addr_pattern_match() 1753 == p->addr.v4.start); in nxt_http_route_addr_pattern_match() 1785 match = (nxt_memcmp(&sin6->sin6_addr, &p->addr.v6.start, in nxt_http_route_addr_pattern_match() 1791 match = (nxt_memcmp(&sin6->sin6_addr, &p->addr.v6.start, in nxt_http_route_addr_pattern_match() 1793 && nxt_memcmp(&sin6->sin6_addr, &p->addr.v6.end, in nxt_http_route_addr_pattern_match() 1800 & p->addr.v6.end.s6_addr[i]) in nxt_http_route_addr_pattern_match() 1801 == p->addr.v6.start.s6_addr[i]); in nxt_http_route_addr_pattern_match()
|
H A D | nxt_test_build.h | 91 int accept4(int sockfd, struct sockaddr *addr, socklen_t *addrlen, int flags);
|
H A D | nxt_http_request.c | 469 nxt_str_t addr; in nxt_http_request_client_ip_sockaddr() local 472 addr.start = start; in nxt_http_request_client_ip_sockaddr() 473 addr.length = len; in nxt_http_request_client_ip_sockaddr() 475 sa = nxt_sockaddr_parse_optport(r->mem_pool, &addr); in nxt_http_request_client_ip_sockaddr()
|
H A D | nxt_mem_zone.c | 94 #define nxt_mem_zone_addr_page(zone, addr) \ argument 95 &zone->pages[((u_char *) addr - zone->start) >> zone->page_size_shift]
|
/unit/test/ |
H A D | test_access_log.py | 109 addr = option.temp_dir + '/sock' 112 {"unix:" + addr: {"pass": "applications/empty"}}, 'listeners' 115 self.get(sock_type='unix', addr=addr)
|
H A D | test_settings.py | 170 def req(addr, data_len): argument 172 sock.connect(addr) 204 addr = temp_dir + '/sock' 207 {"unix:" + addr: {'application': 'body_generate'}}, 'listeners' 212 data = req(addr, data_len) 218 data = req(addr, data_len)
|
H A D | test_configuration.py | 10 def try_addr(self, addr): argument 13 "listeners": {addr: {"pass": "routes"}},
|
H A D | test_proxy.py | 348 addr = temp_dir + '/sock' 353 "unix:" + addr: {'application': 'mirror'}, 359 [{"action": {"proxy": 'http://unix:' + addr}}], 'routes'
|
H A D | test_routing.py | 1723 addr = temp_dir + '/sock' 1726 {"unix:" + addr: {"pass": "routes"}}, 'listeners' 1731 self.get(sock_type='unix', addr=addr)['status'] == 200 1736 self.get(sock_type='unix', addr=addr)['status'] == 200
|
H A D | conftest.py | 522 addr=sock, 533 http.get(url='/certificates', sock_type='unix', addr=sock)['body'] 543 addr=sock,
|
H A D | test_static.py | 395 addr=temp_dir + '/control.unit.sock',
|
/unit/test/unit/check/ |
H A D | chroot.py | 15 addr=option.temp_dir + '/control.unit.sock',
|
H A D | isolation.py | 136 addr=option.temp_dir + '/control.unit.sock',
|
/unit/go/ |
H A D | unit.go | 141 func ListenAndServe(addr string, handler http.Handler) error { 153 return http.ListenAndServe(addr, handler)
|
/unit/test/unit/ |
H A D | http.py | 28 addr = '::1' if sock_type == 'ipv6' else '127.0.0.1' 30 addr = kwargs['addr'] 51 connect_args = addr if sock_type == 'unix' else (addr, port)
|