Lines Matching refs:ret

191     nxt_int_t           ret;  in nxt_port_rpc_ex_set_peer()  local
221 ret = nxt_lvlhsh_insert(&port->rpc_peers, &lhq); in nxt_port_rpc_ex_set_peer()
223 switch (ret) { in nxt_port_rpc_ex_set_peer()
244 "peer for stream #%uD (%d)", reg->stream, ret); in nxt_port_rpc_ex_set_peer()
258 nxt_int_t ret; in nxt_port_rpc_remove_from_peers() local
274 ret = nxt_lvlhsh_delete(&port->rpc_peers, &lhq); in nxt_port_rpc_remove_from_peers()
288 ret = nxt_lvlhsh_insert(&port->rpc_peers, &lhq); in nxt_port_rpc_remove_from_peers()
296 ret = NXT_OK; in nxt_port_rpc_remove_from_peers()
299 if (nxt_slow_path(ret != NXT_OK)) { in nxt_port_rpc_remove_from_peers()
301 " to delete peer %PI (%d)", stream, reg->peer, ret); in nxt_port_rpc_remove_from_peers()
311 nxt_int_t ret; in nxt_port_rpc_handler() local
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()
332 if (ret != NXT_OK) { in nxt_port_rpc_handler()
371 nxt_int_t ret; in nxt_port_rpc_remove_peer() local
381 ret = nxt_lvlhsh_delete(&port->rpc_peers, &lhq); in nxt_port_rpc_remove_peer()
383 if (nxt_slow_path(ret != NXT_OK)) { in nxt_port_rpc_remove_peer()
443 ret = nxt_lvlhsh_delete(&port->rpc_streams, &lhq); in nxt_port_rpc_remove_peer()
445 if (nxt_slow_path(ret != NXT_OK)) { in nxt_port_rpc_remove_peer()
462 nxt_int_t ret; in nxt_port_rpc_cancel() local
469 ret = nxt_lvlhsh_delete(&port->rpc_streams, &lhq); in nxt_port_rpc_cancel()
471 if (ret != NXT_OK) { in nxt_port_rpc_cancel()