TAO/orbsvcs/tests/Notify/lib/Peer_T.h

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file Peer_T.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_Tests_PEER_T_H
   9 #define TAO_Notify_Tests_PEER_T_H
  10 #include /**/ "ace/pre.h"
  11
  12 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  13 # pragma once
  14 #endif /* ACE_LACKS_PRAGMA_ONCE */
  15
  16 #include "Peer.h"
  17 #include "tao/PortableServer/Servant_Base.h"
  18
  19 /**
  20  * @class TAO_Notify_Tests_Peer_T
  21  *
  22  * @brief Base implementation for all Supplier and Consumer Classes.
  23  */
  24 template <class Peer_Traits>
  25 class TAO_Notify_Tests_Peer_T : public TAO_Notify_Tests_Peer, public Peer_Traits::SKELETON
  26 {
  27   typedef typename Peer_Traits::Admin_Traits Admin_Traits;
  28   typedef typename Peer_Traits::Admin_Ext_Traits Admin_Ext_Traits;
  29   typedef typename Peer_Traits::Proxy_Traits Proxy_Traits;
  30
  31   typedef typename Peer_Traits::PTR Peer_Traits_PTR;
  32
  33   typedef typename Proxy_Traits::INTERFACE Proxy_Traits_INTERFACE;
  34   typedef typename Proxy_Traits::PTR Proxy_Traits_PTR;
  35   typedef typename Proxy_Traits::ID Proxy_Traits_ID;
  36
  37   typedef typename Admin_Traits::PTR Admin_Traits_PTR;
  38
  39   typedef typename Admin_Ext_Traits::INTERFACE Admin_Ext_Traits_INTERFACE;
  40   typedef typename Admin_Ext_Traits::PTR Admin_Ext_Traits_PTR;
  41
  42 public:
  43   /// Constructor
  44   TAO_Notify_Tests_Peer_T ();
  45
  46   /// Destructor
  47   virtual ~TAO_Notify_Tests_Peer_T ();
  48
  49   // Activates this servant with the POA supplied in init.
  50   // Connects to given proxy.
  51   void connect (Proxy_Traits_PTR proxy, Proxy_Traits_ID proxy_id);
  52
  53   // Activates this servant with the POA supplied in init.
  54   // Creates a new proxy supplier and connects to it.
  55   void connect (Admin_Traits_PTR admin_ptr);
  56
  57   /// Connect using options parsed and set initial QoS.
  58   virtual void connect ();
  59
  60   // Disconnect from the Peer.
  61   void disconnect ();
  62
  63   /// Set Qos
  64   void set_qos (CosNotification::QoSProperties& qos);
  65
  66   /// Dump status
  67   void status ();
  68
  69   // Accessor for <proxy_>.
  70   Proxy_Traits_PTR get_proxy ();
  71
  72   /// Deactivate the object.
  73   void deactivate ();
  74
  75   // = ServantBase operations
  76   virtual PortableServer::POA_ptr _default_POA ();
  77
  78 protected:
  79   /// Activate this object in the default POA.
  80   virtual Peer_Traits_PTR activate ();
  81
  82   ///= To be implemented by specializations.
  83
  84   /// Connect to Peer.
  85   virtual void connect_to_peer (Proxy_Traits_PTR proxy_ptr, Peer_Traits_PTR peer_ptr) = 0;
  86
  87   /// Obtain Proxy.
  88   virtual Proxy_Traits_PTR obtain_proxy (Admin_Traits_PTR admin_ptr) = 0;
  89
  90   /// Obtain Proxy with QoS.
  91   virtual Proxy_Traits_PTR obtain_proxy (Admin_Ext_Traits_PTR admin_ptr
  92                                          , CosNotification::QoSProperties& qos) = 0;
  93
  94   /// Disconnect from proxy.
  95   virtual void disconnect_from_proxy () = 0;
  96
  97   // = Data Members
  98
  99   /// The proxy that we are connected to.
 100    typename Proxy_Traits::VAR proxy_;
 101
 102   /// This <proxy_> id.
 103    typename Proxy_Traits::ID proxy_id_;
 104 };
 105
 106 #include "Peer_T.cpp"
 107
 108 #include /**/ "ace/post.h"
 109 #endif /* TAO_Notify_Tests_PEER_T_H */