ZMQ: fixed warnings

balabit · Dec 18, 2014 · 1b70152 · 1b70152
1 parent 15fa852
commit 1b70152
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/modules/zmq/zmq-destination.c b/modules/zmq/zmq-destination.c
@@ -148,7 +148,6 @@ static worker_insert_result_t
 zmq_worker_insert(LogThrDestDriver *destination, LogMessage *msg)
 {
   ZMQDestDriver *self = (ZMQDestDriver *)destination;
-  gboolean success = TRUE;
   GString *result = g_string_new("");
 
   if (self->socket == NULL)

diff --git a/modules/zmq/zmq-source.c b/modules/zmq/zmq-source.c
@@ -37,6 +37,8 @@
 #include "poll-fd-events.h"
 #include "logproto/logproto-text-server.h"
 
+void zmq_sd_set_address(LogDriver *source, const gchar *address);
+void zmq_sd_set_port(LogDriver *source, gint port);
 
 typedef struct _ZMQReaderContext
 {

diff --git a/modules/zmq/zmq-transport.c b/modules/zmq/zmq-transport.c
@@ -31,10 +31,10 @@ typedef struct _LogTransportZMQ
 } LogTransportZMQ;
 
 static gssize
-log_transport_zmq_read_method(LogTransport *s, gpointer buf, gsize buflen, GSockAddr **sa)
+log_transport_zmq_read_method(LogTransport *s, gpointer buf, gsize buflen, LogTransportAuxData *aux)
 {
   LogTransportZMQ *self = (LogTransportZMQ *) s;
-  return zmq_recv(self->socket, buf, buflen, ZMQ_DONTWAIT);
+  return zmq_recv (self->socket, buf, buflen, ZMQ_DONTWAIT);
 }
 
 static gssize