Convert some plugins to new logger
authorHenning Rogge <hrogge@googlemail.com>
Sat, 21 Mar 2009 22:19:32 +0000 (23:19 +0100)
committerHenning Rogge <hrogge@googlemail.com>
Sat, 21 Mar 2009 22:19:32 +0000 (23:19 +0100)
12 files changed:
lib/arprefresh/src/olsrd_arprefresh.c
lib/bmf/src/Bmf.c
lib/bmf/src/Bmf.h
lib/bmf/src/NetworkInterfaces.c
lib/bmf/src/olsrd_plugin.c
lib/dot_draw/src/olsrd_dot_draw.c
lib/dot_draw/src/olsrd_plugin.c
lib/dyn_gw/src/olsrd_dyn_gw.c
lib/dyn_gw_plain/src/olsrd_dyn_gw_plain.c
lib/txtinfo/src/olsrd_plugin.c
lib/txtinfo/src/olsrd_txtinfo.c
lib/watchdog/src/olsrd_plugin.c

index 43b4e9c..6822593 100644 (file)
@@ -64,8 +64,8 @@
 #include "kernel_routes.h"
 #include "scheduler.h"
 #include "misc.h"
+#include "olsr_logging.h"
 
-#undef ARPREFRESH_DEBUG
 #define PLUGIN_INTERFACE_VERSION 5
 
 /****************************************************************************
@@ -140,7 +140,7 @@ static void olsr_arp_event(void* foo __attribute__((unused)))
                        memcpy(&req.arp.arp_ha.sa_data, &buf.eth.h_source, sizeof(buf.eth.h_source));
                        req.arp.arp_flags = ATF_COM;
                        if_indextoname(from.sll_ifindex, req.arp.arp_dev);
-#ifdef ARPREFRESH_DEBUG
+#if 0
                        {
                                int i;
                                OLSR_PRINTF(0, "Refresh on %s, %s=", req.arp.arp_dev,
@@ -152,7 +152,7 @@ static void olsr_arp_event(void* foo __attribute__((unused)))
                        }
 #endif
                        if (ioctl(arprefresh_sockfd, SIOCSARP, &req) < 0) {
-                               OLSR_PRINTF(1, "*** ARPREFRESH: SIOCSARP: %s\n", strerror(errno));
+                               OLSR_WARN(LOG_PLUGINS, "*** ARPREFRESH: SIOCSARP: %s\n", strerror(errno));
                                close(arprefresh_sockfd);
                                arprefresh_sockfd = -1;
                                return;
@@ -205,12 +205,12 @@ int olsrd_plugin_init(void)
                }
                else
                {
-                       OLSR_PRINTF(1, "*** ARPREFRESH: Cannot create non-blocking filtering packet socket: %s\n", strerror(errno));
+                       OLSR_WARN(LOG_PLUGINS, "*** ARPREFRESH: Cannot create non-blocking filtering packet socket: %s\n", strerror(errno));
                }
        }
        else
        {
-               OLSR_PRINTF(1, "*** ARPREFRESH: IPv6 not supported\n");
+         OLSR_WARN(LOG_PLUGINS, "*** ARPREFRESH: IPv6 not supported\n");
        }
        return ret;
 }
@@ -224,7 +224,7 @@ static void __attribute__ ((destructor)) my_fini(void);
 
 static void my_init(void)
 {
-       printf("OLSRD arprefresh plugin by Sven-Ola\n");
+  OLSR_INFO(LOG_PLUGINS, "OLSRD arprefresh plugin by Sven-Ola\n");
 }
 
 /**
index 0d8fae9..c888457 100644 (file)
@@ -65,6 +65,7 @@
 #include "mpr_selector_set.h" /* olsr_lookup_mprs_set() */
 #include "link_set.h" /* get_best_link_to_neighbor() */
 #include "net_olsr.h" /* ipequal */
+#include "olsr_logging.h"
 
 /* BMF includes */
 #include "NetworkInterfaces.h" /* TBmfInterface, CreateBmfNetworkInterfaces(), CloseBmfNetworkInterfaces() */
