TAO/orbsvcs/ImplRepo_Service/UpdateableServerInfo.cpp

   1 #include "orbsvcs/Log_Macros.h"
   2 #include "Locator_Repository.h"
   3 #include "UpdateableServerInfo.h"
   4
   5 UpdateableServerInfo::UpdateableServerInfo (const Repository_Ptr& repo,
   6                                             const ACE_CString& name,
   7                                             int pid)
   8 : repo_(repo),
   9   si_(repo->get_active_server (name,pid)),
  10   needs_update_(false)
  11 {
  12 }
  13
  14 UpdateableServerInfo::UpdateableServerInfo (const Repository_Ptr& repo,
  15                                             const Server_Info_Ptr& si,
  16                                             bool reset_start_count)
  17 : repo_(repo),
  18   si_(si),
  19   needs_update_(false)
  20 {
  21   if (reset_start_count)
  22     {
  23       needs_update_ = repo_.get() != 0;
  24       si_->active_info ()->start_count_ = 0;
  25     }
  26 }
  27
  28 UpdateableServerInfo::UpdateableServerInfo (UpdateableServerInfo& other)
  29   :repo_ (other.repo_),
  30    si_ (other.si_),
  31    needs_update_(other.needs_update_)
  32 {
  33   other.needs_update_ = false;
  34 }
  35
  36 UpdateableServerInfo::~UpdateableServerInfo ()
  37 {
  38   update_repo ();
  39 }
  40
  41 void
  42 UpdateableServerInfo::server_info (const Server_Info_Ptr& si)
  43 {
  44   this->si_ = si;
  45 }
  46
  47 void
  48 UpdateableServerInfo::notify_remote_access
  49 (ImplementationRepository::AAM_Status state)
  50 {
  51   repo_->notify_remote_access (this->si_->ping_id (), state);
  52 }
  53
  54 void
  55 UpdateableServerInfo::update_repo ()
  56 {
  57   if (!needs_update_)
  58     return;
  59
  60   needs_update_ = false;
  61   int err = repo_->update_server (si_);
  62   if (err == 0 && !si_->alt_info_.null ())
  63     {
  64       err = repo_->update_server (si_->alt_info_);
  65     }
  66   if (err != 0)
  67     {
  68       ORBSVCS_ERROR ((LM_ERROR,"(%P|%t) update repo failed err = %d, %p\n",
  69                       err, "update_server"));
  70     }
  71 }
  72
  73 const Server_Info*
  74 UpdateableServerInfo::operator-> () const
  75 {
  76   return si_.get();
  77 }
  78
  79 const Server_Info&
  80 UpdateableServerInfo::operator* () const
  81 {
  82   return *(si_.get());
  83 }
  84
  85
  86 const Server_Info_Ptr&
  87 UpdateableServerInfo::edit (bool active)
  88 {
  89   needs_update_ = active && repo_.get() != 0;
  90   return si_;
  91 }
  92
  93 bool
  94 UpdateableServerInfo::null() const
  95 {
  96   return si_.null();
  97 }