/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_;
|