aboutsummaryrefslogtreecommitdiff
path: root/zenhttp/iothreadpool.h
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2021-09-09 15:14:08 +0200
committerStefan Boberg <[email protected]>2021-09-09 15:14:08 +0200
commit6ec26c46d694a1d5291790a9c70bec25dce4b513 (patch)
tree4177d45f9703d11f00e495f0fde77f4445453d2d /zenhttp/iothreadpool.h
parentHttpServer::AddEndpoint -> HttpServer::RegisterService (diff)
downloadzen-6ec26c46d694a1d5291790a9c70bec25dce4b513.tar.xz
zen-6ec26c46d694a1d5291790a9c70bec25dce4b513.zip
Factored out http server related code into zenhttp module since it feels out of place in zencore
Diffstat (limited to 'zenhttp/iothreadpool.h')
-rw-r--r--zenhttp/iothreadpool.h31
1 files changed, 31 insertions, 0 deletions
diff --git a/zenhttp/iothreadpool.h b/zenhttp/iothreadpool.h
new file mode 100644
index 000000000..f64868540
--- /dev/null
+++ b/zenhttp/iothreadpool.h
@@ -0,0 +1,31 @@
+// Copyright Epic Games, Inc. All Rights Reserved.
+
+#pragma once
+
+#include <zencore/windows.h>
+
+namespace zen {
+
+//////////////////////////////////////////////////////////////////////////
+//
+// Thread pool. Implemented in terms of Windows thread pool right now, will
+// need a cross-platform implementation eventually
+//
+
+class WinIoThreadPool
+{
+public:
+ WinIoThreadPool(int InThreadCount);
+ ~WinIoThreadPool();
+
+ void CreateIocp(HANDLE IoHandle, PTP_WIN32_IO_CALLBACK Callback, void* Context);
+ inline PTP_IO Iocp() const { return m_ThreadPoolIo; }
+
+private:
+ PTP_POOL m_ThreadPool = nullptr;
+ PTP_CLEANUP_GROUP m_CleanupGroup = nullptr;
+ PTP_IO m_ThreadPoolIo = nullptr;
+ TP_CALLBACK_ENVIRON m_CallbackEnvironment;
+};
+
+} // namespace zen