Postgres replication

include/db/db.h

@@ -47,7 +47,7 @@ typedef struct init_db_func_ptr_s {
 struct db_t {
 	postgres_t *pg_conf;
 
-	void *host_conn;
+	void *origin_conn;
 	void *target_conn;
 };
 

include/db/postgres.h

@@ -3,8 +3,24 @@
 
 #include "db/db.h"
 
+/*
+ * For the `pg_dump` and `pg_restore` to work we need to set the passwords as env variables,
+ * prefixed with `PGPASSWORD=`
+ */
+#define PG_PASS_PREFIX 11
+#define PG_DUMP_COMMAND "pg_dump"
+#define PG_RESTORE_COMMAND "pg_restore"
+
+void read_buffer_pipe(int *);
+
+void construct_dump_path(char *);
+
+int construct_pg(void);
+
 int connect_pg(struct db_t *);
 void close_pg(struct db_t *pg_db_t);
 int replicate(struct db_t *pg_db_t, struct options *pg_options);
 
+int execve_binary(char* ,char *const[], char *const[]);
+
 #endif

src/db.c

@@ -1,5 +1,6 @@
 #include "db/db.h"
 #include "db/postgres.h"
+
 #include <stddef.h>
 #include <stdlib.h>
 
@@ -11,6 +12,8 @@ struct db_operations **available_dbs;
 
 int execute_db_operations(void)
 {
+	int ret = 0;
+	struct db_t *available_db;
 	available_dbs = (struct db_operations **)calloc(
 		MAX_AVAILABLE_DBS, sizeof(struct db_operations **));
 
@@ -22,13 +25,19 @@ int execute_db_operations(void)
 	for (int i = 0; i < MAX_AVAILABLE_DBS; i++) {
 		/* do db_operations for all available db impl. */
 		if (available_dbs[i] != NULL) {
-			struct db_t *available_db = available_dbs[i]->db;
-			available_dbs[i]->connect(available_db);
-			available_dbs[i]->close(available_db);
+			available_db = available_dbs[i]->db;
+			ret = available_dbs[i]->connect(available_db);
+			if (ret != 0) {
+				available_dbs[i]->close(available_db);
+				return ret;
+			}
 			available_dbs[i]->replicate(available_db, NULL);
-			free(available_db);
+			available_dbs[i]->close(available_db);
 		}
 	}
 
+	free(available_db);
+	free(available_dbs);
+
 	return 0;
 }

src/main.c

@@ -12,8 +12,8 @@ extern config_t *yaml_config;
 extern bool verbose;
 
 static struct option options[] = {
-	{ "config-file", required_argument, 0, 'f' },
-	{ "verbose", no_argument, 0, 'v' },
+	{ "config-file", required_argument, NULL, 'f' },
+	{ "verbose", no_argument, NULL, 'v' },
 };
 
 int main(int argc, char **argv)