mx/Jungfraujoch
2
1
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases 67 Wiki Activity

Experimental support for raw TCP/IP with zero copy feature

Browse Source
This commit is contained in:
leonarski_f
2026-03-01 16:42:29 +01:00
parent eb67d537fd
commit fa5da877cf
14 changed files with 1065 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
image_puller/ZMQImagePuller.cpp
+6 -6
View File
@@ -48,7 +48,7 @@ void ZMQImagePuller::Disconnect() {
void ZMQImagePuller::PullerThread() {
while (true) {
ImagePullerOutput ret;
ret.msg = std::make_shared<ZMQMessage>();
ret.zmq_msg = std::make_shared<ZMQMessage>();
bool received = false;
while (!received) {
if (disconnect) {
@@ -56,7 +56,7 @@ void ZMQImagePuller::PullerThread() {
return;
}
try {
received = socket.Receive(*ret.msg, false);
received = socket.Receive(*ret.zmq_msg, false);
if (!received)
std::this_thread::sleep_for(std::chrono::milliseconds(1));
} catch (const JFJochException &e) {
@@ -70,9 +70,9 @@ void ZMQImagePuller::PullerThread() {
void ZMQImagePuller::CBORThread() {
auto ret = cbor_fifo.GetBlocking();
while (ret.msg) {
while (ret.zmq_msg) {
try {
ret.cbor = CBORStream2Deserialize(ret.msg->data(), ret.msg->size());
ret.cbor = CBORStream2Deserialize(ret.zmq_msg->data(), ret.zmq_msg->size());
if (ret.cbor->msg_type == CBORImageType::END)
logger.Info("Received END");
@@ -98,7 +98,7 @@ void ZMQImagePuller::RepubThread() {
auto ret = repub_fifo.GetBlocking();
bool repub_active = false;
while (ret.msg) {
while (ret.zmq_msg) {
try {
if (ret.cbor->msg_type == CBORImageType::START) {
// Start message needs to be cleaned when running republish
@@ -112,7 +112,7 @@ void ZMQImagePuller::RepubThread() {
logger.Info("Republish active");
} else {
if (repub_active)
repub_socket->Send(ret.msg->data(), ret.msg->size(), true);
repub_socket->Send(ret.zmq_msg->data(), ret.zmq_msg->size(), true);
}
} catch (const JFJochException &e) {
logger.ErrorException(e);