Barrier.h

Go to the documentation of this file.

#ifndef BARRIER_H
#define BARRIER_H
#include <string>
#include <vector>

class Barrier
{
 private:
  std::string name;
  std::vector<bool> nodes;

 public:
  static std::string currentBarrier;

 public:
  Barrier(const char *bname, int node_num);
  /* Wait for all acks to come in */
  bool CheckBarrierReached(int delay = 100);
  
  /* Client side functions */
  /* Acknowledge that we reached the barrier */
  static void SendAck(void);
  /* Wait for the go ahead message */
  static bool WaitGoAhead(int delay = 100);
  /* Wait for the server to send out a new barrier*/
  static bool WaitForBarrier(std::string bname, int delay = 100);

 private:
  /* Send go ahead message to all nodes */
  void sendGoAhead(void);
 
};

#endif /*BARRIER_H*/

---