Searched refs:AsyncSocket (Results 1 - 25 of 89) sorted by relevance

1234

/external/chromium_org/third_party/webrtc/base/
H A Dsocketstream.h24 explicit SocketStream(AsyncSocket* socket);
27 void Attach(AsyncSocket* socket);
28 AsyncSocket* Detach();
30 AsyncSocket* GetSocket() { return socket_; }
43 void OnConnectEvent(AsyncSocket* socket);
44 void OnReadEvent(AsyncSocket* socket);
45 void OnWriteEvent(AsyncSocket* socket);
46 void OnCloseEvent(AsyncSocket* socket, int err);
48 AsyncSocket* socket_;
H A Dasyncsocket.cc15 AsyncSocket::AsyncSocket() { function in class:rtc::AsyncSocket
18 AsyncSocket::~AsyncSocket() {
21 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) {
29 void AsyncSocketAdapter::Attach(AsyncSocket* socket) {
H A Dproxyserver.h33 ProxyBinding(AsyncProxyServerSocket* in_socket, AsyncSocket* out_socket);
39 void OnInternalRead(AsyncSocket* socket);
40 void OnInternalWrite(AsyncSocket* socket);
41 void OnInternalClose(AsyncSocket* socket, int err);
42 void OnExternalConnect(AsyncSocket* socket);
43 void OnExternalRead(AsyncSocket* socket);
44 void OnExternalWrite(AsyncSocket* socket);
45 void OnExternalClose(AsyncSocket* socket, int err);
47 static void Read(AsyncSocket* socket, FifoBuffer* buffer);
48 static void Write(AsyncSocket* socke
[all...]
H A Dasyncsocket.h20 // TODO: Remove Socket and rename AsyncSocket to Socket.
23 class AsyncSocket : public Socket { class in namespace:rtc
25 AsyncSocket();
26 virtual ~AsyncSocket();
28 virtual AsyncSocket* Accept(SocketAddress* paddr) = 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, publi
[all...]
H A Dasynctcpsocket.h25 AsyncTCPSocketBase(AsyncSocket* socket, bool listen, size_t max_packet_size);
33 virtual void HandleIncomingConnection(AsyncSocket* socket) = 0;
51 static AsyncSocket* ConnectSocket(AsyncSocket* socket,
65 void OnConnectEvent(AsyncSocket* socket);
66 void OnReadEvent(AsyncSocket* socket);
67 void OnWriteEvent(AsyncSocket* socket);
68 void OnCloseEvent(AsyncSocket* socket, int error);
70 scoped_ptr<AsyncSocket> socket_;
83 static AsyncTCPSocket* Create(AsyncSocket* socke
[all...]
H A Dsocketfactory.h32 virtual AsyncSocket* CreateAsyncSocket(int type) = 0;
33 virtual AsyncSocket* CreateAsyncSocket(int family, int type) = 0;
H A Dssladapter.h22 explicit SSLAdapter(AsyncSocket* socket)
36 static SSLAdapter* Create(AsyncSocket* socket);
H A Dproxyserver.cc39 void ProxyServer::OnAcceptEvent(AsyncSocket* socket) {
41 AsyncSocket* int_socket = socket->Accept(NULL);
43 AsyncSocket* ext_socket = ext_factory_->CreateAsyncSocket(ext_ip_.family(),
62 AsyncSocket* ext_socket)
84 void ProxyBinding::OnInternalRead(AsyncSocket* socket) {
89 void ProxyBinding::OnInternalWrite(AsyncSocket* socket) {
93 void ProxyBinding::OnInternalClose(AsyncSocket* socket, int err) {
97 void ProxyBinding::OnExternalConnect(AsyncSocket* socket) {
103 void ProxyBinding::OnExternalRead(AsyncSocket* socket) {
108 void ProxyBinding::OnExternalWrite(AsyncSocket* socke
[all...]
H A Dasyncudpsocket.h27 static AsyncUDPSocket* Create(AsyncSocket* socket,
33 explicit AsyncUDPSocket(AsyncSocket* socket);
52 void OnReadEvent(AsyncSocket* socket);
54 void OnWriteEvent(AsyncSocket* socket);
56 scoped_ptr<AsyncSocket> socket_;
H A Dautodetectproxy.h29 class AsyncSocket;
71 void OnConnectEvent(AsyncSocket * socket);
72 void OnReadEvent(AsyncSocket * socket);
73 void OnCloseEvent(AsyncSocket * socket, int error);
82 AsyncSocket* socket_;
H A Dopenssladapter.h31 OpenSSLAdapter(AsyncSocket* socket);
43 virtual void OnConnectEvent(AsyncSocket* socket);
44 virtual void OnReadEvent(AsyncSocket* socket);
45 virtual void OnWriteEvent(AsyncSocket* socket);
46 virtual void OnCloseEvent(AsyncSocket* socket, int err);
H A Dschanneladapter.h25 SChannelAdapter(AsyncSocket* socket);
42 virtual void OnConnectEvent(AsyncSocket* socket);
43 virtual void OnReadEvent(AsyncSocket* socket);
44 virtual void OnWriteEvent(AsyncSocket* socket);
45 virtual void OnCloseEvent(AsyncSocket* socket, int err);
H A Dsocketstream.cc15 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) {
23 void SocketStream::Attach(AsyncSocket* socket) {
35 AsyncSocket* SocketStream::Detach() {
36 AsyncSocket* socket = socket_;
100 void SocketStream::OnConnectEvent(AsyncSocket* socket) {
105 void SocketStream::OnReadEvent(AsyncSocket* socket) {
110 void SocketStream::OnWriteEvent(AsyncSocket* socket) {
115 void SocketStream::OnCloseEvent(AsyncSocket* socket, int err) {
H A Dsocketadapters.h33 BufferedReadAdapter(AsyncSocket* socket, size_t buffer_size);
47 virtual void OnReadEvent(AsyncSocket * socket);
61 AsyncProxyServerSocket(AsyncSocket* socket, size_t buffer_size)
74 explicit AsyncSSLSocket(AsyncSocket* socket);
79 virtual void OnConnectEvent(AsyncSocket* socket);
88 explicit AsyncSSLServerSocket(AsyncSocket* socket);
100 AsyncHttpsProxySocket(AsyncSocket* socket, const std::string& user_agent,
116 virtual void OnConnectEvent(AsyncSocket* socket);
117 virtual void OnCloseEvent(AsyncSocket* socket, int err);
146 explicit AsyncHttpsProxyServerSocket(AsyncSocket* socke
[all...]
H A Dsocket_unittest.cc196 scoped_ptr<AsyncSocket> client(ss_->CreateAsyncSocket(loopback.family(),
199 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState());
203 scoped_ptr<AsyncSocket> server(
208 EXPECT_EQ(AsyncSocket::CS_CONNECTING, server->GetState());
221 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState());
227 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
233 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState());
238 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout);
251 scoped_ptr<AsyncSocket> client(
256 scoped_ptr<AsyncSocket> serve
[all...]
H A Dssladapter_unittest.cc23 static rtc::AsyncSocket* CreateSocket(const rtc::SSLMode& ssl_mode) {
26 rtc::AsyncSocket* socket = rtc::Thread::Current()->
43 rtc::AsyncSocket* socket = CreateSocket(ssl_mode_);
58 rtc::AsyncSocket::ConnState GetState() const {
89 void OnSSLAdapterReadEvent(rtc::AsyncSocket* socket) {
103 void OnSSLAdapterCloseEvent(rtc::AsyncSocket* socket, int error) {
107 if (socket->GetState() != rtc::AsyncSocket::CS_CLOSED) {
173 void OnServerSocketReadEvent(rtc::AsyncSocket* socket) {
180 rtc::AsyncSocket* new_socket = socket->Accept(&address);
231 rtc::scoped_ptr<rtc::AsyncSocket> server_socket
[all...]
H A Dasyncudpsocket.cc19 AsyncSocket* socket,
21 scoped_ptr<AsyncSocket> owned_socket(socket);
31 AsyncSocket* socket =
38 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket)
96 void AsyncUDPSocket::OnReadEvent(AsyncSocket* socket) {
118 void AsyncUDPSocket::OnWriteEvent(AsyncSocket* socket) {
/external/qemu/android/
H A Dasync-socket.h42 typedef struct AsyncSocket AsyncSocket; typedef in typeref:struct:AsyncSocket
50 * as - Initialized AsyncSocket instance.
56 AsyncSocket* as,
93 /* Gets AsyncSocket instance for an I/O. Note that this routine will reference
94 * AsyncSocket instance before returning it to the caller. */
95 extern AsyncSocket* async_socket_io_get_socket(const AsyncSocketIO* asio);
133 * AsyncSocket API
145 * Initialized AsyncSocket instance on success, or NULL on failure.
147 extern AsyncSocket* async_socket_ne
[all...]
H A Dasync-socket.c48 static const char* _async_socket_string(AsyncSocket* as);
51 static Looper* _async_socket_get_looper(AsyncSocket* as);
58 static AsyncIOAction _async_socket_io_timed_out(AsyncSocket* as,
69 AsyncSocket* as;
126 _async_socket_rw_new(AsyncSocket* as,
173 AsyncSocket* const as = asio->as;
234 _async_socket_reader_new(AsyncSocket* as,
257 _async_socket_writer_new(AsyncSocket* as,
275 AsyncSocket* const as = asio->as;
291 AsyncSocket*
358 struct AsyncSocket { struct
[all...]
/external/chromium_org/third_party/libjingle/source/talk/xmpp/
H A Dxmppsocket.h45 extern rtc::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(rtc::AsyncSocket * socket);
70 void OnWriteEvent(rtc::AsyncSocket * socket);
71 void OnConnectEvent(rtc::AsyncSocket * socket);
72 void OnCloseEvent(rtc::AsyncSocket * socket, int error);
77 rtc::AsyncSocket * cricket_socket_;
81 buzz::AsyncSocket
[all...]
H A Dxmppsocket.cc53 state_ = buzz::AsyncSocket::STATE_CLOSED;
61 rtc::AsyncSocket* socket =
96 void XmppSocket::OnReadEvent(rtc::AsyncSocket * socket) {
100 void XmppSocket::OnWriteEvent(rtc::AsyncSocket * socket) {
114 void XmppSocket::OnConnectEvent(rtc::AsyncSocket * socket) {
116 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) {
117 state_ = buzz::AsyncSocket::STATE_TLS_OPEN;
123 state_ = buzz::AsyncSocket::STATE_OPEN;
127 void XmppSocket::OnCloseEvent(rtc::AsyncSocket * socket, int error) {
137 if (state_ == buzz::AsyncSocket
[all...]
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
H A Dasyncstuntcpsocket.h43 rtc::AsyncSocket* socket,
47 AsyncStunTCPSocket(rtc::AsyncSocket* socket, bool listen);
53 virtual void HandleIncomingConnection(rtc::AsyncSocket* socket);
H A Dtestrelayserver.h72 rtc::AsyncSocket* CreateListenSocket(rtc::Thread* thread,
74 rtc::AsyncSocket* socket =
81 void OnAccept(rtc::AsyncSocket* socket) {
86 rtc::AsyncSocket* raw_socket = socket->Accept(NULL);
110 rtc::scoped_ptr<rtc::AsyncSocket> tcp_int_socket_;
111 rtc::scoped_ptr<rtc::AsyncSocket> tcp_ext_socket_;
112 rtc::scoped_ptr<rtc::AsyncSocket> ssl_int_socket_;
113 rtc::scoped_ptr<rtc::AsyncSocket> ssl_ext_socket_;
H A Dbasicpacketsocketfactory.h35 class AsyncSocket;
57 int BindSocket(AsyncSocket* socket, const SocketAddress& local_address,
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/client/
H A Dpeer_connection_client.h94 void OnConnect(rtc::AsyncSocket* socket);
95 void OnHangingGetConnect(rtc::AsyncSocket* socket);
106 bool ReadIntoBuffer(rtc::AsyncSocket* socket, std::string* data,
109 void OnRead(rtc::AsyncSocket* socket);
111 void OnHangingGetRead(rtc::AsyncSocket* socket);
122 void OnClose(rtc::AsyncSocket* socket, int err);
129 rtc::scoped_ptr<rtc::AsyncSocket> control_socket_;
130 rtc::scoped_ptr<rtc::AsyncSocket> hanging_get_;

Completed in 293 milliseconds

1234