From 1b70152f3f9354818f2731975a5034dcf1c89396 Mon Sep 17 00:00:00 2001 From: Laszlo Meszaros Date: Thu, 18 Dec 2014 16:00:03 +0100 Subject: [PATCH] ZMQ: fixed warnings --- modules/zmq/zmq-destination.c | 1 - modules/zmq/zmq-source.c | 2 ++ modules/zmq/zmq-transport.c | 4 ++-- 3 files changed, 4 insertions(+), 3 deletions(-) diff --git a/modules/zmq/zmq-destination.c b/modules/zmq/zmq-destination.c index d6655f0..921714e 100644 --- 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 index 5f622a9..a962de1 100644 --- 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 index a18e3f7..8c051d5 100644 --- 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