Home
last modified time | relevance | path

Searched refs:proto (Results 1 – 25 of 64) sorted by path

123

/unit/go/
H A Drequest.go51 proto := GoStringN(&req.version, C.int(req.version_length))
59 Proto: proto,
61 ProtoMinor: int(proto[7] - '0'),
/unit/src/
H A Dnxt_application.c1098 lhq->proto = &lvlhsh_processes_proto; in nxt_proto_process_lhq_pid()
H A Dnxt_cache.c49 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 Dnxt_cache.h20 const nxt_lvlhsh_proto_t *proto; member
H A Dnxt_cert.c401 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 Dnxt_conf.c1660 lhq.proto = &nxt_conf_object_hash_proto; in nxt_conf_object_hash_add()
H A Dnxt_conf_validation.c1801 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 Dnxt_fastcgi_source.c580 lhq.proto = &nxt_upstream_header_hash_proto; in nxt_fastcgi_source_header_process()
H A Dnxt_fd_event.c41 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 Dnxt_h1proto.c55 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 Dnxt_h1proto_websocket.c83 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 Dnxt_hash.h13 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 Dnxt_http.h119 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 Dnxt_http_error.c66 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 Dnxt_http_parse.c1191 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 Dnxt_http_parse.h141 lhq.proto = &nxt_http_fields_hash_proto; in nxt_http_field_process()
H A Dnxt_http_proxy.c84 up->proto = &nxt_upstream_simple_proto; in nxt_http_proxy_init()
146 upstream->proto->get(task, us); in nxt_upstream_proxy_handler()
H A Dnxt_http_request.c600 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 Dnxt_http_route.c1577 if (r->local == NULL && nxt_fast_path(r->proto.any != NULL)) { in nxt_http_route_match()
H A Dnxt_http_source.c358 lhq.proto = &nxt_upstream_header_hash_proto; in nxt_http_source_header_line_process()
H A Dnxt_http_static.c873 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 Dnxt_lvlhsh.c75 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 Dnxt_lvlhsh.h94 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 Dnxt_openssl.c1001 lhq.proto = &nxt_openssl_bundle_hash_proto;
1122 lhq.proto = &nxt_openssl_bundle_hash_proto;
H A Dnxt_poll_engine.c425 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()

123