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.
4
5 #include "ppapi/proxy/proxy_channel.h"
6
7 #include "base/logging.h"
8 #include "ipc/ipc_platform_file.h"
9 #include "ipc/ipc_test_sink.h"
10
11 #if defined(OS_NACL)
12 #include <unistd.h>
13 #endif
14
15 namespace ppapi {
16 namespace proxy {
17
ProxyChannel()18 ProxyChannel::ProxyChannel()
19 : delegate_(NULL),
20 peer_pid_(base::kNullProcessId),
21 test_sink_(NULL) {
22 }
23
~ProxyChannel()24 ProxyChannel::~ProxyChannel() {
25 DVLOG(1) << "ProxyChannel::~ProxyChannel()";
26 }
27
InitWithChannel(Delegate * delegate,base::ProcessId peer_pid,const IPC::ChannelHandle & channel_handle,bool is_client)28 bool ProxyChannel::InitWithChannel(Delegate* delegate,
29 base::ProcessId peer_pid,
30 const IPC::ChannelHandle& channel_handle,
31 bool is_client) {
32 delegate_ = delegate;
33 peer_pid_ = peer_pid;
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());
40 return true;
41 }
42
InitWithTestSink(IPC::TestSink * test_sink)43 void ProxyChannel::InitWithTestSink(IPC::TestSink* test_sink) {
44 DCHECK(!test_sink_);
45 test_sink_ = test_sink;
46 #if !defined(OS_NACL)
47 peer_pid_ = base::GetCurrentProcId();
48 #endif
49 }
50
OnChannelError()51 void ProxyChannel::OnChannelError() {
52 channel_.reset();
53 }
54
55 #if defined(OS_POSIX) && !defined(OS_NACL)
TakeRendererFD()56 int ProxyChannel::TakeRendererFD() {
57 DCHECK(channel());
58 return channel()->TakeClientFileDescriptor();
59 }
60 #endif
61
ShareHandleWithRemote(base::PlatformFile handle,bool should_close_source)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);
69 }
70 return IPC::InvalidPlatformFileForTransit();
71 }
72 DCHECK(peer_pid_ != base::kNullProcessId);
73 return delegate_->ShareHandleWithRemote(handle, peer_pid_,
74 should_close_source);
75 }
76
Send(IPC::Message * msg)77 bool ProxyChannel::Send(IPC::Message* msg) {
78 if (test_sink_)
79 return test_sink_->Send(msg);
80 if (channel_.get())
81 return channel_->Send(msg);
82
83 // Remote side crashed, drop this message.
84 delete msg;
85 return false;
86 }
87
88 } // namespace proxy
89 } // namespace ppapi
90