Implemented BluetoothTaskManagerWin class.

device/bluetooth/bluetooth_polling_thread_win.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 "device/bluetooth/bluetooth_polling_thread_win.h"
+
+#include <BluetoothAPIs.h>
+#include "base/message_loop.h"
+#include "base/stringprintf.h"
+#include "base/sys_string_conversions.h"
+#include "content/public/browser/browser_thread.h"
+#include "device/bluetooth/bluetooth_adapter_win.h"
+
+# pragma comment(lib, "Bthprops.lib")
+
+namespace {
+
+const char* kBluetoothManagerThreadName = "BluetoothPollingThreadWin";
+const BLUETOOTH_FIND_RADIO_PARAMS adapter_param =
+    { sizeof(BLUETOOTH_FIND_RADIO_PARAMS) };
+
+}  // namespace
+
+namespace device {
+
+// static
+const int BluetoothPollingThreadWin::kPollIntervalMs = 500;
+
+BluetoothPollingThreadWin::BluetoothPollingThreadWin()
+    : Thread(kBluetoothManagerThreadName),
+      ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) {
+  thread_checker_.DetachFromThread();
+}
+
+BluetoothPollingThreadWin::~BluetoothPollingThreadWin() {
+  cancellation_flag_.Set();

[bryeung, 2012/11/28 16:26:08]

Are you sure this is the right pattern?  To me, this looks like the cancellation
flag will be set and then immediately destructed when this method completes. 
It's not clear to me how that is helpful.

[youngki, 2012/11/28 19:19:13]

Thread::Stop() on the next line waits until all the pending tasks in
BluetoothPollingThread finish. So setting cancellation_flag_ here will make
those tasks skip the most of the logics and quit. Also this class won't get
destroyed until it makes sure the thread completely terminates. I documented
this as comments here.

+  Stop();
+}
+
+void BluetoothPollingThreadWin::AddObserver(Observer* observer) {
+  DCHECK(observer);

[bryeung, 2012/11/28 16:26:08]

CHECK is probably better here (and below)

[youngki, 2012/11/28 19:19:13]

Done.

+  observers_.AddObserver(observer);
+}
+
+void BluetoothPollingThreadWin::RemoveObserver(Observer* observer) {
+  DCHECK(observer);
+  observers_.RemoveObserver(observer);
+}
+
+void BluetoothPollingThreadWin::Init() {
+  if (!message_loop()) {
+    Start();
+    message_loop()->PostTask(
+        FROM_HERE,
+        base::Bind(&BluetoothPollingThreadWin::PollAdapter,
+                   base::Unretained(this),
+                   weak_ptr_factory_.GetWeakPtr()));
+  }
+}
+
+// static
+void BluetoothPollingThreadWin::GetAdapterState(
+    const HANDLE adapter_handle, AdapterState* state) {
+  std::string name;
+  std::string address;
+  bool powered = false;
+  BLUETOOTH_RADIO_INFO adapter_info = { sizeof(BLUETOOTH_RADIO_INFO), 0 };
+  if (adapter_handle &&
+      ERROR_SUCCESS == BluetoothGetRadioInfo(adapter_handle,
+                                             &adapter_info)) {
+    name = base::SysWideToUTF8(adapter_info.szName);
+    address = base::StringPrintf("%02X:%02X:%02X:%02X:%02X:%02X",
+        adapter_info.address.rgBytes[5],
+        adapter_info.address.rgBytes[4],
+        adapter_info.address.rgBytes[3],
+        adapter_info.address.rgBytes[2],
+        adapter_info.address.rgBytes[1],
+        adapter_info.address.rgBytes[0]);
+    powered = !!BluetoothIsConnectable(adapter_handle);
+  }
+  state->name = name;
+  state->address = address;
+  state->powered = powered;
+}
+
+void BluetoothPollingThreadWin::PollAdapter(
+    base::WeakPtr<BluetoothPollingThreadWin> weak_ptr) {

[bryeung, 2012/11/28 16:26:08]

why is this taking a weak_ptr?  When do you intend for the argument weak_ptr to
be different than |this|?  Why?

[youngki, 2012/11/28 19:19:13]

All the instances that we intend to post tasks to UI thread have to be weak
pointers because we cannot guarantee that the instance will live until the UI
thread terminates.

+  if (cancellation_flag_.IsSet())
+    return;
+
+  DCHECK(thread_checker_.CalledOnValidThread());
+
+  HBLUETOOTH_RADIO_FIND adapter_handle = NULL;
+  HBLUETOOTH_RADIO_FIND handle = BluetoothFindFirstRadio(&adapter_param,
+                                                         &adapter_handle);
+  if (handle)
+    BluetoothFindRadioClose(handle);
+
+  AdapterState* state = new AdapterState();
+  GetAdapterState(adapter_handle, state);
+
+  content::BrowserThread::PostTask(
+      content::BrowserThread::UI,
+      FROM_HERE,
+      base::Bind(&BluetoothPollingThreadWin::OnAdapterStateChanged,
+                 weak_ptr,
+                 base::Owned(state)));
+
+  // Re-poll.
+  MessageLoop::current()->PostDelayedTask(
+      FROM_HERE,
+      base::Bind(&BluetoothPollingThreadWin::PollAdapter,
+                 base::Unretained(this),
+                 weak_ptr),
+      base::TimeDelta::FromMilliseconds(kPollIntervalMs));
+}
+
+void BluetoothPollingThreadWin::OnAdapterStateChanged(
+    const AdapterState* state) {

[bryeung, 2012/11/28 16:26:08]

CHECK the thread here

[youngki, 2012/11/28 19:19:13]

Done. I also changed all DCHECK in this file to CHECK.

+  FOR_EACH_OBSERVER(BluetoothPollingThreadWin::Observer, observers_,
+                    AdapterStateChanged(*state));
+}
+
+}  // namespace device