Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(564)

Side by Side Diff: remoting/host/win/wts_session_process_delegate.cc

Issue 1739203004: Add support for Attachment Brokering of IPC::Channels on multiple threads. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebase. Created 4 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « remoting/host/win/unprivileged_process_delegate.cc ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 the Windows service controlling Me2Me host processes 5 // This file implements the Windows service controlling Me2Me host processes
6 // running within user sessions. 6 // running within user sessions.
7 7
8 #include "remoting/host/win/wts_session_process_delegate.h" 8 #include "remoting/host/win/wts_session_process_delegate.h"
9 9
10 #include <utility> 10 #include <utility>
(...skipping 409 matching lines...) Expand 10 before | Expand all | Expand 10 after
420 if (!ResumeThread(worker_thread.Get())) { 420 if (!ResumeThread(worker_thread.Get())) {
421 PLOG(ERROR) << "Failed to resume the worker thread"; 421 PLOG(ERROR) << "Failed to resume the worker thread";
422 ReportFatalError(); 422 ReportFatalError();
423 return; 423 return;
424 } 424 }
425 425
426 channel_ = std::move(channel); 426 channel_ = std::move(channel);
427 pipe_ = std::move(pipe); 427 pipe_ = std::move(pipe);
428 428
429 IPC::AttachmentBroker::GetGlobal()->RegisterCommunicationChannel( 429 IPC::AttachmentBroker::GetGlobal()->RegisterCommunicationChannel(
430 channel_.get()); 430 channel_.get(), io_task_runner_);
431 431
432 // Report success if the worker process is lauched directly. Otherwise, PID of 432 // Report success if the worker process is lauched directly. Otherwise, PID of
433 // the client connected to the pipe will be used later. See 433 // the client connected to the pipe will be used later. See
434 // OnChannelConnected(). 434 // OnChannelConnected().
435 if (!launch_elevated_) 435 if (!launch_elevated_)
436 ReportProcessLaunched(std::move(worker_process)); 436 ReportProcessLaunched(std::move(worker_process));
437 } 437 }
438 438
439 void WtsSessionProcessDelegate::Core::DrainJobNotifications() { 439 void WtsSessionProcessDelegate::Core::DrainJobNotifications() {
440 DCHECK(io_task_runner_->BelongsToCurrentThread()); 440 DCHECK(io_task_runner_->BelongsToCurrentThread());
(...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after
555 555
556 void WtsSessionProcessDelegate::CloseChannel() { 556 void WtsSessionProcessDelegate::CloseChannel() {
557 core_->CloseChannel(); 557 core_->CloseChannel();
558 } 558 }
559 559
560 void WtsSessionProcessDelegate::KillProcess() { 560 void WtsSessionProcessDelegate::KillProcess() {
561 core_->KillProcess(); 561 core_->KillProcess();
562 } 562 }
563 563
564 } // namespace remoting 564 } // namespace remoting
OLDNEW
« no previous file with comments | « remoting/host/win/unprivileged_process_delegate.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698