Wait for non-empty buffers before starting recording

Eliminates zero-padding in continuous data files

Author: jsiegle

Source/Plugins/BinaryWriter/BinaryRecording.cpp

@@ -161,6 +161,8 @@ void BinaryRecording::openFiles(File rootFolder, int experimentNumber, int recor
 	Array<uint32> procIDs;
 	for (int i = 0; i < nChans; i++)
 	{
+		if (i == 0)
+			std::cout << "Start timestamp: " << getTimestamp(i) << std::endl;
 		m_startTS.add(getTimestamp(i));
 	}
 

Source/Plugins/BinaryWriter/SequentialBlockFile.cpp

@@ -99,6 +99,12 @@ bool SequentialBlockFile::writeChannel(uint64 startPos, int channel, int16* data
 		int samplesToWrite = jmin((nSamples - writtenSamples), (m_samplesPerBlock - startIdx));
 		for (int i = 0; i < samplesToWrite; i++)
 		{
+			//if (writtenSamples == 0 && *(data + dataIdx) == 0)
+			//{
+			//	std::cout << "Found a zero." << std::endl;
+			//	break;
+			//}
+
 			*(blockPtr + startMemPos + channel + i*m_nChannels) = *(data + dataIdx);
 			dataIdx++;
 		}

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 (true)
+    if (isRecording)
     {
 
             if ((*(event.getRawData()+0) & 0x80) == 0) // saving flag > 0 (i.e., event has not already been processed)
@@ -476,6 +476,8 @@ void RecordNode::process(AudioSampleBuffer& buffer)
 	// FIRST: cycle through events -- extract the TTLs and the timestamps
     checkForEvents();
 
+	bool noEmptyBuffers = true;
+
     if (isRecording)
     {
         // SECOND: write channel data
@@ -484,20 +486,33 @@ void RecordNode::process(AudioSampleBuffer& buffer)
 		{
 			int realChan = channelMap[chan];
 			int nSamples = getNumSamples(realChan);
-			int timestamp = getTimestamp(realChan);
-			m_dataQueue->writeChannel(buffer, chan, realChan, nSamples, timestamp);
+
+			if (nSamples == 0)
+				noEmptyBuffers = false;
 		}
 
-        //  std::cout << nSamples << " " << samplesWritten << " " << blockIndex << std::endl;
-		if (!setFirstBlock)
+		if (noEmptyBuffers || setFirstBlock)
 		{
-			m_recordThread->setFirstBlockFlag(true);
-			setFirstBlock = true;
+			for (int chan = 0; chan < recordChans; ++chan)
+			{
+				int realChan = channelMap[chan];
+				int nSamples = getNumSamples(realChan);
+				int timestamp = getTimestamp(realChan);
+				m_dataQueue->writeChannel(buffer, chan, realChan, nSamples, timestamp);
+			}
+			if (!setFirstBlock)
+			{
+
+				m_recordThread->setFirstBlockFlag(true);
+				setFirstBlock = true;
+			}
 		}
+
+        //  std::cout << nSamples << " " << samplesWritten << " " << blockIndex << std::endl;
+		
 
     }
 
-
 }
 
 void RecordNode::registerProcessor(const GenericProcessor* sourceNode)

Source/Processors/RecordNode/RecordThread.cpp

@@ -83,13 +83,14 @@ void RecordThread::run()
 		wait(1);
 	}
 
-	//2-Open Files
+	//2-Open Files 
 	if (!threadShouldExit())
 	{
 		m_cleanExit = false;
 		closeEarly = false;
 		Array<int64> timestamps;
 		m_dataQueue->getTimestampsForBlock(0, timestamps);
+
 		EVERY_ENGINE->updateTimestamps(timestamps);
 		EVERY_ENGINE->openFiles(m_rootFolder, m_experimentNumber, m_recordingNumber);
 	}