Changeset 58a84d386885a444866925f495594b50f1bc4623

Timestamp:

02/18/11 16:51:16 (2 years ago)

Author:

Theo Schlossnagle <jesus@omniti.com>

git-committer:

Theo Schlossnagle <jesus@omniti.com> 1298047876 +0000

git-parent:

[4a4fa329f7b3b7b3d8927d10092ec0ec3a8c7770]

git-author:

Theo Schlossnagle <jesus@omniti.com> 1298047876 +0000

Message:

expose jobq info

Files:

• src/noit_console_state.c (modified) (5 diffs)

src/noit_console_state.c

@@ -34 +34 @@
-
-#include "eventer/eventer.h"
+#include "eventer/eventer_jobq.h"
-#include "utils/noit_log.h"
-#include "utils/noit_hash.h"
@@ -80 +81 @@
-            cname ? cname : funcptr, e->closure);
-}
+static void
+noit_console_spit_jobq(eventer_jobq_t *jobq, void *c) {
+  noit_console_closure_t ncct = c;
+  int qlen = 0;
+  const char *bqn = "(undefined)";
+  if(jobq->backq && jobq->backq->queue_name) bqn = jobq->backq->queue_name;
+  nc_printf(ncct, "=== %s ===\n", jobq->queue_name);
+  nc_printf(ncct, " concurrency: %d\n", jobq->concurrency);
+  nc_printf(ncct, " backq: %s\n", bqn);
+  sem_getvalue(&jobq->semaphore, &qlen);
+  nc_printf(ncct, " queue size: %d\n", qlen);
+}
-static int
-noit_console_eventer_timers(noit_console_closure_t ncct, int argc, char **argv,
@@ -92 +105 @@
-  if(argc != 0) return -1;
-  eventer_foreach_fdevent(noit_console_spit_event, ncct);
+  return 0;
+}
+static int
+noit_console_eventer_jobq(noit_console_closure_t ncct, int argc, char **argv,
+                             noit_console_state_t *dstate, void *unused) {
+  eventer_jobq_t *jobq;
+  if(argc != 1) return -1;
+  jobq = eventer_jobq_retrieve(argv[0]);
+  if(!jobq) {
+    nc_printf(ncct, "no jobq found for '%s'\n", argv[0] ? argv[0] : "");
+    return 0;
+  }
+  noit_console_spit_jobq(jobq, ncct);
-  return 0;
-}
@@ -112 +138 @@
-cmd_info_t console_command_eventer_sockets = {
-  "sockets", noit_console_eventer_sockets, NULL, NULL, NULL
+};
+cmd_info_t console_command_eventer_jobq = {
+  "jobq", noit_console_eventer_jobq, NULL, NULL, NULL
-};
-
@@ -484 +513 @@
-    noit_console_state_add_cmd(evdeb, &console_command_eventer_timers);
-    noit_console_state_add_cmd(evdeb, &console_command_eventer_sockets);
+    noit_console_state_add_cmd(evdeb, &console_command_eventer_jobq);
-  }
-  return _top_level_state;