summaryrefslogtreecommitdiffstats
path: root/remoting/host/remoting_me2me_host.cc
diff options
context:
space:
mode:
Diffstat (limited to 'remoting/host/remoting_me2me_host.cc')
-rw-r--r--remoting/host/remoting_me2me_host.cc31
1 files changed, 16 insertions, 15 deletions
diff --git a/remoting/host/remoting_me2me_host.cc b/remoting/host/remoting_me2me_host.cc
index 6aa6e93..65b605b 100644
--- a/remoting/host/remoting_me2me_host.cc
+++ b/remoting/host/remoting_me2me_host.cc
@@ -146,7 +146,7 @@ class HostProcess
void ConfigUpdatedDelayed() {
if (LoadConfig()) {
- context_->network_message_loop()->PostTask(
+ context_->network_task_runner()->PostTask(
FROM_HERE,
base::Bind(&HostProcess::CreateAuthenticatorFactory,
base::Unretained(this)));
@@ -158,21 +158,22 @@ class HostProcess
#if defined(OS_WIN)
class ConfigChangedDelegate : public base::files::FilePathWatcher::Delegate {
public:
- ConfigChangedDelegate(base::MessageLoopProxy* message_loop,
- const base::Closure& callback)
- : message_loop_(message_loop),
+ ConfigChangedDelegate(
+ scoped_refptr<base::SingleThreadTaskRunner> task_runner,
+ const base::Closure& callback)
+ : task_runner_(task_runner),
callback_(callback) {
}
void OnFilePathChanged(const FilePath& path) OVERRIDE {
- message_loop_->PostTask(FROM_HERE, callback_);
+ task_runner_->PostTask(FROM_HERE, callback_);
}
void OnFilePathError(const FilePath& path) OVERRIDE {
}
private:
- scoped_refptr<base::MessageLoopProxy> message_loop_;
+ scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
base::Closure callback_;
DISALLOW_COPY_AND_ASSIGN(ConfigChangedDelegate);
@@ -215,7 +216,7 @@ class HostProcess
StartWatchingNatPolicy();
#if defined(OS_MACOSX) || defined(OS_WIN)
- context_->file_message_loop()->PostTask(
+ context_->file_task_runner()->PostTask(
FROM_HERE,
base::Bind(&HostProcess::ListenForConfigChanges,
base::Unretained(this)));
@@ -243,7 +244,7 @@ class HostProcess
private:
void StartWatchingNatPolicy() {
nat_policy_.reset(
- policy_hack::NatPolicy::Create(context_->file_message_loop()));
+ policy_hack::NatPolicy::Create(context_->file_task_runner()));
nat_policy_->StartWatching(
base::Bind(&HostProcess::OnNatPolicyUpdate, base::Unretained(this)));
}
@@ -314,8 +315,8 @@ class HostProcess
}
void OnNatPolicyUpdate(bool nat_traversal_enabled) {
- if (!context_->network_message_loop()->BelongsToCurrentThread()) {
- context_->network_message_loop()->PostTask(FROM_HERE, base::Bind(
+ if (!context_->network_task_runner()->BelongsToCurrentThread()) {
+ context_->network_task_runner()->PostTask(FROM_HERE, base::Bind(
&HostProcess::OnNatPolicyUpdate, base::Unretained(this),
nat_traversal_enabled));
return;
@@ -336,7 +337,7 @@ class HostProcess
}
void StartHost() {
- DCHECK(context_->network_message_loop()->BelongsToCurrentThread());
+ DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
DCHECK(!host_);
if (!signal_strategy_.get()) {
@@ -429,7 +430,7 @@ class HostProcess
}
void RestartHost() {
- DCHECK(context_->network_message_loop()->BelongsToCurrentThread());
+ DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
if (restarting_ || shutting_down_)
return;
@@ -440,7 +441,7 @@ class HostProcess
}
void RestartOnHostShutdown() {
- DCHECK(context_->network_message_loop()->BelongsToCurrentThread());
+ DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
if (shutting_down_)
return;
@@ -455,7 +456,7 @@ class HostProcess
}
void Shutdown(int exit_code) {
- DCHECK(context_->network_message_loop()->BelongsToCurrentThread());
+ DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
if (shutting_down_)
return;
@@ -467,7 +468,7 @@ class HostProcess
}
void OnShutdownFinished() {
- DCHECK(context_->network_message_loop()->BelongsToCurrentThread());
+ DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
// Destroy networking objects while we are on the network thread.
host_ = NULL;