Index: chrome/browser/local_discovery/service_discovery_host_client.cc |
diff --git a/chrome/browser/local_discovery/service_discovery_host_client.cc b/chrome/browser/local_discovery/service_discovery_host_client.cc |
index f201ffbdc876f286a80554214afbc37e10e2f073..3d75a03e11aab749296162079ac2b6f7c0487ceb 100644 |
--- a/chrome/browser/local_discovery/service_discovery_host_client.cc |
+++ b/chrome/browser/local_discovery/service_discovery_host_client.cc |
@@ -186,7 +186,7 @@ ServiceDiscoveryHostClient::~ServiceDiscoveryHostClient() { |
scoped_ptr<ServiceWatcher> ServiceDiscoveryHostClient::CreateServiceWatcher( |
const std::string& service_type, |
const ServiceWatcher::UpdatedCallback& callback) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
return scoped_ptr<ServiceWatcher>( |
new ServiceWatcherProxy(this, service_type, callback)); |
} |
@@ -194,7 +194,7 @@ scoped_ptr<ServiceWatcher> ServiceDiscoveryHostClient::CreateServiceWatcher( |
scoped_ptr<ServiceResolver> ServiceDiscoveryHostClient::CreateServiceResolver( |
const std::string& service_name, |
const ServiceResolver::ResolveCompleteCallback& callback) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
return scoped_ptr<ServiceResolver>( |
new ServiceResolverProxy(this, service_name, callback)); |
} |
@@ -204,14 +204,14 @@ ServiceDiscoveryHostClient::CreateLocalDomainResolver( |
const std::string& domain, |
net::AddressFamily address_family, |
const LocalDomainResolver::IPAddressCallback& callback) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
return scoped_ptr<LocalDomainResolver>(new LocalDomainResolverProxy( |
this, domain, address_family, callback)); |
} |
uint64 ServiceDiscoveryHostClient::RegisterWatcherCallback( |
const ServiceWatcher::UpdatedCallback& callback) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
DCHECK(!ContainsKey(service_watcher_callbacks_, current_id_ + 1)); |
service_watcher_callbacks_[++current_id_] = callback; |
return current_id_; |
@@ -219,7 +219,7 @@ uint64 ServiceDiscoveryHostClient::RegisterWatcherCallback( |
uint64 ServiceDiscoveryHostClient::RegisterResolverCallback( |
const ServiceResolver::ResolveCompleteCallback& callback) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
DCHECK(!ContainsKey(service_resolver_callbacks_, current_id_ + 1)); |
service_resolver_callbacks_[++current_id_] = callback; |
return current_id_; |
@@ -227,31 +227,31 @@ uint64 ServiceDiscoveryHostClient::RegisterResolverCallback( |
uint64 ServiceDiscoveryHostClient::RegisterLocalDomainResolverCallback( |
const LocalDomainResolver::IPAddressCallback& callback) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
DCHECK(!ContainsKey(domain_resolver_callbacks_, current_id_ + 1)); |
domain_resolver_callbacks_[++current_id_] = callback; |
return current_id_; |
} |
void ServiceDiscoveryHostClient::UnregisterWatcherCallback(uint64 id) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
service_watcher_callbacks_.erase(id); |
} |
void ServiceDiscoveryHostClient::UnregisterResolverCallback(uint64 id) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
service_resolver_callbacks_.erase(id); |
} |
void ServiceDiscoveryHostClient::UnregisterLocalDomainResolverCallback( |
uint64 id) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
domain_resolver_callbacks_.erase(id); |
} |
void ServiceDiscoveryHostClient::Start( |
const base::Closure& error_callback) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
DCHECK(!utility_host_); |
DCHECK(error_callback_.is_null()); |
error_callback_ = error_callback; |
@@ -261,7 +261,7 @@ void ServiceDiscoveryHostClient::Start( |
} |
void ServiceDiscoveryHostClient::Shutdown() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
io_runner_->PostTask( |
FROM_HERE, |
base::Bind(&ServiceDiscoveryHostClient::ShutdownOnIOThread, this)); |
@@ -270,7 +270,7 @@ void ServiceDiscoveryHostClient::Shutdown() { |
#if defined(OS_POSIX) |
void ServiceDiscoveryHostClient::StartOnIOThread() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
DCHECK(!utility_host_); |
BrowserThread::PostTaskAndReplyWithResult( |
BrowserThread::FILE, |
@@ -280,7 +280,7 @@ void ServiceDiscoveryHostClient::StartOnIOThread() { |
} |
void ServiceDiscoveryHostClient::OnSocketsReady(const SocketInfoList& sockets) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
DCHECK(!utility_host_); |
utility_host_ = UtilityProcessHost::Create( |
this, base::MessageLoopProxy::current().get())->AsWeakPtr(); |
@@ -302,7 +302,7 @@ void ServiceDiscoveryHostClient::OnSocketsReady(const SocketInfoList& sockets) { |
#else // OS_POSIX |
void ServiceDiscoveryHostClient::StartOnIOThread() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
DCHECK(!utility_host_); |
utility_host_ = UtilityProcessHost::Create( |
this, base::MessageLoopProxy::current().get())->AsWeakPtr(); |
@@ -317,7 +317,7 @@ void ServiceDiscoveryHostClient::StartOnIOThread() { |
#endif // OS_POSIX |
void ServiceDiscoveryHostClient::ShutdownOnIOThread() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
if (utility_host_) { |
utility_host_->Send(new LocalDiscoveryMsg_ShutdownLocalDiscovery); |
utility_host_->EndBatchMode(); |
@@ -327,14 +327,14 @@ void ServiceDiscoveryHostClient::ShutdownOnIOThread() { |
} |
void ServiceDiscoveryHostClient::Send(IPC::Message* msg) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
io_runner_->PostTask( |
FROM_HERE, |
base::Bind(&ServiceDiscoveryHostClient::SendOnIOThread, this, msg)); |
} |
void ServiceDiscoveryHostClient::SendOnIOThread(IPC::Message* msg) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
if (utility_host_) { |
utility_host_->Send(msg); |
} else { |
@@ -343,7 +343,7 @@ void ServiceDiscoveryHostClient::SendOnIOThread(IPC::Message* msg) { |
} |
void ServiceDiscoveryHostClient::OnProcessCrashed(int exit_code) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
DCHECK(!utility_host_); |
OnError(); |
} |
@@ -379,7 +379,7 @@ void ServiceDiscoveryHostClient::InvalidateWatchers() { |
} |
void ServiceDiscoveryHostClient::OnError() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
if (!error_callback_.is_null()) |
callback_runner_->PostTask(FROM_HERE, error_callback_); |
} |
@@ -388,7 +388,7 @@ void ServiceDiscoveryHostClient::OnWatcherCallback( |
uint64 id, |
ServiceWatcher::UpdateType update, |
const std::string& service_name) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
callback_runner_->PostTask( |
FROM_HERE, |
base::Bind(&ServiceDiscoveryHostClient::RunWatcherCallback, this, id, |
@@ -399,7 +399,7 @@ void ServiceDiscoveryHostClient::OnResolverCallback( |
uint64 id, |
ServiceResolver::RequestStatus status, |
const ServiceDescription& description) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
callback_runner_->PostTask( |
FROM_HERE, |
base::Bind(&ServiceDiscoveryHostClient::RunResolverCallback, this, id, |
@@ -411,7 +411,7 @@ void ServiceDiscoveryHostClient::OnLocalDomainResolverCallback( |
bool success, |
const net::IPAddressNumber& ip_address_ipv4, |
const net::IPAddressNumber& ip_address_ipv6) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
callback_runner_->PostTask( |
FROM_HERE, |
base::Bind(&ServiceDiscoveryHostClient::RunLocalDomainResolverCallback, |
@@ -422,7 +422,7 @@ void ServiceDiscoveryHostClient::RunWatcherCallback( |
uint64 id, |
ServiceWatcher::UpdateType update, |
const std::string& service_name) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
WatcherCallbacks::iterator it = service_watcher_callbacks_.find(id); |
if (it != service_watcher_callbacks_.end() && !it->second.is_null()) |
it->second.Run(update, service_name); |
@@ -432,7 +432,7 @@ void ServiceDiscoveryHostClient::RunResolverCallback( |
uint64 id, |
ServiceResolver::RequestStatus status, |
const ServiceDescription& description) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
ResolverCallbacks::iterator it = service_resolver_callbacks_.find(id); |
if (it != service_resolver_callbacks_.end() && !it->second.is_null()) |
it->second.Run(status, description); |
@@ -443,7 +443,7 @@ void ServiceDiscoveryHostClient::RunLocalDomainResolverCallback( |
bool success, |
const net::IPAddressNumber& ip_address_ipv4, |
const net::IPAddressNumber& ip_address_ipv6) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
DomainResolverCallbacks::iterator it = domain_resolver_callbacks_.find(id); |
if (it != domain_resolver_callbacks_.end() && !it->second.is_null()) |
it->second.Run(success, ip_address_ipv4, ip_address_ipv6); |