$Revision: 1.13 $
$Date: 2010/09/10 06:43:03 $
*/
-#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
-#include <string.h>
#include <sys/uio.h>
#include <sys/time.h>
#include <sys/ioctl.h>
#include <sys/poll.h>
-#include <errno.h>
#include <fcntl.h>
-#include <stdlib.h>
-#include <signal.h>
#include <unistd.h>
-#include "common.h"
+#include <cstdio>
+#include <cstring>
+#include <cerrno>
+#include <cstdlib>
+#include <csignal>
+
+#include <algorithm>
+#include <vector>
+
+#include "stg/common.h"
+#include "stg/traffcounter.h"
#include "divert_cap.h"
#define BUFF_LEN (16384) /* max mtu -> lo=16436 TODO why?*/
DIVERT_CAP_CREATOR()
: divc(new DIVERT_CAP())
{
- };
+ }
~DIVERT_CAP_CREATOR()
{
delete divc;
- };
+ }
DIVERT_CAP * GetCapturer()
{
return divc;
- };
+ }
};
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
{
}
//-----------------------------------------------------------------------------
-void DIVERT_CAP::SetTraffcounter(TRAFFCOUNTER * tc)
-{
-traffCnt = tc;
-}
-//-----------------------------------------------------------------------------
-const std::string & DIVERT_CAP::GetStrError() const
-{
-return errorStr;
-}
-//-----------------------------------------------------------------------------
int DIVERT_CAP::Start()
{
if (isRunning)
return 0;
}
//-----------------------------------------------------------------------------
-bool DIVERT_CAP::IsRunning()
-{
-return isRunning;
-}
-//-----------------------------------------------------------------------------
void * DIVERT_CAP::Run(void * d)
{
DIVERT_CAP * dc = (DIVERT_CAP *)d;
dc->isRunning = true;
-/*struct ETH_IP
-{
-uint16_t ethHdr[8];
-RAW_PACKET rp;
-char padding[4];
-char padding1[8];
-};
-
-ETH_IP * ethIP;
-
-char ethip[sizeof(ETH_IP)];
-
-//memset(ðIP, 0, sizeof(ethIP));
-memset(ðip, 0, sizeof(ETH_IP));
-
-ethIP = (ETH_IP *)ðip;
-ethIP->rp.dataLen = -1;
-*/
-//char * iface = NULL;
char buffer[64];
while (dc->nonstop)
{
RAW_PACKET rp;
dc->DivertCapRead(buffer, 64, NULL);
- //printf("%x %x %x %x \n", buffer[0], buffer[4], buffer[8], buffer[12]);
- //printf("%x %x %x %x \n", buffer[16], buffer[20], buffer[24], buffer[28]);
- //printf("%x %x %x %x \n", buffer[32], buffer[36], buffer[40], buffer[44]);
-
if (buffer[12] != 0x8)
continue;
memcpy(rp.pckt, &buffer[14], pcktSize);
- //dc->traffCnt->Process(*((RAW_PACKET*)( &buffer[14] ))); // - too dirty!
dc->traffCnt->Process(rp);
}
return NULL;
}
//-----------------------------------------------------------------------------
-uint16_t DIVERT_CAP::GetStartPosition() const
-{
-return 10;
-}
-//-----------------------------------------------------------------------------
-uint16_t DIVERT_CAP::GetStopPosition() const
-{
-return 10;
-}
-//-----------------------------------------------------------------------------
-/*****************************************************************************/
-/*****************************************************************************/
-/*****************************************************************************/
-/*****************************************************************************/
-/*****************************************************************************/
-//-----------------------------------------------------------------------------
int DIVERT_CAP::DivertCapOpen()
{
memset(&pollddiv, 0, sizeof(pollddiv));
{
int p;
PARAM_VALUE pv;
-vector<PARAM_VALUE>::const_iterator pvi;
+std::vector<PARAM_VALUE>::const_iterator pvi;
pv.param = "Port";
-pvi = find(settings.moduleParams.begin(), settings.moduleParams.end(), pv);
+pvi = std::find(settings.moduleParams.begin(), settings.moduleParams.end(), pv);
if (pvi == settings.moduleParams.end())
{
port = 15701;
return 0;
}
//-----------------------------------------------------------------------------
-void DIVERT_CAP::SetSettings(const MODULE_SETTINGS & s)
-{
-settings = s;
-}
-//-----------------------------------------------------------------------------
-