Updated the syslog interface to a more OS independent one
authorAndreas Tonnesen <andreto@olsr.org>
Sun, 19 Sep 2004 13:09:34 +0000 (13:09 +0000)
committerAndreas Tonnesen <andreto@olsr.org>
Sun, 19 Sep 2004 13:09:34 +0000 (13:09 +0000)
13 files changed:
src/configfile.c
src/defs.h
src/ipc_frontend.c
src/linux/ifnet.c
src/linux/kernel_routes.c
src/main.c
src/main.h
src/net.c
src/olsr.c
src/parser.c
src/process_routes.c
src/scheduler.c
src/socket_parser.c

index fd86096..9ab0485 100644 (file)
@@ -658,7 +658,7 @@ read_config_file(char *filename)
             }
 
 
-         //syslog(LOG_ERR, "Could not parse config file(%s) line:\"%s\"", filename, line);
+         //olsr_syslog(OLSR_LOG_ERR, "Could not parse config file(%s) line:\"%s\"", filename, line);
 
          olsr_printf(1, "Could not parse config file(%s) line: %s", filename, line);
        }
index 5a958a6..bd8c0ba 100644 (file)
@@ -27,7 +27,6 @@
 #include <sys/time.h>
 #include <net/route.h>
 
-#include <syslog.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
@@ -38,6 +37,7 @@
 #define UP             1
 #define DOWN           0
 
+#include "log.h"
 #include "olsr_protocol.h"
 #include "process_routes.h" /* Needed for rt_entry */
 #include "net.h" /* IPaddr -> string conversions is used by everyone */
index 0e88d0f..1397692 100644 (file)
@@ -120,7 +120,7 @@ ipc_accept_thread()
          if(ntohl(pin.sin_addr.s_addr) != INADDR_LOOPBACK)
            {
              olsr_printf(1, "Front end-connection from foregin host(%s) not allowed!\n", addr);
-             syslog(LOG_ERR, "OLSR: Front end-connection from foregin host(%s) not allowed!\n", addr);
+             olsr_syslog(OLSR_LOG_ERR, "OLSR: Front end-connection from foregin host(%s) not allowed!\n", addr);
              close(ipc_connection);
            }
          else
