Initial version.

1 files changed, 107 insertions, 0 deletions

diff --git a/src/nxt_event_set.c b/src/nxt_event_set.c
new file mode 100644
index 00000000..2e75267b
--- /dev/null
+++ b/src/nxt_event_set.c
@@ -0,0 +1,107 @@
+
+/*
+ * Copyright (C) Igor Sysoev
+ * Copyright (C) NGINX, Inc.
+ */
+
+#include <nxt_main.h>
+
+
+static nxt_int_t nxt_event_set_fd_hash_test(nxt_lvlhsh_query_t *lhq,
+    void *data);
+
+
+static const nxt_lvlhsh_proto_t  nxt_event_set_fd_hash_proto  nxt_aligned(64) =
+{
+    NXT_LVLHSH_LARGE_MEMALIGN,
+    0,
+    nxt_event_set_fd_hash_test,
+    nxt_lvlhsh_alloc,
+    nxt_lvlhsh_free,
+};
+
+
+/* nxt_murmur_hash2() is unique for 4 bytes. */
+
+static nxt_int_t
+nxt_event_set_fd_hash_test(nxt_lvlhsh_query_t *lhq, void *data)
+{
+    return NXT_OK;
+}
+
+
+nxt_int_t
+nxt_event_set_fd_hash_add(nxt_lvlhsh_t *lh, nxt_fd_t fd, nxt_event_fd_t *ev)
+{
+    nxt_lvlhsh_query_t  lhq;
+
+    lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t));
+    lhq.replace = 0;
+    lhq.value = ev;
+    lhq.proto = &nxt_event_set_fd_hash_proto;
+
+    if (nxt_lvlhsh_insert(lh, &lhq) == NXT_OK) {
+        return NXT_OK;
+    }
+
+    nxt_log_alert(ev->log, "event fd %d is already in hash", ev->fd);
+    return NXT_ERROR;
+}
+
+
+void *
+nxt_event_set_fd_hash_get(nxt_lvlhsh_t *lh, nxt_fd_t fd)
+{
+    nxt_lvlhsh_query_t  lhq;
+
+    lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t));
+    lhq.proto = &nxt_event_set_fd_hash_proto;
+
+    if (nxt_lvlhsh_find(lh, &lhq) == NXT_OK) {
+        return lhq.value;
+    }
+
+    nxt_thread_log_alert("event fd %d not found in hash", fd);
+    return NULL;
+}
+
+
+void
+nxt_event_set_fd_hash_delete(nxt_lvlhsh_t *lh, nxt_fd_t fd, nxt_bool_t ignore)
+{
+    nxt_lvlhsh_query_t  lhq;
+
+    lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t));
+    lhq.proto = &nxt_event_set_fd_hash_proto;
+
+    if (nxt_lvlhsh_delete(lh, &lhq) != NXT_OK && !ignore) {
+        nxt_thread_log_alert("event fd %d not found in hash", fd);
+    }
+}
+
+
+void
+nxt_event_set_fd_hash_destroy(nxt_lvlhsh_t *lh)
+{
+    nxt_event_fd_t      *ev;
+    nxt_lvlhsh_each_t   lhe;
+    nxt_lvlhsh_query_t  lhq;
+
+    nxt_memzero(&lhe, sizeof(nxt_lvlhsh_each_t));
+    lhe.proto = &nxt_event_set_fd_hash_proto;
+    lhq.proto = &nxt_event_set_fd_hash_proto;
+
+    for ( ;; ) {
+        ev = nxt_lvlhsh_each(lh, &lhe);
+
+        if (ev == NULL) {
+            return;
+        }
+
+        lhq.key_hash = nxt_murmur_hash2(&ev->fd, sizeof(nxt_fd_t));
+
+        if (nxt_lvlhsh_delete(lh, &lhq) != NXT_OK) {
+            nxt_thread_log_alert("event fd %d not found in hash", ev->fd);
+        }
+    }
+}