Work around for ska-sa/spead2#40

ska-sa · Mar 6, 2019 · a57fc11 · a57fc11
1 parent f57c28c
commit a57fc11
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/katsdpcal/test/test_control.py b/katsdpcal/test/test_control.py
@@ -342,8 +342,10 @@ def setUp(self):
         # heaps are received in a predictable order and not affected by timing.
         endpoints_per_server = self.n_endpoints // self.n_servers
         for i, endpoint in enumerate(self.l0_endpoints):
-            # Compute first endpoint index of the server
-            base = i // endpoints_per_server * endpoints_per_server
+            # Compute last endpoint index of the server. We use the last
+            # rather than the first as a quick workaround for
+            # https://github.com/ska-sa/spead2/issues/40
+            base = (i // endpoints_per_server + 1) * endpoints_per_server - 1
             queue = self.l0_queues[self.l0_endpoints[base]]
             stream = spead2.send.InprocStream(sender_thread_pool, queue)
             stream.set_cnt_sequence(i, self.n_endpoints)