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/child/child_thread_impl.h" | 5 #include "content/child/child_thread_impl.h" |
6 | 6 |
7 #include <signal.h> | 7 #include <signal.h> |
8 #include <string> | 8 #include <string> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 547 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
558 void ChildThreadImpl::OnChannelConnected(int32_t peer_pid) { | 558 void ChildThreadImpl::OnChannelConnected(int32_t peer_pid) { |
559 channel_connected_factory_.InvalidateWeakPtrs(); | 559 channel_connected_factory_.InvalidateWeakPtrs(); |
560 } | 560 } |
561 | 561 |
562 void ChildThreadImpl::OnChannelError() { | 562 void ChildThreadImpl::OnChannelError() { |
563 on_channel_error_called_ = true; | 563 on_channel_error_called_ = true; |
564 base::MessageLoop::current()->QuitWhenIdle(); | 564 base::MessageLoop::current()->QuitWhenIdle(); |
565 } | 565 } |
566 | 566 |
567 bool ChildThreadImpl::Send(IPC::Message* msg) { | 567 bool ChildThreadImpl::Send(IPC::Message* msg) { |
568 DCHECK(base::MessageLoop::current() == message_loop()); | 568 DCHECK(message_loop_->task_runner()->BelongsToCurrentThread()); |
569 if (!channel_) { | 569 if (!channel_) { |
570 delete msg; | 570 delete msg; |
571 return false; | 571 return false; |
572 } | 572 } |
573 | 573 |
574 return channel_->Send(msg); | 574 return channel_->Send(msg); |
575 } | 575 } |
576 | 576 |
577 #if defined(OS_WIN) | 577 #if defined(OS_WIN) |
578 void ChildThreadImpl::PreCacheFont(const LOGFONT& log_font) { | 578 void ChildThreadImpl::PreCacheFont(const LOGFONT& log_font) { |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
610 | 610 |
611 shell::InterfaceRegistry* ChildThreadImpl::GetInterfaceRegistryForConnection() { | 611 shell::InterfaceRegistry* ChildThreadImpl::GetInterfaceRegistryForConnection() { |
612 return GetInterfaceRegistry(); | 612 return GetInterfaceRegistry(); |
613 } | 613 } |
614 | 614 |
615 shell::InterfaceProvider* ChildThreadImpl::GetInterfaceProviderForConnection() { | 615 shell::InterfaceProvider* ChildThreadImpl::GetInterfaceProviderForConnection() { |
616 return GetRemoteInterfaces(); | 616 return GetRemoteInterfaces(); |
617 } | 617 } |
618 | 618 |
619 IPC::MessageRouter* ChildThreadImpl::GetRouter() { | 619 IPC::MessageRouter* ChildThreadImpl::GetRouter() { |
620 DCHECK(base::MessageLoop::current() == message_loop()); | 620 DCHECK(message_loop_->task_runner()->BelongsToCurrentThread()); |
621 return &router_; | 621 return &router_; |
622 } | 622 } |
623 | 623 |
624 std::unique_ptr<base::SharedMemory> ChildThreadImpl::AllocateSharedMemory( | 624 std::unique_ptr<base::SharedMemory> ChildThreadImpl::AllocateSharedMemory( |
625 size_t buf_size) { | 625 size_t buf_size) { |
626 DCHECK(base::MessageLoop::current() == message_loop()); | 626 DCHECK(message_loop_->task_runner()->BelongsToCurrentThread()); |
627 return AllocateSharedMemory(buf_size, this, nullptr); | 627 return AllocateSharedMemory(buf_size, this, nullptr); |
628 } | 628 } |
629 | 629 |
630 // static | 630 // static |
631 std::unique_ptr<base::SharedMemory> ChildThreadImpl::AllocateSharedMemory( | 631 std::unique_ptr<base::SharedMemory> ChildThreadImpl::AllocateSharedMemory( |
632 size_t buf_size, | 632 size_t buf_size, |
633 IPC::Sender* sender, | 633 IPC::Sender* sender, |
634 bool* out_of_memory) { | 634 bool* out_of_memory) { |
635 std::unique_ptr<base::SharedMemory> shared_buf; | 635 std::unique_ptr<base::SharedMemory> shared_buf; |
636 // Ask the browser to create the shared memory, since this is blocked by the | 636 // Ask the browser to create the shared memory, since this is blocked by the |
(...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
766 void ChildThreadImpl::EnsureConnected() { | 766 void ChildThreadImpl::EnsureConnected() { |
767 VLOG(0) << "ChildThreadImpl::EnsureConnected()"; | 767 VLOG(0) << "ChildThreadImpl::EnsureConnected()"; |
768 base::Process::Current().Terminate(0, false); | 768 base::Process::Current().Terminate(0, false); |
769 } | 769 } |
770 | 770 |
771 bool ChildThreadImpl::IsInBrowserProcess() const { | 771 bool ChildThreadImpl::IsInBrowserProcess() const { |
772 return static_cast<bool>(browser_process_io_runner_); | 772 return static_cast<bool>(browser_process_io_runner_); |
773 } | 773 } |
774 | 774 |
775 } // namespace content | 775 } // namespace content |
OLD | NEW |