| 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);
|
|
|