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

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

[legend]Collaboration diagram for OpenDDS::DCPS::TransportClient::PendingAssoc:

[legend]List of all members.

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 167 of file TransportClient.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::TransportClient::PendingAssoc::PendingAssoc

(

)

[inline]

Definition at line 174 of file TransportClient.h.

      : active_(false), removed_(false), blob_index_(0)
    {}

---

Member Function Documentation

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

Definition at line 384 of file TransportClient.cpp.

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

{
  TransportClient* tc = static_cast<TransportClient*>(const_cast<void*>(arg));

  tc->use_datalink(data_.remote_id_, 0);

  return 0;
}

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

Definition at line 477 of file TransportClient.cpp.

References attribs_, blob_index_, data_, impls_, OpenDDS::DCPS::TransportClient::initiate_connect_i(), OpenDDS::DCPS::RcHandle< T >::is_nil(), OpenDDS::DCPS::TransportImpl::AcceptConnectResult::link_, 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::TransportClient::use_datalink_i(), and VDBG_LVL.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

{
  GuidConverter local(tc->repo_id_);
  GuidConverter remote(this->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()) {
    const TransportImpl_rch& 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(this->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_ && !this->removed_) {
            GuidConverter local(tc->repo_id_);
            GuidConverter remote(this->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);
          return false;
        }

        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(this->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(this->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;
}

---

Member Data Documentation

bool OpenDDS::DCPS::TransportClient::PendingAssoc::active_

Definition at line 168 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

TransportImpl::ConnectionAttribs OpenDDS::DCPS::TransportClient::PendingAssoc::attribs_

Definition at line 172 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and initiate_connect().

CORBA::ULong OpenDDS::DCPS::TransportClient::PendingAssoc::blob_index_

Definition at line 170 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and initiate_connect().

AssociationData OpenDDS::DCPS::TransportClient::PendingAssoc::data_

Definition at line 171 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), handle_timeout(), initiate_connect(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

ImplsType OpenDDS::DCPS::TransportClient::PendingAssoc::impls_

Definition at line 169 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), initiate_connect(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

bool OpenDDS::DCPS::TransportClient::PendingAssoc::removed_

Definition at line 168 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::use_datalink_i().

---

The documentation for this struct was generated from the following files:

• TransportClient.h
• TransportClient.cpp

---