OpenDDS::DCPS::TransportClient::PendingAssoc Struct Reference

Inheritance diagram for OpenDDS::DCPS::TransportClient::PendingAssoc:

Collaboration diagram for OpenDDS::DCPS::TransportClient::PendingAssoc:

Public Member Functions
	PendingAssoc ()
bool	initiate_connect (TransportClient *tc, Guard &guard)
int	handle_timeout (const ACE_Time_Value &time, const void *arg)
Public Attributes
bool	active_
bool	removed_
ImplsType	impls_
CORBA::ULong	blob_index_
AssociationData	data_
TransportImpl::ConnectionAttribs	attribs_

Detailed Description

Definition at line 171 of file TransportClient.h.

Constructor & Destructor Documentation

OpenDDS::DCPS::TransportClient::PendingAssoc::PendingAssoc ( ) [inline]

Definition at line 178 of file TransportClient.h.

00179       : active_(false)
00180       , removed_(false)
00181       , blob_index_(0)
00182     {}

Member Function Documentation

int OpenDDS::DCPS::TransportClient::PendingAssoc::handle_timeout	(	const ACE_Time_Value &	time,
		const void *	arg
	)			`[virtual]`

Reimplemented from ACE_Event_Handler.

Definition at line 299 of file TransportClient.cpp.

References data_, OpenDDS::DCPS::AssociationData::remote_id_, and OpenDDS::DCPS::TransportClient::use_datalink().

00301 {
00302   TransportClient* tc = static_cast<TransportClient*>(const_cast<void*>(arg));
00303 
00304   tc->use_datalink(data_.remote_id_, DataLink_rch());
00305 
00306   return 0;
00307 }

Here is the call graph for this function:

bool OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect	(	TransportClient *	tc,
		Guard &	guard
	)

Definition at line 361 of file TransportClient.cpp.

References ACE_TEXT(), attribs_, blob_index_, data_, impls_, OpenDDS::DCPS::TransportClient::initiate_connect_i(), OpenDDS::DCPS::RcHandle< T >::is_nil(), OpenDDS::DCPS::TransportImpl::AcceptConnectResult::link_, LM_DEBUG, OPENDDS_STRING, OpenDDS::DCPS::AssociationData::publication_transport_priority_, OpenDDS::DCPS::AssociationData::remote_data_, OpenDDS::DCPS::AssociationData::remote_durable_, OpenDDS::DCPS::AssociationData::remote_id_, OpenDDS::DCPS::AssociationData::remote_reliable_, OpenDDS::DCPS::TransportClient::repo_id_, OpenDDS::DCPS::TransportImpl::AcceptConnectResult::success_, OpenDDS::DCPS::TransportImpl::transport_type(), OpenDDS::DCPS::TransportClient::use_datalink_i(), and VDBG_LVL.

00364 00365 00366 00367 00368 00369 00370 00371 00372 00373 00374 00375 00376 00377 00378 00379 00380 00381 00382 00383 00384 00385 00386 00387 00388 00389 00390 00391 00392 00393 00394 00395 00396           } 00397 00398 00399 00400 00401 00402 00403         } 00404 00405 00406 00407 00408 00409 00410 00411 00412 00413 00414 00415 00416 00417 00418 00419           } 00420 00421 00422 00423 00424 00425 00426 00427 00428 00429         } 00430       } 00431     } 00432 00433 00434 00435   } 00436 00437 00438 }

class="fragment">00363 { GuidConverter local(tc->repo_id_); GuidConverter remote(data_.remote_id_); VDBG_LVL((LM_DEBUG, "(%P|%t) PendingAssoc::initiate_connect - " "between %C and remote %C\n", OPENDDS_STRING(local).c_str(), OPENDDS_STRING(remote).c_str()), 0); // find the next impl / blob entry that have matching types while (!impls_.empty()) { TransportImpl* impl = impls_.back(); const OPENDDS_STRING type = impl->transport_type(); for (; blob_index_ < data_.remote_data_.length(); ++blob_index_) { if (data_.remote_data_[blob_index_].transport_type.in() == type) { const TransportImpl::RemoteTransport remote = { data_.remote_id_, data_.remote_data_[blob_index_].data, data_.publication_transport_priority_, data_.remote_reliable_, data_.remote_durable_}; TransportImpl::AcceptConnectResult res; GuidConverter tmp_local(tc->repo_id_); GuidConverter tmp_remote(data_.remote_id_); if (!tc->initiate_connect_i(res, impl, remote, attribs_, guard)) { //tc init connect returned false there is no PendingAssoc left in map because use_datalink_i finished elsewhere //so don't do anything further with pend and return success or failure up to tc's associate if (res.success_ ) { GuidConverter local(tc->repo_id_); GuidConverter remote(data_.remote_id_); VDBG_LVL((LM_DEBUG, ACE_TEXT("(%P|%t) PendingAssoc::initiate_connect - ") ACE_TEXT("between %C and remote %C success\n"), OPENDDS_STRING(local).c_str(), OPENDDS_STRING(remote).c_str()), 0); return true; VDBG_LVL((LM_DEBUG, "(%P|%t) PendingAssoc::initiate_connect - " "between %C and remote %C unsuccessful\n", OPENDDS_STRING(tmp_local).c_str(), OPENDDS_STRING(tmp_remote).c_str()), 0); break; if (res.success_) { ++blob_index_; if (!res.link_.is_nil()) { tc->use_datalink_i(data_.remote_id_, res.link_, guard); } else { GuidConverter local(tc->repo_id_); GuidConverter remote(data_.remote_id_); VDBG_LVL((LM_DEBUG, "(%P|%t) PendingAssoc::intiate_connect - " "resulting link from initiate_connect_i (local: %C to remote: %C) was nil\n", OPENDDS_STRING(local).c_str(), OPENDDS_STRING(remote).c_str()), 0); return true; } else { GuidConverter local(tc->repo_id_); GuidConverter remote(data_.remote_id_); VDBG_LVL((LM_DEBUG, "(%P|%t) PendingAssoc::intiate_connect - " "result of initiate_connect_i (local: %C to remote: %C) was not success \n", OPENDDS_STRING(local).c_str(), OPENDDS_STRING(remote).c_str()), 0); impls_.pop_back(); blob_index_ = 0; return false;

Here is the call graph for this function: