First commit with MySQL_Logger

include/MySQL_Logger.hpp

@@ -0,0 +1,18 @@
+#ifndef __CLASS_MYSQL_LOGGER_H
+#define __CLASS_MYSQL_LOGGER_H
+#include "proxysql.h"
+#include "cpp.h"
+
+class MySQL_Logger {
+	private:
+	rwlock_t rwlock;
+	void wrlock();
+	void wrunlock();
+	public:
+	MySQL_Logger();
+	~MySQL_Logger();
+	void flush_log();
+};
+
+
+#endif /* __CLASS_MYSQL_LOGGER_H */

include/cpp.h

@@ -17,4 +17,5 @@
 #include "query_processor.h"
 #include "proxysql_admin.h"
 #include "MySQL_HostGroups_Manager.h"
+#include "MySQL_Logger.hpp"
 //#endif /* __cplusplus */

lib/Makefile

@@ -46,7 +46,7 @@ default: libproxysql.a
 
 _OBJ = sqlite3.o c_tokenizer.o
 OBJ = $(patsubst %,$(ODIR)/%,$(_OBJ))
-_OBJ_CPP = ProxySQL_GloVars.oo network.oo debug.oo configfile.oo Query_Cache.oo SpookyV2.oo MySQL_Authentication.oo gen_utils.oo simple_kv.oo sqlite3db.oo global_variables.oo proxysql_mem.oo mysql_connection.oo MySQL_HostGroups_Manager.oo mysql_data_stream.oo MySQL_Thread.oo MySQL_Session.oo MySQL_Protocol.oo mysql_backend.oo Query_Processor.oo ProxySQL_Admin.oo MySQL_Monitor.oo
+_OBJ_CPP = ProxySQL_GloVars.oo network.oo debug.oo configfile.oo Query_Cache.oo SpookyV2.oo MySQL_Authentication.oo gen_utils.oo simple_kv.oo sqlite3db.oo global_variables.oo proxysql_mem.oo mysql_connection.oo MySQL_HostGroups_Manager.oo mysql_data_stream.oo MySQL_Thread.oo MySQL_Session.oo MySQL_Protocol.oo mysql_backend.oo Query_Processor.oo ProxySQL_Admin.oo MySQL_Monitor.oo MySQL_Logger.oo
 OBJ_CPP = $(patsubst %,$(ODIR)/%,$(_OBJ_CPP))
 
 %.ko: %.cpp

lib/MySQL_Logger.cpp

@@ -0,0 +1,20 @@
+#include "proxysql.h"
+#include "cpp.h"
+
+MySQL_Logger::MySQL_Logger() {
+	spinlock_rwlock_init(&rwlock);
+};
+
+MySQL_Logger::~MySQL_Logger() {
+};
+
+void MySQL_Logger::wrlock() {
+  spin_wrlock(&rwlock);
+};
+
+void MySQL_Logger::wrunlock() {
+  spin_wrunlock(&rwlock);
+};
+
+void MySQL_Logger::flush_log() {
+};

src/main.cpp

@@ -118,6 +118,8 @@ MySQL_Threads_Handler *GloMTH;
 MySQL_Monitor *GloMyMon;
 std::thread *MyMon_thread;
 
+MySQL_Logger *GloMyLogger;
+
 
 void * mysql_worker_thread_func(void *arg) {
 
@@ -206,8 +208,10 @@ void ProxySQL_Main_init_main_modules() {
 	GloMTH=NULL;
 	GloMyAuth=NULL;
 	GloMyMon=NULL;
+	GloMyLogger=NULL;
 	MyHGM=new MySQL_HostGroups_Manager();
 	GloMTH=new MySQL_Threads_Handler();
+	GloMyLogger = new MySQL_Logger();
 }
 
 
@@ -297,6 +301,10 @@ void ProxySQL_Main_shutdown_all_modules() {
 		delete GloMTH;
 		GloMTH=NULL;
 	}
+	if (GloMyLogger) {
+		delete GloMyLogger;
+		GloMyLogger=NULL;
+	}
 
 	delete GloAdmin;
 	delete MyHGM;