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 |