loic/ina260-zmq-publisher
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/ina260-zmq-publisher.git synced 2025-04-05 11:26:25 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Minor changes

Browse source
This commit is contained in:
Loïc Guégan 2023-08-25 11:54:39 +02:00
parent f68447e201
commit 2bc5f2c00f
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/publisher.c
View file

@ -155,10 +155,11 @@ void *publisher(void *zmq_publisher) {
int queue_id = 0;
while (!__stop) {
if (queues[queue_id].issending) {
long long startat=TIMESTAMP();
printf("Publishing...");
zmq_send(zmq_publisher, queues[queue_id].msg, queues[queue_id].size, 0);
queues[queue_id].issending = 0;
printf("done\n");
printf("done (duration %lld)\n",TIMESTAMP()-startat);
} else {
#if LOG_DELAY > 0
usleep(LOG_DELAY * 1000);