From dbd45e0fa0f102c9febef6bbea19c5b3f95ca52b Mon Sep 17 00:00:00 2001
From: Loic Guegan <manzerbredes@mailbox.org>
Date: Sun, 16 Jul 2023 12:46:22 +0200
Subject: [PATCH] Minor changes
---
config.mk | 4 ++--
src/subscriber.c | 5 +++--
2 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/config.mk b/config.mk
index 65cdb07..e65753a 100644
--- a/config.mk
+++ b/config.mk
@@ -8,8 +8,8 @@ SUBSCRIBER_ADDR=localhost
# messages from publishers. Leave as is if not sure.
ZMQ_TOKEN=ina260-zmq-publisher
# ZMQ_MSG_SIZE max number of bytes per ZeroMQ messages
-# Be careful with this parameter
-ZMQ_MSG_SIZE=2550
+# Be careful with this parameter. Default is 5MiB
+ZMQ_MSG_SIZE=5242880
##### Logger/Publisher
# LOGGERS_DIR will contains all the data generated by the loggers
diff --git a/src/subscriber.c b/src/subscriber.c
index 26f7e69..2f8dd2a 100644
--- a/src/subscriber.c
+++ b/src/subscriber.c
@@ -54,7 +54,8 @@ int main (int argc, char *argv [])
interval=atoi(token);
if(line==4){
- printf("Data received: key=%s client=%s interval=%ld\n",key, client, interval);
+ double size_mib=size/(1024*1024);
+ printf("Data received: key=%s client=%s interval=%ld msgsize=%.2lfMiB\n",key, client, interval,size_mib);
char path[STATIC_LEN]="";
//sprintf(path,"%s/%s_%s_%ld",cdatadir,key,client,interval);
sprintf(path,"%s/%s/%s/",cdatadir,key,client);
@@ -67,7 +68,7 @@ int main (int argc, char *argv [])
if(line>4){
fwrite(token, strlen(token), 1, fptr);
- fwrite("\n",2,1,fptr);
+ fwrite("\n",1,1,fptr);
}
token=strtok(NULL, "\n");