Several small refactorings. Split log-group of network scheduler and timer scheduler
authorHenning Rogge <hrogge@googlemail.com>
Sat, 13 Nov 2010 11:39:43 +0000 (12:39 +0100)
committerHenning Rogge <hrogge@googlemail.com>
Sat, 13 Nov 2010 11:39:43 +0000 (12:39 +0100)
gui/linux-gtk/src/ipc.c
lib/nameservice/src/nameservice.c
lib/nameservice/src/nameservice.h
src/link_set.c
src/linux/kernel_tunnel.c
src/olsr_cfg_data.c
src/olsr_cfg_data.h
src/scheduler.c

index c16b09a..016d78f 100644 (file)
@@ -320,7 +320,7 @@ ipc_eval_net_info(struct netmsg *msg)
   printf("Evaluating NET info...\n");
 
   /*
-     printf("\tMain address: %s\n", ip_to_string(&msg->main_addr));
+     printf("\tMain address: %s\n", ip_to_string(&msg->router_id));
      printf("\tMid adresses: %d\n", msg->mids);
      printf("\tHna adresses: %d\n", msg->hnas);
      printf("\tHELLO interval: %f\n", (float)(ntohs(msg->hello_int)));
index b7709aa..12c00c9 100644 (file)
@@ -316,7 +316,7 @@ add_name_to_list(struct name_entry *my_list, const char *value, int type, const
   tmp->name = olsr_strndup(value, MAX_NAME);
   tmp->len = strlen(tmp->name);
   tmp->type = type;
-  // all IPs with value 0 will be set to main_addr later
+  // all IPs with value 0 will be set to router_id later
   if (ip == NULL)
     memset(&tmp->ip, 0, sizeof(tmp->ip));
   else
@@ -329,14 +329,14 @@ add_name_to_list(struct name_entry *my_list, const char *value, int type, const
 /**
  * last initialization
  *
- * we have to do this here because some things like main_addr
+ * we have to do this here because some things like router_id
  * or the dns suffix (for validation) are not known before
  *
  * this is beause of the order in which the plugin is initialized
  * by the plugin loader:
  *   - first the parameters are sent
  *   - then register_olsr_data() from olsrd_plugin.c is called
- *     which sets up main_addr and some other variables
+ *     which sets up router_id and some other variables
  *   - register_olsr_data() then then finally calls this function
  */
 int
