gadget::Connector Class Reference

Simple connector type. More...

#include <gadget/Connector.h>

List of all members.

Public Member Functions
	Connector ()
virtual	~Connector ()
vpr::ReturnStatus	attemptConnect (Node *node)
	Attempt to connect to the given node.

---

Detailed Description

Simple connector type.

Definition at line 51 of file Connector.h.

---

Constructor & Destructor Documentation

gadget::Connector::Connector

(

)

[inline]

Definition at line 62 of file Connector.h.

   {;}

virtual gadget::Connector::~Connector

(

)

[inline, virtual]

Definition at line 64 of file Connector.h.

   {;}

---

Member Function Documentation

vpr::ReturnStatus gadget::Connector::attemptConnect

(

Node *

node

)

Attempt to connect to the given node.

Definition at line 46 of file Connector.cpp.

References gadgetDBG_NET_MGR(), cluster::ConnectionAck::getAck(), gadget::Node::getHostname(), gadget::Node::getName(), gadget::Node::getPort(), gadget::Node::getSockStream(), gadget::Node::getStatus(), gadget::Node::NEWCONNECTION, gadget::Node::PENDING, cluster::ConnectionAck::printData(), gadget::Node::recvPacket(), gadget::Node::setSockStream(), and gadget::Node::setStatus().

{
   // - Try to connect to remote host
   // - If successful
   //
   //   - Lock pending list
   //     - If hostname exists in pending list
   //       - Remove Node from pending list
   //   - Unlock pending list
   //
   //   - If Node not connected
   //     - Set socket stream
   //     - Set NEWCONNECTION
   
   vprASSERT( Node::PENDING == node->getStatus() &&
              "Can not connect to a node that is not pending." );

   vpr::SocketStream* sock_stream;
   vpr::InetAddr inet_addr;

   vprDEBUG( gadgetDBG_NET_MGR, vprDBG_VERB_LVL )
      << clrOutBOLD( clrBLUE, "[Connector]" )
      << " Attempting to connect to: " << node->getName()
      << std::endl << vprDEBUG_FLUSH;
      
   // Set the address that we want to connect to
   if ( !inet_addr.setAddress( node->getHostname(), node->getPort() ).success() )
   {
      vprDEBUG( gadgetDBG_NET_MGR, vprDBG_CRITICAL_LVL )
         << clrOutBOLD( clrBLUE, "[Connector]" )
         << clrOutBOLD( clrRED, " ERROR:" )
         << " Failed to set address" << std::endl << vprDEBUG_FLUSH;
      return vpr::ReturnStatus::Fail;
   }

   // Create a new socket stream to this address
   sock_stream = new vpr::SocketStream( vpr::InetAddr::AnyAddr, inet_addr );

   // If we can successfully open the socket and connect to the server
   if ( sock_stream->open().success() &&
        sock_stream->connect().success() )
   {
      vprDEBUG( gadgetDBG_NET_MGR, vprDBG_CONFIG_STATUS_LVL )
         << clrOutBOLD( clrBLUE, "[Connector]" )
         << " Successfully connected to: "
         << node->getHostname() <<":"<< node->getPort()
         << std::endl << vprDEBUG_FLUSH;
         
      sock_stream->setNoDelay( true );
      vpr::SocketStream* old_stream = node->getSockStream();
      node->setSockStream( sock_stream );

      vprDEBUG( gadgetDBG_NET_MGR, vprDBG_CONFIG_STATUS_LVL )
         << clrOutBOLD( clrBLUE, "[Connector]" )
         << " Waiting for connection ACK/NACK"
         << std::endl << vprDEBUG_FLUSH;
      
      cluster::Packet* temp_packet = node->recvPacket();
      cluster::ConnectionAck* ack_packet = dynamic_cast<cluster::ConnectionAck*>( temp_packet );
      node->setSockStream( old_stream );

      vprDEBUG( gadgetDBG_NET_MGR, vprDBG_CONFIG_STATUS_LVL )
         << clrOutBOLD( clrBLUE,"[Connector]" )
         << " Recieved" << ( ack_packet->getAck() ? " an Ack" : " a NACK" )
         << std::endl << vprDEBUG_FLUSH;
     
      vprASSERT( NULL != ack_packet && "Dynamic cast failed, must not be a ConnectionAck packet." );
      
      ack_packet->printData( vprDBG_CONFIG_STATUS_LVL );
      
      if ( ack_packet->getAck() )
      {
         //   - Lock pending list
         //     - If hostname exists in pending list
         //       - Remove Node from pending list
         //   - Unlock pending list
      
         vprASSERT( Node::PENDING == node->getStatus() && "Trying to connect to a node that is not pending" );
         node->setStatus( Node::NEWCONNECTION );

         //   - If Node not connected
         //     - Set socket stream
         //     - Set NEWCONNECTION

         vprASSERT( Node::NEWCONNECTION == node->getStatus() && "Should be NEWCONNECTION." );
         
         node->setSockStream( sock_stream );
         node->setStatus( Node::NEWCONNECTION );

         // XXX: We need to fix this in the near future.
         //ClusterDelta cluster_delta;
         //vpr::Interval temp;
         //temp = cluster_delta.getClusterDelta( getSockStream() );
         //mDelta = temp.getBaseVal();
      }
      else
      {
         node->setSockStream( NULL );
         delete sock_stream; 
         return vpr::ReturnStatus::Fail;
      }
   }
   else
   {
      delete sock_stream;
      
      vprDEBUG( gadgetDBG_NET_MGR, vprDBG_VERB_LVL )
         << clrOutBOLD( clrBLUE, "[Connector]" )
         << clrOutBOLD( clrRED, " ERROR:" )
         << " Could not connect to Node: "
         << node->getHostname() << " : " << node->getPort()
         << std::endl << vprDEBUG_FLUSH;
         
      return vpr::ReturnStatus::Fail;
   }
   
   return vpr::ReturnStatus::Succeed;
}

---

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

• Connector.h
• Connector.cpp

---