ZMQ: fixed some memory leaks in the source

modules/zmq/zmq-source.c

@@ -97,12 +97,16 @@ create_zmq_context(ZMQSourceDriver* self)
     return FALSE;
   }
 
-  if (zmq_bind(self->socket, get_address(self)) != 0)
+  gchar* address = get_address(self);
+
+  if (zmq_bind(self->socket, address) != 0)
   {
-    msg_error("Failed to bind!", evt_tag_str("Bind address", get_address(self)), evt_tag_errno("Error", errno),NULL);
+    msg_error("Failed to bind!", evt_tag_str("Bind address", address), evt_tag_errno("Error", errno),NULL);
+    g_free(address);
     return FALSE;
   }
 
+  g_free(address);
   return TRUE;
 }
 
@@ -126,7 +130,11 @@ zmq_sd_init(LogPipe *s)
     return FALSE;
   }
 
-  ZMQReaderContext* reader_context = cfg_persist_config_fetch(cfg, get_persist_name(self));
+  gchar* persist_name = get_persist_name(self);
+
+  ZMQReaderContext* reader_context = cfg_persist_config_fetch(cfg, persist_name);
+
+  g_free(persist_name);
 
   log_reader_options_init(&self->reader_options, cfg, "zmq");
 
@@ -188,7 +196,11 @@ zmq_sd_deinit(LogPipe *s)
   self->context = NULL;
   self->reader = NULL;
 
-  cfg_persist_config_add(cfg, get_persist_name(self), reader_context, (GDestroyNotify) zmq_socket_deinit, FALSE);
+  gchar* persist_name = get_persist_name(self);
+
+  cfg_persist_config_add(cfg, persist_name, reader_context, (GDestroyNotify) zmq_socket_deinit, FALSE);
+
+  g_free(persist_name);
 
   return log_src_driver_deinit_method(s);
 }