TAO/tao/PortableServer/ServantRetentionStrategyRetain.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file ServantRetentionStrategyRetain.h
   6  *
   7  *  @author  Johnny Willemsen  <jwillemsen@remedy.nl>
   8  */
   9 //=============================================================================
  10
  11 #ifndef TAO_SERVANT_RETENTION_STRATEGY_RETAIN_H
  12 #define TAO_SERVANT_RETENTION_STRATEGY_RETAIN_H
  13 #include /**/ "ace/pre.h"
  14
  15 #include "tao/PortableServer/ServantRetentionStrategyNonRetain.h"
  16
  17 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  18 # pragma once
  19 #endif /* ACE_LACKS_PRAGMA_ONCE */
  20
  21 #include "tao/PortableServer/Active_Object_Map.h"
  22 #include <memory>
  23
  24 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  25
  26 class TAO_Root_POA;
  27
  28 namespace TAO
  29 {
  30   namespace Portable_Server
  31   {
  32     class ServantRetentionStrategyRetain
  33        : public ServantRetentionStrategyNonRetain
  34     {
  35     public:
  36       ServantRetentionStrategyRetain () = default;
  37
  38       CORBA::ULong waiting_servant_deactivation () const override;
  39
  40       void strategy_init (TAO_Root_POA *poa) override;
  41
  42       void strategy_cleanup() override;
  43
  44       int is_servant_in_map (PortableServer::Servant servant,
  45                              bool &wait_occurred_restart_call) override;
  46
  47       PortableServer::ObjectId *
  48       activate_object (PortableServer::Servant servant,
  49                        CORBA::Short priority,
  50                        bool &wait_occurred_restart_call) override;
  51
  52       void
  53       activate_object_with_id (const PortableServer::ObjectId &id,
  54                                PortableServer::Servant servant,
  55                                CORBA::Short priority,
  56                                bool &wait_occurred_restart_call) override;
  57
  58       void deactivate_object (const PortableServer::ObjectId &id) override;
  59
  60       PortableServer::Servant find_servant (const PortableServer::ObjectId &system_id) override;
  61
  62       PortableServer::ObjectId * system_id_to_object_id (const PortableServer::ObjectId &system_id) override;
  63
  64       PortableServer::Servant user_id_to_servant (const PortableServer::ObjectId &id) override;
  65
  66       CORBA::Object_ptr id_to_reference (const PortableServer::ObjectId &id,
  67                                          bool indirect) override;
  68
  69       TAO_Servant_Location
  70       servant_present (const PortableServer::ObjectId &system_id,
  71                        PortableServer::Servant &servant) override;
  72
  73       PortableServer::Servant find_servant (
  74         const PortableServer::ObjectId &system_id,
  75         TAO::Portable_Server::Servant_Upcall &servant_upcall,
  76         TAO::Portable_Server::POA_Current_Impl &poa_current_impl) override;
  77
  78       int find_servant_priority (
  79         const PortableServer::ObjectId &system_id,
  80         CORBA::Short &priority) override;
  81
  82       void deactivate_all_objects () override;
  83
  84       PortableServer::ObjectId *servant_to_user_id (PortableServer::Servant servant) override;
  85
  86       CORBA::Object_ptr servant_to_reference (PortableServer::Servant servant) override;
  87
  88       CORBA::Object_ptr create_reference (const char *intf, CORBA::Short priority) override;
  89
  90 #if !defined (CORBA_E_MICRO)
  91       CORBA::Object_ptr create_reference_with_id (
  92         const PortableServer::ObjectId &oid,
  93         const char *intf,
  94         CORBA::Short priority) override;
  95 #endif
  96
  97     protected:
  98       int
  99       is_user_id_in_map (const PortableServer::ObjectId &id,
 100                          CORBA::Short priority,
 101                          bool &priorities_match,
 102                          bool &wait_occurred_restart_call);
 103
 104       void
 105       deactivate_map_entry (TAO_Active_Object_Map_Entry *active_object_map_entry);
 106
 107       PortableServer::ObjectId *servant_to_system_id_i (
 108           PortableServer::Servant p_servant,
 109           CORBA::Short &priority);
 110
 111       int rebind_using_user_id_and_system_id (
 112         PortableServer::Servant servant,
 113         const PortableServer::ObjectId &user_id,
 114         const PortableServer::ObjectId &system_id,
 115         TAO::Portable_Server::Servant_Upcall &servant_upcall) override;
 116
 117       CORBA::Boolean servant_has_remaining_activations (
 118         PortableServer::Servant servant) override;
 119
 120       int unbind_using_user_id (
 121         const PortableServer::ObjectId &user_id) override;
 122
 123       TAO_Active_Object_Map * get_active_object_map() const override;
 124
 125     private:
 126       std::unique_ptr<TAO_Active_Object_Map> active_object_map_;
 127       CORBA::ULong waiting_servant_deactivation_ { 0 } ;
 128     };
 129   }
 130 }
 131
 132 TAO_END_VERSIONED_NAMESPACE_DECL
 133
 134 #include /**/ "ace/post.h"
 135 #endif /* TAO_SERVANT_RETENTION_STRATEGY_RETAIN_H */