Use actual_time to encode allow_belated argument

Author: mgeier

examples/bleeperoo.py

@@ -90,7 +90,6 @@
 max_delay = -np.inf
 for action in actionlist:
     assert action.type == rtmixer.PLAY_BUFFER
-    # NB: action.allow_belated might have been invalidated
     assert action.requested_time != 0
     if not action.actual_time:
         belated += 1

src/rtmixer.c

@@ -160,7 +160,7 @@ int callback(const void* input, void* output, frame_t frameCount
 
           // Due to inaccuracies in timeInfo, "diff" might have a small negative
           // value in a future block.  We don't count this as "belated" though:
-          action->allow_belated = true;
+          action->actual_time = -1.0;
           actionaddr = &(action->next);
           continue;
         }
@@ -170,9 +170,9 @@ int callback(const void* input, void* output, frame_t frameCount
       else
       {
         // We are too late!
-        if (!action->allow_belated)
+        if (action->actual_time == 0.0)
         {
-          action->actual_time = 0.0;  // a.k.a. "false"
+          // allow_belated == False
           remove_action(actionaddr, state);
           continue;
         }
@@ -213,8 +213,10 @@ int callback(const void* input, void* output, frame_t frameCount
             }
             else
             {
-              if (!delinquent->allow_belated)
+              if (delinquent->actual_time == 0.0)
               {
+                // allow_belated == False
+
                 // TODO: save some status information?
                 break;  // The action will not be started, no need to cancel it
               }

src/rtmixer.h

@@ -34,9 +34,8 @@ struct stats
 struct action
 {
   const enum actiontype type;
-  bool allow_belated;  // NB: Might be invalidated in the callback function!
   const PaTime requested_time;
-  PaTime actual_time;
+  PaTime actual_time;  // Set != 0.0 to allow belated actions
   struct action* next;  // Used to create singly linked list of actions
   union {
     float* const buffer;

src/rtmixer.py

@@ -72,7 +72,7 @@ def cancel(self, action, time=0, allow_belated=True):
         """
         cancel_action = _ffi.new('struct action*', dict(
             type=CANCEL,
-            allow_belated=allow_belated,
+            actual_time=-1.0 if allow_belated else 0.0,
             requested_time=time,
             action=action,
         ))
@@ -88,7 +88,7 @@ def fetch_and_reset_stats(self, time=0, allow_belated=True):
         """
         action = _ffi.new('struct action*', dict(
             type=FETCH_AND_RESET_STATS,
-            allow_belated=allow_belated,
+            actual_time=-1.0 if allow_belated else 0.0,
             requested_time=time,
         ))
         self._enqueue(action)
@@ -173,7 +173,7 @@ def play_buffer(self, buffer, channels, start=0, allow_belated=True):
         _, samplesize = _sd._split(self.samplesize)
         action = _ffi.new('struct action*', dict(
             type=PLAY_BUFFER,
-            allow_belated=allow_belated,
+            actual_time=-1.0 if allow_belated else 0.0,
             requested_time=start,
             buffer=_ffi.cast('float*', buffer),
             total_frames=len(buffer) // channels // samplesize,
@@ -199,7 +199,7 @@ def play_ringbuffer(self, ringbuffer, channels=None, start=0,
             raise ValueError('Incompatible elementsize')
         action = _ffi.new('struct action*', dict(
             type=PLAY_RINGBUFFER,
-            allow_belated=allow_belated,
+            actual_time=-1.0 if allow_belated else 0.0,
             requested_time=start,
             ringbuffer=ringbuffer._ptr,
             total_frames=ULONG_MAX,
@@ -238,7 +238,7 @@ def record_buffer(self, buffer, channels, start=0, allow_belated=True):
         samplesize, _ = _sd._split(self.samplesize)
         action = _ffi.new('struct action*', dict(
             type=RECORD_BUFFER,
-            allow_belated=allow_belated,
+            actual_time=-1.0 if allow_belated else 0.0,
             requested_time=start,
             buffer=_ffi.cast('float*', buffer),
             total_frames=len(buffer) // channels // samplesize,
@@ -264,7 +264,7 @@ def record_ringbuffer(self, ringbuffer, channels=None, start=0,
             raise ValueError('Incompatible elementsize')
         action = _ffi.new('struct action*', dict(
             type=RECORD_RINGBUFFER,
-            allow_belated=allow_belated,
+            actual_time=-1.0 if allow_belated else 0.0,
             requested_time=start,
             ringbuffer=ringbuffer._ptr,
             total_frames=ULONG_MAX,