Move CancellationFlag and WaitableEvent to the synchronization subdirectory....

base/waitable_event_unittest.cc

-// Copyright (c) 2010 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/time.h"
-#include "base/waitable_event.h"
-#include "base/threading/platform_thread.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-using base::TimeDelta;
-using base::WaitableEvent;
-
-namespace {
-typedef testing::Test WaitableEventTest;
-}
-
-TEST(WaitableEventTest, ManualBasics) {
-  WaitableEvent event(true, false);
-
-  EXPECT_FALSE(event.IsSignaled());
-
-  event.Signal();
-  EXPECT_TRUE(event.IsSignaled());
-  EXPECT_TRUE(event.IsSignaled());
-
-  event.Reset();
-  EXPECT_FALSE(event.IsSignaled());
-  EXPECT_FALSE(event.TimedWait(TimeDelta::FromMilliseconds(10)));
-
-  event.Signal();
-  EXPECT_TRUE(event.Wait());
-  EXPECT_TRUE(event.TimedWait(TimeDelta::FromMilliseconds(10)));
-}
-
-TEST(WaitableEventTest, AutoBasics) {
-  WaitableEvent event(false, false);
-
-  EXPECT_FALSE(event.IsSignaled());
-
-  event.Signal();
-  EXPECT_TRUE(event.IsSignaled());
-  EXPECT_FALSE(event.IsSignaled());
-
-  event.Reset();
-  EXPECT_FALSE(event.IsSignaled());
-  EXPECT_FALSE(event.TimedWait(TimeDelta::FromMilliseconds(10)));
-
-  event.Signal();
-  EXPECT_TRUE(event.Wait());
-  EXPECT_FALSE(event.TimedWait(TimeDelta::FromMilliseconds(10)));
-
-  event.Signal();
-  EXPECT_TRUE(event.TimedWait(TimeDelta::FromMilliseconds(10)));
-}
-
-TEST(WaitableEventTest, WaitManyShortcut) {
-  WaitableEvent* ev[5];
-  for (unsigned i = 0; i < 5; ++i)
-    ev[i] = new WaitableEvent(false, false);
-
-  ev[3]->Signal();
-  EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 3u);
-
-  ev[3]->Signal();
-  EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 3u);
-
-  ev[4]->Signal();
-  EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 4u);
-
-  ev[0]->Signal();
-  EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 0u);
-
-  for (unsigned i = 0; i < 5; ++i)
-    delete ev[i];
-}
-
-class WaitableEventSignaler : public base::PlatformThread::Delegate {
- public:
-  WaitableEventSignaler(double seconds, WaitableEvent* ev)
-      : seconds_(seconds),
-        ev_(ev) {
-  }
-
-  void ThreadMain() {
-    base::PlatformThread::Sleep(static_cast<int>(seconds_ * 1000));
-    ev_->Signal();
-  }
-
- private:
-  const double seconds_;
-  WaitableEvent *const ev_;
-};
-
-TEST(WaitableEventTest, WaitMany) {
-  WaitableEvent* ev[5];
-  for (unsigned i = 0; i < 5; ++i)
-    ev[i] = new WaitableEvent(false, false);
-
-  WaitableEventSignaler signaler(0.1, ev[2]);
-  base::PlatformThreadHandle thread;
-  base::PlatformThread::Create(0, &signaler, &thread);
-
-  EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 2u);
-
-  base::PlatformThread::Join(thread);
-
-  for (unsigned i = 0; i < 5; ++i)
-    delete ev[i];
-}