TAO/tests/AMI_Buffering/AMI_Buffering.h

   1
   2 #ifndef AMI_BUFFERING_H
   3 #define AMI_BUFFERING_H
   4 #include /**/ "ace/pre.h"
   5
   6 #include "TestS.h"
   7
   8 /// Implement the Test::AMI_Buffering interface
   9 class AMI_Buffering
  10   : public virtual POA_Test::AMI_Buffering
  11 {
  12 public:
  13   /// Constructor
  14   AMI_Buffering (CORBA::ORB_ptr orb,
  15                  Test::AMI_Buffering_Admin_ptr admin);
  16
  17   // = The skeleton methods
  18   virtual void receive_data (const Test::Payload &the_payload);
  19
  20   virtual void flush ();
  21
  22   virtual void sync ();
  23
  24   virtual void shutdown ();
  25
  26   /// internal implementation of shutdown. This
  27   void try_shutdown ();
  28
  29   class Nest_Guard
  30     {
  31     public:
  32       Nest_Guard (AMI_Buffering &);
  33       ~Nest_Guard ();
  34     private:
  35       AMI_Buffering &target_;
  36     };
  37
  38   /// Use an ORB reference to shutdown the application.
  39   CORBA::ORB_var orb_;
  40
  41   /// Report request progress to this interface
  42   Test::AMI_Buffering_Admin_var admin_;
  43
  44   /// nesting depth count for receive_data processing
  45   int nest_;
  46
  47   /// maximum nesting depth reached during run
  48   int max_nest_;
  49
  50   /// flag indicating that a shutdown is required as soon
  51   /// as the nest count reaches 0.
  52   bool must_shutdown_;
  53 };
  54
  55 #include /**/ "ace/post.h"
  56 #endif /* AMI_BUFFERING_H */