summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/AMI_Primary_Replication_Strategy.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/AMI_Primary_Replication_Strategy.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/AMI_Primary_Replication_Strategy.cpp27
1 files changed, 11 insertions, 16 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/AMI_Primary_Replication_Strategy.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/AMI_Primary_Replication_Strategy.cpp
index 7a8965f5c46..9e6b48d3f06 100644
--- a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/AMI_Primary_Replication_Strategy.cpp
+++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/AMI_Primary_Replication_Strategy.cpp
@@ -1,13 +1,13 @@
// $Id$
-#include "orbsvcs/FtRtEvent/EventChannel/AMI_Primary_Replication_Strategy.h"
+#include "AMI_Primary_Replication_Strategy.h"
#include "ace/Synch_T.h"
-#include "orbsvcs/FtRtEvent/EventChannel/GroupInfoPublisher.h"
-#include "orbsvcs/FtRtEvent/EventChannel/Request_Context_Repository.h"
-#include "orbsvcs/FtRtEvent/EventChannel/create_persistent_poa.h"
-#include "orbsvcs/FtRtEvent/EventChannel/Update_Manager.h"
+#include "GroupInfoPublisher.h"
+#include "Request_Context_Repository.h"
+#include "create_persistent_poa.h"
+#include "Update_Manager.h"
#include "tao/Utils/PolicyList_Destroyer.h"
-#include "orbsvcs/FtRtEvent/EventChannel/ObjectGroupManagerHandler.h"
+#include "ObjectGroupManagerHandler.h"
#include "tao/Utils/Implicit_Deactivator.h"
#include "../Utils/resolve_init.h"
#include "../Utils/ScopeGuard.h"
@@ -17,11 +17,8 @@ ACE_RCSID (EventChannel,
AMI_Primary_Replication_Strategy,
"$Id$")
-TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-
AMI_Primary_Replication_Strategy::AMI_Primary_Replication_Strategy(bool mt)
- : handler_(this),
- mutex_ (mt ? new ACE_SYNCH_RW_MUTEX : 0)
+: handler_(this), mutex_(mt ? new ACE_SYNCH_RW_MUTEX : 0)
{
}
@@ -107,8 +104,8 @@ AMI_Primary_Replication_Strategy::replicate_request(
ACE_ENV_ARG_DECL)
{
ACE_Auto_Event event;
- Update_Manager* manager = 0;
- bool success = false;
+ Update_Manager* manager;
+ bool success;
FTRT::TransactionDepth transaction_depth =
Request_Context_Repository().get_transaction_depth(ACE_ENV_SINGLE_ARG_PARAMETER);
@@ -120,7 +117,7 @@ AMI_Primary_Replication_Strategy::replicate_request(
size_t num_backups = backups.length();
if ((size_t)transaction_depth > num_backups) {
- TAO_FTRTEC::Log(3, "Throwing FTRT::TransactionDepthTooHigh\n");
+ TAO_FTRTEC::Log(3, ACE_TEXT("Throwing FTRT::TransactionDepthTooHigh\n"));
ACE_THROW(FTRT::TransactionDepthTooHigh());
}
@@ -167,7 +164,7 @@ AMI_Primary_Replication_Strategy::replicate_request(
}
ACE_ENDTRY;
}
- TAO_FTRTEC::Log(3, "Throwing FTRT::TransactionDepthTooHigh\n");
+ TAO_FTRTEC::Log(3, ACE_TEXT("Throwing FTRT::TransactionDepthTooHigh\n"));
ACE_THROW(FTRT::TransactionDepthTooHigh());
}
@@ -218,5 +215,3 @@ AMI_Primary_Replication_Strategy::add_member(const FTRT::ManagerInfo & info,
event.wait();
}
-
-TAO_END_VERSIONED_NAMESPACE_DECL