include/vcomm/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/vcomm/NetworkSink.h
   9
  10 */
  11
  12 #ifndef AesalonVComm_NetworkSink_H
  13 #define AesalonVComm_NetworkSink_H
  14
  15 #include <vector>
  16
  17 #include <semaphore.h>
  18
  19 #include "DataSink.h"
  20
  21 namespace VComm {
  22
  23 class NetworkSink : public DataSink {
  24 private:
  25         sem_t m_accessLock;
  26         int m_serverFd;
  27         int m_sockType;
  28
  29         typedef std::vector<int> ClientFdList;
  30         ClientFdList m_clientFds;
  31 public:
  32         NetworkSink();
  33         ~NetworkSink();
  34
  35         /** Sink a packet across a network socket.
  36         */
  37         virtual void sinkPacket(Common::VPacket *packet);
  38 private:
  39         void openSocket();
  40         void closeSocket();
  41         void waitForConnections(int connectionCount);
  42
  43         void sendPacket(Common::VPacket *packet, int fd);
  44 };
  45
  46 } // namespace VComm
  47
  48 #endif