/unit/src/ |
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_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_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_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_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_upstream.c | 128 up[i] = u[i].proto->joint_create(tmcf, &u[i]); in nxt_upstreams_joint_create()
|
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_upstream.h | 42 const nxt_upstream_server_proto_t *proto; member
|
H A D | nxt_upstream_round_robin.c | 115 upstream->proto = &nxt_upstream_round_robin_proto; in nxt_upstream_round_robin_create()
|
H A D | nxt_vector.c | 12 const nxt_mem_proto_t *proto, void *pool) in nxt_vector_create() argument 16 vector = proto->alloc(pool, sizeof(nxt_vector_t) + items * item_size); in nxt_vector_create() 32 const nxt_mem_proto_t *proto, void *pool) in nxt_vector_init() argument 34 vector->start = proto->alloc(pool, items * item_size); in nxt_vector_init() 48 nxt_vector_destroy(nxt_vector_t *vector, const nxt_mem_proto_t *proto, in nxt_vector_destroy() argument 54 proto->free(pool, vector->start); in nxt_vector_destroy() 63 proto->free(pool, vector->start); in nxt_vector_destroy() 68 proto->free(pool, vector); in nxt_vector_destroy() 96 start = proto->alloc(pool, size); in nxt_vector_add() 111 proto->free(pool, old); in nxt_vector_add() [all …]
|
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()
|
H A D | nxt_port_hash.c | 57 lhq->proto = &lvlhsh_ports_proto; in nxt_port_hash_lhq()
|
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_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_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()
|
/unit/src/test/ |
H A D | nxt_lvlhsh_test.c | 49 lhq.proto = proto; in nxt_lvlhsh_test_add() 76 lhq.proto = proto; in nxt_lvlhsh_test_get() 102 lhq.proto = proto; in nxt_lvlhsh_test_delete() 126 const nxt_lvlhsh_proto_t *proto; in nxt_lvlhsh_test() local 145 proto = &pool_proto; in nxt_lvlhsh_test() 150 proto = &malloc_proto; in nxt_lvlhsh_test() 160 if (nxt_lvlhsh_test_add(&lh, proto, mp, key) != NXT_OK) { in nxt_lvlhsh_test() 171 if (nxt_lvlhsh_test_get(&lh, proto, key) != NXT_OK) { in nxt_lvlhsh_test() 176 nxt_lvlhsh_each_init(&lhe, proto); in nxt_lvlhsh_test() 191 value = nxt_lvlhsh_peek(&lh, proto); in nxt_lvlhsh_test() [all …]
|
/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'),
|