From b9a57f196d56baf041df029b7c46bb9e396d5140 Mon Sep 17 00:00:00 2001
From: bmy <2583236812@qq.com>
Date: Wed, 29 May 2024 21:51:28 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BF=AE=E6=94=B9=E9=80=9A=E4=BF=A1?=
 =?UTF-8?q?=E6=A8=A1=E5=BC=8F=E4=B8=BAREQ?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 capture.cc | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/capture.cc b/capture.cc
index 8d8567a..cb7511e 100644
--- a/capture.cc
+++ b/capture.cc
@@ -36,13 +36,13 @@ capture::capture(int camera_index, int zmq_port, int width_set, int height_set,
     }
 
     context = new zmq::context_t(1);
-    socket = new zmq::socket_t(*context, ZMQ_PUB);
-    int hwm = 10;
-    socket->setsockopt(ZMQ_SNDHWM, &hwm, sizeof(hwm));
+    socket = new zmq::socket_t(*context, ZMQ_REP);
+    // int hwm = 10;
+    // socket->setsockopt(ZMQ_SNDHWM, &hwm, sizeof(hwm));
     char zmq_bind_port[10] = {0};
     sprintf(zmq_bind_port, "%d", port);
     strcat(zmq_bind_addr, zmq_bind_port);
-    log_info("set camera %d zmq address %s", index, zmq_bind_addr);
+    log_info("set camera %d zmq address test %s", index, zmq_bind_addr);
     socket->bind(zmq_bind_addr);
 }
 
@@ -64,6 +64,8 @@ void capture::run(void)
     cv::Mat dst;
     while (1)
     {
+        zmq::message_t msg_temp;
+        socket->recv(&msg_temp);
         *cap >> frame;
         if (frame.empty())
         {