Support generic synchronization against an IPC::Channel

ipc/ipc_message_pipe_reader.cc

 // 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 "ipc/ipc_message_pipe_reader.h"
 
 #include <stdint.h>
 
 #include <utility>
 
@@ skipping 66 matching lines @@
 void MessagePipeReader::GetRemoteInterface(
     const std::string& name,
     mojo::ScopedInterfaceEndpointHandle handle) {
   if (!sender_.is_bound())
     return;
   mojom::GenericInterfaceAssociatedRequest request;
   request.Bind(std::move(handle));
   sender_->GetAssociatedInterface(name, std::move(request));
 }
 
+void MessagePipeReader::SendEventToSignal(mojo::common::mojom::EventPtr event) {
+  if (!sender_.is_bound())
+    return;
+  sender_->SignalEvent(std::move(event));
+}
+
 void MessagePipeReader::SetPeerPid(int32_t peer_pid) {
   peer_pid_ = peer_pid;
   delegate_->OnPeerPidReceived();
 }
 
 void MessagePipeReader::Receive(
     const std::vector<uint8_t>& data,
     base::Optional<std::vector<mojom::SerializedHandlePtr>> handles) {
   DCHECK_NE(peer_pid_, base::kNullProcessId);
   Message message(
@@ skipping 17 matching lines @@
 }
 
 void MessagePipeReader::GetAssociatedInterface(
     const std::string& name,
     mojom::GenericInterfaceAssociatedRequest request) {
   DCHECK(thread_checker_.CalledOnValidThread());
   if (delegate_)
     delegate_->OnAssociatedInterfaceRequest(name, request.PassHandle());
 }
 
+void MessagePipeReader::SignalEvent(mojo::common::mojom::EventPtr event) {
+  event->Signal();
+}
+
 void MessagePipeReader::OnPipeError(MojoResult error) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   Close();
 
   // NOTE: The delegate call below may delete |this|.
   if (delegate_)
     delegate_->OnPipeError();
 }
 
 }  // namespace internal
 }  // namespace IPC