index 70381b8..3cc921d 100644 (file)
@@ -274,7 +274,7 @@ chk_if_changed(struct if_name *iface)
                    ipsize) == 0)
            {
              olsr_printf(1, "New main address: %s\n", sockaddr_to_string(&ifr.ifr_addr));
-             syslog(LOG_INFO, "New main address: %s\n", sockaddr_to_string(&ifr.ifr_addr));
+             olsr_syslog(OLSR_LOG_INFO, "New main address: %s\n", sockaddr_to_string(&ifr.ifr_addr));
              memcpy(&main_addr, 
                     &((struct sockaddr_in *)&ifp->int_addr)->sin_addr.s_addr, 
                     ipsize);
@@ -291,7 +291,7 @@ chk_if_changed(struct if_name *iface)
       /* Check netmask */
       if (ioctl(ioctl_s, SIOCGIFNETMASK, &ifr) < 0) 
        {
-         syslog(LOG_ERR, "%s: ioctl (get broadaddr)", ifr.ifr_name);
+         olsr_syslog(OLSR_LOG_ERR, "%s: ioctl (get broadaddr)", ifr.ifr_name);
          goto remove_interface;
        }
 
@@ -316,7 +316,7 @@ chk_if_changed(struct if_name *iface)
       /* Check broadcast address */      
       if (ioctl(ioctl_s, SIOCGIFBRDADDR, &ifr) < 0) 
        {
-         syslog(LOG_ERR, "%s: ioctl (get broadaddr)", ifr.ifr_name);
+         olsr_syslog(OLSR_LOG_ERR, "%s: ioctl (get broadaddr)", ifr.ifr_name);
          goto remove_interface;
        }
 
@@ -357,7 +357,7 @@ chk_if_changed(struct if_name *iface)
 
  remove_interface:
   olsr_printf(1, "Removing interface %s\n", iface->name);
-  syslog(LOG_INFO, "Removing interface %s\n", iface->name);
+  olsr_syslog(OLSR_LOG_INFO, "Removing interface %s\n", iface->name);
 
   /*
    *Call possible ifchange functions registered by plugins  
@@ -396,7 +396,7 @@ chk_if_changed(struct if_name *iface)
        {
          COPY_IP(&main_addr, &ifnet->ip_addr);
          olsr_printf(1, "New main address: %s\n", olsr_ip_to_string(&main_addr));
-         syslog(LOG_INFO, "New main address: %s\n", olsr_ip_to_string(&main_addr));
+         olsr_syslog(OLSR_LOG_INFO, "New main address: %s\n", olsr_ip_to_string(&main_addr));
        }
     }
 
@@ -414,7 +414,7 @@ chk_if_changed(struct if_name *iface)
   if((nbinterf == 0) && (!allow_no_int))
     {
       olsr_printf(1, "No more active interfaces - exiting.\n");
-      syslog(LOG_INFO, "No more active interfaces - exiting.\n");
+      olsr_syslog(OLSR_LOG_INFO, "No more active interfaces - exiting.\n");
       exit_value = EXIT_FAILURE;
       kill(getpid(), SIGINT);
     }
@@ -538,7 +538,7 @@ chk_if_up(struct if_name *iface, int debuglvl)
       
       if (ioctl(ioctl_s, SIOCGIFNETMASK, &ifr) < 0) 
        {
-         syslog(LOG_ERR, "%s: ioctl (get broadaddr)", ifr.ifr_name);
+         olsr_syslog(OLSR_LOG_ERR, "%s: ioctl (get broadaddr)", ifr.ifr_name);
          return 0;
        }
       
@@ -548,7 +548,7 @@ chk_if_up(struct if_name *iface, int debuglvl)
       
       if (ioctl(ioctl_s, SIOCGIFBRDADDR, &ifr) < 0) 
        {
-         syslog(LOG_ERR, "%s: ioctl (get broadaddr)", ifr.ifr_name);
+         olsr_syslog(OLSR_LOG_ERR, "%s: ioctl (get broadaddr)", ifr.ifr_name);
          return 0;
        }
       
@@ -574,7 +574,7 @@ chk_if_up(struct if_name *iface, int debuglvl)
   /* setting the interfaces number*/
   ifs.if_nr = iface->index;
 
-  syslog(LOG_INFO, "Adding interface %s\n", iface->name);
+  olsr_syslog(OLSR_LOG_INFO, "Adding interface %s\n", iface->name);
   olsr_printf(1, "Interface %s set up for use with index %d\n", iface->name, ifs.if_nr);
 
   if(ipversion == AF_INET)
@@ -621,7 +621,7 @@ chk_if_up(struct if_name *iface, int debuglvl)
       if (ifp->olsr_socket < 0)
        {
          fprintf(stderr, "Could not initialize socket... exiting!\n\n");
-         syslog(LOG_ERR, "Could not initialize socket... exiting!\n\n");
+         olsr_syslog(OLSR_LOG_ERR, "Could not initialize socket... exiting!\n\n");
          exit_value = EXIT_FAILURE;
          kill(getpid(), SIGINT);
        }
@@ -645,7 +645,7 @@ chk_if_up(struct if_name *iface, int debuglvl)
       if (ifp->olsr_socket < 0)
        {
          fprintf(stderr, "Could not initialize socket... exiting!\n\n");
-         syslog(LOG_ERR, "Could not initialize socket... exiting!\n\n");
+         olsr_syslog(OLSR_LOG_ERR, "Could not initialize socket... exiting!\n\n");
          exit_value = EXIT_FAILURE;
          kill(getpid(), SIGINT);
        }
@@ -661,12 +661,12 @@ chk_if_up(struct if_name *iface, int debuglvl)
   if (setsockopt(ifp->olsr_socket, SOL_SOCKET, SO_PRIORITY, (char*)&precedence, sizeof(precedence)) < 0)
     {
       perror("setsockopt(SO_PRIORITY)");
-      syslog(LOG_ERR, "OLSRD: setsockopt(SO_PRIORITY) error %m");
+      olsr_syslog(OLSR_LOG_ERR, "OLSRD: setsockopt(SO_PRIORITY) error %m");
     }
   if (setsockopt(ifp->olsr_socket, SOL_IP, IP_TOS, (char*)&tos_bits, sizeof(tos_bits)) < 0)    
     {
       perror("setsockopt(IP_TOS)");
-      syslog(LOG_ERR, "setsockopt(IP_TOS) error %m");
+      olsr_syslog(OLSR_LOG_ERR, "setsockopt(IP_TOS) error %m");
     }
   
   /*
@@ -682,7 +682,7 @@ chk_if_up(struct if_name *iface, int debuglvl)
     {
       COPY_IP(&main_addr, &ifp->ip_addr);
       olsr_printf(1, "New main address: %s\n", olsr_ip_to_string(&main_addr));
-      syslog(LOG_INFO, "New main address: %s\n", olsr_ip_to_string(&main_addr));
+      olsr_syslog(OLSR_LOG_INFO, "New main address: %s\n", olsr_ip_to_string(&main_addr));
     }
   
   /*
index 4a6b961..8ff14ef 100644 (file)
@@ -183,7 +183,7 @@ olsr_ioctl_add_route6(struct rt_entry *destination)
   if((tmp = ioctl(ioctl_s, SIOCADDRT,&kernel_route)) < 0)
     {
       olsr_printf(1, "Add route: %s\n", strerror(errno));
-      syslog(LOG_ERR, "Add route:%m");
+      olsr_syslog(OLSR_LOG_ERR, "Add route:%m");
     }
   else
     {
@@ -413,7 +413,7 @@ add_tunnel_route(union olsr_ip_addr *gw)
   if((tmp = ioctl(ioctl_s,SIOCADDRT,&kernel_route)) < 0)
     {
       olsr_printf(1, "Add tunnel route: %s\n", strerror(errno));
-      syslog(LOG_ERR, "Add tunnel route:%m");
+      olsr_syslog(OLSR_LOG_ERR, "Add tunnel route:%m");
     }
 
   free(kernel_route.rt_dev);
@@ -464,7 +464,7 @@ delete_tunnel_route()
   if((tmp = ioctl(ioctl_s,SIOCDELRT,&kernel_route)) < 0)
     {
       olsr_printf(1, "Del tunnel route: %s\n", strerror(errno));
-      syslog(LOG_ERR, "Del tunnel route:%m");
+      olsr_syslog(OLSR_LOG_ERR, "Del tunnel route:%m");
     }
   
   free(kernel_route.rt_dev);
@@ -504,7 +504,7 @@ delete_tunnel_route()
   if((tmp = ioctl(ioctl_s,SIOCDELRT,&kernel_route)) < 0)
     {
       olsr_printf(1, "Del tunnel route: %s\n", strerror(errno));
-      syslog(LOG_ERR, "Del tunnel route:%m");
+      olsr_syslog(OLSR_LOG_ERR, "Del tunnel route:%m");
     }
   
 
@@ -534,7 +534,7 @@ delete_all_inet_gws()
   /* Get a socket */
   if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) 
     {
-      syslog(LOG_ERR, "socket: %m");
+      olsr_syslog(OLSR_LOG_ERR, "socket: %m");
       close(s);
       return -1;
     }
