Index: ipc/mojo_event.cc |
diff --git a/ipc/mojo_event.cc b/ipc/mojo_event.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..623b473c9f38c684a117c544c0d4466376c24a0b |
--- /dev/null |
+++ b/ipc/mojo_event.cc |
@@ -0,0 +1,39 @@ |
+// Copyright 2016 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 "ipc/mojo_event.h" |
+ |
+namespace IPC { |
+ |
+MojoEvent::MojoEvent() { |
+ mojo::MessagePipe pipe; |
+ signal_handle_ = std::move(pipe.handle0); |
+ wait_handle_ = std::move(pipe.handle1); |
+} |
+ |
+MojoEvent::~MojoEvent() {} |
+ |
+void MojoEvent::Signal() { |
+ base::AutoLock lock(lock_); |
+ if (is_signaled_) |
+ return; |
+ is_signaled_ = true; |
+ MojoResult rv = mojo::WriteMessageRaw( |
+ signal_handle_.get(), nullptr, 0, nullptr, 0, |
+ MOJO_WRITE_MESSAGE_FLAG_NONE); |
+ DCHECK_EQ(rv, MOJO_RESULT_OK); |
+} |
+ |
+void MojoEvent::Reset() { |
+ base::AutoLock lock(lock_); |
+ if (!is_signaled_) |
+ return; |
+ is_signaled_ = false; |
+ MojoResult rv = mojo::ReadMessageRaw( |
+ wait_handle_.get(), nullptr, nullptr, nullptr, nullptr, |
+ MOJO_READ_MESSAGE_FLAG_NONE); |
+ DCHECK_EQ(rv, MOJO_RESULT_OK); |
+} |
+ |
+} // namespace IPC |