device/bluetooth/bluetooth_socket_thread_win.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "device/bluetooth/bluetooth_socket_thread_win.h"
   6
   7 #include "base/lazy_instance.h"
   8 #include "base/sequenced_task_runner.h"
   9 #include "base/threading/thread.h"
  10
  11 namespace device {
  12
  13 base::LazyInstance<scoped_refptr<BluetoothSocketThreadWin> > g_instance =
  14     LAZY_INSTANCE_INITIALIZER;
  15
  16 // static
  17 scoped_refptr<BluetoothSocketThreadWin> BluetoothSocketThreadWin::Get() {
  18   if (!g_instance.Get().get()) {
  19     g_instance.Get() = new BluetoothSocketThreadWin();
  20   }
  21   return g_instance.Get();
  22 }
  23
  24 BluetoothSocketThreadWin::BluetoothSocketThreadWin()
  25     : active_socket_count_(0) {}
  26
  27 BluetoothSocketThreadWin::~BluetoothSocketThreadWin() {}
  28
  29 void BluetoothSocketThreadWin::OnSocketActivate() {
  30   DCHECK(thread_checker_.CalledOnValidThread());
  31   active_socket_count_++;
  32   EnsureStarted();
  33 }
  34
  35 void BluetoothSocketThreadWin::OnSocketDeactivate() {
  36   DCHECK(thread_checker_.CalledOnValidThread());
  37   active_socket_count_--;
  38   if (active_socket_count_ == 0 && thread_) {
  39     thread_->Stop();
  40     thread_.reset(NULL);
  41     task_runner_ = NULL;
  42   }
  43 }
  44
  45 void BluetoothSocketThreadWin::EnsureStarted() {
  46   DCHECK(thread_checker_.CalledOnValidThread());
  47   if (thread_)
  48     return;
  49
  50   base::Thread::Options thread_options;
  51   thread_options.message_loop_type = base::MessageLoop::TYPE_IO;
  52   thread_.reset(new base::Thread("BluetoothSocketThreadWin"));
  53   thread_->StartWithOptions(thread_options);
  54   task_runner_ = thread_->message_loop_proxy();
  55 }
  56
  57 scoped_refptr<base::SequencedTaskRunner> BluetoothSocketThreadWin::task_runner()
  58     const {
  59   DCHECK(active_socket_count_ > 0);
  60   DCHECK(thread_);
  61   DCHECK(task_runner_);
  62
  63   return task_runner_;
  64 }
  65
  66 }  // namespace device