Public Types | Public Member Functions | Static Public Attributes | Private Member Functions | Private Attributes
ros::TransportTCP Class Reference

TCPROS transport. More...

#include <transport_tcp.h>

Inheritance diagram for ros::TransportTCP:
Inheritance graph
[legend]

List of all members.

Public Types

typedef boost::function< void(const
TransportTCPPtr &)> 
AcceptCallback
enum  Flags { SYNCHRONOUS = 1<<0 }

Public Member Functions

TransportTCPPtr accept ()
 Accept a connection on a server socket. Blocks until a connection is available.
virtual void close ()
 Close this transport. Once this call has returned, writing on this transport should always return an error.
bool connect (const std::string &host, int port)
 Connect to a remote host.
virtual void disableRead ()
 Disable reading on this transport. Allows derived classes to, for example, disable read polling for asynchronous sockets.
virtual void disableWrite ()
 Disable writing on this transport. Allows derived classes to, for example, disable write polling for asynchronous sockets.
virtual void enableRead ()
 Enable reading on this transport. Allows derived classes to, for example, enable read polling for asynchronous sockets.
virtual void enableWrite ()
 Enable writing on this transport. Allows derived classes to, for example, enable write polling for asynchronous sockets.
std::string getClientURI ()
 Returns the URI of the remote host.
const std::string & getConnectedHost ()
int getConnectedPort ()
int getServerPort ()
 Returns the port this transport is listening on.
virtual std::string getTransportInfo ()
 Returns a string description of both the type of transport and who the transport is connected to.
virtual const char * getType ()
 Return a string that details the type of transport (Eg. TCPROS)
bool listen (int port, int backlog, const AcceptCallback &accept_cb)
 Start a server socket and listen on a port.
virtual void parseHeader (const Header &header)
 Provides an opportunity for transport-specific options to come in through the header.
virtual int32_t read (uint8_t *buffer, uint32_t size)
 Read a number of bytes into the supplied buffer. Not guaranteed to actually read that number of bytes.
void setKeepAlive (bool use, uint32_t idle, uint32_t interval, uint32_t count)
void setNoDelay (bool nodelay)
 TransportTCP (PollSet *poll_set, int flags=0)
virtual int32_t write (uint8_t *buffer, uint32_t size)
 Write a number of bytes from the supplied buffer. Not guaranteed to actually write that number of bytes.
virtual ~TransportTCP ()

Static Public Attributes

static bool s_use_keepalive_ = true

Private Member Functions

bool initializeSocket ()
 Initializes the assigned socket -- sets it to non-blocking and enables reading.
bool setNonBlocking ()
bool setSocket (int sock)
 Set the socket to be used by this transport.
void socketUpdate (int events)

Private Attributes

AcceptCallback accept_cb_
std::string cached_remote_host_
boost::recursive_mutex close_mutex_
bool closed_
std::string connected_host_
int connected_port_
bool expecting_read_
bool expecting_write_
int flags_
bool is_server_
PollSetpoll_set_
sockaddr_in server_address_
int server_port_
socket_fd_t sock_

Detailed Description

TCPROS transport.

Definition at line 56 of file transport_tcp.h.


Member Typedef Documentation

typedef boost::function<void(const TransportTCPPtr&)> ros::TransportTCP::AcceptCallback

Definition at line 83 of file transport_tcp.h.


Member Enumeration Documentation

Enumerator:
SYNCHRONOUS 

Definition at line 62 of file transport_tcp.h.


Constructor & Destructor Documentation

ros::TransportTCP::TransportTCP ( PollSet poll_set,
int  flags = 0 
)

Definition at line 50 of file transport_tcp.cpp.

Definition at line 63 of file transport_tcp.cpp.


Member Function Documentation

TransportTCPPtr ros::TransportTCP::accept ( )

Accept a connection on a server socket. Blocks until a connection is available.

Definition at line 528 of file transport_tcp.cpp.

void ros::TransportTCP::close ( ) [virtual]

Close this transport. Once this call has returned, writing on this transport should always return an error.

Implements ros::Transport.

Definition at line 334 of file transport_tcp.cpp.

bool ros::TransportTCP::connect ( const std::string &  host,
int  port 
)

Connect to a remote host.

Parameters:
hostThe hostname/IP to connect to
portThe port to connect to
Returns:
Whether or not the connection was successful

Definition at line 195 of file transport_tcp.cpp.

void ros::TransportTCP::disableRead ( ) [virtual]

Disable reading on this transport. Allows derived classes to, for example, disable read polling for asynchronous sockets.

Implements ros::Transport.

Definition at line 468 of file transport_tcp.cpp.

void ros::TransportTCP::disableWrite ( ) [virtual]

Disable writing on this transport. Allows derived classes to, for example, disable write polling for asynchronous sockets.

Implements ros::Transport.

Definition at line 508 of file transport_tcp.cpp.

void ros::TransportTCP::enableRead ( ) [virtual]

