| Index: content/common/unix_domain_socket_posix.cc
|
| ===================================================================
|
| --- content/common/unix_domain_socket_posix.cc (revision 140304)
|
| +++ content/common/unix_domain_socket_posix.cc (working copy)
|
| @@ -1,146 +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 "content/common/unix_domain_socket_posix.h"
|
| -
|
| -#include <errno.h>
|
| -#include <unistd.h>
|
| -#include <sys/uio.h>
|
| -#include <sys/socket.h>
|
| -
|
| -#include "base/eintr_wrapper.h"
|
| -#include "base/logging.h"
|
| -#include "base/pickle.h"
|
| -#include "base/stl_util.h"
|
| -
|
| -// static
|
| -bool UnixDomainSocket::SendMsg(int fd,
|
| - const void* buf,
|
| - size_t length,
|
| - const std::vector<int>& fds) {
|
| - struct msghdr msg;
|
| - memset(&msg, 0, sizeof(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;
|
| - }
|
| -
|
| - const ssize_t r = HANDLE_EINTR(sendmsg(fd, &msg, 0));
|
| - 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,
|
| - std::vector<int>* fds) {
|
| - static const unsigned kMaxDescriptors = 16;
|
| -
|
| - fds->clear();
|
| -
|
| - struct msghdr msg;
|
| - memset(&msg, 0, sizeof(msg));
|
| - struct iovec iov = {buf, length};
|
| - msg.msg_iov = &iov;
|
| - msg.msg_iovlen = 1;
|
| -
|
| - char control_buffer[CMSG_SPACE(sizeof(int) * kMaxDescriptors)];
|
| - msg.msg_control = control_buffer;
|
| - msg.msg_controllen = sizeof(control_buffer);
|
| -
|
| - const ssize_t r = HANDLE_EINTR(recvmsg(fd, &msg, 0));
|
| - if (r == -1)
|
| - return -1;
|
| -
|
| - int* wire_fds = NULL;
|
| - unsigned wire_fds_len = 0;
|
| -
|
| - if (msg.msg_controllen > 0) {
|
| - struct cmsghdr* cmsg;
|
| - for (cmsg = CMSG_FIRSTHDR(&msg); cmsg; cmsg = CMSG_NXTHDR(&msg, cmsg)) {
|
| - if (cmsg->cmsg_level == SOL_SOCKET &&
|
| - cmsg->cmsg_type == SCM_RIGHTS) {
|
| - const unsigned payload_len = cmsg->cmsg_len - CMSG_LEN(0);
|
| - DCHECK(payload_len % sizeof(int) == 0);
|
| - wire_fds = reinterpret_cast<int*>(CMSG_DATA(cmsg));
|
| - wire_fds_len = payload_len / sizeof(int);
|
| - break;
|
| - }
|
| - }
|
| - }
|
| -
|
| - 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;
|
| - }
|
| -
|
| - fds->resize(wire_fds_len);
|
| - memcpy(vector_as_array(fds), wire_fds, sizeof(int) * wire_fds_len);
|
| -
|
| - return r;
|
| -}
|
| -
|
| -// static
|
| -ssize_t UnixDomainSocket::SendRecvMsg(int fd,
|
| - uint8_t* reply,
|
| - unsigned max_reply_len,
|
| - int* result_fd,
|
| - const Pickle& request) {
|
| - int fds[2];
|
| -
|
| - // This socketpair is only used for the IPC and is cleaned up before
|
| - // returning.
|
| - if (socketpair(AF_UNIX, SOCK_DGRAM, 0, fds) == -1)
|
| - return false;
|
| -
|
| - std::vector<int> fd_vector;
|
| - fd_vector.push_back(fds[1]);
|
| - if (!SendMsg(fd, request.data(), request.size(), fd_vector)) {
|
| - close(fds[0]);
|
| - close(fds[1]);
|
| - return -1;
|
| - }
|
| - close(fds[1]);
|
| -
|
| - fd_vector.clear();
|
| - const ssize_t reply_len = RecvMsg(fds[0], reply, max_reply_len, &fd_vector);
|
| - close(fds[0]);
|
| - if (reply_len == -1)
|
| - return -1;
|
| -
|
| - if ((!fd_vector.empty() && result_fd == NULL) || fd_vector.size() > 1) {
|
| - for (std::vector<int>::const_iterator
|
| - i = fd_vector.begin(); i != fd_vector.end(); ++i) {
|
| - close(*i);
|
| - }
|
| -
|
| - NOTREACHED();
|
| -
|
| - return -1;
|
| - }
|
| -
|
| - if (result_fd)
|
| - *result_fd = fd_vector.empty() ? -1 : fd_vector[0];
|
| -
|
| - return reply_len;
|
| -}
|
|
|