| /external/webrtc/webrtc/p2p/base/ |
| D | tcpport.h | 82 void OnNewConnection(rtc::AsyncPacketSocket* socket,
83 rtc::AsyncPacketSocket* new_socket);
88 rtc::AsyncPacketSocket* socket;
91 rtc::AsyncPacketSocket* GetIncoming(
95 void OnReadPacket(rtc::AsyncPacketSocket* socket,
100 void OnSentPacket(rtc::AsyncPacketSocket* socket,
103 void OnReadyToSend(rtc::AsyncPacketSocket* socket);
105 void OnAddressReady(rtc::AsyncPacketSocket* socket,
111 rtc::AsyncPacketSocket* socket_;
122 rtc::AsyncPacketSocket* socket = 0);
[all …]
|
| D | relayserver.h | 47 void AddInternalSocket(rtc::AsyncPacketSocket* socket);
48 void RemoveInternalSocket(rtc::AsyncPacketSocket* socket);
53 void AddExternalSocket(rtc::AsyncPacketSocket* socket);
54 void RemoveExternalSocket(rtc::AsyncPacketSocket* socket);
71 typedef std::vector<rtc::AsyncPacketSocket*> SocketList;
88 void OnInternalPacket(rtc::AsyncPacketSocket* socket,
92 void OnExternalPacket(rtc::AsyncPacketSocket* socket,
102 rtc::AsyncPacketSocket* socket,
106 rtc::AsyncPacketSocket* socket);
137 rtc::AsyncPacketSocket* socket);
[all …]
|
| D | tcpport.cc | 158 if (rtc::AsyncPacketSocket* socket = in CreateConnection()
176 if (socket_->GetState() == rtc::AsyncPacketSocket::STATE_BOUND || in PrepareAddress()
177 socket_->GetState() == rtc::AsyncPacketSocket::STATE_CLOSED) in PrepareAddress()
199 rtc::AsyncPacketSocket * socket = NULL; in SendTo()
252 void TCPPort::OnNewConnection(rtc::AsyncPacketSocket* socket, in OnNewConnection()
253 rtc::AsyncPacketSocket* new_socket) { in OnNewConnection()
268 rtc::AsyncPacketSocket* TCPPort::GetIncoming( in GetIncoming()
270 rtc::AsyncPacketSocket* socket = NULL; in GetIncoming()
283 void TCPPort::OnReadPacket(rtc::AsyncPacketSocket* socket, in OnReadPacket()
290 void TCPPort::OnSentPacket(rtc::AsyncPacketSocket* socket, in OnSentPacket()
[all …]
|
| D | turnserver.h | 46 rtc::AsyncPacketSocket* socket);
48 rtc::AsyncPacketSocket* socket() { return socket_; } in socket()
57 rtc::AsyncPacketSocket* socket_;
71 rtc::AsyncPacketSocket* server_socket,
102 void OnExternalPacket(rtc::AsyncPacketSocket* socket,
128 rtc::scoped_ptr<rtc::AsyncPacketSocket> external_socket_;
192 void AddInternalSocket(rtc::AsyncPacketSocket* socket,
204 void OnInternalPacket(rtc::AsyncPacketSocket* socket, const char* data,
212 void OnInternalSocketClose(rtc::AsyncPacketSocket* socket, int err);
247 void DestroyInternalSocket(rtc::AsyncPacketSocket* socket);
[all …]
|
| D | packetsocketfactory.h | 18 class AsyncPacketSocket; variable
32 virtual AsyncPacketSocket* CreateUdpSocket(const SocketAddress& address,
35 virtual AsyncPacketSocket* CreateServerTcpSocket(
43 virtual AsyncPacketSocket* CreateClientTcpSocket(
|
| D | turnport.h | 46 rtc::AsyncPacketSocket* socket, in Create()
98 rtc::AsyncPacketSocket* socket, const char* data, size_t size, in HandleIncomingPacket()
104 virtual void OnReadPacket(rtc::AsyncPacketSocket* socket,
109 virtual void OnSentPacket(rtc::AsyncPacketSocket* socket,
111 virtual void OnReadyToSend(rtc::AsyncPacketSocket* socket);
117 void OnSocketConnect(rtc::AsyncPacketSocket* socket);
118 void OnSocketClose(rtc::AsyncPacketSocket* socket, int error);
128 rtc::AsyncPacketSocket* socket() const { in socket()
159 rtc::AsyncPacketSocket* socket,
257 rtc::AsyncPacketSocket* socket_;
|
| D | stunport.h | 34 rtc::AsyncPacketSocket* socket, in Create()
91 rtc::AsyncPacketSocket* socket, const char* data, size_t size, in HandleIncomingPacket()
124 rtc::AsyncPacketSocket* socket,
137 void OnLocalAddressReady(rtc::AsyncPacketSocket* socket,
139 void OnReadPacket(rtc::AsyncPacketSocket* socket,
144 void OnSentPacket(rtc::AsyncPacketSocket* socket,
147 void OnReadyToSend(rtc::AsyncPacketSocket* socket);
215 rtc::AsyncPacketSocket* socket_;
|
| D | relayport.cc | 31 rtc::AsyncPacketSocket* socket,
34 rtc::AsyncPacketSocket* socket() const { return socket_; } in socket()
67 rtc::AsyncPacketSocket* socket_;
124 void HandleConnectFailure(rtc::AsyncPacketSocket* socket);
138 void OnSocketConnect(rtc::AsyncPacketSocket* socket);
139 void OnSocketClose(rtc::AsyncPacketSocket* socket, int error);
143 rtc::AsyncPacketSocket* socket,
148 void OnSentPacket(rtc::AsyncPacketSocket* socket,
152 void OnReadyToSend(rtc::AsyncPacketSocket* socket);
404 rtc::AsyncPacketSocket* socket, in RelayConnection()
[all …]
|
| D | basicpacketsocketfactory.h | 29 AsyncPacketSocket* CreateUdpSocket(const SocketAddress& local_address,
32 AsyncPacketSocket* CreateServerTcpSocket(const SocketAddress& local_address,
36 AsyncPacketSocket* CreateClientTcpSocket(const SocketAddress& local_address,
|
| D | relayserver.cc | 33 void Send(rtc::AsyncPacketSocket* socket, const char* bytes, size_t size, in Send()
47 rtc::AsyncPacketSocket* socket, in SendStun()
55 void SendStunError(const StunMessage& msg, rtc::AsyncPacketSocket* socket, in SendStunError()
102 void RelayServer::AddInternalSocket(rtc::AsyncPacketSocket* socket) { in AddInternalSocket()
109 void RelayServer::RemoveInternalSocket(rtc::AsyncPacketSocket* socket) { in RemoveInternalSocket()
118 void RelayServer::AddExternalSocket(rtc::AsyncPacketSocket* socket) { in AddExternalSocket()
125 void RelayServer::RemoveExternalSocket(rtc::AsyncPacketSocket* socket) { in RemoveExternalSocket()
182 rtc::AsyncPacketSocket* socket, const char* bytes, size_t size, in OnInternalPacket()
227 rtc::AsyncPacketSocket* socket, const char* bytes, size_t size, in OnExternalPacket()
297 rtc::AsyncPacketSocket* socket, std::string* username, in HandleStun()
[all …]
|
| D | basicpacketsocketfactory.cc | 46 AsyncPacketSocket* BasicPacketSocketFactory::CreateUdpSocket( in CreateUdpSocket()
66 AsyncPacketSocket* BasicPacketSocketFactory::CreateServerTcpSocket( in CreateServerTcpSocket()
107 AsyncPacketSocket* BasicPacketSocketFactory::CreateClientTcpSocket( in CreateClientTcpSocket()
164 AsyncPacketSocket* tcp_socket; in CreateClientTcpSocket()
|
| D | asyncstuntcpsocket_unittest.cc | 94 void OnReadPacket(rtc::AsyncPacketSocket* socket, const char* data, in OnReadPacket()
100 void OnNewConnection(rtc::AsyncPacketSocket* server, in OnNewConnection()
101 rtc::AsyncPacketSocket* new_socket) { in OnNewConnection()
129 rtc::scoped_ptr<rtc::AsyncPacketSocket> listen_socket_;
|
| D | stunport.cc | 166 rtc::AsyncPacketSocket* socket, in UDPPort()
239 if (socket_->GetState() == rtc::AsyncPacketSocket::STATE_BOUND) { in PrepareAddress()
300 void UDPPort::OnLocalAddressReady(rtc::AsyncPacketSocket* socket, in OnLocalAddressReady()
317 void UDPPort::OnReadPacket(rtc::AsyncPacketSocket* socket, in OnReadPacket()
341 void UDPPort::OnSentPacket(rtc::AsyncPacketSocket* socket, in OnSentPacket()
346 void UDPPort::OnReadyToSend(rtc::AsyncPacketSocket* socket) { in OnReadyToSend()
397 } else if (socket_->GetState() == rtc::AsyncPacketSocket::STATE_BOUND) { in SendStunBindingRequest()
|
| D | turnserver.cc | 134 rtc::AsyncPacketSocket* socket = it->first; in ~TurnServer()
145 void TurnServer::AddInternalSocket(rtc::AsyncPacketSocket* socket, in AddInternalSocket()
187 void TurnServer::OnInternalSocketClose(rtc::AsyncPacketSocket* socket, in OnInternalSocketClose()
192 void TurnServer::OnInternalPacket(rtc::AsyncPacketSocket* socket, in OnInternalPacket()
438 rtc::AsyncPacketSocket* external_socket = (external_socket_factory_) ? in CreateAllocation()
504 rtc::AsyncPacketSocket* socket = allocation->conn()->socket(); in OnAllocationDestroyed()
518 void TurnServer::DestroyInternalSocket(rtc::AsyncPacketSocket* socket) { in DestroyInternalSocket()
521 rtc::AsyncPacketSocket* socket = iter->first; in DestroyInternalSocket()
531 rtc::AsyncPacketSocket* socket) in TurnServerConnection()
558 rtc::AsyncPacketSocket* socket, in TurnServerAllocation()
[all …]
|
| D | testrelayserver.h | 85 void OnInternalClose(rtc::AsyncPacketSocket* socket, int error) { in OnInternalClose()
88 void OnExternalClose(rtc::AsyncPacketSocket* socket, int error) { in OnExternalClose()
|
| /external/webrtc/webrtc/base/ |
| D | asyncpacketsocket.h | 67 class AsyncPacketSocket : public sigslot::has_slots<> {
77 AsyncPacketSocket();
78 ~AsyncPacketSocket() override;
109 sigslot::signal5<AsyncPacketSocket*, const char*, size_t,
114 sigslot::signal2<AsyncPacketSocket*, const SentPacket&> SignalSentPacket;
117 sigslot::signal1<AsyncPacketSocket*> SignalReadyToSend;
123 sigslot::signal2<AsyncPacketSocket*, const SocketAddress&> SignalAddressReady;
127 sigslot::signal1<AsyncPacketSocket*> SignalConnect;
131 sigslot::signal2<AsyncPacketSocket*, int> SignalClose;
134 sigslot::signal2<AsyncPacketSocket*, AsyncPacketSocket*> SignalNewConnection;
[all …]
|
| D | testclient.h | 40 explicit TestClient(AsyncPacketSocket* socket);
47 bool CheckConnState(AsyncPacketSocket::State state);
51 return CheckConnState(AsyncPacketSocket::STATE_CONNECTED); in CheckConnected()
83 void OnPacket(AsyncPacketSocket* socket, const char* buf, size_t len,
86 void OnReadyToSend(AsyncPacketSocket* socket);
89 AsyncPacketSocket* socket_;
|
| D | asyncpacketsocket.cc | 23 AsyncPacketSocket::AsyncPacketSocket() { in AsyncPacketSocket() function in rtc::AsyncPacketSocket
26 AsyncPacketSocket::~AsyncPacketSocket() { in ~AsyncPacketSocket()
|
| D | testclient.cc | 21 TestClient::TestClient(AsyncPacketSocket* socket) in TestClient()
35 bool TestClient::CheckConnState(AsyncPacketSocket::State state) { in CheckConnState()
121 void TestClient::OnPacket(AsyncPacketSocket* socket, const char* buf, in OnPacket()
128 void TestClient::OnReadyToSend(AsyncPacketSocket* socket) { in OnReadyToSend()
|
| D | testechoserver.h | 52 void OnPacket(AsyncPacketSocket* socket, const char* buf, size_t size, in OnPacket()
58 void OnClose(AsyncPacketSocket* socket, int err) { in OnClose()
|
| D | natserver.h | 78 void OnInternalUDPPacket(AsyncPacketSocket* socket, const char* buf,
81 void OnExternalUDPPacket(AsyncPacketSocket* socket, const char* buf,
|
| D | asyncudpsocket_unittest.cc | 35 void OnReadyToSend(rtc::AsyncPacketSocket* socket) { in OnReadyToSend()
|
| D | asynctcpsocket_unittest.cc | 35 void OnReadyToSend(rtc::AsyncPacketSocket* socket) { in OnReadyToSend()
|
| /external/webrtc/webrtc/p2p/stunprober/ |
| D | stunprober.cc | 64 rtc::AsyncPacketSocket* socket,
73 void OnStunResponseReceived(rtc::AsyncPacketSocket* socket,
92 rtc::scoped_ptr<rtc::AsyncPacketSocket> socket_;
110 rtc::AsyncPacketSocket* socket, in Requester()
200 rtc::AsyncPacketSocket* socket, in OnStunResponseReceived()
304 void StunProber::OnSocketReady(rtc::AsyncPacketSocket* socket, in OnSocketReady()
347 rtc::scoped_ptr<rtc::AsyncPacketSocket> socket( in OnServerResolved()
356 if (socket->GetState() == rtc::AsyncPacketSocket::STATE_BINDING) { in OnServerResolved()
|
| D | stunprober.h | 31 class AsyncPacketSocket; variable
175 void OnSocketReady(rtc::AsyncPacketSocket* socket,
236 std::vector<rtc::AsyncPacketSocket*> sockets_;
|