1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #include "ppapi/proxy/proxy_channel.h"
7 #include "base/logging.h"
8 #include "ipc/ipc_platform_file.h"
9 #include "ipc/ipc_test_sink.h"
18 ProxyChannel::ProxyChannel()
20 peer_pid_(base::kNullProcessId),
24 ProxyChannel::~ProxyChannel() {
25 DVLOG(1) << "ProxyChannel::~ProxyChannel()";
28 bool ProxyChannel::InitWithChannel(Delegate* delegate,
29 base::ProcessId peer_pid,
30 const IPC::ChannelHandle& channel_handle,
34 IPC::Channel::Mode mode = is_client
35 ? IPC::Channel::MODE_CLIENT
36 : IPC::Channel::MODE_SERVER;
37 channel_ = IPC::SyncChannel::Create(channel_handle, mode, this,
38 delegate->GetIPCMessageLoop(), true,
39 delegate->GetShutdownEvent());
43 void ProxyChannel::InitWithTestSink(IPC::TestSink* test_sink) {
45 test_sink_ = test_sink;
47 peer_pid_ = base::GetCurrentProcId();
51 void ProxyChannel::OnChannelError() {
55 #if defined(OS_POSIX) && !defined(OS_NACL)
56 base::ScopedFD ProxyChannel::TakeRendererFD() {
58 return channel()->TakeClientFileDescriptor();
62 IPC::PlatformFileForTransit ProxyChannel::ShareHandleWithRemote(
63 base::PlatformFile handle,
64 bool should_close_source) {
65 // Channel could be closed if the plugin crashes.
66 if (!channel_.get()) {
67 if (should_close_source) {
68 base::File file_closer(handle);
70 return IPC::InvalidPlatformFileForTransit();
72 DCHECK(peer_pid_ != base::kNullProcessId);
73 return delegate_->ShareHandleWithRemote(handle, peer_pid_,
77 bool ProxyChannel::Send(IPC::Message* msg) {
79 return test_sink_->Send(msg);
81 return channel_->Send(msg);
83 // Remote side crashed, drop this message.