---

vpr::sim::SocketManager Class Reference

Abstraction for C-style sockets. More...

#include <SocketManager.h>

Collaboration diagram for vpr::sim::SocketManager:

[legend]List of all members.

Public Methods
	SocketManager (void)
void	setActive (void)
vpr::ReturnStatus	connect (vpr::SocketImplSIM *localSock, const vpr::InetAddrSIM &remoteName, NetworkGraph::VertexListPtr &path, vpr::Interval timeout)
	If the socket is of type SOCK_STREAM, then this call attempts to make a connection to another socket. More...
vpr::ReturnStatus	bind (vpr::SocketImplSIM *handle)
	Bind ties the given adddress to the given socket. More...
vpr::ReturnStatus	unbind (vpr::SocketImplSIM *handle)
	Unbinds the given socket from its registered address. More...
vpr::ReturnStatus	listen (vpr::SocketStreamImplSIM *handle, const int backlog=5)
	Sets a socket s to listen for connections. More...
void	findRoute (vpr::SocketImplSIM *src_sock, vpr::SocketImplSIM *dest_sock)
void	sendMessage (vpr::sim::MessagePtr msg)
	Puts the given message on its way to its destination. More...
void	sendMessageTo (vpr::sim::MessagePtr msg, const vpr::SocketImplSIM *src_sock, const vpr::InetAddrSIM &dest_addr)
	Defines the path from the source socket to the destination address for the given message. More...
bool	isListening (const vpr::InetAddrSIM &address)
	Is there someone listening on the address? More...
Protected Types
typedef std::map< vpr::InetAddr, vpr::SocketStreamImplSIM * >	listener_map_t
typedef std::map< vpr::Uint32, vpr::sim::NetworkNodePtr >	node_map_t
Protected Methods
vpr::ReturnStatus	assignToNode (vpr::SocketImplSIM *handle)
	Assign the given socket to a node on the actual network This is based on the following address scheme for assignment. More...
vpr::ReturnStatus	unassignFromNode (vpr::SocketImplSIM *handle)
	Unassigns the socket from the node that it is bound to This is basically the opposite of assignToNode (and unbind if you will). More...
vpr::ReturnStatus	ensureNetworkNodeIsRegistered (const vpr::Uint32 &ipAddr)
	Make sure that the local data structures know about the node at the given address. More...
	SocketManager (const SocketManager &o)
	Get the ip address value for the "localhost" node that we are using. More...
void	operator= (const SocketManager &o)
Protected Attributes
bool	mActive
listener_map_t	mListenerList
	This is a list of sockets that have gone into a listening state Used to track which sockets are currently in a listening state XXX: Could move this into the actually socket as a socket state instead. More...
vpr::Mutex	mListenerListMutex
node_map_t	mNetworkNodes
	The nodes in the managed network. More...
vpr::Mutex	mNetworkNodesMutex

---

Detailed Description

Abstraction for C-style sockets.

This is used by Plexus sim sockets, and in the overall sim socket scheme, this sits at the operating system level. This roughly corresponds to the data link or transport layer.

It provides a way to bind address and send messages.

Definition at line 87 of file SocketManager.h.

---

Member Typedef Documentation

typedef std::map<vpr::InetAddr, vpr::SocketStreamImplSIM* > vpr::sim::SocketManager::listener_map_t [protected]

Definition at line 246 of file SocketManager.h.

typedef std::map<vpr::Uint32, vpr::sim::NetworkNodePtr> vpr::sim::SocketManager::node_map_t [protected]

Definition at line 247 of file SocketManager.h.

---

Constructor & Destructor Documentation

vpr::sim::SocketManager::SocketManager (  void    )  [inline]

Definition at line 90 of file SocketManager.h. : mActive(false) { /* Do nothing. */ ; }

vpr::sim::SocketManager::SocketManager (  const SocketManager &    o )  [inline, protected]

Get the ip address value for the "localhost" node that we are using. Definition at line 237 of file SocketManager.h. {;}

---

Member Function Documentation

void vpr::sim::SocketManager::setActive (  void    )  [inline]

