Linting
This commit is contained in:
parent
cba7c32c99
commit
406a92b66f
|
|
@ -47,7 +47,7 @@ def main():
|
||||||
|
|
||||||
# Send results back in chunks
|
# Send results back in chunks
|
||||||
for i in range(0, len(combined), BUFFER_SIZE):
|
for i in range(0, len(combined), BUFFER_SIZE):
|
||||||
sock.sendto(combined[i: i + BUFFER_SIZE].encode(), addr)
|
sock.sendto(combined[i : i + BUFFER_SIZE].encode(), addr)
|
||||||
print(f"[Relay] Sent results back to {addr}")
|
print(f"[Relay] Sent results back to {addr}")
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -60,7 +60,7 @@ def send_0mq(args):
|
||||||
take = min(len(new_samples), total_samples - received)
|
take = min(len(new_samples), total_samples - received)
|
||||||
|
|
||||||
# Copy to main buffer
|
# Copy to main buffer
|
||||||
complex_values[received: received + take] = new_samples[:take]
|
complex_values[received : received + take] = new_samples[:take]
|
||||||
received += take
|
received += take
|
||||||
|
|
||||||
# Save any leftover samples
|
# Save any leftover samples
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user