1 files changed, 19 insertions, 18 deletions

diff --git a/src/log.c b/src/log.c
index 755a913..14fc3fe 100644
--- a/src/log.c
+++ b/src/log.c
@@ -27,7 +27,7 @@
 #include "heap.h"
 #include "log.h"
 #include "utils.h"
-#include "vector.h"
+#include "sblist.h"
 #include "conf.h"
 #include <pthread.h>
 
@@ -64,7 +64,7 @@ static int log_level = LOG_INFO;
  * The key is the actual messages (already filled in full), and the value
  * is the log level.
  */
-static vector_t log_message_storage;
+static sblist *log_message_storage;
 
 static unsigned int logging_initialized = FALSE;     /* boolean */
 
@@ -108,7 +108,8 @@ void set_log_level (int level)
 void log_message (int level, const char *fmt, ...)
 {
         va_list args;
-        time_t nowtime;
+        struct timespec nowtime;
+        struct tm tm_buf;
 
         char time_string[TIME_LENGTH];
         char str[STRING_LENGTH];
@@ -142,7 +143,7 @@ void log_message (int level, const char *fmt, ...)
                 char *entry_buffer;
 
                 if (!log_message_storage) {
-                        log_message_storage = vector_create ();
+                        log_message_storage = sblist_new (sizeof(char*), 64);
                         if (!log_message_storage)
                                 goto out;
                 }
@@ -154,10 +155,8 @@ void log_message (int level, const char *fmt, ...)
                         goto out;
 
                 sprintf (entry_buffer, "%d %s", level, str);
-                vector_append (log_message_storage, entry_buffer,
-                               strlen (entry_buffer) + 1);
-
-                safefree (entry_buffer);
+                if(!sblist_add (log_message_storage, &entry_buffer))
+                        safefree (entry_buffer);
                 goto out;
         }
 
@@ -176,13 +175,14 @@ void log_message (int level, const char *fmt, ...)
         } else {
                 char *p;
 
-                nowtime = time (NULL);
+                clock_gettime(CLOCK_REALTIME, &nowtime);
                 /* Format is month day hour:minute:second (24 time) */
                 strftime (time_string, TIME_LENGTH, "%b %d %H:%M:%S",
-                          localtime (&nowtime));
+                          localtime_r (&nowtime.tv_sec, &tm_buf));
 
-                snprintf (str, STRING_LENGTH, "%-9s %s [%ld]: ",
+                snprintf (str, STRING_LENGTH, "%-9s %s.%03lu [%ld]: ",
                           syslog_level[level], time_string,
+                          (unsigned long) nowtime.tv_nsec/1000000ul,
                           (long int) getpid ());
 
                 /*
@@ -227,7 +227,7 @@ out:
  */
 static void send_stored_logs (void)
 {
-        char *string;
+        char **string;
         char *ptr;
         int level;
         size_t i;
@@ -237,12 +237,12 @@ static void send_stored_logs (void)
 
         log_message(LOG_DEBUG, "sending stored logs");
 
-        for (i = 0; (ssize_t) i != vector_length (log_message_storage); ++i) {
-                string =
-                    (char *) vector_getentry (log_message_storage, i, NULL);
+        for (i = 0; i < sblist_getsize (log_message_storage); ++i) {
+                string = sblist_get (log_message_storage, i);
+                if (!string || !*string) continue;
 
-                ptr = strchr (string, ' ') + 1;
-                level = atoi (string);
+                ptr = strchr (*string, ' ') + 1;
+                level = atoi (*string);
 
 #ifdef NDEBUG
                 if (log_level == LOG_CONN && level == LOG_INFO)
@@ -255,9 +255,10 @@ static void send_stored_logs (void)
 #endif
 
                 log_message (level, "%s", ptr);
+                safefree(*string);
         }
 
-        vector_delete (log_message_storage);
+        sblist_free (log_message_storage);
         log_message_storage = NULL;
 
         log_message(LOG_DEBUG, "done sending stored logs");