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 // This file implements a standalone host process for Me2Me. | 5 // This file implements a standalone host process for Me2Me. |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <memory> | 10 #include <memory> |
(...skipping 455 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
466 | 466 |
467 #if defined(OS_WIN) | 467 #if defined(OS_WIN) |
468 base::win::ScopedHandle pipe(reinterpret_cast<HANDLE>(pipe_handle)); | 468 base::win::ScopedHandle pipe(reinterpret_cast<HANDLE>(pipe_handle)); |
469 IPC::ChannelHandle channel_handle(pipe.Get()); | 469 IPC::ChannelHandle channel_handle(pipe.Get()); |
470 #elif defined(OS_POSIX) | 470 #elif defined(OS_POSIX) |
471 base::FileDescriptor pipe(pipe_handle, true); | 471 base::FileDescriptor pipe(pipe_handle, true); |
472 IPC::ChannelHandle channel_handle(channel_name, pipe); | 472 IPC::ChannelHandle channel_handle(channel_name, pipe); |
473 #endif // defined(OS_POSIX) | 473 #endif // defined(OS_POSIX) |
474 | 474 |
475 // Connect to the daemon process. | 475 // Connect to the daemon process. |
476 daemon_channel_ = IPC::ChannelProxy::Create(channel_handle, | 476 daemon_channel_.reset( |
477 IPC::Channel::MODE_CLIENT, | 477 new IPC::ChannelProxy(this, context_->network_task_runner())); |
478 this, | |
479 context_->network_task_runner()); | |
480 | |
481 IPC::AttachmentBrokerUnprivileged::CreateBrokerIfNeeded(); | 478 IPC::AttachmentBrokerUnprivileged::CreateBrokerIfNeeded(); |
482 IPC::AttachmentBroker* broker = IPC::AttachmentBroker::GetGlobal(); | 479 IPC::AttachmentBroker* broker = IPC::AttachmentBroker::GetGlobal(); |
483 if (broker && !broker->IsPrivilegedBroker()) | 480 if (broker && !broker->IsPrivilegedBroker()) |
484 broker->RegisterBrokerCommunicationChannel(daemon_channel_.get()); | 481 broker->RegisterBrokerCommunicationChannel(daemon_channel_.get()); |
| 482 daemon_channel_->Init(channel_handle, IPC::Channel::MODE_CLIENT, true); |
485 | 483 |
486 #else // !defined(REMOTING_MULTI_PROCESS) | 484 #else // !defined(REMOTING_MULTI_PROCESS) |
487 if (cmd_line->HasSwitch(kHostConfigSwitchName)) { | 485 if (cmd_line->HasSwitch(kHostConfigSwitchName)) { |
488 host_config_path_ = cmd_line->GetSwitchValuePath(kHostConfigSwitchName); | 486 host_config_path_ = cmd_line->GetSwitchValuePath(kHostConfigSwitchName); |
489 | 487 |
490 // Read config from stdin if necessary. | 488 // Read config from stdin if necessary. |
491 if (host_config_path_ == base::FilePath(kStdinConfigPath)) { | 489 if (host_config_path_ == base::FilePath(kStdinConfigPath)) { |
492 const size_t kBufferSize = 4096; | 490 const size_t kBufferSize = 4096; |
493 std::unique_ptr<char[]> buf(new char[kBufferSize]); | 491 std::unique_ptr<char[]> buf(new char[kBufferSize]); |
494 size_t len; | 492 size_t len; |
(...skipping 1157 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1652 base::TimeDelta::FromSeconds(kShutdownTimeoutSeconds)); | 1650 base::TimeDelta::FromSeconds(kShutdownTimeoutSeconds)); |
1653 new HostProcess(std::move(context), &exit_code, &shutdown_watchdog); | 1651 new HostProcess(std::move(context), &exit_code, &shutdown_watchdog); |
1654 | 1652 |
1655 // Run the main (also UI) message loop until the host no longer needs it. | 1653 // Run the main (also UI) message loop until the host no longer needs it. |
1656 message_loop.Run(); | 1654 message_loop.Run(); |
1657 | 1655 |
1658 return exit_code; | 1656 return exit_code; |
1659 } | 1657 } |
1660 | 1658 |
1661 } // namespace remoting | 1659 } // namespace remoting |
OLD | NEW |