diff options
| author | Loic Guegan <manzerbredes@mailbox.org> | 2023-07-15 16:06:43 +0200 |
|---|---|---|
| committer | Loic Guegan <manzerbredes@mailbox.org> | 2023-07-15 16:06:43 +0200 |
| commit | 97c48bd23dacabf9ceb986dcfa6cce1e3caa7586 (patch) | |
| tree | 61f2916a650d8b133e51f2f530ca422286586258 | |
| parent | b8bdb006a334d1b688fb8c2468f2293a0781829b (diff) | |
Minor changes
| -rw-r--r-- | config.mk | 2 | ||||
| -rw-r--r-- | src/client.c | 1 | ||||
| -rw-r--r-- | src/publisher.c | 8 |
3 files changed, 7 insertions, 4 deletions
@@ -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); |
