create new sockets when launching influx sender threads

Author: miDeb

include/logging/influxDb.h

@@ -33,6 +33,8 @@ extern "C" {
     int initDbContext(influxDbContext *cntxt, const char *hostname, const char *port, const char *database);
     int deInitDbContext(influxDbContext *cntxt);
 
+    int createSocket(influxDbContext *cntxt);
+
     int sendData(influxDbContext *cntxt, char *data, size_t length);
 #ifdef __cplusplus
 }

src/logging/InfluxDbWriter.cpp

@@ -114,7 +114,9 @@ void InfluxDbWriter::flush() {
 
     // spawn a thread to send the buffer
     threads.emplace_back([this, buf = std::move(buf_to_send)]() mutable {
-        sendData(&cntxt, buf.data(), buf.size());
+        influxDbContext context = cntxt;
+        createSocket(&context); // create a new socket to ensure thread safety
+        sendData(&context, buf.data(), buf.size());
         // return the buffer to the pool
         std::lock_guard thread_lock(buffer_mutex);
         available_buffers.emplace_back(std::move(buf));

src/logging/influxDb.c

@@ -43,7 +43,6 @@ void set_credentials(influxDbContext *cntxt, const char *username, const char *p
 }
 
 int initDbContext(influxDbContext *cntxt, const char *hostname, const char *port, const char *database) {
-    struct addrinfo hints, *ai = NULL;
 
     cntxt->sock_fd = -1;
     memset(cntxt->user, 0, SETTINGS_LENGTH);
@@ -54,12 +53,18 @@ int initDbContext(influxDbContext *cntxt, const char *hostname, const char *port
     safe_str_cpy(cntxt->port, port, SETTINGS_LENGTH);
     safe_str_cpy(cntxt->db_name, database, SETTINGS_LENGTH);
 
+    return createSocket(cntxt);
+}
+
+int createSocket(influxDbContext *cntxt) {
+    struct addrinfo hints, *ai = NULL;
+
     memset(&hints, 0, sizeof(struct addrinfo));
     hints.ai_family = AF_INET;
     hints.ai_socktype = SOCK_STREAM;
 
     do {
-        if(getaddrinfo(hostname, port, &hints, &ai) != 0) {
+        if(getaddrinfo(cntxt->hostname, cntxt->port, &hints, &ai) != 0) {
             break;
         }