diff options
author | huangming <huangming@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-11-29 22:48:41 +0000 |
---|---|---|
committer | huangming <huangming@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-11-29 22:48:41 +0000 |
commit | f8b664ce0a067b3c0f1e3363bc898b8db47f3801 (patch) | |
tree | e4dabd270f1fe2e244a6a1fd2d5b6bc01e0739fd /TAO/orbsvcs/orbsvcs/FtRtEvent | |
parent | e5cd003cddb4f27f75db604b395cb59cafe44c94 (diff) | |
download | ATCD-f8b664ce0a067b3c0f1e3363bc898b8db47f3801.tar.gz |
Mon Nov 29 16:45:00 2004 Huang-Ming Huang <hh1@cse.wustl.edu>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/FtRtEvent')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/GroupInfoPublisher.cpp | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/GroupInfoPublisher.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/GroupInfoPublisher.cpp index 794af13cf6b..21b34516c83 100644 --- a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/GroupInfoPublisher.cpp +++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/GroupInfoPublisher.cpp @@ -91,7 +91,7 @@ GroupInfoPublisherBase::setup_info(const FTRT::ManagerInfoList & info_list, /// check if sucessor changed size_t successors_length = info_list.length() - my_position -1; - if (successors_length != info_->backups.length()) { + if (successors_length /*!= info_->backups.length() */) { // successor changed, update successor iors.length(successors_length); for (i = 0; i < successors_length; ++i) { @@ -107,16 +107,18 @@ GroupInfoPublisherBase::setup_info(const FTRT::ManagerInfoList & info_list, ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN(0); } + /* else { result->successor = info_->successor; } - + if (!CORBA::is_nil(result->successor.in())) { CORBA::PolicyList_var pols; result->successor->_validate_connection (pols.out ()); } - + */ + // update backups result->backups.length(successors_length); for (i = 0; i < successors_length; ++i) { @@ -124,8 +126,8 @@ GroupInfoPublisherBase::setup_info(const FTRT::ManagerInfoList & info_list, FtRtecEventChannelAdmin::EventChannel::_narrow( info_list[i+ my_position+1].ior.in() ACE_ENV_ARG_PARAMETER); - CORBA::PolicyList_var pols; - result->backups[i]->_validate_connection (pols.out ()); + //CORBA::PolicyList_var pols; + //result->backups[i]->_validate_connection (pols.out ()); ACE_CHECK_RETURN(0); } return result.release(); |