An implementation of a stream socket using TCP. More...

#include <tcp-tahoe.h>

Inheritance diagram for ns3::TcpTahoe:

Collaboration diagram for ns3::TcpTahoe:

Public Member Functions
	TcpTahoe (void)
	TcpTahoe (const TcpTahoe &sock)
virtual	~TcpTahoe (void)
virtual int	Connect (const Address &address)
virtual int	Listen (void)
Public Member Functions inherited from ns3::TcpSocketBase
	TcpSocketBase (void)
	TcpSocketBase (const TcpSocketBase &sock)
virtual	~TcpSocketBase (void)
virtual int	Bind (void)
virtual int	Bind (const Address &address)
virtual int	Bind6 (void)
	Allocate a local IPv6 endpoint for this socket.
virtual void	BindToNetDevice (Ptr< NetDevice > netdevice)
virtual int	Close (void)
virtual enum SocketErrno	GetErrno (void) const
virtual Ptr< Node >	GetNode (void) const
virtual uint32_t	GetRxAvailable (void) const
virtual enum SocketType	GetSocketType (void) const
virtual int	GetSockName (Address &address) const
virtual uint32_t	GetTxAvailable (void) const
virtual Ptr< Packet >	Recv (uint32_t maxSize, uint32_t flags)
virtual Ptr< Packet >	RecvFrom (uint32_t maxSize, uint32_t flags, Address &fromAddress)
virtual int	Send (Ptr< Packet > p, uint32_t flags)
virtual int	SendTo (Ptr< Packet > p, uint32_t flags, const Address &toAddress)
virtual void	SetNode (Ptr< Node > node)
virtual void	SetRtt (Ptr< RttEstimator > rtt)
virtual void	SetTcp (Ptr< TcpL4Protocol > tcp)
virtual int	ShutdownRecv (void)
virtual int	ShutdownSend (void)
Public Member Functions inherited from ns3::TcpSocket
	TcpSocket (void)
virtual	~TcpSocket (void)
Public Member Functions inherited from ns3::Socket
	Socket (void)
virtual	~Socket (void)
Ptr< NetDevice >	GetBoundNetDevice ()
	Returns socket's bound netdevice, if any.
uint8_t	GetIpTos (void) const
virtual uint8_t	GetIpTtl (void) const
virtual uint8_t	GetIpv6HopLimit (void) const
uint8_t	GetIpv6Tclass (void) const
bool	IsIpRecvTos (void) const
	Ask if the socket is currently passing information about IP Type of Service up the stack.
bool	IsIpRecvTtl (void) const
	Ask if the socket is currently passing information about IP_TTL up the stack.
bool	IsIpv6RecvHopLimit (void) const
	Ask if the socket is currently passing information about IPv6 Hop Limit up the stack.
bool	IsIpv6RecvTclass (void) const
	Ask if the socket is currently passing information about IPv6 Traffic Class up the stack.
bool	IsRecvPktInfo () const
	Get status indicating whether enable/disable packet information to socket.
Ptr< Packet >	Recv (void)
	Read a single packet from the socket.
int	Recv (uint8_t *buf, uint32_t size, uint32_t flags)
	Recv data (or dummy data) from the remote host.
Ptr< Packet >	RecvFrom (Address &fromAddress)
	Read a single packet from the socket and retrieve the sender address.
int	RecvFrom (uint8_t *buf, uint32_t size, uint32_t flags, Address &fromAddress)
	Read a single packet from the socket and retrieve the sender address.
int	Send (Ptr< Packet > p)
	Send data (or dummy data) to the remote host.
int	Send (const uint8_t *buf, uint32_t size, uint32_t flags)
	Send data (or dummy data) to the remote host.
int	SendTo (const uint8_t *buf, uint32_t size, uint32_t flags, const Address &address)
	Send data to a specified peer.
