| /unit/src/ |
| H A D | nxt_unit.c | 4428 lhq->proto = &lvlhsh_processes_proto; in nxt_unit_process_lhq_pid()
6399 lhq->proto = &lvlhsh_ports_proto; in nxt_unit_port_hash_lhq()
6495 lhq.proto = &lvlhsh_requests_proto; in nxt_unit_request_hash_add()
6531 lhq.proto = &lvlhsh_requests_proto; in nxt_unit_request_hash_find()
|
| H A D | nxt_port_socket.c | 1100 lhq.proto = &lvlhsh_frag_proto; in nxt_port_frag_start()
1150 lhq.proto = &lvlhsh_frag_proto; in nxt_port_frag_find()
|
| H A D | nxt_http_static.c | 873 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_http_static_buf_completion()
1044 lhq.proto = &nxt_http_static_mtypes_hash_proto; in nxt_http_static_mtypes_hash_add()
1061 lhq.proto = &nxt_http_static_mtypes_hash_proto; in nxt_http_static_mtype_get()
|
| H A D | nxt_http_request.c | 600 if (nxt_fast_path(r->proto.any != NULL)) { in nxt_http_request_proto_info()
609 if (nxt_fast_path(r->proto.any != NULL)) { in nxt_http_request_read_body()
677 if (nxt_fast_path(r->proto.any != NULL)) { in nxt_http_request_header_send()
693 if (r->proto.any != NULL) { in nxt_http_request_ws_frame_start()
775 nxt_http_proto_t proto; in nxt_http_request_error_handler() local
779 proto.any = data; in nxt_http_request_error_handler()
785 if (nxt_fast_path(proto.any != NULL)) { in nxt_http_request_error_handler()
794 nxt_http_proto_t proto; in nxt_http_request_close_handler() local
801 proto.any = data; in nxt_http_request_close_handler()
817 r->proto.any = NULL; in nxt_http_request_close_handler()
[all …]
|
| H A D | nxt_http_parse.c | 1191 lhq.proto = &nxt_http_fields_hash_proto; in nxt_http_fields_hash()
1225 nxt_lvlhsh_proto_t proto; in nxt_http_fields_hash_collisions() local
1228 proto = nxt_http_fields_hash_proto; in nxt_http_fields_hash_collisions()
1229 proto.test = nxt_http_field_hash_collision; in nxt_http_fields_hash_collisions()
1232 lhq.proto = &proto; in nxt_http_fields_hash_collisions()
|
| H A D | nxt_http_parse.h | 141 lhq.proto = &nxt_http_fields_hash_proto; in nxt_http_field_process()
|
| H A D | nxt_http.h | 119 nxt_http_proto_t proto; member
133 nxt_http_proto_t proto; member
260 nxt_off_t (*body_bytes_sent)(nxt_task_t *task, nxt_http_proto_t proto);
262 void (*close)(nxt_task_t *task, nxt_http_proto_t proto,
|
| H A D | nxt_conf.c | 1660 lhq.proto = &nxt_conf_object_hash_proto; in nxt_conf_object_hash_add()
|
| H A D | nxt_router.c | 68 uint8_t proto; /* 1 bit */ member
75 uint8_t proto; /* 1 bit */ member
471 app_joint_rpc->proto = (b != NULL); in nxt_router_start_app_process_handler()
2362 lhq.proto = &nxt_router_apps_hash_proto; in nxt_router_apps_hash_add()
2387 lhq.proto = &nxt_router_apps_hash_proto; in nxt_router_apps_hash_get()
2864 rpc->proto = (b != NULL); in nxt_router_app_rpc_create()
2906 if (rpc->proto) { in nxt_router_app_prefork_ready()
2963 if (rpc->proto) { in nxt_router_app_prefork_error()
3831 bytes = nxt_http_proto[r->protocol].body_bytes_sent(task, r->proto); in nxt_router_access_log_writer()
4580 if (app_joint_rpc->proto) { in nxt_router_app_port_ready()
[all …]
|
| H A D | nxt_http_route.c | 1577 if (r->local == NULL && nxt_fast_path(r->proto.any != NULL)) { in nxt_http_route_match()
|
| H A D | nxt_h1proto.c | 55 nxt_http_proto_t proto);
487 r->proto.h1 = h1p; in nxt_h1p_conn_request_init()
853 h1p = r->proto.h1; in nxt_h1p_request_body_read()
1227 h1p = r->proto.h1; in nxt_h1p_request_header_send()
1462 h1p = r->proto.h1; in nxt_h1p_request_send()
1549 h1p = proto.h1; in nxt_h1p_request_body_bytes_sent()
1568 h1p = r->proto.h1; in nxt_h1p_request_discard()
1692 h1p = proto.h1; in nxt_h1p_request_close()
2166 peer->proto.h1 = h1p; in nxt_h1p_peer_connect()
2307 c = peer->proto.h1->conn; in nxt_h1p_peer_header_send()
[all …]
|
| H A D | nxt_conf_validation.c | 1801 nxt_str_t proto; in nxt_conf_vldt_python_protocol() local
1806 nxt_conf_get_string(value, &proto); in nxt_conf_vldt_python_protocol()
1808 if (nxt_strstr_eq(&proto, &wsgi) || nxt_strstr_eq(&proto, &asgi)) { in nxt_conf_vldt_python_protocol()
|
| H A D | nxt_var.c | 112 lhq.proto = &nxt_var_hash_proto; in nxt_var_hash_find()
137 lhq.proto = &nxt_var_cache_proto; in nxt_var_cache_find()
158 lhq.proto = &nxt_var_cache_proto; in nxt_var_cache_add()
172 lhq.proto = &nxt_var_hash_proto; in nxt_var_register()
|
| H A D | nxt_port_rpc.c | 77 lhq->proto = &lvlhsh_rpc_reg_proto; in nxt_port_rpc_lhq_stream()
87 lhq->proto = &lvlhsh_rpc_reg_proto; in nxt_port_rpc_lhq_peer()
|
| H A D | nxt_openssl.c | 1001 lhq.proto = &nxt_openssl_bundle_hash_proto;
1122 lhq.proto = &nxt_openssl_bundle_hash_proto;
|
| H A D | nxt_vector.h | 32 const nxt_mem_proto_t *proto, void *pool);
34 size_t item_size, const nxt_mem_proto_t *proto, void *pool);
36 const nxt_mem_proto_t *proto, void *pool);
38 const nxt_mem_proto_t *proto, void *pool);
40 const nxt_mem_proto_t *proto, void *pool);
|
| H A D | nxt_lvlhsh.h | 94 const nxt_lvlhsh_proto_t *proto; member
103 const nxt_lvlhsh_proto_t *proto; member
167 (lhe)->proto = _proto; \
184 const nxt_lvlhsh_proto_t *proto);
193 const nxt_lvlhsh_proto_t *proto, void *pool);
|
| H A D | nxt_lvlhsh.c | 75 proto->bucket_size
359 proto = lhq->proto; in nxt_lvlhsh_bucket_insert()
462 proto = lhq->proto; in nxt_lvlhsh_convert_bucket_to_level()
490 q.proto = proto; in nxt_lvlhsh_convert_bucket_to_level()
560 proto = lhq->proto; in nxt_lvlhsh_bucket_convertion_insert()
607 proto = lhq->proto; in nxt_lvlhsh_free_level()
617 proto->free(lhq->pool, nxt_lvlhsh_bucket(proto, level[i])); in nxt_lvlhsh_free_level()
692 proto = lhq->proto; in nxt_lvlhsh_bucket_delete()
871 peek.proto = proto; in nxt_lvlhsh_peek()
955 proto = peek->proto; in nxt_lvlhsh_bucket_peek()
[all …]
|
| H A D | nxt_fastcgi_source.c | 580 lhq.proto = &nxt_upstream_header_hash_proto; in nxt_fastcgi_source_header_process()
|
| H A D | nxt_cache.c | 49 static const nxt_lvlhsh_proto_t proto nxt_aligned(64) = { in nxt_cache_shm_create()
63 cache->proto = &proto; in nxt_cache_shm_create()
82 static const nxt_lvlhsh_proto_t proto nxt_aligned(64) = { in nxt_cache_init()
90 cache->proto = &proto; in nxt_cache_init()
143 lhq.proto = cache->proto; in nxt_cache_query()
428 lhq.proto = cache->proto; in nxt_cache_update()
|
| /unit/test/ |
| H A D | test_forwarded_header.py | 157 for proto in ['http', 'https']:
158 assert self.get_scheme('ipv6', xfp=proto) == proto, 'replace'
|
| H A D | test_variables.py | 1 from unit.applications.proto import TestApplicationProto
|
| H A D | test_static.py | 8 from unit.applications.proto import TestApplicationProto
|
| H A D | test_return.py | 3 from unit.applications.proto import TestApplicationProto
|
| H A D | test_reconfigure.py | 4 from unit.applications.proto import TestApplicationProto
|