Merge pull request #5 from plainlystated/fix_5_second_writes

Open/close a socket per point. We were doing persistent HTTP requests,

Author: myagley

include/tempodb/tempodb.h

@@ -26,6 +26,8 @@ tempodb_platform_config * tempodb_platform_create(void);
 int tempodb_platform_destroy(tempodb_platform_config *config);
 int tempodb_platform_send(tempodb_platform_config *config, const char *command);
 int tempodb_platform_read_response(tempodb_platform_config *config, char *buffer, const int buffer_size);
+void tempodb_platform_open_socket(tempodb_platform_config *config);
+void tempodb_platform_close_socket(tempodb_platform_config *config);
 
 tempodb_config * tempodb_create(const char *key, const char *secret);
 void tempodb_destroy(tempodb_config *config);

mocks/platform_mock.c

@@ -40,6 +40,12 @@ int tempodb_platform_read_response(tempodb_platform_config *config, char *buffer
   return 0;
 }
 
+void tempodb_platform_open_socket(tempodb_platform_config *config) {
+}
+
+void tempodb_platform_close_socket(tempodb_platform_config *config) {
+}
+
 void set_test_response(const char *buffer) {
   strncpy(response_buffer, buffer, response_buffer_size);
 }

src/tempodb/platform/posix.c

@@ -4,6 +4,7 @@
 #include <netinet/in.h>
 #include <netdb.h>
 #include <arpa/inet.h>
+#include <unistd.h>
 
 static int tempodb_create_socket(void);
 static struct sockaddr_in * tempodb_addr(void);
@@ -15,7 +16,6 @@ struct tempodb_platform_config {
 
 tempodb_platform_config * tempodb_platform_create(void) {
   tempodb_platform_config *config = (tempodb_platform_config *)malloc(sizeof(tempodb_platform_config));
-  config->sock = tempodb_create_socket();
   return config;
 }
 
@@ -25,6 +25,14 @@ int tempodb_platform_destroy(tempodb_platform_config *config)
   return 0;
 }
 
+void tempodb_platform_open_socket(tempodb_platform_config *config) {
+  config->sock = tempodb_create_socket();
+}
+
+void tempodb_platform_close_socket(tempodb_platform_config *config) {
+  close(config->sock);
+}
+
 int tempodb_platform_read_response(tempodb_platform_config *config, char *buffer, const int buffer_size) {
   size_t bytes_read = 0;
   size_t bytes_read_part;

src/tempodb/tempodb.c

@@ -140,9 +140,12 @@ int tempodb_write_by_path(tempodb_config *config, const char *path, const float
 }
 
 int tempodb_write(tempodb_config *config, const char *query_buffer, char *response_buffer, const ssize_t response_buffer_size) {
-  int status = tempodb_platform_send(config->platform_config, query_buffer);
+  int status;
+  tempodb_platform_open_socket(config->platform_config);
+  status = tempodb_platform_send(config->platform_config, query_buffer);
   if (status != -1) {
     status = tempodb_platform_read_response(config->platform_config, response_buffer, response_buffer_size);
   }
+  tempodb_platform_close_socket(config->platform_config);
   return status;
 }