void	SetAcceptCallback (Callback< bool, Ptr< Socket >, const Address & > connectionRequest, Callback< void, Ptr< Socket >, const Address & > newConnectionCreated)
	Accept connection requests from remote hosts.
void	SetCloseCallbacks (Callback< void, Ptr< Socket > > normalClose, Callback< void, Ptr< Socket > > errorClose)
	Detect socket recv() events such as graceful shutdown or error.
void	SetConnectCallback (Callback< void, Ptr< Socket > > connectionSucceeded, Callback< void, Ptr< Socket > > connectionFailed)
	Specify callbacks to allow the caller to determine if the connection succeeds of fails.
void	SetDataSentCallback (Callback< void, Ptr< Socket >, uint32_t > dataSent)
	Notify application when a packet has been sent from transport protocol (non-standard socket call)
void	SetIpRecvTos (bool ipv4RecvTos)
	Tells a socket to pass information about IP Type of Service up the stack.
void	SetIpRecvTtl (bool ipv4RecvTtl)
	Tells a socket to pass information about IP_TTL up the stack.
void	SetIpTos (uint8_t ipTos)
virtual void	SetIpTtl (uint8_t ipTtl)
virtual void	SetIpv6HopLimit (uint8_t ipHopLimit)
void	SetIpv6RecvHopLimit (bool ipv6RecvHopLimit)
	Tells a socket to pass information about IPv6 Hop Limit up the stack.
void	SetIpv6RecvTclass (bool ipv6RecvTclass)
	Tells a socket to pass information about IPv6 Traffic Class up the stack.
void	SetIpv6Tclass (int ipTclass)
void	SetRecvCallback (Callback< void, Ptr< Socket > >)
	Notify application when new data is available to be read.
void	SetRecvPktInfo (bool flag)
	Enable/Disable receive packet information to socket.
void	SetSendCallback (Callback< void, Ptr< Socket >, uint32_t > sendCb)
	Notify application when space in transmit buffer is added.
Public Member Functions inherited from ns3::Object
	Object ()
virtual	~Object ()
void	AggregateObject (Ptr< Object > other)
void	Dispose (void)
AggregateIterator	GetAggregateIterator (void) const
virtual TypeId	GetInstanceTypeId (void) const
template<typename T >
Ptr< T >	GetObject (void) const
template<typename T >
Ptr< T >	GetObject (TypeId tid) const
void	Initialize (void)
Public Member Functions inherited from ns3::SimpleRefCount< Object, ObjectBase, ObjectDeleter >
	SimpleRefCount ()
	SimpleRefCount (const SimpleRefCount &o)
uint32_t	GetReferenceCount (void) const
SimpleRefCount &	operator= (const SimpleRefCount &o)
void	Ref (void) const
void	Unref (void) const
Public Member Functions inherited from ns3::ObjectBase
virtual	~ObjectBase ()
void	GetAttribute (std::string name, AttributeValue &value) const
bool	GetAttributeFailSafe (std::string name, AttributeValue &attribute) const
void	SetAttribute (std::string name, const AttributeValue &value)
bool	SetAttributeFailSafe (std::string name, const AttributeValue &value)
bool	TraceConnect (std::string name, std::string context, const CallbackBase &cb)
bool	TraceConnectWithoutContext (std::string name, const CallbackBase &cb)
bool	TraceDisconnect (std::string name, std::string context, const CallbackBase &cb)
bool	TraceDisconnectWithoutContext (std::string name, const CallbackBase &cb)

Static Public Member Functions
static TypeId	GetTypeId (void)

