Lines Matching refs:nxt_port_rpc_reg_t
13 typedef struct nxt_port_rpc_reg_s nxt_port_rpc_reg_t; typedef
30 nxt_port_rpc_reg_t *reg);
97 nxt_port_rpc_reg_t *reg; in nxt_port_rpc_register_handler()
110 reg = nxt_pointer_to(ex, -sizeof(nxt_port_rpc_reg_t)); in nxt_port_rpc_register_handler()
126 nxt_port_rpc_reg_t *reg; in nxt_port_rpc_register_handler_ex()
133 reg = nxt_mp_zalloc(port->mem_pool, sizeof(nxt_port_rpc_reg_t) + ex_size); in nxt_port_rpc_register_handler_ex()
177 nxt_port_rpc_reg_t *reg; in nxt_port_rpc_ex_stream()
179 reg = nxt_pointer_to(ex, -sizeof(nxt_port_rpc_reg_t)); in nxt_port_rpc_ex_stream()
193 nxt_port_rpc_reg_t *reg; in nxt_port_rpc_ex_set_peer()
196 reg = nxt_pointer_to(ex, -sizeof(nxt_port_rpc_reg_t)); in nxt_port_rpc_ex_set_peer()
255 nxt_port_rpc_reg_t *reg) in nxt_port_rpc_remove_from_peers()
260 nxt_port_rpc_reg_t *r; in nxt_port_rpc_remove_from_peers()
283 r = nxt_queue_link_data(reg->link.next, nxt_port_rpc_reg_t, link); in nxt_port_rpc_remove_from_peers()
313 nxt_port_rpc_reg_t *reg; in nxt_port_rpc_handler()
374 nxt_port_rpc_reg_t *reg; in nxt_port_rpc_remove_peer()
405 reg = nxt_queue_link_data(peer_link, nxt_port_rpc_reg_t, link); in nxt_port_rpc_remove_peer()
463 nxt_port_rpc_reg_t *reg; in nxt_port_rpc_cancel()
495 nxt_port_rpc_reg_t *reg; in nxt_port_rpc_close()