TAO/tests/LongUpcalls/AMI_Manager.h

   1 #ifndef LONGUPCALLS_AMI_MANAGER_H
   2 #define LONGUPCALLS_AMI_MANAGER_H
   3
   4 #include "TestS.h"
   5 #include "ace/Task.h"
   6
   7 class AMI_Manager
   8   : public virtual POA_Test::Manager
   9 {
  10 public:
  11   AMI_Manager (CORBA::ORB_ptr orb);
  12   // Constructor
  13
  14   // = The skeleton methods
  15   virtual void start_workers (CORBA::Short worker_count,
  16                               CORBA::Long milliseconds,
  17                               Test::Controller_ptr controller);
  18   virtual void shutdown ();
  19
  20 private:
  21   CORBA::ORB_var orb_;
  22   // The ORB, to shutdown
  23 };
  24
  25 // ****************************************************************
  26
  27 class Worker : public ACE_Task_Base
  28 {
  29 public:
  30   Worker (ACE_Thread_Manager *thr_mgr,
  31           Test::Controller_ptr controller,
  32           CORBA::Long milliseconds,
  33           CORBA::ORB_ptr orb);
  34
  35   virtual int svc ();
  36   // The service method
  37
  38 private:
  39   Test::Controller_var controller_;
  40   // The controller pointer
  41
  42   CORBA::Long milliseconds_;
  43   // The number of milliseconds.
  44
  45   CORBA::ORB_var orb_;
  46   // The orb
  47 };
  48
  49 // ****************************************************************
  50
  51 class Controller_Handler
  52   :  public virtual POA_Test::AMI_ControllerHandler
  53 {
  54 public:
  55   Controller_Handler (TAO_SYNCH_MUTEX *mutex,
  56                       int *pending_replies);
  57   // Constructor
  58
  59   virtual void worker_started ();
  60   virtual void worker_started_excep (::Messaging::ExceptionHolder*);
  61   virtual void worker_finished ();
  62   virtual void worker_finished_excep (::Messaging::ExceptionHolder*);
  63
  64 private:
  65   TAO_SYNCH_MUTEX *mutex_;
  66   int *pending_replies_;
  67   // The pending replies is decremented each time a reply is
  68   // received.
  69   // The mutex is used to protect the access to the flag.
  70 };
  71
  72 #endif /* LONGUPCALLS_AMI_MANAGER_H */