1 files changed, 78 insertions, 87 deletions

diff --git a/lib/wheel.c b/lib/wheel.c
index f273a29262..9f1f189b72 100644
--- a/lib/wheel.c
+++ b/lib/wheel.c
@@ -24,137 +24,128 @@
 #include "wheel.h"
 #include "log.h"
 
-DEFINE_MTYPE_STATIC(LIB, TIMER_WHEEL,   "Timer Wheel")
+DEFINE_MTYPE_STATIC(LIB, TIMER_WHEEL, "Timer Wheel")
 DEFINE_MTYPE_STATIC(LIB, TIMER_WHEEL_LIST, "Timer Wheel Slot List")
 
 static int debug_timer_wheel = 0;
 
-static int
-wheel_timer_thread (struct thread *t)
+static int wheel_timer_thread(struct thread *t)
 {
-  struct listnode *node, *nextnode;
-  unsigned long long curr_slot;
-  unsigned int slots_to_skip = 1;
-  struct timer_wheel *wheel;
-  void *data;
+	struct listnode *node, *nextnode;
+	unsigned long long curr_slot;
+	unsigned int slots_to_skip = 1;
+	struct timer_wheel *wheel;
+	void *data;
 
-  wheel = THREAD_ARG(t);
-  THREAD_OFF(wheel->timer);
+	wheel = THREAD_ARG(t);
+	THREAD_OFF(wheel->timer);
 
-  wheel->curr_slot += wheel->slots_to_skip;
+	wheel->curr_slot += wheel->slots_to_skip;
 
-  curr_slot = wheel->curr_slot % wheel->slots;
+	curr_slot = wheel->curr_slot % wheel->slots;
 
-  if (debug_timer_wheel)
-    zlog_debug ("%s: Wheel Slot: %lld(%lld) count: %d",
-		__PRETTY_FUNCTION__,
-		wheel->curr_slot,
-		curr_slot, listcount(wheel->wheel_slot_lists[curr_slot]));
+	if (debug_timer_wheel)
+		zlog_debug("%s: Wheel Slot: %lld(%lld) count: %d",
+			   __PRETTY_FUNCTION__, wheel->curr_slot, curr_slot,
+			   listcount(wheel->wheel_slot_lists[curr_slot]));
 
-  for (ALL_LIST_ELEMENTS (wheel->wheel_slot_lists[curr_slot], node, nextnode, data))
-    (*wheel->slot_run)(data);
+	for (ALL_LIST_ELEMENTS(wheel->wheel_slot_lists[curr_slot], node,
+			       nextnode, data))
+		(*wheel->slot_run)(data);
 
-  while (list_isempty(wheel->wheel_slot_lists[(curr_slot + slots_to_skip) % wheel->slots]) &&
-	 (curr_slot + slots_to_skip ) % wheel->slots != curr_slot)
-    slots_to_skip++;
+	while (list_isempty(wheel->wheel_slot_lists[(curr_slot + slots_to_skip)
+						    % wheel->slots])
+	       && (curr_slot + slots_to_skip) % wheel->slots != curr_slot)
+		slots_to_skip++;
 
-  wheel->slots_to_skip = slots_to_skip;
-  thread_add_timer_msec(wheel->master, wheel_timer_thread, wheel,
-                        wheel->nexttime * slots_to_skip, &wheel->timer);
+	wheel->slots_to_skip = slots_to_skip;
+	thread_add_timer_msec(wheel->master, wheel_timer_thread, wheel,
+			      wheel->nexttime * slots_to_skip, &wheel->timer);
 
-  return 0;
+	return 0;
 }
 
