Chromium Code Reviews| Index: base/synchronization/waitable_event_watcher_unittest.cc |
| diff --git a/base/synchronization/waitable_event_watcher_unittest.cc b/base/synchronization/waitable_event_watcher_unittest.cc |
| index 9df72892c3c3813adf8d1286c7bdf6dfefe48930..362c8f2b62945713496aee9fbf9dc5c2b88ca4e5 100644 |
| --- a/base/synchronization/waitable_event_watcher_unittest.cc |
| +++ b/base/synchronization/waitable_event_watcher_unittest.cc |
| @@ -7,10 +7,12 @@ |
| #include "base/bind.h" |
| #include "base/callback.h" |
| #include "base/macros.h" |
| +#include "base/memory/ptr_util.h" |
| #include "base/message_loop/message_loop.h" |
| #include "base/run_loop.h" |
| #include "base/synchronization/waitable_event.h" |
| #include "base/threading/platform_thread.h" |
| +#include "base/threading/sequenced_task_runner_handle.h" |
| #include "build/build_config.h" |
| #include "testing/gtest/include/gtest/gtest.h" |
| @@ -38,6 +40,7 @@ class DecrementCountContainer { |
| explicit DecrementCountContainer(int* counter) : counter_(counter) { |
| } |
| void OnWaitableEventSignaled(WaitableEvent* object) { |
| + // NOTE: |object| may be already deleted. |
| --(*counter_); |
| } |
| private: |
| @@ -126,15 +129,35 @@ void RunTest_DeleteUnder(MessageLoop::Type message_loop_type) { |
| { |
| WaitableEventWatcher watcher; |
| - WaitableEvent* event = |
| - new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC, |
| - WaitableEvent::InitialState::NOT_SIGNALED); |
| + auto event = new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC, |
|
danakj
2017/05/04 16:09:37
auto*
|
| + WaitableEvent::InitialState::NOT_SIGNALED); |
| watcher.StartWatching(event, BindOnce(&QuitWhenSignaled)); |
| delete event; |
| } |
| } |
| +void RunTest_SignalAndDelete(MessageLoop::Type message_loop_type) { |
| + // Signal and immediately delete the WaitableEvent out from under the Watcher. |
| + |
| + MessageLoop message_loop(message_loop_type); |
| + |
| + { |
| + WaitableEventWatcher watcher; |
| + |
| + auto event = base::MakeUnique<WaitableEvent>( |
| + WaitableEvent::ResetPolicy::AUTOMATIC, |
| + WaitableEvent::InitialState::NOT_SIGNALED); |
| + |
| + watcher.StartWatching(event.get(), BindOnce(&QuitWhenSignaled)); |
| + event->Signal(); |
| + event.reset(); |
| + |
| + // Wait for the watcher callback: |
|
danakj
2017/05/04 16:09:38
nit: s/:/./
|
| + RunLoop().Run(); |
| + } |
| +} |
| + |
| } // namespace |
| //----------------------------------------------------------------------------- |
| @@ -169,4 +192,10 @@ TEST(WaitableEventWatcherTest, DeleteUnder) { |
| } |
| } |
| +TEST(WaitableEventWatcherTest, SignalAndDelete) { |
| + for (int i = 0; i < kNumTestingMessageLoops; i++) { |
| + RunTest_SignalAndDelete(testing_message_loops[i]); |
| + } |
| +} |
| + |
| } // namespace base |