RunSync.hh

 
#ifndef GRAMODS_NETWORK_RUNSYNC
#define GRAMODS_NETWORK_RUNSYNC
 
#include <gmNetwork/Protocol.hh>
 
#include <set>
#include <mutex>
#include <condition_variable>
 
BEGIN_NAMESPACE_GMNETWORK;
 
class RunSync
  : public Protocol {
 
public:
 
  RunSync();
  ~RunSync();
 
  void wait();
 
  void processMessage(Message m) override;
 
  void lostPeer(size_t idx) override;
 
  char getProtocolFlag() override { return 10; }
 
private:
 
  struct Impl;
  std::unique_ptr<Impl> _impl;
};
 
END_NAMESPACE_GMNETWORK;
 
#endif