Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "media/midi/midi_manager.h" | 5 #include "media/midi/midi_manager.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/debug/trace_event.h" | 8 #include "base/debug/trace_event.h" |
| 9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
| 10 #include "base/message_loop/message_loop_proxy.h" | 10 #include "base/message_loop/message_loop_proxy.h" |
| (...skipping 26 matching lines...) Expand all Loading... | |
| 37 if (!session_is_ready) { | 37 if (!session_is_ready) { |
| 38 // Do not accept a new request if the pending client list contains too | 38 // Do not accept a new request if the pending client list contains too |
| 39 // many clients. | 39 // many clients. |
| 40 too_many_pending_clients_exist = | 40 too_many_pending_clients_exist = |
| 41 pending_clients_.size() >= kMaxPendingClientCount; | 41 pending_clients_.size() >= kMaxPendingClientCount; |
| 42 | 42 |
| 43 if (!too_many_pending_clients_exist) { | 43 if (!too_many_pending_clients_exist) { |
| 44 // Call StartInitialization() only for the first request. | 44 // Call StartInitialization() only for the first request. |
| 45 session_needs_initialization = pending_clients_.empty(); | 45 session_needs_initialization = pending_clients_.empty(); |
| 46 pending_clients_.insert( | 46 pending_clients_.insert( |
| 47 std::pair<int, MidiManagerClient*>(client_id, client)); | 47 std::pair<MidiManagerClient*, int>(client, client_id)); |
|
yhirano
2014/06/12 04:49:10
You can use std::make_pair.
Takashi Toyoshima
2014/06/12 04:54:30
Done.
| |
| 48 } | 48 } |
| 49 } | 49 } |
| 50 } | 50 } |
| 51 | 51 |
| 52 // Lazily initialize the MIDI back-end. | 52 // Lazily initialize the MIDI back-end. |
| 53 if (!session_is_ready) { | 53 if (!session_is_ready) { |
| 54 if (session_needs_initialization) { | 54 if (session_needs_initialization) { |
| 55 TRACE_EVENT0("midi", "MidiManager::StartInitialization"); | 55 TRACE_EVENT0("midi", "MidiManager::StartInitialization"); |
| 56 session_thread_runner_ = | 56 session_thread_runner_ = |
| 57 base::MessageLoop::current()->message_loop_proxy(); | 57 base::MessageLoop::current()->message_loop_proxy(); |
| (...skipping 16 matching lines...) Expand all Loading... | |
| 74 base::AutoLock auto_lock(lock_); | 74 base::AutoLock auto_lock(lock_); |
| 75 if (result_ == MIDI_OK) | 75 if (result_ == MIDI_OK) |
| 76 clients_.insert(client); | 76 clients_.insert(client); |
| 77 result = result_; | 77 result = result_; |
| 78 } | 78 } |
| 79 client->CompleteStartSession(client_id, result); | 79 client->CompleteStartSession(client_id, result); |
| 80 } | 80 } |
| 81 | 81 |
| 82 void MidiManager::EndSession(MidiManagerClient* client) { | 82 void MidiManager::EndSession(MidiManagerClient* client) { |
| 83 base::AutoLock auto_lock(lock_); | 83 base::AutoLock auto_lock(lock_); |
| 84 ClientList::iterator i = clients_.find(client); | 84 clients_.erase(client); |
| 85 if (i != clients_.end()) | 85 pending_clients_.erase(client); |
| 86 clients_.erase(i); | |
| 87 } | 86 } |
| 88 | 87 |
| 89 void MidiManager::DispatchSendMidiData(MidiManagerClient* client, | 88 void MidiManager::DispatchSendMidiData(MidiManagerClient* client, |
| 90 uint32 port_index, | 89 uint32 port_index, |
| 91 const std::vector<uint8>& data, | 90 const std::vector<uint8>& data, |
| 92 double timestamp) { | 91 double timestamp) { |
| 93 NOTREACHED(); | 92 NOTREACHED(); |
| 94 } | 93 } |
| 95 | 94 |
| 96 void MidiManager::StartInitialization() { | 95 void MidiManager::StartInitialization() { |
| (...skipping 28 matching lines...) Expand all Loading... | |
| 125 | 124 |
| 126 for (ClientList::iterator i = clients_.begin(); i != clients_.end(); ++i) | 125 for (ClientList::iterator i = clients_.begin(); i != clients_.end(); ++i) |
| 127 (*i)->ReceiveMidiData(port_index, data, length, timestamp); | 126 (*i)->ReceiveMidiData(port_index, data, length, timestamp); |
| 128 } | 127 } |
| 129 | 128 |
| 130 void MidiManager::CompleteInitializationInternal(MidiResult result) { | 129 void MidiManager::CompleteInitializationInternal(MidiResult result) { |
| 131 TRACE_EVENT0("midi", "MidiManager::CompleteInitialization"); | 130 TRACE_EVENT0("midi", "MidiManager::CompleteInitialization"); |
| 132 | 131 |
| 133 base::AutoLock auto_lock(lock_); | 132 base::AutoLock auto_lock(lock_); |
| 134 DCHECK(clients_.empty()); | 133 DCHECK(clients_.empty()); |
| 135 DCHECK(!pending_clients_.empty()); | |
| 136 DCHECK(!initialized_); | 134 DCHECK(!initialized_); |
| 137 initialized_ = true; | 135 initialized_ = true; |
| 138 result_ = result; | 136 result_ = result; |
| 139 | 137 |
| 140 for (PendingClientMap::iterator it = pending_clients_.begin(); | 138 for (PendingClientMap::iterator it = pending_clients_.begin(); |
| 141 it != pending_clients_.end(); | 139 it != pending_clients_.end(); |
| 142 ++it) { | 140 ++it) { |
| 143 if (result_ == MIDI_OK) | 141 if (result_ == MIDI_OK) |
| 144 clients_.insert(it->second); | 142 clients_.insert(it->first); |
| 145 it->second->CompleteStartSession(it->first, result_); | 143 it->first->CompleteStartSession(it->second, result_); |
| 146 } | 144 } |
| 147 pending_clients_.clear(); | 145 pending_clients_.clear(); |
| 148 } | 146 } |
| 149 | 147 |
| 150 } // namespace media | 148 } // namespace media |
| OLD | NEW |