webkit  2cdf99a9e3038c7e01b3c37e8ad903ecbe5eecf1
https://github.com/WebKit/webkit
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Modules Pages
Public Member Functions | Protected Member Functions | Static Protected Member Functions | Protected Attributes | List of all members
rtc::PhysicalSocket Class Reference

#include <physicalsocketserver.h>

Inheritance diagram for rtc::PhysicalSocket:
rtc::AsyncSocket sigslot::has_slots<> rtc::AsyncSocket sigslot::has_slots<> sigslot::has_slots_interface sigslot::has_slots_interface rtc::Socket rtc::Socket sigslot::has_slots_interface sigslot::has_slots_interface rtc::Socket rtc::Socket rtc::SocketDispatcher rtc::SocketDispatcher rtc::FakeSocketDispatcher rtc::FakeSocketDispatcher

Public Member Functions

 PhysicalSocket (PhysicalSocketServer *ss, SOCKET s=INVALID_SOCKET)
 
 ~PhysicalSocket () override
 
virtual bool Create (int family, int type)
 
SocketAddress GetLocalAddress () const override
 
SocketAddress GetRemoteAddress () const override
 
int Bind (const SocketAddress &bind_addr) override
 
int Connect (const SocketAddress &addr) override
 
int GetError () const override
 
void SetError (int error) override
 
ConnState GetState () const override
 
int GetOption (Option opt, int *value) override
 
int SetOption (Option opt, int value) override
 
int Send (const void *pv, size_t cb) override
 
int SendTo (const void *buffer, size_t length, const SocketAddress &addr) override
 
int Recv (void *buffer, size_t length, int64_t *timestamp) override
 
int RecvFrom (void *buffer, size_t length, SocketAddress *out_addr, int64_t *timestamp) override
 
int Listen (int backlog) override
 
AsyncSocketAccept (SocketAddress *out_addr) override
 
int Close () override
 
int EstimateMTU (uint16_t *mtu) override
 
SocketServersocketserver ()
 
 PhysicalSocket (PhysicalSocketServer *ss, SOCKET s=INVALID_SOCKET)
 
 ~PhysicalSocket () override
 
virtual bool Create (int family, int type)
 
SocketAddress GetLocalAddress () const override
 
SocketAddress GetRemoteAddress () const override
 
int Bind (const SocketAddress &bind_addr) override
 
int Connect (const SocketAddress &addr) override
 
int GetError () const override
 
void SetError (int error) override
 
ConnState GetState () const override
 
int GetOption (Option opt, int *value) override
 
int SetOption (Option opt, int value) override
 
int Send (const void *pv, size_t cb) override
 
int SendTo (const void *buffer, size_t length, const SocketAddress &addr) override
 
int Recv (void *buffer, size_t length, int64_t *timestamp) override
 
int RecvFrom (void *buffer, size_t length, SocketAddress *out_addr, int64_t *timestamp) override
 
int Listen (int backlog) override
 
AsyncSocketAccept (SocketAddress *out_addr) override
 
int Close () override
 
int EstimateMTU (uint16_t *mtu) override
 
SocketServersocketserver ()
 
- Public Member Functions inherited from rtc::AsyncSocket
 AsyncSocket ()
 
 ~AsyncSocket () override
 
 AsyncSocket ()
 
 ~AsyncSocket () override
 
- Public Member Functions inherited from rtc::Socket
virtual ~Socket ()
 
bool IsBlocking () const
 
virtual ~Socket ()
 
bool IsBlocking () const
 
- Public Member Functions inherited from sigslot::has_slots<>
 has_slots ()
 
 has_slots ()
 
 ~has_slots ()
 
 ~has_slots ()
 
- Public Member Functions inherited from sigslot::has_slots_interface
void signal_connect (_signal_base_interface *sender)
 
void signal_disconnect (_signal_base_interface *sender)
 
void disconnect_all ()
 
void signal_connect (_signal_base_interface *sender)
 
void signal_disconnect (_signal_base_interface *sender)
 
void disconnect_all ()
 

Protected Member Functions

int DoConnect (const SocketAddress &connect_addr)
 
virtual SOCKET DoAccept (SOCKET socket, sockaddr *addr, socklen_t *addrlen)
 
virtual int DoSend (SOCKET socket, const char *buf, int len, int flags)
 
virtual int DoSendTo (SOCKET socket, const char *buf, int len, int flags, const struct sockaddr *dest_addr, socklen_t addrlen)
 
void OnResolveResult (AsyncResolverInterface *resolver)
 
void UpdateLastError ()
 
void MaybeRemapSendError ()
 
int error_ GUARDED_BY (crit_)
 
int DoConnect (const SocketAddress &connect_addr)
 
virtual SOCKET DoAccept (SOCKET socket, sockaddr *addr, socklen_t *addrlen)
 
