/external/chromium_org/third_party/webrtc/base/ |
H A D | socketstream.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_;
|
H A D | asyncsocket.cc | 15 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 D | proxyserver.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); 48 static void Write(AsyncSocket* socke [all...] |
H A D | asyncsocket.h | 20 // 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 D | 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* socke [all...] |
H A D | socketfactory.h | 32 virtual AsyncSocket* CreateAsyncSocket(int type) = 0; 33 virtual AsyncSocket* CreateAsyncSocket(int family, int type) = 0;
|
H A D | ssladapter.h | 22 explicit SSLAdapter(AsyncSocket* socket) 36 static SSLAdapter* Create(AsyncSocket* socket);
|
H A D | 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* socke [all...] |
H A D | 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_;
|
H A D | 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_;
|
H A D | 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);
|
H A D | 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);
|
H A D | 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) {
|
H A D | socketadapters.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); 146 explicit AsyncHttpsProxyServerSocket(AsyncSocket* socke [all...] |
H A D | 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> serve [all...] |
H A D | 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...] |
H A D | 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/ |
H A D | async-socket.h | 42 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 D | async-socket.c | 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, 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 D | xmppsocket.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); 77 rtc::AsyncSocket * cricket_socket_; 81 buzz::AsyncSocket [all...] |
H A D | 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 [all...] |
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
H A D | asyncstuntcpsocket.h | 43 rtc::AsyncSocket* socket, 47 AsyncStunTCPSocket(rtc::AsyncSocket* socket, bool listen); 53 virtual void HandleIncomingConnection(rtc::AsyncSocket* socket);
|
H A D | 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_;
|
H A D | basicpacketsocketfactory.h | 35 class AsyncSocket; 57 int BindSocket(AsyncSocket* socket, const SocketAddress& local_address,
|
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/client/ |
H A D | 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_;
|