-struct timer_wheel *
-wheel_init (struct thread_master *master, int period, size_t slots,
-	    unsigned int (*slot_key) (void *),
-	    void (*slot_run) (void *))
+struct timer_wheel *wheel_init(struct thread_master *master, int period,
+			       size_t slots, unsigned int (*slot_key)(void *),
+			       void (*slot_run)(void *))
 {
-  struct timer_wheel *wheel;
-  size_t i;
+	struct timer_wheel *wheel;
+	size_t i;
 
-  wheel = XCALLOC(MTYPE_TIMER_WHEEL, sizeof (struct timer_wheel));
+	wheel = XCALLOC(MTYPE_TIMER_WHEEL, sizeof(struct timer_wheel));
 
-  wheel->slot_key = slot_key;
-  wheel->slot_run = slot_run;
+	wheel->slot_key = slot_key;
+	wheel->slot_run = slot_run;
 
-  wheel->period = period;
-  wheel->slots = slots;
-  wheel->curr_slot = 0;
-  wheel->master = master;
-  wheel->nexttime = period / slots;
+	wheel->period = period;
+	wheel->slots = slots;
+	wheel->curr_slot = 0;
+	wheel->master = master;
+	wheel->nexttime = period / slots;
 
-  wheel->wheel_slot_lists = XCALLOC(MTYPE_TIMER_WHEEL_LIST,
-				    slots * sizeof (struct listnode *));
-  for (i = 0; i < slots; i++)
-    wheel->wheel_slot_lists[i] = list_new ();
+	wheel->wheel_slot_lists = XCALLOC(MTYPE_TIMER_WHEEL_LIST,
+					  slots * sizeof(struct listnode *));
+	for (i = 0; i < slots; i++)
+		wheel->wheel_slot_lists[i] = list_new();
 
-  thread_add_timer_msec(wheel->master, wheel_timer_thread, wheel,
-                        wheel->nexttime, &wheel->timer);
+	thread_add_timer_msec(wheel->master, wheel_timer_thread, wheel,
+			      wheel->nexttime, &wheel->timer);
 
-  return wheel;
+	return wheel;
 }
 
-void
-wheel_delete (struct timer_wheel *wheel)
+void wheel_delete(struct timer_wheel *wheel)
 {
-  int i;
+	int i;
 
-  for (i = 0; i < wheel->slots; i++)
-    {
-      list_delete(wheel->wheel_slot_lists[i]);
-    }
+	for (i = 0; i < wheel->slots; i++) {
+		list_delete(wheel->wheel_slot_lists[i]);
+	}
 
-  THREAD_OFF(wheel->timer);
-  XFREE(MTYPE_TIMER_WHEEL_LIST, wheel->wheel_slot_lists);
-  XFREE(MTYPE_TIMER_WHEEL, wheel);
+	THREAD_OFF(wheel->timer);
+	XFREE(MTYPE_TIMER_WHEEL_LIST, wheel->wheel_slot_lists);
+	XFREE(MTYPE_TIMER_WHEEL, wheel);
 }
 
-int
-wheel_stop (struct timer_wheel *wheel)
+int wheel_stop(struct timer_wheel *wheel)
 {
-  THREAD_OFF(wheel->timer);
-  return 0;
+	THREAD_OFF(wheel->timer);
+	return 0;
 }
 
-int
-wheel_start (struct timer_wheel *wheel)
+int wheel_start(struct timer_wheel *wheel)
 {
-  if (!wheel->timer)
-    thread_add_timer_msec(wheel->master, wheel_timer_thread, wheel,
-                          wheel->nexttime, &wheel->timer);
+	if (!wheel->timer)
+		thread_add_timer_msec(wheel->master, wheel_timer_thread, wheel,
+				      wheel->nexttime, &wheel->timer);
 
-  return 0;
+	return 0;
 }
 
-int
-wheel_add_item (struct timer_wheel *wheel, void *item)
+int wheel_add_item(struct timer_wheel *wheel, void *item)
 {
-  long long slot;
+	long long slot;
 
-  slot = (*wheel->slot_key)(item);
+	slot = (*wheel->slot_key)(item);
 
-  if (debug_timer_wheel)
-    zlog_debug ("%s: Inserting %p: %lld %lld",
-		__PRETTY_FUNCTION__, item,
-		slot, slot % wheel->slots);
-  listnode_add (wheel->wheel_slot_lists[slot % wheel->slots], item);
+	if (debug_timer_wheel)
+		zlog_debug("%s: Inserting %p: %lld %lld", __PRETTY_FUNCTION__,
+			   item, slot, slot % wheel->slots);
+	listnode_add(wheel->wheel_slot_lists[slot % wheel->slots], item);
 
-  return 0;
+	return 0;
 }
 
-int
-wheel_remove_item (struct timer_wheel *wheel, void *item)
+int wheel_remove_item(struct timer_wheel *wheel, void *item)
 {
-  long long slot;
+	long long slot;
 
-  slot = (*wheel->slot_key)(item);
+	slot = (*wheel->slot_key)(item);
 
-  if (debug_timer_wheel)
-    zlog_debug ("%s: Removing %p: %lld %lld",
-		__PRETTY_FUNCTION__, item,
-		slot, slot % wheel->slots);
-  listnode_delete (wheel->wheel_slot_lists[slot % wheel->slots], item);
+	if (debug_timer_wheel)
+		zlog_debug("%s: Removing %p: %lld %lld", __PRETTY_FUNCTION__,
+			   item, slot, slot % wheel->slots);
+	listnode_delete(wheel->wheel_slot_lists[slot % wheel->slots], item);
 
-  return 0;
+	return 0;
 }