| /external/webrtc/webrtc/base/ |
| asyncpacketsocket.cc | 11 #include "webrtc/base/asyncpacketsocket.h"
23 AsyncPacketSocket::AsyncPacketSocket() {
26 AsyncPacketSocket::~AsyncPacketSocket() {
|
| 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...] |
| testclient.h | 40 explicit TestClient(AsyncPacketSocket* socket);
47 bool CheckConnState(AsyncPacketSocket::State state);
51 return CheckConnState(AsyncPacketSocket::STATE_CONNECTED);
80 // Workaround for the fact that AsyncPacketSocket::GetConnState doesn't exist.
83 void OnPacket(AsyncPacketSocket* socket, const char* buf, size_t len,
86 void OnReadyToSend(AsyncPacketSocket* socket);
89 AsyncPacketSocket* socket_;
|
| asynctcpsocket_unittest.cc | 35 void OnReadyToSend(rtc::AsyncPacketSocket* socket) {
|
| asyncudpsocket_unittest.cc | 35 void OnReadyToSend(rtc::AsyncPacketSocket* socket) {
|
| testechoserver.h | 52 void OnPacket(AsyncPacketSocket* socket, const char* buf, size_t size,
58 void OnClose(AsyncPacketSocket* socket, int err) {
|
| asyncudpsocket.h | 14 #include "webrtc/base/asyncpacketsocket.h"
22 class AsyncUDPSocket : public AsyncPacketSocket {
|
| testclient.cc | 21 TestClient::TestClient(AsyncPacketSocket* socket)
35 bool TestClient::CheckConnState(AsyncPacketSocket::State state) {
121 void TestClient::OnPacket(AsyncPacketSocket* socket, const char* buf,
128 void TestClient::OnReadyToSend(AsyncPacketSocket* socket) {
|
| natserver.h | 78 void OnInternalUDPPacket(AsyncPacketSocket* socket, const char* buf,
81 void OnExternalUDPPacket(AsyncPacketSocket* socket, const char* buf,
|
| /external/webrtc/webrtc/p2p/base/ |
| packetsocketfactory.h | 18 class AsyncPacketSocket;
32 virtual AsyncPacketSocket* CreateUdpSocket(const SocketAddress& address,
35 virtual AsyncPacketSocket* CreateServerTcpSocket(
43 virtual AsyncPacketSocket* CreateClientTcpSocket(
|
| tcpport.h | 17 #include "webrtc/base/asyncpacketsocket.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_
[all...] |
| basicpacketsocketfactory.h | 29 AsyncPacketSocket* CreateUdpSocket(const SocketAddress& local_address,
32 AsyncPacketSocket* CreateServerTcpSocket(const SocketAddress& local_address,
36 AsyncPacketSocket* CreateClientTcpSocket(const SocketAddress& local_address,
|
| 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...] |
| turnserver.h | 20 #include "webrtc/base/asyncpacketsocket.h"
46 rtc::AsyncPacketSocket* socket);
48 rtc::AsyncPacketSocket* socket() { return 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)
[all...] |
| tcpport.cc | 158 if (rtc::AsyncPacketSocket* socket =
176 if (socket_->GetState() == rtc::AsyncPacketSocket::STATE_BOUND ||
177 socket_->GetState() == rtc::AsyncPacketSocket::STATE_CLOSED)
199 rtc::AsyncPacketSocket * socket = NULL;
252 void TCPPort::OnNewConnection(rtc::AsyncPacketSocket* socket,
253 rtc::AsyncPacketSocket* new_socket) {
268 rtc::AsyncPacketSocket* TCPPort::GetIncoming(
270 rtc::AsyncPacketSocket* socket = NULL;
283 void TCPPort::OnReadPacket(rtc::AsyncPacketSocket* socket,
290 void TCPPort::OnSentPacket(rtc::AsyncPacketSocket* socket
[all...] |
| stunport.h | 18 #include "webrtc/base/asyncpacketsocket.h"
34 rtc::AsyncPacketSocket* socket,
91 rtc::AsyncPacketSocket* socket, const char* data, size_t size,
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_;
|
| turnport.h | 20 #include "webrtc/base/asyncpacketsocket.h"
46 rtc::AsyncPacketSocket* socket,
98 rtc::AsyncPacketSocket* socket, const char* data, size_t size,
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 {
159 rtc::AsyncPacketSocket* socket
[all...] |
| basicpacketsocketfactory.cc | 46 AsyncPacketSocket* BasicPacketSocketFactory::CreateUdpSocket(
66 AsyncPacketSocket* BasicPacketSocketFactory::CreateServerTcpSocket(
107 AsyncPacketSocket* BasicPacketSocketFactory::CreateClientTcpSocket(
164 AsyncPacketSocket* tcp_socket;
|
| stunserver.h | 32 rtc::AsyncPacketSocket* socket, const char* buf, size_t size,
|
| testrelayserver.h | 85 void OnInternalClose(rtc::AsyncPacketSocket* socket, int error) {
88 void OnExternalClose(rtc::AsyncPacketSocket* socket, int error) {
|
| relayport.cc | 13 #include "webrtc/base/asyncpacketsocket.h"
31 rtc::AsyncPacketSocket* socket,
34 rtc::AsyncPacketSocket* socket() const { return 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)
[all...] |
| asyncstuntcpsocket_unittest.cc | 94 void OnReadPacket(rtc::AsyncPacketSocket* socket, const char* data,
100 void OnNewConnection(rtc::AsyncPacketSocket* server,
101 rtc::AsyncPacketSocket* new_socket) {
129 rtc::scoped_ptr<rtc::AsyncPacketSocket> listen_socket_;
|
| stunport.cc | 166 rtc::AsyncPacketSocket* socket,
239 if (socket_->GetState() == rtc::AsyncPacketSocket::STATE_BOUND) {
300 void UDPPort::OnLocalAddressReady(rtc::AsyncPacketSocket* socket,
317 void UDPPort::OnReadPacket(rtc::AsyncPacketSocket* socket,
341 void UDPPort::OnSentPacket(rtc::AsyncPacketSocket* socket,
346 void UDPPort::OnReadyToSend(rtc::AsyncPacketSocket* socket) {
397 } else if (socket_->GetState() == rtc::AsyncPacketSocket::STATE_BOUND) {
|
| /external/webrtc/webrtc/p2p/stunprober/ |
| stunprober.h | 31 class AsyncPacketSocket;
175 void OnSocketReady(rtc::AsyncPacketSocket* socket,
236 std::vector<rtc::AsyncPacketSocket*> sockets_;
|
| stunprober.cc | 15 #include "webrtc/base/asyncpacketsocket.h"
64 rtc::AsyncPacketSocket* socket,
73 void OnStunResponseReceived(rtc::AsyncPacketSocket* socket,
92 rtc::scoped_ptr<rtc::AsyncPacketSocket> socket_;
110 rtc::AsyncPacketSocket* socket,
200 rtc::AsyncPacketSocket* socket,
304 void StunProber::OnSocketReady(rtc::AsyncPacketSocket* socket,
347 rtc::scoped_ptr<rtc::AsyncPacketSocket> socket(
356 if (socket->GetState() == rtc::AsyncPacketSocket::STATE_BINDING) {
|
