content/child/bluetooth/bluetooth_dispatcher.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 CONTENT_CHILD_BLUETOOTH_BLUETOOTH_DISPATCHER_H_
   6 #define CONTENT_CHILD_BLUETOOTH_BLUETOOTH_DISPATCHER_H_
   7
   8 #include "base/id_map.h"
   9 #include "base/memory/ref_counted.h"
  10 #include "content/child/worker_task_runner.h"
  11 #include "content/common/bluetooth/bluetooth_device.h"
  12 #include "content/common/bluetooth/bluetooth_error.h"
  13 #include "third_party/WebKit/public/platform/WebBluetooth.h"
  14
  15 namespace base {
  16 class MessageLoop;
  17 class TaskRunner;
  18 }
  19
  20 namespace IPC {
  21 class Message;
  22 }
  23
  24 namespace content {
  25 class ThreadSafeSender;
  26
  27 // Dispatcher for child process threads which communicates to the browser's
  28 // BluetoothDispatcherHost.
  29 //
  30 // Instances are created for each thread as necessary by WebBluetoothImpl.
  31 //
  32 // Incoming IPC messages are received by the BluetoothMessageFilter and
  33 // directed to the thread specific instance of this class.
  34 // Outgoing messages come from WebBluetoothImpl.
  35 class BluetoothDispatcher : public WorkerTaskRunner::Observer {
  36  public:
  37   explicit BluetoothDispatcher(ThreadSafeSender* sender);
  38   ~BluetoothDispatcher() override;
  39
  40   // Gets or Creates a BluetoothDispatcher for the current thread.
  41   // |thread_safe_sender| is required when constructing a BluetoothDispatcher.
  42   static BluetoothDispatcher* GetOrCreateThreadSpecificInstance(
  43       ThreadSafeSender* thread_safe_sender);
  44
  45   // IPC Send and Receiving interface, see IPC::Sender and IPC::Listener.
  46   bool Send(IPC::Message* msg);
  47   void OnMessageReceived(const IPC::Message& msg);
  48
  49   // Corresponding to WebBluetoothImpl methods.
  50   void requestDevice(blink::WebBluetoothRequestDeviceCallbacks* callbacks);
  51   void SetBluetoothMockDataSetForTesting(const std::string& name);
  52
  53   // WorkerTaskRunner::Observer implementation.
  54   void OnWorkerRunLoopStopped() override;
  55
  56  private:
  57   // IPC Handlers, see definitions in bluetooth_messages.h.
  58   void OnRequestDeviceSuccess(int thread_id,
  59                               int request_id,
  60                               const BluetoothDevice& device);
  61   void OnRequestDeviceError(int thread_id,
  62                             int request_id,
  63                             BluetoothError error_type);
  64
  65   scoped_refptr<ThreadSafeSender> thread_safe_sender_;
  66
  67   // Tracks requests sent to browser to match replies with callbacks.
  68   // Owns callback objects.
  69   IDMap<blink::WebBluetoothRequestDeviceCallbacks, IDMapOwnPointer>
  70       pending_requests_;
  71
  72   DISALLOW_COPY_AND_ASSIGN(BluetoothDispatcher);
  73 };
  74
  75 }  // namespace content
  76
  77 #endif  // CONTENT_CHILD_BLUETOOTH_BLUETOOTH_DISPATCHER_H_