@@ -81,46 +82,6 @@ int FanOutLimit = 2;
 int BroadcastRetransmitCount = 1;
 
 /* -------------------------------------------------------------------------
- * Function   : BmfPError
- * Description: Prints an error message at OLSR debug level 1.
- *              First the plug-in name is printed. Then (if format is not NULL
- *              and *format is not empty) the arguments are printed, followed
- *              by a colon and a blank. Then the message and a new-line.
- * Input      : format, arguments
- * Output     : none
- * Return     : none
- * Data Used  : none
- * ------------------------------------------------------------------------- */
-void BmfPError(const char* format, ...)
-{
-#define MAX_STR_DESC 255
-#ifndef NODEBUG
-  char* strErr = strerror(errno);
-#endif
-  char strDesc[MAX_STR_DESC];
-
-  /* Rely on short-circuit boolean evaluation */
-  if (format == NULL || *format == '\0')
-  {
-    OLSR_PRINTF(1, "%s: %s\n", PLUGIN_NAME, strErr);
-  }
-  else
-  {
-    va_list arglist;
-
-    OLSR_PRINTF(1, "%s: ", PLUGIN_NAME);
-
-    va_start(arglist, format);
-    vsnprintf(strDesc, MAX_STR_DESC, format, arglist);
-    va_end(arglist);
-
-    strDesc[MAX_STR_DESC - 1] = '\0'; /* Ensures null termination */
-
-    OLSR_PRINTF(1, "%s: %s\n", strDesc, strErr);
-  }
-} /* BmfPError */
-
-/* -------------------------------------------------------------------------
  * Function   : MainAddressOf
  * Description: Lookup the main address of a node
  * Input      : ip - IP address of the node
@@ -174,10 +135,9 @@ static void EncapsulateAndForwardPacket(
 
   if (nPossibleNeighbors <= 0)
   {
-    OLSR_PRINTF(
-      8,
-      "%s: --> not encap-forwarding on \"%s\": there is no neighbor that needs my retransmission\n",
-      PLUGIN_NAME_SHORT,
+    OLSR_DEBUG(
+      LOG_PLUGINS,
+      "BMF: not encap-forwarding on \"%s\": there is no neighbor that needs my retransmission\n",
       intf->ifName);
     return;
   }
@@ -244,17 +204,16 @@ static void EncapsulateAndForwardPacket(
     /* Evaluate and display result */
     if (nBytesWritten != udpDataLen)
     {
-      BmfPError("sendto() error forwarding pkt on \"%s\"", intf->ifName);
+      OLSR_WARN(LOG_PLUGINS, "BMF: sendto() error forwarding pkt on \"%s\"", intf->ifName);
     }
     else
     {
       /* Increase counter */
       intf->nBmfPacketsTx++;
 
-      OLSR_PRINTF(
-        8,
-        "%s: --> encapsulated and forwarded on \"%s\" to %s\n",
-        PLUGIN_NAME_SHORT,
+      OLSR_DEBUG(
+        LOG_PLUGINS,
+        "BMF: encapsulated and forwarded on \"%s\" to %s\n",
         intf->ifName,
         inet_ntoa(forwardTo.sin_addr));
     } /* if (nBytesWritten != udpDataLen) */
@@ -333,10 +292,9 @@ static void BmfPacketCaptured(
 
   src.v4 = ipHeader->ip_src;
 
-  OLSR_PRINTF(
-    8,
-    "%s: %s pkt of %ld bytes captured on %s interface \"%s\": %s->%s\n",
-    PLUGIN_NAME_SHORT,
+  OLSR_DEBUG(
+    LOG_PLUGINS,
+    "BMF: %s pkt of %ld bytes captured on %s interface \"%s\": %s->%s\n",
     sllPkttype == PACKET_OUTGOING ? "outgoing" : "incoming",
     (long)ipPacketLen,
     isFromOlsrIntf ? "OLSR" : "non-OLSR",
@@ -356,10 +314,7 @@ static void BmfPacketCaptured(
     /* Increase counter */
     intf->nBmfPacketsRxDup++;
 
-    OLSR_PRINTF(
-      8,
-      "%s: --> discarding: packet is duplicate\n",
-      PLUGIN_NAME_SHORT);
+    OLSR_DEBUG(LOG_PLUGINS, "BMF: discarding: packet is duplicate\n");
     return;
   }
 
@@ -440,20 +395,18 @@ static void BmfPacketCaptured(
         /* Case 1.1 */
         {
           struct ipaddr_str buf;
-          OLSR_PRINTF(
-            8,
-            "%s: --> not encap-forwarding on \"%s\": I am not selected as MPR by neighbor %s\n",
-            PLUGIN_NAME_SHORT,
+          OLSR_DEBUG(
+            LOG_PLUGINS,
+            "BMF: not encap-forwarding on \"%s\": I am not selected as MPR by neighbor %s\n",
             walker->ifName,
             olsr_ip_to_string(&buf, &src));
         }
       }
       else if (sllPkttype == PACKET_OUTGOING && intf == walker)
       {
-        OLSR_PRINTF(
-          8,
-          "%s: --> not encap-forwarding on \"%s\": pkt was captured on that interface\n",
-          PLUGIN_NAME_SHORT,
+        OLSR_DEBUG(
+          LOG_PLUGINS,
+          "BMF: not encap-forwarding on \"%s\": pkt was captured on that interface\n",
           walker->ifName);
       }
       else
@@ -498,14 +451,14 @@ static void BmfPacketCaptured(
         sizeof(dest));
       if (nBytesWritten != ipPacketLen)
       {
-        BmfPError("sendto() error forwarding pkt on \"%s\"", walker->ifName);
+        OLSR_WARN(LOG_PLUGINS, "BMF: sendto() error forwarding pkt on \"%s\"", walker->ifName);
       }
       else
       {
         /* Increase counter */
         walker->nBmfPacketsTx++;
 
-        OLSR_PRINTF(8, "%s: --> forwarded on \"%s\"\n", PLUGIN_NAME_SHORT, walker->ifName);
+        OLSR_WARN(LOG_PLUGINS, "BMF: forwarded on \"%s\"\n", walker->ifName);
       }
     } /* else if (isFromOlsrIntf && !isToOlsrIntf) */
 
@@ -524,10 +477,9 @@ static void BmfPacketCaptured(
       /* Don't forward on interface on which packet was received */
       if (intf == walker)
       {
-        OLSR_PRINTF(
-          8,
-          "%s: --> not forwarding on \"%s\": pkt was captured on that interface\n",
-          PLUGIN_NAME_SHORT,
+        OLSR_DEBUG(
+          LOG_PLUGINS,
+          "not forwarding on \"%s\": pkt was captured on that interface\n",
           walker->ifName);
       }
 
@@ -564,17 +516,16 @@ static void BmfPacketCaptured(
           sizeof(dest));
         if (nBytesWritten != ipPacketLen)
         {
-          BmfPError("sendto() error forwarding pkt on \"%s\"", walker->ifName);
+          OLSR_WARN(LOG_PLUGINS, "BMF: sendto() error forwarding pkt on \"%s\"", walker->ifName);
         }
         else
         {
           /* Increase counter */
           walker->nBmfPacketsTx++;
 
-          OLSR_PRINTF(
-            8,
-            "%s: --> forwarded from non-OLSR on non-OLSR \"%s\"\n",
-            PLUGIN_NAME_SHORT,
+          OLSR_DEBUG(
+            LOG_PLUGINS,
+            "BMF: forwarded from non-OLSR on non-OLSR \"%s\"\n",
             walker->ifName);
         }
       } /* if (intf == walker) */
@@ -638,11 +589,9 @@ static void BmfEncapsulationPacketReceived(
   /* Increase counter */
   intf->nBmfPacketsRx++;
 
-  /* Beware: not possible to call olsr_ip_to_string more than 4 times in same printf */
-  OLSR_PRINTF(
-    8,
-    "%s: encapsulated pkt of %ld bytes incoming on \"%s\": %s->%s, forwarded by %s to %s\n",
-    PLUGIN_NAME_SHORT,
+  OLSR_DEBUG(
+    LOG_PLUGINS,
+    "BMF: encapsulated pkt of %ld bytes incoming on \"%s\": %s->%s, forwarded by %s to %s\n",
     (long)ipPacketLen,
     intf->ifName,
     olsr_ip_to_string(&mcSrcBuf, &mcSrc),
@@ -658,8 +607,8 @@ static void BmfEncapsulationPacketReceived(
       encapsulationHdr->len != BMF_ENCAP_LEN ||
       ntohs(encapsulationHdr->reserved != 0))
   {
-    OLSR_PRINTF(
-      8,
+    OLSR_DEBUG(
+      LOG_PLUGINS,
       "%s: --> discarding: format of BMF encapsulation header not recognized\n",
       PLUGIN_NAME_SHORT);
     return;
@@ -671,10 +620,7 @@ static void BmfEncapsulationPacketReceived(
     /* Increase counter */
     intf->nBmfPacketsRxDup++;
 
-    OLSR_PRINTF(
-      8,
-      "%s: --> discarding: packet is duplicate\n",
-      PLUGIN_NAME_SHORT);
+    OLSR_DEBUG(LOG_PLUGINS, "BMF: discarding: packet is duplicate\n");
     return;
   }
 
@@ -700,15 +646,11 @@ static void BmfEncapsulationPacketReceived(
     nBytesWritten = write(EtherTunTapFd, bufferToWrite, nBytesToWrite);
     if (nBytesWritten != nBytesToWrite)
     {
-      BmfPError("write() error forwarding encapsulated pkt on \"%s\"", EtherTunTapIfName);
+      OLSR_WARN(LOG_PLUGINS, "BMF: write() error forwarding encapsulated pkt on \"%s\"", EtherTunTapIfName);
     }
     else
     {
-      OLSR_PRINTF(
-        8,
-        "%s: --> unpacked and delivered locally on \"%s\"\n",
-        PLUGIN_NAME_SHORT,
-        EtherTunTapIfName);
+      OLSR_DEBUG(LOG_PLUGINS, "BMF: unpacked and delivered locally on \"%s\"\n", EtherTunTapIfName);
     }
   } /* if (EtherTunTapFd >= 0) */
 
@@ -770,17 +712,16 @@ static void BmfEncapsulationPacketReceived(
         sizeof(dest));
       if (nBytesWritten != ipPacketLen)
       {
-        BmfPError("sendto() error forwarding unpacked encapsulated pkt on \"%s\"", walker->ifName);
+        OLSR_WARN(LOG_PLUGINS, "BMF: sendto() error forwarding unpacked encapsulated pkt on \"%s\"", walker->ifName);
       }
       else
       {
         /* Increase counter */
         walker->nBmfPacketsTx++;
 
-        OLSR_PRINTF(
-          8,
-          "%s: --> unpacked and forwarded on \"%s\"\n",
-          PLUGIN_NAME_SHORT,
+        OLSR_DEBUG(
+          LOG_PLUGINS,
+          "unpacked and forwarded on \"%s\"\n",
           walker->ifName);
       }
     } /* if (walker->olsrIntf == NULL) */
@@ -808,10 +749,9 @@ static void BmfEncapsulationPacketReceived(
 
       if (nPossibleNeighbors <= 0)
       {
-        OLSR_PRINTF(
-          8,
-          "%s: --> not forwarding on \"%s\": there is no neighbor that needs my retransmission\n",
-          PLUGIN_NAME_SHORT,
+        OLSR_DEBUG(
+          LOG_PLUGINS,
+          "not forwarding on \"%s\": there is no neighbor that needs my retransmission\n",
           walker->ifName);
 
         continue; /* for */
@@ -874,17 +814,16 @@ static void BmfEncapsulationPacketReceived(
         /* Evaluate and display result */
         if (nBytesWritten != encapsulationUdpDataLen)
         {
-          BmfPError("sendto() error forwarding encapsulated pkt on \"%s\"", walker->ifName);
+          OLSR_WARN(LOG_PLUGINS, "sendto() error forwarding encapsulated pkt on \"%s\"", walker->ifName);
         }
         else
         {
           /* Increase counter */
           walker->nBmfPacketsTx++;
 
-          OLSR_PRINTF(
-            8,
-            "%s: --> forwarded on \"%s\" to %s\n",
-            PLUGIN_NAME_SHORT,
+          OLSR_DEBUG(
+            LOG_PLUGINS,
+            "forwarded on \"%s\" to %s\n",
             walker->ifName,
             inet_ntoa(forwardTo.sin_addr));
         } /* if */
@@ -896,10 +835,9 @@ static void BmfEncapsulationPacketReceived(
       struct ipaddr_str buf;
       /* 'walker' is an OLSR interface, but I am not selected as MPR. In that
        * case, don't forward. */
-      OLSR_PRINTF(
-        8,
-        "%s: --> not forwarding on \"%s\": I am not selected as MPR by %s\n",
-        PLUGIN_NAME_SHORT,
+      OLSR_DEBUG(
+        LOG_PLUGINS,
+        "not forwarding on \"%s\": I am not selected as MPR by %s\n",
         walker->ifName,
         olsr_ip_to_string(&buf, forwardedBy));
     } /* else */
@@ -949,10 +887,9 @@ static void BmfTunPacketCaptured(unsigned char* encapsulationUdpData)
 
   srcIp.v4 = ipHeader->ip_src;
 
-  OLSR_PRINTF(
-    8,
-    "%s: outgoing pkt of %ld bytes captured on tuntap interface \"%s\": %s->%s\n",
-    PLUGIN_NAME_SHORT,
+  OLSR_DEBUG(
+    LOG_PLUGINS,
+    "outgoing pkt of %ld bytes captured on tuntap interface \"%s\": %s->%s\n",
     (long)ipPacketLen,
     EtherTunTapIfName,
     olsr_ip_to_string(&srcIpBuf, &srcIp),
@@ -964,10 +901,7 @@ static void BmfTunPacketCaptured(unsigned char* encapsulationUdpData)
   /* Check if this packet was seen recently */
   if (CheckAndMarkRecentPacket(crc32))
   {
-    OLSR_PRINTF(
-      8,
-      "%s: --> discarding: packet is duplicate\n",
-      PLUGIN_NAME_SHORT);
+    OLSR_DEBUG(LOG_PLUGINS, "discarding: packet is duplicate\n");
     return;
   }
 
@@ -1027,17 +961,16 @@ static void BmfTunPacketCaptured(unsigned char* encapsulationUdpData)
         sizeof(dest));
       if (nBytesWritten != ipPacketLen)
       {
-        BmfPError("sendto() error forwarding pkt on \"%s\"", walker->ifName);
+        OLSR_WARN(LOG_PLUGINS, "sendto() error forwarding pkt on \"%s\"", walker->ifName);
       }
       else
       {
         /* Increase counter */
         walker->nBmfPacketsTx++;
 
-        OLSR_PRINTF(
-          8,
-          "%s: --> forwarded from non-OLSR to non-OLSR \"%s\"\n",
-          PLUGIN_NAME_SHORT,
+        OLSR_DEBUG(
+          LOG_PLUGINS,
+          "forwarded from non-OLSR to non-OLSR \"%s\"\n",
           walker->ifName);
       } /* if */
     } /* if */
@@ -1072,7 +1005,7 @@ static void DoBmf(void)
   {
     if (errno != EINTR)
     {
-      BmfPError("select() error");
+      OLSR_WARN(LOG_PLUGINS, "select() error");
     }
     return;
   }
@@ -1109,7 +1042,7 @@ static void DoBmf(void)
           &addrLen);
         if (nBytes < 0)
         {
-          BmfPError("recvfrom() error on \"%s\"", walker->ifName);
+          OLSR_WARN(LOG_PLUGINS, "recvfrom() error on \"%s\"", walker->ifName);
 
           continue; /* for */
         } /* if (nBytes < 0) */
@@ -1122,10 +1055,9 @@ static void DoBmf(void)
          * returned on a non-VLAN interface, for the same ethernet frame. */
         if (nBytes < (int)sizeof(struct ip))
         {
-          OLSR_PRINTF(
-            1,
-            "%s: captured frame too short (%d bytes) on \"%s\"\n",
-            PLUGIN_NAME,
+          OLSR_DEBUG(
+            LOG_PLUGINS,
+            "captured frame too short (%d bytes) on \"%s\"\n",
             nBytes,
             walker->ifName);
 
@@ -1174,7 +1106,7 @@ static void DoBmf(void)
           &addrLen);
         if (nBytes < 0)
         {
-          BmfPError("recvfrom() error on \"%s\"", walker->ifName);
+          OLSR_WARN(LOG_PLUGINS, "recvfrom() error on \"%s\"", walker->ifName);
 
           continue; /* for */
         } /* if (nBytes < 0) */
@@ -1221,10 +1153,9 @@ static void DoBmf(void)
           sizeof(struct ip);
         if (nBytes < minimumLength)
         {
-          OLSR_PRINTF(
-            1,
-            "%s: captured a too short encapsulation packet (%d bytes) on \"%s\"\n",
-            PLUGIN_NAME,
+          OLSR_DEBUG(
+            LOG_PLUGINS,
+            "captured a too short encapsulation packet (%d bytes) on \"%s\"\n",
             nBytes,
             walker->ifName);
 
@@ -1268,7 +1199,7 @@ static void DoBmf(void)
           &fromLen);
         if (nBytes < 0)
         {
-          BmfPError("recvfrom() error on \"%s\"", walker->ifName);
+          OLSR_WARN(LOG_PLUGINS, "recvfrom() error on \"%s\"", walker->ifName);
 
           continue; /* for */
         } /* if (nBytes < 0) */
@@ -1285,10 +1216,9 @@ static void DoBmf(void)
         if (nBytes < minimumLength)
         {
           struct ipaddr_str buf;
-          OLSR_PRINTF(
-            1,
-            "%s: received a too short encapsulation packet (%d bytes) from %s on \"%s\"\n",
-            PLUGIN_NAME,
+          OLSR_DEBUG(
+            LOG_PLUGINS,
+            "received a too short encapsulation packet (%d bytes) from %s on \"%s\"\n",
             nBytes,
             olsr_ip_to_string(&buf, &forwardedBy),
             walker->ifName);
@@ -1327,7 +1257,7 @@ static void DoBmf(void)
 
       if (nBytes < 0)
       {
-        BmfPError("recvfrom() error on \"%s\"", EtherTunTapIfName);
+        OLSR_WARN(LOG_PLUGINS, "recvfrom() error on \"%s\"", EtherTunTapIfName);
       }
       else
       {
@@ -1335,10 +1265,9 @@ static void DoBmf(void)
          * packet which contains at least a minimum-size IP header */
         if (nBytes < (int)sizeof(struct ip))
         {
-          OLSR_PRINTF(
-            1,
-            "%s: captured packet too short (%d bytes) on \"%s\"\n",
-            PLUGIN_NAME,
+          OLSR_DEBUG(
+            LOG_PLUGINS,
+            "captured packet too short (%d bytes) on \"%s\"\n",
             nBytes,
             EtherTunTapIfName);
         }
@@ -1385,7 +1314,7 @@ static void* BmfRun(void* useless __attribute__((unused)))
   sigdelset(&blockedSigs, SIGALRM);
   if (pthread_sigmask(SIG_BLOCK, &blockedSigs, NULL) != 0)
   {
-    BmfPError("pthread_sigmask() error");
+    OLSR_WARN(LOG_PLUGINS, "pthread_sigmask() error");
   }
 
   /* Set up the signal handler for the process: use SIGALRM to terminate
@@ -1396,7 +1325,7 @@ static void* BmfRun(void* useless __attribute__((unused)))
    * function (see DoBmf()). */
   if (signal(SIGALRM, BmfSignalHandler) == SIG_ERR)
   {
-    BmfPError("signal() error");
+    OLSR_WARN(LOG_PLUGINS, "signal() error");
   }
 
   /* Call the thread function until flagged to exit */
@@ -1425,7 +1354,7 @@ int InterfaceChange(struct interface* interf, int action)
   {
   case (IFCHG_IF_ADD):
     AddInterface(interf);
-    OLSR_PRINTF(1, "%s: interface %s added\n", PLUGIN_NAME, interf->int_name);
+    OLSR_DEBUG(LOG_PLUGINS, "interface %s added\n", interf->int_name);
     break;
 
   case (IFCHG_IF_REMOVE):
@@ -1436,18 +1365,17 @@ int InterfaceChange(struct interface* interf, int action)
      * interfaces. After that, BMF is re-started (InitBmf(interf)). */
     CloseBmf();
     InitBmf(interf);
-    OLSR_PRINTF(1, "%s: interface %s removed\n", PLUGIN_NAME, interf->int_name);
+    OLSR_DEBUG(LOG_PLUGINS, "interface %s removed\n", interf->int_name);
     break;
 
   case (IFCHG_IF_UPDATE):
-    OLSR_PRINTF(1, "%s: interface %s updated\n", PLUGIN_NAME, interf->int_name);
+    OLSR_DEBUG(LOG_PLUGINS, "interface %s updated\n", interf->int_name);
     break;
 
   default:
-    OLSR_PRINTF(
-      1,
-      "%s: interface %s: error - unknown action (%d)\n",
-      PLUGIN_NAME,
+    OLSR_WARN(
+      LOG_PLUGINS,
+      "interface %s: error - unknown action (%d)\n",
       interf->int_name, action);
     break;
   }
@@ -1499,7 +1427,7 @@ int InitBmf(struct interface* skipThisIntf)
   BmfThreadRunning = 1;
   if (pthread_create(&BmfThread, NULL, BmfRun, NULL) != 0)
   {
-    BmfPError("pthread_create() error");
+    OLSR_WARN(LOG_PLUGINS, "pthread_create() error");
     return 0;
   }
 
@@ -1546,13 +1474,13 @@ void CloseBmf(void)
      * signal in its thread entry function BmfRun(...). */
     if (pthread_kill(BmfThread, SIGALRM) != 0)
     {
-      BmfPError("pthread_kill() error");
+      OLSR_WARN(LOG_PLUGINS, "pthread_kill() error");
     }
 
     /* Wait for BmfThread to acknowledge */
     if (pthread_join(BmfThread, NULL) != 0)
     {
-      BmfPError("pthread_join() error");
+      OLSR_WARN(LOG_PLUGINS, "pthread_join() error");
     }
   }
 
index f8f61c8..d2d769a 100644 (file)
@@ -60,7 +60,6 @@ struct interface;
 extern int FanOutLimit;
 extern int BroadcastRetransmitCount;
 
-void BmfPError(const char* format, ...) __attribute__((format(printf, 1, 2)));
 union olsr_ip_addr* MainAddressOf(union olsr_ip_addr* ip);
 int InterfaceChange(struct interface* interf, int action);
 int SetFanOutLimit(const char* value, void* data, set_plugin_parameter_addon addon);
index 6fb16b0..e31a4a4 100644 (file)
@@ -66,6 +66,7 @@
 #include "net_olsr.h" /* ipequal */
 #include "lq_plugin.h"
 #include "olsr_ip_prefix_list.h"
+#include "olsr_logging.h"
 
 /* Plugin includes */
 #include "Packet.h" /* IFHWADDRLEN */
@@ -322,8 +323,8 @@ int DeactivateSpoofFilter(void)
   procSpoof = fopen(procFile, "r");
   if (procSpoof == NULL)
   {
-    fprintf(
-      stderr,
+    OLSR_WARN(
+      LOG_PLUGINS,
       "WARNING! Could not open the %s file to check/disable the IP spoof filter!\n"
       "Are you using the procfile filesystem?\n"
       "Does your system support IPv4?\n"
@@ -342,16 +343,13 @@ int DeactivateSpoofFilter(void)
   procSpoof = fopen(procFile, "w");
   if (procSpoof == NULL)
   {
-    fprintf(stderr, "Could not open %s for writing!\n", procFile);
-    fprintf(
-      stderr,
+    OLSR_WARN(LOG_PLUGINS, "Could not open %s for writing!\n"
       "I will continue (in 3 sec) - but you should manually ensure that IP"
-      " spoof filtering is disabled!\n\n");
+      " spoof filtering is disabled!\n\n", procFile);
     sleep(3);
     return 0;
   }
 
-  syslog(LOG_INFO, "Writing \"0\" to %s", procFile);
   fputs("0", procSpoof);
 
   fclose(procSpoof);
@@ -380,12 +378,10 @@ void RestoreSpoofFilter(void)
   procSpoof = fopen(procFile, "w");
   if (procSpoof == NULL)
   {
-    fprintf(stderr, "Could not open %s for writing!\nSettings not restored!\n", procFile);
+    OLSR_WARN(LOG_PLUGINS, "Could not open %s for writing!\nSettings not restored!\n", procFile);
   }
   else
   {
-    syslog(LOG_INFO, "Resetting %s to %c\n", procFile, EthTapSpoofState);
-
     fputc(EthTapSpoofState, procSpoof);
     fclose(procSpoof);
   }
@@ -453,10 +449,9 @@ void FindNeighbors(
       continue; /* for */
     }
 
-    OLSR_PRINTF(
-      9,
-      "%s: ----> Considering forwarding pkt on \"%s\" to %s\n",
-      PLUGIN_NAME_SHORT,
+    OLSR_DEBUG(
+      LOG_PLUGINS,
+      "Considering forwarding pkt on \"%s\" to %s\n",
       intf->ifName,
       olsr_ip_to_string(&buf, &walker->neighbor_iface_addr));
 
@@ -466,10 +461,9 @@ void FindNeighbors(
      * passed IP addresses (if passed). Rely on short-circuit boolean evaluation. */
     if (source != NULL && olsr_ipcmp(neighborMainIp, MainAddressOf(source)) == 0)
     {
-      OLSR_PRINTF(
-        9,
-        "%s: ----> Not forwarding to %s: is source of pkt\n",
-        PLUGIN_NAME_SHORT,
+      OLSR_DEBUG(
+        LOG_PLUGINS,
+        "Not forwarding to %s: is source of pkt\n",
         olsr_ip_to_string(&buf, &walker->neighbor_iface_addr));
 
       continue; /* for */
@@ -478,10 +472,9 @@ void FindNeighbors(
     /* Rely on short-circuit boolean evaluation */
     if (forwardedBy != NULL && olsr_ipcmp(neighborMainIp, MainAddressOf(forwardedBy)) == 0)
     {
-      OLSR_PRINTF(
-        9,
-        "%s: ----> Not forwarding to %s: is the node that forwarded the pkt\n",
-        PLUGIN_NAME_SHORT,
+      OLSR_DEBUG(
+        LOG_PLUGINS,
+        "Not forwarding to %s: is the node that forwarded the pkt\n",
         olsr_ip_to_string(&buf, &walker->neighbor_iface_addr));
 
       continue; /* for */
@@ -490,10 +483,9 @@ void FindNeighbors(
     /* Rely on short-circuit boolean evaluation */
     if (forwardedTo != NULL && olsr_ipcmp(neighborMainIp, MainAddressOf(forwardedTo)) == 0)
     {
-      OLSR_PRINTF(
-        9,
-        "%s: ----> Not forwarding to %s: is the node to which the pkt was forwarded\n",
-        PLUGIN_NAME_SHORT,
+      OLSR_DEBUG(
+        LOG_PLUGINS,
+        "Not forwarding to %s: is the node to which the pkt was forwarded\n",
         olsr_ip_to_string(&buf, &walker->neighbor_iface_addr));
 
       continue; /* for */
@@ -506,20 +498,18 @@ void FindNeighbors(
 
     if (currEtx >= LINK_COST_BROKEN)
     {
-      OLSR_PRINTF(
-        9,
-        "%s: ----> Not forwarding to %s: link is timing out\n",
-        PLUGIN_NAME_SHORT,
+      OLSR_DEBUG(
+        LOG_PLUGINS,
+        "Not forwarding to %s: link is timing out\n",
         olsr_ip_to_string(&buf, &walker->neighbor_iface_addr));
 
       continue; /* for */
     }
 
     /* Compare costs to check if the candidate neighbor is best reached via 'intf' */
-    OLSR_PRINTF(
-      9,
-      "%s: ----> Forwarding pkt to %s will cost ETX %5.2f\n",
-      PLUGIN_NAME_SHORT,
+    OLSR_DEBUG(
+      LOG_PLUGINS,
+      "Forwarding pkt to %s will cost ETX %5.2f\n",
       olsr_ip_to_string(&buf, &walker->neighbor_iface_addr),
       currEtx);
 
@@ -534,22 +524,20 @@ void FindNeighbors(
     {
       if (bestLinkToNeighbor == NULL)
       {
-        OLSR_PRINTF(
-          9,
-          "%s: ----> Not forwarding to %s: no link found\n",
-          PLUGIN_NAME_SHORT,
+        OLSR_DEBUG(
+          LOG_PLUGINS,
+          "Not forwarding to %s: no link found\n",
           olsr_ip_to_string(&buf, &walker->neighbor_iface_addr));
       }
       else
       {
-#ifndef NODEBUG
+#if !defined REMOVE_DEBUG
         struct interface* bestIntf = if_ifwithaddr(&bestLinkToNeighbor->local_iface_addr);
         struct lqtextbuffer lqbuffer;
 #endif
-        OLSR_PRINTF(
-          9,
-          "%s: ----> Not forwarding to %s: \"%s\" gives a better link to this neighbor, costing %s\n",
-          PLUGIN_NAME_SHORT,
+        OLSR_DEBUG(
+          LOG_PLUGINS,
+          "Not forwarding to %s: \"%s\" gives a better link to this neighbor, costing %s\n",
           olsr_ip_to_string(&buf, &walker->neighbor_iface_addr),
           bestIntf->int_name,
           get_linkcost_text(bestLinkToNeighbor->linkcost, false, &lqbuffer));
@@ -560,14 +548,13 @@ void FindNeighbors(
 
     if (forwardedBy != NULL)
     {
-#ifndef NODEBUG
-      struct ipaddr_str forwardedByBuf, niaBuf;
+#if !defined REMOVE_DEBUG
+struct ipaddr_str forwardedByBuf, niaBuf;
       struct lqtextbuffer lqbuffer;
 #endif
-      OLSR_PRINTF(
-        9,
-        "%s: ----> 2-hop path from %s via me to %s will cost ETX %s\n",
-        PLUGIN_NAME_SHORT,
+      OLSR_DEBUG(
+        LOG_PLUGINS,
+        "2-hop path from %s via me to %s will cost ETX %s\n",
         olsr_ip_to_string(&forwardedByBuf, forwardedBy),
         olsr_ip_to_string(&niaBuf, &walker->neighbor_iface_addr),
         get_linkcost_text(previousLinkEtx + currEtx, true, &lqbuffer));
@@ -592,15 +579,14 @@ void FindNeighbors(
 
           if (previousLinkEtx + currEtx > tcEtx)
           {
-#ifndef NODEBUG
+#if !defined REMOVE_DEBUG
             struct ipaddr_str neighbor_iface_buf, forw_buf;
             struct lqtextbuffer lqbuffer;
             olsr_ip_to_string(&neighbor_iface_buf, &walker->neighbor_iface_addr);
 #endif
-            OLSR_PRINTF(
-              9,
-              "%s: ----> Not forwarding to %s: I am not an MPR between %s and %s, direct link costs %s\n",
-              PLUGIN_NAME_SHORT,
+            OLSR_DEBUG(
+              LOG_PLUGINS,
+              "Not forwarding to %s: I am not an MPR between %s and %s, direct link costs %s\n",
               neighbor_iface_buf.buf,
               olsr_ip_to_string(&forw_buf, forwardedBy),
               neighbor_iface_buf.buf,
@@ -633,19 +619,17 @@ void FindNeighbors(
   /* Display the result of the neighbor search */
   if (*nPossibleNeighbors == 0)
   {
-    OLSR_PRINTF(
-      9,
-      "%s: ----> No suitable neighbor found to forward to on \"%s\"\n",
-      PLUGIN_NAME_SHORT,
+    OLSR_DEBUG(
+      LOG_PLUGINS,
+      "No suitable neighbor found to forward to on \"%s\"\n",
       intf->ifName);
   }
   else
   {
     struct ipaddr_str buf;
-    OLSR_PRINTF(
-      9,
-      "%s: ----> %d neighbors found on \"%s\"; best neighbor to forward to: %s\n",
-      PLUGIN_NAME_SHORT,
+    OLSR_DEBUG(
+      LOG_PLUGINS,
+      "%d neighbors found on \"%s\"; best neighbor to forward to: %s\n",
       *nPossibleNeighbors,
       intf->ifName,
       olsr_ip_to_string(&buf, &(*bestNeighbor)->neighbor_iface_addr));
@@ -674,7 +658,7 @@ static int CreateCaptureSocket(const char* ifName)
   int skfd = socket(PF_PACKET, SOCK_DGRAM, htons(ETH_P_IP));
   if (skfd < 0)
   {
-    BmfPError("socket(PF_PACKET) error");
+    OLSR_WARN(LOG_PLUGINS, "socket(PF_PACKET) error");
     return -1;
   }
 
@@ -684,7 +668,7 @@ static int CreateCaptureSocket(const char* ifName)
   mreq.mr_type = PACKET_MR_PROMISC;
   if (setsockopt(skfd, SOL_PACKET, PACKET_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) < 0)
   {
-    BmfPError("setsockopt(PACKET_MR_PROMISC) error");
+    OLSR_WARN(LOG_PLUGINS, "setsockopt(PACKET_MR_PROMISC) error");
     close(skfd);
     return -1;
   }
@@ -695,7 +679,7 @@ static int CreateCaptureSocket(const char* ifName)
   req.ifr_name[IFNAMSIZ-1] = '\0'; /* Ensures null termination */
   if (ioctl(skfd, SIOCGIFHWADDR, &req) < 0)
   {
-    BmfPError("error retrieving MAC address");
+    OLSR_WARN(LOG_PLUGINS, "error retrieving MAC address");
     close(skfd);
     return -1;
   }
@@ -710,7 +694,7 @@ static int CreateCaptureSocket(const char* ifName)
 
   if (bind(skfd, (struct sockaddr*)&bindTo, sizeof(bindTo)) < 0)
   {
-    BmfPError("bind() error");
+    OLSR_WARN(LOG_PLUGINS, "bind() error");
     close(skfd);
     return -1;
   }
@@ -718,7 +702,7 @@ static int CreateCaptureSocket(const char* ifName)
   /* Set socket to blocking operation */
   if (fcntl(skfd, F_SETFL, fcntl(skfd, F_GETFL, 0) & ~O_NONBLOCK) < 0)
   {
-    BmfPError("fcntl() error");
+    OLSR_WARN(LOG_PLUGINS, "fcntl() error");
     close(skfd);
     return -1;
   }
@@ -750,7 +734,7 @@ static int CreateListeningSocket(const char* ifName)
   int skfd = socket(PF_PACKET, SOCK_DGRAM, htons(ETH_P_IP));
   if (skfd < 0)
   {
-    BmfPError("socket(PF_PACKET) error");
+    OLSR_WARN(LOG_PLUGINS, "socket(PF_PACKET) error");
     return -1;
   }
 
@@ -760,7 +744,7 @@ static int CreateListeningSocket(const char* ifName)
   mreq.mr_type = PACKET_MR_PROMISC;
   if (setsockopt(skfd, SOL_PACKET, PACKET_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) < 0)
   {
-    BmfPError("setsockopt(PACKET_MR_PROMISC) error");
+    OLSR_WARN(LOG_PLUGINS, "setsockopt(PACKET_MR_PROMISC) error");
     close(skfd);
     return -1;
   }
@@ -771,7 +755,7 @@ static int CreateListeningSocket(const char* ifName)
   req.ifr_name[IFNAMSIZ-1] = '\0'; /* Ensures null termination */
   if (ioctl(skfd, SIOCGIFHWADDR, &req) < 0)
   {
-    BmfPError("error retrieving MAC address");
+    OLSR_WARN(LOG_PLUGINS, "error retrieving MAC address");
     close(skfd);
     return -1;
   }
@@ -786,7 +770,7 @@ static int CreateListeningSocket(const char* ifName)
 
   if (bind(skfd, (struct sockaddr*)&bindTo, sizeof(bindTo)) < 0)
   {
-    BmfPError("bind() error");
+    OLSR_WARN(LOG_PLUGINS, "bind() error");
     close(skfd);
     return -1;
   }
@@ -794,7 +778,7 @@ static int CreateListeningSocket(const char* ifName)
   /* Set socket to blocking operation */
   if (fcntl(skfd, F_SETFL, fcntl(skfd, F_GETFL, 0) & ~O_NONBLOCK) < 0)
   {
-    BmfPError("fcntl() error");
+    OLSR_WARN(LOG_PLUGINS, "fcntl() error");
     close(skfd);
     return -1;
   }
@@ -824,14 +808,14 @@ static int CreateEncapsulateSocket(const char* ifName)
   int skfd = socket(PF_INET, SOCK_DGRAM, 0);
   if (skfd < 0)
   {
-    BmfPError("socket(PF_INET) error");
+    OLSR_WARN(LOG_PLUGINS, "socket(PF_INET) error");
     return -1;
   }
 
   /* Enable sending to broadcast addresses */
   if (setsockopt(skfd, SOL_SOCKET, SO_BROADCAST, &on, sizeof(on)) < 0)
   {
-    BmfPError("setsockopt(SO_BROADCAST) error");
+    OLSR_WARN(LOG_PLUGINS, "setsockopt(SO_BROADCAST) error");
     close(skfd);
     return -1;
   }
@@ -840,7 +824,7 @@ static int CreateEncapsulateSocket(const char* ifName)
   /* When using Kernel 2.6 this must happer prior to the port binding! */
   if (setsockopt(skfd, SOL_SOCKET, SO_BINDTODEVICE, ifName, strlen(ifName) + 1) < 0)
   {
-    BmfPError("setsockopt(SO_BINDTODEVICE) error");
+    OLSR_WARN(LOG_PLUGINS, "setsockopt(SO_BINDTODEVICE) error");
     close(skfd);
     return -1;
   }
@@ -853,7 +837,7 @@ static int CreateEncapsulateSocket(const char* ifName)
 
   if (bind(skfd, (struct sockaddr*)&bindTo, sizeof(bindTo)) < 0)
   {
-    BmfPError("bind() error");
+    OLSR_WARN(LOG_PLUGINS, "bind() error");
     close(skfd);
     return -1;
   }
@@ -861,7 +845,7 @@ static int CreateEncapsulateSocket(const char* ifName)
   /* Set socket to blocking operation */
   if (fcntl(skfd, F_SETFL, fcntl(skfd, F_GETFL, 0) & ~O_NONBLOCK) < 0)
   {
-    BmfPError("fcntl() error");
+    OLSR_WARN(LOG_PLUGINS, "fcntl() error");
     close(skfd);
     return -1;
   }
@@ -897,7 +881,7 @@ static int CreateLocalEtherTunTap(void)
   etfd = open(deviceName, O_RDWR | O_NONBLOCK);
   if (etfd < 0)
   {
-    BmfPError("error opening %s", deviceName);
+    OLSR_WARN(LOG_PLUGINS, "error opening %s", deviceName);
     return -1;
   }
 
@@ -912,7 +896,7 @@ static int CreateLocalEtherTunTap(void)
 
   if (ioctl(etfd, TUNSETIFF, (void *)&ifreq) < 0)
   {
-    BmfPError("ioctl(TUNSETIFF) error on %s", deviceName);
+    OLSR_WARN(LOG_PLUGINS, "ioctl(TUNSETIFF) error on %s", deviceName);
     close(etfd);
     return -1;
   }
@@ -925,7 +909,7 @@ static int CreateLocalEtherTunTap(void)
   ioctlSkfd = socket(PF_INET, SOCK_DGRAM, 0);
   if (ioctlSkfd < 0)
   {
-    BmfPError("socket(PF_INET) error on %s", deviceName);
+    OLSR_WARN(LOG_PLUGINS, "socket(PF_INET) error on %s", deviceName);
     close(etfd);
     return -1;
   }
@@ -985,7 +969,7 @@ static int CreateLocalEtherTunTap(void)
   if (ioctlres < 0)
   {
     /* Any of the above ioctl() calls failed */
-    BmfPError("error bringing up EtherTunTap interface \"%s\"", EtherTunTapIfName);
+    OLSR_WARN(LOG_PLUGINS, "error bringing up EtherTunTap interface \"%s\"", EtherTunTapIfName);
 
     close(etfd);
     close(ioctlSkfd);
@@ -1006,7 +990,7 @@ static int CreateLocalEtherTunTap(void)
   if (ioctlres < 0)
   {
     /* Any of the two above ioctl() calls failed */
-    BmfPError("error setting multicast flag on EtherTunTap interface \"%s\"", EtherTunTapIfName);
+    OLSR_WARN(LOG_PLUGINS, "error setting multicast flag on EtherTunTap interface \"%s\"", EtherTunTapIfName);
 
     /* Continue anyway */
   }
@@ -1016,12 +1000,12 @@ static int CreateLocalEtherTunTap(void)
    * daemon (e.g. mrouted) may be using the tuntap interface. */
   if (ioctl(etfd, TUNSETPERSIST, (void *)&ifreq) < 0)
   {
-    BmfPError("error making EtherTunTap interface \"%s\" persistent", EtherTunTapIfName);
+    OLSR_WARN(LOG_PLUGINS, "error making EtherTunTap interface \"%s\" persistent", EtherTunTapIfName);
 
     /* Continue anyway */
   }
 
-  OLSR_PRINTF(8, "%s: opened 1 socket on \"%s\"\n", PLUGIN_NAME_SHORT, EtherTunTapIfName);
+  OLSR_DEBUG(LOG_PLUGINS, "opened 1 socket on \"%s\"\n", EtherTunTapIfName);
 
   AddDescriptorToInputSet(etfd);
 
@@ -1125,7 +1109,7 @@ static int CreateInterface(
   ifr.ifr_name[IFNAMSIZ - 1] = '\0'; /* Ensures null termination */
   if (ioctl(ioctlSkfd, SIOCGIFHWADDR, &ifr) < 0)
   {
-    BmfPError("ioctl(SIOCGIFHWADDR) error for interface \"%s\"", ifName);
+    OLSR_WARN(LOG_PLUGINS, "ioctl(SIOCGIFHWADDR) error for interface \"%s\"", ifName);
     close(capturingSkfd);
     close(encapsulatingSkfd);
     free(newIf);
@@ -1155,7 +1139,7 @@ static int CreateInterface(
     ifr.ifr_name[IFNAMSIZ - 1] = '\0'; /* Ensures null termination */
     if (ioctl(ioctlSkfd, SIOCGIFADDR, &ifr) < 0)
     {
-      BmfPError("ioctl(SIOCGIFADDR) error for interface \"%s\"", ifName);
+      OLSR_WARN(LOG_PLUGINS, "ioctl(SIOCGIFADDR) error for interface \"%s\"", ifName);
 
       newIf->intAddr.v4.s_addr = inet_addr("0.0.0.0");
     }
@@ -1171,7 +1155,7 @@ static int CreateInterface(
     ifr.ifr_name[IFNAMSIZ - 1] = '\0'; /* Ensures null termination */
     if (ioctl(ioctlSkfd, SIOCGIFBRDADDR, &ifr) < 0)
     {
-      BmfPError("ioctl(SIOCGIFBRDADDR) error for interface \"%s\"", ifName);
+      OLSR_WARN(LOG_PLUGINS, "ioctl(SIOCGIFBRDADDR) error for interface \"%s\"", ifName);
 
       newIf->broadAddr.v4.s_addr = inet_addr("0.0.0.0");
     }
@@ -1213,10 +1197,9 @@ static int CreateInterface(
     LastBmfInterface = newIf;
   }
 
-  OLSR_PRINTF(
-    8,
-    "%s: opened %d socket%s on %s interface \"%s\"\n",
-    PLUGIN_NAME_SHORT,
+  OLSR_DEBUG(
+    LOG_PLUGINS,
+    "opened %d socket%s on %s interface \"%s\"\n",
     nOpened,
     nOpened == 1 ? "" : "s",
     olsrIntf != NULL ? "OLSR" : "non-OLSR",
@@ -1249,7 +1232,7 @@ int CreateBmfNetworkInterfaces(struct interface* skipThisIntf)
   skfd = socket(PF_INET, SOCK_DGRAM, 0);
   if (skfd < 0)
   {
-    BmfPError("no inet socket available to retrieve interface list");
+    OLSR_WARN(LOG_PLUGINS, "no inet socket available to retrieve interface list");
     return -1;
   }
 
@@ -1262,7 +1245,7 @@ int CreateBmfNetworkInterfaces(struct interface* skipThisIntf)
 
     if (ioctl(skfd, SIOCGIFCONF, &ifc) < 0)
     {
-      BmfPError("ioctl(SIOCGIFCONF) error");
+      OLSR_WARN(LOG_PLUGINS, "ioctl(SIOCGIFCONF) error");
 
       close(skfd);
       free(ifc.ifc_buf);
@@ -1324,11 +1307,11 @@ int CreateBmfNetworkInterfaces(struct interface* skipThisIntf)
 
   if (BmfInterfaces == NULL)
   {
-    OLSR_PRINTF(1, "%s: could not initialize any network interface\n", PLUGIN_NAME);
+    OLSR_WARN(LOG_PLUGINS, "could not initialize any network interface\n");
   }
   else
   {
-    OLSR_PRINTF(1, "%s: opened %d sockets\n", PLUGIN_NAME, nOpenedSockets);
+    OLSR_WARN(LOG_PLUGINS, "opened %d sockets\n", nOpenedSockets);
   }
   return 0;
 } /* CreateBmfNetworkInterfaces */
@@ -1350,7 +1333,7 @@ void AddInterface(struct interface* newIntf)
 
   nOpened = CreateInterface(newIntf->int_name, newIntf);
 
-  OLSR_PRINTF(1, "%s: opened %d sockets\n", PLUGIN_NAME, nOpened);
+  OLSR_DEBUG(LOG_PLUGINS, "opened %d sockets\n", nOpened);
 } /* AddInterface */
 
 /* -------------------------------------------------------------------------
@@ -1397,20 +1380,18 @@ void CloseBmfNetworkInterfaces(void)
       nClosed++;
     }
 
-    OLSR_PRINTF(
-      7,
-      "%s: %s interface \"%s\": RX pkts %u (%u dups); TX pkts %u\n",
-      PLUGIN_NAME_SHORT,
+    OLSR_DEBUG(
+      LOG_PLUGINS,
+      "%s interface \"%s\": RX pkts %u (%u dups); TX pkts %u\n",
       bmfIf->olsrIntf != NULL ? "OLSR" : "non-OLSR",
       bmfIf->ifName,
       bmfIf->nBmfPacketsRx,
       bmfIf->nBmfPacketsRxDup,
       bmfIf->nBmfPacketsTx);
 
-    OLSR_PRINTF(
-      1,
-      "%s: closed %s interface \"%s\"\n",
-      PLUGIN_NAME_SHORT,
+    OLSR_DEBUG(
+      LOG_PLUGINS,
+      "closed %s interface \"%s\"\n",
       bmfIf->olsrIntf != NULL ? "OLSR" : "non-OLSR",
       bmfIf->ifName);
 
@@ -1436,24 +1417,22 @@ void CloseBmfNetworkInterfaces(void)
     close(EtherTunTapFd);
     nClosed++;
 
-    OLSR_PRINTF(7, "%s: closed \"%s\"\n", PLUGIN_NAME_SHORT, EtherTunTapIfName);
+    OLSR_DEBUG(LOG_PLUGINS, "closed \"%s\"\n", EtherTunTapIfName);
   }
 
   BmfInterfaces = NULL;
 
-  OLSR_PRINTF(1, "%s: closed %d sockets\n", PLUGIN_NAME_SHORT, nClosed);
+  OLSR_DEBUG(LOG_PLUGINS, "closed %d sockets\n", nClosed);
 
-  OLSR_PRINTF(
-    7,
-    "%s: Total all OLSR interfaces    : RX pkts %u (%u dups); TX pkts %u\n",
-    PLUGIN_NAME_SHORT,
+  OLSR_DEBUG(
+        LOG_PLUGINS,
+        "Total all OLSR interfaces    : RX pkts %u (%u dups); TX pkts %u\n",
     totalOlsrBmfPacketsRx,
     totalOlsrBmfPacketsRxDup,
     totalOlsrBmfPacketsTx);
-  OLSR_PRINTF(
-    7,
-    "%s: Total all non-OLSR interfaces: RX pkts %u (%u dups); TX pkts %u\n",
-    PLUGIN_NAME_SHORT,
+  OLSR_DEBUG(
+    LOG_PLUGINS,
+    "Total all non-OLSR interfaces: RX pkts %u (%u dups); TX pkts %u\n",
     totalNonOlsrBmfPacketsRx,
     totalNonOlsrBmfPacketsRxDup,
     totalNonOlsrBmfPacketsTx);
@@ -1483,10 +1462,9 @@ int AddNonOlsrBmfIf(
 
   if (nNonOlsrIfs >= MAX_NON_OLSR_IFS)
   {
-    OLSR_PRINTF(
-      1,
-      "%s: too many non-OLSR interfaces specified, maximum is %d\n",
-      PLUGIN_NAME,
+    OLSR_WARN(
+      LOG_PLUGINS,
+      "too many non-OLSR interfaces specified, maximum is %d\n",
       MAX_NON_OLSR_IFS);
     return 1;
   }
@@ -1598,7 +1576,7 @@ void AddMulticastRoute(void)
   int ioctlSkfd = socket(PF_INET, SOCK_DGRAM, 0);
   if (ioctlSkfd < 0)
   {
-    BmfPError("socket(PF_INET) error");
+    OLSR_WARN(LOG_PLUGINS, "socket(PF_INET) error");
     return;
   }
 
@@ -1619,7 +1597,7 @@ void AddMulticastRoute(void)
 
   if (ioctl(ioctlSkfd, SIOCADDRT, &kernel_route) < 0)
   {
-    BmfPError("error setting multicast route via EtherTunTap interface \"%s\"", EtherTunTapIfName);
+    OLSR_WARN(LOG_PLUGINS, "error setting multicast route via EtherTunTap interface \"%s\"", EtherTunTapIfName);
 
     /* Continue anyway */
   }
@@ -1643,7 +1621,7 @@ void DeleteMulticastRoute(void)
     int ioctlSkfd = socket(PF_INET, SOCK_DGRAM, 0);
     if (ioctlSkfd < 0)
     {
-      BmfPError("socket(PF_INET) error");
+      OLSR_WARN(LOG_PLUGINS, "socket(PF_INET) error");
       return;
     }
 
@@ -1664,7 +1642,7 @@ void DeleteMulticastRoute(void)
 
     if (ioctl(ioctlSkfd, SIOCDELRT, &kernel_route) < 0)
     {
-      BmfPError("error deleting multicast route via EtherTunTap interface \"%s\"", EtherTunTapIfName);
+      OLSR_WARN(LOG_PLUGINS, "error deleting multicast route via EtherTunTap interface \"%s\"", EtherTunTapIfName);
 
       /* Continue anyway */
     }
index 7e0ee9e..8544e2c 100644 (file)
@@ -48,6 +48,7 @@
 #include "scheduler.h" /* olsr_start_timer() */
 #include "olsr_cfg.h" /* olsr_cnf() */
 #include "olsr_cookie.h" /* olsr_alloc_cookie() */
+#include "olsr_logging.h"
 
 /* BMF includes */
 #include "Bmf.h" /* InitBmf(), CloseBmf() */
@@ -91,7 +92,7 @@ int olsrd_plugin_init(void)
   /* Check validity */
   if (olsr_cnf->ip_version != AF_INET)
   {
-    fprintf(stderr, PLUGIN_NAME ": This plugin only supports IPv4!\n");
+    OLSR_WARN(LOG_PLUGINS, PLUGIN_NAME ": This plugin only supports IPv4!\n");
     return 0;
   }
 
@@ -165,7 +166,7 @@ void olsrd_get_plugin_parameters(const struct olsrd_plugin_parameters **params,
 static void my_init(void)
 {
   /* Print plugin info to stdout */
-  printf("%s\n", MOD_DESC);
+  OLSR_INFO(LOG_PLUGINS, "%s\n", MOD_DESC);
 
   return;
 }
index bf2e75d..610b1c9 100644 (file)
@@ -50,6 +50,7 @@
 #include "hna_set.h"
 #include "link_set.h"
 #include "olsr_ip_prefix_list.h"
+#include "olsr_logging.h"
 
 #ifdef _WRS_KERNEL
 #include <vxWorks.h>
@@ -179,19 +180,19 @@ plugin_ipc_init(void)
   /* Init ipc socket */
   ipc_socket = socket(AF_INET, SOCK_STREAM, 0);
   if (ipc_socket == -1) {
-    OLSR_PRINTF(1, "(DOT DRAW)IPC socket %s\n", strerror(errno));
+    OLSR_WARN(LOG_PLUGINS, "(DOT DRAW)IPC socket %s\n", strerror(errno));
     return 0;
   }
 
   if (setsockopt(ipc_socket, SOL_SOCKET, SO_REUSEADDR, (char *)&yes, sizeof(yes)) < 0) {
-    perror("SO_REUSEADDR failed");
+    OLSR_WARN(LOG_PLUGINS, "SO_REUSEADDR failed %s\n", strerror(errno));
     CLOSESOCKET(ipc_socket);
     return 0;
   }
 
 #if defined __FreeBSD__ && defined SO_NOSIGPIPE
   if (setsockopt(ipc_socket, SOL_SOCKET, SO_NOSIGPIPE, (char *)&yes, sizeof(yes)) < 0) {
-    perror("SO_REUSEADDR failed");
+    OLSR_WARN(LOG_PLUGINS, "SO_REUSEADDR failed %s\n", strerror(errno));
     CLOSESOCKET(ipc_socket);
     return 0;
   }
@@ -207,22 +208,19 @@ plugin_ipc_init(void)
 
   /* bind the socket to the port number */
   if (bind(ipc_socket, (struct sockaddr *) &addr, sizeof(addr)) == -1) {
-    OLSR_PRINTF(1, "(DOT DRAW)IPC bind %s\n", strerror(errno));
+    OLSR_WARN(LOG_PLUGINS, "(DOT DRAW)IPC bind %s\n", strerror(errno));
     CLOSESOCKET(ipc_socket);
     return 0;
   }
 
   /* show that we are willing to listen */
   if (listen(ipc_socket, 1) == -1) {
-    OLSR_PRINTF(1, "(DOT DRAW)IPC listen %s\n", strerror(errno));
+    OLSR_WARN(LOG_PLUGINS, "(DOT DRAW)IPC listen %s\n", strerror(errno));
     CLOSESOCKET(ipc_socket);
     return 0;
   }
 
   /* Register with olsrd */
-#if 0
-  printf("Adding socket with olsrd\n");
-#endif
   add_olsr_socket(ipc_socket, &ipc_action, NULL, NULL, SP_PR_READ);
 
   return 1;
@@ -236,17 +234,17 @@ ipc_action(int fd __attribute__((unused)), void *data __attribute__((unused)), u
   socklen_t addrlen = sizeof(struct sockaddr_in);
   int ipc_connection = accept(ipc_socket, (struct sockaddr *)&pin, &addrlen);
   if (ipc_connection == -1) {
-    OLSR_PRINTF(1, "(DOT DRAW)IPC accept: %s\n", strerror(errno));
+    OLSR_WARN(LOG_PLUGINS, "(DOT DRAW)IPC accept: %s\n", strerror(errno));
     return;
   }
 #ifndef _WRS_KERNEL
   if (ip4cmp(&pin.sin_addr, &ipc_accept_ip.v4) != 0) {
-    OLSR_PRINTF(0, "Front end-connection from foreign host (%s) not allowed!\n", inet_ntoa(pin.sin_addr));
+    OLSR_WARN(LOG_PLUGINS, "Front end-connection from foreign host (%s) not allowed!\n", inet_ntoa(pin.sin_addr));
     CLOSESOCKET(ipc_connection);
     return;
   }
 #endif
-  OLSR_PRINTF(1, "(DOT DRAW)IPC: Connection from %s\n", inet_ntoa(pin.sin_addr));
+  OLSR_DEBUG(LOG_PLUGINS, "(DOT DRAW)IPC: Connection from %s\n", inet_ntoa(pin.sin_addr));
   pcf_event(ipc_connection, 1, 1, 1);
   CLOSESOCKET(ipc_connection); /* close connection after one output */
 }
index b120bc6..c5a5474 100644 (file)
@@ -44,6 +44,7 @@
 #include "olsrd_dot_draw.h"
 #include "olsr.h"
 #include "defs.h"
+#include "olsr_logging.h"
 
 #include <stdio.h>
 #include <string.h>
@@ -72,7 +73,7 @@ static void my_fini(void) __attribute__((destructor));
 static void my_init(void)
 {
     /* Print plugin info to stdout */
-    printf("%s\n", MOD_DESC);
+    OLSR_INFO(LOG_PLUGINS, "%s\n", MOD_DESC);
 
     /* defaults for parameters */
     ipc_port = 2004;
index 1c8396a..2be269a 100644 (file)
@@ -50,6 +50,7 @@
 #include "scheduler.h"
 #include "olsr_cookie.h"
 #include "olsr_ip_prefix_list.h"
+#include "olsr_logging.h"
 
 #include <net/route.h>
 #include <arpa/inet.h>
@@ -129,7 +130,7 @@ static int set_plugin_ping(const char *value, void *data __attribute__((unused))
     union olsr_ip_addr foo_addr;
 
     if (inet_pton(olsr_cnf->ip_version, value, &foo_addr) <= 0) {
-        OLSR_PRINTF(0, "Illegal IP address \"%s\"", value);
+        OLSR_WARN(LOG_PLUGINS, "Illegal IP address \"%s\"", value);
         return 1;
     }
     /*if first ping without hna then assume inet gateway*/
@@ -157,19 +158,19 @@ static int set_plugin_hna(const char *value, void *data __attribute__((unused)),
     //192.168.1.0  255.255.255.0
     int i = sscanf(value,"%127s %127s", s_netaddr, s_mask);
     if (i != 2) {
-        OLSR_PRINTF(0, "Cannot get IP address and netmask from \"%s\"", value);
+        OLSR_WARN(LOG_PLUGINS, "Cannot get IP address and netmask from \"%s\"", value);
         return 1;
     }
 
     //printf("%s():i:%i; net:%s; mask:%s\n",__func__,i,s_netaddr,s_mask);
     if (inet_pton(olsr_cnf->ip_version, s_netaddr, &temp_net) <= 0) {
-        OLSR_PRINTF(0, "Illegal IP address \"%s\"", s_netaddr);
+      OLSR_WARN(LOG_PLUGINS, "Illegal IP address \"%s\"", s_netaddr);
         return 1;
     }
 
     //printf("GOT: %s(%08x)",inet_ntoa(foo_addr),foo_addr.s_addr);
     if (inet_pton(olsr_cnf->ip_version, s_mask, &temp_netmask) <= 0) {
-        OLSR_PRINTF(0, "Illegal netmask \"%s\"", s_netaddr);
+      OLSR_WARN(LOG_PLUGINS, "Illegal netmask \"%s\"", s_netaddr);
         return 1;
     }
 
@@ -313,8 +314,7 @@ check_gw(union olsr_ip_addr *net, uint8_t prefixlen, struct ping_list *the_ping_
     FILE *fp = fopen(PROCENTRY_ROUTE, "r");
     if (!fp)
       {
-        perror(PROCENTRY_ROUTE);
-        OLSR_PRINTF(1, "INET (IPv4) not configured in this system.\n");
+        OLSR_WARN(LOG_PLUGINS, "Cannot read proc file %s: %s\n", PROCENTRY_ROUTE, strerror(errno));
        return -1;
       }
 
@@ -355,11 +355,11 @@ check_gw(union olsr_ip_addr *net, uint8_t prefixlen, struct ping_list *the_ping_
             if (the_ping_list != NULL) {
               /*validate the found inet gw by pinging*/
               if (ping_is_possible(the_ping_list)) {
-                OLSR_PRINTF(1, "HNA[%08x/%08x](ping is possible) VIA %s detected in routing table.\n", dest_addr,netmask,iface);
+                OLSR_DEBUG(LOG_PLUGINS, "HNA[%08x/%08x](ping is possible) VIA %s detected in routing table.\n", dest_addr,netmask,iface);
                 retval=1;
               }
             } else {
-              OLSR_PRINTF(1, "HNA[%08x/%08x] VIA %s detected in routing table.\n", dest_addr,netmask,iface);
+              OLSR_DEBUG(LOG_PLUGINS, "HNA[%08x/%08x] VIA %s detected in routing table.\n", dest_addr,netmask,iface);
               retval=1;
             }
           }
@@ -368,7 +368,7 @@ check_gw(union olsr_ip_addr *net, uint8_t prefixlen, struct ping_list *the_ping_
     fclose(fp);
     if(retval == 0){
       /* And we cast here since we get warnings on Win32 */
-      OLSR_PRINTF(1, "HNA[%08x/%08x] is invalid\n", (unsigned int)net->v4.s_addr, (unsigned int)mask.v4.s_addr);
+      OLSR_WARN(LOG_PLUGINS, "HNA[%08x/%08x] is invalid\n", (unsigned int)net->v4.s_addr, (unsigned int)mask.v4.s_addr);
     }
     return retval;
 }
@@ -380,12 +380,11 @@ ping_is_possible(struct ping_list *the_ping_list)
   for(list = the_ping_list; list; list = list->next) {
     char ping_command[50];
     snprintf(ping_command, sizeof(ping_command), "ping -c 1 -q %s", list->ping_address);
-    OLSR_PRINTF(1, "\nDo ping on %s ...\n", list->ping_address);
     if (system(ping_command) == 0) {
-      OLSR_PRINTF(1, "...OK\n\n");
+      OLSR_DEBUG(LOG_PLUGINS, "\nDo ping on %s ... ok\n", list->ping_address);
       return 1;
     }
-    OLSR_PRINTF(1, "...FAILED\n\n");
+    OLSR_DEBUG(LOG_PLUGINS, "\nDo ping on %s ... failed\n", list->ping_address);
   }
   return 0;
 }
@@ -394,12 +393,7 @@ ping_is_possible(struct ping_list *the_ping_list)
 static struct ping_list *
 add_to_ping_list(const char *ping_address, struct ping_list *the_ping_list)
 {
-  struct ping_list *new = malloc(sizeof(struct ping_list));
-  if(!new)
-  {
-    fprintf(stderr, "DYN GW: Out of memory!\n");
-    exit(0);
-  }
+  struct ping_list *new = olsr_malloc(sizeof(struct ping_list), "ping list");
   new->ping_address = olsr_strdup(ping_address);
   new->next = the_ping_list;
   return new;
@@ -410,12 +404,7 @@ add_to_ping_list(const char *ping_address, struct ping_list *the_ping_list)
 static struct hna_list *
 add_to_hna_list(struct hna_list * list_root, union olsr_ip_addr *hna_net, uint8_t hna_prefixlen )
 {
-  struct hna_list *new = malloc(sizeof(struct hna_list));
-  if(new == NULL)
-  {
-    fprintf(stderr, "DYN GW: Out of memory!\n");
-    exit(0);
-  }
+  struct hna_list *new = olsr_malloc(sizeof(struct hna_list), "hna list");
   //memcpy(&new->hna_net,hna_net,sizeof(union hna_net));
   //memcpy(&new->hna_netmask,hna_netmask,sizeof(union hna_netmask));
   new->hna_net.v4=hna_net->v4;
index 4804e21..36ba27a 100644 (file)
@@ -46,6 +46,7 @@
 #include "olsr.h"
 #include "olsr_cookie.h"
 #include "olsr_ip_prefix_list.h"
+#include "olsr_logging.h"
 
 #include <stdio.h>
 #include <string.h>
@@ -54,8 +55,6 @@
 #include <unistd.h>
 #include <errno.h>
 
-#define DEBUGLEV 1
-
 #define PLUGIN_INTERFACE_VERSION 5
 
 static int has_inet_gateway;
@@ -90,7 +89,7 @@ olsrd_get_plugin_parameters(const struct olsrd_plugin_parameters **params, int *
 int
 olsrd_plugin_init(void)
 {
-  printf("OLSRD dyn_gw_plain plugin by Sven-Ola\n");
+  OLSR_INFO(LOG_PLUGINS, "OLSRD dyn_gw_plain plugin by Sven-Ola\n");
 
   gw_net.v4.s_addr = INET_NET;
   gw_netmask.v4.s_addr = INET_PREFIX;
@@ -99,7 +98,7 @@ olsrd_plugin_init(void)
 
   /* Remove all local Inet HNA entries */
   while (ip_prefix_list_remove(&olsr_cnf->hna_entries, &gw_net, olsr_netmask_to_prefix(&gw_netmask), olsr_cnf->ip_version)) {
-    OLSR_PRINTF(DEBUGLEV, "HNA Internet gateway deleted\n");
+    OLSR_DEBUG(LOG_PLUGINS, "HNA Internet gateway deleted\n");
   }
 
   /* create the cookie */
@@ -123,8 +122,7 @@ check_gw(union olsr_ip_addr *net, union olsr_ip_addr *mask)
   FILE *fp = fopen(PROCENTRY_ROUTE, "r");
 
   if (!fp) {
-    perror(PROCENTRY_ROUTE);
-    OLSR_PRINTF(DEBUGLEV, "INET (IPv4) not configured in this system.\n");
+    OLSR_WARN(LOG_PLUGINS, "Cannot read proc file %s: %s\n", PROCENTRY_ROUTE, strerror(errno));
     return -1;
   }
 
@@ -135,7 +133,7 @@ check_gw(union olsr_ip_addr *net, union olsr_ip_addr *mask)
      "Flags Metric Ref    Use Iface\n");
    */
   while (fgets(buff, 1023, fp)) {
-#ifdef DEBUG
+#if !defined REMOVE_DEBUG
     struct ipaddr_str buf;
 #endif
     num =
@@ -145,18 +143,15 @@ check_gw(union olsr_ip_addr *net, union olsr_ip_addr *mask)
     if (num < 8) {
       continue;
     }
-#ifdef DEBUG
-    OLSR_PRINTF(DEBUGLEV, "%-15s ", olsr_ip_to_string(&buf, (union olsr_ip_addr *)&netmask));
-
-    OLSR_PRINTF(DEBUGLEV, "%-15s ", olsr_ip_to_string(&buf, (union olsr_ip_addr *)&dest_addr));
-
-    OLSR_PRINTF(DEBUGLEV, "%-15s %-6d %-2d %7d %s\n", olsr_ip_to_string(&buf, (union olsr_ip_addr *)&gate_addr), metric, refcnt,
-                use, iface);
-#endif
+    OLSR_DEBUG(LOG_PLUGINS, "%-15s %-15s %-15s %-6d %-2d %7d %s\n",
+        olsr_ip_to_string(&buf, (union olsr_ip_addr *)&netmask),
+        olsr_ip_to_string(&buf, (union olsr_ip_addr *)&dest_addr),
+        olsr_ip_to_string(&buf, (union olsr_ip_addr *)&gate_addr),
+        metric, refcnt, use, iface);
 
     if (                        /* (iflags & RTF_GATEWAY) && */
          (iflags & RTF_UP) && (metric == 0) && (netmask == mask->v4.s_addr) && (dest_addr == net->v4.s_addr)) {
-      OLSR_PRINTF(DEBUGLEV, "INTERNET GATEWAY VIA %s detected in routing table.\n", iface);
+      OLSR_DEBUG(LOG_PLUGINS, "INTERNET GATEWAY VIA %s detected in routing table.\n", iface);
       retval = 1;
     }
 
@@ -165,7 +160,7 @@ check_gw(union olsr_ip_addr *net, union olsr_ip_addr *mask)
   fclose(fp);
 
   if (retval == 0) {
-    OLSR_PRINTF(DEBUGLEV, "No Internet GWs detected...\n");
+    OLSR_DEBUG(LOG_PLUGINS, "No Internet GWs detected...\n");
   }
 
   return retval;
@@ -180,13 +175,13 @@ olsr_event(void *foo __attribute__ ((unused)))
 {
   int res = check_gw(&gw_net, &gw_netmask);
   if (1 == res && 0 == has_inet_gateway) {
-    OLSR_PRINTF(DEBUGLEV, "Adding OLSR local HNA entry for Internet\n");
+    OLSR_DEBUG(LOG_PLUGINS, "Adding OLSR local HNA entry for Internet\n");
     ip_prefix_list_add(&olsr_cnf->hna_entries, &gw_net, olsr_netmask_to_prefix(&gw_netmask));
     has_inet_gateway = 1;
   } else if (0 == res && 1 == has_inet_gateway) {
     /* Remove all local Inet HNA entries */
     while (ip_prefix_list_remove(&olsr_cnf->hna_entries, &gw_net, olsr_netmask_to_prefix(&gw_netmask), olsr_cnf->ip_version)) {
-      OLSR_PRINTF(DEBUGLEV, "Removing OLSR local HNA entry for Internet\n");
+      OLSR_DEBUG(LOG_PLUGINS, "Removing OLSR local HNA entry for Internet\n");
     }
     has_inet_gateway = 0;
   }
index c6da97c..6cd927e 100644 (file)
@@ -56,6 +56,7 @@
 #include "ipcalc.h"
 #include "olsr_cfg.h"
 #include "olsr.h"
+#include "olsr_logging.h"
 
 #define PLUGIN_NAME    "OLSRD txtinfo plugin"
 #define PLUGIN_VERSION "0.1"
@@ -78,7 +79,7 @@ static void my_fini(void) __attribute__ ((destructor));
 static void my_init(void)
 {
     /* Print plugin info to stdout */
-    printf("%s\n", MOD_DESC);
+    OLSR_INFO(LOG_PLUGINS, "%s\n", MOD_DESC);
 
     /* defaults for parameters */
     ipc_port = 2006;
index 7bc820d..2796dcf 100644 (file)
@@ -171,21 +171,17 @@ olsrd_plugin_init(void)
   /* Init ipc socket */
   listen_socket = socket(olsr_cnf->ip_version, SOCK_STREAM, 0);
   if (listen_socket == -1) {
-#ifndef NODEBUG
-    OLSR_PRINTF(1, "(TXTINFO) socket()=%s\n", strerror(errno));
-#endif
+    OLSR_WARN(LOG_PLUGINS, "(TXTINFO) socket()=%s\n", strerror(errno));
     return 0;
   }
   if (setsockopt(listen_socket, SOL_SOCKET, SO_REUSEADDR, (char *)&yes, sizeof(yes)) < 0) {
-#ifndef NODEBUG
-    OLSR_PRINTF(1, "(TXTINFO) setsockopt()=%s\n", strerror(errno));
-#endif
+    OLSR_WARN(LOG_PLUGINS, "(TXTINFO) setsockopt()=%s\n", strerror(errno));
     CLOSESOCKET(listen_socket);
     return 0;
   }
 #if defined __FreeBSD__ && defined SO_NOSIGPIPE
   if (setsockopt(listen_socket, SOL_SOCKET, SO_NOSIGPIPE, (char *)&yes, sizeof(yes)) < 0) {
-    perror("SO_REUSEADDR failed");
+    OLSR_WARN(LOG_PLUGINS, "(TXTINFO) reusing address failed: %s", strerror(errno));
     CLOSESOCKET(listen_socket);
     return 0;
   }
@@ -216,18 +212,14 @@ olsrd_plugin_init(void)
 
   /* bind the socket to the port number */
   if (bind(listen_socket, (struct sockaddr *)&sst, addrlen) == -1) {
-#ifndef NODEBUG
-    OLSR_PRINTF(1, "(TXTINFO) bind()=%s\n", strerror(errno));
-#endif
+    OLSR_WARN(LOG_PLUGINS, "(TXTINFO) bind()=%s\n", strerror(errno));
     CLOSESOCKET(listen_socket);
     return 0;
   }
 
   /* show that we are willing to listen */
   if (listen(listen_socket, 1) == -1) {
-#ifndef NODEBUG
-    OLSR_PRINTF(1, "(TXTINFO) listen()=%s\n", strerror(errno));
-#endif
+    OLSR_WARN(LOG_PLUGINS, "(TXTINFO) listen()=%s\n", strerror(errno));
     CLOSESOCKET(listen_socket);
     return 0;
   }
@@ -235,9 +227,7 @@ olsrd_plugin_init(void)
   /* Register with olsrd */
   add_olsr_socket(listen_socket, NULL, &ipc_action, NULL, SP_IMM_READ);
 
-#ifndef NODEBUG
-  OLSR_PRINTF(2, "(TXTINFO) listening on port %d\n", ipc_port);
-#endif
+  OLSR_INFO(LOG_PLUGINS, "(TXTINFO) listening on port %d\n", ipc_port);
 
   memset(recv_packets, 0, sizeof(recv_packets));
   memset(recv_messages, 0, sizeof(recv_messages));
@@ -344,9 +334,7 @@ ipc_action(int fd, void *data __attribute__ ((unused)), unsigned int flags __att
 
   if (http_connection == -1) {
     /* this may well happen if the other side immediately closes the connection. */
-#ifndef NODEBUG
-    OLSR_PRINTF(1, "(TXTINFO) accept()=%s\n", strerror(errno));
-#endif
+    OLSR_WARN(LOG_PLUGINS, "(TXTINFO) accept()=%s\n", strerror(errno));
     return;
   }
 
@@ -360,13 +348,11 @@ ipc_action(int fd, void *data __attribute__ ((unused)), unsigned int flags __att
   }
 
   if (!ip_acl_acceptable(&allowed_nets, ipaddr, olsr_cnf->ip_version)) {
-    OLSR_PRINTF(1, "(TXTINFO) From host(%s) not allowed!\n", addr);
+    OLSR_WARN(LOG_PLUGINS, "(TXTINFO) From host(%s) not allowed!\n", addr);
     CLOSESOCKET(http_connection);
     return;
   }
-#ifndef NODEBUG
-  OLSR_PRINTF(2, "(TXTINFO) Connect from %s\n", addr);
-#endif
+  OLSR_WARN(LOG_PLUGINS, "(TXTINFO) Connect from %s\n", addr);
 
   /* make the fd non-blocking */
   if (set_nonblocking(http_connection) < 0) {
index 17790a4..7157b7f 100644 (file)
@@ -51,6 +51,7 @@
 #include "defs.h"
 #include "scheduler.h"
 #include "olsr_cookie.h"
+#include "olsr_logging.h"
 
 #include "plugin.h"
 
@@ -112,7 +113,7 @@ olsr_watchdog_write_alivefile(void *foo __attribute__ ((unused)))
 {
   FILE *file = fopen(watchdog_filename, "w");
   if (file == NULL) {
-    OLSR_PRINTF(3, "Error, cannot write watchdog alivefile");
+    OLSR_WARN(LOG_PLUGINS, "Error, cannot write watchdog alivefile");
   } else {
     fprintf(file, "%ld\n", (long)time(NULL));
     fflush(file);