azaion/annotations
1
0
Fork 0
mirror of https://github.com/azaion/annotations.git synced 2026-04-22 13:36:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix hardware service

Browse Source
This commit is contained in:
Alex Bezdieniezhnykh
2025-05-02 13:25:33 +03:00
parent 7842fe1067
commit 472ed6533e
15 changed files with 118 additions and 142 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Azaion.Inference/remote_command_handler.pyx
+3 -6
View File
@@ -6,16 +6,13 @@ cimport constants
import yaml
cdef class RemoteCommandHandler:
def __init__(self, object on_command):
def __init__(self, int zmq_port, object on_command):
self._on_command = on_command
self._context = zmq.Context.instance()
self._router = self._context.socket(zmq.ROUTER)
self._router.setsockopt(zmq.LINGER, 0)
with open(<str>constants.CONFIG_FILE, "r") as f:
config = yaml.safe_load(f)
port = config["zmq_port"]
self._router.bind(f'tcp://*:{port}')
self._router.bind(f'tcp://*:{zmq_port}')
self._dealer = self._context.socket(zmq.DEALER)
self._dealer.setsockopt(zmq.LINGER, 0)
@@ -31,7 +28,7 @@ cdef class RemoteCommandHandler:
for _ in range(4): # 4 worker threads
worker = Thread(target=self._worker_loop, daemon=True)
self._workers.append(worker)
print(f'Listening to commands on port {port}...')
print(f'Listening to commands on port {zmq_port}...')
cdef start(self):
self._proxy_thread.start()