TAO/tests/Big_Oneways/Coordinator.h

   1
   2 #ifndef BIG_ONEWAYS_COORDINATOR_H
   3 #define BIG_ONEWAYS_COORDINATOR_H
   4 #include /**/ "ace/pre.h"
   5
   6 #include "TestS.h"
   7
   8 /// Implement the Test::Coordinator interface
   9 class Coordinator
  10   : public virtual POA_Test::Coordinator
  11 {
  12 public:
  13   /// Constructor
  14   Coordinator (CORBA::ULong peer_count);
  15
  16
  17   /// Check if all the peers have registered already
  18   int has_all_peers () const;
  19
  20   /// Check a session on each peer
  21   void create_session_list (Test::Session_Control_ptr session_control,
  22                             CORBA::ULong payload_size,
  23                             CORBA::ULong thread_count,
  24                             CORBA::ULong message_count,
  25                             Test::Session_List &session_list);
  26
  27   /// Shutdown all the peers
  28   void shutdown_all_peers ();
  29
  30   // = The skeleton methods
  31   virtual void add_peer (Test::Peer_ptr peer);
  32
  33 protected:
  34   /// Protected Destructor, call _remove_ref() instead
  35   virtual ~Coordinator ();
  36
  37 private:
  38   /// Store a reference to each peer
  39   Test::Peer_var *peers_;
  40
  41   /// Current number of elements in the array
  42   size_t peer_count_;
  43
  44   /// Array's capacity
  45   size_t peer_max_;
  46 };
  47
  48 #include /**/ "ace/post.h"
  49 #endif /* BIG_ONEWAYS_COORDINATOR_H */