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

Unified Diff: base/posix/unix_domain_socket_linux.cc

Issue 1647803004: Move base to DEPS (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 4 years, 11 months 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 | « base/posix/unix_domain_socket_linux.h ('k') | base/posix/unix_domain_socket_linux_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: base/posix/unix_domain_socket_linux.cc
diff --git a/base/posix/unix_domain_socket_linux.cc b/base/posix/unix_domain_socket_linux.cc
deleted file mode 100644
index 62c930fdee7c02620bdc25a48e7d91cad3d3e523..0000000000000000000000000000000000000000
--- a/base/posix/unix_domain_socket_linux.cc
+++ /dev/null
@@ -1,245 +0,0 @@
-// Copyright (c) 2011 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 "base/posix/unix_domain_socket_linux.h"
-
-#include <errno.h>
-#include <sys/socket.h>
-#include <unistd.h>
-
-#include <vector>
-
-#include "base/files/scoped_file.h"
-#include "base/logging.h"
-#include "base/memory/scoped_vector.h"
-#include "base/pickle.h"
-#include "base/posix/eintr_wrapper.h"
-#include "base/stl_util.h"
-
-#if !defined(OS_NACL_NONSFI)
-#include <sys/uio.h>
-#endif
-
-namespace base {
-
-const size_t UnixDomainSocket::kMaxFileDescriptors = 16;
-
-#if !defined(OS_NACL_NONSFI)
-// Creates a connected pair of UNIX-domain SOCK_SEQPACKET sockets, and passes
-// ownership of the newly allocated file descriptors to |one| and |two|.
-// Returns true on success.
-static bool CreateSocketPair(ScopedFD* one, ScopedFD* two) {
- int raw_socks[2];
- if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, raw_socks) == -1)
- return false;
- one->reset(raw_socks[0]);
- two->reset(raw_socks[1]);
- return true;
-}
-
-// static
-bool UnixDomainSocket::EnableReceiveProcessId(int fd) {
- const int enable = 1;
- return setsockopt(fd, SOL_SOCKET, SO_PASSCRED, &enable, sizeof(enable)) == 0;
-}
-#endif // !defined(OS_NACL_NONSFI)
-
-// static
-bool UnixDomainSocket::SendMsg(int fd,
- const void* buf,
- size_t length,
- const std::vector<int>& fds) {
- struct msghdr msg = {};
- struct iovec iov = { const_cast<void*>(buf), length };
- msg.msg_iov = &iov;
- msg.msg_iovlen = 1;
-
- char* control_buffer = NULL;
- if (fds.size()) {
- const unsigned control_len = CMSG_SPACE(sizeof(int) * fds.size());
- control_buffer = new char[control_len];
-
- struct cmsghdr* cmsg;
- msg.msg_control = control_buffer;
- msg.msg_controllen = control_len;
- cmsg = CMSG_FIRSTHDR(&msg);
- cmsg->cmsg_level = SOL_SOCKET;
- cmsg->cmsg_type = SCM_RIGHTS;
- cmsg->cmsg_len = CMSG_LEN(sizeof(int) * fds.size());
- memcpy(CMSG_DATA(cmsg), &fds[0], sizeof(int) * fds.size());
- msg.msg_controllen = cmsg->cmsg_len;
- }
-
- // Avoid a SIGPIPE if the other end breaks the connection.
- // Due to a bug in the Linux kernel (net/unix/af_unix.c) MSG_NOSIGNAL isn't
- // regarded for SOCK_SEQPACKET in the AF_UNIX domain, but it is mandated by
- // POSIX.
- const int flags = MSG_NOSIGNAL;
- const ssize_t r = HANDLE_EINTR(sendmsg(fd, &msg, flags));
- const bool ret = static_cast<ssize_t>(length) == r;
- delete[] control_buffer;
- return ret;
-}
-
-// static
-ssize_t UnixDomainSocket::RecvMsg(int fd,
- void* buf,
- size_t length,
- ScopedVector<ScopedFD>* fds) {
- return UnixDomainSocket::RecvMsgWithPid(fd, buf, length, fds, NULL);
-}
-
-// static
-ssize_t UnixDomainSocket::RecvMsgWithPid(int fd,
- void* buf,
- size_t length,
- ScopedVector<ScopedFD>* fds,
- ProcessId* pid) {
- return UnixDomainSocket::RecvMsgWithFlags(fd, buf, length, 0, fds, pid);
-}
-
-// static
-ssize_t UnixDomainSocket::RecvMsgWithFlags(int fd,
- void* buf,
- size_t length,
- int flags,
- ScopedVector<ScopedFD>* fds,
- ProcessId* out_pid) {
- fds->clear();
-
- struct msghdr msg = {};
- struct iovec iov = { buf, length };
- msg.msg_iov = &iov;
- msg.msg_iovlen = 1;
-
- const size_t kControlBufferSize =
- CMSG_SPACE(sizeof(int) * kMaxFileDescriptors)
-#if !defined(OS_NACL_NONSFI)
- // The PNaCl toolchain for Non-SFI binary build does not support ucred.
- + CMSG_SPACE(sizeof(struct ucred))
-#endif
- ;
- char control_buffer[kControlBufferSize];
- msg.msg_control = control_buffer;
- msg.msg_controllen = sizeof(control_buffer);
-
- const ssize_t r = HANDLE_EINTR(recvmsg(fd, &msg, flags));
- if (r == -1)
- return -1;
-
- int* wire_fds = NULL;
- unsigned wire_fds_len = 0;
- ProcessId pid = -1;
-
- if (msg.msg_controllen > 0) {
- struct cmsghdr* cmsg;
- for (cmsg = CMSG_FIRSTHDR(&msg); cmsg; cmsg = CMSG_NXTHDR(&msg, cmsg)) {
- const unsigned payload_len = cmsg->cmsg_len - CMSG_LEN(0);
- if (cmsg->cmsg_level == SOL_SOCKET &&
- cmsg->cmsg_type == SCM_RIGHTS) {
- DCHECK_EQ(payload_len % sizeof(int), 0u);
- DCHECK_EQ(wire_fds, static_cast<void*>(nullptr));
- wire_fds = reinterpret_cast<int*>(CMSG_DATA(cmsg));
- wire_fds_len = payload_len / sizeof(int);
- }
-#if !defined(OS_NACL_NONSFI)
- // The PNaCl toolchain for Non-SFI binary build does not support
- // SCM_CREDENTIALS.
- if (cmsg->cmsg_level == SOL_SOCKET &&
- cmsg->cmsg_type == SCM_CREDENTIALS) {
- DCHECK_EQ(payload_len, sizeof(struct ucred));
- DCHECK_EQ(pid, -1);
- pid = reinterpret_cast<struct ucred*>(CMSG_DATA(cmsg))->pid;
- }
-#endif
- }
- }
-
- if (msg.msg_flags & MSG_TRUNC || msg.msg_flags & MSG_CTRUNC) {
- for (unsigned i = 0; i < wire_fds_len; ++i)
- close(wire_fds[i]);
- errno = EMSGSIZE;
- return -1;
- }
-
- if (wire_fds) {
- for (unsigned i = 0; i < wire_fds_len; ++i)
- fds->push_back(new ScopedFD(wire_fds[i]));
- }
-
- if (out_pid) {
- // |pid| will legitimately be -1 if we read EOF, so only DCHECK if we
- // actually received a message. Unfortunately, Linux allows sending zero
- // length messages, which are indistinguishable from EOF, so this check
- // has false negatives.
- if (r > 0 || msg.msg_controllen > 0)
- DCHECK_GE(pid, 0);
-
- *out_pid = pid;
- }
-
- return r;
-}
-
-#if !defined(OS_NACL_NONSFI)
-// static
-ssize_t UnixDomainSocket::SendRecvMsg(int fd,
- uint8_t* reply,
- unsigned max_reply_len,
- int* result_fd,
- const Pickle& request) {
- return UnixDomainSocket::SendRecvMsgWithFlags(fd, reply, max_reply_len,
- 0, /* recvmsg_flags */
- result_fd, request);
-}
-
-// static
-ssize_t UnixDomainSocket::SendRecvMsgWithFlags(int fd,
- uint8_t* reply,
- unsigned max_reply_len,
- int recvmsg_flags,
- int* result_fd,
- const Pickle& request) {
- // This socketpair is only used for the IPC and is cleaned up before
- // returning.
- ScopedFD recv_sock, send_sock;
- if (!CreateSocketPair(&recv_sock, &send_sock))
- return -1;
-
- {
- std::vector<int> send_fds;
- send_fds.push_back(send_sock.get());
- if (!SendMsg(fd, request.data(), request.size(), send_fds))
- return -1;
- }
-
- // Close the sending end of the socket right away so that if our peer closes
- // it before sending a response (e.g., from exiting), RecvMsgWithFlags() will
- // return EOF instead of hanging.
- send_sock.reset();
-
- ScopedVector<ScopedFD> recv_fds;
- // When porting to OSX keep in mind it doesn't support MSG_NOSIGNAL, so the
- // sender might get a SIGPIPE.
- const ssize_t reply_len = RecvMsgWithFlags(
- recv_sock.get(), reply, max_reply_len, recvmsg_flags, &recv_fds, NULL);
- recv_sock.reset();
- if (reply_len == -1)
- return -1;
-
- // If we received more file descriptors than caller expected, then we treat
- // that as an error.
- if (recv_fds.size() > (result_fd != NULL ? 1 : 0)) {
- NOTREACHED();
- return -1;
- }
-
- if (result_fd)
- *result_fd = recv_fds.empty() ? -1 : recv_fds[0]->release();
-
- return reply_len;
-}
-#endif // !defined(OS_NACL_NONSFI)
-
-} // namespace base
« no previous file with comments | « base/posix/unix_domain_socket_linux.h ('k') | base/posix/unix_domain_socket_linux_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698