Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(48)

Side by Side Diff: media/midi/midi_manager.h

Issue 23379002: Web MIDI: fix multi-threading problem around message buffer handling (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: review #7 and #8 Created 7 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 #ifndef MEDIA_MIDI_MIDI_MANAGER_H_ 5 #ifndef MEDIA_MIDI_MIDI_MANAGER_H_
6 #define MEDIA_MIDI_MIDI_MANAGER_H_ 6 #define MEDIA_MIDI_MIDI_MANAGER_H_
7 7
8 #include <set> 8 #include <set>
9 #include <vector>
9 10
10 #include "base/basictypes.h" 11 #include "base/basictypes.h"
11 #include "base/memory/scoped_ptr.h" 12 #include "base/memory/scoped_ptr.h"
12 #include "base/message_loop/message_loop_proxy.h" 13 #include "base/message_loop/message_loop_proxy.h"
13 #include "base/synchronization/lock.h" 14 #include "base/synchronization/lock.h"
14 #include "media/base/media_export.h" 15 #include "media/base/media_export.h"
15 #include "media/midi/midi_port_info.h" 16 #include "media/midi/midi_port_info.h"
16 17
17 namespace base { 18 namespace base {
18 class Thread; 19 class Thread;
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
63 void EndSession(MIDIManagerClient* client); 64 void EndSession(MIDIManagerClient* client);
64 65
65 // DispatchSendMIDIData() schedules one or more messages to be sent 66 // DispatchSendMIDIData() schedules one or more messages to be sent
66 // at the given time on a dedicated thread. 67 // at the given time on a dedicated thread.
67 // |port_index| represents the specific output port from output_ports(). 68 // |port_index| represents the specific output port from output_ports().
68 // |data| represents a series of bytes encoding one or more MIDI messages. 69 // |data| represents a series of bytes encoding one or more MIDI messages.
69 // |length| is the number of bytes in |data|. 70 // |length| is the number of bytes in |data|.
70 // |timestamp| is the time to send the data, in seconds. A value of 0 71 // |timestamp| is the time to send the data, in seconds. A value of 0
71 // means send "now" or as soon as possible. 72 // means send "now" or as soon as possible.
72 void DispatchSendMIDIData(MIDIManagerClient* client, 73 void DispatchSendMIDIData(MIDIManagerClient* client,
73 int port_index, 74 size_t port_index,
74 const uint8* data, 75 const std::vector<uint8>& data,
75 size_t length,
76 double timestamp); 76 double timestamp);
77 77
78 // input_ports() is a list of MIDI ports for receiving MIDI data. 78 // input_ports() is a list of MIDI ports for receiving MIDI data.
79 // Each individual port in this list can be identified by its 79 // Each individual port in this list can be identified by its
80 // integer index into this list. 80 // integer index into this list.
81 const MIDIPortInfoList& input_ports() { return input_ports_; } 81 const MIDIPortInfoList& input_ports() { return input_ports_; }
82 82
83 // output_ports() is a list of MIDI ports for sending MIDI data. 83 // output_ports() is a list of MIDI ports for sending MIDI data.
84 // Each individual port in this list can be identified by its 84 // Each individual port in this list can be identified by its
85 // integer index into this list. 85 // integer index into this list.
86 const MIDIPortInfoList& output_ports() { return output_ports_; } 86 const MIDIPortInfoList& output_ports() { return output_ports_; }
87 87
88 protected: 88 protected:
89 // Initializes the MIDI system, returning |true| on success. 89 // Initializes the MIDI system, returning |true| on success.
90 virtual bool Initialize() = 0; 90 virtual bool Initialize() = 0;
91 91
92 // Implements the platform-specific details of sending MIDI data. 92 // Implements the platform-specific details of sending MIDI data.
93 // This function runs on MIDISendThread.
93 virtual void SendMIDIData(MIDIManagerClient* client, 94 virtual void SendMIDIData(MIDIManagerClient* client,
94 int port_index, 95 size_t port_index,
95 const uint8* data, 96 const std::vector<uint8>& data,
96 size_t length,
97 double timestamp) = 0; 97 double timestamp) = 0;
98 98
99 void AddInputPort(const MIDIPortInfo& info); 99 void AddInputPort(const MIDIPortInfo& info);
100 void AddOutputPort(const MIDIPortInfo& info); 100 void AddOutputPort(const MIDIPortInfo& info);
101 101
102 // Dispatches to all clients. 102 // Dispatches to all clients.
103 void ReceiveMIDIData( 103 // TODO(toyoshim): Make |port_index| size_t to be consistent with send side.
palmer 2013/08/26 17:43:25 uint32_t. And, why not do it now?
Takashi Toyoshima 2013/08/27 07:14:33 Maybe I should split all type related changes to a
104 int port_index, 104 void ReceiveMIDIData(int port_index,
105 const uint8* data, 105 const uint8* data,
106 size_t length, 106 size_t length,
107 double timestamp); 107 double timestamp);
108
109 // Checks if current thread is MIDISendThread.
110 bool CurrentlyOnMIDISendThread();
108 111
109 bool initialized_; 112 bool initialized_;
110 113
111 // Keeps track of all clients who wish to receive MIDI data. 114 // Keeps track of all clients who wish to receive MIDI data.
112 typedef std::set<MIDIManagerClient*> ClientList; 115 typedef std::set<MIDIManagerClient*> ClientList;
113 ClientList clients_; 116 ClientList clients_;
114 117
115 // Protects access to our clients. 118 // Protects access to our clients.
116 base::Lock clients_lock_; 119 base::Lock clients_lock_;
117 120
118 MIDIPortInfoList input_ports_; 121 MIDIPortInfoList input_ports_;
119 MIDIPortInfoList output_ports_; 122 MIDIPortInfoList output_ports_;
120 123
121 // |send_thread_| is used to send MIDI data by calling the platform-specific 124 // |send_thread_| is used to send MIDI data by calling the platform-specific
122 // API. 125 // API.
123 scoped_ptr<base::Thread> send_thread_; 126 scoped_ptr<base::Thread> send_thread_;
124 scoped_refptr<base::MessageLoopProxy> send_message_loop_; 127 scoped_refptr<base::MessageLoopProxy> send_message_loop_;
125 128
126 DISALLOW_COPY_AND_ASSIGN(MIDIManager); 129 DISALLOW_COPY_AND_ASSIGN(MIDIManager);
127 }; 130 };
128 131
129 } // namespace media 132 } // namespace media
130 133
131 #endif // MEDIA_MIDI_MIDI_MANAGER_H_ 134 #endif // MEDIA_MIDI_MIDI_MANAGER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698