2 Copyright (C) 2006 Paul Davis
4 This program is free software; you can redistribute it and/or modify it
5 under the terms of the GNU General Public License as published by the Free
6 Software Foundation; either version 2 of the License, or (at your option)
9 This program is distributed in the hope that it will be useful, but WITHOUT
10 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14 You should have received a copy of the GNU General Public License along
15 with this program; if not, write to the Free Software Foundation, Inc.,
16 675 Mass Ave, Cambridge, MA 02139, USA.
21 #include "ardour/buffer.h"
22 #include "ardour/buffer_set.h"
23 #include "ardour/midi_buffer.h"
24 #include "ardour/port.h"
25 #include "ardour/port_set.h"
26 #include "ardour/audioengine.h"
28 #include "ardour/lv2_plugin.h"
29 #include "ardour/lv2_event_buffer.h"
34 /** Create a new, empty BufferSet */
35 BufferSet::BufferSet()
38 for (size_t i=0; i < DataType::num_types; ++i) {
39 _buffers.push_back(BufferVec());
46 BufferSet::~BufferSet()
51 /** Destroy all contained buffers.
57 for (std::vector<BufferVec>::iterator i = _buffers.begin(); i != _buffers.end(); ++i) {
58 for (BufferVec::iterator j = (*i).begin(); j != (*i).end(); ++j) {
69 /** Make this BufferSet a direct mirror of a PortSet's buffers.
72 BufferSet::attach_buffers(PortSet& ports, nframes_t nframes, nframes_t offset)
76 for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
77 _buffers.push_back(BufferVec());
78 BufferVec& v = _buffers[*t];
80 for (PortSet::iterator p = ports.begin(*t); p != ports.end(*t); ++p) {
81 assert(p->type() == *t);
82 v.push_back(&(p->get_buffer(nframes, offset)));
86 _count = ports.count();
91 /** Ensure that there are @a num_buffers buffers of type @a type available,
92 * each of size at least @a buffer_size
95 BufferSet::ensure_buffers(DataType type, size_t num_buffers, size_t buffer_capacity)
97 assert(type != DataType::NIL);
98 assert(type < _buffers.size());
100 if (num_buffers == 0)
103 // The vector of buffers of the type we care about
104 BufferVec& bufs = _buffers[type];
106 // If we're a mirror just make sure we're ok
108 assert(_count.get(type) >= num_buffers);
109 assert(bufs[0]->type() == type);
113 // If there's not enough or they're too small, just nuke the whole thing and
114 // rebuild it (so I'm lazy..)
115 if (bufs.size() < num_buffers
116 || (bufs.size() > 0 && bufs[0]->capacity() < buffer_capacity)) {
119 for (BufferVec::iterator i = bufs.begin(); i != bufs.end(); ++i) {
125 for (size_t i = 0; i < num_buffers; ++i) {
126 bufs.push_back(Buffer::create(type, buffer_capacity));
129 _available.set(type, num_buffers);
133 // Ensure enough low level MIDI format buffers are available for conversion
134 // in both directions (input & output, out-of-place)
135 if (type == DataType::MIDI && _lv2_buffers.size() < _buffers[type].size() * 2) {
136 while (_lv2_buffers.size() < _buffers[type].size() * 2) {
137 _lv2_buffers.push_back(std::make_pair(false, new LV2EventBuffer(buffer_capacity)));
143 assert(bufs[0]->type() == type);
144 assert(bufs.size() >= num_buffers);
145 assert(bufs.size() == _available.get(type));
146 assert(bufs[0]->capacity() >= buffer_capacity);
149 /** Get the capacity (size) of the available buffers of the given type.
151 * All buffers of a certain type always have the same capacity.
154 BufferSet::buffer_capacity(DataType type) const
156 assert(_available.get(type) > 0);
157 return _buffers[type][0]->capacity();
161 BufferSet::get(DataType type, size_t i)
163 assert(i <= _count.get(type));
164 return *_buffers[type][i];
170 BufferSet::get_lv2_midi(bool input, size_t i)
172 MidiBuffer& mbuf = get_midi(i);
173 LV2Buffers::value_type b = _lv2_buffers.at(i * 2 + (input ? 0 : 1));
174 LV2EventBuffer* ebuf = b.second;
178 for (MidiBuffer::iterator e = mbuf.begin(); e != mbuf.end(); ++e) {
179 const Evoral::MIDIEvent<nframes_t> ev(*e, false);
180 uint32_t type = LV2Plugin::midi_event_type();
181 ebuf->append(ev.time(), 0, type, ev.size(), ev.buffer());
188 BufferSet::flush_lv2_midi(bool input, size_t i)
190 MidiBuffer& mbuf = get_midi(i);
191 LV2Buffers::value_type b = _lv2_buffers.at(i * 2 + (input ? 0 : 1));
192 LV2EventBuffer* ebuf = b.second;
195 for (ebuf->rewind(); ebuf->is_valid(); ebuf->increment()) {
201 ebuf->get_event(&frames, &subframes, &type, &size, &data);
202 mbuf.push_back(frames, size, data);
208 // FIXME: make 'in' const
210 BufferSet::read_from (BufferSet& in, nframes_t nframes)
212 assert(available() >= in.count());
214 // Copy all buffers 1:1
215 for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
216 BufferSet::iterator o = begin(*t);
217 for (BufferSet::iterator i = in.begin(*t); i != in.end(*t); ++i, ++o) {
218 o->read_from (*i, nframes);
222 set_count(in.count());
225 } // namespace ARDOUR