Definition at line 95 of file SocketManager.h. Referenced by vpr::sim::Controller::constructNetwork. { mActive = true; }

vpr::ReturnStatus vpr::sim::SocketManager::connect (  vpr::SocketImplSIM *    localSock, const vpr::InetAddrSIM &    remoteName, NetworkGraph::VertexListPtr &    path, vpr::Interval    timeout )

If the socket is of type SOCK_STREAM, then this call attempts to make a connection to another socket. The other socket is specified by name, which is an address in the communications space of the socket. If the socket is of type SOCK_DGRAM, then this call specifies the peer with which the socket is to be associated; this address is that to which datagrams are to be sent, and the only address from which datagrams are to be received. Each communications space interprets the name parameter in its own way. Generally, stream sockets may successfully connect only once; datagram sockets may use connect multiple times to change their association. Datagram sockets may dissolve the association by connecting to an invalid address, such as a zero-filled address. Definition at line 83 of file SocketManager.cpp. References vpr::MutexPosix::acquire, vpr::sim::Controller::addConnectionEvent, vpr::SocketStreamImplSIM::addConnector, vpr::SocketImplSIM::completeConnection, vpr::ReturnStatus::Fail, vpr::ReturnStatus::failure, vpr::sim::Controller::getClock, vpr::sim::Clock::getCurrentTime, vpr::SocketImplSIM::getNetworkNode, vpr::sim::Controller::instance, vpr::SocketImplSIM::isBound, isListening, mActive, mListenerList, mListenerListMutex, vpr::SocketImplSIM::mLocalAddr, vpr::MutexPosix::release, vpr::ReturnStatus::setCode, vprASSERT, vprDBG_ALL, vprDBG_CRITICAL_LVL, vprDBG_STATE_LVL, vprDEBUG, and vprDEBUG_FLUSH. Referenced by vpr::SocketImplSIM::connect. { vprASSERT(mActive && "Socket manager not activated yet"); vprASSERT(localSock->isBound() && "Precondition is that socket is bound"); vprASSERT(localSock->mLocalAddr != vpr::InetAddr::AnyAddr && "Must be bound to an address"); vpr::ReturnStatus status; vprDEBUG(vprDBG_ALL, vprDBG_STATE_LVL) <<"connect( "<<remoteName<<" )\n"<<vprDEBUG_FLUSH; vpr::SocketStreamImplSIM* local_stream_socket; local_stream_socket = dynamic_cast<vpr::SocketStreamImplSIM*>(localSock); // If we have a vpr::SocketStreamImplSIM* object, we perform a real // simulated connection. if ( local_stream_socket != NULL ) { if ( isListening( remoteName ) ) // If remote side is accepting connections { vpr::SocketImplSIM* remote_sock; mListenerListMutex.acquire(); { vprASSERT(mListenerList.find(remoteName) != mListenerList.end()); remote_sock = (*mListenerList.find(remoteName)).second; } mListenerListMutex.release(); vpr::SocketStreamImplSIM* remote_stream_socket = dynamic_cast<vpr::SocketStreamImplSIM*>(remote_sock); vprASSERT(NULL != remote_stream_socket && "We should have a stream socket, but don't"); // Queue us up in the listening socket's connection queue. status = remote_stream_socket->addConnector(localSock); vprASSERT(!status.failure() && "Failed to add connector"); vpr::sim::Controller* controller = vpr::sim::Controller::instance(); controller->addConnectionEvent(controller->getClock().getCurrentTime(), remote_sock); } else { vprDEBUG(vprDBG_ALL, vprDBG_CRITICAL_LVL) << "vpr::sim::SocketManager: Cannot connect, no one listening on " << remoteName << std::endl << vprDEBUG_FLUSH; vprDEBUG(vprDBG_ALL, vprDBG_CRITICAL_LVL) << "--------- Listening list ---------\n" << vprDEBUG_FLUSH; for(listener_map_t::iterator i=mListenerList.begin(); i != mListenerList.end(); ++i) { vprDEBUG(vprDBG_ALL, vprDBG_CRITICAL_LVL) << (*i).second->getLocalAddr() << std::endl << vprDEBUG_FLUSH; } vprDEBUG(vprDBG_ALL, vprDBG_CRITICAL_LVL) << "---- [End] Listening list ---------\n" << vprDEBUG_FLUSH; vprASSERT(false && "Tried to connect to a non-listening node"); status.setCode(vpr::ReturnStatus::Fail); } } // We are dealing with datagram sockets. else { vpr::SocketImplSIM* remote_sock; vpr::SocketDatagramImplSIM* remote_dgram_socket; mListenerListMutex.acquire(); { vprASSERT(mListenerList.find(remoteName) != mListenerList.end()); remote_sock = (*mListenerList.find(remoteName)).second; } mListenerListMutex.release(); remote_dgram_socket = dynamic_cast<vpr::SocketDatagramImplSIM*>(remote_sock); // Ensure that we really did get a datagram socket. Basically, the // only reason dgram_socket exists is for this conditional. vprASSERT( remote_dgram_socket != NULL ); // We have to cast away the const-ness so that we can add the // connector information. localSock->completeConnection( remote_sock ); // XXX: Don't tell the other side that it is connected to us //remote_dgram_socket->completeConnection(localSock); // Now find the shortest path between u and v. const NetworkGraph::net_vertex_t& u = localSock->getNetworkNode(); const NetworkGraph::net_vertex_t& v = remote_dgram_socket->getNetworkNode(); path = vpr::sim::Controller::instance()->getNetworkGraph().getShortestPath(u, v); } vprDEBUG(vprDBG_ALL, vprDBG_STATE_LVL) << "DONE: connect()\n" << vprDEBUG_FLUSH; return status; }

vpr::ReturnStatus vpr::sim::SocketManager::bind (  vpr::SocketImplSIM *    handle )

Bind ties the given adddress to the given socket. In reality, this registers the given socket object with the simulator and makes it possible to look up the socket by its address. Assign the socket to the network somwhere Case localAddr = InetAddr::Any ==> 0x7F000001 with random port Case localAddr = Have IP and port=0 (ie. Give me a random port. I don't care) Case localAddr = Have IP and port != 0 (bind me to that exact one) Postcondition: If the binding process succeeds, the given socket is assigned a node in the network graph. Parameters: handle  The socket object to be bound (this must have it's local addr assigned already) Returns: vpr::ReturnStatus::Success is returned if the handle could be bound to the given address. vpr::ReturnStatus::Failure is returned otherwise. Definition at line 184 of file SocketManager.cpp. References assignToNode, vpr::SocketImplSIM::isBound, vpr::SocketImplSIM::isOpen, vprASSERT, vprDBG_ALL, vprDBG_STATE_LVL, vprDEBUG_BEGIN, vprDEBUG_END, and vprDEBUG_FLUSH. Referenced by vpr::SocketImplSIM::bind. { vprASSERT(handle->isOpen() && !handle->isBound() && "Against preconditions to have a handle not open or already bound"); vprDEBUG_BEGIN(vprDBG_ALL, vprDBG_STATE_LVL) << "bind(" << handle << ")\n" << vprDEBUG_FLUSH; vpr::ReturnStatus ret_stat = assignToNode(handle); vprDEBUG_END(vprDBG_ALL, vprDBG_STATE_LVL) << "bind complete\n" << vprDEBUG_FLUSH; return ret_stat; }

vpr::ReturnStatus vpr::sim::SocketManager::unbind (  vpr::SocketImplSIM *    handle )

Unbinds the given socket from its registered address. Once the socket is unbound, it should close. For sockets that are not bound, no action is taken. Postcondition: The bound address is released so another socket may bind to it. Parameters: handle  The socket object to be unbound from its registered address. Returns: vpr::ReturnStatus::Success is returned if the handle could be unbound from its local address. vpr::ReturnStatus::Failure is returned otherwise. Definition at line 196 of file SocketManager.cpp. References vpr::SocketImplSIM::getLocalAddr, vpr::SocketImplSIM::isBound, unassignFromNode, vprASSERT, vprDBG_ALL, vprDBG_STATE_LVL, vprDEBUG, and vprDEBUG_FLUSH. { vpr::ReturnStatus status; vprASSERT( handle->isBound() && "Can't unbind and unbound handle"); vprDEBUG(vprDBG_ALL, vprDBG_STATE_LVL) << "Unbinding handle (" << handle << " --> " << handle->getLocalAddr() << ")\n" << vprDEBUG_FLUSH; // -- Unassign from node status = unassignFromNode( handle ); return status; }

vpr::ReturnStatus vpr::sim::SocketManager::listen (  vpr::SocketStreamImplSIM *    handle, const int    backlog = 5 )

Sets a socket s to listen for connections. Precondition: The listen call applies only to sockets of type SOCK_STREAM. Returns: true for success, false for error Definition at line 214 of file SocketManager.cpp. References vpr::MutexPosix::acquire, vpr::SocketImplSIM::getLocalAddr, vpr::SocketImplSIM::getType, vpr::SocketImplSIM::isBound, isListening, mListenerList, mListenerListMutex, vpr::MutexPosix::release, vprASSERT, vprDBG_ALL, vprDBG_STATE_LVL, vprDEBUG, and vprDEBUG_FLUSH. { vpr::ReturnStatus status; vprDEBUG(vprDBG_ALL, vprDBG_STATE_LVL) <<"SocketManager::listen: Added listner: " << handle->getLocalAddr() << std::endl << vprDEBUG_FLUSH; vprASSERT( handle->isBound() && "Can't listen on unbound socket"); vprASSERT( handle->getType() == vpr::SocketTypes::STREAM && "Trying to listen with not stream socket"); // enter self into list for accepting connections. mListenerListMutex.acquire(); { mListenerList[handle->getLocalAddr()] = handle; } mListenerListMutex.release(); vprASSERT( isListening(handle->getLocalAddr()) && "Didn't add listener" ); return status; }

void vpr::sim::SocketManager::findRoute (  vpr::SocketImplSIM *    src_sock, vpr::SocketImplSIM *    dest_sock )

Definition at line 237 of file SocketManager.cpp. References vpr::SocketImplSIM::getNetworkNode, vpr::sim::NetworkGraph::getShortestPath, vpr::sim::Controller::instance, mActive, vpr::sim::NetworkGraph::reversePath, vpr::SocketImplSIM::setPathToPeer, and vprASSERT. Referenced by vpr::SocketStreamImplSIM::accept. { vprASSERT(mActive && "Socket manager not activated!"); const NetworkGraph::net_vertex_t& u = src_sock->getNetworkNode(); const NetworkGraph::net_vertex_t& v = dest_sock->getNetworkNode(); NetworkGraph::VertexListPtr path; vpr::sim::NetworkGraph& net_graph = vpr::sim::Controller::instance()->getNetworkGraph(); // Now find the shortest path between u and v. path = net_graph.getShortestPath(u, v); src_sock->setPathToPeer(path); dest_sock->setPathToPeer(net_graph.reversePath(path)); }

void vpr::sim::SocketManager::sendMessage (  vpr::sim::MessagePtr    msg )

Puts the given message on its way to its destination. This call should be used for "reliable" messages or messages that know where they are going. Definition at line 254 of file SocketManager.cpp. References vpr::sim::Controller::addLocalhostDeliveryEvent, vpr::sim::Controller::addMessageEvent, vpr::sim::Controller::getClock, vpr::sim::Clock::getCurrentTime, vpr::sim::NetworkGraph::getEdge, vpr::sim::NetworkGraph::getLineProperty, vpr::sim::Controller::getNetworkGraph, vpr::sim::Controller::instance, vpr::sim::NetworkGraph::isSource, mActive, vpr::Interval::now, vprASSERT, vprDBG_ALL, vprDBG_HVERB_LVL, vprDBG_STATE_LVL, vprDBG_VERB_LVL, vprDEBUG, and vprDEBUG_FLUSH. Referenced by sendMessageTo. { // There is no point in doing anything if we do not have a controller // for the simulation. vprASSERT(mActive && "Socket manager not activated yet"); vprDEBUG(vprDBG_ALL, vprDBG_HVERB_LVL) << "SocketManager::sendMessage(): Sending message from " << msg->getSourceSocket()->getLocalAddr() << " to " << msg->getDestinationSocket()->getLocalAddr() << "\n" << vprDEBUG_FLUSH; NetworkGraph::net_vertex_t first_hop(msg->getNextHop()); bool end_of_path; msg->incNextHop(end_of_path); vpr::sim::Controller* controller = vpr::sim::Controller::instance(); if ( ! end_of_path ) { NetworkGraph::net_vertex_t second_hop(msg->getNextHop()); NetworkGraph::net_edge_t first_edge; bool found; vpr::sim::NetworkGraph& net_graph = controller->getNetworkGraph(); boost::tie(first_edge, found) = net_graph.getEdge(first_hop, second_hop); if ( found ) { NetworkLine::LineDirection dir; NetworkLine& first_edge_prop = net_graph.getLineProperty(first_edge); // Determine the direction for the message on this line. dir = net_graph.isSource(first_hop, first_edge) ? NetworkLine::FORWARD : NetworkLine::REVERSE; first_edge_prop.calculateMessageEventTimes(msg, vpr::Interval::now(), dir); vprDEBUG(vprDBG_ALL, vprDBG_STATE_LVL) << "SocketManager::sendMessage(): Starting message [" << msg->getSourceSocket()->getLocalAddr() << " ==> " << msg->getDestinationSocket()->getLocalAddr() << "] on wire " << first_edge_prop.getNetworkAddressString() << ": (" << msg->whenStartOnWire().getBaseVal() << ", " << msg->whenFullyOnWire().getBaseVal() << ", " << msg->whenArrivesFully().getBaseVal() << ")\n" << vprDEBUG_FLUSH; first_edge_prop.addMessage(msg, dir); controller->addMessageEvent(msg->whenArrivesFully(), first_edge, dir); } } // This is a loopback, so we can just deliver the message without going // through the network. else { vprASSERT(msg->getSourceSocket()->getLocalAddr().getAddressValue() == msg->getDestinationSocket()->getLocalAddr().getAddressValue() && "Could not get second node in message's path"); vprDEBUG(vprDBG_ALL, vprDBG_VERB_LVL) << "SocketManager::sendMessage(): Loopback--delivering to " << msg->getDestinationSocket()->getLocalAddr() << "(" << msg->getDestinationSocket() << ") immediately\n" << vprDEBUG_FLUSH; msg->getDestinationSocket()->addArrivedMessage(msg); controller->addLocalhostDeliveryEvent(controller->getClock().getCurrentTime(), msg->getDestinationSocket()); } }

void vpr::sim::SocketManager::sendMessageTo (  vpr::sim::MessagePtr    msg, const vpr::SocketImplSIM *    src_sock, const vpr::InetAddrSIM &    dest_addr )

Defines the path from the source socket to the destination address for the given message. This call should be used for "unreliable" messages only. For example, the given destination address may be unreachable, and thus the message will not be delivered. Definition at line 325 of file SocketManager.cpp. References vpr::InetAddrSIM::getAddressValue, vpr::SocketImplSIM::getNetworkNode, vpr::sim::NetworkGraph::getNodeProperty, vpr::sim::NetworkGraph::getNodeWithAddr, vpr::InetAddrSIM::getPort, vpr::sim::NetworkGraph::getShortestPath, vpr::SocketImplSIM::getType, vpr::sim::Controller::instance, vpr::SocketImplSIM::isBound, vpr::sim::NetworkNodePtr, sendMessage, vpr::ReturnStatus::success, and vprASSERT. Referenced by vpr::SocketDatagramImplSIM::sendto. { vprASSERT(src_sock->getType() == vpr::SocketTypes::DATAGRAM && "Only datagram sockets may use sendMessageTo()"); vpr::ReturnStatus status; NetworkGraph::net_vertex_t dest_node; vpr::sim::NetworkGraph& net_graph = vpr::sim::Controller::instance()->getNetworkGraph(); status = net_graph.getNodeWithAddr(dest_addr.getAddressValue(), dest_node); if ( status.success() ) { NetworkNodePtr dest_node_prop; dest_node_prop = net_graph.getNodeProperty(dest_node); if ( dest_node_prop->hasSocket(dest_addr.getPort(), vpr::SocketTypes::DATAGRAM) ) { vpr::SocketImplSIM* peer; NetworkGraph::VertexListPtr path; peer = dest_node_prop->getSocket( dest_addr.getPort(), vpr::SocketTypes::DATAGRAM); vprASSERT(src_sock->isBound() && "Trying to send from socket not bound."); path = net_graph.getShortestPath(src_sock->getNetworkNode(), dest_node); msg->setPath(path, src_sock, peer); // At this point, the message is ready to go, so we can send it in // the same manner as a "reliable" message. sendMessage(msg); } } }

bool vpr::sim::SocketManager::isListening (  const vpr::InetAddrSIM &    address )

Is there someone listening on the address? Definition at line 364 of file SocketManager.cpp. References vpr::MutexPosix::acquire, mListenerList, mListenerListMutex, and vpr::MutexPosix::release. Referenced by connect, and listen. { bool status; mListenerListMutex.acquire(); { status = (mListenerList.find( address) != mListenerList.end()); } mListenerListMutex.release(); return status; }

vpr::ReturnStatus vpr::sim::SocketManager::assignToNode (  vpr::SocketImplSIM *    handle )  [protected]

Assign the given socket to a node on the actual network This is based on the following address scheme for assignment. Assign the socket to the network somwhere Case localAddr = InetAddr::Any ==> 0x7F000001 with random port Case localAddr = Have IP and port=0 (ie. Give me a random port. I don't care) Case localAddr = Have IP and port != 0 (bind me to that exact one) Definition at line 383 of file SocketManager.cpp. References ensureNetworkNodeIsRegistered, vpr::InetAddrSIM::getAddressValue, vpr::SocketImplSIM::getLocalAddr, vpr::InetAddrSIM::getPort, vpr::SocketImplSIM::getType, vpr::sim::LocalHostIpAddrValue, mNetworkNodes, vpr::sim::NetworkNodePtr, vpr::InetAddrSIM::setAddress, vpr::SocketImplSIM::setLocalAddr, vpr::SocketImplSIM::setNetworkNode, vpr::InetAddrSIM::setPort, vpr::ReturnStatus::success, vprASSERT, vprDBG_ALL, vprDBG_STATE_LVL, vprDEBUG, and vprDEBUG_FLUSH. Referenced by bind. { vpr::ReturnStatus status; NetworkGraph net_graph = Controller::instance()->getNetworkGraph(); // --- Get the local address setup correctly --- // vpr::InetAddrSIM local_addr; local_addr = handle->getLocalAddr(); // If any addr, then set it to local host // Case localAddr = InetAddr::Any ==> "localhost" with random port if(local_addr == vpr::InetAddr::AnyAddr ) { local_addr.setAddress(LocalHostIpAddrValue, 0); } // Make sure that we know about the node of the given address ensureNetworkNodeIsRegistered(local_addr.getAddressValue() ); vprASSERT( mNetworkNodes.find(local_addr.getAddressValue()) != mNetworkNodes.end()); // --- Bind the socket to an actual node in the graph -- // // - Get the node // - Register this socket with that node NetworkNodePtr net_node = mNetworkNodes[local_addr.getAddressValue()]; // - Deal with port assignment issues // Case localAddr = Have IP and port=0 (ie. Give me a random port. I don't care) // Case localAddr = Have IP and port != 0 (bind me to that exact one) if(local_addr.getPort() == 0) { vpr::Uint32 port_num; if(handle->getType() == vpr::SocketTypes::STREAM) { port_num = net_node->getUnassignedTcpPortNumber(); } else { port_num = net_node->getUnassignedUdpPortNumber(); } local_addr.setPort(port_num); } // Set the final local address and add the socket to the node handle->setLocalAddr(local_addr); net_node->addSocket( handle ); // Store the network node vertex in the socket for fast access NetworkGraph::net_vertex_t node_vertex; status = net_graph.getNodeWithAddr(local_addr.getAddressValue(), node_vertex); vprASSERT(status.success()); handle->setNetworkNode( node_vertex ); vprDEBUG(vprDBG_ALL, vprDBG_STATE_LVL) << "SocketManager::assignToNode(): Assigned node: local_addr:" << local_addr << " type: " << ((handle->getType()==vpr::SocketTypes::STREAM) ? "STREAM" : "DATAGRAM") << " --> node: " << net_node->getIpAddressString() << std::endl << vprDEBUG_FLUSH; return status; }

vpr::ReturnStatus vpr::sim::SocketManager::unassignFromNode (  vpr::SocketImplSIM *    handle )  [protected]

Unassigns the socket from the node that it is bound to This is basically the opposite of assignToNode (and unbind if you will). Definition at line 439 of file SocketManager.cpp. References vpr::InetAddrSIM::getAddressValue, vpr::SocketImplSIM::getLocalAddr, mNetworkNodes, vpr::sim::NetworkNodePtr, vpr::ReturnStatus::success, and vprASSERT. Referenced by unbind. { vpr::ReturnStatus status; vpr::InetAddrSIM local_addr = handle->getLocalAddr(); vprASSERT( mNetworkNodes.find(local_addr.getAddressValue()) != mNetworkNodes.end()); // Get the network node NetworkNodePtr net_node = mNetworkNodes[local_addr.getAddressValue()]; // Remove the socket from the node status = net_node->removeSocket( handle ); vprASSERT(status.success()); return status; }

vpr::ReturnStatus vpr::sim::SocketManager::ensureNetworkNodeIsRegistered (  const vpr::Uint32 &    ipAddr )  [protected]

Make sure that the local data structures know about the node at the given address. Precondition: addr is a valid address in the network Returns: success completed successfully Definition at line 455 of file SocketManager.cpp. References mNetworkNodes, vpr::sim::NetworkNodePtr, vpr::ReturnStatus::Succeed, vpr::ReturnStatus::success, and vprASSERT. Referenced by assignToNode. { vpr::ReturnStatus ret_stat(vpr::ReturnStatus::Succeed); if( mNetworkNodes.find(ipAddr) == mNetworkNodes.end()) // If not registered yet { NetworkGraph::net_vertex_t node_vertex; NetworkGraph net_graph = Controller::instance()->getNetworkGraph(); ret_stat = net_graph.getNodeWithAddr(ipAddr, node_vertex); vprASSERT(ret_stat.success() && "Specified IP address does not actually exist in the sim net graph."); NetworkNodePtr node_prop = net_graph.getNodeProperty(node_vertex); vprASSERT(node_prop.get() != NULL); mNetworkNodes.insert( std::pair<node_map_t::key_type, node_map_t::data_type>(ipAddr, node_prop) ); } return ret_stat; }

void vpr::sim::SocketManager::operator= (  const SocketManager &    o )  [inline, protected]

Definition at line 238 of file SocketManager.h. {;}

---

Member Data Documentation

bool vpr::sim::SocketManager::mActive [protected]

Definition at line 240 of file SocketManager.h. Referenced by connect, findRoute, and sendMessage.

listener_map_t vpr::sim::SocketManager::mListenerList [protected]

This is a list of sockets that have gone into a listening state Used to track which sockets are currently in a listening state XXX: Could move this into the actually socket as a socket state instead. Definition at line 254 of file SocketManager.h. Referenced by connect, isListening, and listen.

vpr::Mutex vpr::sim::SocketManager::mListenerListMutex [protected]

Definition at line 255 of file SocketManager.h. Referenced by connect, isListening, and listen.

node_map_t vpr::sim::SocketManager::mNetworkNodes [protected]

The nodes in the managed network. Definition at line 261 of file SocketManager.h. Referenced by assignToNode, ensureNetworkNodeIsRegistered, and unassignFromNode.

vpr::Mutex vpr::sim::SocketManager::mNetworkNodesMutex [protected]

Definition at line 262 of file SocketManager.h.

---

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

• SocketManager.h
• SocketManager.cpp

---