Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(312)

Unified Diff: mojo/shell/domain_socket/socket_libevent.cc

Issue 775343004: Move //mojo/shell to //shell (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 6 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/shell/domain_socket/socket_libevent.h ('k') | mojo/shell/domain_socket/test_completion_callback.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/shell/domain_socket/socket_libevent.cc
diff --git a/mojo/shell/domain_socket/socket_libevent.cc b/mojo/shell/domain_socket/socket_libevent.cc
deleted file mode 100644
index cf4bd7912881e66ca994b474f44f5e16d95bc5eb..0000000000000000000000000000000000000000
--- a/mojo/shell/domain_socket/socket_libevent.cc
+++ /dev/null
@@ -1,387 +0,0 @@
-// Copyright 2014 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "mojo/shell/domain_socket/socket_libevent.h"
-
-#include <errno.h>
-#include <fcntl.h>
-#include <netinet/in.h>
-#include <sys/socket.h>
-#include <unistd.h>
-
-#include "base/callback_helpers.h"
-#include "base/logging.h"
-#include "base/posix/eintr_wrapper.h"
-#include "mojo/shell/domain_socket/net_errors.h"
-
-namespace mojo {
-namespace shell {
-
-SockaddrStorage::SockaddrStorage(const SockaddrStorage& other)
- : addr_len(other.addr_len),
- addr(reinterpret_cast<struct sockaddr*>(&addr_storage)) {
- memcpy(addr, other.addr, addr_len);
-}
-
-void SockaddrStorage::operator=(const SockaddrStorage& other) {
- addr_len = other.addr_len;
- // addr is already set to &this->addr_storage by default ctor.
- memcpy(addr, other.addr, addr_len);
-}
-
-namespace {
-
-int MapAcceptError(int os_error) {
- switch (os_error) {
- // If the client aborts the connection before the server calls accept,
- // POSIX specifies accept should fail with ECONNABORTED. The server can
- // ignore the error and just call accept again, so we map the error to
- // ERR_IO_PENDING. See UNIX Network Programming, Vol. 1, 3rd Ed., Sec.
- // 5.11, "Connection Abort before accept Returns".
- case ECONNABORTED:
- return net::ERR_IO_PENDING;
- default:
- return net::MapSystemError(os_error);
- }
-}
-
-int MapConnectError(int os_error) {
- switch (os_error) {
- case EINPROGRESS:
- return net::ERR_IO_PENDING;
- case EACCES:
- return net::ERR_NETWORK_ACCESS_DENIED;
- case ETIMEDOUT:
- return net::ERR_CONNECTION_TIMED_OUT;
- default: {
- int net_error = net::MapSystemError(os_error);
- if (net_error == net::ERR_FAILED)
- return net::ERR_CONNECTION_FAILED; // More specific than ERR_FAILED.
- return net_error;
- }
- }
-}
-
-int SetNonBlocking(int fd) {
- int flags = fcntl(fd, F_GETFL, 0);
- if (-1 == flags)
- return flags;
- return fcntl(fd, F_SETFL, flags | O_NONBLOCK);
-}
-
-} // namespace
-
-SocketLibevent::SocketLibevent()
- : socket_fd_(kInvalidSocket), waiting_connect_(false) {
-}
-
-SocketLibevent::~SocketLibevent() {
- Close();
-}
-
-int SocketLibevent::Open(int address_family) {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK_EQ(kInvalidSocket, socket_fd_);
- DCHECK(address_family == AF_INET || address_family == AF_INET6 ||
- address_family == AF_UNIX);
-
- int socket_type = SOCK_STREAM;
-#ifdef SOCK_NONBLOCK
- socket_type |= SOCK_NONBLOCK;
-#endif
- socket_fd_ = ::socket(address_family,
- socket_type,
- address_family == AF_UNIX ? 0 : IPPROTO_TCP);
-#ifndef SOCK_NONBLOCK
- if (SetNonBlocking(socket_fd_) != 0) {
- PLOG(ERROR) << "SetNonBlocking() returned an error, errno=" << errno;
- return net::MapSystemError(errno);
- }
-#endif
- if (socket_fd_ < 0) {
- PLOG(ERROR) << "CreatePlatformSocket() returned an error, errno=" << errno;
- return net::MapSystemError(errno);
- }
-
- return net::OK;
-}
-
-int SocketLibevent::AdoptConnectedSocket(SocketDescriptor socket,
- const SockaddrStorage& address) {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK_EQ(kInvalidSocket, socket_fd_);
-
- socket_fd_ = socket;
-
- if (SetNonBlocking(socket_fd_)) {
- int rv = net::MapSystemError(errno);
- Close();
- return rv;
- }
-
- SetPeerAddress(address);
- return net::OK;
-}
-
-SocketDescriptor SocketLibevent::ReleaseConnectedSocket() {
- StopWatchingAndCleanUp();
- SocketDescriptor socket_fd = socket_fd_;
- socket_fd_ = kInvalidSocket;
- return socket_fd;
-}
-
-int SocketLibevent::Bind(const SockaddrStorage& address) {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK_NE(kInvalidSocket, socket_fd_);
-
- int rv = bind(socket_fd_, address.addr, address.addr_len);
- if (rv < 0) {
- PLOG(ERROR) << "bind() returned an error, errno=" << errno;
- return net::MapSystemError(errno);
- }
-
- return net::OK;
-}
-
-int SocketLibevent::Listen(int backlog) {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK_NE(kInvalidSocket, socket_fd_);
- DCHECK_LT(0, backlog);
-
- int rv = listen(socket_fd_, backlog);
- if (rv < 0) {
- PLOG(ERROR) << "listen() returned an error, errno=" << errno;
- return net::MapSystemError(errno);
- }
-
- return net::OK;
-}
-
-int SocketLibevent::Accept(scoped_ptr<SocketLibevent>* socket,
- const CompletionCallback& callback) {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK_NE(kInvalidSocket, socket_fd_);
- DCHECK(accept_callback_.is_null());
- DCHECK(socket);
- DCHECK(!callback.is_null());
-
- int rv = DoAccept(socket);
- if (rv != net::ERR_IO_PENDING)
- return rv;
-
- if (!base::MessageLoopForIO::current()->WatchFileDescriptor(
- socket_fd_,
- true,
- base::MessageLoopForIO::WATCH_READ,
- &accept_socket_watcher_,
- this)) {
- PLOG(ERROR) << "WatchFileDescriptor failed on accept, errno " << errno;
- return net::MapSystemError(errno);
- }
-
- accept_socket_ = socket;
- accept_callback_ = callback;
- return net::ERR_IO_PENDING;
-}
-
-int SocketLibevent::Connect(const SockaddrStorage& address,
- const CompletionCallback& callback) {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK_NE(kInvalidSocket, socket_fd_);
- DCHECK(!waiting_connect_);
- DCHECK(!callback.is_null());
-
- SetPeerAddress(address);
-
- int rv = DoConnect();
- if (rv != net::ERR_IO_PENDING)
- return rv;
-
- if (!base::MessageLoopForIO::current()->WatchFileDescriptor(
- socket_fd_,
- true,
- base::MessageLoopForIO::WATCH_WRITE,
- &write_socket_watcher_,
- this)) {
- PLOG(ERROR) << "WatchFileDescriptor failed on connect, errno " << errno;
- return net::MapSystemError(errno);
- }
-
- write_callback_ = callback;
- waiting_connect_ = true;
- return net::ERR_IO_PENDING;
-}
-
-bool SocketLibevent::IsConnected() const {
- DCHECK(thread_checker_.CalledOnValidThread());
-
- if (socket_fd_ == kInvalidSocket || waiting_connect_)
- return false;
-
- // Checks if connection is alive.
- char c;
- int rv = HANDLE_EINTR(recv(socket_fd_, &c, 1, MSG_PEEK));
- if (rv == 0)
- return false;
- if (rv == -1 && errno != EAGAIN && errno != EWOULDBLOCK)
- return false;
-
- return true;
-}
-
-bool SocketLibevent::IsConnectedAndIdle() const {
- DCHECK(thread_checker_.CalledOnValidThread());
-
- if (socket_fd_ == kInvalidSocket || waiting_connect_)
- return false;
-
- // Check if connection is alive and we haven't received any data
- // unexpectedly.
- char c;
- int rv = HANDLE_EINTR(recv(socket_fd_, &c, 1, MSG_PEEK));
- if (rv >= 0)
- return false;
- if (errno != EAGAIN && errno != EWOULDBLOCK)
- return false;
-
- return true;
-}
-
-int SocketLibevent::GetLocalAddress(SockaddrStorage* address) const {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK(address);
-
- if (getsockname(socket_fd_, address->addr, &address->addr_len) < 0)
- return net::MapSystemError(errno);
- return net::OK;
-}
-
-int SocketLibevent::GetPeerAddress(SockaddrStorage* address) const {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK(address);
-
- if (!HasPeerAddress())
- return net::ERR_SOCKET_NOT_CONNECTED;
-
- *address = *peer_address_;
- return net::OK;
-}
-
-void SocketLibevent::SetPeerAddress(const SockaddrStorage& address) {
- DCHECK(thread_checker_.CalledOnValidThread());
- // |peer_address_| will be non-NULL if Connect() has been called. Unless
- // Close() is called to reset the internal state, a second call to Connect()
- // is not allowed.
- // Please note that we don't allow a second Connect() even if the previous
- // Connect() has failed. Connecting the same |socket_| again after a
- // connection attempt failed results in unspecified behavior according to
- // POSIX.
- DCHECK(!peer_address_);
- peer_address_.reset(new SockaddrStorage(address));
-}
-
-bool SocketLibevent::HasPeerAddress() const {
- DCHECK(thread_checker_.CalledOnValidThread());
- return peer_address_ != NULL;
-}
-
-void SocketLibevent::Close() {
- DCHECK(thread_checker_.CalledOnValidThread());
-
- StopWatchingAndCleanUp();
-
- if (socket_fd_ != kInvalidSocket) {
- if (IGNORE_EINTR(close(socket_fd_)) < 0)
- PLOG(ERROR) << "close() returned an error, errno=" << errno;
- socket_fd_ = kInvalidSocket;
- }
-}
-
-void SocketLibevent::OnFileCanReadWithoutBlocking(int fd) {
- DCHECK(!accept_callback_.is_null() || !read_callback_.is_null());
- if (!accept_callback_.is_null()) {
- AcceptCompleted();
- } else { // !read_callback_.is_null()
- NOTREACHED();
- }
-}
-
-void SocketLibevent::OnFileCanWriteWithoutBlocking(int fd) {
- DCHECK(!write_callback_.is_null());
- if (waiting_connect_) {
- ConnectCompleted();
- } else {
- NOTREACHED();
- }
-}
-
-int SocketLibevent::DoAccept(scoped_ptr<SocketLibevent>* socket) {
- SockaddrStorage new_peer_address;
- int new_socket = HANDLE_EINTR(
- accept(socket_fd_, new_peer_address.addr, &new_peer_address.addr_len));
- if (new_socket < 0)
- return MapAcceptError(errno);
-
- scoped_ptr<SocketLibevent> accepted_socket(new SocketLibevent);
- int rv = accepted_socket->AdoptConnectedSocket(new_socket, new_peer_address);
- if (rv != net::OK)
- return rv;
-
- *socket = accepted_socket.Pass();
- return net::OK;
-}
-
-void SocketLibevent::AcceptCompleted() {
- DCHECK(accept_socket_);
- int rv = DoAccept(accept_socket_);
- if (rv == net::ERR_IO_PENDING)
- return;
-
- bool ok = accept_socket_watcher_.StopWatchingFileDescriptor();
- DCHECK(ok);
- accept_socket_ = NULL;
- base::ResetAndReturn(&accept_callback_).Run(rv);
-}
-
-int SocketLibevent::DoConnect() {
- int rv = HANDLE_EINTR(
- connect(socket_fd_, peer_address_->addr, peer_address_->addr_len));
- DCHECK_GE(0, rv);
- return rv == 0 ? net::OK : MapConnectError(errno);
-}
-
-void SocketLibevent::ConnectCompleted() {
- // Get the error that connect() completed with.
- int os_error = 0;
- socklen_t len = sizeof(os_error);
- if (getsockopt(socket_fd_, SOL_SOCKET, SO_ERROR, &os_error, &len) == 0) {
- // TCPSocketLibevent expects errno to be set.
- errno = os_error;
- }
-
- int rv = MapConnectError(errno);
- if (rv == net::ERR_IO_PENDING)
- return;
-
- bool ok = write_socket_watcher_.StopWatchingFileDescriptor();
- DCHECK(ok);
- waiting_connect_ = false;
- base::ResetAndReturn(&write_callback_).Run(rv);
-}
-
-void SocketLibevent::StopWatchingAndCleanUp() {
- bool ok = accept_socket_watcher_.StopWatchingFileDescriptor();
- DCHECK(ok);
-
- if (!accept_callback_.is_null()) {
- accept_socket_ = NULL;
- accept_callback_.Reset();
- }
-
- waiting_connect_ = false;
- peer_address_.reset();
-}
-
-} // namespace shell
-} // namespace mojo
« no previous file with comments | « mojo/shell/domain_socket/socket_libevent.h ('k') | mojo/shell/domain_socket/test_completion_callback.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698