Home
last modified time | relevance | path

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

12

/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/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_;
Dautodetectproxy.h43 class AsyncSocket; variable
76 void OnConnectEvent(AsyncSocket * socket);
77 void OnReadEvent(AsyncSocket * socket);
78 void OnCloseEvent(AsyncSocket * socket, int error);
84 AsyncSocket* socket_;
Dschanneladapter.h42 SChannelAdapter(AsyncSocket* socket);
59 virtual void OnConnectEvent(AsyncSocket* socket);
60 virtual void OnReadEvent(AsyncSocket* socket);
61 virtual void OnWriteEvent(AsyncSocket* socket);
62 virtual void OnCloseEvent(AsyncSocket* socket, int err);
Dopenssladapter.h48 OpenSSLAdapter(AsyncSocket* socket);
60 virtual void OnConnectEvent(AsyncSocket* socket);
61 virtual void OnReadEvent(AsyncSocket* socket);
62 virtual void OnWriteEvent(AsyncSocket* socket);
63 virtual void OnCloseEvent(AsyncSocket* socket, int err);
Dasynctcpsocket.cc52 AsyncSocket* sock = factory->CreateAsyncSocket(SOCK_STREAM); in Create()
63 AsyncTCPSocket::AsyncTCPSocket(AsyncSocket* socket, bool listen) in AsyncTCPSocket()
213 void AsyncTCPSocket::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
217 void AsyncTCPSocket::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
222 talk_base::AsyncSocket* new_socket = socket->Accept(&address); in OnReadEvent()
256 void AsyncTCPSocket::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
264 void AsyncTCPSocket::OnCloseEvent(AsyncSocket* socket, int error) { in OnCloseEvent()
Dasyncudpsocket.h45 explicit AsyncUDPSocket(AsyncSocket* socket);
62 void OnReadEvent(AsyncSocket* socket);
64 scoped_ptr<AsyncSocket> socket_;
Dsocketadapters.cc58 BufferedReadAdapter::BufferedReadAdapter(AsyncSocket* socket, size_t size) in BufferedReadAdapter()
109 void BufferedReadAdapter::OnReadEvent(AsyncSocket * socket) { in OnReadEvent()
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()
555 void AsyncSocksProxySocket::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
[all …]
Dbasicpacketsocketfactory.cc56 talk_base::AsyncSocket* socket = in CreateUdpSocket()
73 talk_base::AsyncSocket* socket = in CreateServerTcpSocket()
97 talk_base::AsyncSocket* socket = in CreateClientTcpSocket()
137 AsyncSocket* socket, const SocketAddress& local_address, in BindSocket()
Dfirewallsocketserver.cc40 FirewallSocket(FirewallSocketServer* server, AsyncSocket* socket, int type) in FirewallSocket()
99 virtual AsyncSocket* Accept(SocketAddress* paddr) { in Accept()
101 while (AsyncSocket* sock = AsyncSocketAdapter::Accept(&addr)) { in Accept()
197 AsyncSocket* FirewallSocketServer::CreateAsyncSocket(int type) { in CreateAsyncSocket()
201 AsyncSocket* FirewallSocketServer::WrapSocket(AsyncSocket* sock, int type) { in WrapSocket()
Dsslsocketfactory.cc121 AsyncSocket* SslSocketFactory::CreateAsyncSocket(int type) { in CreateAsyncSocket()
129 AsyncSocket* SslSocketFactory::CreateProxySocket(const ProxyInfo& proxy, in CreateProxySocket()
131 AsyncSocket* socket = factory_->CreateAsyncSocket(type); in CreateProxySocket()
142 AsyncSocket* proxy_socket = 0; in CreateProxySocket()
Dasyncudpsocket.cc41 scoped_ptr<AsyncSocket> socket(factory->CreateAsyncSocket(SOCK_DGRAM)); in Create()
51 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket) in AsyncUDPSocket()
108 void AsyncUDPSocket::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
Dopenssladapter.cc73 BIO* BIO_new_socket(talk_base::AsyncSocket* socket) { in BIO_new_socket()
99 talk_base::AsyncSocket* socket = static_cast<talk_base::AsyncSocket*>(b->ptr); in socket_read()
115 talk_base::AsyncSocket* socket = static_cast<talk_base::AsyncSocket*>(b->ptr); in socket_write()
237 OpenSSLAdapter::OpenSSLAdapter(AsyncSocket* socket) in OpenSSLAdapter()
536 OpenSSLAdapter::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
551 OpenSSLAdapter::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
581 OpenSSLAdapter::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
612 OpenSSLAdapter::OnCloseEvent(AsyncSocket* socket, int err) { in OnCloseEvent()
Dssladapter.h39 SSLAdapter(AsyncSocket* socket) in SSLAdapter()
51 static SSLAdapter* Create(AsyncSocket* socket);
Dfirewallsocketserver.h79 virtual AsyncSocket* CreateAsyncSocket(int type);
91 AsyncSocket * WrapSocket(AsyncSocket * sock, int type);
Dbasicpacketsocketfactory.h36 class AsyncSocket; variable
56 int BindSocket(AsyncSocket* socket, const SocketAddress& local_address,
/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/third_party/libjingle/source/talk/p2p/base/
Drelayserver.h76 void AddInternalServerSocket(talk_base::AsyncSocket* socket,
80 void RemoveInternalServerSocket(talk_base::AsyncSocket* socket);
89 typedef std::map<talk_base::AsyncSocket*,
111 void OnReadEvent(talk_base::AsyncSocket* socket);
139 void AcceptConnection(talk_base::AsyncSocket* server_socket);

12