1 files changed, 58 insertions, 0 deletions

diff --git a/src/midi_sequencer_impl.hpp b/src/midi_sequencer_impl.hpp
index 4dc3013..02a4156 100644
--- a/src/midi_sequencer_impl.hpp
+++ b/src/midi_sequencer_impl.hpp
@@ -315,6 +315,7 @@ BW_MidiSequencer::BW_MidiSequencer() :
 {
     m_loop.reset();
     m_loop.invalidLoop = false;
+    m_time.init();
 }
 
 BW_MidiSequencer::~BW_MidiSequencer()
@@ -342,9 +343,56 @@ void BW_MidiSequencer::setInterface(const BW_MidiRtInterface *intrf)
     //System Exclusive hook is REQUIRED
     assert(intrf->rt_systemExclusive);
 
+    if(intrf->pcmSampleRate != 0 && intrf->pcmFrameSize != 0)
+    {
+        m_time.sampleRate = intrf->pcmSampleRate;
+        m_time.frameSize = intrf->pcmFrameSize;
+        m_time.reset();
+    }
+
     m_interface = intrf;
 }
 
+int BW_MidiSequencer::playStream(uint8_t *stream, size_t length)
+{
+    int count = 0;
+    size_t samples = static_cast<size_t>(length / static_cast<size_t>(m_time.frameSize));
+    size_t left = samples;
+    size_t periodSize = 0;
+    uint8_t *stream_pos = stream;
+
+    assert(m_interface->onPcmRender);
+
+    while(left > 0)
+    {
+        const double leftDelay = left / double(m_time.sampleRate);
+        const double maxDelay = m_time.timeRest < leftDelay ? m_time.timeRest : leftDelay;
+        if((positionAtEnd()) && (m_time.delay <= 0.0))
+            break;//Stop to fetch samples at reaching the song end with disabled loop
+
+        m_time.timeRest -= maxDelay;
+        periodSize = static_cast<size_t>(static_cast<double>(m_time.sampleRate) * maxDelay);
+
+        if(stream)
+        {
+            size_t generateSize = periodSize > left ? static_cast<size_t>(left) : static_cast<size_t>(periodSize);
+            m_interface->onPcmRender(m_interface->onPcmRender_userData, stream_pos, generateSize * m_time.frameSize);
+            stream_pos += generateSize * m_time.frameSize;
+            count += generateSize;
+            left -= generateSize;
+            assert(left <= samples);
+        }
+
+        if(m_time.timeRest <= 0.0)
+        {
+            m_time.delay = Tick(m_time.delay, m_time.minDelay);
+            m_time.timeRest += m_time.delay;
+        }
+    }
+
+    return count * static_cast<int>(m_time.frameSize);
+}
+
 BW_MidiSequencer::FileFormat BW_MidiSequencer::getFormat()
 {
     return m_format;
@@ -449,6 +497,7 @@ void BW_MidiSequencer::buildSmfSetupReset(size_t trackCount)
 
     m_loop.reset();
     m_loop.invalidLoop = false;
+    m_time.reset();
 
     m_currentPosition.began = false;
     m_currentPosition.absTimePosition = 0.0;
@@ -1265,12 +1314,14 @@ BW_MidiSequencer::MidiEvent BW_MidiSequencer::parseEvent(const uint8_t **pptr, c
             if(m_musCopyright.empty())
             {
                 m_musCopyright = std::string((const char *)evt.data.data(), evt.data.size());
+                m_musCopyright.push_back('\0'); /* ending fix for UTF16 strings */
                 if(m_interface->onDebugMessage)
                     m_interface->onDebugMessage(m_interface->onDebugMessage_userData, "Music copyright: %s", m_musCopyright.c_str());
             }
             else if(m_interface->onDebugMessage)
             {
                 std::string str((const char *)evt.data.data(), evt.data.size());
+                str.push_back('\0'); /* ending fix for UTF16 strings */
                 m_interface->onDebugMessage(m_interface->onDebugMessage_userData, "Extra copyright event: %s", str.c_str());
             }
         }
@@ -1279,12 +1330,14 @@ BW_MidiSequencer::MidiEvent BW_MidiSequencer::parseEvent(const uint8_t **pptr, c
             if(m_musTitle.empty())
             {
                 m_musTitle = std::string((const char *)evt.data.data(), evt.data.size());
+                m_musTitle.push_back('\0'); /* ending fix for UTF16 strings */
                 if(m_interface->onDebugMessage)
                     m_interface->onDebugMessage(m_interface->onDebugMessage_userData, "Music title: %s", m_musTitle.c_str());
             }
             else
             {
                 std::string str((const char *)evt.data.data(), evt.data.size());
+                str.push_back('\0'); /* ending fix for UTF16 strings */
                 m_musTrackTitles.push_back(str);
                 if(m_interface->onDebugMessage)
                     m_interface->onDebugMessage(m_interface->onDebugMessage_userData, "Track title: %s", str.c_str());
@@ -1295,6 +1348,7 @@ BW_MidiSequencer::MidiEvent BW_MidiSequencer::parseEvent(const uint8_t **pptr, c
             if(m_interface->onDebugMessage)
             {
                 std::string str((const char *)evt.data.data(), evt.data.size());
+                str.push_back('\0'); /* ending fix for UTF16 strings */
                 m_interface->onDebugMessage(m_interface->onDebugMessage_userData, "Instrument: %s", str.c_str());
             }
         }
@@ -1889,6 +1943,9 @@ double BW_MidiSequencer::seek(double seconds, const double granularity)
     if(m_currentPosition.wait < 0.0)
         m_currentPosition.wait = 0.0;
 
+    m_time.reset();
+    m_time.delay = m_currentPosition.wait;
+
     m_loopEnabled = loopFlagState;
     return m_currentPosition.wait;
 }
@@ -1920,6 +1977,7 @@ void BW_MidiSequencer::rewind()
 
     m_loop.reset();
     m_loop.caughtStart  = true;
+    m_time.reset();
 }
 
 void BW_MidiSequencer::setTempo(double tempo)