| Index: sandbox/mac/dispatch_source_mach_unittest.cc
|
| diff --git a/sandbox/mac/dispatch_source_mach_unittest.cc b/sandbox/mac/dispatch_source_mach_unittest.cc
|
| deleted file mode 100644
|
| index 123a44c3c1fa2cb8e8b03d9fb35c1043b053ebe2..0000000000000000000000000000000000000000
|
| --- a/sandbox/mac/dispatch_source_mach_unittest.cc
|
| +++ /dev/null
|
| @@ -1,119 +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 "sandbox/mac/dispatch_source_mach.h"
|
| -
|
| -#include <mach/mach.h>
|
| -
|
| -#include "base/logging.h"
|
| -#include "base/mac/scoped_mach_port.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "base/test/test_timeouts.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -
|
| -namespace sandbox {
|
| -
|
| -class DispatchSourceMachTest : public testing::Test {
|
| - public:
|
| - void SetUp() override {
|
| - mach_port_t port = MACH_PORT_NULL;
|
| - ASSERT_EQ(KERN_SUCCESS, mach_port_allocate(mach_task_self(),
|
| - MACH_PORT_RIGHT_RECEIVE, &port));
|
| - receive_right_.reset(port);
|
| -
|
| - ASSERT_EQ(KERN_SUCCESS, mach_port_insert_right(mach_task_self(), port,
|
| - port, MACH_MSG_TYPE_MAKE_SEND));
|
| - send_right_.reset(port);
|
| - }
|
| -
|
| - mach_port_t port() { return receive_right_.get(); }
|
| -
|
| - void WaitForSemaphore(dispatch_semaphore_t semaphore) {
|
| - dispatch_semaphore_wait(semaphore, dispatch_time(
|
| - DISPATCH_TIME_NOW,
|
| - TestTimeouts::action_timeout().InSeconds() * NSEC_PER_SEC));
|
| - }
|
| -
|
| - private:
|
| - base::mac::ScopedMachReceiveRight receive_right_;
|
| - base::mac::ScopedMachSendRight send_right_;
|
| -};
|
| -
|
| -TEST_F(DispatchSourceMachTest, ReceiveAfterResume) {
|
| - dispatch_semaphore_t signal = dispatch_semaphore_create(0);
|
| -
|
| - bool __block did_receive = false;
|
| - DispatchSourceMach source("org.chromium.sandbox.test.ReceiveAfterResume",
|
| - port(), ^{
|
| - mach_msg_empty_rcv_t msg = {{0}};
|
| - msg.header.msgh_size = sizeof(msg);
|
| - msg.header.msgh_local_port = port();
|
| - mach_msg_receive(&msg.header);
|
| - did_receive = true;
|
| -
|
| - dispatch_semaphore_signal(signal);
|
| - });
|
| -
|
| - mach_msg_empty_send_t msg = {{0}};
|
| - msg.header.msgh_size = sizeof(msg);
|
| - msg.header.msgh_remote_port = port();
|
| - msg.header.msgh_bits = MACH_MSGH_BITS_REMOTE(MACH_MSG_TYPE_COPY_SEND);
|
| - ASSERT_EQ(KERN_SUCCESS, mach_msg_send(&msg.header));
|
| -
|
| - EXPECT_FALSE(did_receive);
|
| -
|
| - source.Resume();
|
| -
|
| - WaitForSemaphore(signal);
|
| -
|
| - EXPECT_TRUE(did_receive);
|
| -}
|
| -
|
| -TEST_F(DispatchSourceMachTest, NoMessagesAfterDestruction) {
|
| - scoped_ptr<int> count(new int(0));
|
| - int* __block count_ptr = count.get();
|
| -
|
| - scoped_ptr<DispatchSourceMach> source(new DispatchSourceMach(
|
| - "org.chromium.sandbox.test.NoMessagesAfterDestruction",
|
| - port(), ^{
|
| - mach_msg_empty_rcv_t msg = {{0}};
|
| - msg.header.msgh_size = sizeof(msg);
|
| - msg.header.msgh_local_port = port();
|
| - mach_msg_receive(&msg.header);
|
| - LOG(INFO) << "Receieve " << *count_ptr;
|
| - ++(*count_ptr);
|
| - }));
|
| - source->Resume();
|
| -
|
| - dispatch_queue_t queue =
|
| - dispatch_queue_create("org.chromium.sandbox.test.MessageSend", NULL);
|
| - dispatch_semaphore_t signal = dispatch_semaphore_create(0);
|
| - for (int i = 0; i < 30; ++i) {
|
| - dispatch_async(queue, ^{
|
| - mach_msg_empty_send_t msg = {{0}};
|
| - msg.header.msgh_size = sizeof(msg);
|
| - msg.header.msgh_remote_port = port();
|
| - msg.header.msgh_bits =
|
| - MACH_MSGH_BITS_REMOTE(MACH_MSG_TYPE_COPY_SEND);
|
| - mach_msg_send(&msg.header);
|
| - });
|
| -
|
| - // After sending five messages, shut down the source and taint the
|
| - // pointer the handler dereferences. The test will crash if |count_ptr|
|
| - // is being used after "free".
|
| - if (i == 5) {
|
| - scoped_ptr<DispatchSourceMach>* source_ptr = &source;
|
| - dispatch_async(queue, ^{
|
| - source_ptr->reset();
|
| - count_ptr = reinterpret_cast<int*>(0xdeaddead);
|
| - dispatch_semaphore_signal(signal);
|
| - });
|
| - }
|
| - }
|
| -
|
| - WaitForSemaphore(signal);
|
| - dispatch_release(queue);
|
| -}
|
| -
|
| -} // namespace sandbox
|
|
|