| /external/webrtc/webrtc/base/ |
| D | asyncsocket.h | 23 class AsyncSocket : public Socket {
25 AsyncSocket();
26 ~AsyncSocket() override;
28 AsyncSocket* Accept(SocketAddress* paddr) override = 0;
35 sigslot::signal1<AsyncSocket*,
38 sigslot::signal1<AsyncSocket*,
40 sigslot::signal1<AsyncSocket*> SignalConnectEvent; // connected
41 sigslot::signal2<AsyncSocket*, int> SignalCloseEvent; // closed
44 class AsyncSocketAdapter : public AsyncSocket, public sigslot::has_slots<> {
50 explicit AsyncSocketAdapter(AsyncSocket* socket);
[all …]
|
| D | proxyserver.h | 33 ProxyBinding(AsyncProxyServerSocket* in_socket, AsyncSocket* out_socket);
40 void OnInternalRead(AsyncSocket* socket);
41 void OnInternalWrite(AsyncSocket* socket);
42 void OnInternalClose(AsyncSocket* socket, int err);
43 void OnExternalConnect(AsyncSocket* socket);
44 void OnExternalRead(AsyncSocket* socket);
45 void OnExternalWrite(AsyncSocket* socket);
46 void OnExternalClose(AsyncSocket* socket, int err);
48 static void Read(AsyncSocket* socket, FifoBuffer* buffer);
49 static void Write(AsyncSocket* socket, FifoBuffer* buffer);
[all …]
|
| D | socket_unittest.cc | 197 scoped_ptr<AsyncSocket> client(ss_->CreateAsyncSocket(loopback.family(), in ConnectInternal()
200 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState()); in ConnectInternal()
204 scoped_ptr<AsyncSocket> server( in ConnectInternal()
209 EXPECT_EQ(AsyncSocket::CS_CONNECTING, server->GetState()); in ConnectInternal()
222 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectInternal()
228 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr)); in ConnectInternal()
234 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState()); in ConnectInternal()
239 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in ConnectInternal()
252 scoped_ptr<AsyncSocket> client( in ConnectWithDnsLookupInternal()
257 scoped_ptr<AsyncSocket> server( in ConnectWithDnsLookupInternal()
[all …]
|
| D | asynctcpsocket.h | 25 AsyncTCPSocketBase(AsyncSocket* socket, bool listen, size_t max_packet_size);
33 virtual void HandleIncomingConnection(AsyncSocket* socket) = 0;
53 static AsyncSocket* ConnectSocket(AsyncSocket* socket,
67 void OnConnectEvent(AsyncSocket* socket);
68 void OnReadEvent(AsyncSocket* socket);
69 void OnWriteEvent(AsyncSocket* socket);
70 void OnCloseEvent(AsyncSocket* socket, int error);
72 scoped_ptr<AsyncSocket> socket_;
85 static AsyncTCPSocket* Create(AsyncSocket* socket,
88 AsyncTCPSocket(AsyncSocket* socket, bool listen);
[all …]
|
| D | socketstream.h | 24 explicit SocketStream(AsyncSocket* socket);
27 void Attach(AsyncSocket* socket);
28 AsyncSocket* Detach();
30 AsyncSocket* GetSocket() { return socket_; } in GetSocket()
47 void OnConnectEvent(AsyncSocket* socket);
48 void OnReadEvent(AsyncSocket* socket);
49 void OnWriteEvent(AsyncSocket* socket);
50 void OnCloseEvent(AsyncSocket* socket, int err);
52 AsyncSocket* socket_;
|
| D | asyncsocket.cc | 15 AsyncSocket::AsyncSocket() { in AsyncSocket() function in rtc::AsyncSocket
18 AsyncSocket::~AsyncSocket() { in ~AsyncSocket()
21 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) { in AsyncSocketAdapter()
29 void AsyncSocketAdapter::Attach(AsyncSocket* socket) { in Attach()
79 AsyncSocket* AsyncSocketAdapter::Accept(SocketAddress* paddr) { in Accept()
95 AsyncSocket::ConnState AsyncSocketAdapter::GetState() const { in GetState()
111 void AsyncSocketAdapter::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
115 void AsyncSocketAdapter::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
119 void AsyncSocketAdapter::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
123 void AsyncSocketAdapter::OnCloseEvent(AsyncSocket* socket, int err) { in OnCloseEvent()
|
| D | proxyserver.cc | 43 void ProxyServer::OnAcceptEvent(AsyncSocket* socket) { in OnAcceptEvent()
45 AsyncSocket* int_socket = socket->Accept(NULL); in OnAcceptEvent()
47 AsyncSocket* ext_socket = ext_factory_->CreateAsyncSocket(ext_ip_.family(), in OnAcceptEvent()
66 AsyncSocket* ext_socket) in ProxyBinding()
90 void ProxyBinding::OnInternalRead(AsyncSocket* socket) { in OnInternalRead()
95 void ProxyBinding::OnInternalWrite(AsyncSocket* socket) { in OnInternalWrite()
99 void ProxyBinding::OnInternalClose(AsyncSocket* socket, int err) { in OnInternalClose()
103 void ProxyBinding::OnExternalConnect(AsyncSocket* socket) { in OnExternalConnect()
109 void ProxyBinding::OnExternalRead(AsyncSocket* socket) { in OnExternalRead()
114 void ProxyBinding::OnExternalWrite(AsyncSocket* socket) { in OnExternalWrite()
[all …]
|
| D | socketadapters.h | 33 BufferedReadAdapter(AsyncSocket* socket, size_t buffer_size);
47 void OnReadEvent(AsyncSocket* socket) override;
61 AsyncProxyServerSocket(AsyncSocket* socket, size_t buffer_size);
74 explicit AsyncSSLSocket(AsyncSocket* socket);
79 void OnConnectEvent(AsyncSocket* socket) override;
88 explicit AsyncSSLServerSocket(AsyncSocket* socket);
100 AsyncHttpsProxySocket(AsyncSocket* socket, const std::string& user_agent,
116 void OnConnectEvent(AsyncSocket* socket) override;
117 void OnCloseEvent(AsyncSocket* socket, int err) override;
160 AsyncSocksProxySocket(AsyncSocket* socket, const SocketAddress& proxy,
[all …]
|
| D | virtualsocket_unittest.cc | 30 Sender(Thread* th, AsyncSocket* s, uint32_t rt) in Sender()
76 Receiver(Thread* th, AsyncSocket* s, uint32_t bw) in Receiver()
169 AsyncSocket* socket = in TestDefaultRoute()
177 AsyncSocket* socket2 = in TestDefaultRoute()
198 AsyncSocket* socket = ss_->CreateAsyncSocket(initial_addr.family(), in BasicTest()
206 AsyncSocket* socket2 = in BasicTest()
246 AsyncSocket* client = ss_->CreateAsyncSocket(initial_addr.family(), in ConnectTest()
249 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in ConnectTest()
253 AsyncSocket* server = ss_->CreateAsyncSocket(initial_addr.family(), in ConnectTest()
260 EXPECT_EQ(server->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
[all …]
|
| D | ssladapter_unittest.cc | 24 static rtc::AsyncSocket* CreateSocket(const rtc::SSLMode& ssl_mode) { in CreateSocket()
27 rtc::AsyncSocket* socket = rtc::Thread::Current()-> in CreateSocket()
44 rtc::AsyncSocket* socket = CreateSocket(ssl_mode_); in SSLAdapterTestDummyClient()
65 rtc::AsyncSocket::ConnState GetState() const { in GetState()
100 void OnSSLAdapterReadEvent(rtc::AsyncSocket* socket) { in OnSSLAdapterReadEvent()
114 void OnSSLAdapterCloseEvent(rtc::AsyncSocket* socket, int error) { in OnSSLAdapterCloseEvent()
118 if (socket->GetState() != rtc::AsyncSocket::CS_CLOSED) { in OnSSLAdapterCloseEvent()
195 rtc::AsyncSocket* socket = server_socket_.release(); in AcceptConnection()
202 void OnServerSocketReadEvent(rtc::AsyncSocket* socket) { in OnServerSocketReadEvent()
231 void DoHandshake(rtc::AsyncSocket* socket) { in DoHandshake()
[all …]
|
| D | asynctcpsocket.cc | 35 AsyncSocket* AsyncTCPSocketBase::ConnectSocket( in ConnectSocket()
36 rtc::AsyncSocket* socket, in ConnectSocket()
39 rtc::scoped_ptr<rtc::AsyncSocket> owned_socket(socket); in ConnectSocket()
51 AsyncTCPSocketBase::AsyncTCPSocketBase(AsyncSocket* socket, bool listen, in AsyncTCPSocketBase()
174 void AsyncTCPSocketBase::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
178 void AsyncTCPSocketBase::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
183 rtc::AsyncSocket* new_socket = socket->Accept(&address); in OnReadEvent()
217 void AsyncTCPSocketBase::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
229 void AsyncTCPSocketBase::OnCloseEvent(AsyncSocket* socket, int error) { in OnCloseEvent()
238 AsyncSocket* socket, in Create()
[all …]
|
| D | socketstream.cc | 15 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { in SocketStream()
23 void SocketStream::Attach(AsyncSocket* socket) { in Attach()
35 AsyncSocket* SocketStream::Detach() { in Detach()
36 AsyncSocket* socket = socket_; in Detach()
100 void SocketStream::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
105 void SocketStream::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
110 void SocketStream::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
115 void SocketStream::OnCloseEvent(AsyncSocket* socket, int err) { in OnCloseEvent()
|
| D | testutils.h | 77 void Monitor(AsyncSocket* socket) { in Monitor()
85 void Unmonitor(AsyncSocket* socket) { in Unmonitor()
92 bool Check(AsyncSocket* socket, StreamSinkEvent event, bool reset = true) {
95 int Events(AsyncSocket* socket, bool reset = true) {
108 void OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
111 void OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
114 void OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
117 void OnCloseEvent(AsyncSocket* socket, int error) { in OnCloseEvent()
281 SocketTestClient(AsyncSocket* socket) { in SocketTestClient()
289 AsyncSocket* socket() { return socket_.get(); } in socket()
[all …]
|
| D | asyncudpsocket.h | 27 static AsyncUDPSocket* Create(AsyncSocket* socket,
33 explicit AsyncUDPSocket(AsyncSocket* socket);
55 void OnReadEvent(AsyncSocket* socket);
57 void OnWriteEvent(AsyncSocket* socket);
59 scoped_ptr<AsyncSocket> socket_;
|
| D | natsocketfactory.h | 31 virtual AsyncSocket* CreateInternalSocket(int family, int type,
46 AsyncSocket* CreateAsyncSocket(int type) override;
47 AsyncSocket* CreateAsyncSocket(int family, int type) override;
50 AsyncSocket* CreateInternalSocket(int family,
139 AsyncSocket* CreateAsyncSocket(int type) override;
140 AsyncSocket* CreateAsyncSocket(int family, int type) override;
147 AsyncSocket* CreateInternalSocket(int family,
|
| D | autodetectproxy.h | 29 class AsyncSocket; variable
70 void OnConnectEvent(AsyncSocket * socket);
71 void OnReadEvent(AsyncSocket * socket);
72 void OnCloseEvent(AsyncSocket * socket, int error);
81 AsyncSocket* socket_;
|
| D | asyncudpsocket.cc | 19 AsyncSocket* socket, in Create()
21 scoped_ptr<AsyncSocket> owned_socket(socket); in Create()
31 AsyncSocket* socket = in Create()
38 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket) in AsyncUDPSocket()
102 void AsyncUDPSocket::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
124 void AsyncUDPSocket::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
|
| D | natsocketfactory.cc | 70 class NATSocket : public AsyncSocket, public sigslot::has_slots<> {
217 AsyncSocket* Accept(SocketAddress* paddr) override { in Accept()
233 void OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
243 void OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
252 void OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
256 void OnCloseEvent(AsyncSocket* socket, int error) { in OnCloseEvent()
297 AsyncSocket* socket_;
318 AsyncSocket* NATSocketFactory::CreateAsyncSocket(int type) { in CreateAsyncSocket()
322 AsyncSocket* NATSocketFactory::CreateAsyncSocket(int family, int type) { in CreateAsyncSocket()
326 AsyncSocket* NATSocketFactory::CreateInternalSocket(int family, int type, in CreateInternalSocket()
[all …]
|
| D | physicalsocketserver_unittest.cc | 42 AsyncSocket* CreateAsyncSocket(int type) override { in CreateAsyncSocket()
52 AsyncSocket* CreateAsyncSocket(int family, int type) override { in CreateAsyncSocket()
131 scoped_ptr<AsyncSocket> client1(server_->CreateAsyncSocket(loopback.family(), in ConnectInternalAcceptError()
134 EXPECT_EQ(AsyncSocket::CS_CLOSED, client1->GetState()); in ConnectInternalAcceptError()
137 scoped_ptr<AsyncSocket> client2(server_->CreateAsyncSocket(loopback.family(), in ConnectInternalAcceptError()
140 EXPECT_EQ(AsyncSocket::CS_CLOSED, client2->GetState()); in ConnectInternalAcceptError()
144 scoped_ptr<AsyncSocket> server( in ConnectInternalAcceptError()
149 EXPECT_EQ(AsyncSocket::CS_CONNECTING, server->GetState()); in ConnectInternalAcceptError()
162 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client1->GetState()); in ConnectInternalAcceptError()
170 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr)); in ConnectInternalAcceptError()
[all …]
|
| D | openssladapter.h | 33 OpenSSLAdapter(AsyncSocket* socket);
48 void OnConnectEvent(AsyncSocket* socket) override;
49 void OnReadEvent(AsyncSocket* socket) override;
50 void OnWriteEvent(AsyncSocket* socket) override;
51 void OnCloseEvent(AsyncSocket* socket, int err) override;
|
| D | socketadapters.cc | 43 BufferedReadAdapter::BufferedReadAdapter(AsyncSocket* socket, size_t size) in BufferedReadAdapter()
102 void BufferedReadAdapter::OnReadEvent(AsyncSocket * socket) { in OnReadEvent()
128 AsyncProxyServerSocket::AsyncProxyServerSocket(AsyncSocket* socket, in AsyncProxyServerSocket()
177 AsyncSSLSocket::AsyncSSLSocket(AsyncSocket* socket) in AsyncSSLSocket()
188 void AsyncSSLSocket::OnConnectEvent(AsyncSocket * socket) { in OnConnectEvent()
219 AsyncSSLServerSocket::AsyncSSLServerSocket(AsyncSocket* socket) in AsyncSSLServerSocket()
250 AsyncHttpsProxySocket::AsyncHttpsProxySocket(AsyncSocket* socket, in AsyncHttpsProxySocket()
301 void AsyncHttpsProxySocket::OnConnectEvent(AsyncSocket * socket) { in OnConnectEvent()
311 void AsyncHttpsProxySocket::OnCloseEvent(AsyncSocket * socket, int err) { in OnCloseEvent()
517 AsyncSocksProxySocket::AsyncSocksProxySocket(AsyncSocket* socket, in AsyncSocksProxySocket()
[all …]
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | xmppsocket.cc | 35 state_ = buzz::AsyncSocket::STATE_CLOSED; in XmppSocket()
43 rtc::AsyncSocket* socket = in CreateCricketSocket()
78 void XmppSocket::OnReadEvent(rtc::AsyncSocket * socket) { in OnReadEvent()
82 void XmppSocket::OnWriteEvent(rtc::AsyncSocket * socket) { in OnWriteEvent()
96 void XmppSocket::OnConnectEvent(rtc::AsyncSocket * socket) { in OnConnectEvent()
98 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) { in OnConnectEvent()
99 state_ = buzz::AsyncSocket::STATE_TLS_OPEN; in OnConnectEvent()
105 state_ = buzz::AsyncSocket::STATE_OPEN; in OnConnectEvent()
109 void XmppSocket::OnCloseEvent(rtc::AsyncSocket * socket, int error) { in OnCloseEvent()
119 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) { in OnEvent()
[all …]
|
| D | xmppsocket.h | 28 extern rtc::AsyncSocket* cricket_socket_;
32 class XmppSocket : public buzz::AsyncSocket, public sigslot::has_slots<> {
37 virtual buzz::AsyncSocket::State state();
38 virtual buzz::AsyncSocket::Error error();
52 void OnReadEvent(rtc::AsyncSocket * socket);
53 void OnWriteEvent(rtc::AsyncSocket * socket);
54 void OnConnectEvent(rtc::AsyncSocket * socket);
55 void OnCloseEvent(rtc::AsyncSocket * socket, int error);
60 rtc::AsyncSocket * cricket_socket_;
64 buzz::AsyncSocket::State state_;
|
| /external/webrtc/webrtc/p2p/base/ |
| D | testrelayserver.h | 55 rtc::AsyncSocket* CreateListenSocket(rtc::Thread* thread, in CreateListenSocket()
57 rtc::AsyncSocket* socket = in CreateListenSocket()
64 void OnAccept(rtc::AsyncSocket* socket) { in OnAccept()
69 rtc::AsyncSocket* raw_socket = socket->Accept(NULL); in OnAccept()
93 rtc::scoped_ptr<rtc::AsyncSocket> tcp_int_socket_;
94 rtc::scoped_ptr<rtc::AsyncSocket> tcp_ext_socket_;
95 rtc::scoped_ptr<rtc::AsyncSocket> ssl_int_socket_;
96 rtc::scoped_ptr<rtc::AsyncSocket> ssl_ext_socket_;
|
| /external/webrtc/webrtc/examples/peerconnection/client/ |
| D | peer_connection_client.h | 77 void OnConnect(rtc::AsyncSocket* socket);
78 void OnHangingGetConnect(rtc::AsyncSocket* socket);
89 bool ReadIntoBuffer(rtc::AsyncSocket* socket, std::string* data,
92 void OnRead(rtc::AsyncSocket* socket);
94 void OnHangingGetRead(rtc::AsyncSocket* socket);
105 void OnClose(rtc::AsyncSocket* socket, int err);
112 rtc::scoped_ptr<rtc::AsyncSocket> control_socket_;
113 rtc::scoped_ptr<rtc::AsyncSocket> hanging_get_;
|