From eb78c4a211abca843aceda57bd5c4b33a166da7b Mon Sep 17 00:00:00 2001 From: flandre Date: Sat, 18 Jan 2025 21:19:25 +0800 Subject: [PATCH] fix --- test/testcppzmq.py | 23 +++++++++++++++-------- 1 file changed, 15 insertions(+), 8 deletions(-) diff --git a/test/testcppzmq.py b/test/testcppzmq.py index 9890f99..259d331 100644 --- a/test/testcppzmq.py +++ b/test/testcppzmq.py @@ -1,17 +1,24 @@ +import struct +from pathlib import Path + import zmq import time import sys -if __name__ == '__main__': - s = sys.argv[1] + +def f0(): ctx = zmq.Context() sock = ctx.socket(zmq.REQ) sock.connect('tcp://11.6.1.66:5556') -# time.sleep(1) - sock.send(s.encode()) - print(sock.recv()) - exit(0) + sock.send(b'file' + Path('/home/lambda/source/scarlet/flandre/config/64-1.txt').read_bytes()) + + +def f1(): + ctx = zmq.Context() sock = ctx.socket(zmq.PULL) - sock.bind('tcp://0.0.0.0:5558') + sock.connect('tcp://11.6.1.66:5556') while True: s = sock.recv() - print(s) + print(struct.unpack('=iqi', s)) + +if __name__ == '__main__': + f1()