virtual int DoSend (SOCKET socket, const char *buf, int len, int flags)
 
virtual int DoSendTo (SOCKET socket, const char *buf, int len, int flags, const struct sockaddr *dest_addr, socklen_t addrlen)
 
void OnResolveResult (AsyncResolverInterface *resolver)
 
void UpdateLastError ()
 
void MaybeRemapSendError ()
 
int error_ GUARDED_BY (crit_)
 
- Protected Member Functions inherited from rtc::Socket
 Socket ()
 
 Socket ()
 
- Protected Member Functions inherited from sigslot::has_slots_interface
 has_slots_interface (signal_connect_t conn, signal_disconnect_t disc, disconnect_all_t disc_all)
 
virtual ~has_slots_interface ()
 
 has_slots_interface (signal_connect_t conn, signal_disconnect_t disc, disconnect_all_t disc_all)
 
virtual ~has_slots_interface ()
 

Static Protected Member Functions

static int TranslateOption (Option opt, int *slevel, int *sopt)
 
static int TranslateOption (Option opt, int *slevel, int *sopt)
 

Protected Attributes

PhysicalSocketServerss_
 
SOCKET s_
 
uint8_t enabled_events_
 
bool udp_
 
CriticalSection crit_
 
ConnState state_
 
AsyncResolverresolver_
 
std::string dbg_addr_
 

Additional Inherited Members

- Public Types inherited from rtc::Socket
enum  ConnState {
  CS_CLOSED, CS_CONNECTING, CS_CONNECTED, CS_CLOSED,
  CS_CONNECTING, CS_CONNECTED
}
 
enum  Option {
  OPT_DONTFRAGMENT, OPT_RCVBUF, OPT_SNDBUF, OPT_NODELAY,
  OPT_IPV6_V6ONLY, OPT_DSCP, OPT_RTP_SENDTIME_EXTN_ID, OPT_DONTFRAGMENT,
  OPT_RCVBUF, OPT_SNDBUF, OPT_NODELAY, OPT_IPV6_V6ONLY,
  OPT_DSCP, OPT_RTP_SENDTIME_EXTN_ID
}
 
enum  ConnState {
  CS_CLOSED, CS_CONNECTING, CS_CONNECTED, CS_CLOSED,
  CS_CONNECTING, CS_CONNECTED
}
 
enum  Option {
  OPT_DONTFRAGMENT, OPT_RCVBUF, OPT_SNDBUF, OPT_NODELAY,
  OPT_IPV6_V6ONLY, OPT_DSCP, OPT_RTP_SENDTIME_EXTN_ID, OPT_DONTFRAGMENT,
  OPT_RCVBUF, OPT_SNDBUF, OPT_NODELAY, OPT_IPV6_V6ONLY,
  OPT_DSCP, OPT_RTP_SENDTIME_EXTN_ID
}
 
- Public Attributes inherited from rtc::AsyncSocket
sigslot::signal1< AsyncSocket *, sigslot::multi_threaded_local > SignalReadEvent
 
sigslot::signal1< AsyncSocket *, sigslot::multi_threaded_local > SignalWriteEvent
 
sigslot::signal1< AsyncSocket * > SignalConnectEvent
 
sigslot::signal2< AsyncSocket *, int > SignalCloseEvent
 

Constructor & Destructor Documentation

◆ PhysicalSocket() [1/2]

rtc::PhysicalSocket::PhysicalSocket ( PhysicalSocketServer ss,
SOCKET  s = INVALID_SOCKET 
)

◆ ~PhysicalSocket() [1/2]

rtc::PhysicalSocket::~PhysicalSocket ( )
override

◆ PhysicalSocket() [2/2]

rtc::PhysicalSocket::PhysicalSocket ( PhysicalSocketServer ss,
SOCKET  s = INVALID_SOCKET 
)

◆ ~PhysicalSocket() [2/2]

rtc::PhysicalSocket::~PhysicalSocket ( )
override

Member Function Documentation

◆ Accept() [1/2]

AsyncSocket * rtc::PhysicalSocket::Accept ( SocketAddress out_addr)
overridevirtual

Implements rtc::AsyncSocket.

◆ Accept() [2/2]

AsyncSocket* rtc::PhysicalSocket::Accept ( SocketAddress out_addr)
overridevirtual

Implements rtc::AsyncSocket.

◆ Bind() [1/2]

int rtc::PhysicalSocket::Bind ( const SocketAddress bind_addr)
overridevirtual

Implements rtc::Socket.

◆ Bind() [2/2]

int rtc::PhysicalSocket::Bind ( const SocketAddress bind_addr)
overridevirtual

Implements rtc::Socket.

◆ Close() [1/2]

int rtc::PhysicalSocket::Close ( )
overridevirtual

Implements rtc::Socket.

