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 "remoting/host/desktop_session_agent.h" | 5 #include "remoting/host/desktop_session_agent.h" |
6 | 6 |
7 #include "base/files/file_util.h" | 7 #include "base/files/file_util.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/macros.h" |
9 #include "base/memory/shared_memory.h" | 10 #include "base/memory/shared_memory.h" |
| 11 #include "build/build_config.h" |
10 #include "ipc/ipc_channel_proxy.h" | 12 #include "ipc/ipc_channel_proxy.h" |
11 #include "ipc/ipc_message.h" | 13 #include "ipc/ipc_message.h" |
12 #include "ipc/ipc_message_macros.h" | 14 #include "ipc/ipc_message_macros.h" |
13 #include "remoting/base/auto_thread_task_runner.h" | 15 #include "remoting/base/auto_thread_task_runner.h" |
14 #include "remoting/base/constants.h" | 16 #include "remoting/base/constants.h" |
15 #include "remoting/host/audio_capturer.h" | 17 #include "remoting/host/audio_capturer.h" |
16 #include "remoting/host/chromoting_messages.h" | 18 #include "remoting/host/chromoting_messages.h" |
17 #include "remoting/host/desktop_environment.h" | 19 #include "remoting/host/desktop_environment.h" |
18 #include "remoting/host/input_injector.h" | 20 #include "remoting/host/input_injector.h" |
19 #include "remoting/host/ipc_util.h" | 21 #include "remoting/host/ipc_util.h" |
(...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
154 IPC_MESSAGE_HANDLER(ChromotingNetworkDesktopMsg_StartSessionAgent, | 156 IPC_MESSAGE_HANDLER(ChromotingNetworkDesktopMsg_StartSessionAgent, |
155 OnStartSessionAgent) | 157 OnStartSessionAgent) |
156 IPC_MESSAGE_UNHANDLED(handled = false) | 158 IPC_MESSAGE_UNHANDLED(handled = false) |
157 IPC_END_MESSAGE_MAP() | 159 IPC_END_MESSAGE_MAP() |
158 } | 160 } |
159 | 161 |
160 CHECK(handled) << "Received unexpected IPC type: " << message.type(); | 162 CHECK(handled) << "Received unexpected IPC type: " << message.type(); |
161 return handled; | 163 return handled; |
162 } | 164 } |
163 | 165 |
164 void DesktopSessionAgent::OnChannelConnected(int32 peer_pid) { | 166 void DesktopSessionAgent::OnChannelConnected(int32_t peer_pid) { |
165 DCHECK(caller_task_runner_->BelongsToCurrentThread()); | 167 DCHECK(caller_task_runner_->BelongsToCurrentThread()); |
166 | 168 |
167 VLOG(1) << "IPC: desktop <- network (" << peer_pid << ")"; | 169 VLOG(1) << "IPC: desktop <- network (" << peer_pid << ")"; |
168 | 170 |
169 desktop_pipe_.Close(); | 171 desktop_pipe_.Close(); |
170 } | 172 } |
171 | 173 |
172 void DesktopSessionAgent::OnChannelError() { | 174 void DesktopSessionAgent::OnChannelError() { |
173 DCHECK(caller_task_runner_->BelongsToCurrentThread()); | 175 DCHECK(caller_task_runner_->BelongsToCurrentThread()); |
174 | 176 |
(...skipping 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
600 void DesktopSessionAgent::OnSharedBufferDeleted(int id) { | 602 void DesktopSessionAgent::OnSharedBufferDeleted(int id) { |
601 DCHECK(video_capture_task_runner_->BelongsToCurrentThread()); | 603 DCHECK(video_capture_task_runner_->BelongsToCurrentThread()); |
602 DCHECK(id != 0); | 604 DCHECK(id != 0); |
603 | 605 |
604 shared_buffers_--; | 606 shared_buffers_--; |
605 DCHECK_GE(shared_buffers_, 0); | 607 DCHECK_GE(shared_buffers_, 0); |
606 SendToNetwork(new ChromotingDesktopNetworkMsg_ReleaseSharedBuffer(id)); | 608 SendToNetwork(new ChromotingDesktopNetworkMsg_ReleaseSharedBuffer(id)); |
607 } | 609 } |
608 | 610 |
609 } // namespace remoting | 611 } // namespace remoting |
OLD | NEW |