summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLoic Guegan <manzerbredes@mailbox.org>2023-07-15 16:06:43 +0200
committerLoic Guegan <manzerbredes@mailbox.org>2023-07-15 16:06:43 +0200
commit97c48bd23dacabf9ceb986dcfa6cce1e3caa7586 (patch)
tree61f2916a650d8b133e51f2f530ca422286586258
parentb8bdb006a334d1b688fb8c2468f2293a0781829b (diff)
Minor changes
-rw-r--r--config.mk2
-rw-r--r--src/client.c1
-rw-r--r--src/publisher.c8
3 files changed, 7 insertions, 4 deletions
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);