chrome.mdns API

chrome/browser/extensions/api/dial/dial_api.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/extensions/api/dial/dial_api.h"
 
 #include <vector>
 
 #include "base/time/time.h"
 #include "chrome/browser/extensions/api/dial/dial_api_factory.h"
@@ skipping 13 matching lines @@
 
 // How often to poll for devices.
 const int kDialRefreshIntervalSecs = 120;
 
 // We prune a device if it does not respond after this time.
 const int kDialExpirationSecs = 240;
 
 // The maximum number of devices retained at once in the registry.
 const size_t kDialMaxDevices = 256;
 
+//
+const char kCastDefaultDeviceType[] = "_privet._tcp.local";
+
 }  // namespace
 
 namespace extensions {
 
 DialAPI::DialAPI(Profile* profile)
     : RefcountedBrowserContextKeyedService(BrowserThread::IO),
       profile_(profile) {
   ExtensionSystem::Get(profile)->event_router()->RegisterObserver(
       this, extensions::event_names::kOnDialDeviceList);
 }
 
 DialAPI::~DialAPI() {}
 
 DialRegistry* DialAPI::dial_registry() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   if (!dial_registry_.get()) {
     dial_registry_.reset(new DialRegistry(this,
         TimeDelta::FromSeconds(kDialRefreshIntervalSecs),
         TimeDelta::FromSeconds(kDialExpirationSecs),
         kDialMaxDevices));
   }
   return dial_registry_.get();
 }
 
+MDNSService* DialAPI::mdns_service() {
+  // TODO(justinlin): Any creation/access thread constraints?
+  // DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (!mdns_service_.get()) {
+    mdns_service_.reset(new MDNSService(kCastDefaultDeviceType));
+  }
+  return mdns_service_.get();
+}
+
 void DialAPI::OnListenerAdded(const EventListenerInfo& details) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
       base::Bind(&DialAPI::NotifyListenerAddedOnIOThread, this));
 }
 
 void DialAPI::OnListenerRemoved(const EventListenerInfo& details) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   BrowserThread::PostTask(
@@ skipping 96 matching lines @@
 
 bool DialDiscoverNowFunction::Respond() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   if (!result_)
     error_ = kDialServiceError;
 
   SetResult(new base::FundamentalValue(result_));
   return true;
 }
 
+
+DialGetNetworkServicesFunction::DialGetNetworkServicesFunction()
+    : dial_(NULL), result_(false) {
+}
+
+bool DialGetNetworkServicesFunction::Prepare() {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  DCHECK(profile());
+  dial_ = DialAPIFactory::GetInstance()->GetForProfile(profile()).get();
+  return true;
+}
+
+void DialGetNetworkServicesFunction::Work() {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+  // TODO(justinlin): Should instead instantiate a NetworkServicesRegistry,
+  // which calls into MDNSService.
+  result_ = dial_->mdns_service()->Start();
+}
+
+bool DialGetNetworkServicesFunction::Respond() {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (!result_)
+    error_ = kDialServiceError;
+
+  SetResult(new base::FundamentalValue(result_));
+  return true;
+}
+
 }  // namespace api
 
 }  // namespace extensions