| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2011 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 "content/browser/renderer_host/java/java_bridge_channel_host.h" | |
| 6 | |
| 7 #include "base/atomicops.h" | |
| 8 #include "base/lazy_instance.h" | |
| 9 #include "base/strings/stringprintf.h" | |
| 10 #include "base/synchronization/waitable_event.h" | |
| 11 #include "content/common/java_bridge_messages.h" | |
| 12 | |
| 13 using base::WaitableEvent; | |
| 14 | |
| 15 namespace content { | |
| 16 namespace { | |
| 17 struct WaitableEventLazyInstanceTraits | |
| 18 : public base::DefaultLazyInstanceTraits<WaitableEvent> { | |
| 19 static WaitableEvent* New(void* instance) { | |
| 20 // Use placement new to initialize our instance in our preallocated space. | |
| 21 // The parenthesis is very important here to force POD type initialization. | |
| 22 return new (instance) WaitableEvent(false, false); | |
| 23 } | |
| 24 }; | |
| 25 base::LazyInstance<WaitableEvent, WaitableEventLazyInstanceTraits> dummy_event = | |
| 26 LAZY_INSTANCE_INITIALIZER; | |
| 27 | |
| 28 base::subtle::AtomicWord g_last_id = 0; | |
| 29 } | |
| 30 | |
| 31 JavaBridgeChannelHost::~JavaBridgeChannelHost() { | |
| 32 #if defined(OS_POSIX) | |
| 33 if (channel_handle_.socket.fd > 0) { | |
| 34 close(channel_handle_.socket.fd); | |
| 35 } | |
| 36 #endif | |
| 37 } | |
| 38 | |
| 39 JavaBridgeChannelHost* JavaBridgeChannelHost::GetJavaBridgeChannelHost( | |
| 40 int renderer_id, | |
| 41 base::MessageLoopProxy* ipc_message_loop) { | |
| 42 std::string channel_name(base::StringPrintf("r%d.javabridge", renderer_id)); | |
| 43 // There's no need for a shutdown event here. If the browser is terminated | |
| 44 // while the JavaBridgeChannelHost is blocked on a synchronous IPC call, the | |
| 45 // renderer's shutdown event will cause the underlying channel to shut down, | |
| 46 // thus terminating the IPC call. | |
| 47 return static_cast<JavaBridgeChannelHost*>(NPChannelBase::GetChannel( | |
| 48 channel_name, | |
| 49 IPC::Channel::MODE_SERVER, | |
| 50 ClassFactory, | |
| 51 ipc_message_loop, | |
| 52 true, | |
| 53 dummy_event.Pointer())); | |
| 54 } | |
| 55 | |
| 56 int JavaBridgeChannelHost::ThreadsafeGenerateRouteID() { | |
| 57 return base::subtle::NoBarrier_AtomicIncrement(&g_last_id, 1); | |
| 58 } | |
| 59 | |
| 60 int JavaBridgeChannelHost::GenerateRouteID() { | |
| 61 return ThreadsafeGenerateRouteID(); | |
| 62 } | |
| 63 | |
| 64 bool JavaBridgeChannelHost::Init(base::MessageLoopProxy* ipc_message_loop, | |
| 65 bool create_pipe_now, | |
| 66 WaitableEvent* shutdown_event) { | |
| 67 if (!NPChannelBase::Init(ipc_message_loop, create_pipe_now, shutdown_event)) { | |
| 68 return false; | |
| 69 } | |
| 70 | |
| 71 // Finish populating our ChannelHandle. | |
| 72 #if defined(OS_POSIX) | |
| 73 // We take control of the FD for all session between this host and | |
| 74 // the corresponding renderers. We keep it open until this object | |
| 75 // is deleted. | |
| 76 channel_handle_.socket.fd = channel_->TakeClientFileDescriptor(); | |
| 77 #endif | |
| 78 | |
| 79 return true; | |
| 80 } | |
| 81 | |
| 82 bool JavaBridgeChannelHost::OnControlMessageReceived( | |
| 83 const IPC::Message& message) { | |
| 84 bool handled = true; | |
| 85 IPC_BEGIN_MESSAGE_MAP(JavaBridgeChannelHost, message) | |
| 86 IPC_MESSAGE_HANDLER(JavaBridgeMsg_GenerateRouteID, OnGenerateRouteID) | |
| 87 IPC_END_MESSAGE_MAP() | |
| 88 return handled; | |
| 89 } | |
| 90 | |
| 91 void JavaBridgeChannelHost::OnGenerateRouteID(int* route_id) { | |
| 92 *route_id = GenerateRouteID(); | |
| 93 } | |
| 94 | |
| 95 } // namespace content | |
| OLD | NEW |