TAO/tests/Big_Twoways/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   /// Check if all the peers have registered already
  17   int has_all_peers () const;
  18
  19   /// Check a session on each peer
  20   void create_session_list (Test::Session_Control_ptr session_control,
  21                             CORBA::ULong payload_size,
  22                             CORBA::ULong thread_count,
  23                             CORBA::ULong message_count,
  24                             Test::Session_List &session_list);
  25
  26   /// Shutdown all the peers
  27   void shutdown_all_peers ();
  28
  29   // = The skeleton methods
  30   virtual void add_peer (Test::Peer_ptr peer);
  31
  32 protected:
  33   /// Protected destructor, call _remove_ref() to delete
  34   virtual ~Coordinator ();
  35
  36 private:
  37   /// Store a reference to each peer
  38   Test::Peer_var *peers_;
  39
  40   /// Current number of elements in the array
  41   size_t peer_count_;
  42
  43   /// Array's capacity
  44   size_t peer_max_;
  45 };
  46
  47 #include /**/ "ace/post.h"
  48 #endif /* BIG_ONEWAYS_COORDINATOR_H */