| Index: trunk/src/content/renderer/media/midi_message_filter.cc
|
| ===================================================================
|
| --- trunk/src/content/renderer/media/midi_message_filter.cc (revision 207994)
|
| +++ trunk/src/content/renderer/media/midi_message_filter.cc (working copy)
|
| @@ -1,199 +0,0 @@
|
| -// Copyright (c) 2013 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 "content/renderer/media/midi_message_filter.h"
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/debug/trace_event.h"
|
| -#include "base/message_loop/message_loop_proxy.h"
|
| -#include "base/strings/utf_string_conversions.h"
|
| -#include "content/common/media/midi_messages.h"
|
| -#include "content/renderer/render_thread_impl.h"
|
| -#include "ipc/ipc_logging.h"
|
| -
|
| -using media::MIDIPortInfoList;
|
| -using base::AutoLock;
|
| -
|
| -namespace content {
|
| -
|
| -MIDIMessageFilter::MIDIMessageFilter(
|
| - const scoped_refptr<base::MessageLoopProxy>& io_message_loop)
|
| - : channel_(NULL),
|
| - io_message_loop_(io_message_loop),
|
| - next_available_id_(0) {
|
| -}
|
| -
|
| -MIDIMessageFilter::~MIDIMessageFilter() {}
|
| -
|
| -void MIDIMessageFilter::Send(IPC::Message* message) {
|
| - DCHECK(io_message_loop_->BelongsToCurrentThread());
|
| - if (!channel_) {
|
| - delete message;
|
| - } else {
|
| - channel_->Send(message);
|
| - }
|
| -}
|
| -
|
| -bool MIDIMessageFilter::OnMessageReceived(const IPC::Message& message) {
|
| - DCHECK(io_message_loop_->BelongsToCurrentThread());
|
| - bool handled = true;
|
| - IPC_BEGIN_MESSAGE_MAP(MIDIMessageFilter, message)
|
| - IPC_MESSAGE_HANDLER(MIDIMsg_AccessApproved, OnAccessApproved)
|
| - IPC_MESSAGE_HANDLER(MIDIMsg_DataReceived, OnDataReceived)
|
| - IPC_MESSAGE_UNHANDLED(handled = false)
|
| - IPC_END_MESSAGE_MAP()
|
| - return handled;
|
| -}
|
| -
|
| -void MIDIMessageFilter::OnFilterAdded(IPC::Channel* channel) {
|
| - DCHECK(io_message_loop_->BelongsToCurrentThread());
|
| - channel_ = channel;
|
| -}
|
| -
|
| -void MIDIMessageFilter::OnFilterRemoved() {
|
| - DCHECK(io_message_loop_->BelongsToCurrentThread());
|
| -
|
| - // Once removed, a filter will not be used again. At this time all
|
| - // delegates must be notified so they release their reference.
|
| - OnChannelClosing();
|
| -}
|
| -
|
| -void MIDIMessageFilter::OnChannelClosing() {
|
| - DCHECK(io_message_loop_->BelongsToCurrentThread());
|
| - channel_ = NULL;
|
| -}
|
| -
|
| -void MIDIMessageFilter::RequestAccess(
|
| - WebKit::WebMIDIAccessorClient* client, int access) {
|
| - // Generate and keep track of a "client id" which is sent to the browser
|
| - // to ask permission to talk to MIDI hardware.
|
| - // This id is handed back when we receive the answer in OnAccessApproved().
|
| - if (clients_.find(client) == clients_.end()) {
|
| - int client_id = next_available_id_++;
|
| - clients_[client] = client_id;
|
| -
|
| - io_message_loop_->PostTask(FROM_HERE,
|
| - base::Bind(&MIDIMessageFilter::RequestAccessOnIOThread, this,
|
| - client_id, access));
|
| - }
|
| -}
|
| -
|
| -void MIDIMessageFilter::RequestAccessOnIOThread(int client_id, int access) {
|
| - Send(new MIDIHostMsg_RequestAccess(client_id, access));
|
| -}
|
| -
|
| -void MIDIMessageFilter::RemoveClient(WebKit::WebMIDIAccessorClient* client) {
|
| - ClientsMap::iterator i = clients_.find(client);
|
| - if (i != clients_.end())
|
| - clients_.erase(i);
|
| -}
|
| -
|
| -// Received from browser.
|
| -
|
| -void MIDIMessageFilter::OnAccessApproved(
|
| - int client_id,
|
| - int access,
|
| - bool success,
|
| - MIDIPortInfoList inputs,
|
| - MIDIPortInfoList outputs) {
|
| - // Handle on the main JS thread.
|
| - ChildThread::current()->message_loop()->PostTask(FROM_HERE,
|
| - base::Bind(&MIDIMessageFilter::HandleAccessApproved, this,
|
| - client_id, access, success, inputs, outputs));
|
| -}
|
| -
|
| -void MIDIMessageFilter::HandleAccessApproved(
|
| - int client_id,
|
| - int access,
|
| - bool success,
|
| - MIDIPortInfoList inputs,
|
| - MIDIPortInfoList outputs) {
|
| - WebKit::WebMIDIAccessorClient* client = GetClientFromId(client_id);
|
| - if (!client)
|
| - return;
|
| -
|
| - if (success) {
|
| - // Add the client's input and output ports.
|
| - for (size_t i = 0; i < inputs.size(); ++i) {
|
| - client->didAddInputPort(
|
| - UTF8ToUTF16(inputs[i].id),
|
| - UTF8ToUTF16(inputs[i].manufacturer),
|
| - UTF8ToUTF16(inputs[i].name),
|
| - UTF8ToUTF16(inputs[i].version));
|
| - }
|
| -
|
| - for (size_t i = 0; i < outputs.size(); ++i) {
|
| - client->didAddOutputPort(
|
| - UTF8ToUTF16(outputs[i].id),
|
| - UTF8ToUTF16(outputs[i].manufacturer),
|
| - UTF8ToUTF16(outputs[i].name),
|
| - UTF8ToUTF16(outputs[i].version));
|
| - }
|
| - }
|
| -
|
| - if (success)
|
| - client->didAllowAccess();
|
| - else
|
| - client->didBlockAccess();
|
| -}
|
| -
|
| -WebKit::WebMIDIAccessorClient*
|
| -MIDIMessageFilter::GetClientFromId(int client_id) {
|
| - // Iterating like this seems inefficient, but in practice there generally
|
| - // will be very few clients (usually one). Additionally, this lookup
|
| - // usually happens one time during page load. So the performance hit is
|
| - // negligible.
|
| - for (ClientsMap::iterator i = clients_.begin(); i != clients_.end(); ++i) {
|
| - if ((*i).second == client_id)
|
| - return (*i).first;
|
| - }
|
| - return NULL;
|
| -}
|
| -
|
| -void MIDIMessageFilter::OnDataReceived(int port,
|
| - const std::vector<uint8>& data,
|
| - double timestamp) {
|
| - TRACE_EVENT0("midi", "MIDIMessageFilter::OnDataReceived");
|
| -
|
| - ChildThread::current()->message_loop()->PostTask(FROM_HERE,
|
| - base::Bind(&MIDIMessageFilter::HandleDataReceived, this,
|
| - port, data, timestamp));
|
| -}
|
| -
|
| -void MIDIMessageFilter::HandleDataReceived(int port,
|
| - const std::vector<uint8>& data,
|
| - double timestamp) {
|
| - TRACE_EVENT0("midi", "MIDIMessageFilter::HandleDataReceived");
|
| -
|
| -#if defined(OS_ANDROID)
|
| - // TODO(crogers): figure out why data() method does not compile on Android.
|
| - NOTIMPLEMENTED();
|
| -#else
|
| - for (ClientsMap::iterator i = clients_.begin(); i != clients_.end(); ++i)
|
| - (*i).first->didReceiveMIDIData(port, data.data(), data.size(), timestamp);
|
| -#endif
|
| -}
|
| -
|
| -void MIDIMessageFilter::SendMIDIData(int port,
|
| - const uint8* data,
|
| - size_t length,
|
| - double timestamp) {
|
| - // TODO(crogers): we need more work to check the amount of data sent,
|
| - // throttle if necessary, and filter out the SYSEX messages if not
|
| - // approved. For now, we will not implement the sending of MIDI data.
|
| - NOTIMPLEMENTED();
|
| - // std::vector<uint8> v(data, data + length);
|
| - // io_message_loop_->PostTask(FROM_HERE,
|
| - // base::Bind(&MIDIMessageFilter::SendMIDIDataOnIOThread, this,
|
| - // port, v, timestamp));
|
| -}
|
| -
|
| -void MIDIMessageFilter::SendMIDIDataOnIOThread(int port,
|
| - const std::vector<uint8>& data,
|
| - double timestamp) {
|
| - // Send to the browser.
|
| - Send(new MIDIHostMsg_SendData(port, data, timestamp));
|
| -}
|
| -
|
| -} // namespace content
|
|
|