@@ -543,7 +543,7 @@ delete_all_inet_gws()
   ifc.ifc_buf = buf;
   if (ioctl(s, SIOCGIFCONF, (char *)&ifc) < 0) 
     {
-      syslog(LOG_ERR, "ioctl (get interface configuration)");
+      olsr_syslog(OLSR_LOG_ERR, "ioctl (get interface configuration)");
       close(s);
       return -1;
     }
index 056f880..62f1d36 100644 (file)
@@ -59,6 +59,21 @@ void ListInterfaces(void);
 #       error "Unsupported system"
 #endif
 
+/*
+ * Begin: Local function prototypes
+ */
+
+static void
+print_usage();
+
+static void
+set_default_values();
+
+
+/*
+ * End: Local function prototypes
+ */
+
 /**
  *The main funtion does a LOT of things. It should 
  *probably be much shorter
@@ -107,13 +122,12 @@ main(int argc, char *argv[])
 #endif
 
   /* Open syslog */
-  openlog("olsrd", LOG_PID | LOG_ODELAY, LOG_DAEMON);
-  setlogmask(LOG_UPTO(LOG_INFO));
+  olsr_openlog("olsrd");
 
   /*
    * Start syslog entry
    */
-  syslog(LOG_INFO, "%s started", SOFTWARE_VERSION);
+  olsr_syslog(OLSR_LOG_INFO, "%s started", SOFTWARE_VERSION);
 
   /* Set default values */
   set_default_values();
