btl143/project_capture
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 修改通信模式为REQ

Browse Source
This commit is contained in:
bmy
2024-05-29 21:51:28 +08:00
parent 22734fdf13
commit b9a57f196d
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
capture.cc
View File

@@ -36,13 +36,13 @@ capture::capture(int camera_index, int zmq_port, int width_set, int height_set,
} }
context = new zmq::context_t(1); context = new zmq::context_t(1);
socket = new zmq::socket_t(*context, ZMQ_PUB); socket = new zmq::socket_t(*context, ZMQ_REP);
int hwm = 10; // int hwm = 10;
socket->setsockopt(ZMQ_SNDHWM, &hwm, sizeof(hwm)); // socket->setsockopt(ZMQ_SNDHWM, &hwm, sizeof(hwm));
char zmq_bind_port[10] = {0}; char zmq_bind_port[10] = {0};
sprintf(zmq_bind_port, "%d", port); sprintf(zmq_bind_port, "%d", port);
strcat(zmq_bind_addr, zmq_bind_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); socket->bind(zmq_bind_addr);
} }
@@ -64,6 +64,8 @@ void capture::run(void)
cv::Mat dst; cv::Mat dst;
while (1) while (1)
{ {
zmq::message_t msg_temp;
socket->recv(&msg_temp);
*cap >> frame; *cap >> frame;
if (frame.empty()) if (frame.empty())
{ {