diff -r 77241b3ba544 -r 97039494764b src/server/test/event.c
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/server/test/event.c	Fri Aug 16 16:59:05 2024 +0200
@@ -0,0 +1,120 @@
+/*
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
+ *
+ * Copyright 2024 Olaf Wintermann. All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ *   1. Redistributions of source code must retain the above copyright
+ *      notice, this list of conditions and the following disclaimer.
+ *
+ *   2. Redistributions in binary form must reproduce the above copyright
+ *      notice, this list of conditions and the following disclaimer in the
+ *      documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
+ * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+ * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+ * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+ * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+ * POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include "event.h"
+
+#include "../daemon/event.h"
+
+typedef struct EVTest {
+    EventHandler *h;
+    pthread_mutex_t mutex;
+    pthread_cond_t cond;
+    void *data1;
+    void *data2;
+    int i1;
+    int i2;
+} EVTest;
+
+UCX_TEST(test_evhandler_create) {
+    EventHandlerConfig cfg1 = { .nthreads = 1};
+    
+    EventHandlerConfig cfg4 = { .nthreads = 4};
+    
+    UCX_TEST_BEGIN;
+    
+    EVHandler *ev1 = evhandler_create(&cfg1);
+    UCX_TEST_ASSERT(ev1, "evhandler_create (1) failed");
+    UCX_TEST_ASSERT(ev1->numins == 1, "ev1 wrong number of instances");
+    
+    EVHandler *ev2 = evhandler_create(&cfg4);
+    UCX_TEST_ASSERT(ev2, "evhandler_create (2) failed");
+    UCX_TEST_ASSERT(ev2->numins == 4, "ev2 wrong number of instances");
+    
+    evhandler_close(ev1);
+    evhandler_close(ev2);
+    
+    UCX_TEST_END;
+}
+
+static int test_event_send_fn(EventHandler *h, Event *event) {
+    EVTest *test = event->cookie;
+    test->i1 = 1;
+    test->i2 = h == test->h;
+    
+    pthread_mutex_lock(&test->mutex);
+    pthread_cond_signal(&test->cond);
+    pthread_mutex_unlock(&test->mutex);
+    
+    return 0;
+}
+
+UCX_TEST(test_event_send) {
+    EventHandlerConfig cfg = { .nthreads = 1};
+    
+    EVHandler *ev = evhandler_create(&cfg);
+    EventHandler *h = ev_instance(ev);
+    
+    EVTest testdata;
+    ZERO(&testdata, sizeof(EVTest));
+    testdata.h = h;
+    pthread_mutex_init(&testdata.mutex, NULL);
+    pthread_cond_init(&testdata.cond, NULL);
+    
+    UCX_TEST_BEGIN;
+    
+    Event evt;
+    ZERO(&evt, sizeof(Event));
+    evt.fn = test_event_send_fn;
+    evt.cookie = &testdata;
+    
+    int ret = event_send(h, &evt);
+    
+    // wait for event finish
+    time_t tstart = time(NULL);
+    while(!testdata.i1) {
+        time_t t = time(NULL);
+        if(t - tstart > 10) {
+            break;
+        }
+        
+        pthread_mutex_lock(&testdata.mutex);
+        pthread_cond_wait(&testdata.cond, &testdata.mutex);
+        pthread_mutex_unlock(&testdata.mutex);
+    }
+    
+    UCX_TEST_ASSERT(!ret, "event_send failed");
+    UCX_TEST_ASSERT(testdata.i1, "event callback not called");
+    UCX_TEST_ASSERT(testdata.i2, "event callback received wrong event handler pointer");
+    
+    UCX_TEST_END;
+    
+    pthread_mutex_destroy(&testdata.mutex);
+    pthread_cond_destroy(&testdata.cond);
+    
+    evhandler_close(ev);
+}