X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=libs%2Fardour%2Fasync_midi_port.cc;h=bbcc0aab85e7e086d9a081e6d062e15df18bda2a;hb=5b40e073e9c973479c3d286a007c57e1e0fa3d0f;hp=3dfb5610d9958153363fb219b0b392d5f88737f7;hpb=f74eab854a2cafab82dae17ae04e5ea5945016bd;p=ardour.git

diff --git a/libs/ardour/async_midi_port.cc b/libs/ardour/async_midi_port.cc
index 3dfb5610d9..bbcc0aab85 100644
--- a/libs/ardour/async_midi_port.cc
+++ b/libs/ardour/async_midi_port.cc
@@ -168,7 +168,7 @@ AsyncMIDIPort::cycle_end (MIDI::pframes_t nframes)
  * Cannot be called from a processing thread.
  */
 void
-AsyncMIDIPort::drain (int check_interval_usecs)
+AsyncMIDIPort::drain (int check_interval_usecs, int total_usecs_to_wait)
 {
 	RingBuffer< Evoral::Event<double> >::rw_vector vec = { { 0, 0 }, { 0, 0} };
 
@@ -183,12 +183,16 @@ AsyncMIDIPort::drain (int check_interval_usecs)
 		return;
 	}
 
-	while (1) {
+	microseconds_t now = get_microseconds ();
+	microseconds_t end = now + total_usecs_to_wait;
+
+	while (now < end) {
 		output_fifo.get_write_vector (&vec);
 		if (vec.len[0] + vec.len[1] >= output_fifo.bufsize() - 1) {
 			break;
 		}
 		Glib::usleep (check_interval_usecs);
+		now = get_microseconds();
 	}
 }