TCPEndpoint
TCPEndpoint* fEndpoint;
ConnectionHashDefinition::Hash(TCPEndpoint* endpoint) const
TCPEndpoint* endpoint) const
TCPEndpoint*&
ConnectionHashDefinition::GetLink(TCPEndpoint* endpoint) const
EndpointHashDefinition::Hash(TCPEndpoint* endpoint) const
EndpointHashDefinition::Compare(uint16 port, TCPEndpoint* endpoint) const
EndpointHashDefinition::CompareValues(TCPEndpoint* first,
TCPEndpoint* second) const
TCPEndpoint*&
EndpointHashDefinition::GetLink(TCPEndpoint* endpoint) const
TCPEndpoint*
EndpointManager::SetConnection(TCPEndpoint* endpoint, const sockaddr* _local,
EndpointManager::SetPassive(TCPEndpoint* endpoint)
TCPEndpoint*
TCPEndpoint *endpoint = _LookupConnection(local, peer);
EndpointManager::Bind(TCPEndpoint* endpoint, const sockaddr* address)
Bind(TCPEndpoint* endpoint, ConstSocketAddress& address, bool ephemeral)
EndpointManager::BindChild(TCPEndpoint* endpoint, const sockaddr* address)
EndpointManager::_BindToAddress(WriteLocker& locker, TCPEndpoint* endpoint,
TCPEndpoint* user = portUsers.Next();
EndpointManager::_BindToEphemeral(TCPEndpoint* endpoint,
Bind(TCPEndpoint* endpoint, SocketAddress& address, bool ephemeral)
EndpointManager::_Bind(TCPEndpoint* endpoint, const sockaddr* address)
EndpointManager::Unbind(TCPEndpoint* endpoint)
TCPEndpoint *endpoint = iterator.Next();
TCPEndpoint* fEndpoint;
Connect(TCPEndpoint* endpoint)
TCPEndpoint* fEndpoint;
Unbind(TCPEndpoint* endpoint)
status_t _Bind(TCPEndpoint* endpoint,
TCPEndpoint* endpoint, const sockaddr* address);
status_t _BindToEphemeral(TCPEndpoint* endpoint,
class TCPEndpoint;
typedef TCPEndpoint ValueType;
size_t Hash(TCPEndpoint* endpoint) const;
TCPEndpoint* endpoint) const;
TCPEndpoint*& GetLink(TCPEndpoint* endpoint) const;
typedef TCPEndpoint ValueType;
size_t Hash(TCPEndpoint* endpoint) const;
bool Compare(uint16 port, TCPEndpoint* endpoint) const;
bool CompareValues(TCPEndpoint* first,
TCPEndpoint* second) const;
TCPEndpoint*& GetLink(TCPEndpoint* endpoint) const;
TCPEndpoint* FindConnection(sockaddr* local, sockaddr* peer);
status_t SetConnection(TCPEndpoint* endpoint,
status_t SetPassive(TCPEndpoint* endpoint);
status_t Bind(TCPEndpoint* endpoint,
status_t BindChild(TCPEndpoint* endpoint,
status_t Unbind(TCPEndpoint* endpoint);
TCPEndpoint* _LookupConnection(const sockaddr* local,
TCPEndpoint::ReadAvailable()
TCPEndpoint::SetSendBufferSize(size_t length)
TCPEndpoint::SetReceiveBufferSize(size_t length)
TCPEndpoint::GetOption(int option, void* _value, int* _length)
TCPEndpoint::SetOption(int option, const void* _value, int length)
TCPEndpoint::IsBound() const
TCPEndpoint::IsLocal() const
TCPEndpoint::DelayedAcknowledge()
TCPEndpoint::_StartPersistTimer()
TCPEndpoint* fEndpoint;
TCPEndpoint::_EnterTimeWait()
TCPEndpoint::_UpdateTimeWait()
TCPEndpoint::_CancelConnectionTimers()
TCPEndpoint::_Disconnect(bool closing)
TCPEndpoint::_MarkEstablished()
TCPEndpoint::_WaitForEstablished(MutexLocker &locker, bigtime_t timeout)
TCPEndpoint::_Close()
Send(TCPEndpoint* endpoint, tcp_segment_header& segment, net_buffer* buffer,
TCPEndpoint::_HandleReset(status_t error)
TCPEndpoint::_DuplicateAcknowledge(tcp_segment_header &segment)
TCPEndpoint::_UpdateTimestamps(tcp_segment_header& segment,
TCPEndpoint::_UpdateReceiveBuffer()
TCPEndpoint::_AvailableData() const
TCPEndpoint::_NotifyReader()
TCPEndpoint::_AddData(tcp_segment_header& segment, net_buffer* buffer)
TCPEndpoint::_PrepareReceivePath(tcp_segment_header& segment)
TCPEndpoint::_ShouldReceive() const
TCPEndpoint* fEndpoint;
TCPEndpoint::_Spawn(TCPEndpoint* parent, tcp_segment_header& segment,
TCPEndpoint::_ListenReceive(tcp_segment_header& segment, net_buffer* buffer)
return ((TCPEndpoint *)newSocket->first_protocol)->_Spawn(this,
TCPEndpoint::_SynchronizeSentReceive(tcp_segment_header &segment,
TCPEndpoint::_Receive(tcp_segment_header& segment, net_buffer* buffer)
State(TCPEndpoint* endpoint)
TCPEndpoint* fEndpoint;
Spawn(TCPEndpoint* listeningEndpoint, TCPEndpoint* spawnedEndpoint)
TCPEndpoint::SegmentReceived(tcp_segment_header& segment, net_buffer* buffer)
TCPEndpoint* fListeningEndpoint;
TCPEndpoint* fSpawnedEndpoint;
TCPEndpoint::ErrorReceived(net_error error, net_error_data* errorData,
TCPEndpoint::_PrepareSendSegment()
Error(TCPEndpoint* endpoint, const char* error, int32 line)
TCPEndpoint::_PrepareAndSend(tcp_segment_header& segment, net_buffer* buffer,
TCPEndpoint::_ShouldSendSegment(tcp_segment_header& segment, uint32 length,
TCPEndpoint* fEndpoint;
TCPEndpoint::_SendAcknowledge(bool force)
TCPEndpoint::_SendReset(bool force)
TCPEndpoint::_SendQueued(bool force)
TimerSet(TCPEndpoint* endpoint, const char* which, bigtime_t timeout)
TCPEndpoint::_MaxSegmentSize(const sockaddr* address) const
TCPEndpoint::_PrepareSendPath(const sockaddr* peer)
TCPEndpoint::_Acknowledged(tcp_segment_header& segment)
TCPEndpoint* fEndpoint;
TCPEndpoint::_Retransmit()
TimerTriggered(TCPEndpoint* endpoint, const char* which)
TCPEndpoint::_UpdateRoundTripTime(int32 roundTripTime, int32 expectedSamples)
TCPEndpoint::_ResetSlowStart()
TCPEndpoint::_RetransmitTimer(net_timer* timer, void* _endpoint)
TCPEndpoint* endpoint = (TCPEndpoint*)_endpoint;
TCPEndpoint::_PersistTimer(net_timer* timer, void* _endpoint)
TCPEndpoint* endpoint = (TCPEndpoint*)_endpoint;
TCPEndpoint::_DelayedAcknowledgeTimer(net_timer* timer, void* _endpoint)
TCPEndpoint* endpoint = (TCPEndpoint*)_endpoint;
TCPEndpoint::_TimeWaitTimer(net_timer* timer, void* _endpoint)
TCPEndpoint* endpoint = (TCPEndpoint*)_endpoint;
TCPEndpoint::_WaitForCondition(ConditionVariable& condition,
TCPEndpoint* fEndpoint;
TCPEndpoint::Dump() const
APICall(TCPEndpoint* endpoint, const char* which)
TCPEndpoint* fEndpoint;
TCPEndpoint::TCPEndpoint(net_socket* socket)
gStackModule->init_timer(&fPersistTimer, TCPEndpoint::_PersistTimer, this);
gStackModule->init_timer(&fRetransmitTimer, TCPEndpoint::_RetransmitTimer,
TCPEndpoint::_DelayedAcknowledgeTimer, this);
gStackModule->init_timer(&fTimeWaitTimer, TCPEndpoint::_TimeWaitTimer,
TCPEndpoint::~TCPEndpoint()
TCPEndpoint::InitCheck() const
TCPEndpoint::Open()
TCPEndpoint::Close()
TCPEndpoint::Free()
TCPEndpoint::Connect(const sockaddr* address)
TCPEndpoint::Accept(struct net_socket** _acceptedSocket)
TCPEndpoint::Bind(const sockaddr *address)
TCPEndpoint::Unbind(struct sockaddr *address)
TCPEndpoint::Listen(int count)
TCPEndpoint::Shutdown(int direction)
TCPEndpoint::SendData(net_buffer *buffer)
TCPEndpoint::SendAvailable()
TCPEndpoint::FillStat(net_stat *stat)
Receive(TCPEndpoint* endpoint, tcp_segment_header& segment, uint32 window,
TCPEndpoint::ReadData(size_t numBytes, uint32 flags, net_buffer** _buffer)
TCPEndpoint* fConnectionHashLink;
TCPEndpoint* fEndpointHashLink;
class TCPEndpoint : public net_protocol, public ProtocolSocket {
TCPEndpoint(net_socket* socket);
~TCPEndpoint();
int32 _Spawn(TCPEndpoint* parent, tcp_segment_header& segment,
TCPEndpoint* endpoint = (TCPEndpoint*)parse_expression(argv[1]);
TCPEndpoint* protocol = new (std::nothrow) TCPEndpoint(socket);
delete (TCPEndpoint*)protocol;
return ((TCPEndpoint*)protocol)->Open();
return ((TCPEndpoint*)protocol)->Close();
((TCPEndpoint*)protocol)->Free();
return ((TCPEndpoint*)protocol)->Connect(address);
return ((TCPEndpoint*)protocol)->Accept(_acceptedSocket);
TCPEndpoint* protocol = (TCPEndpoint*)_protocol;
TCPEndpoint* protocol = (TCPEndpoint*)_protocol;
TCPEndpoint* protocol = (TCPEndpoint*)_protocol;
return ((TCPEndpoint*)protocol)->Bind(address);
return ((TCPEndpoint*)protocol)->Unbind(address);
return ((TCPEndpoint*)protocol)->Listen(count);
return ((TCPEndpoint*)protocol)->Shutdown(direction);
return ((TCPEndpoint*)protocol)->SendData(buffer);
return ((TCPEndpoint*)protocol)->SendAvailable();
return ((TCPEndpoint*)protocol)->ReadData(numBytes, flags, _buffer);
return ((TCPEndpoint*)protocol)->ReadAvailable();
TCPEndpoint* endpoint = endpointManager->FindConnection(
TCPEndpoint* endpoint = endpointManager->FindConnection(