diff options
| author | Lennart Poettering <lennart@poettering.net> | 2009-06-04 15:39:58 +0200 |
|---|---|---|
| committer | Lennart Poettering <lennart@poettering.net> | 2009-06-04 15:39:58 +0200 |
| commit | 350c8e2ad3fb4e9999c7573fc413874fdedc6b13 (patch) | |
| tree | 734b3efd7c2a867e2010b2862e71793ee5cbee4f | |
| parent | b021f87d875c8c649478948df6dbdd1b73a605bb (diff) | |
maintain global process/thread statistics
| -rw-r--r-- | rtkit-daemon.c | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/rtkit-daemon.c b/rtkit-daemon.c index 187ce30..55c944b 100644 --- a/rtkit-daemon.c +++ b/rtkit-daemon.c @@ -113,6 +113,8 @@ struct user { static struct user *users = NULL; static unsigned n_users = 0; +static unsigned n_total_processes = 0; +static unsigned n_total_threads = 0; static const char *proc = NULL; static const char *get_proc_path(void) { @@ -291,6 +293,7 @@ static int find_process(struct process** _p, struct user *u, pid_t pid, unsigned p->next = u->processes; u->processes = p; u->n_processes++; + n_total_processes++; *_p = p; return 0; @@ -319,6 +322,7 @@ static int find_thread(struct thread** _t, struct user *u, struct process *p, pi t->next = p->threads; p->threads = t; u->n_threads++; + n_total_threads++; *_t = t; return 0; @@ -394,8 +398,12 @@ static void thread_gc(struct user *u, struct process *p) { l->next = n; else p->threads = n; + assert(u->n_threads >= 1); u->n_threads--; + + assert(n_total_threads >= 1); + n_total_threads--; } else l = t; } @@ -421,6 +429,9 @@ static void process_gc(struct user *u) { assert(u->n_processes >= 1); u->n_processes--; + + assert(n_total_processes >= 1); + n_total_processes--; } else l = p; } @@ -958,6 +969,11 @@ static DBusHandlerResult dbus_handler(DBusConnection *c, DBusMessage *m, void *u } else return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; + fprintf(stderr, "Supervising %u threads of %u processes of %u users.\n", + n_total_threads, + n_total_processes, + n_users); + finish: if (r) { |