mpm_motorz: follow up to r1666482.

We only need one compare function for add semantic with apr_skiplist_insert()
and unique timers (pointers). It also works with apr_skiplist_remove() and
apr_skiplist_find().

git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@1666619 13f79535-47bb-0310-9956-ffa450edef68

diff --git a/server/mpm/motorz/motorz.c b/server/mpm/motorz/motorz.c
index 81a830bfbf75c54b36a2354ab0a4732c54865643..3ed9db0b53dade2cea5583673d6ec9c3782eb05c 100644 (file)
--- a/server/mpm/motorz/motorz.c
+++ b/server/mpm/motorz/motorz.c
@@ -64,21 +64,18 @@ static motorz_core_t *motorz_core_get()
     return g_motorz_core;
 }
 
-static int indexing_comp(void *a, void *b)
+static int timer_comp(void *a, void *b)
 {
-    apr_time_t t1 = (apr_time_t) (((motorz_timer_t *) a)->expires);
-    apr_time_t t2 = (apr_time_t) (((motorz_timer_t *) b)->expires);
-    AP_DEBUG_ASSERT(t1);
-    AP_DEBUG_ASSERT(t2);
-    return ((t1 < t2) ? -1 : 1);
-}
-
-static int indexing_compk(void *ac, void *b)
-{
-    apr_time_t *t1 = (apr_time_t *) ac;
-    apr_time_t t2 = (apr_time_t) (((motorz_timer_t *) b)->expires);
-    AP_DEBUG_ASSERT(t2);
-    return ((*t1 < t2) ? -1 : 1);
+    if (a != b) {
+        apr_time_t t1 = (apr_time_t) (((motorz_timer_t *) a)->expires);
+        apr_time_t t2 = (apr_time_t) (((motorz_timer_t *) b)->expires);
+        AP_DEBUG_ASSERT(t1);
+        AP_DEBUG_ASSERT(t2);
+        return ((t1 < t2) ? -1 : 1);
+    }
+    else {
+        return 0;
+    }
 }
 
 static apr_status_t motorz_conn_pool_cleanup(void *baton)
@@ -305,7 +302,11 @@ static void motorz_register_timer(motorz_conn_t *scon,
     elem->mz = mz;
 
     apr_thread_mutex_lock(mz->mtx);
-    apr_skiplist_insert(mz->timer_ring, (void *)elem);
+#ifdef AP_DEBUG
+    ap_assert(apr_skiplist_insert(mz->timer_ring, elem));
+#else
+    apr_skiplist_insert(mz->timer_ring, elem);
+#endif
     apr_thread_mutex_unlock(mz->mtx);
 }
 
@@ -901,7 +902,7 @@ static void child_main(motorz_core_t *mz, int child_num_arg, int child_bucket)
 
 #if 0
     apr_skiplist_init(&mz->timer_ring, mz->pool);
-    apr_skiplist_set_compare(mz->timer_ring, indexing_comp, indexing_compk);
+    apr_skiplist_set_compare(mz->timer_ring, timer_comp, timer_comp);
 #endif
     status = motorz_setup_workers(mz);
     if (status != APR_SUCCESS) {
@@ -1611,7 +1612,7 @@ static int motorz_pre_config(apr_pool_t *p, apr_pool_t *plog, apr_pool_t *ptemp)
     apr_pool_create(&mz->pool, ap_pglobal);
     apr_pool_tag(mz->pool, "motorz-mpm-core");
     apr_skiplist_init(&mz->timer_ring, mz->pool);
-    apr_skiplist_set_compare(mz->timer_ring, indexing_comp, indexing_compk);
+    apr_skiplist_set_compare(mz->timer_ring, timer_comp, timer_comp);
     apr_thread_mutex_create(&mz->mtx, 0, mz->pool);
 
     ap_listen_pre_config();