TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/GroupInfoPublisher.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file   GroupInfoPublisher.h
   6  *
   7  *  @author Huang-Ming Huang <hh1@cse.wustl.edu>
   8  */
   9 //=============================================================================
  10
  11 #ifndef GROUPINFOPUBLISHER_H
  12 #define GROUPINFOPUBLISHER_H
  13 #include "ftrtec_export.h"
  14 #include "orbsvcs/FtRtecEventChannelAdminC.h"
  15 #include "tao/PortableServer/PortableServer.h"
  16 #include "ace/Vector_T.h"
  17 #include "ace/Singleton.h"
  18 #include "ace/Synch.h"
  19 #include <memory>
  20
  21 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  22 # pragma once
  23 #endif /* ACE_LACKS_PRAGMA_ONCE */
  24
  25 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  26
  27 class TAO_FTEC_Become_Primary_Listener;
  28
  29 class GroupInfoPublisherBase
  30 {
  31 public:
  32   typedef FtRtecEventChannelAdmin::EventChannelList BackupList;
  33
  34   struct Info {
  35     bool primary;
  36     CORBA::Object_var iogr;
  37     FtRtecEventChannelAdmin::EventChannel_var successor;
  38     BackupList backups;
  39   };
  40
  41   typedef std::unique_ptr<Info> Info_ptr;
  42
  43   void subscribe(TAO_FTEC_Become_Primary_Listener* listener);
  44   void set_naming_context(CosNaming::NamingContext_var naming_context);
  45   bool is_primary() const;
  46   CORBA::Object_var group_reference() const;
  47
  48   FtRtecEventChannelAdmin::EventChannel_var successor() const;
  49
  50   const BackupList& backups() const;
  51
  52   Info* setup_info(const FTRT::ManagerInfoList & info_list,
  53               int my_position,
  54               CORBA::ULong object_group_ref_version);
  55
  56   void update_info(Info_ptr& info);
  57
  58   const PortableServer::ObjectId& object_id() const;
  59   const CosNaming::Name& name() const;
  60
  61   void object_id(const char* oid);
  62   void name(const char* nam);
  63   GroupInfoPublisherBase();
  64
  65 private:
  66   CosNaming::NamingContext_var naming_context_;
  67   typedef ACE_Vector<TAO_FTEC_Become_Primary_Listener*, 2> Subscribers;
  68   Subscribers subscribers_;
  69   PortableServer::ObjectId object_id_;
  70   CosNaming::Name name_;
  71   Info_ptr info_;
  72 };
  73
  74 TAO_END_VERSIONED_NAMESPACE_DECL
  75
  76 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  77
  78 TAO_FTRTEC_SINGLETON_DECLARE(ACE_Singleton, GroupInfoPublisherBase, TAO_SYNCH_MUTEX)
  79 typedef ACE_Singleton<GroupInfoPublisherBase, TAO_SYNCH_MUTEX> GroupInfoPublisher;
  80
  81 ACE_END_VERSIONED_NAMESPACE_DECL
  82
  83 #endif