summaryrefslogtreecommitdiff
path: root/modules/extra/async_commands.h
diff options
context:
space:
mode:
Diffstat (limited to 'modules/extra/async_commands.h')
-rw-r--r--modules/extra/async_commands.h30
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;
+};
+