Update socket
authorJeroen van der Heijden <jeroen@transceptor.technology>
Fri, 24 Jan 2020 13:50:02 +0000 (14:50 +0100)
committerJeroen van der Heijden <jeroen@transceptor.technology>
Fri, 24 Jan 2020 13:50:02 +0000 (14:50 +0100)
src/siri/db/db.c
src/siri/db/tee.c
src/siri/heartbeat.c
src/siri/siri.c

index 2b94f6681ab49451ef46dd1dc95c331fc3bb6401..a51c75598080733c0fce90d09d2249c19f45e476 100644 (file)
@@ -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);
index 5eafa84dd9f0deb3ed501d954e46af5495b724d3..47d04269dc6df8ccfaae8f8650348230460a5cc7 100644 (file)
@@ -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)
index 0815950e99f4f53887b52db9df5b638dbdda256c..200740ce55b61af52ffb863b805ab352e9a360af 100644 (file)
@@ -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;
index 8630d2a22145a9d649041795ee4aeb39b3f5d34d..242d8ea3f8b2b50b6794e293b623808447656ebc 100644 (file)
@@ -216,8 +216,6 @@ int siri_start(void)
     /* start the event loop */
     uv_run(siri.loop, UV_RUN_DEFAULT);
 
-    LOGC("EXIT...");
-
     /* quit, don't forget to run siri_free() (should be done in main) */
     return 0;
 }
@@ -495,7 +493,6 @@ static void SIRI_walk_close_handlers(
 {
     if (uv_is_closing(handle))
     {
-        LOGC("Handle is closing...");
         return;
     }
 
@@ -509,7 +506,6 @@ static void SIRI_walk_close_handlers(
     case UV_TCP:
     case UV_NAMED_PIPE:
         {
-            LOGC("Found SOCKET...");
             if (handle->data == NULL || siridb_tee_is_handle(handle))
             {
                 uv_close(handle, NULL);