Home
last modified time | relevance | path

Searched refs:r (Results 1 – 25 of 104) sorted by last modified time

12345

/unit/test/
H A Dtest_variables.py82 reg = r'^GET$'
87 reg = r'^POST$'
96 reg = r'^' + re.escape(req_uri) + r'$'
112 reg = r'^' + re.escape(expect) + r'$'
128 reg = r'^' + re.escape(expect) + r'$'
199 reg = r'^GET ' + re.escape(referer) + r'$'
222 reg = r'^GET ' + re.escape(user_agent) + r'$'
243 reg = r'^' + re.escape(expect) + r'$'
276 reg = r'^' + re.escape(expect) + r'$'
307 reg = r'^' + value + r'$'
[all …]
H A Dconftest.py201 for module in re.findall(r'module: ([a-zA-Z]+) (.*) ".*"$', log, re.M):
284 r'read signalfd\(4\) failed',
285 r'sendmsg.+failed',
286 r'recvmsg.+failed',
453 z_ppids = re.findall(r'Z\s*(\d+)', out)
487 alerts = re.findall(r'.+\[alert\].+', log)
589 if re.search(router_pid + r'\s+' + unit_pid + r'.*unit: router', l)
598 controller_pid + r'\s+' + unit_pid + r'.*unit: controller', l
707 r'\s*(\d+)\s*' + str(unit_instance['pid']) + r'.*' + name, output
713 return re.findall(str(unit_instance['pid']) + r'.*' + name, ps_output)
H A Dtest_static.py76 skip_alert(r'failed to apply new conf')
H A Dtest_php_application.py39 r = self.check_opcache()
416 r'exec: \/\w+', body
493 r'exec: \/\w+', body
510 r'exec: \/\w+', body
526 r'time: \d+', body
529 r'exec: \/\w+', body
536 r'012345', self.get()['body']
545 r'012345', self.get()['body']
786 r = self.check_opcache()
787 pid = r['headers']['X-Pid']
[all …]
H A Dtest_upstreams_rr.py77 status = re.findall(r'HTTP\/\d\.\d\s(\d\d\d)', resp)
309 m = re.search(r'HTTP/1.1 20(\d)', resp)
H A Dtest_status.py33 skip_alert(r'Python failed to import module "blah"')
/unit/src/python/
H A Dnxt_python_wsgi.c593 nxt_unit_request_t *r; in nxt_python_get_environ() local
595 r = pctx->req->request; in nxt_python_get_environ()
606 r->method_length)); in nxt_python_get_environ()
610 r->query_length)); in nxt_python_get_environ()
612 r->path_length)); in nxt_python_get_environ()
619 if (r->tls) { in nxt_python_get_environ()
636 for (i = 0; i < r->fields_count;) { in nxt_python_get_environ()
637 f = r->fields + i; in nxt_python_get_environ()
641 f2 = r->fields + j; in nxt_python_get_environ()
658 f = r->fields + r->content_length_field; in nxt_python_get_environ()
[all …]
H A Dnxt_python_asgi.c583 nxt_unit_request_t *r; in nxt_py_asgi_create_http_scope() local
599 r = req->request; in nxt_py_asgi_create_http_scope()
601 if (r->websocket_handshake) { in nxt_py_asgi_create_http_scope()
615 p = nxt_unit_sptr_get(&r->version); in nxt_py_asgi_create_http_scope()
630 v = PyUnicode_DecodeUTF8(nxt_unit_sptr_get(&r->path), r->path_length, in nxt_py_asgi_create_http_scope()
641 query = nxt_unit_sptr_get(&r->query); in nxt_py_asgi_create_http_scope()
643 if (r->query.offset != 0) { in nxt_py_asgi_create_http_scope()
668 v = nxt_py_asgi_create_address(&r->remote, r->remote_length, 0); in nxt_py_asgi_create_http_scope()
677 v = nxt_py_asgi_create_address(&r->local_addr, r->local_addr_length, 80); in nxt_py_asgi_create_http_scope()
695 f = r->fields + i; in nxt_py_asgi_create_http_scope()
[all …]
/unit/pkg/rpm/
H A Dunit.spec.in50 Provides: unit-r%{version}
144 getent group unit >/dev/null || groupadd -r unit
146 useradd -r -g unit -s /sbin/nologin \
H A Dunit.module.spec.in42 Requires: unit-r%%UNIT_VERSION%%
/unit/pkg/deb/debian/
H A Dcontrol.in17 Provides: unit-r%%UNIT_VERSION%%
/unit/pkg/deb/debian.module/
H A Dcontrol.in17 unit-r%%UNIT_VERSION%%%%MODULE_DEPENDS%%
/unit/src/perl/
H A Dnxt_perl_psgi.c619 r = req->request; in nxt_perl_psgi_env_create()
625 &r->method, r->method_length)); in nxt_perl_psgi_env_create()
627 &r->target, r->target_length)); in nxt_perl_psgi_env_create()
629 &r->path, r->path_length)); in nxt_perl_psgi_env_create()
668 &r->query, r->query_length)); in nxt_perl_psgi_env_create()
670 &r->version, r->version_length)); in nxt_perl_psgi_env_create()
672 &r->remote, r->remote_length)); in nxt_perl_psgi_env_create()
674 &r->local_addr, r->local_addr_length)); in nxt_perl_psgi_env_create()
677 &r->server_name, r->server_name_length)); in nxt_perl_psgi_env_create()
689 f = r->fields + r->content_length_field; in nxt_perl_psgi_env_create()
[all …]
/unit/src/
H A Dnxt_php_sapi.c960 p = nxt_cpymem(p, nxt_unit_sptr_get(&r->path), r->path_length); in nxt_php_do_301()
1135 f = r->fields + r->content_type_field;
1141 f = r->fields + r->cookie_field;
1147 f = r->fields + r->authorization_field;
1403 nxt_php_set_sptr(req, "PHP_SELF", &r->path, r->path_length,
1443 nxt_php_set_sptr(req, "REQUEST_URI", &r->target, r->target_length,
1445 nxt_php_set_sptr(req, "QUERY_STRING", &r->query, r->query_length,
1457 if (r->tls) {
1461 f_end = r->fields + r->fields_count;
1470 f = r->fields + r->content_length_field;
[all …]
H A Dnxt_http_route.c1306 ret = nxt_var_query_init(&r->var_query, r, r->mem_pool); in nxt_http_pass_var()
1339 nxt_http_request_t *r; in nxt_http_pass_var_ready() local
1341 r = obj; in nxt_http_pass_var_ready()
1364 nxt_http_request_t *r; in nxt_http_pass_var_error() local
1366 r = obj; in nxt_http_pass_var_error()
1578 ret = nxt_http_route_addr_rule(r, test->addr_rule, r->remote); in nxt_http_route_match()
1581 if (r->local == NULL && nxt_fast_path(r->proto.any != NULL)) { in nxt_http_route_match()
1582 nxt_http_proto[r->protocol].local_addr(task, r); in nxt_http_route_match()
1585 ret = nxt_http_route_addr_rule(r, test->addr_rule, r->local); in nxt_http_route_match()
1983 return nxt_http_route_test_rule(r, rule, r->args_decoded.start, in nxt_http_route_query()
[all …]
H A Dnxt_http_variables.c127 r = ctx; in nxt_http_var_request_time()
151 r = ctx; in nxt_http_var_method()
165 r = ctx; in nxt_http_var_request_uri()
178 r = ctx; in nxt_http_var_uri()
191 r = ctx; in nxt_http_var_host()
205 r = ctx; in nxt_http_var_remote_addr()
229 r = ctx; in nxt_http_var_time_local()
280 r = ctx; in nxt_http_var_request_line()
282 length = r->method->length + 1 + r->target.length + 1 + r->version.length; in nxt_http_var_request_line()
322 r = ctx; in nxt_http_var_body_bytes_sent()
[all …]
H A Dnxt_controller.c693 nxt_controller_request_t *r; in nxt_controller_conn_init() local
705 r->conn = c; in nxt_controller_conn_init()
723 c->socket.data = r; in nxt_controller_conn_init()
755 nxt_controller_request_t *r; in nxt_controller_conn_read() local
758 r = data; in nxt_controller_conn_read()
804 if (preread >= r->length) { in nxt_controller_conn_read()
888 r = data; in nxt_controller_conn_body_read()
894 read, r->length); in nxt_controller_conn_body_read()
896 if (read >= r->length) { in nxt_controller_conn_body_read()
1018 r = ctx; in nxt_controller_request_content_length()
[all …]
H A Dnxt_h1proto.c988 r->state->ready_handler(task, r, NULL); in nxt_h1p_request_body_read()
1679 r->state->error_handler(task, r, h1p); in nxt_h1p_request_error()
2201 r->state->error_handler(task, r, peer); in nxt_h1p_peer_connect()
2229 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_connected()
2247 r->state->error_handler(task, r, peer); in nxt_h1p_peer_refused()
2397 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_header_sent()
2577 r->state->error_handler(task, r, peer); in nxt_h1p_peer_header_read_done()
2708 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_body_process()
2752 r->state->error_handler(task, r, peer); in nxt_h1p_peer_error()
2776 r->state->error_handler(task, r, peer); in nxt_h1p_peer_send_timeout()
[all …]
H A Dnxt_router.c4170 r = obj; in nxt_http_request_send_body()
4371 nxt_event_engine_post(r->engine, &r->err_work); in nxt_router_app_port_error()
4968 r->err_work.obj = r; in nxt_router_process_http_request()
4994 r = obj; in nxt_router_http_request_error()
5013 r = data; in nxt_router_http_request_done()
5021 nxt_http_request_close_handler(task, r, r->proto.any); in nxt_router_http_request_done()
5198 + (r->path->start != r->target.start ? r->path->length + 1 : 0); in nxt_router_prepare_msg()
5238 p = nxt_cpymem(p, r->method->start, r->method->length); in nxt_router_prepare_msg()
5243 p = nxt_cpymem(p, r->version.start, r->version.length); in nxt_router_prepare_msg()
5274 p = nxt_cpymem(p, r->target.start, r->target.length); in nxt_router_prepare_msg()
[all …]
H A Dnxt_unit.c1290 nxt_unit_request_t *r; in nxt_unit_process_req_headers() local
1328 r = req->request; in nxt_unit_process_req_headers()
1330 req->content_length = r->content_length; in nxt_unit_process_req_headers()
1357 (int) r->method_length, in nxt_unit_process_req_headers()
1359 (int) r->target_length, in nxt_unit_process_req_headers()
1949 nxt_unit_request_t *r; in nxt_unit_request_group_dup_fields() local
1957 r = req->request; in nxt_unit_request_group_dup_fields()
1958 fields = r->fields; in nxt_unit_request_group_dup_fields()
1960 for (i = 0; i < r->fields_count; i++) { in nxt_unit_request_group_dup_fields()
1979 r->content_type_field = i; in nxt_unit_request_group_dup_fields()
[all …]
H A Dnxt_http.h241 nxt_http_request_t *r,
257 void (*body_read)(nxt_task_t *task, nxt_http_request_t *r);
258 void (*local_addr)(nxt_task_t *task, nxt_http_request_t *r);
328 nxt_buf_t *nxt_http_buf_last(nxt_http_request_t *r);
339 nxt_array_t *nxt_http_arguments_parse(nxt_http_request_t *r);
340 nxt_array_t *nxt_http_cookies_parse(nxt_http_request_t *r);
360 nxt_int_t nxt_http_route_addr_rule(nxt_http_request_t *r,
364 nxt_int_t nxt_http_route_test_rule(nxt_http_request_t *r,
389 nxt_http_request_t *r, nxt_http_action_t *action);
393 nxt_http_request_t *r, nxt_upstream_t *upstream);
[all …]
H A Dnxt_http_request.c87 r = ctx; in nxt_http_request_host()
204 r = ctx; in nxt_http_request_field()
219 r = ctx; in nxt_http_request_content_length()
285 return r; in nxt_http_request_create()
310 r = obj; in nxt_http_request_start()
545 r = obj; in nxt_http_request_ready()
589 r->server_name = r->host; in nxt_http_application_handler()
782 r = obj; in nxt_http_request_error_handler()
790 nxt_http_proto[r->protocol].discard(task, r, nxt_http_buf_last(r)); in nxt_http_request_error_handler()
805 r = obj; in nxt_http_request_close_handler()
[all …]
/unit/src/test/
H A Dnxt_unit_websocket_chat.c52 nxt_unit_request_t *r; in ws_chat_request_handler() local
55 r = req->request; in ws_chat_request_handler()
57 const char* target = nxt_unit_sptr_get(&r->target); in ws_chat_request_handler()
/unit/auto/
H A Dmake398 install -p -m u=rw,go=r $NXT_BUILD_DIR/$NXT_LIB_UNIT_STATIC \
402 install -p -m u=rw,go=r src/nxt_unit.h \
/unit/test/unit/
H A Dhttp.py209 m = re.search(r'(.*?\x0d\x0a?)\x0d\x0a?(.*)', resp, re.M | re.S)
218 r'^HTTP\/\d\.\d\s(\d+)|$', headers_lines.pop(0)
223 m = re.search(r'(.*)\:\s(.*)', line)

12345