Bugfixes for new logging code
authorHenning Rogge <rogge@fgan.de>
Fri, 6 Feb 2009 14:42:27 +0000 (15:42 +0100)
committerHenning Rogge <rogge@fgan.de>
Fri, 6 Feb 2009 14:42:27 +0000 (15:42 +0100)
lib/quagga/src/quagga.c
src/build_msg.c
src/main.c
src/olsr.c
src/olsr_cfg_data.c
src/olsr_cfg_data.h
src/parser.c
src/process_routes.c
src/scheduler.c
src/unix/ifnet.c

index b786e7a..58ae2c1 100644 (file)
@@ -69,7 +69,7 @@ static void zebra_reconnect (void);
 static void free_ipv4_route (struct zebra_route *);
 
 
-static void *my_realloc (void *buf, size_t s, const char *c) {
+static void *my_realloc (void *buf, size_t s, const char *c __attribute__ ((unused))) {
   buf = realloc (buf, s);
   if (!buf) {
     OLSR_ERROR(LOG_PLUGINS, "(QUAGGA) %s OUT OF MEMORY: %s\n", c, strerror(errno));
index 5c849f9..494462e 100644 (file)
@@ -143,7 +143,7 @@ queue_hna(struct interface *ifp)
 
 
 static void
-check_buffspace(int msgsize, int buffsize, const char *type)
+check_buffspace(int msgsize, int buffsize, const char *type __attribute__ ((unused)))
 {
   if(msgsize > buffsize)
     {
index 3226c7b..c0c59e4 100644 (file)
@@ -106,8 +106,10 @@ main(int argc, char *argv[])
 
   char conf_file_name[FILENAME_MAX];
   char parse_msg[FILENAME_MAX + 256];
-  struct ipaddr_str buf;
   int exitcode = 0;
+#ifndef REMOVE_LOG_INFO
+  struct ipaddr_str buf;
+#endif
 #ifdef WIN32
   WSADATA WsaData;
   size_t len;
@@ -282,7 +284,7 @@ main(int argc, char *argv[])
     } else {
       olsr_cnf->willingness = olsr_calculate_willingness();
 
-      OLSR_PRINTF(1, "Willingness set to %d - next update in %.1f secs\n", olsr_cnf->willingness, olsr_cnf->will_int);
+      OLSR_INFO(LOG_MAIN, "Willingness set to %d - next update in %.1f secs\n", olsr_cnf->willingness, olsr_cnf->will_int);
     }
   }
 
@@ -331,7 +333,7 @@ main(int argc, char *argv[])
   /* activate LQ algorithm */
   init_lq_handler();
 
-  OLSR_PRINTF(1, "Main address: %s\n\n", olsr_ip_to_string(&buf, &olsr_cnf->router_id));
+  OLSR_INFO(LOG_MAIN, "Main address: %s\n\n", olsr_ip_to_string(&buf, &olsr_cnf->router_id));
 
   /* Start syslog entry */
   OLSR_INFO(LOG_MAIN, "%s successfully started", olsrd_version);
@@ -429,7 +431,7 @@ main(int argc, char *argv[])
  *@param signal the signal that triggered this callback
  */
 static void
-signal_reconfigure(int signo)
+signal_reconfigure(int signo __attribute__ ((unused)))
 {
   const int save_errno = errno;
   OLSR_INFO(LOG_MAIN, "Received signal %d - requesting reconfiguration", signo);
@@ -449,7 +451,7 @@ int __stdcall
 SignalHandler(unsigned long signo)
 #else
 static void
-signal_shutdown(int signo)
+signal_shutdown(int signo __attribute__ ((unused)))
 #endif
 {
   const int save_errno = errno;
@@ -480,7 +482,7 @@ olsr_shutdown(void)
     olsr_delete_mid_entry(mid);
   } OLSR_FOR_ALL_MID_ENTRIES_END(mid);
 
-  OLSR_PRINTF(1, "Closing sockets...\n");
+  OLSR_INFO(LOG_MAIN, "Closing sockets...\n");
 
   /* Flush duplicate set */
   olsr_flush_duplicate_entries();
@@ -531,9 +533,7 @@ olsr_shutdown(void)
   /* Remove IP filters */
   deinit_netfilters();
 
-  OLSR_INFO(LOG_MAIN, "%s stopped", olsrd_version);
-
-  OLSR_PRINTF(1, "\n <<<< %s - terminating >>>>\n           http://www.olsr.org\n", olsrd_version);
+  OLSR_INFO(LOG_MAIN, "\n <<<< %s - terminating >>>>\n           http://www.olsr.org\n", olsrd_version);
 
   olsr_log_cleanup();
 
index 6b17387..faadd0f 100644 (file)
@@ -628,7 +628,7 @@ olsr_exit(int val)
  * @return a void pointer to the memory allocated
  */
 void *
-olsr_malloc(size_t size, const char *id)
+olsr_malloc(size_t size, const char *id __attribute__((unused)))
 {
   void *ptr;
 
@@ -639,8 +639,7 @@ olsr_malloc(size_t size, const char *id)
   ptr = calloc(1, size);
 
   if (!ptr) {
-      const char * const err_msg = strerror(errno);
-      OLSR_ERROR(LOG_MAIN, "Out of memory for id '%s': %s\n", id, err_msg);
+      OLSR_ERROR(LOG_MAIN, "Out of memory for id '%s': %s\n", id, strerror(errno));
       olsr_exit(EXIT_FAILURE);
   }
 
index fef9b2d..11c12c5 100644 (file)
@@ -58,7 +58,8 @@ const char *LOG_SOURCE_NAMES[] = {
   "scheduler",
   "plugins",
   "lq-plugins",
-  "ll-plugins"
+  "ll-plugins",
+  "duplicate-set"
 };
 
 const char *LOG_SEVERITY_NAMES[] = {
index 91b58ea..59c4b53 100644 (file)
@@ -55,10 +55,11 @@ enum log_source {
   LOG_ROUTING,            //!< LOG_ROUTING
   LOG_SCHEDULER,          //!< LOG_SCHEDULER
   LOG_PLUGINS,            //!< LOG_PLUGINS
-
   LOG_LQ_PLUGINS,         //!< LOG_LQ_PLUGINS
   LOG_LL_PLUGINS,         //!< LOG_LL_PLUGINS
 
+  LOG_DUPLICATE_SET,      //!< LOG_DUPLICATE_SET
+
   /* this one must be the last of the enums ! */
   LOG_SOURCE_COUNT//!< LOG_SOURCE_COUNT
 };
index 03a9727..00adc85 100644 (file)
@@ -84,7 +84,7 @@ static struct packetparser_function_entry *packetparser_functions;
  */
 void olsr_init_parser(void)
 {
-  OLSR_PRINTF(3, "Initializing parser...\n");
+  OLSR_INFO(LOG_PACKET_PARSING, "Initializing parser...\n");
 
   /* Initialize the packet functions */
   olsr_init_package_process();
@@ -92,7 +92,7 @@ void olsr_init_parser(void)
 
 void olsr_deinit_parser(void)
 {
-  OLSR_PRINTF(3, "Deinitializing parser...\n");
+  OLSR_INFO(LOG_PACKET_PARSING, "Deinitializing parser...\n");
   olsr_deinit_package_process();
 }
 
@@ -100,8 +100,6 @@ void olsr_parser_add_function(parse_function *function, uint32_t type)
 {
   struct parse_function_entry *new_entry;
 
-  OLSR_PRINTF(3, "Parser: registering event for type %u\n", type);
-
   new_entry = olsr_malloc(sizeof(*new_entry), "Register parse function");
 
   new_entry->function = function;
@@ -111,7 +109,7 @@ void olsr_parser_add_function(parse_function *function, uint32_t type)
   new_entry->next = parse_functions;
   parse_functions = new_entry;
 
-  OLSR_PRINTF(3, "Register parse function: Added function for type %u\n", type);
+  OLSR_INFO(LOG_PACKET_PARSING, "Register parse function: Added function for type %u\n", type);
 }
 
 int olsr_parser_remove_function(parse_function *function, uint32_t type)
@@ -138,8 +136,6 @@ void olsr_preprocessor_add_function(preprocessor_function *function)
 {
   struct preprocessor_function_entry *new_entry;
 
-  OLSR_PRINTF(3, "Parser: registering preprocessor\n");
-
   new_entry = olsr_malloc(sizeof(*new_entry), "Register preprocessor function");
   new_entry->function = function;
 
@@ -147,7 +143,7 @@ void olsr_preprocessor_add_function(preprocessor_function *function)
   new_entry->next = preprocessor_functions;
   preprocessor_functions = new_entry;
 
-  OLSR_PRINTF(3, "Registered preprocessor function\n");
+  OLSR_INFO(LOG_PACKET_PARSING, "Registered preprocessor function\n");
 }
 
 int olsr_preprocessor_remove_function(preprocessor_function *function)
@@ -174,8 +170,6 @@ void olsr_packetparser_add_function(packetparser_function *function)
 {
   struct packetparser_function_entry *new_entry;
 
-  OLSR_PRINTF(3, "Parser: registering packetparser\n");
-
   new_entry = olsr_malloc(sizeof(struct packetparser_function_entry), "Register packetparser function");
 
   new_entry->function = function;
@@ -184,8 +178,7 @@ void olsr_packetparser_add_function(packetparser_function *function)
   new_entry->next = packetparser_functions;
   packetparser_functions = new_entry;
 
-  OLSR_PRINTF(3, "Registered packetparser  function\n");
-
+  OLSR_INFO(LOG_PACKET_PARSING, "Registered packetparser  function\n");
 }
 
 int olsr_packetparser_remove_function(packetparser_function *function)
@@ -249,12 +242,14 @@ static void parse_packet(struct olsr *olsr, int size, struct interface *in_if, u
   struct parse_function_entry *entry;
   struct packetparser_function_entry *packetparser;
   int count = size - ((char *)m - (char *)olsr);
+#if !defined(REMOVE_LOG_INFO) || !defined(REMOVE_LOG_WARN)
+  struct ipaddr_str buf;
+#endif
 
   if (count < MIN_PACKET_SIZE(olsr_cnf->ip_version)) {
     return;
   }
   if (ntohs(olsr->olsr_packlen) != size) {
-    struct ipaddr_str buf;
     OLSR_WARN(LOG_PACKET_PARSING, "Size error detected in received packet from %s.\nRecieved %d, in packet %d\n",
         olsr_ip_to_string(&buf, from_addr), size, ntohs(olsr->olsr_packlen));
     return;
@@ -288,7 +283,6 @@ static void parse_packet(struct olsr *olsr, int size, struct interface *in_if, u
 
     /* Check size of message */
     if (count < 0) {
-      struct ipaddr_str buf;
       OLSR_WARN(LOG_PACKET_PARSING, "packet length error in  packet received from %s!",
                   olsr_ip_to_string(&buf, from_addr));
       break;
@@ -305,11 +299,8 @@ static void parse_packet(struct olsr *olsr, int size, struct interface *in_if, u
     /* Should be the same for IPv4 and IPv6 */
     if (olsr_ipequal((union olsr_ip_addr *)&m->v4.originator, &olsr_cnf->router_id)
         || !olsr_validate_address((union olsr_ip_addr *)&m->v4.originator)) {
-#ifdef DEBUG
-      struct ipaddr_str buf;
-      OLSR_PRINTF(3, "Not processing message originating from %s!\n",
+      OLSR_INFO(LOG_PACKET_PARSING, "Not processing message originating from %s!\n",
                   olsr_ip_to_string(&buf,(union olsr_ip_addr *)&m->v4.originator));
-#endif
       continue;
     }
 
@@ -340,6 +331,12 @@ void
 olsr_input(int fd, void *data __attribute__((unused)), unsigned int flags __attribute__((unused)))
 {
   unsigned int cpu_overload_exit = 0;
+#ifndef REMOVE_LOG_DEBUG
+      char addrbuf[128];
+#endif
+#ifndef REMOVE_LOG_WARN
+      struct ipaddr_str buf;
+#endif
 
   for (;;) {
     struct interface *olsr_in_if;
@@ -353,7 +350,7 @@ olsr_input(int fd, void *data __attribute__((unused)), unsigned int flags __attr
     char inbuf[MAXMESSAGESIZE+1];
 
     if (32 < ++cpu_overload_exit) {
-      OLSR_PRINTF(1, "CPU overload detected, ending olsr_input() loop\n");
+      OLSR_WARN(LOG_PACKET_PARSING, "CPU overload detected, ending olsr_input() loop\n");
       break;
     }
 
@@ -367,14 +364,7 @@ olsr_input(int fd, void *data __attribute__((unused)), unsigned int flags __attr
       break;
     }
 
-#ifdef DEBUG
-    {
-#ifndef NODEBUG
-      char addrbuf[128];
-#endif
-      OLSR_PRINTF(5, "Recieved a packet from %s\n", sockaddr_to_string(addrbuf, sizeof(addrbuf), (struct sockaddr *)&from, fromlen));
-    }
-#endif
+    OLSR_DEBUG(LOG_PACKET_PARSING, "Recieved a packet from %s\n", sockaddr_to_string(addrbuf, sizeof(addrbuf), (struct sockaddr *)&from, fromlen));
 
     if (olsr_cnf->ip_version == AF_INET) {
       /* IPv4 sender address */
@@ -396,7 +386,6 @@ olsr_input(int fd, void *data __attribute__((unused)), unsigned int flags __attr
     }
     olsr_in_if = if_ifwithsock(fd);
     if (olsr_in_if == NULL) {
-      struct ipaddr_str buf;
       OLSR_WARN(LOG_PACKET_PARSING, "Could not find input interface for message from %s size %d\n",
                   olsr_ip_to_string(&buf, &from_addr),
                   cc);
@@ -441,6 +430,9 @@ void olsr_input_hostemu(int fd, void *data __attribute__((unused)), unsigned int
   struct preprocessor_function_entry *entry;
   char *packet;
   char inbuf[MAXMESSAGESIZE+1];
+#ifndef REMOVE_LOG_WARN
+  struct ipaddr_str buf;
+#endif
 
   /* Host emulator receives IP address first to emulate
    direct link */
@@ -463,7 +455,7 @@ void olsr_input_hostemu(int fd, void *data __attribute__((unused)), unsigned int
       OLSR_ERROR(LOG_NETWORKING, "Lost olsr_switch connection - exit!\n");
       olsr_exit(EXIT_FAILURE);
     }
-    fprintf(stderr, "[hust-emu] error extracting size(%d) %s!\n", cc, strerror(errno));
+    OLSR_WARN(LOG_NETWORKING, "[hust-emu] error extracting size(%d) %s!\n", cc, strerror(errno));
     return;
   }
   pcklen = ntohs(pcklen);
@@ -472,8 +464,7 @@ void olsr_input_hostemu(int fd, void *data __attribute__((unused)), unsigned int
   cc = olsr_recvfrom(fd, inbuf, pcklen, 0, (struct sockaddr *)&from, &fromlen);
   if (cc <= 0) {
     if (cc < 0 && errno != EWOULDBLOCK) {
-      const char * const err_msg = strerror(errno);
-      OLSR_WARN(LOG_NETWORKING, "error recvfrom: %s", err_msg);
+      OLSR_WARN(LOG_NETWORKING, "error recvfrom: %s", strerror(errno));
     }
     return;
   }
@@ -485,7 +476,6 @@ void olsr_input_hostemu(int fd, void *data __attribute__((unused)), unsigned int
 
   olsr_in_if = if_ifwithsock(fd);
   if (olsr_in_if == NULL) {
-    struct ipaddr_str buf;
     OLSR_WARN(LOG_NETWORKING, "Could not find input interface for message from %s size %d\n",
                 olsr_ip_to_string(&buf, &from_addr),
                 cc);
index c8c7bad..b44ce86 100644 (file)
@@ -129,10 +129,7 @@ olsr_del_route(struct rt_entry *rt)
   int16_t error = olsr_del_route_function(rt, olsr_cnf->ip_version);
 
   if(error < 0) {
-    const char * const err_msg = strerror(errno);
-    const char * const routestr = olsr_rt_to_string(rt);
-
-    OLSR_WARN(LOG_ROUTING, "KERN: ERROR deleting %s: %s\n", routestr, err_msg);
+    OLSR_WARN(LOG_ROUTING, "KERN: ERROR deleting %s: %s\n", olsr_rt_to_string(rt), strerror(errno));
   } else {
 
     /* release the interface. */
@@ -160,9 +157,7 @@ exit(9);
   }
 
   if (0 > olsr_add_route_function(rt, olsr_cnf->ip_version)) {
-    const char * const err_msg = strerror(errno);
-    const char * const routestr = olsr_rtp_to_string(rt->rt_best);
-    OLSR_WARN(LOG_ROUTING, "KERN: ERROR adding %s: %s\n", routestr, err_msg);
+    OLSR_WARN(LOG_ROUTING, "KERN: ERROR adding %s: %s\n", olsr_rtp_to_string(rt->rt_best), strerror(errno));
   } else {
     /* route addition has suceeded */
 
index 4b698f3..1ce8ce8 100644 (file)
@@ -240,8 +240,7 @@ poll_sockets(void)
     return;
   }
   if (n == -1) {       /* Did something go wrong? */
-    const char * const err_msg = strerror(errno);
-    OLSR_WARN(LOG_SCHEDULER, "select error: %s", err_msg);
+    OLSR_WARN(LOG_SCHEDULER, "select error: %s", strerror(errno));
     return;
   }
 
index 83f11e7..475a0ee 100644 (file)
@@ -477,6 +477,7 @@ chk_if_up(struct olsr_if_config *iface, int debuglvl __attribute__((unused)))
   struct interface *ifp;
   struct ifreq ifr;
   const char *ifr_basename;
+  struct ipaddr_str buf;
 
   /*
    * Sanity check.
@@ -530,7 +531,6 @@ chk_if_up(struct olsr_if_config *iface, int debuglvl __attribute__((unused)))
   /* IP version 6 */
   if (olsr_cnf->ip_version == AF_INET6) {
     /* Get interface address */
-    struct ipaddr_str buf;
     int result;
 
     if (iface->cnf->ipv6_addrtype == OLSR_IP6T_AUTO) {
@@ -654,12 +654,10 @@ chk_if_up(struct olsr_if_config *iface, int debuglvl __attribute__((unused)))
   OLSR_PRINTF(1, "\tIndex %d\n", ifp->if_index);
 
   if(olsr_cnf->ip_version == AF_INET) {
-    struct ipaddr_str buf;
     OLSR_PRINTF(1, "\tAddress:%s\n", ip4_to_string(&buf, ifp->int_addr.sin_addr));
     OLSR_PRINTF(1, "\tNetmask:%s\n", ip4_to_string(&buf, ifp->int_netmask.sin_addr));
     OLSR_PRINTF(1, "\tBroadcast address:%s\n", ip4_to_string(&buf, ifp->int_broadaddr.sin_addr));
   } else {
-    struct ipaddr_str buf;
     OLSR_PRINTF(1, "\tAddress: %s\n", ip6_to_string(&buf, &ifp->int6_addr.sin6_addr));
     OLSR_PRINTF(1, "\tMulticast: %s\n", ip6_to_string(&buf, &ifp->int6_multaddr.sin6_addr));
   }
@@ -731,7 +729,6 @@ chk_if_up(struct olsr_if_config *iface, int debuglvl __attribute__((unused)))
    * Set main address if this is the only interface
    */
   if (!olsr_cnf->fixed_origaddr && olsr_ipequal(&all_zero, &olsr_cnf->router_id)) {
-    struct ipaddr_str buf;
     olsr_cnf->router_id = ifp->ip_addr;
     OLSR_INFO(LOG_NETWORKING, "New main address: %s\n", olsr_ip_to_string(&buf, &olsr_cnf->router_id));
   }