| /external/chromium/net/socket/ |
| tcp_client_socket_libevent.h | 49 explicit ReadWatcher(TCPClientSocketLibevent* socket) : socket_(socket) {}
54 if (socket_->read_callback_)
55 socket_->DidCompleteRead();
61 TCPClientSocketLibevent* const socket_; member in class:net::TCPClientSocketLibevent::ReadWatcher
68 explicit WriteWatcher(TCPClientSocketLibevent* socket) : socket_(socket) {}
75 if (socket_->waiting_connect_) {
76 socket_->DidCompleteConnect();
77 } else if (socket_->write_callback_) {
78 socket_->DidCompleteWrite();
83 TCPClientSocketLibevent* const socket_; member in class:net::TCPClientSocketLibevent::WriteWatcher
99 int socket_; member in class:net::TCPClientSocketLibevent
[all...] |
| tcp_client_socket_libevent.cc | 126 : socket_(kInvalidSocket),
143 if (socket_ != kInvalidSocket)
178 if (!HANDLE_EINTR(connect(socket_, current_ai_->ai_addr,
188 close(socket_);
189 socket_ = kInvalidSocket;
206 socket_, true, MessageLoopForIO::WATCH_WRITE, &write_socket_watcher_,
209 close(socket_);
210 socket_ = kInvalidSocket;
218 if (socket_ == kInvalidSocket)
227 close(socket_);
[all...] |
| tcp_client_socket_win.cc | 136 void Detach() { socket_ = NULL; }
190 TCPClientSocketWin* socket_; member in class:net::TCPClientSocketWin::Core
214 : socket_(socket),
250 if (core_->socket_) {
251 if (core_->socket_->waiting_connect_) {
252 core_->socket_->DidCompleteConnect();
254 core_->socket_->DidCompleteRead();
264 if (core_->socket_)
265 core_->socket_->DidCompleteWrite();
273 : socket_(INVALID_SOCKET)
[all...] |
| client_socket_handle.cc | 15 : socket_(NULL),
31 if (socket_.get()) {
|
| client_socket_handle.h | 83 bool is_initialized() const { return socket_ != NULL; }
90 void set_socket(ClientSocket* s) { socket_.reset(s); }
95 ClientSocket* socket() { return socket_.get(); }
96 ClientSocket* release_socket() { return socket_.release(); }
135 scoped_ptr<ClientSocket> socket_; member in class:net::ClientSocketHandle
|
| tcp_client_socket_win.h | 55 SOCKET socket_; member in class:net::TCPClientSocketWin
|
| client_socket_pool_base.h | 77 // Releases |socket_| to the client. On connection error, this should return
79 ClientSocket* ReleaseSocket() { return socket_.release(); }
92 void set_socket(ClientSocket* socket) { socket_.reset(socket); }
93 ClientSocket* socket() { return socket_.get(); }
107 scoped_ptr<ClientSocket> socket_; member in class:net::ConnectJob
|
| socket_test_util.h | 94 SocketDataProvider() : socket_(NULL) {}
107 MockClientSocket* socket() { return socket_; }
108 void set_socket(MockClientSocket* socket) { socket_ = socket; }
115 MockClientSocket* socket_; member in class:net::SocketDataProvider
|
| /external/chromium/net/tools/fetch/ |
| http_session.h | 22 scoped_refptr<HttpListenSocket> socket_; member in class:HttpSession
|
| http_session.cc | 10 socket_(HttpListenSocket::Listen(ip, port, this))) {
|
| http_listen_socket.cc | 25 SOCKET conn = ListenSocket::Accept(socket_);
|
| /external/v8/src/ |
| platform-posix.cc | 201 socket_ = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
203 explicit POSIXSocket(int socket): socket_(socket) { }
223 bool IsValid() const { return socket_ != -1; }
226 int socket_; member in class:v8::internal::POSIXSocket
240 int status = bind(socket_,
252 int status = listen(socket_, backlog);
262 int socket = accept(socket_, NULL, NULL);
289 status = connect(socket_, result->ai_addr, result->ai_addrlen);
298 int status = shutdown(socket_, SHUT_RDWR);
299 close(socket_);
[all...] |
| platform-win32.cc | 1634 SOCKET socket_; member in class:v8::internal::Win32Socket
[all...] |
| /external/chromium/net/base/ |
| listen_socket.cc | 46 : socket_(s),
64 CloseSocket(socket_);
102 listen(socket_, backlog);
121 SOCKET conn = Accept(socket_);
139 len = HANDLE_EINTR(recv(socket_, buf, kReadBufSize, 0));
197 WSAEventSelect(socket_, socket_event_, FD_ACCEPT | FD_CLOSE | FD_READ);
202 socket_, true, MessageLoopForIO::WATCH_READ, &watcher_, this);
208 int sent = HANDLE_EINTR(send(socket_, bytes, len, 0));
254 if (kSocketError == WSAEnumNetworkEvents(socket_, socket_event_, &ev)) {
|
| listen_socket.h | 118 SOCKET socket_; member in class:ListenSocket
|
| telnet_server.cc | 131 SOCKET conn = ListenSocket::Accept(socket_);
259 len = HANDLE_EINTR(recv(socket_, buf, kReadBufSize, 0));
|
| /external/chromium/net/socket_stream/ |
| socket_stream.cc | 139 if (!socket_.get() || !socket_->IsConnected() || next_state_ == STATE_NONE)
174 if (!socket_.get() || !socket_->IsConnected() || next_state_ == STATE_NONE)
176 socket_->Disconnect();
192 if (!socket_.get()) {
257 if (!socket_.get() || !socket_->IsConnected()) {
505 socket_.reset(factory_->CreateTCPClientSocket(addresses_));
507 return socket_->Connect(&io_callback_, load_log_)
[all...] |
| socket_stream.h | 293 scoped_ptr<ClientSocket> socket_; member in class:net::SocketStream
|
| /external/webkit/WebKitTools/pywebsocket/mod_pywebsocket/ |
| standalone.py | 188 socket_ = socket.socket(self.address_family, self.socket_type)
193 socket_ = OpenSSL.SSL.Connection(ctx, socket_)
194 return socket_
|
