This source file includes following definitions.
- profile_
- dial_registry
- OnListenerAdded
- OnListenerRemoved
- NotifyListenerAddedOnIOThread
- NotifyListenerRemovedOnIOThread
- OnDialDeviceEvent
- OnDialError
- SendEventOnUIThread
- SendErrorOnUIThread
- ShutdownOnUIThread
- result_
- Prepare
- Work
- Respond
#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"
#include "chrome/browser/profiles/profile.h"
#include "chrome/common/extensions/api/dial.h"
#include "content/public/browser/browser_thread.h"
#include "extensions/browser/event_router.h"
#include "extensions/browser/extension_system.h"
using base::TimeDelta;
using content::BrowserThread;
namespace {
const char kDialServiceError[] = "Dial service error.";
const int kDialRefreshIntervalSecs = 120;
const int kDialExpirationSecs = 240;
const size_t kDialMaxDevices = 256;
}
namespace extensions {
namespace dial = api::dial;
DialAPI::DialAPI(Profile* profile)
: RefcountedBrowserContextKeyedService(BrowserThread::IO),
profile_(profile) {
ExtensionSystem::Get(profile)->event_router()->RegisterObserver(
this, dial::OnDeviceList::kEventName);
}
DialAPI::~DialAPI() {}
DialRegistry* DialAPI::dial_registry() {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
if (!dial_registry_.get()) {
dial_registry_.reset(new DialRegistry(this,
TimeDelta::FromSeconds(kDialRefreshIntervalSecs),
TimeDelta::FromSeconds(kDialExpirationSecs),
kDialMaxDevices));
}
return dial_registry_.get();
}
void DialAPI::OnListenerAdded(const EventListenerInfo& details) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
BrowserThread::PostTask(
BrowserThread::IO, FROM_HERE,
base::Bind(&DialAPI::NotifyListenerAddedOnIOThread, this));
}
void DialAPI::OnListenerRemoved(const EventListenerInfo& details) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
BrowserThread::PostTask(
BrowserThread::IO, FROM_HERE,
base::Bind(&DialAPI::NotifyListenerRemovedOnIOThread, this));
}
void DialAPI::NotifyListenerAddedOnIOThread() {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
VLOG(1) << "DIAL device event listener added.";
dial_registry()->OnListenerAdded();
}
void DialAPI::NotifyListenerRemovedOnIOThread() {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
VLOG(1) << "DIAL device event listener removed";
dial_registry()->OnListenerRemoved();
}
void DialAPI::OnDialDeviceEvent(const DialRegistry::DeviceList& devices) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
base::Bind(&DialAPI::SendEventOnUIThread, this, devices));
}
void DialAPI::OnDialError(const DialRegistry::DialErrorCode code) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
base::Bind(&DialAPI::SendErrorOnUIThread, this, code));
}
void DialAPI::SendEventOnUIThread(const DialRegistry::DeviceList& devices) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
std::vector<linked_ptr<api::dial::DialDevice> > args;
for (DialRegistry::DeviceList::const_iterator it = devices.begin();
it != devices.end(); ++it) {
linked_ptr<api::dial::DialDevice> api_device =
make_linked_ptr(new api::dial::DialDevice);
it->FillDialDevice(api_device.get());
args.push_back(api_device);
}
scoped_ptr<base::ListValue> results = api::dial::OnDeviceList::Create(args);
scoped_ptr<Event> event(
new Event(dial::OnDeviceList::kEventName, results.Pass()));
extensions::ExtensionSystem::Get(profile_)->event_router()->
BroadcastEvent(event.Pass());
}
void DialAPI::SendErrorOnUIThread(const DialRegistry::DialErrorCode code) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
api::dial::DialError dial_error;
switch (code) {
case DialRegistry::DIAL_NO_LISTENERS:
dial_error.code = api::dial::DIAL_ERROR_CODE_NO_LISTENERS;
break;
case DialRegistry::DIAL_NO_INTERFACES:
dial_error.code = api::dial::DIAL_ERROR_CODE_NO_VALID_NETWORK_INTERFACES;
break;
case DialRegistry::DIAL_CELLULAR_NETWORK:
dial_error.code = api::dial::DIAL_ERROR_CODE_CELLULAR_NETWORK;
break;
case DialRegistry::DIAL_NETWORK_DISCONNECTED:
dial_error.code = api::dial::DIAL_ERROR_CODE_NETWORK_DISCONNECTED;
break;
case DialRegistry::DIAL_SOCKET_ERROR:
dial_error.code = api::dial::DIAL_ERROR_CODE_SOCKET_ERROR;
break;
default:
dial_error.code = api::dial::DIAL_ERROR_CODE_UNKNOWN;
break;
}
scoped_ptr<base::ListValue> results = api::dial::OnError::Create(dial_error);
scoped_ptr<Event> event(new Event(dial::OnError::kEventName, results.Pass()));
extensions::ExtensionSystem::Get(profile_)->event_router()->
BroadcastEvent(event.Pass());
}
void DialAPI::ShutdownOnUIThread() {}
namespace api {
DialDiscoverNowFunction::DialDiscoverNowFunction()
: dial_(NULL), result_(false) {
}
bool DialDiscoverNowFunction::Prepare() {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
DCHECK(browser_context());
dial_ = DialAPIFactory::GetForBrowserContext(browser_context()).get();
return true;
}
void DialDiscoverNowFunction::Work() {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
result_ = dial_->dial_registry()->DiscoverNow();
}
bool DialDiscoverNowFunction::Respond() {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
if (!result_)
error_ = kDialServiceError;
SetResult(new base::FundamentalValue(result_));
return true;
}
}
}