Home
last modified time | relevance | path

Searched refs:m (Results 1 – 25 of 43) sorted by relevance

12

/unit/src/
H A Dnxt_murmur_hash.c15 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 Dnxt_port_memory_int.h91 ((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 Dnxt_clone.c249 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 Dnxt_unit.c2635 } 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 Dnxt_port_memory.c806 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 DPojoMethodMapping.java322 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 Dasgi.py4 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 Dasgi.py5 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 DAuthenticator.java55 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 Dasgi.py6 m = await receive()
7 body += m.get('body', b'')
8 if not m.get('more_body', False):
/unit/test/python/body_bytearray/
H A Dasgi.py6 m = await receive()
7 body += m.get('body', b'')
8 if not m.get('more_body', False):
/unit/test/unit/
H A Dhttp.py209 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 Dunit.go102 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 Dport.go34 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 Dasgi.py6 m = await receive()
7 body += m.get('body', b'')
8 if not m.get('more_body', False):
/unit/test/python/delayed/
H A Dasgi.py9 m = await receive()
10 body += m.get('body', b'')
11 if not m.get('more_body', False):
/unit/src/test/
H A Dnxt_utf8_test.c88 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 Dnxt_cq_test.c344 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 Dtest14 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 Dtest_respawn.py30 m = re.search(fr'\s*(\d+)\s*{ppid}.*{name}', output)
31 return None if m is None else m.group(1)
H A Dtest_proxy_chunked.py68 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 Dunit.spec.in127 %{__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 Dunit.example-python-app6 output = datetime.datetime.now().strftime("%Y-%m-%d %I:%M:%S %p")
/unit/pkg/rpm/rpmbuild/SOURCES/
H A Dunit.example-python-app6 output = datetime.datetime.now().strftime("%Y-%m-%d %I:%M:%S %p")
/unit/pkg/deb/debian.module/
H A Dunit.example-python-app6 output = datetime.datetime.now().strftime("%Y-%m-%d %I:%M:%S %p")

12