summaryrefslogtreecommitdiff
path: root/src/publisher.c
diff options
context:
space:
mode:
authorLoic Guegan <manzerbredes@mailbox.org>2023-07-15 14:36:48 +0200
committerLoic Guegan <manzerbredes@mailbox.org>2023-07-15 14:36:48 +0200
commit59c454173d41e15f9e2fcd7e443fc244c29851f3 (patch)
treeeb4c24fb5b14c7adbe6e7e9ac0c8b0e9cd1d0562 /src/publisher.c
parent5e8c2ae3b5ce467ae5a3eccded779113a2097d4c (diff)
Minor changes
Diffstat (limited to 'src/publisher.c')
-rw-r--r--src/publisher.c14
1 files changed, 9 insertions, 5 deletions
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 <abslogdir> <loginterval> <port>",argv[0]);
+ if(argc != 5){
+ printf("Usage: %s <abslogdir> <loginterval> <port> <key>",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