| /external/chromium_org/third_party/webrtc/base/ |
| socketstream.h | 14 #include "webrtc/base/asyncsocket.h"
24 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_
[all...] |
| asyncsocket.cc | 11 #include "webrtc/base/asyncsocket.h"
15 AsyncSocket::AsyncSocket() {
18 AsyncSocket::~AsyncSocket() {
21 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) {
29 void AsyncSocketAdapter::Attach(AsyncSocket* socket) {
|
| socketfactory.h | 15 #include "webrtc/base/asyncsocket.h"
32 virtual AsyncSocket* CreateAsyncSocket(int type) = 0;
33 virtual AsyncSocket* CreateAsyncSocket(int family, int type) = 0;
|
| proxyserver.h | 15 #include "webrtc/base/asyncsocket.h"
33 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)
[all...] |
| asyncsocket.h | 20 // TODO: Remove Socket and rename AsyncSocket to Socket.
23 class AsyncSocket : public Socket {
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, public sigslot::has_slots<>
[all...] |
| asynctcpsocket.h | 25 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* socket
[all...] |
| asyncudpsocket.h | 27 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_;
|
| schanneladapter.h | 25 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);
|
| ssladapter.h | 14 #include "webrtc/base/asyncsocket.h"
22 explicit SSLAdapter(AsyncSocket* socket)
36 static SSLAdapter* Create(AsyncSocket* socket);
|
| socketadapters.h | 17 #include "webrtc/base/asyncsocket.h"
33 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)
[all...] |
| proxyserver.cc | 39 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* socket)
[all...] |
| autodetectproxy.h | 29 class AsyncSocket;
71 void OnConnectEvent(AsyncSocket * socket);
72 void OnReadEvent(AsyncSocket * socket);
73 void OnCloseEvent(AsyncSocket * socket, int error);
82 AsyncSocket* socket_;
|
| openssladapter.h | 31 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);
|
| nullsocketserver.h | 44 virtual rtc::AsyncSocket* CreateAsyncSocket(int type) {
49 virtual rtc::AsyncSocket* CreateAsyncSocket(int family, int type) {
|
| socketstream.cc | 15 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) {
|
| socket_unittest.cc | 196 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> server
[all...] |
| ssladapter_unittest.cc | 23 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...] |
| asyncudpsocket.cc | 19 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/ |
| async-socket.h | 42 typedef struct AsyncSocket 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_new(int port
[all...] |
| async-socket.c | 32 #define D(...) VERBOSE_PRINT(asyncsocket,__VA_ARGS__)
33 #define D_ACTIVE VERBOSE_CHECK(asyncsocket)
38 #define T(...) VERBOSE_PRINT(asyncsocket,__VA_ARGS__)
48 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
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
| xmppsocket.h | 31 #include "talk/xmpp/asyncsocket.h"
33 #include "webrtc/base/asyncsocket.h"
45 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)
[all...] |
| xmppsocket.cc | 53 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::STATE_TLS_CONNECTING)
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| asyncstuntcpsocket.h | 43 rtc::AsyncSocket* socket,
47 AsyncStunTCPSocket(rtc::AsyncSocket* socket, bool listen);
53 virtual void HandleIncomingConnection(rtc::AsyncSocket* socket);
|
| testrelayserver.h | 72 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_;
|
| /external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/client/ |
| peer_connection_client.h | 94 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_;
|
