#include <PG_Object_Group.h>
Collaboration diagram for TAO::PG_Object_Group:
|
|
Definition at line 104 of file PG_Object_Group.h. |
|
|
Definition at line 105 of file PG_Object_Group.h. |
|
|
Definition at line 111 of file PG_Object_Group.h. Referenced by distribute_iogr(), locations_of_members(), set_primary_member(), and ~PG_Object_Group(). |
|
|
Definition at line 98 of file PG_Object_Group.h. |
|
||||||||||||||||||||||||||||||||||||
|
@TODO DOC Definition at line 63 of file PG_Object_Group.cpp. References PortableGroup::Criteria, empty_, group_specific_factories_, initial_number_members_, members_, minimum_number_members_, primary_location_, properties_, reference_, and role_.
00072 : internals_() 00073 , orb_ (CORBA::ORB::_duplicate (orb)) 00074 , factory_registry_ (PortableGroup::FactoryRegistry::_duplicate (factory_registry)) 00075 , manipulator_ (manipulator) 00076 , empty_ (1) 00077 , role_ (type_id) 00078 , type_id_ (CORBA::string_dup (type_id)) 00079 , tagged_component_ (tagged_component) 00080 , reference_ (CORBA::Object::_duplicate(empty_group)) 00081 , members_ () 00082 , primary_location_(0) 00083 , properties_ (the_criteria, type_properties) 00084 , initial_number_members_ (0) 00085 , minimum_number_members_ (0) 00086 , group_specific_factories_ () 00087 { 00088 } |
|
|
Destructor.
Definition at line 90 of file PG_Object_Group.cpp. References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::begin(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::end(), MemberMap_Iterator, members_, and ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::unbind_all().
00091 {
00092 for (MemberMap_Iterator it = this->members_.begin();
00093 it != this->members_.end();
00094 ++it)
00095 {
00096 MemberInfo * member = (*it).int_id_;
00097 delete member;
00098 }
00099 this->members_.unbind_all ();
00100 }
|
|
|
|
|
|
|
|
||||||||||||
|
Add a new member to the group.
Definition at line 194 of file PG_Object_Group.cpp. References ACE_DEBUG, ACE_GUARD, ACE_NEW_THROW_EX, ACE_TEXT, add_member_to_iogr(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::bind(), distribute_iogr(), increment_version(), LM_DEBUG, PortableGroup::Location, members_, reference_, TAO_debug_level, and TAO_SYNCH_MUTEX.
00197 {
00198 ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->internals_);
00199
00200 /////////////////////////////////////////
00201 // Convert the new member to a string IOR
00202 // This keeps a clean IOR (not an IOGR!)
00203 // while we add it to a group. We need a
00204 // IORs, not IOGRs to send new IOGRs out
00205 // to replicas.
00206
00207 CORBA::String_var member_ior_string =
00208 orb_->object_to_string (member);
00209
00210 PortableGroup::ObjectGroup_var new_reference =
00211 add_member_to_iogr (member);
00212
00213 // Convert new member back to a (non group) ior.
00214 CORBA::Object_var member_ior =
00215 this->orb_->string_to_object (member_ior_string.in ());
00216
00217 MemberInfo * info = 0;
00218 ACE_NEW_THROW_EX (info,
00219 MemberInfo (member_ior.in (),
00220 the_location),
00221 CORBA::NO_MEMORY());
00222
00223 if (this->members_.bind (the_location, info) != 0)
00224 {
00225 // @@ Dale why this is a NO MEMORY exception?
00226 throw CORBA::NO_MEMORY();
00227 }
00228
00229 this->reference_ = new_reference; // note var-to-var assignment does
00230 // a duplicate
00231 if (this->increment_version ())
00232 {
00233 this->distribute_iogr ();
00234 }
00235 else
00236 {
00237 throw PortableGroup::ObjectNotAdded ();
00238 }
00239
00240 if (TAO_debug_level > 6)
00241 {
00242 ACE_DEBUG ((LM_DEBUG,
00243 ACE_TEXT("PG (%P|%t) exit Object_Group add_member \n")));
00244 }
00245 }
|
|
|
Definition at line 153 of file PG_Object_Group.cpp. References CORBA::Object::_duplicate(), empty_, and reference_. Referenced by add_member(), create_member(), and create_members().
00154 {
00155 // assume internals is locked
00156
00157 PortableGroup::ObjectGroup_var result;
00158
00159 ////////////////////////////
00160 // @@ HACK ALERT
00161 // The PortableGroup::ObjectGroupManager creates an object reference
00162 // containing a dummy entry so it will have a place to store the
00163 // tagged group component. If this is the first entry, we need to
00164 // remove that entry once we have a *real* member. This can be
00165 // avoided when we get support for TAG_MULTIPLE_COMPONENTS. For
00166 // now, we already have a copy of the tagGroupTagged component and
00167 // we're going to use it below wen we increment the group version so
00168 // we can clean out the dummy entry.
00169 PortableGroup::ObjectGroup_var cleaned =
00170 PortableGroup::ObjectGroup::_duplicate (this->reference_.in ());
00171 if (this->empty_)
00172 {
00173 // remove the original profile. It's a dummy entry supplied by
00174 // create_object.
00175 cleaned =
00176 this->manipulator_.remove_profiles (cleaned.in (),
00177 this->reference_.in ());
00178 this->empty_ = 0;
00179 }
00180
00181 // create a list of references to be merged
00182 TAO_IOP::TAO_IOR_Manipulation::IORList iors (2);
00183 iors.length (2);
00184 iors [0] = CORBA::Object::_duplicate (cleaned.in());
00185 iors [1] = CORBA::Object::_duplicate (member);
00186
00187 // Now merge the list into one new IOGR
00188 result =
00189 this->manipulator_.merge_iors (iors);
00190 return result._retn ();
00191 }
|
|
||||||||||||||||
|
@TODO DOC Definition at line 593 of file PG_Object_Group.cpp. References ACE_GUARD, ACE_NEW_THROW_EX, add_member_to_iogr(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::bind(), PortableGroup::Criteria, distribute_iogr(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::find(), increment_version(), PortableGroup::Location, members_, reference_, role_, TAO_SYNCH_MUTEX, PortableGroup::FactoryInfo::the_factory, and PortableGroup::FactoryInfo::the_location.
00597 {
00598 ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->internals_);
00599
00600
00601 if (0 != this->members_.find (the_location))
00602 {
00603 // @@ what if factories were passed as criteria?
00604
00605 CORBA::String_var factory_type;
00606 PortableGroup::FactoryInfos_var factories =
00607 this->factory_registry_->list_factories_by_role (
00608 role_.c_str(),
00609 factory_type.out ());
00610
00611 // @@ what if factory_type != type_id != this->type_id_
00612
00613 int created = 0; // bool
00614 CORBA::ULong factory_count = factories->length ();
00615 for (CORBA::ULong factory_pos = 0;
00616 ! created && factory_pos < factory_count;
00617 ++factory_pos)
00618 {
00619 const PortableGroup::FactoryInfo & factory_info =
00620 (*factories)[factory_pos];
00621 if (factory_info.the_location == the_location)
00622 {
00623 // @@ should we merge the_criteria with
00624 // factory_info.the_criteria?
00625
00626 PortableGroup::GenericFactory::FactoryCreationId_var fcid;
00627 CORBA::Object_var member =
00628 factory_info.the_factory->create_object (
00629 type_id,
00630 the_criteria,
00631 fcid. out());
00632
00633 // convert the new member to a stringified IOR to avoid
00634 // contamination with group info
00635 CORBA::String_var member_ior_string =
00636 orb_->object_to_string (member.in ());
00637
00638 PortableGroup::ObjectGroup_var new_reference =
00639 this->add_member_to_iogr (member.in ());
00640
00641 // Convert new member back to a (non group) ior.
00642 CORBA::Object_var member_ior =
00643 this->orb_->string_to_object (member_ior_string.in ());
00644
00645 MemberInfo * info = 0;
00646 ACE_NEW_THROW_EX (info, MemberInfo(
00647 member_ior.in(),
00648 the_location,
00649 factory_info.the_factory,
00650 fcid.in ()),
00651 CORBA::NO_MEMORY());
00652
00653 if (this->members_.bind (the_location, info) != 0)
00654 {
00655 throw CORBA::NO_MEMORY();
00656 }
00657
00658 this->reference_ = new_reference; // note var-to-var
00659 // assignment does a
00660 // duplicate
00661 if (this->increment_version ())
00662 {
00663 this->distribute_iogr ();
00664 }
00665 created = 1;
00666 }
00667 }
00668 if (! created)
00669 {
00670 throw PortableGroup::NoFactory ();
00671 }
00672 }
00673 else
00674 {
00675 throw PortableGroup::MemberAlreadyPresent ();
00676 }
00677 }
|
|
|
Definition at line 680 of file PG_Object_Group.cpp. References ACE_ERROR, ACE_NEW_THROW_EX, ACE_TEXT(), add_member_to_iogr(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::bind(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::current_size(), distribute_iogr(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::find(), increment_version(), LM_ERROR, PortableGroup::Location, members_, reference_, role_, TAO_debug_level, PortableGroup::FactoryInfo::the_criteria, PortableGroup::FactoryInfo::the_factory, and PortableGroup::FactoryInfo::the_location. Referenced by initial_populate(), and minimum_populate().
00681 {
00682 // assume internals is locked
00683 // @@ what if factories were passed as criteria?
00684
00685 CORBA::String_var factory_type;
00686 PortableGroup::FactoryInfos_var factories =
00687 this->factory_registry_->list_factories_by_role (
00688 role_.c_str(),
00689 factory_type.out ());
00690
00691 CORBA::ULong factory_count = factories->length ();
00692 if (factory_count > 0)
00693 {
00694 CORBA::ULong factory_pos = 0;
00695 while (members_.current_size () < count && factory_pos < factory_count)
00696 {
00697 const PortableGroup::FactoryInfo & factory_info =
00698 (*factories)[factory_pos];
00699 const PortableGroup::Location & factory_location =
00700 factory_info.the_location;
00701 if (0 != this->members_.find (factory_location))
00702 {
00703 ///////////////////////////////////////////
00704 // If a factory refuses to create a replica
00705 // it's not fatal.
00706 try
00707 {
00708 PortableGroup::GenericFactory::FactoryCreationId_var fcid;
00709 CORBA::Object_var member =
00710 factory_info.the_factory->create_object (
00711 this->type_id_.in (),
00712 factory_info.the_criteria,
00713 fcid. out());
00714
00715 // convert the new member to a stringified IOR to avoid
00716 // contamination with group info
00717 CORBA::String_var member_ior_string =
00718 orb_->object_to_string (member.in ());
00719
00720 PortableGroup::ObjectGroup_var new_reference =
00721 this->add_member_to_iogr (member.in ());
00722
00723 // Convert new member back to a (non group) ior.
00724 CORBA::Object_var member_ior =
00725 this->orb_->string_to_object (member_ior_string.in ());
00726
00727 MemberInfo * info = 0;
00728 ACE_NEW_THROW_EX (info, MemberInfo(
00729 member_ior.in(),
00730 factory_location,
00731 factory_info.the_factory,
00732 fcid.in ()),
00733 CORBA::NO_MEMORY());
00734
00735 if (this->members_.bind (factory_location, info) != 0)
00736 {
00737 throw CORBA::NO_MEMORY();
00738 }
00739 this->reference_ =
00740 new_reference; // note var-to-var assignment does
00741 // a duplicate
00742 }
00743 catch (const CORBA::Exception&)
00744 {
00745 // log, but otherwise ignore the errorf
00746 if (TAO_debug_level > 0)
00747 {
00748 ACE_ERROR ((LM_ERROR,
00749 ACE_TEXT ("PG (%P|%t) Replica Factory ")
00750 ACE_TEXT ("@ %s refused create_object ")
00751 ACE_TEXT ("request for type %s\n"),
00752 static_cast<const char *> (factory_info.the_location[0].id),
00753 static_cast<const char *> (this->type_id_.in ())
00754 ));
00755 }
00756 }
00757 }
00758 }
00759
00760 if (this->increment_version ())
00761 {
00762 this->distribute_iogr ();
00763 }
00764 }
00765 else
00766 {
00767 throw PortableGroup::NoFactory();
00768 }
00769 }
|
|
|
Definition at line 438 of file PG_Object_Group.cpp. References ACE_DEBUG, ACE_ERROR, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::begin(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::end(), CORBA::is_nil(), TAO::PG_Object_Group::MemberInfo::is_primary_, LM_DEBUG, LM_ERROR, TAO::PG_Object_Group::MemberInfo::location_, TAO::PG_Object_Group::MemberInfo::member_, MemberMap_Iterator, members_, and TAO_debug_level. Referenced by add_member(), create_member(), create_members(), remove_member(), and set_primary_member().
00439 {
00440 // assume internals is locked
00441 CORBA::String_var iogr =
00442 this->orb_->object_to_string (this->reference_.in());
00443
00444 // size_t n_rep = 0; // for dump_ior below
00445 for (MemberMap_Iterator it = this->members_.begin();
00446 it != this->members_.end ();
00447 ++it)
00448 {
00449 MemberInfo const * info = (*it).int_id_;
00450 //
00451 // Unchecked narrow means the member doesn't have to actually implement the TAO_UpdateObjectGroup interface
00452 // PortableGroup::TAO_UpdateObjectGroup_var uog = PortableGroup::TAO_UpdateObjectGroup::_unchecked_narrow ( info->member_);
00453 // but it doesn work: error message at replica is:
00454 // TAO-FT (2996|976) - Wrong version information within the interceptor [1 | 0]
00455 // TAO_Perfect_Hash_OpTable:find for operation 'tao_update_object_group' (length=23) failed
00456 // back to using _narrow
00457 PortableGroup::TAO_UpdateObjectGroup_var uog =
00458 PortableGroup::TAO_UpdateObjectGroup::_narrow ( info->member_.in ());
00459 if (!CORBA::is_nil (uog.in ()))
00460 {
00461 try
00462 {
00463 if (TAO_debug_level > 3)
00464 {
00465 ACE_DEBUG ((LM_DEBUG,
00466 "PG (%P|%t) - Object_Group pushing "
00467 "IOGR to %s member: %s@%s.\n",
00468 (info->is_primary_ ? "Primary" : "Backup"),
00469 this->role_.c_str (),
00470 static_cast<const char *> (info->location_[0].id)
00471 ));
00472 }
00473 // dump_ior ("group", "iogr", this->tagged_component_.object_group_ref_version, iogr);
00474 // CORBA::String_var replica_ior = this->orb_->object_to_string(uog.in());
00475 // dump_ior (info->location_[0].id, "ior", (this->tagged_component_.object_group_ref_version * 100) + n_rep++, replica_ior);
00476 uog->tao_update_object_group (iogr.in (),
00477 this->tagged_component_.object_group_ref_version,
00478 info->is_primary_);
00479 }
00480 catch (const CORBA::Exception&)
00481 {
00482 // we expect an exception
00483 // tao_update_object_group is not a real method
00484 }
00485 }
00486 else
00487 {
00488 ACE_ERROR ((LM_ERROR,
00489 "TAO::PG_Object_Group::distribute iogr can't "
00490 "narrow member reference to "
00491 "PortableGroup::TAO_UpdateObjectGroup.\n"
00492 ));
00493 }
00494 }
00495 }
|
|
|
Note the caller receives a copy of the factoryinfos in the result argument. inefficient, but thread safe. Definition at line 131 of file PG_Object_Group.cpp. References ACE_GUARD, PortableGroup::FactoryInfos, group_specific_factories_, and TAO_SYNCH_MUTEX.
00133 {
00134 ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->internals_);
00135
00136 // copy is needed to have some semblance of thread safeness.
00137 // if performance is an issue avoid this method.
00138 result = this->group_specific_factories_;
00139 }
|
|
|
@TODO DOC Definition at line 580 of file PG_Object_Group.cpp. References PortableGroup::InitialNumberMembersValue, properties_, and TAO_PG_INITIAL_NUMBER_MEMBERS. Referenced by initial_populate().
00581 {
00582 PortableGroup::InitialNumberMembersValue initial_number_members = 0;
00583 if (!TAO::find (properties_,
00584 PortableGroup::PG_INITIAL_NUMBER_MEMBERS,
00585 initial_number_members))
00586 {
00587 initial_number_members = TAO_PG_INITIAL_NUMBER_MEMBERS;
00588 }
00589 return initial_number_members;
00590 }
|
|
|
@TODO DOC Definition at line 529 of file PG_Object_Group.cpp. References CORBA::Object::_duplicate(), ACE_GUARD_RETURN, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::find(), PortableGroup::Location, TAO::PG_Object_Group::MemberInfo::member_, members_, and TAO_SYNCH_MUTEX.
00531 {
00532 ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
00533 guard,
00534 this->internals_,
00535 CORBA::Object::_nil ());
00536
00537 CORBA::Object_var result;
00538
00539 MemberInfo * info = 0;
00540 if (this->members_.find (the_location, info) == 0)
00541 {
00542 result = CORBA::Object::_duplicate (info->member_.in ());
00543 }
00544 else
00545 {
00546 throw PortableGroup::MemberNotFound();
00547 }
00548 return result._retn ();
00549 }
|
|
|
@TODO DOC Definition at line 553 of file PG_Object_Group.cpp. References PortableGroup::MembershipStyleValue, properties_, and TAO_PG_MEMBERSHIP_STYLE. Referenced by initial_populate(), and minimum_populate().
00554 {
00555 PortableGroup::MembershipStyleValue membership_style = 0;
00556 if (!TAO::find (properties_,
00557 PortableGroup::PG_MEMBERSHIP_STYLE,
00558 membership_style))
00559 {
00560 membership_style = TAO_PG_MEMBERSHIP_STYLE;
00561 }
00562 return membership_style;
00563 }
|
|
|
@TODO DOC Definition at line 567 of file PG_Object_Group.cpp. References PortableGroup::MinimumNumberMembersValue, properties_, and TAO_PG_MINIMUM_NUMBER_MEMBERS. Referenced by minimum_populate().
00568 {
00569 PortableGroup::MinimumNumberMembersValue minimum_number_members = 0;
00570 if (!TAO::find (properties_,
00571 PortableGroup::PG_MINIMUM_NUMBER_MEMBERS,
00572 minimum_number_members))
00573 {
00574 minimum_number_members = TAO_PG_MINIMUM_NUMBER_MEMBERS;
00575 }
00576 return minimum_number_members;
00577 }
|
|
|
@TODO DOC Definition at line 368 of file PG_Object_Group.cpp. References ACE_GUARD_RETURN, and TAO_SYNCH_MUTEX. Referenced by TAO::PG_Group_Factory::insert_group().
00369 {
00370 ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
00371 guard,
00372 this->internals_,
00373 0);
00374 return this->tagged_component_.object_group_id;
00375 }
|
|
|
get location of primary member Definition at line 142 of file PG_Object_Group.cpp. References ACE_GUARD_RETURN, primary_location_, and TAO_SYNCH_MUTEX.
00143 {
00144 ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
00145 guard,
00146 this->internals_,
00147 this->primary_location_);
00148 return this->primary_location_;
00149 }
|
|
|
@TODO DOC Definition at line 389 of file PG_Object_Group.cpp. References ACE_GUARD, TAO::PG_Property_Set::export_properties(), properties_, and TAO_SYNCH_MUTEX.
00391 {
00392 ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->internals_);
00393 this->properties_.export_properties(*result);
00394 }
|
|
|
returns a duplicate caller must release Definition at line 398 of file PG_Object_Group.cpp. References ACE_GUARD_RETURN, CORBA::string_dup(), and TAO_SYNCH_MUTEX.
00399 {
00400 ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
00401 guard,
00402 this->internals_,
00403 0);
00404 return CORBA::string_dup (this->type_id_);
00405 }
|
|
|
@TODO DOC Definition at line 805 of file PG_Object_Group.cpp. References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::find(), PortableGroup::Location, and members_. Referenced by TAO::PG_Group_Factory::groups_at_location().
|
|
|
Definition at line 412 of file PG_Object_Group.cpp. References ACE_DEBUG, ACE_TEXT(), LM_DEBUG, TAO::PG_Utils::set_tagged_component(), and TAO_debug_level. Referenced by add_member(), create_member(), create_members(), remove_member(), and set_primary_member().
00413 {
00414 // assume internals is locked
00415 int result = 0;
00416 this->tagged_component_.object_group_ref_version += 1;
00417 if (TAO_debug_level > 3)
00418 {
00419 ACE_DEBUG ((LM_DEBUG,
00420 ACE_TEXT ("%T %n (%P|%t) - Setting IOGR version to %u\n"),
00421 static_cast<unsigned> (this->tagged_component_.object_group_ref_version)
00422 ));
00423 }
00424
00425 // Set the version
00426 if (TAO::PG_Utils::set_tagged_component (this->reference_,
00427 this->tagged_component_))
00428 {
00429 result = 1;
00430 }
00431 return result;
00432 }
|
|
|
@TODO DOC Definition at line 772 of file PG_Object_Group.cpp. References ACE_GUARD, create_members(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::current_size(), get_initial_number_members(), get_membership_style(), PortableGroup::InitialNumberMembersValue, members_, and TAO_SYNCH_MUTEX.
00773 {
00774 ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->internals_);
00775
00776 if (this->get_membership_style () == PortableGroup::MEMB_INF_CTRL)
00777 {
00778 PortableGroup::InitialNumberMembersValue initial_number_members =
00779 this->get_initial_number_members ();
00780
00781 if (this->members_.current_size () < initial_number_members)
00782 {
00783 this->create_members (initial_number_members);
00784 }
00785 }
00786 }
|
|
|
|
@TODO DOC Definition at line 789 of file PG_Object_Group.cpp. References ACE_GUARD, create_members(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::current_size(), get_membership_style(), get_minimum_number_members(), members_, PortableGroup::MinimumNumberMembersValue, and TAO_SYNCH_MUTEX.
00790 {
00791 ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->internals_);
00792
00793 if ( this->get_membership_style () == PortableGroup::MEMB_INF_CTRL )
00794 {
00795 PortableGroup::MinimumNumberMembersValue minimum_number_members =
00796 this->get_minimum_number_members ();
00797 if (members_.current_size () < minimum_number_members)
00798 {
00799 this->create_members (minimum_number_members);
00800 }
00801 }
00802 }
|
|
|
|
|
|
return a duplicated reference to this group (IOGR)
Definition at line 121 of file PG_Object_Group.cpp. References ACE_GUARD_RETURN, and TAO_SYNCH_MUTEX. Referenced by TAO::PG_Group_Factory::groups_at_location().
00122 {
00123 ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
00124 guard,
00125 this->internals_,
00126 PortableGroup::ObjectGroup::_nil ());
00127 return PortableGroup::ObjectGroup::_duplicate (this->reference_);
00128 }
|
|
|
@TODO DOC Definition at line 322 of file PG_Object_Group.cpp. References ACE_DEBUG, ACE_GUARD, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::current_size(), distribute_iogr(), empty_, increment_version(), LM_DEBUG, PortableGroup::Location, TAO::PG_Object_Group::MemberInfo::member_, members_, primary_location_, reference_, TAO_debug_level, TAO_SYNCH_MUTEX, and ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::unbind().
00324 {
00325 ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->internals_);
00326 MemberInfo * info = 0;
00327 if (this->members_.unbind (the_location, info) == 0)
00328 {
00329 if (this->members_.current_size() > 0)
00330 {
00331 this->reference_ =
00332 this->manipulator_.remove_profiles (this->reference_.in (),
00333 info->member_.in ());
00334 }
00335 else
00336 {
00337 empty_ = 1;
00338 }
00339
00340 delete info;
00341
00342 if (the_location == this->primary_location_)
00343 {
00344 this->primary_location_.length(0);
00345 }
00346
00347 if (this->increment_version ())
00348 {
00349 this->distribute_iogr ();
00350 }
00351
00352 }
00353 else
00354 {
00355 if (TAO_debug_level > 6)
00356 {
00357 ACE_DEBUG ((LM_DEBUG,
00358 "TAO-PG (%P|%t) - "
00359 "remove_member throwing MemberNotFound.\n"
00360 ));
00361 }
00362 throw PortableGroup::MemberNotFound();
00363 }
00364 }
|
|
||||||||||||
|
set the replica at the given location to be primary. Note: This should return void and throw FT::PrimaryNotSet but to avoid dependancies between PortableGroup and FaultTolerance it returns a boolean result. A false return means caller should throw FT::PrimaryNot_Set. Definition at line 248 of file PG_Object_Group.cpp. References ACE_DEBUG, ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::begin(), distribute_iogr(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::end(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::find(), increment_version(), TAO::PG_Object_Group::MemberInfo::is_primary_, LM_DEBUG, LM_ERROR, PortableGroup::Location, TAO::PG_Object_Group::MemberInfo::member_, MemberMap_Iterator, members_, primary_location_, TAO_debug_level, and TAO_SYNCH_MUTEX.
00251 {
00252 ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
00253 guard,
00254 this->internals_,
00255 0);
00256 int result = 1;
00257 MemberInfo * info = 0;
00258 if (this->members_.find (the_location, info) == 0)
00259 {
00260 int cleared = 0;
00261 this->primary_location_ = the_location;
00262 for (MemberMap_Iterator it = this->members_.begin();
00263 !cleared && it != this->members_.end();
00264 ++it)
00265 {
00266 cleared = (*it).int_id_->is_primary_;
00267 (*it).int_id_->is_primary_ = 0;
00268 }
00269 info->is_primary_ = 1;
00270
00271 int set_ok =
00272 this->manipulator_.set_primary (prop,
00273 this->reference_.in (),
00274 info->member_.in ());
00275 if (!set_ok)
00276 {
00277 if (TAO_debug_level > 3)
00278 {
00279 ACE_ERROR ((LM_ERROR,
00280 ACE_TEXT ("%T %n (%P|%t) - ")
00281 ACE_TEXT ("Can't set primary in IOGR .\n")
00282 ));
00283 }
00284 //@@: ACE_THROW (FT::PrimaryNotSet());
00285 result = 0;
00286 }
00287
00288 if (result && this->increment_version ())
00289 {
00290 this->distribute_iogr ();
00291 }
00292 else
00293 {
00294 if (TAO_debug_level > 3)
00295 {
00296 ACE_DEBUG ((LM_DEBUG,
00297 ACE_TEXT("TAO-PG (%P|%t) - set_primary_location ")
00298 ACE_TEXT("throwing PrimaryNotSet because increment")
00299 ACE_TEXT("version failed.\n")
00300 ));
00301 }
00302 //@@: ACE_THROW (FT::PrimaryNotSet());
00303 result = 0;
00304 }
00305 }
00306 else
00307 {
00308 if (TAO_debug_level > 3)
00309 {
00310 ACE_DEBUG ((LM_DEBUG,
00311 ACE_TEXT ("TAO-PG (%P|%t) - set_primary_location ")
00312 ACE_TEXT ("throwing MemberNotFound.\n")));
00313 }
00314 throw PortableGroup::MemberNotFound();
00315 }
00316
00317 return result;
00318 }
|
|
|
@TODO DOC Definition at line 378 of file PG_Object_Group.cpp. References ACE_GUARD, TAO::PG_Property_Set::decode(), PortableGroup::Properties, properties_, and TAO_SYNCH_MUTEX.
00380 {
00381 ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->internals_);
00382
00383 this->properties_.decode (overrides);
00384
00385 //@@ int todo_override_rather_than_replace?
00386 }
|
|
|
boolean true if empty group
Definition at line 303 of file PG_Object_Group.h. Referenced by add_member_to_iogr(), PG_Object_Group(), and remove_member(). |
|
|
Where to find the factories for replicas.
Definition at line 296 of file PG_Object_Group.h. |
|
|
Definition at line 341 of file PG_Object_Group.h. Referenced by get_group_specific_factories(), and PG_Object_Group(). |
|
|
Definition at line 339 of file PG_Object_Group.h. Referenced by PG_Object_Group(). |
|
|
Protect internal state. Definition at line 291 of file PG_Object_Group.h. |
|
|
Definition at line 300 of file PG_Object_Group.h. |
|
|
Definition at line 329 of file PG_Object_Group.h. Referenced by add_member(), create_member(), create_members(), distribute_iogr(), get_member_reference(), has_member_at(), initial_populate(), locations_of_members(), minimum_populate(), PG_Object_Group(), remove_member(), set_primary_member(), and ~PG_Object_Group(). |
|
|
Definition at line 340 of file PG_Object_Group.h. Referenced by PG_Object_Group(). |
|
|
The CORBA object id assigned to this object group Definition at line 326 of file PG_Object_Group.h. |
|
|
Definition at line 293 of file PG_Object_Group.h. |
|
|
Definition at line 331 of file PG_Object_Group.h. Referenced by get_primary_location(), PG_Object_Group(), remove_member(), and set_primary_member(). |
|
|
Definition at line 335 of file PG_Object_Group.h. Referenced by get_initial_number_members(), get_membership_style(), get_minimum_number_members(), get_properties(), PG_Object_Group(), and set_properties_dynamically(). |
|
|
the reference (IOGR) to this group Definition at line 321 of file PG_Object_Group.h. Referenced by add_member(), add_member_to_iogr(), create_member(), create_members(), PG_Object_Group(), and remove_member(). |
|
|
Definition at line 305 of file PG_Object_Group.h. Referenced by create_member(), create_members(), and PG_Object_Group(). |
|
|
the GroupTaggedComponent that defines this group contains: GIOP::Version component_version; TAO::String_Manager group_domain_id; PortableGroup::ObjectGroupId object_group_id; PortableGroup::ObjectGroupRefVersion object_group_ref_version; Definition at line 316 of file PG_Object_Group.h. |
|
|
Definition at line 306 of file PG_Object_Group.h. |
1.3.6