---

netmanager.h

#ifndef _NETMANAGER_H_
#define _NETMANAGER_H_

#ifdef _MSC_VER // if the compiler is from Microsoft
  #pragma warning(disable:4786)
#endif

#include <vector>
#include <queue>

using namespace std;

#include "messagepacket.h"
#include <SDL.h>
#include <SDL_thread.h>
#include <SDL_net.h>
#include <iostream>

// $$$ We need to have some kind of error control
// $$$ Also need some flow control
// $$$ Provide a way to clear the output buffers and discard their data
// $$$ Consider to make asyinchronous the data sending, as well

class NetManager {
 public:
  NetManager();

  void keepSending(bool go_on=true);

  virtual ~NetManager();

  void waitForData();

  static const Uint16 SERVER_PORT;

  static const int PACKET_SIZE;

  bool dataReady();

 protected:
  virtual void onReception(unsigned client) {};

  void transmit(const UDPsocket& sock, const MessagePacket& msg) const;

  friend int receiverCallback(void* data);

  virtual void manageReception();

  virtual bool forwardMessage(const MessagePacket& msg, IPaddress* ip) = 0;

  queue<MessagePacket> inputBuffer;

  IPaddress serverIP;

  UDPsocket receiverSocket;

  Uint16 actualPort;

  SDL_Thread* receiver;

  bool exitControllers;

  bool keepSendingFlag;

  SDL_mutex* sendingMutex;

  SDL_mutex* exitMutex;

  SDL_cond* dataReadyCond;

  SDL_mutex* dataReadyMutex;

  SDLNet_SocketSet receiverSet;

  SDL_mutex * socketOpen;
};

#endif

---