summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_port_rpc.c
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2018-03-29 16:35:36 +0300
committerIgor Sysoev <igor@sysoev.ru>2018-03-29 16:35:36 +0300
commit7205bf4b86cfa662a7267afd7c316118084fc600 (patch)
treebddd69d9801ef74f6d61cdfda57d1af625ab714f /src/nxt_port_rpc.c
parentaad7752527faf674bcb01408e997769ba48756d7 (diff)
downloadunit-7205bf4b86cfa662a7267afd7c316118084fc600.tar.gz
unit-7205bf4b86cfa662a7267afd7c316118084fc600.tar.bz2
Using nxt_lvlhsh_peek() and nxt_lvlhsh_retrieve().
Diffstat (limited to 'src/nxt_port_rpc.c')
-rw-r--r--src/nxt_port_rpc.c7
1 files changed, 1 insertions, 6 deletions
diff --git a/src/nxt_port_rpc.c b/src/nxt_port_rpc.c
index d5ec289c..3e29230a 100644
--- a/src/nxt_port_rpc.c
+++ b/src/nxt_port_rpc.c
@@ -467,16 +467,11 @@ static nxt_buf_t nxt_port_close_dummy_buf;
void
nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port)
{
- nxt_lvlhsh_each_t lhe;
nxt_port_rpc_reg_t *reg;
nxt_port_recv_msg_t msg;
for ( ;; ) {
- nxt_memzero(&lhe, sizeof(nxt_lvlhsh_each_t));
-
- lhe.proto = &lvlhsh_rpc_reg_proto;
-
- reg = nxt_lvlhsh_each(&port->rpc_streams, &lhe);
+ reg = nxt_lvlhsh_peek(&port->rpc_streams, &lvlhsh_rpc_reg_proto);
if (reg == NULL) {
return;
}