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/render_thread_impl.h" | 5 #include "content/renderer/render_thread_impl.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <limits> | 8 #include <limits> |
9 #include <map> | 9 #include <map> |
10 #include <vector> | 10 #include <vector> |
(...skipping 359 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
370 #if defined(ENABLE_WEBRTC) | 370 #if defined(ENABLE_WEBRTC) |
371 peer_connection_tracker_.reset(new PeerConnectionTracker()); | 371 peer_connection_tracker_.reset(new PeerConnectionTracker()); |
372 AddObserver(peer_connection_tracker_.get()); | 372 AddObserver(peer_connection_tracker_.get()); |
373 | 373 |
374 p2p_socket_dispatcher_ = | 374 p2p_socket_dispatcher_ = |
375 new P2PSocketDispatcher(GetIOMessageLoopProxy().get()); | 375 new P2PSocketDispatcher(GetIOMessageLoopProxy().get()); |
376 AddFilter(p2p_socket_dispatcher_.get()); | 376 AddFilter(p2p_socket_dispatcher_.get()); |
377 | 377 |
378 webrtc_identity_service_.reset(new WebRTCIdentityService()); | 378 webrtc_identity_service_.reset(new WebRTCIdentityService()); |
379 | 379 |
380 media_stream_factory_.reset(new PeerConnectionDependencyFactory( | 380 peer_connection_factory_.reset(new PeerConnectionDependencyFactory( |
381 p2p_socket_dispatcher_.get())); | 381 p2p_socket_dispatcher_.get())); |
382 AddObserver(media_stream_factory_.get()); | 382 AddObserver(peer_connection_factory_.get()); |
383 #endif // defined(ENABLE_WEBRTC) | 383 #endif // defined(ENABLE_WEBRTC) |
384 | 384 |
385 audio_input_message_filter_ = | 385 audio_input_message_filter_ = |
386 new AudioInputMessageFilter(GetIOMessageLoopProxy()); | 386 new AudioInputMessageFilter(GetIOMessageLoopProxy()); |
387 AddFilter(audio_input_message_filter_.get()); | 387 AddFilter(audio_input_message_filter_.get()); |
388 | 388 |
389 audio_message_filter_ = new AudioMessageFilter(GetIOMessageLoopProxy()); | 389 audio_message_filter_ = new AudioMessageFilter(GetIOMessageLoopProxy()); |
390 AddFilter(audio_message_filter_.get()); | 390 AddFilter(audio_message_filter_.get()); |
391 | 391 |
392 midi_message_filter_ = new MidiMessageFilter(GetIOMessageLoopProxy()); | 392 midi_message_filter_ = new MidiMessageFilter(GetIOMessageLoopProxy()); |
(...skipping 133 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
526 RemoveFilter(devtools_agent_message_filter_.get()); | 526 RemoveFilter(devtools_agent_message_filter_.get()); |
527 devtools_agent_message_filter_ = NULL; | 527 devtools_agent_message_filter_ = NULL; |
528 } | 528 } |
529 | 529 |
530 RemoveFilter(audio_input_message_filter_.get()); | 530 RemoveFilter(audio_input_message_filter_.get()); |
531 audio_input_message_filter_ = NULL; | 531 audio_input_message_filter_ = NULL; |
532 | 532 |
533 RemoveFilter(audio_message_filter_.get()); | 533 RemoveFilter(audio_message_filter_.get()); |
534 audio_message_filter_ = NULL; | 534 audio_message_filter_ = NULL; |
535 | 535 |
536 // |media_stream_factory_| produces users of |vc_manager_| so it must be | |
537 // destroyed first. | |
538 #if defined(ENABLE_WEBRTC) | 536 #if defined(ENABLE_WEBRTC) |
539 media_stream_factory_.reset(); | 537 peer_connection_factory_.reset(); |
540 #endif | 538 #endif |
541 RemoveFilter(vc_manager_->video_capture_message_filter()); | 539 RemoveFilter(vc_manager_->video_capture_message_filter()); |
542 vc_manager_.reset(); | 540 vc_manager_.reset(); |
543 | 541 |
544 RemoveFilter(db_message_filter_.get()); | 542 RemoveFilter(db_message_filter_.get()); |
545 db_message_filter_ = NULL; | 543 db_message_filter_ = NULL; |
546 | 544 |
547 // Shutdown the file thread if it's running. | 545 // Shutdown the file thread if it's running. |
548 if (file_thread_) | 546 if (file_thread_) |
549 file_thread_->Stop(); | 547 file_thread_->Stop(); |
(...skipping 769 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1319 AddObserver(media_stream_center.get()); | 1317 AddObserver(media_stream_center.get()); |
1320 media_stream_center_ = media_stream_center.release(); | 1318 media_stream_center_ = media_stream_center.release(); |
1321 } | 1319 } |
1322 } | 1320 } |
1323 #endif | 1321 #endif |
1324 return media_stream_center_; | 1322 return media_stream_center_; |
1325 } | 1323 } |
1326 | 1324 |
1327 PeerConnectionDependencyFactory* | 1325 PeerConnectionDependencyFactory* |
1328 RenderThreadImpl::GetPeerConnectionDependencyFactory() { | 1326 RenderThreadImpl::GetPeerConnectionDependencyFactory() { |
1329 return media_stream_factory_.get(); | 1327 return peer_connection_factory_.get(); |
1330 } | 1328 } |
1331 | 1329 |
1332 GpuChannelHost* RenderThreadImpl::GetGpuChannel() { | 1330 GpuChannelHost* RenderThreadImpl::GetGpuChannel() { |
1333 if (!gpu_channel_.get()) | 1331 if (!gpu_channel_.get()) |
1334 return NULL; | 1332 return NULL; |
1335 | 1333 |
1336 if (gpu_channel_->IsLost()) | 1334 if (gpu_channel_->IsLost()) |
1337 return NULL; | 1335 return NULL; |
1338 | 1336 |
1339 return gpu_channel_.get(); | 1337 return gpu_channel_.get(); |
(...skipping 167 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1507 hidden_widget_count_--; | 1505 hidden_widget_count_--; |
1508 | 1506 |
1509 if (!GetContentClient()->renderer()->RunIdleHandlerWhenWidgetsHidden()) { | 1507 if (!GetContentClient()->renderer()->RunIdleHandlerWhenWidgetsHidden()) { |
1510 return; | 1508 return; |
1511 } | 1509 } |
1512 | 1510 |
1513 ScheduleIdleHandler(kLongIdleHandlerDelayMs); | 1511 ScheduleIdleHandler(kLongIdleHandlerDelayMs); |
1514 } | 1512 } |
1515 | 1513 |
1516 } // namespace content | 1514 } // namespace content |
OLD | NEW |