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_poll_engine.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_poll_engine.c')
-rw-r--r-- | src/nxt_poll_engine.c | 14 |
1 files changed, 1 insertions, 13 deletions
diff --git a/src/nxt_poll_engine.c b/src/nxt_poll_engine.c index 9b70f8d6..acb44a22 100644 --- a/src/nxt_poll_engine.c +++ b/src/nxt_poll_engine.c @@ -680,27 +680,15 @@ nxt_poll_fd_hash_test(nxt_lvlhsh_query_t *lhq, void *data) static void nxt_poll_fd_hash_destroy(nxt_event_engine_t *engine, nxt_lvlhsh_t *lh) { - nxt_lvlhsh_each_t lhe; - nxt_lvlhsh_query_t lhq; nxt_poll_hash_entry_t *phe; - nxt_memzero(&lhe, sizeof(nxt_lvlhsh_each_t)); - lhe.proto = &nxt_poll_fd_hash_proto; - lhq.proto = &nxt_poll_fd_hash_proto; - for ( ;; ) { - phe = nxt_lvlhsh_each(lh, &lhe); + phe = nxt_lvlhsh_retrieve(lh, &nxt_poll_fd_hash_proto, NULL); if (phe == NULL) { return; } - lhq.key_hash = nxt_murmur_hash2(&phe->fd, sizeof(nxt_fd_t)); - - if (nxt_lvlhsh_delete(lh, &lhq) != NXT_OK) { - nxt_alert(&engine->task, "event fd %d not found in hash", phe->fd); - } - nxt_free(phe); } } |