From 20d28e80a5c861a9d5f449ea911ab75b4f37ad0d Mon Sep 17 00:00:00 2001 From: Jef Date: Tue, 24 Sep 2024 14:54:57 +0200 Subject: Initial community commit --- Src/replicant/nu/win/MessageLoop.h | 45 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 Src/replicant/nu/win/MessageLoop.h (limited to 'Src/replicant/nu/win/MessageLoop.h') diff --git a/Src/replicant/nu/win/MessageLoop.h b/Src/replicant/nu/win/MessageLoop.h new file mode 100644 index 00000000..88e4520f --- /dev/null +++ b/Src/replicant/nu/win/MessageLoop.h @@ -0,0 +1,45 @@ +#pragma once +#include "foundation/types.h" +#include "nu/lfmpscq.h" +#include "nu/LockFreeLIFO.h" +#include + +namespace nu +{ + + /* you can inherit from message_node_t (or combine inside a struct) + but make sure that your message isn't > 64 bytes */ + struct message_node_t : public queue_node_t + { + uint32_t message; + }; + + class MessageLoop + { + public: + MessageLoop(); + ~MessageLoop(); + /* API for Message senders */ + message_node_t *AllocateMessage(); // returns a message for you to fill out + void PostMessage(message_node_t *message); + + /* API for Message receivers */ + void FreeMessage(message_node_t *message); + message_node_t *GetMessage(); // waits forever + message_node_t *PeekMessage(); + message_node_t *PeekMessage(unsigned int milliseconds); + private: + void RefillCache(); + + HANDLE message_notification; + mpscq_t message_queue; + + /* Memory cache to be able to run APCs without having the memory manager lock + we'll allocate 100 at a time (#defined by MESSAGE_CACHE_SEED) + and allocate new ones only if the cache is empty (which unfortunately will lock) + cache_bases holds the pointers we've allocated (to free on destruction of this object) + and message_cache holds the individual pointers */ + static lifo_t message_cache; + static lifo_t cache_bases; + }; +} \ No newline at end of file -- cgit