diff options
author | Igor Sysoev <igor@sysoev.ru> | 2018-03-29 16:35:36 +0300 |
---|---|---|
committer | Igor Sysoev <igor@sysoev.ru> | 2018-03-29 16:35:36 +0300 |
commit | 7205bf4b86cfa662a7267afd7c316118084fc600 (patch) | |
tree | bddd69d9801ef74f6d61cdfda57d1af625ab714f /src/nxt_port_rpc.c | |
parent | aad7752527faf674bcb01408e997769ba48756d7 (diff) | |
download | unit-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.c | 7 |
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; } |