loic/ina260-zmq-publisher
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/ina260-zmq-publisher.git synced 2025-04-06 03:46: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:59:44 +02:00
parent 2bc5f2c00f
commit 8350d7e977
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/publisher.c
View file

@ -102,12 +102,13 @@ int main(int argc, char *argv[]) {
//----- Start logging //----- Start logging
printf("Logger started [client=%s,interval=%ds]\n", client, loginterval); printf("Logger started [client=%s,interval=%ds]\n", client, loginterval);
while (!__stop) { while (!__stop) {
interval = INTERVAL(loginterval); // Wait for next queue to be available:
// Log current interval
queue_id = (queue_id + 1) >= MAX_QUEUES ? 0 : (queue_id + 1); queue_id = (queue_id + 1) >= MAX_QUEUES ? 0 : (queue_id + 1);
// Busy wait: // Busy wait:
while (queues[queue_id].issending) { while (queues[queue_id].issending) {
}; };
// Get current interval
interval = INTERVAL(loginterval);
// Write msg header: // Write msg header:
*queues[queue_id].msg = '\0'; *queues[queue_id].msg = '\0';
sprintf(queues[queue_id].msg, "%s\n%s\n%s\n%ld\n", ZMQ_TOKEN, key, client, sprintf(queues[queue_id].msg, "%s\n%s\n%s\n%ld\n", ZMQ_TOKEN, key, client,