yukari/flandre
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix test

Browse Source
This commit is contained in:
flandre 2025-01-18 21:27:17 +08:00
parent eb78c4a211
commit 5f1f1a0820
1 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
test/testcppzmq.py
View File

@ -5,20 +5,42 @@ import zmq
import time import time
import sys import sys
def f0():
def exit():
ctx = zmq.Context()
sock = ctx.socket(zmq.REQ)
sock.connect('tcp://11.6.1.66:5556')
# sock.send(b'file' + Path('/home/lambda/source/scarlet/flandre/config/64-1.txt').read_bytes())
sock.send(b'exit')
def cmd(c: str):
ctx = zmq.Context()
sock = ctx.socket(zmq.REQ)
sock.connect('tcp://11.6.1.66:5556')
sock.send(c.encode())
def file():
ctx = zmq.Context() ctx = zmq.Context()
sock = ctx.socket(zmq.REQ) sock = ctx.socket(zmq.REQ)
sock.connect('tcp://11.6.1.66:5556') sock.connect('tcp://11.6.1.66:5556')
sock.send(b'file' + Path('/home/lambda/source/scarlet/flandre/config/64-1.txt').read_bytes()) sock.send(b'file' + Path('/home/lambda/source/scarlet/flandre/config/64-1.txt').read_bytes())
def f1(): def test():
ctx = zmq.Context() ctx = zmq.Context()
sock = ctx.socket(zmq.PULL) sock = ctx.socket(zmq.PULL)
sock.connect('tcp://11.6.1.66:5556') sock.connect('tcp://11.6.1.66:5555')
while True: while True:
s = sock.recv() s = sock.recv()
print(struct.unpack('=iqi', s)) print(struct.unpack_from('=iqi', s))
print(s[4 + 8 + 4:].__len__())
break
if __name__ == '__main__': if __name__ == '__main__':
f1() if len(sys.argv) < 2:
test()
else:
globals()[sys.argv[1]](*sys.argv[2:])