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/modules/bluetooth/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 connectGATT(const blink::WebString& device_instance_id,
  52                    blink::WebBluetoothConnectGATTCallbacks* callbacks);
  53   void SetBluetoothMockDataSetForTesting(const std::string& name);
  54
  55   // WorkerTaskRunner::Observer implementation.
  56   void OnWorkerRunLoopStopped() override;
  57
  58  private:
  59   // IPC Handlers, see definitions in bluetooth_messages.h.
  60   void OnRequestDeviceSuccess(int thread_id,
  61                               int request_id,
  62                               const BluetoothDevice& device);
  63   void OnRequestDeviceError(int thread_id,
  64                             int request_id,
  65                             BluetoothError error_type);
  66
  67   void OnConnectGATTSuccess(int thread_id,
  68                             int request_id,
  69                             const std::string& message);
  70
  71   scoped_refptr<ThreadSafeSender> thread_safe_sender_;
  72
  73   // Tracks device requests sent to browser to match replies with callbacks.
  74   // Owns callback objects.
  75   IDMap<blink::WebBluetoothRequestDeviceCallbacks, IDMapOwnPointer>
  76       pending_requests_;
  77   // Tracks requests to connect to a device.
  78   // Owns callback objects.
  79   IDMap<blink::WebBluetoothConnectGATTCallbacks, IDMapOwnPointer>
  80       pending_connect_requests_;
  81
  82   DISALLOW_COPY_AND_ASSIGN(BluetoothDispatcher);
  83 };
  84
  85 }  // namespace content
  86
  87 #endif  // CONTENT_CHILD_BLUETOOTH_BLUETOOTH_DISPATCHER_H_