index c3be6e4..e7eee11 100644 (file)
@@ -98,7 +98,7 @@ struct name_entry {
 
 /* *
  * linked list of db_entries for each originator with
- * originator being its main_addr
+ * originator being its router_id
  *
  * names points to the name_entry with its hostname, dns-server or
  * service-line entry
index 9f3e41b..88b8d3f 100644 (file)
@@ -494,7 +494,7 @@ lookup_link_entry(const union olsr_ip_addr *remote, const union olsr_ip_addr *re
                                                                 : olsr_ipcmp(&local->ip_addr, &link->local_iface_addr) == 0)) {
       /* check the remote-main address only if there is one given */
       if (NULL != remote_main && olsr_ipcmp(remote_main, &link->neighbor->nbr_addr) != 0) {
-        /* Neighbor has changed it's main_addr, update */
+        /* Neighbor has changed it's router_id, update */
 #if !defined REMOVE_LOG_DEBUG
         struct ipaddr_str oldbuf, newbuf;
 #endif
index 064b8ca..0515fa1 100644 (file)
@@ -89,7 +89,7 @@ int os_iptunnel_init(void) {
     return -1;
   }
 
-  return olsr_os_ifip(if_nametoindex(dev), &olsr_cnf->main_addr, true);
+  return olsr_os_ifip(if_nametoindex(dev), &olsr_cnf->router_id, true);
 }
 
 void os_iptunnel_cleanup(void) {
@@ -252,7 +252,7 @@ struct olsr_iptunnel_entry *os_iptunnel_add_ipip(union olsr_ip_addr *target, boo
     }
 
     /* set originator IP for tunnel */
-    olsr_os_ifip(if_idx, &olsr_cnf->main_addr, true);
+    olsr_os_ifip(if_idx, &olsr_cnf->router_id, true);
 
     t = olsr_cookie_malloc(tunnel_cookie);
     memcpy(&t->target, target, sizeof(*target));
index 0547dfe..327d728 100644 (file)
@@ -58,6 +58,7 @@ const char *LOG_SOURCE_NAMES[] = {
   "packet_parsing",
   "routing",
   "scheduler",
+  "timer",
   "plugins",
   "lq-plugins",
   "ll-plugins",
index 046be12..1141e52 100644 (file)
@@ -56,6 +56,7 @@ enum log_source {
   LOG_PACKET_PARSING,                  //!< LOG_PACKET_PARSING
   LOG_ROUTING,                         //!< LOG_ROUTING
   LOG_SCHEDULER,                       //!< LOG_SCHEDULER
+  LOG_TIMER,                           //!< LOG_TIMER
   LOG_PLUGINS,                         //!< LOG_PLUGINS
   LOG_LQ_PLUGINS,                      //!< LOG_LQ_PLUGINS
   LOG_LL_PLUGINS,                      //!< LOG_LL_PLUGINS
index 0c3b017..cf9d386 100644 (file)
@@ -345,6 +345,11 @@ poll_sockets(void)
     if (FD_ISSET(entry->fd, &obits)) {
       flags |= SP_PR_WRITE;
     }
+
+    if (flags) {
+      OLSR_DEBUG(LOG_SCHEDULER, "Event from socket %d (%d)", entry->fd, flags);
+    }
+
     if (flags != 0) {
       entry->process_pollrate(entry->fd, entry->data, flags);
     }
@@ -531,7 +536,7 @@ calc_jitter(unsigned int rel_time, uint8_t jitter_pct, unsigned int random_val)
   jitter_time = (jitter_pct * rel_time) / 100;
   jitter_time = random_val / (1 + RAND_MAX / (jitter_time + 1));
 
-  OLSR_DEBUG(LOG_SCHEDULER, "TIMER: jitter %u%% rel_time %ums to %ums\n", jitter_pct, rel_time, rel_time - jitter_time);
+  OLSR_DEBUG(LOG_TIMER, "TIMER: jitter %u%% rel_time %ums to %ums\n", jitter_pct, rel_time, rel_time - jitter_time);
 
   return GET_TIMESTAMP(rel_time - jitter_time);
 }
@@ -548,7 +553,7 @@ olsr_init_timers(void)
 
   /* Grab initial timestamp */
   if (os_gettimeofday(&first_tv, NULL)) {
-    OLSR_ERROR(LOG_SCHEDULER, "OS clock is not working, have to shut down OLSR (%s)\n", strerror(errno));
+    OLSR_ERROR(LOG_TIMER, "OS clock is not working, have to shut down OLSR (%s)\n", strerror(errno));
     olsr_exit(1);
   }
   last_tv = first_tv;
@@ -618,7 +623,7 @@ walk_timers(uint32_t * last_run)
 
       /* Ready to fire ? */
       if (TIMED_OUT(timer->timer_clock)) {
-        OLSR_DEBUG(LOG_SCHEDULER, "TIMER: fire %s timer %p, ctx %p, "
+        OLSR_DEBUG(LOG_TIMER, "TIMER: fire %s timer %p, ctx %p, "
                    "at clocktick %u (%s)\n",
                    timer->timer_info->name,
                    timer, timer->timer_cb_context, (unsigned int)*last_run, olsr_wallclock_string());
@@ -667,7 +672,7 @@ walk_timers(uint32_t * last_run)
     wheel_slot_walks++;
   }
 
-  OLSR_DEBUG(LOG_SCHEDULER, "TIMER: processed %4u/%d clockwheel slots, "
+  OLSR_DEBUG(LOG_TIMER, "TIMER: processed %4u/%d clockwheel slots, "
              "timers walked %4u/%u, timers fired %u\n",
              wheel_slot_walks, TIMER_WHEEL_SLOTS, total_timers_walked, timer_mem_cookie->ci_usage, total_timers_fired);
 
@@ -809,6 +814,8 @@ olsr_start_timer(unsigned int rel_time,
   struct timer_entry *timer;
 
   assert(ti != 0);          /* we want timer cookies everywhere */
+  assert(rel_time);
+  assert(jitter_pct <= 100);
 
   timer = olsr_cookie_malloc(timer_mem_cookie);
 
@@ -838,11 +845,12 @@ olsr_start_timer(unsigned int rel_time,
    */
   list_add_before(&timer_wheel[timer->timer_clock & TIMER_WHEEL_MASK], &timer->timer_list);
 
-  OLSR_DEBUG(LOG_SCHEDULER, "TIMER: start %s timer %p firing in %s, ctx %p\n",
+  OLSR_DEBUG(LOG_TIMER, "TIMER: start %s timer %p firing in %s, ctx %p\n",
              ti->name, timer, olsr_clock_string(timer->timer_clock), context);
 
   return timer;
 }
+#include "valgrind/valgrind.h"
 
 /**
  * Delete a timer.
@@ -861,7 +869,7 @@ olsr_stop_timer(struct timer_entry *timer)
   assert(timer->timer_info);     /* we want timer cookies everywhere */
   assert(timer->timer_list.next != NULL && timer->timer_list.prev != NULL);
 
-  OLSR_DEBUG(LOG_SCHEDULER, "TIMER: stop %s timer %p, ctx %p\n",
+  OLSR_DEBUG(LOG_TIMER, "TIMER: stop %s timer %p, ctx %p\n",
              timer->timer_info->name, timer, timer->timer_cb_context);
 
 
@@ -909,7 +917,7 @@ olsr_change_timer(struct timer_entry *timer, unsigned int rel_time, uint8_t jitt
   list_remove(&timer->timer_list);
   list_add_before(&timer_wheel[timer->timer_clock & TIMER_WHEEL_MASK], &timer->timer_list);
 
-  OLSR_DEBUG(LOG_SCHEDULER, "TIMER: change %s timer %p, firing to %s, ctx %p\n",
+  OLSR_DEBUG(LOG_TIMER, "TIMER: change %s timer %p, firing to %s, ctx %p\n",
              timer->timer_info->name, timer,
              olsr_clock_string(timer->timer_clock), timer->timer_cb_context);
 }