Protected Member Functions
virtual void	DupAck (const TcpHeader &t, uint32_t count)
virtual Ptr< TcpSocketBase >	Fork (void)
virtual uint32_t	GetInitialCwnd (void) const
virtual uint32_t	GetSSThresh (void) const
virtual void	NewAck (SequenceNumber32 const &seq)
virtual void	Retransmit (void)
virtual void	SetInitialCwnd (uint32_t cwnd)
virtual void	SetSegSize (uint32_t size)
virtual void	SetSSThresh (uint32_t threshold)
virtual uint32_t	Window (void)
Protected Member Functions inherited from ns3::TcpSocketBase
virtual void	AddOptions (TcpHeader &)
virtual uint16_t	AdvertisedWindowSize (void)
virtual uint32_t	AvailableWindow (void)
virtual uint32_t	BytesInFlight (void)
void	CancelAllTimers (void)
void	CloseAndNotify (void)
void	CompleteFork (Ptr< Packet >, const TcpHeader &, const Address &fromAddress, const Address &toAdress)
void	ConnectionSucceeded (void)
void	DeallocateEndPoint (void)
virtual void	DelAckTimeout (void)
void	Destroy (void)
void	Destroy6 (void)
int	DoClose (void)
int	DoConnect (void)
virtual void	DoForwardUp (Ptr< Packet > packet, Ipv4Header header, uint16_t port, Ptr< Ipv4Interface > incomingInterface)
virtual void	DoForwardUp (Ptr< Packet > packet, Ipv6Header header, uint16_t port)
void	DoPeerClose (void)
virtual void	DoRetransmit (void)
virtual void	EstimateRtt (const TcpHeader &)
void	ForwardIcmp (Ipv4Address icmpSource, uint8_t icmpTtl, uint8_t icmpType, uint8_t icmpCode, uint32_t icmpInfo)
void	ForwardIcmp6 (Ipv6Address icmpSource, uint8_t icmpTtl, uint8_t icmpType, uint8_t icmpCode, uint32_t icmpInfo)
void	ForwardUp (Ptr< Packet > packet, Ipv4Header header, uint16_t port, Ptr< Ipv4Interface > incomingInterface)
void	ForwardUp6 (Ptr< Packet > packet, Ipv6Header header, uint16_t port)
virtual bool	GetAllowBroadcast (void) const
	Query whether broadcast datagram transmissions are allowed.
virtual uint32_t	GetConnCount (void) const
virtual Time	GetConnTimeout (void) const
virtual uint32_t	GetDelAckMaxCount (void) const
virtual Time	GetDelAckTimeout (void) const
virtual Time	GetPersistTimeout (void) const
virtual uint32_t	GetRcvBufSize (void) const
virtual uint32_t	GetSegSize (void) const
virtual uint32_t	GetSndBufSize (void) const
virtual bool	GetTcpNoDelay (void) const
virtual void	LastAckTimeout (void)
bool	OutOfRange (SequenceNumber32 head, SequenceNumber32 tail) const
void	PeerClose (Ptr< Packet >, const TcpHeader &)
virtual void	PersistTimeout (void)
void	ProcessClosing (Ptr< Packet >, const TcpHeader &)
void	ProcessEstablished (Ptr< Packet >, const TcpHeader &)
void	ProcessLastAck (Ptr< Packet >, const TcpHeader &)
void	ProcessListen (Ptr< Packet >, const TcpHeader &, const Address &, const Address &)
void	ProcessSynRcvd (Ptr< Packet >, const TcpHeader &, const Address &, const Address &)
void	ProcessSynSent (Ptr< Packet >, const TcpHeader &)
void	ProcessWait (Ptr< Packet >, const TcpHeader &)
virtual void	ReadOptions (const TcpHeader &)
virtual void	ReceivedAck (Ptr< Packet >, const TcpHeader &)
virtual void	ReceivedData (Ptr< Packet >, const TcpHeader &)
virtual void	ReTxTimeout (void)
uint32_t	SendDataPacket (SequenceNumber32 seq, uint32_t maxSize, bool withAck)
void	SendEmptyPacket (uint8_t flags)
bool	SendPendingData (bool withAck=false)
void	SendRST (void)
virtual bool	SetAllowBroadcast (bool allowBroadcast)
	Configure whether broadcast datagram transmissions are allowed.
