device/bluetooth/bluetooth_socket_thread.h

   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 #ifndef DEVICE_BLUETOOTH_BLUETOOTH_SOCKET_THREAD_H_
   6 #define DEVICE_BLUETOOTH_BLUETOOTH_SOCKET_THREAD_H_
   7
   8 #include "base/memory/ref_counted.h"
   9 #include "base/memory/scoped_ptr.h"
  10 #include "base/threading/thread_checker.h"
  11 #include "device/bluetooth/bluetooth_export.h"
  12
  13 namespace base {
  14 class SequencedTaskRunner;
  15 class Thread;
  16 }  // namespace base
  17
  18 namespace device {
  19
  20 // Thread abstraction used by |BluetoothSocketChromeOS| and |BluetoothSocketWin|
  21 // to perform IO operations on the underlying platform sockets. An instance of
  22 // this class can be shared by many active sockets.
  23 class DEVICE_BLUETOOTH_EXPORT BluetoothSocketThread
  24     : public base::RefCountedThreadSafe<BluetoothSocketThread> {
  25  public:
  26   static scoped_refptr<BluetoothSocketThread> Get();
  27   static void CleanupForTesting();
  28
  29   void OnSocketActivate();
  30   void OnSocketDeactivate();
  31
  32   scoped_refptr<base::SequencedTaskRunner> task_runner() const;
  33
  34  private:
  35   friend class base::RefCountedThreadSafe<BluetoothSocketThread>;
  36   BluetoothSocketThread();
  37   virtual ~BluetoothSocketThread();
  38
  39   void EnsureStarted();
  40
  41   base::ThreadChecker thread_checker_;
  42   int active_socket_count_;
  43   scoped_ptr<base::Thread> thread_;
  44   scoped_refptr<base::SequencedTaskRunner> task_runner_;
  45
  46   DISALLOW_COPY_AND_ASSIGN(BluetoothSocketThread);
  47 };
  48
  49 }  // namespace device
  50
  51 #endif  // DEVICE_BLUETOOTH_BLUETOOTH_SOCKET_THREAD_H_