Changeset 77beb3c for logging.c

Timestamp:

Aug 5, 2017, 11:21:53 PM (7 years ago)

Author:

Jason Gross <jasongross9@gmail.com>

Branches:

master

Children:

e6f21ea

Parents:

ec36247

git-author:

Jason Gross <jgross@mit.edu> (05/26/13 12:50:13)

git-committer:

Jason Gross <jasongross9@gmail.com> (08/05/17 23:21:53)

Message:

Add a -f flag to :flush-logs

This allows us to bypass any troublesome messages in the queue.

File:

• logging.c (modified) (4 diffs)

logging.c

@@ -211 +211 @@
 }
 #endif
+
+static void owl_log_file_error(owl_log_entry *msg, int ret)
+{
+  owl_log_error("Unable to open file for logging: %s (file %s)",
+                g_strerror(ret),
+                msg->filename);
+}
 
 /* If we are deferring log messages, enqueue this entry for writing.
@@ -236 +243 @@
       owl_log_deferred_enqueue_message(msg->message, msg->filename);
     } else if (ret != 0) {
-      owl_log_error("Unable to open file for logging: %s (file %s)",
-                    g_strerror(ret),
-                    msg->filename);
+      owl_log_file_error(msg, ret);
     }
   }
@@ -247 +252 @@
 {
   owl_log_entry *entry;
+  bool drop_failed_logs = *(bool *)data;
+  int ret;
 
   defer_logs = false;
   while (!g_queue_is_empty(deferred_entry_queue) && !defer_logs) {
     entry = (owl_log_entry*)g_queue_pop_head(deferred_entry_queue);
-    owl_log_eventually_write_entry(entry);
+    if (drop_failed_logs) {
+      owl_log_eventually_write_entry(entry);
+    } else {
+      ret = owl_log_try_write_entry(entry);
+      if (ret != 0) {
+        owl_log_file_error(entry, ret);
+      }
+    }
     owl_log_entry_free(entry);
   }
 }
 
-void owl_log_flush_logs(void)
-{
-  owl_select_post_task(owl_log_write_deferred_entries, NULL, NULL, log_context);
+void owl_log_flush_logs(bool drop_failed_logs)
+{
+  bool *data = g_new(bool, 1);
+  *data = drop_failed_logs;
+
+  owl_select_post_task(owl_log_write_deferred_entries,
+                       data,
+                       g_free,
+                       log_context);
 }
 
@@ -539 +559 @@
 {
   /* flush the deferred logs queue, trying to write the
-   * entries to the disk one last time */
-  owl_log_write_deferred_entries(NULL);
+   * entries to the disk one last time.  Drop any failed
+   * entries */
+  bool bool_true = true;
+  owl_log_write_deferred_entries(&bool_true);
 #if GLIB_CHECK_VERSION(2, 32, 0)
   g_queue_free_full(deferred_entry_queue, owl_log_entry_free);