From a57fc1106a1c8d1c418ab33b7e957a816753966e Mon Sep 17 00:00:00 2001 From: Bruce Merry Date: Wed, 6 Mar 2019 13:34:51 +0200 Subject: [PATCH] Work around for ska-sa/spead2#40 --- katsdpcal/test/test_control.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/katsdpcal/test/test_control.py b/katsdpcal/test/test_control.py index 74fa2410..891d56f4 100644 --- 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)