public inbox for cluster-cvs@sourceware.org
help / color / mirror / Atom feed
* STABLE2 - rgmanager: Make clustat and clusvcadm work faster
@ 2008-09-22 15:48 Lon Hohberger
0 siblings, 0 replies; only message in thread
From: Lon Hohberger @ 2008-09-22 15:48 UTC (permalink / raw)
To: cluster-cvs-relay
Gitweb: http://git.fedorahosted.org/git/cluster.git?p=cluster.git;a=commitdiff;h=50582b1fe9330cfd26be7031743cbc5b002eff55
Commit: 50582b1fe9330cfd26be7031743cbc5b002eff55
Parent: a627a3eb07fbe2d1af4f9790f167ffb911b48fec
Author: Lon Hohberger <lhh@redhat.com>
AuthorDate: Thu Sep 11 13:08:51 2008 -0400
Committer: Lon Hohberger <lhh@redhat.com>
CommitterDate: Mon Sep 22 11:24:24 2008 -0400
rgmanager: Make clustat and clusvcadm work faster
rhbz#461956
---
rgmanager/src/daemons/rg_event.c | 34 +++++++++++++++++++++++++---------
1 files changed, 25 insertions(+), 9 deletions(-)
diff --git a/rgmanager/src/daemons/rg_event.c b/rgmanager/src/daemons/rg_event.c
index 8339f03..41a88ca 100644
--- a/rgmanager/src/daemons/rg_event.c
+++ b/rgmanager/src/daemons/rg_event.c
@@ -10,6 +10,7 @@
#include <stdint.h>
#include <vf.h>
#include <members.h>
+#include <time.h>
/**
@@ -23,6 +24,7 @@ static pthread_mutex_t mi_mutex = PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP;
static pthread_mutex_t event_queue_mutex = PTHREAD_MUTEX_INITIALIZER;
static pthread_mutex_t mi_mutex = PTHREAD_MUTEX_INITIALIZER;
#endif
+static pthread_cond_t event_queue_cond = PTHREAD_COND_INITIALIZER;
static pthread_t event_thread = 0;
static int transition_throttling = 5;
static int central_events = 0;
@@ -373,23 +375,35 @@ void *
_event_thread_f(void __attribute__ ((unused)) *arg)
{
event_t *ev;
+ struct timeval now;
+ struct timespec expire;
int notice = 0, count = 0;
+ /* Event thread usually doesn't hang around. When it's
+ spawned, sleep for this many seconds in order to let
+ some events queue up */
+ if (transition_throttling && !central_events) {
+ sleep(transition_throttling);
+ }
+
while (1) {
pthread_mutex_lock(&event_queue_mutex);
ev = event_queue;
- if (ev)
- list_remove(&event_queue, ev);
- else
+ if (!ev && !central_events) {
+ gettimeofday(&now, NULL);
+ expire.tv_sec = now.tv_sec + 5;
+ expire.tv_nsec = now.tv_usec * 1000;
+ pthread_cond_timedwait(&event_queue_cond,
+ &event_queue_mutex,
+ &expire);
+ ev = event_queue;
+ }
+ if (!ev)
break; /* We're outta here */
- ++count;
- /* Event thread usually doesn't hang around. When it's
- spawned, sleep for this many seconds in order to let
- some events queue up */
- if ((count==1) && transition_throttling && !central_events)
- sleep(transition_throttling);
+ list_remove(&event_queue, ev);
+ ++count;
pthread_mutex_unlock(&event_queue_mutex);
if (ev->ev_type == EVENT_CONFIG) {
@@ -489,6 +503,8 @@ insert_event(event_t *ev)
pthread_create(&event_thread, &attrs, _event_thread_f, NULL);
pthread_attr_destroy(&attrs);
+ } else {
+ pthread_cond_broadcast(&event_queue_cond);
}
pthread_mutex_unlock (&event_queue_mutex);
}
^ permalink raw reply [flat|nested] only message in thread
only message in thread, other threads:[~2008-09-22 15:48 UTC | newest]
Thread overview: (only message) (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2008-09-22 15:48 STABLE2 - rgmanager: Make clustat and clusvcadm work faster Lon Hohberger
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for read-only IMAP folder(s) and NNTP newsgroup(s).