Home
last modified time | relevance | path

Searched refs:AsyncSocket (Results 1 – 25 of 130) sorted by relevance

123456

/external/qemu/android/
Dasync-socket.h42 typedef struct AsyncSocket AsyncSocket; typedef
56 AsyncSocket* as,
95 extern AsyncSocket* async_socket_io_get_socket(const AsyncSocketIO* asio);
147 extern AsyncSocket* async_socket_new(int port,
159 extern int async_socket_reference(AsyncSocket* as);
169 extern int async_socket_release(AsyncSocket* as);
179 extern void async_socket_connect(AsyncSocket* as, int retry_to);
187 extern void async_socket_disconnect(AsyncSocket* as);
196 extern void async_socket_reconnect(AsyncSocket* as, int retry_to);
206 extern void async_socket_read_abs(AsyncSocket* as,
[all …]
Dasync-socket.c47 static const char* _async_socket_string(AsyncSocket* as);
50 static Looper* _async_socket_get_looper(AsyncSocket* as);
57 static AsyncIOAction _async_socket_io_timed_out(AsyncSocket* as,
68 AsyncSocket* as;
125 _async_socket_rw_new(AsyncSocket* as, in _async_socket_rw_new()
172 AsyncSocket* const as = asio->as; in _async_socket_io_free()
233 _async_socket_reader_new(AsyncSocket* as, in _async_socket_reader_new()
256 _async_socket_writer_new(AsyncSocket* as, in _async_socket_writer_new()
274 AsyncSocket* const as = asio->as; in _on_async_socket_io_timed_out()
290 AsyncSocket*
[all …]
/external/chromium_org/third_party/libjingle/source/talk/base/
Dproxyserver.h50 ProxyBinding(AsyncProxyServerSocket* in_socket, AsyncSocket* out_socket);
56 void OnInternalRead(AsyncSocket* socket);
57 void OnInternalWrite(AsyncSocket* socket);
58 void OnInternalClose(AsyncSocket* socket, int err);
59 void OnExternalConnect(AsyncSocket* socket);
60 void OnExternalRead(AsyncSocket* socket);
61 void OnExternalWrite(AsyncSocket* socket);
62 void OnExternalClose(AsyncSocket* socket, int err);
64 static void Read(AsyncSocket* socket, FifoBuffer* buffer);
65 static void Write(AsyncSocket* socket, FifoBuffer* buffer);
[all …]
Dasyncsocket.h40 class AsyncSocket : public Socket {
42 AsyncSocket();
43 virtual ~AsyncSocket();
45 virtual AsyncSocket* Accept(SocketAddress* paddr) = 0;
52 sigslot::signal1<AsyncSocket*,
55 sigslot::signal1<AsyncSocket*,
57 sigslot::signal1<AsyncSocket*> SignalConnectEvent; // connected
58 sigslot::signal2<AsyncSocket*, int> SignalCloseEvent; // closed
61 class AsyncSocketAdapter : public AsyncSocket, public sigslot::has_slots<> {
67 explicit AsyncSocketAdapter(AsyncSocket* socket);
[all …]
Dasynctcpsocket.h42 AsyncTCPSocketBase(AsyncSocket* socket, bool listen, size_t max_packet_size);
49 virtual void HandleIncomingConnection(AsyncSocket* socket) = 0;
67 static AsyncSocket* ConnectSocket(AsyncSocket* socket,
81 void OnConnectEvent(AsyncSocket* socket);
82 void OnReadEvent(AsyncSocket* socket);
83 void OnWriteEvent(AsyncSocket* socket);
84 void OnCloseEvent(AsyncSocket* socket, int error);
86 scoped_ptr<AsyncSocket> socket_;
99 static AsyncTCPSocket* Create(AsyncSocket* socket,
102 AsyncTCPSocket(AsyncSocket* socket, bool listen);
[all …]
Dsocketstream.h41 explicit SocketStream(AsyncSocket* socket);
44 void Attach(AsyncSocket* socket);
45 AsyncSocket* Detach();
47 AsyncSocket* GetSocket() { return socket_; } in GetSocket()
60 void OnConnectEvent(AsyncSocket* socket);
61 void OnReadEvent(AsyncSocket* socket);
62 void OnWriteEvent(AsyncSocket* socket);
63 void OnCloseEvent(AsyncSocket* socket, int err);
65 AsyncSocket* socket_;
Dsocket_unittest.cc213 scoped_ptr<AsyncSocket> client(ss_->CreateAsyncSocket(loopback.family(), in ConnectInternal()
216 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState()); in ConnectInternal()
220 scoped_ptr<AsyncSocket> server( in ConnectInternal()
225 EXPECT_EQ(AsyncSocket::CS_CONNECTING, server->GetState()); in ConnectInternal()
238 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectInternal()
244 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr)); in ConnectInternal()
250 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState()); in ConnectInternal()
255 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in ConnectInternal()
268 scoped_ptr<AsyncSocket> client( in ConnectWithDnsLookupInternal()
273 scoped_ptr<AsyncSocket> server( in ConnectWithDnsLookupInternal()
[all …]
Dproxyserver.cc56 void ProxyServer::OnAcceptEvent(AsyncSocket* socket) { in OnAcceptEvent()
58 AsyncSocket* int_socket = socket->Accept(NULL); in OnAcceptEvent()
60 AsyncSocket* ext_socket = ext_factory_->CreateAsyncSocket(ext_ip_.family(), in OnAcceptEvent()
79 AsyncSocket* ext_socket) in ProxyBinding()
101 void ProxyBinding::OnInternalRead(AsyncSocket* socket) { in OnInternalRead()
106 void ProxyBinding::OnInternalWrite(AsyncSocket* socket) { in OnInternalWrite()
110 void ProxyBinding::OnInternalClose(AsyncSocket* socket, int err) { in OnInternalClose()
114 void ProxyBinding::OnExternalConnect(AsyncSocket* socket) { in OnExternalConnect()
120 void ProxyBinding::OnExternalRead(AsyncSocket* socket) { in OnExternalRead()
125 void ProxyBinding::OnExternalWrite(AsyncSocket* socket) { in OnExternalWrite()
[all …]
Dsocketadapters.h50 BufferedReadAdapter(AsyncSocket* socket, size_t buffer_size);
64 virtual void OnReadEvent(AsyncSocket * socket);
78 AsyncProxyServerSocket(AsyncSocket* socket, size_t buffer_size) in AsyncProxyServerSocket()
91 explicit AsyncSSLSocket(AsyncSocket* socket);
96 virtual void OnConnectEvent(AsyncSocket* socket);
105 explicit AsyncSSLServerSocket(AsyncSocket* socket);
117 AsyncHttpsProxySocket(AsyncSocket* socket, const std::string& user_agent,
133 virtual void OnConnectEvent(AsyncSocket* socket);
134 virtual void OnCloseEvent(AsyncSocket* socket, int err);
177 AsyncSocksProxySocket(AsyncSocket* socket, const SocketAddress& proxy,
[all …]
Dasyncsocket.cc32 AsyncSocket::AsyncSocket() { in AsyncSocket() function in talk_base::AsyncSocket
35 AsyncSocket::~AsyncSocket() { in ~AsyncSocket()
38 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) { in AsyncSocketAdapter()
46 void AsyncSocketAdapter::Attach(AsyncSocket* socket) { in Attach()
Dsocketstream.cc32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { in SocketStream()
40 void SocketStream::Attach(AsyncSocket* socket) { in Attach()
52 AsyncSocket* SocketStream::Detach() { in Detach()
53 AsyncSocket* socket = socket_; in Detach()
117 void SocketStream::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
122 void SocketStream::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
127 void SocketStream::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
132 void SocketStream::OnCloseEvent(AsyncSocket* socket, int err) { in OnCloseEvent()
Dasynctcpsocket.cc52 AsyncSocket* AsyncTCPSocketBase::ConnectSocket( in ConnectSocket()
53 talk_base::AsyncSocket* socket, in ConnectSocket()
56 talk_base::scoped_ptr<talk_base::AsyncSocket> owned_socket(socket); in ConnectSocket()
68 AsyncTCPSocketBase::AsyncTCPSocketBase(AsyncSocket* socket, bool listen, in AsyncTCPSocketBase()
191 void AsyncTCPSocketBase::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
195 void AsyncTCPSocketBase::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
200 talk_base::AsyncSocket* new_socket = socket->Accept(&address); in OnReadEvent()
234 void AsyncTCPSocketBase::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
246 void AsyncTCPSocketBase::OnCloseEvent(AsyncSocket* socket, int error) { in OnCloseEvent()
255 AsyncSocket* socket, in Create()
[all …]
Dvirtualsocket_unittest.cc46 Sender(Thread* th, AsyncSocket* s, uint32 rt) in Sender()
88 Receiver(Thread* th, AsyncSocket* s, uint32 bw) in Receiver()
169 AsyncSocket* socket = ss_->CreateAsyncSocket(initial_addr.family(), in BasicTest()
177 AsyncSocket* socket2 = in BasicTest()
217 AsyncSocket* client = ss_->CreateAsyncSocket(initial_addr.family(), in ConnectTest()
220 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in ConnectTest()
224 AsyncSocket* server = ss_->CreateAsyncSocket(initial_addr.family(), in ConnectTest()
231 EXPECT_EQ(server->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
245 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
252 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
[all …]
/external/chromium/third_party/libjingle/source/talk/base/
Dasyncsocket.h40 class AsyncSocket : public Socket {
42 AsyncSocket();
43 virtual ~AsyncSocket();
45 virtual AsyncSocket* Accept(SocketAddress* paddr) = 0;
47 sigslot::signal1<AsyncSocket*> SignalReadEvent; // ready to read
48 sigslot::signal1<AsyncSocket*> SignalWriteEvent; // ready to write
49 sigslot::signal1<AsyncSocket*> SignalConnectEvent; // connected
50 sigslot::signal2<AsyncSocket*, int> SignalCloseEvent; // closed
53 class AsyncSocketAdapter : public AsyncSocket, public sigslot::has_slots<> {
59 explicit AsyncSocketAdapter(AsyncSocket* socket);
[all …]
Dsocketstream.h41 explicit SocketStream(AsyncSocket* socket);
44 void Attach(AsyncSocket* socket);
45 AsyncSocket* Detach();
47 AsyncSocket* GetSocket() { return socket_; } in GetSocket()
60 void OnConnectEvent(AsyncSocket* socket);
61 void OnReadEvent(AsyncSocket* socket);
62 void OnWriteEvent(AsyncSocket* socket);
63 void OnCloseEvent(AsyncSocket* socket, int err);
65 AsyncSocket* socket_;
Dsocketadapters.h50 BufferedReadAdapter(AsyncSocket* socket, size_t buffer_size);
64 virtual void OnReadEvent(AsyncSocket * socket);
78 AsyncProxyServerSocket(AsyncSocket* socket, size_t buffer_size) in AsyncProxyServerSocket()
91 explicit AsyncSSLSocket(AsyncSocket* socket);
96 virtual void OnConnectEvent(AsyncSocket* socket);
105 explicit AsyncSSLServerSocket(AsyncSocket* socket);
117 AsyncHttpsProxySocket(AsyncSocket* socket, const std::string& user_agent,
133 virtual void OnConnectEvent(AsyncSocket* socket);
134 virtual void OnCloseEvent(AsyncSocket* socket, int err);
177 AsyncSocksProxySocket(AsyncSocket* socket, const SocketAddress& proxy,
[all …]
Dasyncsocket.cc32 AsyncSocket::AsyncSocket() { in AsyncSocket() function in talk_base::AsyncSocket
35 AsyncSocket::~AsyncSocket() { in ~AsyncSocket()
38 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) { in AsyncSocketAdapter()
46 void AsyncSocketAdapter::Attach(AsyncSocket* socket) { in Attach()
Dsocketstream.cc32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { in SocketStream()
40 void SocketStream::Attach(AsyncSocket* socket) { in Attach()
52 AsyncSocket* SocketStream::Detach() { in Detach()
53 AsyncSocket* socket = socket_; in Detach()
117 void SocketStream::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
122 void SocketStream::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
127 void SocketStream::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
132 void SocketStream::OnCloseEvent(AsyncSocket* socket, int err) { in OnCloseEvent()
Dasynctcpsocket.h43 explicit AsyncTCPSocket(AsyncSocket* socket, bool listen);
66 void OnConnectEvent(AsyncSocket* socket);
67 void OnReadEvent(AsyncSocket* socket);
68 void OnWriteEvent(AsyncSocket* socket);
69 void OnCloseEvent(AsyncSocket* socket, int error);
71 scoped_ptr<AsyncSocket> socket_;
/external/chromium_org/third_party/libjingle/source/talk/xmpp/
Dxmppsocket.cc53 state_ = buzz::AsyncSocket::STATE_CLOSED; in XmppSocket()
61 talk_base::AsyncSocket* socket = in CreateCricketSocket()
96 void XmppSocket::OnReadEvent(talk_base::AsyncSocket * socket) { in OnReadEvent()
100 void XmppSocket::OnWriteEvent(talk_base::AsyncSocket * socket) { in OnWriteEvent()
114 void XmppSocket::OnConnectEvent(talk_base::AsyncSocket * socket) { in OnConnectEvent()
116 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) { in OnConnectEvent()
117 state_ = buzz::AsyncSocket::STATE_TLS_OPEN; in OnConnectEvent()
123 state_ = buzz::AsyncSocket::STATE_OPEN; in OnConnectEvent()
127 void XmppSocket::OnCloseEvent(talk_base::AsyncSocket * socket, int error) { in OnCloseEvent()
137 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) { in OnEvent()
[all …]
Dxmppsocket.h45 extern talk_base::AsyncSocket* cricket_socket_;
49 class XmppSocket : public buzz::AsyncSocket, public sigslot::has_slots<> {
54 virtual buzz::AsyncSocket::State state();
55 virtual buzz::AsyncSocket::Error error();
69 void OnReadEvent(talk_base::AsyncSocket * socket);
70 void OnWriteEvent(talk_base::AsyncSocket * socket);
71 void OnConnectEvent(talk_base::AsyncSocket * socket);
72 void OnCloseEvent(talk_base::AsyncSocket * socket, int error);
77 talk_base::AsyncSocket * cricket_socket_;
81 buzz::AsyncSocket::State state_;
/external/chromium/third_party/libjingle/source/talk/examples/login/
Dxmppsocket.cc50 talk_base::AsyncSocket* socket = in XmppSocket()
74 state_ = buzz::AsyncSocket::STATE_CLOSED; in XmppSocket()
87 void XmppSocket::OnReadEvent(talk_base::AsyncSocket * socket) { in OnReadEvent()
91 void XmppSocket::OnWriteEvent(talk_base::AsyncSocket * socket) { in OnWriteEvent()
105 void XmppSocket::OnConnectEvent(talk_base::AsyncSocket * socket) { in OnConnectEvent()
107 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) { in OnConnectEvent()
108 state_ = buzz::AsyncSocket::STATE_TLS_OPEN; in OnConnectEvent()
114 state_ = buzz::AsyncSocket::STATE_OPEN; in OnConnectEvent()
118 void XmppSocket::OnCloseEvent(talk_base::AsyncSocket * socket, int error) { in OnCloseEvent()
128 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) { in OnEvent()
[all …]
Dxmppsocket.h43 extern talk_base::AsyncSocket* cricket_socket_;
45 class XmppSocket : public buzz::AsyncSocket, public sigslot::has_slots<> {
50 virtual buzz::AsyncSocket::State state();
51 virtual buzz::AsyncSocket::Error error();
64 void OnReadEvent(talk_base::AsyncSocket * socket);
65 void OnWriteEvent(talk_base::AsyncSocket * socket);
66 void OnConnectEvent(talk_base::AsyncSocket * socket);
67 void OnCloseEvent(talk_base::AsyncSocket * socket, int error);
72 talk_base::AsyncSocket * cricket_socket_;
76 buzz::AsyncSocket::State state_;
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
Dtestrelayserver.h72 talk_base::AsyncSocket* CreateListenSocket(talk_base::Thread* thread, in CreateListenSocket()
74 talk_base::AsyncSocket* socket = in CreateListenSocket()
81 void OnAccept(talk_base::AsyncSocket* socket) { in OnAccept()
86 talk_base::AsyncSocket* raw_socket = socket->Accept(NULL); in OnAccept()
110 talk_base::scoped_ptr<talk_base::AsyncSocket> tcp_int_socket_;
111 talk_base::scoped_ptr<talk_base::AsyncSocket> tcp_ext_socket_;
112 talk_base::scoped_ptr<talk_base::AsyncSocket> ssl_int_socket_;
113 talk_base::scoped_ptr<talk_base::AsyncSocket> ssl_ext_socket_;
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/client/
Dpeer_connection_client.h94 void OnConnect(talk_base::AsyncSocket* socket);
95 void OnHangingGetConnect(talk_base::AsyncSocket* socket);
106 bool ReadIntoBuffer(talk_base::AsyncSocket* socket, std::string* data,
109 void OnRead(talk_base::AsyncSocket* socket);
111 void OnHangingGetRead(talk_base::AsyncSocket* socket);
122 void OnClose(talk_base::AsyncSocket* socket, int err);
129 talk_base::scoped_ptr<talk_base::AsyncSocket> control_socket_;
130 talk_base::scoped_ptr<talk_base::AsyncSocket> hanging_get_;

123456