include/monitor/vcommunication/NetworkSink.h

   1 /**
   2         Aesalon, a tool to visualize a program's behaviour at run-time.
   3         Copyright (C) 2010, Aesalon Development Team.
   4
   5         Aesalon is distributed under the terms of the GNU GPLv3. For more
   6         licensing information, see the file LICENSE included with the distribution.
   7
   8         @file include/monitor/vcommunication/NetworkSink.h
   9
  10 */
  11
  12 #ifndef AesalonMonitor_VCommunication_NetworkSink_H
  13 #define AesalonMonitor_VCommunication_NetworkSink_H
  14
  15 #include <vector>
  16
  17 #include <semaphore.h>
  18
  19 #include "DataSink.h"
  20
  21 namespace Monitor {
  22 namespace VCommunication {
  23
  24 class NetworkSink : public DataSink {
  25 private:
  26         sem_t m_accessLock;
  27         int m_serverFd;
  28         int m_sockType;
  29
  30         typedef std::vector<int> ClientFdList;
  31         ClientFdList m_clientFds;
  32 public:
  33         NetworkSink();
  34         ~NetworkSink();
  35
  36         /** Sink a packet across a network socket.
  37         */
  38         virtual void sinkPacket(Common::VPacket *packet);
  39 private:
  40         void openSocket();
  41         void closeSocket();
  42         void waitForConnections(int connectionCount);
  43
  44         void sendPacket(Common::VPacket *packet, int fd);
  45 };
  46
  47 } // namespace VCommunication
  48 } // namespace Monitor
  49
  50 #endif