/unit/src/ |
H A D | nxt_murmur_hash.c | 15 const uint32_t m = 0x5BD1E995; in nxt_murmur_hash2() local 26 k *= m; in nxt_murmur_hash2() 28 k *= m; in nxt_murmur_hash2() 30 h *= m; in nxt_murmur_hash2() 46 h *= m; in nxt_murmur_hash2() 50 h *= m; in nxt_murmur_hash2() 64 const uint32_t m = 0x5BD1E995; in nxt_murmur_hash2_uint32() local 73 k *= m; in nxt_murmur_hash2_uint32() 75 k *= m; in nxt_murmur_hash2_uint32() 78 h *= m; in nxt_murmur_hash2_uint32() [all …]
|
H A D | nxt_port_memory_int.h | 91 ((m[FREE_IDX(c)] & FREE_MASK(c)) == 0) 94 nxt_port_mmap_set_chunk_busy(nxt_free_map_t *m, nxt_chunk_id_t c); 100 nxt_port_mmap_set_chunk_free(nxt_free_map_t *m, nxt_chunk_id_t c); 125 nxt_port_mmap_get_free_chunk(nxt_free_map_t *m, nxt_chunk_id_t *c) in nxt_port_mmap_get_free_chunk() argument 138 bits = m[i] & mask; in nxt_port_mmap_get_free_chunk() 149 if (nxt_port_mmap_chk_set_chunk_busy(m, chunk)) { in nxt_port_mmap_get_free_chunk() 161 nxt_port_mmap_set_chunk_busy(nxt_free_map_t *m, nxt_chunk_id_t c) in nxt_port_mmap_set_chunk_busy() argument 163 nxt_atomic_and_fetch(m + FREE_IDX(c), ~FREE_MASK(c)); in nxt_port_mmap_set_chunk_busy() 173 f = m + FREE_IDX(c); in nxt_port_mmap_chk_set_chunk_busy() 190 nxt_port_mmap_set_chunk_free(nxt_free_map_t *m, nxt_chunk_id_t c) in nxt_port_mmap_set_chunk_free() argument [all …]
|
H A D | nxt_clone.c | 249 nxt_clone_map_entry_t m; in nxt_clone_vldt_credential_uidmap() local 280 m = map->map[i]; in nxt_clone_vldt_credential_uidmap() 283 && creds->uid < (nxt_uid_t) (m.container + m.size)) in nxt_clone_vldt_credential_uidmap() 303 nxt_clone_map_entry_t m; in nxt_clone_vldt_credential_gidmap() local 331 m = map->map[0]; in nxt_clone_vldt_credential_gidmap() 344 m.size); in nxt_clone_vldt_credential_gidmap() 382 m = map->map[j]; in nxt_clone_vldt_credential_gidmap() 385 && creds->base_gid < (nxt_gid_t) (m.container + m.size)) in nxt_clone_vldt_credential_gidmap() 391 && creds->gids[i] < (nxt_gid_t) (m.container + m.size)) in nxt_clone_vldt_credential_gidmap() 405 m = map->map[i]; in nxt_clone_vldt_credential_gidmap() [all …]
|
H A D | nxt_unit.c | 2635 } m; in nxt_unit_mmap_buf_send() local 2659 m.msg.mmap = hdr != NULL && m.mmap_msg.size > 0; in nxt_unit_mmap_buf_send() 2660 m.msg.nf = 0; in nxt_unit_mmap_buf_send() 2661 m.msg.mf = 0; in nxt_unit_mmap_buf_send() 2721 memcpy(buf->start - sizeof(m.msg), &m.msg, sizeof(m.msg)); in nxt_unit_mmap_buf_send() 2725 (int) (sizeof(m.msg) + m.mmap_msg.size)); in nxt_unit_mmap_buf_send() 4319 } m; in nxt_unit_get_mmap() local 5355 } m; in nxt_unit_send_port() local 5376 res = nxt_unit_port_send(ctx, dst, &m, sizeof(m), &oob); in nxt_unit_send_port() 5858 &m, sizeof(m), NULL); in nxt_unit_quit() [all …]
|
H A D | nxt_port_memory.c | 806 nxt_port_method_t m; in nxt_port_mmap_get_method() local 808 m = NXT_PORT_METHOD_ANY; in nxt_port_mmap_get_method() 817 if (m == NXT_PORT_METHOD_PLAIN) { in nxt_port_mmap_get_method() 825 if (m == NXT_PORT_METHOD_ANY) { in nxt_port_mmap_get_method() 828 m = NXT_PORT_METHOD_MMAP; in nxt_port_mmap_get_method() 831 if (m == NXT_PORT_METHOD_MMAP) { in nxt_port_mmap_get_method() 836 m = NXT_PORT_METHOD_PLAIN; in nxt_port_mmap_get_method() 841 if (m == NXT_PORT_METHOD_ANY) { in nxt_port_mmap_get_method() 844 m = NXT_PORT_METHOD_PLAIN; in nxt_port_mmap_get_method() 849 return m; in nxt_port_mmap_get_method()
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | PojoMethodMapping.java | 322 type, m.getName(), m.getClass().getName())); in getPathParams() 329 m.getName(), m.getDeclaringClass().getName())); in getPathParams() 385 this.m = m; in MessageHandlerInfo() 498 m.getName(), m.getDeclaringClass().getName())); in MessageHandlerInfo() 507 m.getName(), m.getDeclaringClass().getName())); in MessageHandlerInfo() 516 m.getName(), m.getDeclaringClass().getName())); in MessageHandlerInfo() 568 m.getName(), m.getDeclaringClass().getName())); in MessageHandlerInfo() 573 m.getName(), m.getDeclaringClass().getName())); in MessageHandlerInfo() 578 m.getName(), m.getDeclaringClass().getName())); in MessageHandlerInfo() 583 m.getName(), m.getDeclaringClass().getName())); in MessageHandlerInfo() [all …]
|
/unit/test/python/websockets/mirror/ |
H A D | asgi.py | 4 m = await receive() 5 if m['type'] == 'websocket.connect': 8 if m['type'] == 'websocket.receive': 12 'bytes': m.get('bytes', None), 13 'text': m.get('text', None), 17 if m['type'] == 'websocket.disconnect':
|
/unit/test/python/websockets/subprotocol/ |
H A D | asgi.py | 5 m = await receive() 6 if m['type'] == 'websocket.connect': 19 if m['type'] == 'websocket.receive': 23 'bytes': m.get('bytes', None), 24 'text': m.get('text', None), 28 if m['type'] == 'websocket.disconnect':
|
/unit/src/java/nginx/unit/websocket/ |
H A D | Authenticator.java | 55 Matcher m = pattern.matcher(WWWAuthenticate); in parseWWWAuthenticateHeader() local 58 while (m.find()) { in parseWWWAuthenticateHeader() 59 String key = m.group(1); in parseWWWAuthenticateHeader() 60 String qtedValue = m.group(3); in parseWWWAuthenticateHeader() 61 String value = m.group(4); in parseWWWAuthenticateHeader()
|
/unit/test/python/mirror/ |
H A D | asgi.py | 6 m = await receive() 7 body += m.get('body', b'') 8 if not m.get('more_body', False):
|
/unit/test/python/body_bytearray/ |
H A D | asgi.py | 6 m = await receive() 7 body += m.get('body', b'') 8 if not m.get('more_body', False):
|
/unit/test/unit/ |
H A D | http.py | 209 m = re.search(r'(.*?\x0d\x0a?)\x0d\x0a?(.*)', resp, re.M | re.S) 211 if not m: 214 headers_text, body = m.group(1), m.group(2) 223 m = re.search(r'(.*)\:\s(.*)', line) 225 if m.group(1) not in headers: 226 headers[m.group(1)] = m.group(2) 228 elif isinstance(headers[m.group(1)], list): 229 headers[m.group(1)].append(m.group(2)) 232 headers[m.group(1)] = [headers[m.group(1)], m.group(2)]
|
/unit/go/ |
H A D | unit.go | 102 m map[uintptr]*http.Handler member 110 if handler_registry_.m == nil { 111 handler_registry_.m = make(map[uintptr]*http.Handler) 117 handler_registry_.m[h] = handler 128 return *handler_registry_.m[h] 134 if handler_registry_.m != nil { 135 delete(handler_registry_.m, h)
|
H A D | port.go | 34 m map[port_key]*port member 41 res := port_registry_.m[key] 50 if port_registry_.m == nil { 51 port_registry_.m = make(map[port_key]*port) 54 old := port_registry_.m[p.key] 57 port_registry_.m[p.key] = p 135 if port_registry_.m != nil { 136 delete(port_registry_.m, key)
|
/unit/test/python/variables/ |
H A D | asgi.py | 6 m = await receive() 7 body += m.get('body', b'') 8 if not m.get('more_body', False):
|
/unit/test/python/delayed/ |
H A D | asgi.py | 9 m = await receive() 10 body += m.get('body', b'') 11 if not m.get('more_body', False):
|
/unit/src/test/ |
H A D | nxt_utf8_test.c | 88 nxt_uint_t i, k, l, m; in nxt_utf8_test() local 168 for (m = 0; m < 256; m++) { in nxt_utf8_test() 169 utf8[3] = m; in nxt_utf8_test()
|
H A D | nxt_cq_test.c | 344 double *stats, m, c; in main() local 539 m = mean(stats + k - STAT_ITER, STAT_ITER); in main() 540 c = cov(stats + k - STAT_ITER, m, STAT_ITER); in main() 546 (int) k + 1, times[k], mopsec[k], m, c); in main() 551 (int) k + 1, times[k], mopsec[k], m, c); in main() 559 if (fabs(stats[i] - m) < fabs(stats[rk] - m)) { in main()
|
/unit/auto/os/ |
H A D | test | 14 NXT_SYSTEM_PLATFORM=`uname -m 2>/dev/null` 22 NXT_SYSTEM_PLATFORM=`uname -m 2>/dev/null` 43 NXT_SYSTEM_PLATFORM=`uname -m 2>/dev/null` 59 NXT_SYSTEM_PLATFORM=`uname -m 2>/dev/null` 83 NXT_SYSTEM_PLATFORM=`uname -m 2>/dev/null`
|
/unit/test/ |
H A D | test_respawn.py | 30 m = re.search(fr'\s*(\d+)\s*{ppid}.*{name}', output) 31 return None if m is None else m.group(1)
|
H A D | test_proxy_chunked.py | 68 m = re.search('\x0d\x0a\x0d\x0a(.*)', data, re.M | re.S) 69 if m is not None: 70 body = m.group(1)
|
/unit/pkg/rpm/ |
H A D | unit.spec.in | 127 %{__install} -m 644 -p %{SOURCE4} \ 130 %{__install} -m 644 -p %{SOURCE3} \ 132 %{__install} -m 644 -p CHANGES \ 134 %{__install} -m 644 -p NOTICE \ 136 %{__install} -m 644 -p README.md \ 138 %{__install} -m 644 -p CONTRIBUTING.md \ 142 %{__install} -p -D -m 0644 %{SOURCE1} %{buildroot}%{_unitdir}/unit.service 143 %{__install} -p -D -m 0644 %{SOURCE2} %{buildroot}%{_unitdir}/unit-debug.service 147 %{__install} -m 644 pkg/contrib/libunit-wasm/src/c/libunit-wasm.a %{buildroot}%{_libdir}/ 148 %{__install} -m 644 pkg/contrib/libunit-wasm/src/c/include/unit/unit-wasm.h %{buildroot}%{_included…
|
/unit/pkg/deb/debian/ |
H A D | unit.example-python-app | 6 output = datetime.datetime.now().strftime("%Y-%m-%d %I:%M:%S %p")
|
/unit/pkg/rpm/rpmbuild/SOURCES/ |
H A D | unit.example-python-app | 6 output = datetime.datetime.now().strftime("%Y-%m-%d %I:%M:%S %p")
|
/unit/pkg/deb/debian.module/ |
H A D | unit.example-python-app | 6 output = datetime.datetime.now().strftime("%Y-%m-%d %I:%M:%S %p")
|