Sleep while waiting for ADC buffer to fill

open-ephys-plugins · Sep 3, 2024 · 5c37c0d · 5c37c0d
1 parent 2e544b8
commit 5c37c0d
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/Source/Probes/OneBoxADC.cpp b/Source/Probes/OneBoxADC.cpp
@@ -218,6 +218,9 @@ void OneBoxADC::run()
 
     Neuropixels::PacketInfo packetInfo[MAXPACKETS];
 
+    int packetsAvailable;
+    int headroom;
+
     while (! threadShouldExit())
     {
         int count = MAXPACKETS;
@@ -267,5 +270,14 @@ void OneBoxADC::run()
         {
             LOGD ("readPackets error code: ", errorCode, " for ADCs");
         }
+
+        Neuropixels::ADC_getPacketFifoStatus (basestation->slot, &packetsAvailable, &headroom);
+
+        if (packetsAvailable < MAXPACKETS)
+        {
+            int uSecToWait = (MAXPACKETS - packetsAvailable) * 30;
+
+            std::this_thread::sleep_for (std::chrono::microseconds (uSecToWait));
+        }
     }
 }