---

collector.h

Go to the documentation of this file.

/***************************************************************************
                                 collector.h
                             -------------------
    begin                : Fri Feb 1 2002
    copyright            : (C) 2002 by Constantinos A. Kotsokalis
    email                : ckotso@grnet.gr
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 ***************************************************************************/

#ifndef COLLECTOR_H
#define COLLECTOR_H

class Collector;

#include <cc++/socket.h>

#ifdef  CCXX_NAMESPACES
    using namespace std;
    using namespace ost;
#endif

#include <sys/stat.h>

#include "mconfig.h"
#include "timestamp.h"
#include "timeslot.h"
#include "pdu.h"
#include "webbroker.h"
#include "peer.h"
#include "detector.h"

typedef struct RemoteDetector {
    InetHostAddress local; 
  InetHostAddress remote; 
    uint16_t remport; 
    string remid; 
} RemoteDetector;

class Collector {
public:
    Collector();
    virtual ~Collector();
    void BindAndLoop();
    void setConfiguration(MConfig &);
    virtual void setIfInfoFile(const char * _newVal);
  virtual const char * getIfInfoFile();
    void setRemotePeer(const InetHostAddress&, const InetHostAddress&, const uint16_t&, const string&);
    RemoteDetector getRemotePeer(const InetHostAddress&);
    void makeSlots(uint32_t&, uint32_t&);
    TimeSlot *getProcTS() { return tsProc; }
    string getUID() const { return myuid; }

private:
    const char * ifinfofile;
    InetHostAddress router;
  InetHostAddress websrv;
    Mutex *mtx;
    uint32_t SlotPeriod;
  uint32_t slotcount;
    float increase;
  float percentage;
    char *incharge;
  char *execcmd;
    uint16_t port;
  uint16 peer_port;
  uint16 web_port;
  vector<RemoteDetector> RemotePeers;
  UDPSocket sock;
  TimeSlot *tsAdd, *tsProc, *tsPrev, *tsLast;
  PDU *datapacket;
  uint8_t buff[MAX_DATAGRAM_LEN];
  uint32_t lostpackets;
  string myuid;
  uint16_t netflow;
};

#endif

---