diff options
| author | Loic Guegan <manzerbredes@mailbox.org> | 2023-07-17 18:22:36 +0200 |
|---|---|---|
| committer | Loic Guegan <manzerbredes@mailbox.org> | 2023-07-17 18:22:36 +0200 |
| commit | 76f13c34f390e7dbbadb2051cda316f0060bdbff (patch) | |
| tree | 3de5c0342318d513de72f41d051b305838bf2976 /src/logger.c | |
| parent | 8f78b632bf246c6f420735229bad0340f99bb25e (diff) | |
Minor changes
Diffstat (limited to 'src/logger.c')
| -rw-r--r-- | src/logger.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/logger.c b/src/logger.c index 852898e..4258090 100644 --- a/src/logger.c +++ b/src/logger.c @@ -117,7 +117,7 @@ int main (int argc, char *argv []) char line[STATIC_LEN]; sprintf(line,"%ld,%ld,%d\n",power_ts.tv_sec,power_ts.tv_nsec,atoi(buffer)); int linelen=strlen(line); - if(queues[queue_id].size+linelen>ZMQ_MSG_SIZE){ + if((queues[queue_id].size+linelen)>ZMQ_MSG_SIZE){ printf("To many measurements to publish. Please increase ZMQ_MSG_SIZE\n"); } else { memcpy(queues[queue_id].msg+queues[queue_id].size,line,linelen); @@ -128,7 +128,7 @@ int main (int argc, char *argv []) #if LOGGERS_DELAY > 0 usleep(LOGGERS_DELAY*1000); #endif - printf("Tick\n"); fflush(stdout); + //printf("Tick\n"); fflush(stdout); } publish(queue_id,publisher); } @@ -144,4 +144,5 @@ int main (int argc, char *argv []) void publish(int queue_id, void* publisher){ printf("Publishing...\n"); zmq_send(publisher,queues[queue_id].msg,queues[queue_id].size,0); + printf("Done\n"); }
\ No newline at end of file |