| Index: base/mach_ipc_mac.mm
|
| diff --git a/base/mach_ipc_mac.mm b/base/mach_ipc_mac.mm
|
| deleted file mode 100644
|
| index 6f2575eda03a418598853bf169f499a40f693875..0000000000000000000000000000000000000000
|
| --- a/base/mach_ipc_mac.mm
|
| +++ /dev/null
|
| @@ -1,358 +0,0 @@
|
| -// Copyright (c) 2012 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/mach_ipc_mac.h"
|
| -
|
| -#import <Foundation/Foundation.h>
|
| -#include <mach/vm_map.h>
|
| -
|
| -#include <stdio.h>
|
| -#include "base/logging.h"
|
| -
|
| -namespace base {
|
| -
|
| -// static
|
| -const size_t MachMessage::kEmptyMessageSize = sizeof(mach_msg_header_t) +
|
| - sizeof(mach_msg_body_t) + sizeof(MessageDataPacket);
|
| -
|
| -//==============================================================================
|
| -MachSendMessage::MachSendMessage(int32_t message_id) : MachMessage() {
|
| - Initialize(message_id);
|
| -}
|
| -
|
| -MachSendMessage::MachSendMessage(void *storage, size_t storage_length,
|
| - int32_t message_id)
|
| - : MachMessage(storage, storage_length) {
|
| - Initialize(message_id);
|
| -}
|
| -
|
| -void MachSendMessage::Initialize(int32_t message_id) {
|
| - Head()->msgh_bits = MACH_MSGH_BITS(MACH_MSG_TYPE_COPY_SEND, 0);
|
| -
|
| - // head.msgh_remote_port = ...; // filled out in MachPortSender::SendMessage()
|
| - Head()->msgh_local_port = MACH_PORT_NULL;
|
| - Head()->msgh_reserved = 0;
|
| - Head()->msgh_id = 0;
|
| -
|
| - SetDescriptorCount(0); // start out with no descriptors
|
| -
|
| - SetMessageID(message_id);
|
| - SetData(NULL, 0); // client may add data later
|
| -}
|
| -
|
| -//==============================================================================
|
| -MachMessage::MachMessage()
|
| - : storage_(new MachMessageData), // Allocate storage_ ourselves
|
| - storage_length_bytes_(sizeof(MachMessageData)),
|
| - own_storage_(true) {
|
| - memset(storage_, 0, storage_length_bytes_);
|
| -}
|
| -
|
| -//==============================================================================
|
| -MachMessage::MachMessage(void *storage, size_t storage_length)
|
| - : storage_(static_cast<MachMessageData*>(storage)),
|
| - storage_length_bytes_(storage_length),
|
| - own_storage_(false) {
|
| - DCHECK(storage);
|
| - DCHECK_GE(storage_length, kEmptyMessageSize);
|
| -}
|
| -
|
| -//==============================================================================
|
| -MachMessage::~MachMessage() {
|
| - if (own_storage_) {
|
| - delete storage_;
|
| - storage_ = NULL;
|
| - }
|
| -}
|
| -
|
| -//==============================================================================
|
| -// returns true if successful
|
| -bool MachMessage::SetData(const void* data,
|
| - int32_t data_length) {
|
| - // Enforce the fact that it's only safe to call this method once on a
|
| - // message.
|
| - DCHECK(GetDataPacket()->data_length == 0);
|
| -
|
| - // first check to make sure we have enough space
|
| - int size = CalculateSize();
|
| - int new_size = size + data_length;
|
| -
|
| - if ((unsigned)new_size > storage_length_bytes_) {
|
| - return false; // not enough space
|
| - }
|
| -
|
| - GetDataPacket()->data_length = EndianU32_NtoL(data_length);
|
| - if (data) memcpy(GetDataPacket()->data, data, data_length);
|
| -
|
| - // Update the Mach header with the new aligned size of the message.
|
| - CalculateSize();
|
| -
|
| - return true;
|
| -}
|
| -
|
| -//==============================================================================
|
| -// calculates and returns the total size of the message
|
| -// Currently, the entire message MUST fit inside of the MachMessage
|
| -// messsage size <= EmptyMessageSize()
|
| -int MachMessage::CalculateSize() {
|
| - int size = sizeof(mach_msg_header_t) + sizeof(mach_msg_body_t);
|
| -
|
| - // add space for MessageDataPacket
|
| - int32_t alignedDataLength = (GetDataLength() + 3) & ~0x3;
|
| - size += 2*sizeof(int32_t) + alignedDataLength;
|
| -
|
| - // add space for descriptors
|
| - size += GetDescriptorCount() * sizeof(MachMsgPortDescriptor);
|
| -
|
| - Head()->msgh_size = size;
|
| -
|
| - return size;
|
| -}
|
| -
|
| -//==============================================================================
|
| -MachMessage::MessageDataPacket *MachMessage::GetDataPacket() const {
|
| - int desc_size = sizeof(MachMsgPortDescriptor)*GetDescriptorCount();
|
| - MessageDataPacket *packet =
|
| - reinterpret_cast<MessageDataPacket*>(storage_->padding + desc_size);
|
| -
|
| - return packet;
|
| -}
|
| -
|
| -//==============================================================================
|
| -void MachMessage::SetDescriptor(int n,
|
| - const MachMsgPortDescriptor &desc) {
|
| - MachMsgPortDescriptor *desc_array =
|
| - reinterpret_cast<MachMsgPortDescriptor*>(storage_->padding);
|
| - desc_array[n] = desc;
|
| -}
|
| -
|
| -//==============================================================================
|
| -// returns true if successful otherwise there was not enough space
|
| -bool MachMessage::AddDescriptor(const MachMsgPortDescriptor &desc) {
|
| - // first check to make sure we have enough space
|
| - int size = CalculateSize();
|
| - int new_size = size + sizeof(MachMsgPortDescriptor);
|
| -
|
| - if ((unsigned)new_size > storage_length_bytes_) {
|
| - return false; // not enough space
|
| - }
|
| -
|
| - // unfortunately, we need to move the data to allow space for the
|
| - // new descriptor
|
| - u_int8_t *p = reinterpret_cast<u_int8_t*>(GetDataPacket());
|
| - bcopy(p, p+sizeof(MachMsgPortDescriptor), GetDataLength()+2*sizeof(int32_t));
|
| -
|
| - SetDescriptor(GetDescriptorCount(), desc);
|
| - SetDescriptorCount(GetDescriptorCount() + 1);
|
| -
|
| - CalculateSize();
|
| -
|
| - return true;
|
| -}
|
| -
|
| -//==============================================================================
|
| -void MachMessage::SetDescriptorCount(int n) {
|
| - storage_->body.msgh_descriptor_count = n;
|
| -
|
| - if (n > 0) {
|
| - Head()->msgh_bits |= MACH_MSGH_BITS_COMPLEX;
|
| - } else {
|
| - Head()->msgh_bits &= ~MACH_MSGH_BITS_COMPLEX;
|
| - }
|
| -}
|
| -
|
| -//==============================================================================
|
| -MachMsgPortDescriptor *MachMessage::GetDescriptor(int n) const {
|
| - if (n < GetDescriptorCount()) {
|
| - MachMsgPortDescriptor *desc =
|
| - reinterpret_cast<MachMsgPortDescriptor*>(storage_->padding);
|
| - return desc + n;
|
| - }
|
| -
|
| - return nil;
|
| -}
|
| -
|
| -//==============================================================================
|
| -mach_port_t MachMessage::GetTranslatedPort(int n) const {
|
| - if (n < GetDescriptorCount()) {
|
| - return GetDescriptor(n)->GetMachPort();
|
| - }
|
| - return MACH_PORT_NULL;
|
| -}
|
| -
|
| -#pragma mark -
|
| -
|
| -//==============================================================================
|
| -// create a new mach port for receiving messages and register a name for it
|
| -ReceivePort::ReceivePort(const char *receive_port_name) {
|
| - mach_port_t current_task = mach_task_self();
|
| -
|
| - init_result_ = mach_port_allocate(current_task,
|
| - MACH_PORT_RIGHT_RECEIVE,
|
| - &port_);
|
| -
|
| - if (init_result_ != KERN_SUCCESS)
|
| - return;
|
| -
|
| - init_result_ = mach_port_insert_right(current_task,
|
| - port_,
|
| - port_,
|
| - MACH_MSG_TYPE_MAKE_SEND);
|
| -
|
| - if (init_result_ != KERN_SUCCESS)
|
| - return;
|
| -
|
| - // Without |NSMachPortDeallocateNone|, the NSMachPort seems to deallocate
|
| - // receive rights on port when it is eventually released. It is not necessary
|
| - // to deallocate any rights here as |port_| is fully deallocated in the
|
| - // ReceivePort destructor.
|
| - NSPort *ns_port = [NSMachPort portWithMachPort:port_
|
| - options:NSMachPortDeallocateNone];
|
| - NSString *port_name = [NSString stringWithUTF8String:receive_port_name];
|
| - [[NSMachBootstrapServer sharedInstance] registerPort:ns_port name:port_name];
|
| -}
|
| -
|
| -//==============================================================================
|
| -// create a new mach port for receiving messages
|
| -ReceivePort::ReceivePort() {
|
| - mach_port_t current_task = mach_task_self();
|
| -
|
| - init_result_ = mach_port_allocate(current_task,
|
| - MACH_PORT_RIGHT_RECEIVE,
|
| - &port_);
|
| -
|
| - if (init_result_ != KERN_SUCCESS)
|
| - return;
|
| -
|
| - init_result_ = mach_port_insert_right(current_task,
|
| - port_,
|
| - port_,
|
| - MACH_MSG_TYPE_MAKE_SEND);
|
| -}
|
| -
|
| -//==============================================================================
|
| -// Given an already existing mach port, use it. We take ownership of the
|
| -// port and deallocate it in our destructor.
|
| -ReceivePort::ReceivePort(mach_port_t receive_port)
|
| - : port_(receive_port),
|
| - init_result_(KERN_SUCCESS) {
|
| -}
|
| -
|
| -//==============================================================================
|
| -ReceivePort::~ReceivePort() {
|
| - if (init_result_ == KERN_SUCCESS)
|
| - mach_port_deallocate(mach_task_self(), port_);
|
| -}
|
| -
|
| -//==============================================================================
|
| -kern_return_t ReceivePort::WaitForMessage(MachReceiveMessage *out_message,
|
| - mach_msg_timeout_t timeout) {
|
| - if (!out_message) {
|
| - return KERN_INVALID_ARGUMENT;
|
| - }
|
| -
|
| - // return any error condition encountered in constructor
|
| - if (init_result_ != KERN_SUCCESS)
|
| - return init_result_;
|
| -
|
| - out_message->Head()->msgh_bits = 0;
|
| - out_message->Head()->msgh_local_port = port_;
|
| - out_message->Head()->msgh_remote_port = MACH_PORT_NULL;
|
| - out_message->Head()->msgh_reserved = 0;
|
| - out_message->Head()->msgh_id = 0;
|
| -
|
| - mach_msg_option_t rcv_options = MACH_RCV_MSG;
|
| - if (timeout != MACH_MSG_TIMEOUT_NONE)
|
| - rcv_options |= MACH_RCV_TIMEOUT;
|
| -
|
| - kern_return_t result = mach_msg(out_message->Head(),
|
| - rcv_options,
|
| - 0,
|
| - out_message->MaxSize(),
|
| - port_,
|
| - timeout, // timeout in ms
|
| - MACH_PORT_NULL);
|
| -
|
| - return result;
|
| -}
|
| -
|
| -#pragma mark -
|
| -
|
| -//==============================================================================
|
| -// get a port with send rights corresponding to a named registered service
|
| -MachPortSender::MachPortSender(const char *receive_port_name) {
|
| - mach_port_t bootstrap_port = 0;
|
| - init_result_ = task_get_bootstrap_port(mach_task_self(), &bootstrap_port);
|
| -
|
| - if (init_result_ != KERN_SUCCESS)
|
| - return;
|
| -
|
| - init_result_ = bootstrap_look_up(bootstrap_port,
|
| - const_cast<char*>(receive_port_name),
|
| - &send_port_);
|
| -}
|
| -
|
| -//==============================================================================
|
| -MachPortSender::MachPortSender(mach_port_t send_port)
|
| - : send_port_(send_port),
|
| - init_result_(KERN_SUCCESS) {
|
| -}
|
| -
|
| -//==============================================================================
|
| -kern_return_t MachPortSender::SendMessage(const MachSendMessage& message,
|
| - mach_msg_timeout_t timeout) {
|
| - if (message.Head()->msgh_size == 0) {
|
| - NOTREACHED();
|
| - return KERN_INVALID_VALUE; // just for safety -- never should occur
|
| - };
|
| -
|
| - if (init_result_ != KERN_SUCCESS)
|
| - return init_result_;
|
| -
|
| - message.Head()->msgh_remote_port = send_port_;
|
| -
|
| - kern_return_t result = mach_msg(message.Head(),
|
| - MACH_SEND_MSG | MACH_SEND_TIMEOUT,
|
| - message.Head()->msgh_size,
|
| - 0,
|
| - MACH_PORT_NULL,
|
| - timeout, // timeout in ms
|
| - MACH_PORT_NULL);
|
| -
|
| - return result;
|
| -}
|
| -
|
| -//==============================================================================
|
| -
|
| -namespace mac {
|
| -
|
| -kern_return_t GetNumberOfMachPorts(mach_port_t task_port, int* num_ports) {
|
| - mach_port_name_array_t names;
|
| - mach_msg_type_number_t names_count;
|
| - mach_port_type_array_t types;
|
| - mach_msg_type_number_t types_count;
|
| -
|
| - // A friendlier interface would allow NULL buffers to only get the counts.
|
| - kern_return_t kr = mach_port_names(task_port, &names, &names_count,
|
| - &types, &types_count);
|
| - if (kr != KERN_SUCCESS)
|
| - return kr;
|
| -
|
| - // The documentation states this is an invariant.
|
| - DCHECK_EQ(names_count, types_count);
|
| - *num_ports = names_count;
|
| -
|
| - kr = vm_deallocate(mach_task_self(),
|
| - reinterpret_cast<vm_address_t>(names),
|
| - names_count * sizeof(mach_port_name_array_t));
|
| - kr = vm_deallocate(mach_task_self(),
|
| - reinterpret_cast<vm_address_t>(types),
|
| - types_count * sizeof(mach_port_type_array_t));
|
| -
|
| - return kr;
|
| -}
|
| -
|
| -} // namespace mac
|
| -
|
| -} // namespace base
|
|
|