OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "content/renderer/gpu/stream_texture_host_android.h" | 5 #include "content/renderer/gpu/stream_texture_host_android.h" |
6 | 6 |
| 7 #include "base/unguessable_token.h" |
7 #include "content/renderer/render_thread_impl.h" | 8 #include "content/renderer/render_thread_impl.h" |
8 #include "gpu/ipc/client/gpu_channel_host.h" | 9 #include "gpu/ipc/client/gpu_channel_host.h" |
9 #include "gpu/ipc/common/gpu_messages.h" | 10 #include "gpu/ipc/common/gpu_messages.h" |
10 #include "ipc/ipc_message_macros.h" | 11 #include "ipc/ipc_message_macros.h" |
11 | 12 |
12 namespace content { | 13 namespace content { |
13 | 14 |
14 StreamTextureHost::StreamTextureHost(scoped_refptr<gpu::GpuChannelHost> channel) | 15 StreamTextureHost::StreamTextureHost(scoped_refptr<gpu::GpuChannelHost> channel, |
15 : stream_id_(0), | 16 int32_t route_id) |
| 17 : route_id_(route_id), |
16 listener_(NULL), | 18 listener_(NULL), |
17 channel_(std::move(channel)), | 19 channel_(std::move(channel)), |
18 weak_ptr_factory_(this) { | 20 weak_ptr_factory_(this) { |
19 DCHECK(channel_); | 21 DCHECK(channel_); |
20 } | 22 } |
21 | 23 |
22 StreamTextureHost::~StreamTextureHost() { | 24 StreamTextureHost::~StreamTextureHost() { |
23 if (channel_.get() && stream_id_) | 25 if (channel_.get() && route_id_) |
24 channel_->RemoveRoute(stream_id_); | 26 channel_->RemoveRoute(route_id_); |
25 } | 27 } |
26 | 28 |
27 bool StreamTextureHost::BindToCurrentThread(int32_t stream_id, | 29 bool StreamTextureHost::BindToCurrentThread(Listener* listener) { |
28 Listener* listener) { | |
29 listener_ = listener; | 30 listener_ = listener; |
30 if (channel_.get() && stream_id && !stream_id_) { | 31 if (channel_.get() && route_id_) { |
31 stream_id_ = stream_id; | 32 channel_->AddRoute(route_id_, weak_ptr_factory_.GetWeakPtr()); |
32 channel_->AddRoute(stream_id, weak_ptr_factory_.GetWeakPtr()); | 33 channel_->Send(new GpuStreamTextureMsg_StartListening(route_id_)); |
33 channel_->Send(new GpuStreamTextureMsg_StartListening(stream_id)); | |
34 return true; | 34 return true; |
35 } | 35 } |
36 | 36 |
37 return false; | 37 return false; |
38 } | 38 } |
39 | 39 |
40 bool StreamTextureHost::OnMessageReceived(const IPC::Message& message) { | 40 bool StreamTextureHost::OnMessageReceived(const IPC::Message& message) { |
41 bool handled = true; | 41 bool handled = true; |
42 IPC_BEGIN_MESSAGE_MAP(StreamTextureHost, message) | 42 IPC_BEGIN_MESSAGE_MAP(StreamTextureHost, message) |
43 IPC_MESSAGE_HANDLER(GpuStreamTextureMsg_FrameAvailable, | 43 IPC_MESSAGE_HANDLER(GpuStreamTextureMsg_FrameAvailable, |
44 OnFrameAvailable); | 44 OnFrameAvailable); |
45 IPC_MESSAGE_UNHANDLED(handled = false) | 45 IPC_MESSAGE_UNHANDLED(handled = false) |
46 IPC_END_MESSAGE_MAP() | 46 IPC_END_MESSAGE_MAP() |
47 DCHECK(handled); | 47 DCHECK(handled); |
48 return handled; | 48 return handled; |
49 } | 49 } |
50 | 50 |
51 void StreamTextureHost::OnChannelError() { | 51 void StreamTextureHost::OnChannelError() { |
52 } | 52 } |
53 | 53 |
54 void StreamTextureHost::OnFrameAvailable() { | 54 void StreamTextureHost::OnFrameAvailable() { |
55 if (listener_) | 55 if (listener_) |
56 listener_->OnFrameAvailable(); | 56 listener_->OnFrameAvailable(); |
57 } | 57 } |
58 | 58 |
| 59 void StreamTextureHost::EstablishPeer(int player_id, int frame_id) { |
| 60 if (route_id_) { |
| 61 channel_->Send( |
| 62 new GpuStreamTextureMsg_EstablishPeer(route_id_, frame_id, player_id)); |
| 63 } |
| 64 } |
| 65 |
| 66 void StreamTextureHost::SetStreamTextureSize(const gfx::Size& size) { |
| 67 if (route_id_) |
| 68 channel_->Send(new GpuStreamTextureMsg_SetSize(route_id_, size)); |
| 69 } |
| 70 |
| 71 void StreamTextureHost::ForwardStreamTextureForSurfaceRequest( |
| 72 const base::UnguessableToken& request_token) { |
| 73 if (route_id_) { |
| 74 channel_->Send(new GpuStreamTextureMsg_ForwardForSurfaceRequest( |
| 75 route_id_, request_token)); |
| 76 } |
| 77 } |
| 78 |
59 } // namespace content | 79 } // namespace content |
OLD | NEW |