/unit/go/ |
H A D | request.go | 51 proto := GoStringN(&req.version, C.int(req.version_length)) 59 Proto: proto, 61 ProtoMinor: int(proto[7] - '0'),
|
/unit/src/ |
H A D | nxt_application.c | 1098 lhq->proto = &lvlhsh_processes_proto; in nxt_proto_process_lhq_pid()
|
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()
|
H A D | nxt_cache.h | 20 const nxt_lvlhsh_proto_t *proto; member
|
H A D | nxt_cert.c | 401 lhq.proto = &nxt_cert_info_hash_proto; in nxt_cert_info_save() 431 lhq.proto = &nxt_cert_info_hash_proto; in nxt_cert_info_get() 799 lhq.proto = &nxt_cert_info_hash_proto; in nxt_cert_info_delete()
|
H A D | nxt_conf.c | 1660 lhq.proto = &nxt_conf_object_hash_proto; in nxt_conf_object_hash_add()
|
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_fastcgi_source.c | 580 lhq.proto = &nxt_upstream_header_hash_proto; in nxt_fastcgi_source_header_process()
|
H A D | nxt_fd_event.c | 41 lhq.proto = &nxt_event_set_fd_hash_proto; in nxt_fd_event_hash_add() 62 lhq.proto = &nxt_event_set_fd_hash_proto; in nxt_fd_event_hash_get() 84 lhq.proto = &nxt_event_set_fd_hash_proto; in nxt_fd_event_hash_delete()
|
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_h1proto_websocket.c | 83 h1p = r->proto.h1; in nxt_h1p_websocket_first_frame_start() 127 h1p = r->proto.h1; in nxt_h1p_websocket_frame_start() 183 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_keepalive() 605 nxt_http_request_error_handler(task, r, r->proto.any); in hxt_h1p_send_ws_error() 641 r->state->error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_error_sent() 670 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_pong()
|
H A D | nxt_hash.h | 13 const nxt_lvlhsh_proto_t *proto; member 21 lhq->proto = h->proto; in nxt_hash_find() 30 lhq->proto = h->proto; in nxt_hash_insert() 40 lhq->proto = h->proto; in nxt_hash_delete()
|
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_http_error.c | 66 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_http_request_error() 103 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_http_request_send_error_body()
|
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_proxy.c | 84 up->proto = &nxt_upstream_simple_proto; in nxt_http_proxy_init() 146 upstream->proto->get(task, us); in nxt_upstream_proxy_handler()
|
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_route.c | 1577 if (r->local == NULL && nxt_fast_path(r->proto.any != NULL)) { in nxt_http_route_match()
|
H A D | nxt_http_source.c | 358 lhq.proto = &nxt_upstream_header_hash_proto; in nxt_http_source_header_line_process()
|
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_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_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_openssl.c | 1001 lhq.proto = &nxt_openssl_bundle_hash_proto; 1122 lhq.proto = &nxt_openssl_bundle_hash_proto;
|
H A D | nxt_poll_engine.c | 425 lhq.proto = &nxt_poll_fd_hash_proto; in nxt_poll_set_add() 470 lhq.proto = &nxt_poll_fd_hash_proto; in nxt_poll_set_delete() 643 lhq.proto = &nxt_poll_fd_hash_proto; in nxt_poll_fd_hash_get()
|