Added note about waiting rscriptd until message queue becomes empty

[stg.git] / projects / stargazer / plugins / capture / cap_nf / cap_nf.cpp

diff --git a/projects/stargazer/plugins/capture/cap_nf/cap_nf.cpp b/projects/stargazer/plugins/capture/cap_nf/cap_nf.cpp
index 0e0204da761145b8e50a710c582cd77a7de8454d..23d6413c7bf132d1602d9400857eba4ac653ce92 100644 (file)
--- a/projects/stargazer/plugins/capture/cap_nf/cap_nf.cpp
+++ b/projects/stargazer/plugins/capture/cap_nf/cap_nf.cpp
@@ -39,26 +39,24 @@ $Author: faust $
 
 #include <vector>
 
 
 #include <vector>
 

-#include "common.h" 
+#include "stg/common.h" 
+#include "stg/raw_ip_packet.h"
+#include "stg/traffcounter.h"

 #include "cap_nf.h"
 #include "cap_nf.h"

-#include "raw_ip_packet.h"

 
 

-#include "../../../traffcounter.h"
-
-class CAP_NF_CREATOR
-{
+class CAP_NF_CREATOR {

 public:
     CAP_NF_CREATOR()
         : nf(new NF_CAP())
         {
 public:
     CAP_NF_CREATOR()
         : nf(new NF_CAP())
         {

-        };
+        }

 
     ~CAP_NF_CREATOR()
         {
         delete nf;
 
     ~CAP_NF_CREATOR()
         {
         delete nf;

-        };
+        }

 
 

-    NF_CAP * GetCapturer() { return nf; };
+    NF_CAP * GetCapturer() { return nf; }

 private:
     NF_CAP * nf;
 } cnc;
 private:
     NF_CAP * nf;
 } cnc;


@@ -280,9 +278,6 @@ while (cap->runningUDP)
         continue;
         }
 
         continue;
         }
 

-
-    // Wrong logic!
-    // Need to check actual data length and wait all data to receive

     if (res < 24)
         {
         if (errno != EINTR)
     if (res < 24)
         {
         if (errno != EINTR)


@@ -392,14 +387,6 @@ for (int i = 0; i < packets; ++i)
     {
     NF_DATA * data = reinterpret_cast<NF_DATA *>(buf + 24 + i * 48);
 
     {
     NF_DATA * data = reinterpret_cast<NF_DATA *>(buf + 24 + i * 48);
 

-    /*ip.pckt[0] = 4 << 4;
-    ip.pckt[0] |= 5;
-    ip.pckt[9] = data->proto;
-    ip.dataLen = ntohl(data->octets);
-    *(uint32_t *)(ip.pckt + 12) = data->srcAddr;
-    *(uint32_t *)(ip.pckt + 16) = data->dstAddr;
-    *(uint16_t *)(ip.pckt + 20) = data->srcPort;
-    *(uint16_t *)(ip.pckt + 22) = data->dstPort;*/

     ip.header.ipHeader.ip_v = 4;
     ip.header.ipHeader.ip_hl = 5;
     ip.header.ipHeader.ip_p = data->proto;
     ip.header.ipHeader.ip_v = 4;
     ip.header.ipHeader.ip_hl = 5;
     ip.header.ipHeader.ip_p = data->proto;