Fix timestamp error when DataBuffer is empty

DataBuffer needs to keep a copy of the last timestamp, in case it's
empty when a reading occurs.

Author: jsiegle

Source/Processors/DataThreads/DataBuffer.h

@@ -72,6 +72,8 @@ class PLUGIN_API DataBuffer
     HeapBlock<int64> timestampBuffer;
     HeapBlock<uint64> eventCodeBuffer;
 
+	int64 lastTimestamp;
+
     int numChans;
 
     JUCE_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR (DataBuffer);

Source/Processors/RecordNode/RecordNode.cpp

@@ -448,7 +448,7 @@ float RecordNode::getFreeSpace() const
 
 void RecordNode::handleEvent(const EventChannel* eventInfo, const MidiMessage& event, int samplePosition)
 {
-    if (isRecording)
+    if (true)
     {
 
             if ((*(event.getRawData()+0) & 0x80) == 0) // saving flag > 0 (i.e., event has not already been processed)
@@ -459,7 +459,8 @@ void RecordNode::handleEvent(const EventChannel* eventInfo, const MidiMessage& e
 					eventIndex = getEventChannelIndex(Event::getSourceIndex(event), Event::getSourceID(event), Event::getSubProcessorIdx(event));
 				else
 					eventIndex = -1;
-				m_eventQueue->addEvent(event, timestamp, eventIndex);
+				if (isRecording)
+					m_eventQueue->addEvent(event, timestamp, eventIndex);
             }
     }
 }

Source/Processors/RecordNode/RecordThread.cpp

@@ -80,7 +80,7 @@ void RecordThread::run()
 	//1-Wait until the first block has arrived, so we can align the timestamps
 	while (!m_receivedFirstBlock && !threadShouldExit())
 	{
-		wait(100);
+		wait(1);
 	}
 
 	//2-Open Files
@@ -145,7 +145,7 @@ void RecordThread::writeData(const AudioSampleBuffer& dataBuffer, int maxSamples
 			uint16 sourceID = SystemEvent::getSourceID(event);
 			uint16 subProcIdx = SystemEvent::getSubProcessorIdx(event);
 			int64 timestamp = SystemEvent::getTimestamp(event);
-			EVERY_ENGINE->writeTimestampSyncText(sourceID, subProcIdx, timestamp,
+				EVERY_ENGINE->writeTimestampSyncText(sourceID, subProcIdx, timestamp,
 				AccessClass::getProcessorGraph()->getRecordNode()->getSourceTimestamp(sourceID, subProcIdx),
 				SystemEvent::getSyncText(event));
 		}

Source/Processors/SourceNode/SourceNode.cpp

@@ -356,13 +356,15 @@ void SourceNode::process(AudioSampleBuffer& buffer)
 {
 	int nSubs = dataThread->getNumSubProcessors();
 	int copiedChannels = 0;
+
 	for (int sub = 0; sub < nSubs; sub++)
 	{
 		int channelsToCopy = getNumOutputs(sub);
+		
 		int nSamples = inputBuffers[sub]->readAllFromBuffer(buffer, &timestamp, static_cast<uint64*>(eventCodeBuffers[sub]->getData()), buffer.getNumSamples(), copiedChannels, channelsToCopy);
 		copiedChannels += channelsToCopy;
 
-		setTimestampAndSamples(timestamp, nSamples, sub);
+		setTimestampAndSamples(timestamp, nSamples, sub); 
 
 		if (ttlChannels[sub])
 		{