Reimplemented in rtc::SocketDispatcher, and rtc::SocketDispatcher.

◆ Close() [2/2]

int rtc::PhysicalSocket::Close ( )
overridevirtual

Implements rtc::Socket.

Reimplemented in rtc::SocketDispatcher.

◆ Connect() [1/2]

int rtc::PhysicalSocket::Connect ( const SocketAddress addr)
overridevirtual

Implements rtc::Socket.

◆ Connect() [2/2]

int rtc::PhysicalSocket::Connect ( const SocketAddress addr)
overridevirtual

Implements rtc::Socket.

◆ Create() [1/2]

bool rtc::PhysicalSocket::Create ( int  family,
int  type 
)
virtual

◆ Create() [2/2]

virtual bool rtc::PhysicalSocket::Create ( int  family,
int  type 
)
virtual

◆ DoAccept() [1/2]

SOCKET rtc::PhysicalSocket::DoAccept ( SOCKET  socket,
sockaddr *  addr,
socklen_t *  addrlen 
)
protectedvirtual

Reimplemented in rtc::FakeSocketDispatcher.

◆ DoAccept() [2/2]

virtual SOCKET rtc::PhysicalSocket::DoAccept ( SOCKET  socket,
sockaddr *  addr,
socklen_t *  addrlen 
)
protectedvirtual

Reimplemented in rtc::FakeSocketDispatcher.

◆ DoConnect() [1/2]

int rtc::PhysicalSocket::DoConnect ( const SocketAddress connect_addr)
protected

◆ DoConnect() [2/2]

int rtc::PhysicalSocket::DoConnect ( const SocketAddress connect_addr)
protected

◆ DoSend() [1/2]

int rtc::PhysicalSocket::DoSend ( SOCKET  socket,
const char *  buf,
int  len,
int  flags 
)
protectedvirtual

Reimplemented in rtc::FakeSocketDispatcher.

◆ DoSend() [2/2]

virtual int rtc::PhysicalSocket::DoSend ( SOCKET  socket,
const char *  buf,
int  len,
int  flags 
)
protectedvirtual

Reimplemented in rtc::FakeSocketDispatcher.

◆ DoSendTo() [1/2]

virtual int rtc::PhysicalSocket::DoSendTo ( SOCKET  socket,
const char *  buf,
int  len,
int  flags,
const struct sockaddr *  dest_addr,
socklen_t  addrlen 
)
protectedvirtual

Reimplemented in rtc::FakeSocketDispatcher.

◆ DoSendTo() [2/2]

int rtc::PhysicalSocket::DoSendTo ( SOCKET  socket,
const char *  buf,
int  len,
int  flags,
const struct sockaddr *  dest_addr,
socklen_t  addrlen 
)
protectedvirtual

Reimplemented in rtc::FakeSocketDispatcher.

◆ EstimateMTU() [1/2]

int rtc::PhysicalSocket::EstimateMTU ( uint16_t mtu)
overridevirtual

Implements rtc::Socket.

◆ EstimateMTU() [2/2]

int rtc::PhysicalSocket::EstimateMTU ( uint16_t mtu)
overridevirtual

Implements rtc::Socket.

◆ GetError() [1/2]

int rtc::PhysicalSocket::GetError ( ) const
overridevirtual

Implements rtc::Socket.

◆ GetError() [2/2]

int rtc::PhysicalSocket::GetError ( ) const
overridevirtual

Implements rtc::Socket.

◆ GetLocalAddress() [1/2]

SocketAddress rtc::PhysicalSocket::GetLocalAddress ( ) const
overridevirtual

Implements rtc::Socket.

◆ GetLocalAddress() [2/2]

SocketAddress rtc::PhysicalSocket::GetLocalAddress ( ) const
overridevirtual

Implements rtc::Socket.

◆ GetOption() [1/2]

int rtc::PhysicalSocket::GetOption ( Option  opt,
int *  value 
)
overridevirtual

Implements rtc::Socket.

◆ GetOption() [2/2]

int rtc::PhysicalSocket::GetOption ( Option  opt,
int *  value 
)
overridevirtual

Implements rtc::Socket.

◆ GetRemoteAddress() [1/2]

SocketAddress rtc::PhysicalSocket::GetRemoteAddress ( ) const
overridevirtual

Implements rtc::Socket.

◆ GetRemoteAddress() [2/2]

SocketAddress rtc::PhysicalSocket::GetRemoteAddress ( ) const
overridevirtual

Implements rtc::Socket.

◆ GetState() [1/2]

AsyncSocket::ConnState rtc::PhysicalSocket::GetState ( ) const
overridevirtual

Implements rtc::Socket.

◆ GetState() [2/2]

ConnState rtc::PhysicalSocket::GetState ( ) const
overridevirtual

Implements rtc::Socket.