virtual void	SetConnCount (uint32_t count)
virtual void	SetConnTimeout (Time timeout)
virtual void	SetDelAckMaxCount (uint32_t count)
virtual void	SetDelAckTimeout (Time timeout)
virtual void	SetPersistTimeout (Time timeout)
virtual void	SetRcvBufSize (uint32_t size)
virtual void	SetSndBufSize (uint32_t size)
virtual void	SetTcpNoDelay (bool noDelay)
int	SetupCallback (void)
int	SetupEndpoint (void)
int	SetupEndpoint6 (void)
void	TimeWait (void)
virtual uint32_t	UnAckDataCount (void)

Protected Attributes
TracedValue< uint32_t >	m_cWnd
uint32_t	m_initialCWnd
uint32_t	m_retxThresh
uint32_t	m_ssThresh
Protected Attributes inherited from ns3::TcpSocketBase
bool	m_closeNotified
bool	m_closeOnEmpty
uint32_t	m_cnCount
uint32_t	m_cnRetries
Time	m_cnTimeout
bool	m_connected
uint32_t	m_delAckCount
EventId	m_delAckEvent
uint32_t	m_delAckMaxCount
Time	m_delAckTimeout
uint32_t	m_dupAckCount
Ipv4EndPoint *	m_endPoint
Ipv6EndPoint *	m_endPoint6
enum SocketErrno	m_errno
TracedValue< SequenceNumber32 >	m_highTxMark
Callback< void, Ipv4Address, uint8_t, uint8_t, uint8_t, uint32_t >	m_icmpCallback
Callback< void, Ipv6Address, uint8_t, uint8_t, uint8_t, uint32_t >	m_icmpCallback6
EventId	m_lastAckEvent
TracedValue< Time >	m_lastRtt
uint16_t	m_maxWinSize
double	m_msl
TracedValue< SequenceNumber32 >	m_nextTxSequence
Ptr< Node >	m_node
bool	m_noDelay
EventId	m_persistEvent
Time	m_persistTimeout
EventId	m_retxEvent
TracedValue< Time >	m_rto
Ptr< RttEstimator >	m_rtt
TracedValue< uint32_t >	m_rWnd
TcpRxBuffer	m_rxBuffer
uint32_t	m_segmentSize
bool	m_shutdownRecv
bool	m_shutdownSend
TracedValue< TcpStates_t >	m_state
Ptr< TcpL4Protocol >	m_tcp
EventId	m_timewaitEvent
TcpTxBuffer	m_txBuffer

Private Member Functions
void	InitializeCwnd (void)

Additional Inherited Members
Public Types inherited from ns3::Socket
enum	SocketErrno { ERROR_NOTERROR, ERROR_ISCONN, ERROR_NOTCONN, ERROR_MSGSIZE, ERROR_AGAIN, ERROR_SHUTDOWN, ERROR_OPNOTSUPP, ERROR_AFNOSUPPORT, ERROR_INVAL, ERROR_BADF, ERROR_NOROUTETOHOST, ERROR_NODEV, ERROR_ADDRNOTAVAIL, ERROR_ADDRINUSE, SOCKET_ERRNO_LAST }
enum	SocketType { NS3_SOCK_STREAM, NS3_SOCK_SEQPACKET, NS3_SOCK_DGRAM, NS3_SOCK_RAW }
Static Public Attributes inherited from ns3::TcpSocket
static const char *const	TcpStateName [LAST_STATE] = { "CLOSED", "LISTEN", "SYN_SENT", "SYN_RCVD", "ESTABLISHED", "CLOSE_WAIT", "LAST_ACK", "FIN_WAIT_1", "FIN_WAIT_2", "CLOSING", "TIME_WAIT" }

Detailed Description

An implementation of a stream socket using TCP.

