/external/chromium/third_party/libjingle/source/talk/base/ |
asyncsocket.cc | 38 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) { 43 delete socket_; 47 ASSERT(!socket_); 48 socket_ = socket; 49 if (socket_) { 50 socket_->SignalConnectEvent.connect(this, 52 socket_->SignalReadEvent.connect(this, 54 socket_->SignalWriteEvent.connect(this, 56 socket_->SignalCloseEvent.connect(this,
|
socketstream.cc | 32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { 37 delete socket_; 41 if (socket_) 42 delete socket_; 43 socket_ = socket; 44 if (socket_) { 45 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent); 46 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent); 47 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent); 48 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent) [all...] |
asyncsocket.h | 63 return socket_->GetLocalAddress(); 66 return socket_->GetRemoteAddress(); 69 return socket_->Bind(addr); 72 return socket_->Connect(addr); 75 return socket_->Send(pv, cb); 78 return socket_->SendTo(pv, cb, addr); 81 return socket_->Recv(pv, cb); 84 return socket_->RecvFrom(pv, cb, paddr); 87 return socket_->Listen(backlog); 90 return socket_->Accept(paddr) 128 AsyncSocket* socket_; member in class:talk_base::AsyncSocketAdapter [all...] |
asyncudpsocket.cc | 52 : socket_(socket) { 53 ASSERT(socket_.get() != NULL); 58 socket_->SignalReadEvent.connect(this, &AsyncUDPSocket::OnReadEvent); 68 return socket_->GetLocalAddress(); 72 return socket_->GetRemoteAddress(); 76 return socket_->Send(pv, cb); 81 return socket_->SendTo(pv, cb, addr); 85 return socket_->Close(); 89 return socket_->GetState(); 93 return socket_->GetOption(opt, value) [all...] |
asynctcpsocket.cc | 64 : socket_(socket), 73 ASSERT(socket_.get() != NULL); 74 socket_->SignalConnectEvent.connect(this, &AsyncTCPSocket::OnConnectEvent); 75 socket_->SignalReadEvent.connect(this, &AsyncTCPSocket::OnReadEvent); 76 socket_->SignalWriteEvent.connect(this, &AsyncTCPSocket::OnWriteEvent); 77 socket_->SignalCloseEvent.connect(this, &AsyncTCPSocket::OnCloseEvent); 80 if (socket_->Listen(LISTEN_BACKLOG) < 0) { 81 LOG(LS_ERROR) << "Listen() failed with error " << socket_->GetError(); 94 return socket_->GetLocalAddress(); 98 return socket_->GetRemoteAddress() [all...] |
autodetectproxy.cc | 42 : agent_(user_agent), socket_(NULL), next_(0) { 67 delete socket_; 76 OnCloseEvent(socket_, ETIMEDOUT); 91 if (socket_) { 93 socket_->Close(); 94 Thread::Current()->Dispose(socket_); 95 socket_ = NULL; 98 socket_ = Thread::Current()->socketserver()->CreateAsyncSocket(SOCK_STREAM); 99 socket_->SignalConnectEvent.connect(this, &AutoDetectProxy::OnConnectEvent); 100 socket_->SignalReadEvent.connect(this, &AutoDetectProxy::OnReadEvent) [all...] |
sslsocketfactory.cc | 56 ASSERT(NULL == socket_); 71 if (socket_) { 72 return socket_->GetError(); 77 if (socket_) { 78 return socket_->Close(); 87 if (socket_) { 88 return socket_->GetState(); 102 } else if (!IsBlockingError(socket_->GetError())) { 103 SignalCloseEvent(this, socket_->GetError());
|
socketstream.h | 47 AsyncSocket* GetSocket() { return socket_; } 65 AsyncSocket* socket_; member in class:talk_base::SocketStream
|
/external/chromium/net/udp/ |
udp_client_socket.cc | 14 : socket_(net_log, source) { 21 return socket_.Connect(address); 27 return socket_.Read(buf, buf_len, callback); 33 return socket_.Write(buf, buf_len, callback); 37 socket_.Close(); 41 return socket_.GetPeerAddress(address); 45 return socket_.GetLocalAddress(address);
|
udp_server_socket.cc | 11 : socket_(net_log, source) { 18 return socket_.Bind(address); 25 return socket_.RecvFrom(buf, buf_len, address, callback); 32 return socket_.SendTo(buf, buf_len, address, callback); 36 socket_.Close(); 40 return socket_.GetPeerAddress(address); 44 return socket_.GetLocalAddress(address);
|
udp_socket_libevent.h | 94 bool is_connected() const { return socket_ != kInvalidSocket; } 101 explicit ReadWatcher(UDPSocketLibevent* socket) : socket_(socket) {} 106 if (socket_->read_callback_) 107 socket_->DidCompleteRead(); 113 UDPSocketLibevent* const socket_; member in class:net::UDPSocketLibevent::ReadWatcher 120 explicit WriteWatcher(UDPSocketLibevent* socket) : socket_(socket) {} 127 if (socket_->write_callback_) 128 socket_->DidCompleteWrite(); 132 UDPSocketLibevent* const socket_; member in class:net::UDPSocketLibevent::WriteWatcher 156 int socket_; member in class:net::UDPSocketLibevent [all...] |
udp_socket_win.cc | 25 DCHECK_EQ(object, socket_->read_overlapped_.hEvent); 26 socket_->DidCompleteRead(); 30 DCHECK_EQ(object, socket_->write_overlapped_.hEvent); 31 socket_->DidCompleteWrite(); 36 : socket_(INVALID_SOCKET), 73 closesocket(socket_); 74 socket_ = INVALID_SOCKET; 87 if (getpeername(socket_, addr, &addr_len)) 109 if (getsockname(socket_, addr, &addr_len)) 132 DCHECK_NE(INVALID_SOCKET, socket_); [all...] |
udp_socket_win.h | 96 bool is_connected() const { return socket_ != INVALID_SOCKET; } 101 explicit ReadDelegate(UDPSocketWin* socket) : socket_(socket) {} 108 UDPSocketWin* const socket_; member in class:net::UDPSocketWin::ReadDelegate 113 explicit WriteDelegate(UDPSocketWin* socket) : socket_(socket) {} 120 UDPSocketWin* const socket_; member in class:net::UDPSocketWin::WriteDelegate 144 SOCKET socket_; member in class:net::UDPSocketWin
|
/external/chromium/third_party/libjingle/source/talk/p2p/base/ |
udpport.cc | 43 socket_(NULL), 48 socket_ = factory_->CreateUdpSocket( 50 if (!socket_) { 54 socket_->SignalReadPacket.connect(this, &UDPPort::OnReadPacket); 59 delete socket_; 64 talk_base::SocketAddress address = socket_->GetLocalAddress(&allocated); 68 socket_->SignalAddressReady.connect(this, &UDPPort::OnAddresReady); 84 int sent = socket_->SendTo(data, size, addr); 86 error_ = socket_->GetError(); 94 return socket_->SetOption(opt, value) [all...] |
tcpport.cc | 43 socket_(NULL), 50 socket_ = factory_->CreateServerTcpSocket( 53 if (!socket_) { 57 socket_->SignalNewConnection.connect(this, &TCPPort::OnNewConnection); 62 delete socket_; 102 talk_base::SocketAddress address = socket_->GetLocalAddress(&allocated); 106 socket_->SignalAddressReady.connect(this, &TCPPort::OnAddresReady); 134 return socket_->SetOption(opt, value); 143 ASSERT(socket == socket_); 183 : Connection(port, 0, candidate), socket_(socket), error_(0) [all...] |
/external/chromium/net/socket_stream/ |
socket_stream_job.cc | 45 return socket_->GetUserData(key); 50 socket_->SetUserData(key, data); 54 socket_->Connect(); 58 return socket_->SendData(data, len); 62 socket_->Close(); 67 socket_->RestartWithAuth(username, password); 71 socket_->DetachDelegate();
|
socket_stream_job.h | 41 socket_ = socket; 48 return socket_->context(); 51 socket_->set_context(context); 70 scoped_refptr<SocketStream> socket_; member in class:net::SocketStreamJob
|
/external/chromium/net/socket/ |
tcp_client_socket_libevent.h | 80 explicit ReadWatcher(TCPClientSocketLibevent* socket) : socket_(socket) {} 85 if (socket_->read_callback_) 86 socket_->DidCompleteRead(); 92 TCPClientSocketLibevent* const socket_; member in class:net::TCPClientSocketLibevent::ReadWatcher 99 explicit WriteWatcher(TCPClientSocketLibevent* socket) : socket_(socket) {} 106 if (socket_->waiting_connect()) { 107 socket_->DidCompleteConnect(); 108 } else if (socket_->write_callback_) { 109 socket_->DidCompleteWrite(); 114 TCPClientSocketLibevent* const socket_; member in class:net::TCPClientSocketLibevent::WriteWatcher 151 int socket_; member in class:net::TCPClientSocketLibevent [all...] |
tcp_server_socket_libevent.cc | 40 : socket_(kInvalidSocket), 51 if (socket_ != kInvalidSocket) 59 DCHECK_EQ(socket_, kInvalidSocket); 61 socket_ = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); 62 if (socket_ < 0) { 67 if (SetNonBlocking(socket_)) { 79 int result = bind(socket_, addr, addr_len); 87 result = listen(socket_, backlog); 105 if (getsockname(socket_, addr, &addr_len) < 0) 126 socket_, true, MessageLoopForIO::WATCH_READ [all...] |
tcp_server_socket_win.cc | 20 : socket_(INVALID_SOCKET), 40 DCHECK_EQ(socket_, INVALID_SOCKET); 49 socket_ = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); 50 if (socket_ < 0) { 55 if (SetNonBlocking(socket_)) { 67 int result = bind(socket_, addr, addr_len); 75 result = listen(socket_, backlog); 93 if (getsockname(socket_, addr, &addr_len)) 114 WSAEventSelect(socket_, socket_event_, FD_ACCEPT); 129 int result = accept(socket_, addr, &addr_len) [all...] |
tcp_client_socket_libevent.cc | 109 : socket_(kInvalidSocket), 143 DCHECK_EQ(socket_, kInvalidSocket); 144 socket_ = socket; 169 if (socket_ != kInvalidSocket) 246 if (!HANDLE_EINTR(connect(socket_, current_ai_->ai_addr, 254 FD_SET(socket_, &writeset); 258 int res = HANDLE_EINTR(select(socket_ + 1, 0, &writeset, 0, &tv)); 278 socket_, true, MessageLoopForIO::WATCH_WRITE, &write_socket_watcher_, 326 if (socket_ == kInvalidSocket) 336 qtaguid_untagSocket(socket_); [all...] |
tcp_client_socket_win.cc | 74 void Detach() { socket_ = NULL; } 129 TCPClientSocketWin* socket_; member in class:net::TCPClientSocketWin::Core 154 socket_(socket), 190 if (core_->socket_) { 191 if (core_->socket_->waiting_connect()) { 192 core_->socket_->DidCompleteConnect(); 194 core_->socket_->DidCompleteRead(); 204 if (core_->socket_) 205 core_->socket_->DidCompleteWrite(); 215 : socket_(INVALID_SOCKET) [all...] |
/external/chromium/net/tools/fetch/ |
http_session.h | 23 scoped_refptr<HttpListenSocket> socket_; member in class:HttpSession
|
/external/chromium/net/websockets/ |
websocket_job.cc | 78 DCHECK(!socket_.get()); 82 DCHECK(socket_.get()); 85 socket_->Connect(); 115 return socket_->SendData( 135 socket_->Close(); 142 socket_->RestartWithAuth(username, password); 153 if (socket_) 154 socket_->DetachDelegate(); 155 socket_ = NULL; 247 socket_ = NULL [all...] |
/external/chromium/chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/ |
IRCProxyWebSocket.java | 39 Socket socket_ = null; field in class:IRCProxyWebSocket.ChatWebSocket 53 if (socket_ == null) { 58 socket_ = SocketFactory.getDefault().createSocket(tokens[0], 60 out_ = new OutputStreamWriter(socket_.getOutputStream()); 62 socket_.getInputStream()); 89 socket_.close();
|