#include <pbd/xml++.h>
#include <pbd/pthread_utils.h>
+#include <pbd/basename.h>
#include <ardour/midi_source.h>
#include <ardour/midi_ring_buffer.h>
+#include <ardour/session.h>
+#include <ardour/session_directory.h>
+#include <ardour/source_factory.h>
#include "i18n.h"
MidiSource::MidiSource (Session& s, string name)
: Source (s, name, DataType::MIDI)
- , _model(new MidiModel())
- , _model_loaded (false)
+ , _timeline_position(0)
+ , _model(new MidiModel(this))
+ , _writing (false)
{
_read_data_count = 0;
_write_data_count = 0;
MidiSource::MidiSource (Session& s, const XMLNode& node)
: Source (s, node)
- , _model(new MidiModel())
- , _model_loaded (false)
+ , _timeline_position(0)
+ , _model(new MidiModel(this))
+ , _writing (false)
{
_read_data_count = 0;
_write_data_count = 0;
MidiSource::~MidiSource ()
{
- delete _model;
}
XMLNode&
}
nframes_t
-MidiSource::read (MidiRingBuffer& dst, nframes_t start, nframes_t cnt, nframes_t stamp_offset) const
+MidiSource::midi_read (MidiRingBuffer& dst, nframes_t start, nframes_t cnt, nframes_t stamp_offset, nframes_t negative_stamp_offset) const
{
Glib::Mutex::Lock lm (_lock);
- return read_unlocked (dst, start, cnt, stamp_offset);
+ if (_model) {
+ //const size_t n_events =
+ _model->read(dst, start, cnt, stamp_offset - negative_stamp_offset);
+ //cout << "Read " << n_events << " events from model." << endl;
+ return cnt;
+ } else {
+ return read_unlocked (dst, start, cnt, stamp_offset, negative_stamp_offset);
+ }
}
nframes_t
-MidiSource::write (MidiRingBuffer& dst, nframes_t cnt)
+MidiSource::midi_write (MidiRingBuffer& dst, nframes_t cnt)
{
Glib::Mutex::Lock lm (_lock);
return write_unlocked (dst, cnt);
return ( !e1 );
}
+void
+MidiSource::mark_streaming_midi_write_started (NoteMode mode, nframes_t start_frame)
+{
+ set_timeline_position(start_frame); // why do I have a feeling this can break somehow...
+
+ if (_model) {
+ _model->set_note_mode(mode);
+ _model->start_write();
+ }
+
+ _writing = true;
+}
+
+void
+MidiSource::mark_streaming_write_started ()
+{
+ if (_model)
+ _model->start_write();
+
+ _writing = true;
+}
+
+void
+MidiSource::mark_streaming_write_completed ()
+{
+ if (_model)
+ _model->end_write(false); // FIXME: param?
+
+ _writing = false;
+}
+
+void
+MidiSource::session_saved()
+{
+ flush_header();
+ flush_footer();
+
+ if (_model && _model->edited()) {
+ string newname;
+ const string basename = PBD::basename_nosuffix(_name);
+ string::size_type last_dash = basename.find_last_of("-");
+ if (last_dash == string::npos || last_dash == basename.find_first_of("-")) {
+ newname = basename + "-1";
+ } else {
+ stringstream ss(basename.substr(last_dash+1));
+ unsigned write_count = 0;
+ ss >> write_count;
+ cerr << "WRITE COUNT: " << write_count << endl;
+ ++write_count; // start at 1
+ ss.clear();
+ ss << basename.substr(0, last_dash) << "-" << write_count;
+ newname = ss.str();
+ }
+
+ string newpath = _session.session_directory().midi_path().to_string() +"/"+ newname + ".mid";
+
+ boost::shared_ptr<MidiSource> newsrc = boost::dynamic_pointer_cast<MidiSource>(
+ SourceFactory::createWritable(DataType::MIDI, _session, newpath, 1, 0, true));
+
+ newsrc->set_timeline_position(_timeline_position);
+ _model->write_to(newsrc);
+
+ // cyclic dependency here, ugly :(
+ newsrc->set_model(_model);
+ _model->set_midi_source(newsrc.get());
+
+ newsrc->flush_header();
+ newsrc->flush_footer();
+
+ Switched.emit(newsrc);
+ }
+}
+