diff --git a/config.mk b/config.mk index 6a25af2..cda8ad2 100644 --- a/config.mk +++ b/config.mk @@ -1,6 +1,6 @@ ##### ZeroMQ PUBLISHER_PORT=5556 -PUBLISHER_ADDR=localhost +PUBLISHER_INTERFACE=* ##### Logger/Publisher # LOGGERS_DIR will contains all the data generated by the loggers diff --git a/src/client.c b/src/client.c index fc62359..ebc7b2b 100644 --- a/src/client.c +++ b/src/client.c @@ -58,6 +58,7 @@ int main (int argc, char *argv []) interval=atoi(token); if(line==4){ + printf("Data received with key=%s\n",key); char path[255]=""; sprintf(path,"%s/%s_%s_%ld",cdatadir,key,client,interval); fptr=fopen(path,"a"); diff --git a/src/publisher.c b/src/publisher.c index f4bb86d..c30b52a 100644 --- a/src/publisher.c +++ b/src/publisher.c @@ -12,6 +12,7 @@ // Global: char *__logdir; char *__key; +char *__interface; int __loginterval; int __port; @@ -19,8 +20,8 @@ void publish(void *publisher, char *filepath, char* client, long int interval); int main (int argc, char *argv []) { - if(argc != 5){ - printf("Usage: %s <abslogdir> <loginterval> <port> <key>",argv[0]); + if(argc != 6){ + printf("Usage: %s <abslogdir> <loginterval> <port> <key> <interface>",argv[0]); exit(1); } @@ -29,12 +30,13 @@ int main (int argc, char *argv []) __loginterval=atoi(argv[2]); __port=atoi(argv[3]); __key=argv[4]; + __interface=argv[5]; //----- Prepare our context and publisher void *context = zmq_ctx_new (); void *publisher = zmq_socket (context, ZMQ_PUB); char bindto[30]; - sprintf(bindto,"tcp://*:%d",__port); + sprintf(bindto,"tcp://%s:%d",__interface,__port); int rc = zmq_bind (publisher, bindto); if(rc!=0){ printf("Failed to bind zmq on %s\n",bindto);