◆ GUARDED_BY() [1/2]

int error_ rtc::PhysicalSocket::GUARDED_BY ( crit_  )
protected

◆ GUARDED_BY() [2/2]

int error_ rtc::PhysicalSocket::GUARDED_BY ( crit_  )
protected

◆ Listen() [1/2]

int rtc::PhysicalSocket::Listen ( int  backlog)
overridevirtual

Implements rtc::Socket.

◆ Listen() [2/2]

int rtc::PhysicalSocket::Listen ( int  backlog)
overridevirtual

Implements rtc::Socket.

◆ MaybeRemapSendError() [1/2]

void rtc::PhysicalSocket::MaybeRemapSendError ( )
protected

◆ MaybeRemapSendError() [2/2]

void rtc::PhysicalSocket::MaybeRemapSendError ( )
protected

◆ OnResolveResult() [1/2]

void rtc::PhysicalSocket::OnResolveResult ( AsyncResolverInterface resolver)
protected

◆ OnResolveResult() [2/2]

void rtc::PhysicalSocket::OnResolveResult ( AsyncResolverInterface resolver)
protected

◆ Recv() [1/2]

int rtc::PhysicalSocket::Recv ( void buffer,
size_t  length,
int64_t timestamp 
)
overridevirtual

Implements rtc::Socket.

◆ Recv() [2/2]

int rtc::PhysicalSocket::Recv ( void buffer,
size_t  length,
int64_t timestamp 
)
overridevirtual

Implements rtc::Socket.

◆ RecvFrom() [1/2]

int rtc::PhysicalSocket::RecvFrom ( void buffer,
size_t  length,
SocketAddress out_addr,
int64_t timestamp 
)
overridevirtual

Implements rtc::Socket.

◆ RecvFrom() [2/2]

int rtc::PhysicalSocket::RecvFrom ( void buffer,
size_t  length,
SocketAddress out_addr,
int64_t timestamp 
)
overridevirtual

Implements rtc::Socket.

◆ Send() [1/2]

int rtc::PhysicalSocket::Send ( const void pv,
size_t  cb 
)
overridevirtual

Implements rtc::Socket.

◆ Send() [2/2]

int rtc::PhysicalSocket::Send ( const void pv,
size_t  cb 
)
overridevirtual

Implements rtc::Socket.

◆ SendTo() [1/2]

int rtc::PhysicalSocket::SendTo ( const void buffer,
size_t  length,
const SocketAddress addr 
)
overridevirtual

Implements rtc::Socket.

◆ SendTo() [2/2]

int rtc::PhysicalSocket::SendTo ( const void buffer,
size_t  length,
const SocketAddress addr 
)
overridevirtual

Implements rtc::Socket.

◆ SetError() [1/2]

void rtc::PhysicalSocket::SetError ( int  error)
overridevirtual

Implements rtc::Socket.

◆ SetError() [2/2]

void rtc::PhysicalSocket::SetError ( int  error)
overridevirtual

Implements rtc::Socket.

◆ SetOption() [1/2]

int rtc::PhysicalSocket::SetOption ( Option  opt,
int  value 
)
overridevirtual

Implements rtc::Socket.

◆ SetOption() [2/2]

int rtc::PhysicalSocket::SetOption ( Option  opt,
int  value 
)
overridevirtual

Implements rtc::Socket.

◆ socketserver() [1/2]

SocketServer* rtc::PhysicalSocket::socketserver ( )
inline

◆ socketserver() [2/2]

SocketServer* rtc::PhysicalSocket::socketserver ( )
inline

◆ TranslateOption() [1/2]

int rtc::PhysicalSocket::TranslateOption ( Option  opt,
int *  slevel,
int *  sopt 
)
staticprotected

◆ TranslateOption() [2/2]

static int rtc::PhysicalSocket::TranslateOption ( Option  opt,
int *  slevel,
int *  sopt 
)
staticprotected

◆ UpdateLastError() [1/2]

void rtc::PhysicalSocket::UpdateLastError ( )
protected

◆ UpdateLastError() [2/2]

void rtc::PhysicalSocket::UpdateLastError ( )
protected

Member Data Documentation

◆ crit_

CriticalSection rtc::PhysicalSocket::crit_
protected

◆ dbg_addr_

std::string rtc::PhysicalSocket::dbg_addr_
protected

◆ enabled_events_

uint8_t rtc::PhysicalSocket::enabled_events_
protected

◆ resolver_

AsyncResolver * rtc::PhysicalSocket::resolver_
protected

◆ s_

SOCKET rtc::PhysicalSocket::s_
protected

◆ ss_

PhysicalSocketServer * rtc::PhysicalSocket::ss_
protected

◆ state_

ConnState rtc::PhysicalSocket::state_
protected

◆ udp_

bool rtc::PhysicalSocket::udp_
protected

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