Home
last modified time | relevance | path

Searched refs:proto (Results 51 – 69 of 69) sorted by last modified time

123

/unit/src/
H A Dnxt_port_socket.c1100 lhq.proto = &lvlhsh_frag_proto; in nxt_port_frag_start()
1150 lhq.proto = &lvlhsh_frag_proto; in nxt_port_frag_find()
H A Dnxt_port_rpc.c77 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 Dnxt_vector.h32 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 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_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_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_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_upstream.c128 up[i] = u[i].proto->joint_create(tmcf, &u[i]); in nxt_upstreams_joint_create()
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_upstream.h42 const nxt_upstream_server_proto_t *proto; member
H A Dnxt_upstream_round_robin.c115 upstream->proto = &nxt_upstream_round_robin_proto; in nxt_upstream_round_robin_create()
H A Dnxt_vector.c12 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 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()
H A Dnxt_port_hash.c57 lhq->proto = &lvlhsh_ports_proto; in nxt_port_hash_lhq()
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_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_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()
/unit/src/test/
H A Dnxt_lvlhsh_test.c49 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 Drequest.go51 proto := GoStringN(&req.version, C.int(req.version_length))
59 Proto: proto,
61 ProtoMinor: int(proto[7] - '0'),

123