| 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/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
| 9 #include "base/metrics/histogram_macros.h" | 9 #include "base/metrics/histogram_macros.h" |
| 10 #include "base/trace_event/trace_event.h" | 10 #include "base/trace_event/trace_event.h" |
| (...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 119 // Call StartInitialization() only for the first request. | 119 // Call StartInitialization() only for the first request. |
| 120 if (pending_clients_.empty()) { | 120 if (pending_clients_.empty()) { |
| 121 completion = Completion::INVOKE_INITIALIZATION; | 121 completion = Completion::INVOKE_INITIALIZATION; |
| 122 session_thread_runner_ = base::MessageLoop::current()->task_runner(); | 122 session_thread_runner_ = base::MessageLoop::current()->task_runner(); |
| 123 } else { | 123 } else { |
| 124 completion = Completion::COMPLETE_ASYNCHRONOUSLY; | 124 completion = Completion::COMPLETE_ASYNCHRONOUSLY; |
| 125 } | 125 } |
| 126 pending_clients_.insert(client); | 126 pending_clients_.insert(client); |
| 127 } | 127 } |
| 128 } | 128 } |
| 129 |
| 130 if (completion == Completion::COMPLETE_SYNCHRONOUSLY) { |
| 131 client->CompleteStartSession(result); |
| 132 return; |
| 133 } |
| 129 } | 134 } |
| 130 | 135 |
| 131 if (completion == Completion::COMPLETE_SYNCHRONOUSLY) { | 136 if (completion == Completion::INVOKE_INITIALIZATION) { |
| 132 client->CompleteStartSession(result); | |
| 133 } else if (completion == Completion::INVOKE_INITIALIZATION) { | |
| 134 // Lazily initialize the MIDI back-end. | 137 // Lazily initialize the MIDI back-end. |
| 135 TRACE_EVENT0("midi", "MidiManager::StartInitialization"); | 138 TRACE_EVENT0("midi", "MidiManager::StartInitialization"); |
| 136 // CompleteInitialization() will be called asynchronously when platform | 139 // CompleteInitialization() will be called asynchronously when platform |
| 137 // dependent initialization is finished. | 140 // dependent initialization is finished. |
| 138 StartInitialization(); | 141 StartInitialization(); |
| 139 } | 142 } |
| 140 } | 143 } |
| 141 | 144 |
| 142 void MidiManager::EndSession(MidiManagerClient* client) { | 145 void MidiManager::EndSession(MidiManagerClient* client) { |
| 143 ReportUsage(Usage::SESSION_ENDED); | 146 ReportUsage(Usage::SESSION_ENDED); |
| 144 | 147 |
| 145 // At this point, |client| can be in the destruction process, and calling | 148 // At this point, |client| can be in the destruction process, and calling |
| 146 // any method of |client| is dangerous. | 149 // any method of |client| is dangerous. Calls on clients *must* be protected |
| 150 // by |lock_| to prevent race conditions. |
| 147 base::AutoLock auto_lock(lock_); | 151 base::AutoLock auto_lock(lock_); |
| 148 clients_.erase(client); | 152 clients_.erase(client); |
| 149 pending_clients_.erase(client); | 153 pending_clients_.erase(client); |
| 150 } | 154 } |
| 151 | 155 |
| 152 void MidiManager::AccumulateMidiBytesSent(MidiManagerClient* client, size_t n) { | 156 void MidiManager::AccumulateMidiBytesSent(MidiManagerClient* client, size_t n) { |
| 153 base::AutoLock auto_lock(lock_); | 157 base::AutoLock auto_lock(lock_); |
| 154 if (clients_.find(client) == clients_.end()) | 158 if (clients_.find(client) == clients_.end()) |
| 155 return; | 159 return; |
| 156 | 160 |
| 157 // Continue to hold lock_ here in case another thread is currently doing | 161 // Continue to hold lock_ here in case another thread is currently doing |
| 158 // EndSession. | 162 // EndSession. |
| 159 // Note that if we are in EndSession, then a destructor is being called and | |
| 160 // it isn't really safe to call this method. But we don't have another way to | |
| 161 // check this right now. | |
| 162 client->AccumulateMidiBytesSent(n); | 163 client->AccumulateMidiBytesSent(n); |
| 163 } | 164 } |
| 164 | 165 |
| 165 void MidiManager::DispatchSendMidiData(MidiManagerClient* client, | 166 void MidiManager::DispatchSendMidiData(MidiManagerClient* client, |
| 166 uint32_t port_index, | 167 uint32_t port_index, |
| 167 const std::vector<uint8_t>& data, | 168 const std::vector<uint8_t>& data, |
| 168 double timestamp) { | 169 double timestamp) { |
| 169 NOTREACHED(); | 170 NOTREACHED(); |
| 170 } | 171 } |
| 171 | 172 |
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 264 base::AutoLock auto_lock(lock_); | 265 base::AutoLock auto_lock(lock_); |
| 265 finalized_ = true; | 266 finalized_ = true; |
| 266 | 267 |
| 267 // Detach all clients so that they do not call MidiManager methods any more. | 268 // Detach all clients so that they do not call MidiManager methods any more. |
| 268 for (auto client : clients_) | 269 for (auto client : clients_) |
| 269 client->Detach(); | 270 client->Detach(); |
| 270 } | 271 } |
| 271 | 272 |
| 272 } // namespace midi | 273 } // namespace midi |
| 273 } // namespace media | 274 } // namespace media |
| OLD | NEW |