Replace a bunch of potential crashes with graceful handling of the situation.
[ardour.git] / libs / ardour / midi_port.cc
index 5f18810122e713b84a490116fc3aa033324f0eaa..cc72eabba49ed67f6e9d03ef198882da8dd0ef4a 100644 (file)
@@ -21,6 +21,7 @@
 
 #include "ardour/midi_port.h"
 #include "ardour/data_type.h"
+#include "ardour/audioengine.h"
 
 using namespace ARDOUR;
 using namespace std;
@@ -28,9 +29,10 @@ using namespace std;
 MidiPort::MidiPort (const std::string& name, Flags flags)
        : Port (name, DataType::MIDI, flags)
        , _has_been_mixed_down (false)
-       , _resolve_in_process (false)
+       , _resolve_required (false)
+       , _input_active (true)
 {
-       _buffer = new MidiBuffer (raw_buffer_size(0));
+       _buffer = new MidiBuffer (AudioEngine::instance()->raw_buffer_size (DataType::MIDI));
 }
 
 MidiPort::~MidiPort()
@@ -41,8 +43,9 @@ MidiPort::~MidiPort()
 void
 MidiPort::cycle_start (pframes_t nframes)
 {
+       Port::cycle_start (nframes);
+
        _buffer->clear ();
-       assert (_buffer->size () == 0);
 
        if (sends_output ()) {
                jack_midi_clear_buffer (jack_port_get_buffer (_jack_port, nframes));
@@ -50,7 +53,7 @@ MidiPort::cycle_start (pframes_t nframes)
 }
 
 MidiBuffer &
-MidiPort::get_midi_buffer (framecnt_t nframes, framecnt_t offset)
+MidiPort::get_midi_buffer (pframes_t nframes)
 {
        if (_has_been_mixed_down) {
                return *_buffer;
@@ -58,35 +61,40 @@ MidiPort::get_midi_buffer (framecnt_t nframes, framecnt_t offset)
 
        if (receives_input ()) {
 
-               void* jack_buffer = jack_port_get_buffer (_jack_port, nframes);
-               const pframes_t event_count = jack_midi_get_event_count(jack_buffer);
-
-               assert (event_count < _buffer->capacity());
-
-               /* suck all relevant MIDI events from the JACK MIDI port buffer
-                  into our MidiBuffer
-               */
-
-               for (pframes_t i = 0; i < event_count; ++i) {
-
-                       jack_midi_event_t ev;
-
-                       jack_midi_event_get (&ev, jack_buffer, i);
-
-                        if (ev.buffer[0] == 0xfe) {
-                                /* throw away active sensing */
-                                continue;
-                        }
-
-                       if (ev.time >= offset && ev.time < (offset + nframes)) {
-                               _buffer->push_back (ev);
-                       } else {
-                               cerr << "Dropping incoming MIDI at time " << ev.time << "; offset=" << offset << " limit=" << (offset + nframes) << "\n";
-                       }
-               }
-
-               if (nframes) {
-                       _has_been_mixed_down = true;
+               if (_input_active) {
+
+                       void* jack_buffer = jack_port_get_buffer (_jack_port, nframes);
+                       const pframes_t event_count = jack_midi_get_event_count (jack_buffer);
+                       
+                       /* suck all relevant MIDI events from the JACK MIDI port buffer
+                          into our MidiBuffer
+                       */
+                       
+                       for (pframes_t i = 0; i < event_count; ++i) {
+                               
+                               jack_midi_event_t ev;
+                               
+                               jack_midi_event_get (&ev, jack_buffer, i);
+                               
+                               if (ev.buffer[0] == 0xfe) {
+                                       /* throw away active sensing */
+                                       continue;
+                               }
+                               
+                               /* check that the event is in the acceptable time range */
+                               
+                               if ((ev.time >= (_global_port_buffer_offset + _port_buffer_offset)) &&
+                                   (ev.time < (_global_port_buffer_offset + _port_buffer_offset + nframes))) {
+                                       _buffer->push_back (ev);
+                               } else {
+                                       cerr << "Dropping incoming MIDI at time " << ev.time << "; offset="
+                                            << _global_port_buffer_offset << " limit="
+                                            << (_global_port_buffer_offset + _port_buffer_offset + nframes) << "\n";
+                               }
+                       } 
+
+               } else {
+                       _buffer->silence (nframes);
                }
 
        } else {
@@ -114,51 +122,91 @@ MidiPort::cycle_split ()
 }
 
 void
-MidiPort::flush_buffers (pframes_t nframes, framepos_t time, framecnt_t offset)
+MidiPort::resolve_notes (void* jack_buffer, MidiBuffer::TimeType when)
 {
-       if (sends_output ()) {
+       for (uint8_t channel = 0; channel <= 0xF; channel++) {
 
-               void* jack_buffer = jack_port_get_buffer (_jack_port, nframes);
+               uint8_t ev[3] = { ((uint8_t) (MIDI_CMD_CONTROL | channel)), MIDI_CTL_SUSTAIN, 0 };
+
+               /* we need to send all notes off AND turn the
+                * sustain/damper pedal off to handle synths
+                * that prioritize sustain over AllNotesOff
+                */
 
-               // Feed the data through the MidiStateTracker
-               bool did_loop;
+               if (jack_midi_event_write (jack_buffer, when, ev, 3) != 0) {
+                       cerr << "failed to deliver sustain-zero on channel " << channel << " on port " << name() << endl;
+               }
 
-               _midi_state_tracker.track (_buffer->begin(), _buffer->end(), did_loop);
+               ev[1] = MIDI_CTL_ALL_NOTES_OFF;
 
-               if (did_loop || _resolve_in_process) {
-                       /* add necessary note offs */
-                       _midi_state_tracker.resolve_notes (*_buffer, time);
+               if (jack_midi_event_write (jack_buffer, 0, ev, 3) != 0) {
+                       cerr << "failed to deliver ALL NOTES OFF on channel " << channel << " on port " << name() << endl;
                }
+       }
+}
+
+void
+MidiPort::flush_buffers (pframes_t nframes)
+{
+       if (sends_output ()) {
+
+               void* jack_buffer = jack_port_get_buffer (_jack_port, nframes);
 
-               _resolve_in_process = false;
+               if (_resolve_required) {
+                       /* resolve all notes at the start of the buffer */
+                       resolve_notes (jack_buffer, 0);
+                       _resolve_required = false;
+               }
 
                for (MidiBuffer::iterator i = _buffer->begin(); i != _buffer->end(); ++i) {
-                       const Evoral::Event<framepos_t>& ev = *i;
+
+                       const Evoral::MIDIEvent<MidiBuffer::TimeType> ev (*i, false);
 
                        // event times are in frames, relative to cycle start
 
-                       assert (ev.time() < (nframes + offset));
+                       assert (ev.time() < (nframes + _global_port_buffer_offset + _port_buffer_offset));
 
-                       if (ev.time() >= offset) {
+                       if (ev.time() >= _global_port_buffer_offset + _port_buffer_offset) {
                                if (jack_midi_event_write (jack_buffer, (jack_nframes_t) ev.time(), ev.buffer(), ev.size()) != 0) {
-                                        cerr << "write failed, drop flushed note off on the floor, time " << ev.time() << " > " << offset << endl;
-                                }
-                        } else {
-                                cerr << "drop flushed event on the floor, time " << ev.time() << " < " << offset << endl;
-                        }
+                                       cerr << "write failed, drop flushed note off on the floor, time "
+                                            << ev.time() << " > " << _global_port_buffer_offset + _port_buffer_offset << endl;
+                               }
+                       } else {
+                               cerr << "drop flushed event on the floor, time " << ev
+                                    << " to early for " << _global_port_buffer_offset + _port_buffer_offset << endl;
+                       }
                }
        }
 }
 
+void
+MidiPort::require_resolve ()
+{
+       _resolve_required = true;
+}
+
 void
 MidiPort::transport_stopped ()
 {
-       _resolve_in_process = true;
+       _resolve_required = true;
+}
+
+void
+MidiPort::realtime_locate ()
+{
+       _resolve_required = true;
 }
 
-size_t
-MidiPort::raw_buffer_size (pframes_t nframes) const
+void
+MidiPort::reset ()
 {
-       return jack_midi_max_event_size (jack_port_get_buffer (_jack_port, nframes));
+       Port::reset ();
+       delete _buffer;
+       _buffer = new MidiBuffer (AudioEngine::instance()->raw_buffer_size (DataType::MIDI));
 }
 
+void
+MidiPort::set_input_active (bool yn)
+{
+       _input_active = yn;
+}