@@ -499,7 +513,7 @@ main(int argc, char *argv[])
    */
   if ((ioctl_s = socket(ipversion, SOCK_DGRAM, 0)) < 0) 
     {
-      syslog(LOG_ERR, "ioctl socket: %m");
+      olsr_syslog(OLSR_LOG_ERR, "ioctl socket: %m");
       close(ioctl_s);
       olsr_exit(__func__, 0);
     }
@@ -590,7 +604,7 @@ tc_redunadancy = %d          mpr coverage = %d\n",
        {
          olsr_printf(1, "Could not read APM info - setting default willingness(%d)\n", WILL_DEFAULT);
 
-         syslog(LOG_ERR, "Could not read APM info - setting default willingness(%d)\n", WILL_DEFAULT);
+         olsr_syslog(OLSR_LOG_ERR, "Could not read APM info - setting default willingness(%d)\n", WILL_DEFAULT);
 
          willingness_set = 1;
          my_willingness = WILL_DEFAULT;
@@ -765,7 +779,7 @@ olsr_shutdown(int signal)
   /* ioctl socket */
   close(ioctl_s);
 
-  syslog(LOG_INFO, "%s stopped", SOFTWARE_VERSION);
+  olsr_syslog(OLSR_LOG_INFO, "%s stopped", SOFTWARE_VERSION);
 
   olsr_printf(1, "\n <<<< %s - terminating >>>>\n           http://www.olsr.org\n", SOFTWARE_VERSION);
 
@@ -780,7 +794,7 @@ olsr_shutdown(int signal)
 /**
  *Sets the default values of variables at startup
  */
-void
+static void
 set_default_values()
 {
   memset(&main_addr, 0, sizeof(union olsr_ip_addr));
@@ -880,7 +894,7 @@ set_default_values()
 
 
 
-void
+static void
 print_usage()
 {
 
index da60c01..a6c3383 100644 (file)
@@ -29,7 +29,6 @@
 #include <pthread.h>
 #include <errno.h>
 #include <signal.h>
-#include <syslog.h>
 #include <sys/utsname.h>
 #include <sys/stat.h>
 #include <arpa/inet.h>
@@ -69,10 +68,4 @@ extern pthread_mutex_t mutex; /* Mutex for thread */
 void
 olsr_shutdown(int);
 
-void
-print_usage();
-
-void
-set_default_values();
-
 #endif
index 04e0c0b..7ef5f5c 100644 (file)
--- a/src/net.c
+++ b/src/net.c
@@ -193,7 +193,7 @@ net_output(struct interface *ifp)
       if(sendto(ifp->olsr_socket, packet, outputsize, MSG_DONTROUTE, (struct sockaddr *)sin, sizeof (*sin)) < 0)
        {
          perror("sendto(v4)");
-         syslog(LOG_ERR, "OLSR: sendto IPv4 %m");
+         olsr_syslog(OLSR_LOG_ERR, "OLSR: sendto IPv4 %m");
          outputsize = 0;
          return -1;
        }
@@ -204,7 +204,7 @@ net_output(struct interface *ifp)
       if(sendto(ifp->olsr_socket, packet, outputsize, MSG_DONTROUTE, (struct sockaddr *)sin6, sizeof (*sin6)) < 0)
        {
          perror("sendto(v6)");
-         syslog(LOG_ERR, "OLSR: sendto IPv6 %m");
+         olsr_syslog(OLSR_LOG_ERR, "OLSR: sendto IPv6 %m");
          fprintf(stderr, "Socket: %d interface: %d\n", ifp->olsr_socket, ifp->if_nr);
          fprintf(stderr, "To: %s (size: %d)\n", ip6_to_string(&sin6->sin6_addr), sizeof(*sin6));
          fprintf(stderr, "Outputsize: %d\n", outputsize);
@@ -324,7 +324,7 @@ net_forward()
          if(sendto(ifn->olsr_socket, fwd_packet, fwdsize, MSG_DONTROUTE, (struct sockaddr *)sin, sizeof (*sin)) < 0)
            {
              perror("sendto(v4)");
-             syslog(LOG_ERR, "OLSR: forward sendto IPv4 %m");
+             olsr_syslog(OLSR_LOG_ERR, "OLSR: forward sendto IPv4 %m");
              return -1;
            }
        }
@@ -334,7 +334,7 @@ net_forward()
          if(sendto(ifn->olsr_socket, fwd_packet, fwdsize, MSG_DONTROUTE, (struct sockaddr *)sin6, sizeof (*sin6)) < 0)
            {
              perror("sendto(v6)");
-             syslog(LOG_ERR, "OLSR: forward sendto IPv6 %m");
+             olsr_syslog(OLSR_LOG_ERR, "OLSR: forward sendto IPv6 %m");
              fprintf(stderr, "Socket: %d interface: %d\n", ifn->olsr_socket, ifn->if_nr);
              fprintf(stderr, "To: %s (size: %d)\n", ip6_to_string(&sin6->sin6_addr), sizeof(*sin6));
              fprintf(stderr, "Outputsize: %d\n", fwdsize);
index 5b62bbc..c926422 100644 (file)
@@ -489,7 +489,7 @@ void
 olsr_exit(const char *msg, int val)
 {
   olsr_printf(1, "OLSR EXIT: %s\n", msg);
-  syslog(LOG_ERR, "olsrd exit: %s\n", msg);
+  olsr_syslog(OLSR_LOG_ERR, "olsrd exit: %s\n", msg);
   fflush(stdout);
   exit_value = val;
 
@@ -514,7 +514,7 @@ olsr_malloc(size_t size, const char *id)
   if((ptr = malloc(size)) == 0) 
     {
       olsr_printf(1, "OUT OF MEMORY: %s\n", strerror(errno));
-      syslog(LOG_ERR, "olsrd: out of memory!: %m\n");
+      olsr_syslog(OLSR_LOG_ERR, "olsrd: out of memory!: %m\n");
       olsr_exit((char *)id, EXIT_FAILURE);
     }
   return ptr;
index 4e10eaa..90cffbd 100644 (file)
@@ -157,7 +157,7 @@ olsr_input(int fd)
          if (cc < 0 && errno != EWOULDBLOCK)
            {
              olsr_printf(1, "error recvfrom: %s", strerror(errno));
-             syslog(LOG_ERR, "error recvfrom: %m");
+             olsr_syslog(OLSR_LOG_ERR, "error recvfrom: %m");
            }
          break;
        }
@@ -194,7 +194,7 @@ olsr_input(int fd)
          olsr_printf(1, "Could not find input interface for message from %s size %d\n",
                      olsr_ip_to_string(&from_addr),
                      cc);
-         syslog(LOG_ERR, "Could not find input interface for message from %s size %d\n",
+         olsr_syslog(OLSR_LOG_ERR, "Could not find input interface for message from %s size %d\n",
                 olsr_ip_to_string(&from_addr),
                 cc);
          return ;
@@ -246,7 +246,7 @@ parse_packet(struct olsr *olsr, int size, struct interface *in_if, union olsr_ip
     {
       olsr_printf(1, "Size error detected in received packet.\nRecieved %d, in packet %d\n", size, ntohs(olsr->olsr_packlen));
            
-      syslog(LOG_ERR, " packet length error in  packet received from %s!",
+      olsr_syslog(OLSR_LOG_ERR, " packet length error in  packet received from %s!",
             olsr_ip_to_string(from_addr));
       return;
     }
@@ -323,7 +323,7 @@ parse_packet(struct olsr *olsr, int size, struct interface *in_if, union olsr_ip
          olsr_printf(1, "packet length error in  packet received from %s!",
                      olsr_ip_to_string(from_addr));
 
-         syslog(LOG_ERR, " packet length error in  packet received from %s!",
+         olsr_syslog(OLSR_LOG_ERR, " packet length error in  packet received from %s!",
                 olsr_ip_to_string(from_addr));
          break;
        }
index 0df2b6b..1a25e08 100644 (file)
@@ -310,7 +310,7 @@ olsr_delete_routes_from_kernel(struct destination_n *delete_kernel_list)
       if(error < 0)
        {
          olsr_printf(1, "Delete route:%s\n", strerror(errno));
-         syslog(LOG_ERR, "Delete route:%m");
+         olsr_syslog(OLSR_LOG_ERR, "Delete route:%m");
        }
 
       destination_kernel=delete_kernel_list;
@@ -362,7 +362,7 @@ olsr_add_routes_in_kernel(struct destination_n *add_kernel_list)
                    if(error < 0) //print the error msg
                      {
                        olsr_printf(1, "Add route: %s\n",strerror(errno));
-                       syslog(LOG_ERR, "Add route:%m");
+                       olsr_syslog(OLSR_LOG_ERR, "Add route:%m");
                      }
                    
                    //getting rid of this node and hooking up the broken point
index 1142291..9984378 100644 (file)
@@ -256,7 +256,7 @@ olsr_register_scheduler_event(void (*event_function)(), float interval, float in
         (new_entry->interval == interval))
        {
          fprintf(stderr, "Register scheduler event: Event alread registered!\n");
-         syslog(LOG_ERR, "Register scheduler event: Event alread registered!\n");
+         olsr_syslog(OLSR_LOG_ERR, "Register scheduler event: Event alread registered!\n");
          return 0;
        }
       new_entry = new_entry->next;
@@ -328,7 +328,7 @@ olsr_register_timeout_function(void (*time_out_function)())
       if(new_entry->function == time_out_function)
        {
          fprintf(stderr, "Register scheduler timeout: Event alread registered!\n");
-         syslog(LOG_ERR, "Register scheduler timeout: Event alread registered!\n");
+         olsr_syslog(OLSR_LOG_ERR, "Register scheduler timeout: Event alread registered!\n");
          return 0;
        }
       new_entry = new_entry->next;
index f6f601d..8f14a09 100644 (file)
@@ -83,7 +83,7 @@ remove_olsr_socket(int fd, void(*pf)(int))
 
   if((fd == 0) || (pf == NULL))
     {
-      syslog(LOG_ERR, "Bogus socket entry - not processing...\n");
+      olsr_syslog(OLSR_LOG_ERR, "Bogus socket entry - not processing...\n");
       return 0;
     }
   olsr_printf(1, "Removing OLSR socket entry %d\n", fd);
@@ -215,7 +215,7 @@ listen_loop()
            {
              if (errno == EINTR)
                continue;
-             syslog(LOG_ERR, "select: %m");
+             olsr_syslog(OLSR_LOG_ERR, "select: %m");
              olsr_printf(1, "Error select: %s", strerror(errno));
            }
          continue;