Lines Matching refs:socket_

149   DCHECK(!socket_);
150 socket_.reset(new SocketLibevent);
151 int rv = socket_->Open(ConvertAddressFamily(family));
153 socket_.reset();
159 DCHECK(!socket_);
168 socket_.reset(new SocketLibevent);
169 int rv = socket_->AdoptConnectedSocket(socket_fd, storage);
171 socket_.reset();
176 DCHECK(socket_);
182 return socket_->Bind(storage);
186 DCHECK(socket_);
187 return socket_->Listen(backlog);
195 DCHECK(socket_);
200 int rv = socket_->Accept(
211 DCHECK(socket_);
226 socket_->SetPeerAddress(storage);
230 int rv = socket_->Connect(storage,
239 if (!socket_)
243 socket_->HasPeerAddress()) {
249 return socket_->IsConnected();
255 return socket_ && socket_->IsConnectedAndIdle();
261 DCHECK(socket_);
264 int rv = socket_->Read(
281 DCHECK(socket_);
294 rv = socket_->Write(buf, buf_len, write_callback);
305 if (!socket_)
309 int rv = socket_->GetLocalAddress(&storage);
326 int rv = socket_->GetPeerAddress(&storage);
337 DCHECK(socket_);
342 DCHECK(socket_);
347 SetTCPNoDelay(socket_->socket_fd(), true);
363 SetTCPKeepAlive(socket_->socket_fd(), true, kTCPKeepAliveSeconds);
368 DCHECK(socket_);
384 int rv = setsockopt(socket_->socket_fd(), SOL_SOCKET, SO_REUSEADDR,
392 DCHECK(socket_);
393 int rv = setsockopt(socket_->socket_fd(), SOL_SOCKET, SO_RCVBUF,
399 DCHECK(socket_);
400 int rv = setsockopt(socket_->socket_fd(), SOL_SOCKET, SO_SNDBUF,
406 DCHECK(socket_);
407 return SetTCPKeepAlive(socket_->socket_fd(), enable, delay);
411 DCHECK(socket_);
412 return SetTCPNoDelay(socket_->socket_fd(), no_delay);
416 socket_.reset();
431 return socket_ != NULL && socket_->socket_fd() != kInvalidSocket;
493 (*tcp_socket)->socket_.reset(accept_socket_.release());
539 int rv = socket_->GetLocalAddress(&storage);
603 int rv = socket_->GetPeerAddress(&storage);
615 rv = HANDLE_EINTR(sendto(socket_->socket_fd(),
647 return socket_->WaitForWrite(buf, buf_len, callback);
662 getsockopt(socket_->socket_fd(), IPPROTO_TCP, TCP_INFO,