Split db_mysql_live into two modules so other modules can make use of the asynchronous command interface

1 files changed, 30 insertions, 0 deletions

diff --git a/modules/extra/async_commands.h b/modules/extra/async_commands.h
new file mode 100644
index 000000000..b6b9e7c2b
--- /dev/null
+++ b/modules/extra/async_commands.h
@@ -0,0 +1,30 @@
+
+class CommandMutex : public Thread
+{
+ public:
+	// Mutex used by this command to allow the core to drop and pick up processing of it at will
+	Mutex mutex;
+	// Set to true when this thread is processing data that is not thread safe (eg, the command)
+	bool processing;
+	Command *command;
+	CommandSource source;
+	std::vector<Anope::string> params;
+
+	CommandMutex() : Thread(), processing(true) { }
+
+	~CommandMutex() { }
+
+	virtual void Run() = 0;
+
+	virtual void Lock() = 0;
+	
+	virtual void Unlock() = 0;
+};
+
+class AsynchCommandsService : public Service
+{
+ public:
+	AsynchCommandsService(Module *o, const Anope::string &n) : Service(o, n) { }
+	virtual CommandMutex *CurrentCommand() = 0;
+};
+