Home
last modified time | relevance | path

Searched refs:m (Results 1 – 25 of 41) sorted by last modified time

12

/unit/test/unit/
H A Dhttp.py206 m = re.search(r'(.*?\x0d\x0a?)\x0d\x0a?(.*)', resp, re.M | re.S)
208 if not m:
211 headers_text, body = m.group(1), m.group(2)
220 m = re.search(r'(.*)\:\s(.*)', line)
222 if m.group(1) not in headers:
223 headers[m.group(1)] = m.group(2)
225 elif isinstance(headers[m.group(1)], list):
226 headers[m.group(1)].append(m.group(2))
229 headers[m.group(1)] = [headers[m.group(1)], m.group(2)]
/unit/src/
H A Dnxt_router.c5416 nxt_free_map_t *m; in nxt_router_oosm_handler() local
5444 m = mmap_handler->hdr->free_map; in nxt_router_oosm_handler()
5447 if (m[mi] != 0) { in nxt_router_oosm_handler()
5451 i, mi, m[mi]); in nxt_router_oosm_handler()
H A Dnxt_http_route.c364 nxt_http_route_match_t *match, **m; in nxt_http_route_create() local
375 m = &route->match[0]; in nxt_http_route_create()
385 *m++ = match; in nxt_http_route_create()
H A Dnxt_clone.c263 nxt_clone_map_entry_t m; in nxt_clone_vldt_credential_uidmap() local
294 m = map->map[i]; in nxt_clone_vldt_credential_uidmap()
297 && creds->uid < (nxt_uid_t) (m.container + m.size)) in nxt_clone_vldt_credential_uidmap()
317 nxt_clone_map_entry_t m; in nxt_clone_vldt_credential_gidmap() local
345 m = map->map[0]; in nxt_clone_vldt_credential_gidmap()
358 m.size); in nxt_clone_vldt_credential_gidmap()
396 m = map->map[j]; in nxt_clone_vldt_credential_gidmap()
399 && creds->base_gid < (nxt_gid_t) (m.container+m.size)) in nxt_clone_vldt_credential_gidmap()
405 && creds->gids[i] < (nxt_gid_t) (m.container+m.size)) in nxt_clone_vldt_credential_gidmap()
419 m = map->map[i]; in nxt_clone_vldt_credential_gidmap()
[all …]
H A Dnxt_unit.c2620 } m; in nxt_unit_mmap_buf_send() local
2644 m.msg.mmap = hdr != NULL && m.mmap_msg.size > 0; in nxt_unit_mmap_buf_send()
2645 m.msg.nf = 0; in nxt_unit_mmap_buf_send()
2646 m.msg.mf = 0; in nxt_unit_mmap_buf_send()
2706 memcpy(buf->start - sizeof(m.msg), &m.msg, sizeof(m.msg)); in nxt_unit_mmap_buf_send()
2710 (int) (sizeof(m.msg) + m.mmap_msg.size)); in nxt_unit_mmap_buf_send()
4304 } m; in nxt_unit_get_mmap() local
5340 } m; in nxt_unit_send_port() local
5361 res = nxt_unit_port_send(ctx, dst, &m, sizeof(m), &oob); in nxt_unit_send_port()
5843 &m, sizeof(m), NULL); in nxt_unit_quit()
[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_port_socket.c22 static nxt_port_send_msg_t *nxt_port_msg_alloc(const nxt_port_send_msg_t *m);
335 nxt_port_msg_alloc(const nxt_port_send_msg_t *m) in nxt_port_msg_alloc() argument
344 *msg = *m; in nxt_port_msg_alloc()
377 nxt_port_method_t m; in nxt_port_write_handler() local
418 m = nxt_port_mmap_get_method(task, port, msg->buf); in nxt_port_write_handler()
420 if (m == NXT_PORT_METHOD_MMAP) { in nxt_port_write_handler()
436 if (m == NXT_PORT_METHOD_MMAP && plain_size > PORT_MMAP_MIN_SIZE) { in nxt_port_write_handler()
440 m = NXT_PORT_METHOD_PLAIN; in nxt_port_write_handler()
458 m == NXT_PORT_METHOD_MMAP); in nxt_port_write_handler()
H A Dnxt_h1proto.c641 u_char *m; in nxt_h1p_header_process() local
664 m = h1p->parser.method.start; in nxt_h1p_header_process()
667 || m[0] != 'G' in nxt_h1p_header_process()
668 || m[1] != 'E' in nxt_h1p_header_process()
669 || m[2] != 'T')) in nxt_h1p_header_process()
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/pkg/rpm/
H A Dunit.spec.in116 %{__install} -m 644 -p %{SOURCE4} \
119 %{__install} -m 644 -p %{SOURCE3} \
121 %{__install} -m 644 -p CHANGES \
123 %{__install} -m 644 -p NOTICE \
125 %{__install} -m 644 -p README.md \
127 %{__install} -m 644 -p CONTRIBUTING.md \
131 %{__install} -p -D -m 0644 %{SOURCE1} %{buildroot}%{_unitdir}/unit.service
132 %{__install} -p -D -m 0644 %{SOURCE2} %{buildroot}%{_unitdir}/unit-debug.service
H A Dunit.module.spec.in90 %{__install} -m 644 -p %{SOURCE100} \
93 %{__install} -m 644 -p NOTICE \
/unit/
H A DCONTRIBUTING.md89 - Don't rely on command-line commit messages with `-m`; use the editor instead
/unit/test/
H A Dtest_upstreams_rr.py310 m = re.search(r'HTTP/1.1 20(\d)', resp)
311 assert m is not None, 'status'
312 resps[int(m.group(1))] += 1
H A Dtest_respawn.py26 m = re.search(r'\s*(\d+)\s*' + str(ppid) + r'.*' + name, output)
27 return None if m is None else m.group(1)
H A Dtest_proxy_chunked.py51 m = re.search('\x0d\x0a\x0d\x0a(.*)', data, re.M | re.S)
52 if m is not None:
53 body = m.group(1)
H A Dtest_proxy.py48 m = re.search(r'X-Len: (\d+)', data)
49 if m:
50 to_send += b'X' * int(m.group(1))
H A Dconftest.py183 m = re.search('controller started', log)
185 if m is None:
190 if m is None:
694 m = re.search(
697 return None if m is None else m.group(1)
H A Dtest_python_procman.py25 for m in re.findall(
28 pids.add(re.search(r'^\s*(\d+)', m).group(1))
/unit/test/unit/applications/
H A Dwebsockets.py67 return bytes(b ^ m for b, m in zip(data, itertools.cycle(mask)))
/unit/src/java/nginx/unit/
H A DContext.java707 for (FilterMap m : filter_maps_) { in CtxFilterChain()
708 if (filters.indexOf(m.filter_) != -1) { in CtxFilterChain()
712 if (!m.dtypes_.contains(dtype)) { in CtxFilterChain()
716 if (m.pattern_.match(path)) { in CtxFilterChain()
717 filters.add(m.filter_); in CtxFilterChain()
719 trace("add filter (matched): " + m.filter_.getName()); in CtxFilterChain()
723 for (FilterMap m : servlet.filters_) { in CtxFilterChain()
724 if (filters.indexOf(m.filter_) != -1) { in CtxFilterChain()
728 if (!m.dtypes_.contains(dtype)) { in CtxFilterChain()
732 filters.add(m.filter_); in CtxFilterChain()
[all …]
/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/go/
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/auto/
H A Dmake394 install -p -m u=rw,go=r $NXT_BUILD_DIR/$NXT_LIB_UNIT_STATIC \
397 install -p -m u=rw,go=r src/nxt_unit.h \
/unit/auto/modules/
H A Djava542 install -p -m 0644 $NXT_BUILD_DIR/$NXT_UNIT_JAR \$(DESTDIR)$NXT_JARS/
543 install -p -m 0644 $NXT_BUILD_DIR/$NXT_WS_API_JAR \$(DESTDIR)$NXT_JARS/
633 install -p -m 0644 $NXT_JAVA_INSTALL_JARS \$(DESTDIR)$NXT_JARS/
/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':

12