This class contains the Tahoe implementation of TCP. Tahoe is not officially published in RFC. The reference for implementing this is based on Kevin Fall and Sally Floyd, "Simulation-based Comparisons of Tahoe, Reno, and SACK TCP", CCR, 1996 http://inst.eecs.berkeley.edu/~ee122/fa05/projects/Project2/proj2_spec_files/sacks.pdf In summary, we have slow start, congestion avoidance, and fast retransmit. The implementation of these algorithms are based on W. R. Stevens's book and also RFC2001.

Config Paths

ns3::TcpTahoe is accessible through the following paths with Config::Set and Config::Connect:

/NodeList/[i]/$ns3::TcpL4Protocol/SocketList/[i]/$ns3::TcpTahoe

Attributes

ReTxThreshold: Threshold for fast retransmit
- Set with class: ns3::UintegerValue
- Underlying type: uint32_t 0:4294967295
- Initial value: 3
- Flags: construct write read

Attributes defined in parent class ns3::TcpSocketBase

MaxSegLifetime: Maximum segment lifetime in seconds, use for TIME_WAIT state transition to CLOSED state
- Set with class: ns3::DoubleValue
- Underlying type: double 0:1.79769e+308
- Initial value: 120
- Flags: construct write read
MaxWindowSize: Max size of advertised window
- Set with class: ns3::UintegerValue
- Underlying type: uint16_t 0:65535
- Initial value: 65535
- Flags: construct write read
IcmpCallback: Callback invoked whenever an icmp error is received on this socket.
- Set with class: CallbackValue
- Underlying type: Callback
- Initial value: 0
- Flags: construct write read
IcmpCallback6: Callback invoked whenever an icmpv6 error is received on this socket.
- Set with class: CallbackValue
- Underlying type: Callback
- Initial value: 0
- Flags: construct write read

Attributes defined in parent class ns3::TcpSocket

SndBufSize: TcpSocket maximum transmit buffer size (bytes)
- Set with class: ns3::UintegerValue
- Underlying type: uint32_t 0:4294967295
- Initial value: 131072
- Flags: construct write read
RcvBufSize: TcpSocket maximum receive buffer size (bytes)
- Set with class: ns3::UintegerValue
- Underlying type: uint32_t 0:4294967295
- Initial value: 131072
- Flags: construct write read
SegmentSize: TCP maximum segment size in bytes (may be adjusted based on MTU discovery)
- Set with class: ns3::UintegerValue
- Underlying type: uint32_t 0:4294967295
- Initial value: 536
- Flags: construct write read
SlowStartThreshold: TCP slow start threshold (bytes)
- Set with class: ns3::UintegerValue
- Underlying type: uint32_t 0:4294967295
- Initial value: 65535
- Flags: construct write read
InitialCwnd: TCP initial congestion window size (segments)
- Set with class: ns3::UintegerValue
- Underlying type: uint32_t 0:4294967295
- Initial value: 1
- Flags: construct write read
ConnTimeout: TCP retransmission timeout when opening connection (seconds)
- Set with class: TimeValue
- Underlying type: Time
- Initial value: +3000000000.0ns
- Flags: construct write read
ConnCount: Number of connection attempts (SYN retransmissions) before returning failure
- Set with class: ns3::UintegerValue
- Underlying type: uint32_t 0:4294967295
- Initial value: 6
- Flags: construct write read
DelAckTimeout: Timeout value for TCP delayed acks, in seconds
- Set with class: TimeValue
- Underlying type: Time
- Initial value: +200000000.0ns
- Flags: construct write read
DelAckCount: Number of packets to wait before sending a TCP ack
- Set with class: ns3::UintegerValue
- Underlying type: uint32_t 0:4294967295
- Initial value: 2
- Flags: construct write read
TcpNoDelay: Set to true to disable Nagle's algorithm
- Set with class: BooleanValue
- Underlying type: bool
- Initial value: true
- Flags: construct write read
PersistTimeout: Persist timeout to probe for rx window
- Set with class: TimeValue
- Underlying type: Time
- Initial value: +6000000000.0ns
- Flags: construct write read