2 Copyright (C) 2006 Paul Davis
3 Written by Dave Robillard, 2006
5 This program is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation; either version 2 of the License, or
8 (at your option) any later version.
10 This program is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 GNU General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with this program; if not, write to the Free Software
17 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
28 #include <pbd/mountpoint.h>
29 #include <pbd/pathscanner.h>
30 #include <pbd/stl_delete.h>
31 #include <pbd/strsplit.h>
33 #include <glibmm/miscutils.h>
35 #include <evoral/SMFReader.hpp>
36 #include <evoral/Control.hpp>
38 #include <ardour/audioengine.h>
39 #include <ardour/event_type_map.h>
40 #include <ardour/midi_model.h>
41 #include <ardour/midi_ring_buffer.h>
42 #include <ardour/session.h>
43 #include <ardour/smf_source.h>
44 #include <ardour/tempo.h>
48 using namespace ARDOUR;
50 string SMFSource::_search_path;
52 /** Constructor used for new internal-to-session files. File cannot exist. */
53 SMFSource::SMFSource(Session& s, std::string path, Flag flags)
54 : MidiSource(s, region_name_from_path(path, false))
57 , _allow_remove_if_empty(true)
58 , _last_ev_time_beats(0.0)
59 , _last_ev_time_frames(0)
61 if (init(path, false)) {
62 throw failed_constructor ();
66 throw failed_constructor ();
69 assert(_name.find("/") == string::npos);
72 /** Constructor used for existing internal-to-session files. File must exist. */
73 SMFSource::SMFSource(Session& s, const XMLNode& node)
75 , _flags(Flag(Writable|CanRename))
76 , _allow_remove_if_empty(true)
77 , _last_ev_time_beats(0.0)
78 , _last_ev_time_frames(0)
80 if (set_state(node)) {
81 throw failed_constructor ();
84 if (init(_name, true)) {
85 throw failed_constructor ();
89 throw failed_constructor ();
92 assert(_name.find("/") == string::npos);
95 SMFSource::~SMFSource ()
98 unlink (_path.c_str());
103 SMFSource::removable () const
105 return (_flags & Removable) && ((_flags & RemoveAtDestroy) ||
106 ((_flags & RemovableIfEmpty) && is_empty()));
110 SMFSource::init (string pathstr, bool must_exist)
114 if (!find (pathstr, must_exist, is_new)) {
115 cerr << "cannot find " << pathstr << " with me = " << must_exist << endl;
119 if (is_new && must_exist) {
123 assert(_name.find("/") == string::npos);
127 /** All stamps in audio frames */
129 SMFSource::read_unlocked (MidiRingBuffer<nframes_t>& dst, nframes_t start, nframes_t dur,
130 nframes_t stamp_offset, nframes_t negative_stamp_offset) const
132 //cerr << "SMF read_unlocked " << name() << " read "
133 //<< start << ", count=" << dur << ", offset=" << stamp_offset << endl;
136 uint64_t time = 0; // in SMF ticks, 1 tick per _ppqn
138 _read_data_count = 0;
140 // Output parameters for read_event (which will allocate scratch in buffer as needed)
141 uint32_t ev_delta_t = 0;
142 uint32_t ev_type = 0;
143 uint32_t ev_size = 0;
144 uint8_t* ev_buffer = 0;
146 size_t scratch_size = 0; // keep track of scratch to minimize reallocs
148 // FIXME: assumes tempo never changes after start
149 const Tempo& tempo = _session.tempo_map().tempo_at(_timeline_position);
150 const double frames_per_beat = tempo.frames_per_beat(
151 _session.engine().frame_rate(),
152 _session.tempo_map().meter_at(_timeline_position));
154 const uint64_t start_ticks = (uint64_t)((start / frames_per_beat) * ppqn());
156 if (_last_read_end == 0 || start != _last_read_end) {
157 cerr << "SMFSource::read_unlocked seeking to " << start << endl;
158 Evoral::SMF::seek_to_start();
159 while (time < start_ticks) {
160 ret = read_event(&ev_delta_t, &ev_size, &ev_buffer);
161 if (ret == -1) { // EOF
162 _last_read_end = start + dur;
165 time += ev_delta_t; // accumulate delta time
169 _last_read_end = start + dur;
172 ret = read_event(&ev_delta_t, &ev_size, &ev_buffer);
173 if (ret == -1) { // EOF
177 time += ev_delta_t; // accumulate delta time
179 if (ret == 0) { // meta-event (skipped, just accumulate time)
183 ev_type = EventTypeMap::instance().midi_event_type(ev_buffer[0]);
185 assert(time >= start_ticks);
186 const nframes_t ev_frame_time = (nframes_t)(
187 ((time / (double)ppqn()) * frames_per_beat)) + stamp_offset;
189 if (ev_frame_time < start + dur) {
190 dst.write(ev_frame_time - negative_stamp_offset, ev_type, ev_size, ev_buffer);
195 _read_data_count += ev_size;
197 if (ev_size > scratch_size) {
198 scratch_size = ev_size;
200 ev_size = scratch_size; // ensure read_event only allocates if necessary
206 /** All stamps in audio frames */
208 SMFSource::write_unlocked (MidiRingBuffer<nframes_t>& src, nframes_t dur)
210 _write_data_count = 0;
213 Evoral::EventType type;
216 size_t buf_capacity = 4;
217 uint8_t* buf = (uint8_t*)malloc(buf_capacity);
219 if (_model && ! _model->writing()) {
220 _model->start_write();
223 Evoral::MIDIEvent<nframes_t> ev(0, 0.0, 4, NULL, true);
226 bool ret = src.peek_time(&time);
227 if (!ret || time - _timeline_position > _length + dur) {
231 ret = src.read_prefix(&time, &type, &size);
236 if (size > buf_capacity) {
238 buf = (uint8_t*)realloc(buf, size);
241 ret = src.read_contents(size, buf);
243 cerr << "ERROR: Read time/size but not buffer, corrupt MIDI ring buffer" << endl;
247 assert(time >= _timeline_position);
248 time -= _timeline_position;
250 ev.set(buf, size, time);
251 ev.set_event_type(EventTypeMap::instance().midi_event_type(ev.buffer()[0]));
252 if (!(ev.is_channel_event() || ev.is_smf_meta_event() || ev.is_sysex())) {
253 cerr << "SMFSource: WARNING: caller tried to write non SMF-Event of type "
254 << std::hex << int(ev.buffer()[0]) << endl;
258 append_event_unlocked_frames(ev);
262 set_default_controls_interpolation();
265 Evoral::SMF::flush();
268 const nframes_t oldlen = _length;
269 update_length(oldlen, dur);
271 ViewDataRangeReady(_timeline_position + oldlen, dur); /* EMIT SIGNAL */
277 /** Append an event with a timestamp in beats (double) */
279 SMFSource::append_event_unlocked_beats(const Evoral::Event<double>& ev)
281 if (ev.size() == 0) {
285 /*printf("SMFSource: %s - append_event_unlocked_beats time = %lf, size = %u, data = ",
286 name().c_str(), ev.time(), ev.size());
287 for (size_t i = 0; i < ev.size(); ++i) printf("%X ", ev.buffer()[i]); printf("\n");*/
289 assert(ev.time() >= 0);
290 if (ev.time() < _last_ev_time_beats) {
291 cerr << "SMFSource: Warning: Skipping event with non-monotonic time" << endl;
295 const double delta_time_beats = ev.time() - _last_ev_time_beats;
296 const uint32_t delta_time_ticks = (uint32_t)lrint(delta_time_beats * (double)ppqn());
298 Evoral::SMF::append_event_delta(delta_time_ticks, ev.size(), ev.buffer());
299 _last_ev_time_beats = ev.time();
301 _write_data_count += ev.size();
308 /** Append an event with a timestamp in frames (nframes_t) */
310 SMFSource::append_event_unlocked_frames(const Evoral::Event<nframes_t>& ev)
312 if (ev.size() == 0) {
316 /*printf("SMFSource: %s - append_event_unlocked_frames time = %u, size = %u, data = ",
317 name().c_str(), ev.time(), ev.size());
318 for (size_t i=0; i < ev.size(); ++i) printf("%X ", ev.buffer()[i]); printf("\n");*/
320 assert(ev.time() >= 0);
321 if (ev.time() < _last_ev_time_frames) {
322 cerr << "SMFSource: Warning: Skipping event with non-monotonic time" << endl;
326 // FIXME: assumes tempo never changes after start
327 const Tempo& tempo = _session.tempo_map().tempo_at(_timeline_position);
328 const double frames_per_beat = tempo.frames_per_beat(
329 _session.engine().frame_rate(),
330 _session.tempo_map().meter_at(_timeline_position));
332 uint32_t delta_time = (uint32_t)((ev.time() - _last_ev_time_frames)
333 / frames_per_beat * (double)ppqn());
335 Evoral::SMF::append_event_delta(delta_time, ev.size(), ev.buffer());
336 _last_ev_time_frames = ev.time();
338 _write_data_count += ev.size();
341 double beat_time = ev.time() / frames_per_beat;
342 const Evoral::Event<double> beat_ev(
343 ev.event_type(), beat_time, ev.size(), (uint8_t*)ev.buffer());
344 _model->append(beat_ev);
350 SMFSource::get_state ()
352 XMLNode& root (MidiSource::get_state());
354 snprintf (buf, sizeof (buf), "0x%x", (int)_flags);
355 root.add_property ("flags", buf);
360 SMFSource::set_state (const XMLNode& node)
362 const XMLProperty* prop;
364 if (MidiSource::set_state (node)) {
368 if ((prop = node.property (X_("flags"))) != 0) {
370 sscanf (prop->value().c_str(), "0x%x", &ival);
371 _flags = Flag (ival);
376 assert(_name.find("/") == string::npos);
382 SMFSource::mark_for_remove ()
387 _flags = Flag (_flags | RemoveAtDestroy);
391 SMFSource::mark_streaming_midi_write_started (NoteMode mode, nframes_t start_frame)
393 MidiSource::mark_streaming_midi_write_started (mode, start_frame);
394 Evoral::SMF::begin_write ();
395 _last_ev_time_beats = 0.0;
396 _last_ev_time_frames = 0;
400 SMFSource::mark_streaming_write_completed ()
402 MidiSource::mark_streaming_write_completed();
408 _model->set_edited(false);
409 Evoral::SMF::end_write ();
413 SMFSource::mark_take (string id)
421 SMFSource::move_to_trash (const string trash_dir_name)
427 /* don't move the file across filesystems, just stick it in the
428 trash_dir_name directory on whichever filesystem it was already on
431 Glib::ustring newpath;
432 newpath = Glib::path_get_dirname (_path);
433 newpath = Glib::path_get_dirname (newpath);
435 newpath += string("/") + trash_dir_name + "/";
436 newpath += Glib::path_get_basename (_path);
438 /* the new path already exists, try versioning */
439 if (access (newpath.c_str(), F_OK) == 0) {
440 char buf[PATH_MAX+1];
444 snprintf (buf, sizeof (buf), "%s.%d", newpath.c_str(), version);
447 while (access (newpath_v.c_str(), F_OK) == 0 && version < 999) {
448 snprintf (buf, sizeof (buf), "%s.%d", newpath.c_str(), ++version);
452 if (version == 999) {
453 PBD::error << string_compose (
454 _("there are already 1000 files with names like %1; versioning discontinued"),
461 if (::rename (_path.c_str(), newpath.c_str()) != 0) {
462 PBD::error << string_compose (
463 _("cannot rename midi file source from %1 to %2 (%3)"),
464 _path, newpath, strerror (errno)) << endmsg;
470 /* file can not be removed twice, since the operation is not idempotent */
471 _flags = Flag (_flags & ~(RemoveAtDestroy|Removable|RemovableIfEmpty));
477 SMFSource::safe_file_extension(const Glib::ustring& file)
479 return (file.rfind(".mid") != Glib::ustring::npos);
482 // FIXME: Merge this with audiofilesource somehow (make a generic filesource?)
484 SMFSource::find (string pathstr, bool must_exist, bool& isnew)
490 if (pathstr[0] != '/') {
492 /* non-absolute pathname: find pathstr in search path */
499 if (_search_path.length() == 0) {
500 PBD::error << _("FileSource: search path not set") << endmsg;
504 split (_search_path, dirs, ':');
508 for (vector<string>::iterator i = dirs.begin(); i != dirs.end(); ++i) {
510 if (fullpath[fullpath.length()-1] != '/') {
515 if (access (fullpath.c_str(), R_OK) == 0) {
523 PBD::error << string_compose (_("FileSource: \"%1\" is ambigous when searching %2\n\t"), pathstr, _search_path) << endmsg;
526 } else if (cnt == 0) {
529 PBD::error << string_compose(_("Filesource: cannot find required file (%1): while searching %2"), pathstr, _search_path) << endmsg;
542 /* external files and/or very very old style sessions include full paths */
545 _name = pathstr.substr (pathstr.find_last_of ('/') + 1);
547 if (access (_path.c_str(), R_OK) != 0) {
549 /* file does not exist or we cannot read it */
552 PBD::error << string_compose(_("Filesource: cannot find required file (%1): %2"), _path, strerror (errno)) << endmsg;
556 if (errno != ENOENT) {
557 PBD::error << string_compose(_("Filesource: cannot check for existing file (%1): %2"), _path, strerror (errno)) << endmsg;
579 SMFSource::set_search_path (string p)
586 SMFSource::set_allow_remove_if_empty (bool yn)
589 _allow_remove_if_empty = yn;
594 SMFSource::set_source_name (string newname, bool destructive)
596 //Glib::Mutex::Lock lm (_lock); FIXME
597 string oldpath = _path;
598 string newpath = Session::change_midi_path_by_name (oldpath, _name, newname, destructive);
600 if (newpath.empty()) {
601 PBD::error << string_compose (_("programming error: %1"), "cannot generate a changed midi path") << endmsg;
605 if (rename (oldpath.c_str(), newpath.c_str()) != 0) {
606 PBD::error << string_compose (_("cannot rename midi file for %1 to %2"), _name, newpath) << endmsg;
610 _name = Glib::path_get_basename (newpath);
617 SMFSource::load_model(bool lock, bool force_reload)
624 Glib::Mutex::Lock lm (_lock);
627 if (_model && !force_reload) {
632 _model = boost::shared_ptr<MidiModel>(new MidiModel(this));
633 cerr << _name << " loaded new model " << _model.get() << endl;
635 cerr << _name << " reloading model " << _model.get()
636 << " (" << _model->n_notes() << " notes)" <<endl;
640 _model->start_write();
641 Evoral::SMF::seek_to_start();
643 uint64_t time = 0; /* in SMF ticks */
644 Evoral::Event<double> ev;
646 size_t scratch_size = 0; // keep track of scratch and minimize reallocs
648 uint32_t delta_t = 0;
652 while ((ret = read_event(&delta_t, &size, &buf)) >= 0) {
654 ev.set(buf, size, time / (double)ppqn());
656 if (ret > 0) { // didn't skip (meta) event
657 ev.set_event_type(EventTypeMap::instance().midi_event_type(buf[0]));
661 if (ev.size() > scratch_size) {
662 scratch_size = ev.size();
664 ev.size() = scratch_size; // ensure read_event only allocates if necessary
667 set_default_controls_interpolation();
669 _model->end_write(false);
670 _model->set_edited(false);
672 _model_iter = _model->begin();
677 #define LINEAR_INTERPOLATION_MODE_WORKS_PROPERLY 0
680 SMFSource::set_default_controls_interpolation()
682 // set interpolation style to defaults, can be changed by the GUI later
683 Evoral::ControlSet::Controls controls = _model->controls();
684 for (Evoral::ControlSet::Controls::iterator c = controls.begin(); c != controls.end(); ++c) {
685 (*c).second->list()->set_interpolation(
686 // to be enabled when ControlList::rt_safe_earliest_event_linear_unlocked works properly
687 #if LINEAR_INTERPOLATION_MODE_WORKS_PROPERLY
688 EventTypeMap::instance().interpolation_of((*c).first));
690 Evoral::ControlList::Discrete);
697 SMFSource::destroy_model()
699 //cerr << _name << " destroying model " << _model.get() << endl;
704 SMFSource::flush_midi()
706 Evoral::SMF::end_write();