Remove unused firstSampleNumber array

Author: jsiegle

Source/Processors/RecordNode/BinaryFormat/BinaryRecording.cpp

@@ -97,8 +97,6 @@ void BinaryRecording::openFiles (File rootFolder, int experimentNumber, int reco
 
         if (streamId != lastStreamId)
         {
-            wroteFirstSampleNumber[streamId] = false;
-
             firstChannels.add (channelInfo);
             streamIndex++;
 
@@ -112,9 +110,12 @@ void BinaryRecording::openFiles (File rootFolder, int experimentNumber, int reco
             singleStreamJSON.clear();
         }
 
+        LOGD ("Recording channel: ", channelInfo->getName(), " from stream ", streamId, " with global index ", globalIndex, " and local index ", indexWithinStream);
+
         m_fileIndexes.set (ch, streamIndex);
         m_channelIndexes.set (ch, indexWithinStream++);
 
+
         DynamicObject::Ptr singleChannelJSON = new DynamicObject();
 
         singleChannelJSON->setProperty ("channel_name", channelInfo->getName());
@@ -678,12 +679,6 @@ void BinaryRecording::writeContinuousData (int writeChannel,
 
         uint32 streamId = getContinuousChannel (realChannel)->getStreamId();
 
-        if (! wroteFirstSampleNumber[streamId])
-        {
-            firstSampleNumber[streamId] = baseSampleNumber;
-            wroteFirstSampleNumber[streamId] = true;
-        }
-
         /* Generate sequential sample numbers using SIMD-optimized fill */
         SIMDConverter::fillSequentialInt64 (reinterpret_cast<int64_t*> (m_sampleNumberBuffer.getData()), baseSampleNumber, size);
 
@@ -886,12 +881,6 @@ void BinaryRecording::writeContinuousDataBatch (const int* writeChannels,
             int64 baseSampleNumber = getLatestSampleNumber (writeChannels[i]);
             uint32 streamId = getContinuousChannel (realChannels[i])->getStreamId();
 
-            if (! wroteFirstSampleNumber[streamId])
-            {
-                firstSampleNumber[streamId] = baseSampleNumber;
-                wroteFirstSampleNumber[streamId] = true;
-            }
-
             /* Generate sequential sample numbers using SIMD-optimized fill */
             SIMDConverter::fillSequentialInt64 (reinterpret_cast<int64_t*> (m_sampleNumberBuffer.getData()), baseSampleNumber, numSamples);
 
@@ -913,13 +902,7 @@ void BinaryRecording::writeTimestampSyncText (uint64 streamId, int64 sampleNumbe
     String syncString = text + ": " + String (sampleNumber);
     LOGD (syncString);
 
-    int64 fsn = firstSampleNumber[streamId];
-
-    if (streamId > 0)
-        jassert (fsn == sampleNumber);
-
     m_syncTextFile->writeText (syncString + "\r\n", false, false, nullptr);
-    // Note: flush removed - file will be flushed on close or by OS buffering
 }
 
 RecordEngineManager* BinaryRecording::getEngineManager()

Source/Processors/RecordNode/BinaryFormat/BinaryRecording.h

@@ -141,9 +141,6 @@ class BinaryRecording : public RecordEngine
     int m_experimentNum;
     Array<int64> m_samplesWritten;
 
-    std::map<uint64, int64> firstSampleNumber;
-    std::map<uint64, bool> wroteFirstSampleNumber;
-
     const int samplesPerBlock { 8192 };  // Larger blocks reduce memory block operations
 };
 #endif

Source/Processors/RecordNode/RecordThread.cpp

@@ -354,7 +354,10 @@ void RecordThread::writeData (int minSamples,
         if (SystemEvent::getBaseType (event) == EventBase::Type::SYSTEM_EVENT)
         {
             String syncText = SystemEvent::getSyncText (event);
-            m_engine->writeTimestampSyncText (SystemEvent::getStreamId (event), SystemEvent::getSampleNumber (event), 0.0f, SystemEvent::getSyncText (event));
+            m_engine->writeTimestampSyncText (SystemEvent::getStreamId (event),
+                                              SystemEvent::getSampleNumber (event),
+                                              0.0f,
+                                              SystemEvent::getSyncText (event));
         }
         else
         {