Enable reading on this transport. Allows derived classes to, for example, enable read polling for asynchronous sockets.

Implements ros::Transport.

Definition at line 448 of file transport_tcp.cpp.

void ros::TransportTCP::enableWrite ( ) [virtual]

Enable writing on this transport. Allows derived classes to, for example, enable write polling for asynchronous sockets.

Implements ros::Transport.

Definition at line 488 of file transport_tcp.cpp.

Returns the URI of the remote host.

Definition at line 641 of file transport_tcp.cpp.

const std::string& ros::TransportTCP::getConnectedHost ( ) [inline]

Definition at line 103 of file transport_tcp.h.

Definition at line 104 of file transport_tcp.h.

Returns the port this transport is listening on.

Definition at line 98 of file transport_tcp.h.

std::string ros::TransportTCP::getTransportInfo ( ) [virtual]

Returns a string description of both the type of transport and who the transport is connected to.

Implements ros::Transport.

Definition at line 636 of file transport_tcp.cpp.

virtual const char* ros::TransportTCP::getType ( ) [inline, virtual]

Return a string that details the type of transport (Eg. TCPROS)

Returns:
The stringified transport type

Implements ros::Transport.

Definition at line 121 of file transport_tcp.h.

Initializes the assigned socket -- sets it to non-blocking and enables reading.

Definition at line 89 of file transport_tcp.cpp.

bool ros::TransportTCP::listen ( int  port,
int  backlog,
const AcceptCallback accept_cb 
)

Start a server socket and listen on a port.

Parameters:
portThe port to listen on
backlogdefines the maximum length for the queue of pending connections. Identical to the backlog parameter to the ::listen function
accept_cbThe function to call when a client socket has connected

Definition at line 294 of file transport_tcp.cpp.

void ros::TransportTCP::parseHeader ( const Header header) [virtual]

Provides an opportunity for transport-specific options to come in through the header.

Reimplemented from ros::Transport.

Definition at line 134 of file transport_tcp.cpp.

int32_t ros::TransportTCP::read ( uint8_t *  buffer,
uint32_t  size 
) [virtual]

Read a number of bytes into the supplied buffer. Not guaranteed to actually read that number of bytes.

Parameters:
bufferBuffer to read from
sizeSize, in bytes, to read
Returns:
The number of bytes actually read, or -1 if there was an error

Implements ros::Transport.

Definition at line 380 of file transport_tcp.cpp.

void ros::TransportTCP::setKeepAlive ( bool  use,
uint32_t  idle,
uint32_t  interval,
uint32_t  count 
)

Definition at line 154 of file transport_tcp.cpp.

void ros::TransportTCP::setNoDelay ( bool  nodelay)

Definition at line 144 of file transport_tcp.cpp.

Definition at line 74 of file transport_tcp.cpp.

bool ros::TransportTCP::setSocket ( int  sock) [private]

Set the socket to be used by this transport.

Parameters:
sockA valid TCP socket
Returns:
Whether setting the socket was successful

Definition at line 68 of file transport_tcp.cpp.

void ros::TransportTCP::socketUpdate ( int  events) [private]

Definition at line 555 of file transport_tcp.cpp.

int32_t ros::TransportTCP::write ( uint8_t *  buffer,
uint32_t  size 
) [virtual]

Write a number of bytes from the supplied buffer. Not guaranteed to actually write that number of bytes.

Parameters:
bufferBuffer to write from
sizeSize, in bytes, to write
Returns:
The number of bytes actually written, or -1 if there was an error

Implements ros::Transport.

Definition at line 417 of file transport_tcp.cpp.


Member Data Documentation

Definition at line 150 of file transport_tcp.h.

Definition at line 152 of file transport_tcp.h.

boost::recursive_mutex ros::TransportTCP::close_mutex_ [private]

Definition at line 142 of file transport_tcp.h.

Definition at line 141 of file transport_tcp.h.

std::string ros::TransportTCP::connected_host_ [private]

Definition at line 157 of file transport_tcp.h.

Definition at line 158 of file transport_tcp.h.

Definition at line 144 of file transport_tcp.h.

Definition at line 145 of file transport_tcp.h.

Definition at line 155 of file transport_tcp.h.

Definition at line 147 of file transport_tcp.h.

Definition at line 154 of file transport_tcp.h.

Definition at line 59 of file transport_tcp.h.

sockaddr_in ros::TransportTCP::server_address_ [private]

Definition at line 148 of file transport_tcp.h.

Definition at line 149 of file transport_tcp.h.

socket_fd_t ros::TransportTCP::sock_ [private]

Definition at line 140 of file transport_tcp.h.


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


roscpp
Author(s): Morgan Quigley mquigley@cs.stanford.edu, Josh Faust jfaust@willowgarage.com, Brian Gerkey gerkey@willowgarage.com, Troy Straszheim straszheim@willowgarage.com
autogenerated on Sat Dec 28 2013 17:35:53