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");