Home
last modified time | relevance | path

Searched refs:rpc_streams (Results 1 – 3 of 3) sorted by relevance

/unit/src/
H A Dnxt_port_rpc.c152 switch (nxt_lvlhsh_insert(&port->rpc_streams, &lhq)) { in nxt_port_rpc_register_handler_ex()
326 ret = nxt_lvlhsh_delete(&port->rpc_streams, &lhq); in nxt_port_rpc_handler()
329 ret = nxt_lvlhsh_find(&port->rpc_streams, &lhq); in nxt_port_rpc_handler()
443 ret = nxt_lvlhsh_delete(&port->rpc_streams, &lhq); in nxt_port_rpc_remove_peer()
469 ret = nxt_lvlhsh_delete(&port->rpc_streams, &lhq); in nxt_port_rpc_cancel()
499 reg = nxt_lvlhsh_peek(&port->rpc_streams, &lvlhsh_rpc_reg_proto); in nxt_port_rpc_close()
H A Dnxt_port.h258 nxt_lvlhsh_t rpc_streams; /* stream to nxt_port_rpc_reg_t */ member
H A Dnxt_port.c39 nxt_assert(nxt_lvlhsh_is_empty(&port->rpc_streams)); in nxt_port_mp_cleanup()