administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-04-27 09:07:41 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Logging

Browse Source
This commit is contained in:
Nicolas Mowen 2025-08-13 10:43:08 -06:00
parent fbdcaa932c
commit c688c89386
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
frigate/detectors/plugins/zmq_ipc.py
View File

@ -53,7 +53,7 @@ class ZmqIpcDetector(DetectionApi):
def __init__(self, detector_config: ZmqDetectorConfig): def __init__(self, detector_config: ZmqDetectorConfig):
super().__init__(detector_config) super().__init__(detector_config)
self._context = zmq.Context.instance() self._context = zmq.Context()
self._endpoint = detector_config.endpoint self._endpoint = detector_config.endpoint
self._request_timeout_ms = detector_config.request_timeout_ms self._request_timeout_ms = detector_config.request_timeout_ms
self._linger_ms = detector_config.linger_ms self._linger_ms = detector_config.linger_ms
@ -73,7 +73,7 @@ class ZmqIpcDetector(DetectionApi):
# Apply timeouts and linger so calls don't block indefinitely # Apply timeouts and linger so calls don't block indefinitely
self._socket.setsockopt(zmq.RCVTIMEO, self._request_timeout_ms) self._socket.setsockopt(zmq.RCVTIMEO, self._request_timeout_ms)
self._socket.setsockopt(zmq.SNDTIMEO, self._request_timeout_ms) self._socket.setsockopt(zmq.SNDTIMEO, self._request_timeout_ms)
self._socket.setsockopt(zmq.LINGER, self._linger_ms) #self._socket.setsockopt(zmq.LINGER, self._linger_ms)
logger.info(f"ZMQ detector connecting to {self._endpoint}") logger.info(f"ZMQ detector connecting to {self._endpoint}")
self._socket.connect(self._endpoint) self._socket.connect(self._endpoint)
@ -114,9 +114,12 @@ class ZmqIpcDetector(DetectionApi):
payload_bytes = memoryview(tensor_input.tobytes(order="C")) payload_bytes = memoryview(tensor_input.tobytes(order="C"))
# Send request # Send request
print("sending multipart")
self._socket.send_multipart([header_bytes, payload_bytes]) self._socket.send_multipart([header_bytes, payload_bytes])
print("sent multipart")
# Receive reply # Receive reply
print("looking for response")
reply_frames = self._socket.recv_multipart() reply_frames = self._socket.recv_multipart()
detections = self._decode_response(reply_frames) detections = self._decode_response(reply_frames)