Refactored ppapi Dispatcher to share common code between the plugin and broker dispatchers.

Common code is in DispatcherBase. The base of the dispatcher for plugins remains Dispatcher. The base of the dispatcher for Brokers is BrokerDispatcher.

BUG=none
TEST=ppapi out-of-process plugins

Review URL: http://codereview.chromium.org/6859003

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@81883 0039d316-1c4b-4281-b951-d872f2087c98

1 files changed, 88 insertions, 0 deletions

diff --git a/ppapi/proxy/proxy_channel.cc b/ppapi/proxy/proxy_channel.cc
new file mode 100644
index 0000000..0bce041
--- /dev/null
+++ b/ppapi/proxy/proxy_channel.cc
@@ -0,0 +1,88 @@
+// Copyright (c) 2011 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 "ppapi/proxy/proxy_channel.h"
+
+#include "ipc/ipc_test_sink.h"
+
+namespace pp {
+namespace proxy {
+
+ProxyChannel::ProxyChannel(base::ProcessHandle remote_process_handle)
+    : delegate_(NULL),
+      remote_process_handle_(remote_process_handle),
+      test_sink_(NULL) {
+}
+
+ProxyChannel::~ProxyChannel() {
+}
+
+bool ProxyChannel::InitWithChannel(Delegate* delegate,
+                                   const IPC::ChannelHandle& channel_handle,
+                                   bool is_client) {
+  delegate_ = delegate;
+  IPC::Channel::Mode mode = is_client ? IPC::Channel::MODE_CLIENT
+                                      : IPC::Channel::MODE_SERVER;
+  channel_.reset(new IPC::SyncChannel(channel_handle, mode, this,
+                                      delegate->GetIPCMessageLoop(), false,
+                                      delegate->GetShutdownEvent()));
+  return true;
+}
+
+void ProxyChannel::InitWithTestSink(IPC::TestSink* test_sink) {
+  DCHECK(!test_sink_);
+  test_sink_ = test_sink;
+}
+
+void ProxyChannel::OnChannelError() {
+  channel_.reset();
+}
+
+#if defined(OS_POSIX)
+int ProxyChannel::GetRendererFD() {
+  DCHECK(channel());
+  return channel()->GetClientFileDescriptor();
+}
+#endif
+
+IPC::PlatformFileForTransit ProxyChannel::ShareHandleWithRemote(
+      base::PlatformFile handle,
+      bool should_close_source) {
+  IPC::PlatformFileForTransit out_handle;
+#if defined(OS_WIN)
+  DWORD options = DUPLICATE_SAME_ACCESS;
+  if (should_close_source)
+    options |= DUPLICATE_CLOSE_SOURCE;
+  if (!::DuplicateHandle(::GetCurrentProcess(),
+                         handle,
+                         remote_process_handle_,
+                         &out_handle,
+                         0,
+                         FALSE,
+                         options))
+    out_handle = IPC::InvalidPlatformFileForTransit();
+#elif defined(OS_POSIX)
+  // If asked to close the source, we can simply re-use the source fd instead of
+  // dup()ing and close()ing.
+  int fd = should_close_source ? handle : ::dup(handle);
+  out_handle = base::FileDescriptor(fd, true);
+#else
+  #error Not implemented.
+#endif
+  return out_handle;
+}
+
+bool ProxyChannel::Send(IPC::Message* msg) {
+  if (test_sink_)
+    return test_sink_->Send(msg);
+  if (channel_.get())
+    return channel_->Send(msg);
+
+  // Remote side crashed, drop this message.
+  delete msg;
+  return false;
+}
+
+}  // namespace proxy
+}  // namespace pp