← Back to branch summary

~ubuntu-branches/ubuntu/breezy/ace/breezy

« back to all changes in this revision

Viewing changes to TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/Replication_Service.cpp

  • Committer: Bazaar Package Importer
  • Author(s): Adam Conrad, Benjamin Montgomery, Adam Conrad
  • Date: 2005-09-18 22:51:38 UTC
  • mfrom: (1.2.1 upstream) (2.1.1 sarge) (0.1.2 woody)
  • Revision ID: james.westby@ubuntu.com-20050918225138-seav22q6fyylb536
Tags: 5.4.7-3ubuntu1
[ Benjamin Montgomery ]
* Added a patch for amd64 and powerpc that disables the compiler
  option -fvisibility-inlines-hidden

[ Adam Conrad ]
* Added DPATCH_OPTION_CPP=1 to debian/patches/00options to make
  Benjamin's above changes work correctly with dpatch.

Show diffs side-by-side

added added

removed removed

Lines of Context:
TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/Replication_Service.cpp
1
 
// Replication_Service.cpp,v 1.7 2003/12/01 18:26:59 huangming Exp
2
 
 
3
 
#include "Replication_Service.h"
4
 
#include "AMI_Replication_Strategy.h"
5
 
#include "Basic_Replication_Strategy.h"
6
 
#include "FTEC_ORBInitializer.h"
7
 
 
8
 
#include "tao/ORBInitializer_Registry.h"
9
 
 
10
 
#include "ace/OS_NS_strings.h"
11
 
 
12
 
ACE_RCSID (EventChannel,
13
 
           Replication_Service,
14
 
           "Replication_Service.cpp,v 1.7 2003/12/01 18:26:59 huangming Exp")
15
 
 
16
 
namespace FTRTEC
17
 
{
18
 
  namespace {
19
 
    auto_ptr<Replication_Strategy> replication_strategy;
20
 
    Replication_Service* service;
21
 
  }
22
 
 
23
 
  Replication_Service* Replication_Service::instance()
24
 
  {
25
 
    return service;
26
 
  }
27
 
 
28
 
  Replication_Service::Replication_Service()
29
 
  {
30
 
    service = this;
31
 
  }
32
 
 
33
 
  Replication_Service::~Replication_Service()
34
 
  {
35
 
  }
36
 
 
37
 
  int Replication_Service::init (int argc, ACE_TCHAR* argv[])
38
 
  {
39
 
    static int initialized = 0;
40
 
 
41
 
    // Only allow initialization once.
42
 
    if (initialized)
43
 
      return 0;
44
 
 
45
 
    initialized = 1;
46
 
 
47
 
    Replication_Strategy* strategy;
48
 
 
49
 
    // Parse any service configurator parameters.
50
 
    if (argc > 0 && ACE_OS::strcasecmp (argv[0], ACE_LIB_TEXT("AMI")) == 0)
51
 
      ACE_NEW_RETURN (strategy, AMI_Replication_Strategy, -1);
52
 
    else
53
 
      ACE_NEW_RETURN (strategy, Basic_Replication_Strategy, -1);
54
 
 
55
 
     ACE_AUTO_PTR_RESET (replication_strategy, strategy, Replication_Strategy);
56
 
 
57
 
      ACE_TRY_NEW_ENV
58
 
      {
59
 
        PortableInterceptor::ORBInitializer_ptr temp_orb_initializer =
60
 
          PortableInterceptor::ORBInitializer::_nil ();
61
 
        PortableInterceptor::ORBInitializer_var orb_initializer;
62
 
 
63
 
        /// Register the RTCORBA ORBInitializer.
64
 
        ACE_NEW_THROW_EX (temp_orb_initializer,
65
 
          FTEC_ORBInitializer,
66
 
          CORBA::NO_MEMORY ());
67
 
        ACE_TRY_CHECK;
68
 
        orb_initializer = temp_orb_initializer;
69
 
 
70
 
        PortableInterceptor::register_orb_initializer (orb_initializer.in ()
71
 
          ACE_ENV_ARG_PARAMETER);
72
 
        ACE_TRY_CHECK;
73
 
      }
74
 
      ACE_CATCHANY
75
 
      {
76
 
        ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
77
 
          "Unexpected exception caught while "
78
 
          "initializing the TransactionDepth");
79
 
        return -1;
80
 
      }
81
 
      ACE_ENDTRY;
82
 
    return 0;
83
 
  }
84
 
 
85
 
 
86
 
  void Replication_Service::become_primary()
87
 
  {
88
 
    Replication_Strategy* strategy =
89
 
      replication_strategy->make_primary_strategy();
90
 
 
91
 
    ACE_ASSERT(strategy);
92
 
 
93
 
    if (replication_strategy.get() != strategy) {
94
 
      ACE_AUTO_PTR_RESET(replication_strategy, strategy, Replication_Strategy);
95
 
    }
96
 
  }
97
 
 
98
 
  void Replication_Service::check_validity(ACE_ENV_SINGLE_ARG_DECL)
99
 
  {
100
 
    replication_strategy->check_validity(ACE_ENV_SINGLE_ARG_PARAMETER);
101
 
  }
102
 
 
103
 
 
104
 
  void Replication_Service::replicate_request(const FtRtecEventChannelAdmin::Operation& update,
105
 
    RollbackOperation rollback
106
 
    ACE_ENV_ARG_DECL)
107
 
  {
108
 
    TAO_OutputCDR cdr;
109
 
    cdr << update;
110
 
 
111
 
    ACE_Message_Block mb;
112
 
    ACE_CDR::consolidate(&mb, cdr.begin());
113
 
    FTRT::State state(mb.length(), &mb);
114
 
    //FT::State state;
115
 
 
116
 
    replication_strategy->replicate_request(
117
 
      state,
118
 
      rollback,
119
 
      update.object_id
120
 
      ACE_ENV_ARG_PARAMETER);
121
 
  }
122
 
 
123
 
  int  Replication_Service::acquire_read (void)
124
 
  {
125
 
    int r =  replication_strategy->acquire_read();
126
 
    ACE_DEBUG((LM_DEBUG, "Read Lock acquired %d\n", r));
127
 
    return r;
128
 
  }
129
 
 
130
 
  int  Replication_Service::acquire_write (void)
131
 
  {
132
 
    int r= replication_strategy->acquire_write();
133
 
    ACE_DEBUG((LM_DEBUG, "Write Lock acqured %d\n", r));
134
 
    return r;
135
 
  }
136
 
 
137
 
  int  Replication_Service::release (void)
138
 
  {
139
 
    int r= replication_strategy->release();
140
 
    ACE_DEBUG((LM_DEBUG, "Lock Released %d\n", r));
141
 
    return r;
142
 
  }
143
 
 
144
 
  ACE_FACTORY_DEFINE (TAO_FTRTEC, Replication_Service)
145
 
 
146
 
  ACE_STATIC_SVC_DEFINE (Replication_Service,
147
 
    ACE_TEXT ("FTRTEC_Replication"),
148
 
    ACE_SVC_OBJ_T,
149
 
    &ACE_SVC_NAME (Replication_Service),
150
 
    ACE_Service_Type::DELETE_THIS
151
 
    | ACE_Service_Type::DELETE_OBJ,
152
 
    0)
153
 
}