barrier_sync_client.h 713 B

123456789101112131415161718192021222324252627282930313233
  1. #ifndef __BARRIER_SYNC_CLIENT_H__
  2. #define __BARRIER_SYNC_CLIENT_H__
  3. #include "fixed_types.h"
  4. #include "clock_skew_minimization_object.h"
  5. #include "packetize.h"
  6. #include "subsecond_time.h"
  7. // Forward Decls
  8. class Core;
  9. class BarrierSyncClient : public ClockSkewMinimizationClient
  10. {
  11. private:
  12. Core* m_core;
  13. SubsecondTime m_barrier_interval;
  14. SubsecondTime m_next_sync_time;
  15. UInt32 m_num_outstanding;
  16. public:
  17. BarrierSyncClient(Core* core);
  18. ~BarrierSyncClient();
  19. void enable() {}
  20. void disable() {}
  21. void synchronize(SubsecondTime time, bool ignore_time, bool abort_func(void*) = NULL, void* abort_arg = NULL);
  22. };
  23. #endif /* __BARRIER_SYNC_CLIENT_H__ */