Update for test

diff --git a/src/siri/db/db.c b/src/siri/db/db.c
index d9d1425e6e282f43a84e0ce7742776fe1019f8e8..2b94f6681ab49451ef46dd1dc95c331fc3bb6401 100644 (file)
--- a/src/siri/db/db.c
+++ b/src/siri/db/db.c
@@ -273,7 +273,7 @@ siridb_t * siridb_new(const char * dbpath, int lock_flags)
     /* init tee if configured */
     if (siridb_tee_is_configured(siridb->tee))
     {
-        siridb_tee_connect(siridb->tee);
+        // siridb_tee_connect(siridb->tee);
     }
 
     log_info("Finished loading database: '%s'", siridb->dbname);

diff --git a/src/siri/db/tee.c b/src/siri/db/tee.c
index 51f876689e848b1beb272314e067d6da0303a1d0..5eafa84dd9f0deb3ed501d954e46af5495b724d3 100644 (file)
--- a/src/siri/db/tee.c
+++ b/src/siri/db/tee.c
@@ -145,10 +145,10 @@ static void tee__runtime_init(uv_pipe_t * pipe)
     tee->flags &= ~SIRIDB_TEE_FLAG_INIT;
     tee->flags &= ~SIRIDB_TEE_FLAG_CONNECTED;
 
-    if (siridb_tee_connect(tee))
-    {
-        log_error("Could not connect to tee at runtime");
-    }
+    // if (siridb_tee_connect(tee))
+    // {
+    //     log_error("Could not connect to tee at runtime");
+    // }
 }
 
 static void tee__close_cb(uv_pipe_t * pipe)
@@ -193,6 +193,8 @@ static void tee__on_connect(uv_connect_t * req, int status)
     }
 
     free(tee->err_msg_);
+    tee->err_msg_ = NULL;
+
     if (asprintf(
             &tee->err_msg_,
             "Cannot connect to pipe '%s' (%s)",

diff --git a/src/siri/heartbeat.c b/src/siri/heartbeat.c
index 06011e1725f45303095f8e76e3519e1cf5b694ad..0815950e99f4f53887b52db9df5b638dbdda256c 100644 (file)
--- a/src/siri/heartbeat.c
+++ b/src/siri/heartbeat.c
@@ -64,7 +64,7 @@ static void HEARTBEAT_cb(uv_timer_t * handle __attribute__((unused)))
         if (    siridb_tee_is_configured(siridb->tee) &&
                 !siridb_tee_is_connected(siridb->tee))
         {
-            siridb_tee_connect(siridb->tee);
+            // siridb_tee_connect(siridb->tee);
         }
 
         server_node = siridb->servers->first;

diff --git a/src/siri/siri.c b/src/siri/siri.c
index ffeb190736fa4fab4d5b50a6db79672f1f802608..8630d2a22145a9d649041795ee4aeb39b3f5d34d 100644 (file)
--- a/src/siri/siri.c
+++ b/src/siri/siri.c
@@ -563,5 +563,5 @@ static void SIRI_close_handlers(void)
     uv_walk(siri.loop, SIRI_walk_close_handlers, NULL);
 
     /* run the loop once more so call-backs on uv_close() can run */
-    uv_run(siri.loop, UV_RUN_ONCE);
+    uv_run(siri.loop, UV_RUN_NOWAIT);
 }