From 59c454173d41e15f9e2fcd7e443fc244c29851f3 Mon Sep 17 00:00:00 2001 From: Loic Guegan Date: Sat, 15 Jul 2023 14:36:48 +0200 Subject: Minor changes --- src/publisher.c | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) (limited to 'src/publisher.c') diff --git a/src/publisher.c b/src/publisher.c index 51096ef..45a248e 100644 --- a/src/publisher.c +++ b/src/publisher.c @@ -11,15 +11,16 @@ // Global: char *__logdir; +char *__key; int __loginterval; int __port; -void publish(void *publisher, char *filepath, char* client, int interval); +void publish(void *publisher, char *filepath, char* client, long int interval); int main (int argc, char *argv []) { - if(argc != 4){ - printf("Usage: %s ",argv[0]); + if(argc != 5){ + printf("Usage: %s ",argv[0]); exit(1); } @@ -27,6 +28,7 @@ int main (int argc, char *argv []) __logdir=argv[1]; __loginterval=atoi(argv[2]); __port=atoi(argv[3]); + __key=argv[4]; //----- Prepare our context and publisher void *context = zmq_ctx_new (); @@ -88,7 +90,9 @@ int main (int argc, char *argv []) return 0; } -void publish(void *publisher, char *filepath, char* client, int interval){ +void publish(void *publisher, char *filepath, char* client, long int interval){ printf("Publish!\n"); - zmq_send (publisher, ZMQ_TOKEN, strlen(ZMQ_TOKEN), 0); + char buffer[ZMQ_MSG_SIZE]; + sprintf(buffer,"%s\n%s\n%ld",ZMQ_TOKEN,__key,interval); + zmq_send (publisher, buffer, ZMQ_MSG_SIZE, 0); } \ No newline at end of file -- cgit v1.2.3