syslog-ng-ctl: add get size of internal logs command.

Signed-off-by: Mehul Prajapati <mehul.encs@gmail.com>
mehul-m-prajapati · Sep 16, 2024 · 4a14f59 · 4a14f59
1 parent 1e70245
commit 4a14f59
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 0 deletions.
diff --git a/lib/afinter.c b/lib/afinter.c
@@ -704,6 +704,12 @@ afinter_stop_live_collection(void)
     }
 }
 
+void
+afinter_get_size_of_internal_logs(GString *result)
+{
+  g_string_append_printf(result, "Size of internal logs: %d", g_queue_get_length(internal_msg_queue));
+}
+
 void
 afinter_get_collected_messages(GString *result)
 {

diff --git a/lib/afinter.h b/lib/afinter.h
@@ -72,4 +72,5 @@ AFInterLive afinter_start_live_collection(void);
 void afinter_stop_live_collection(void);
 void afinter_reset_live_collection(void);
 void afinter_get_collected_messages(GString *result);
+void afinter_get_size_of_internal_logs(GString *result);
 #endif
diff --git a/lib/mainloop-control.c b/lib/mainloop-control.c
@@ -492,6 +492,10 @@ control_internal_logs(ControlConnection *cc, GString *command, gpointer user_dat
       afinter_stop_live_collection();
       afinter_get_collected_messages(result);
     }
+  else if (g_str_equal(arguments[1], "SIZE"))
+    {
+      afinter_get_size_of_internal_logs(result);
+    }
   else
     {
       g_string_assign(result, "FAIL Invalid arguments received");

diff --git a/syslog-ng-ctl/syslog-ng-ctl.c b/syslog-ng-ctl/syslog-ng-ctl.c
@@ -65,11 +65,13 @@ slng_reload(int argc, char *argv[], const gchar *mode, GOptionContext *ctx)
 
 static gboolean config_options_start = FALSE;
 static gboolean config_options_stop = FALSE;
+static gboolean config_options_size = FALSE;
 
 static GOptionEntry internal_options[] =
 {
   { "start", 's', 0, G_OPTION_ARG_NONE, &config_options_start, "start live collection of internal logs", NULL },
   { "stop", 'x', 0, G_OPTION_ARG_NONE, &config_options_stop, "stop live collection of internal logs", NULL },
+  { "size", 'l', 0, G_OPTION_ARG_NONE, &config_options_size, "get size of internal logs", NULL },
   { NULL,           0,   0, G_OPTION_ARG_NONE, NULL,                         NULL,           NULL }
 };
 
@@ -82,6 +84,8 @@ slng_internal(int argc, char *argv[], const gchar *mode, GOptionContext *ctx)
     g_string_assign(cmd, "INTERLOGS START");
   else if (config_options_stop)
     g_string_assign(cmd, "INTERLOGS STOP");
+  else if (config_options_size)
+    g_string_assign(cmd, "INTERLOGS SIZE");
   else
     {
       fprintf(stderr, "Error: Unknown command\n");
-Original file line number
+Diff line change
@@ Expand Up / @@ -704,6 +704,12 @@ afinter_stop_live_collection(void) @@
         }
     }
+    void
+    afinter_get_size_of_internal_logs(GString *result)
+    {
+      g_string_append_printf(result, "Size of internal logs: %d", g_queue_get_length(internal_msg_queue));
+    }
     void
     afinter_get_collected_messages(GString *result)
     {
@@ Expand Down @@