Re-clone network.hpp from libbitcoin-network.

Author: evoskuil

include/bitcoin/protocol/network.hpp

@@ -24,22 +24,29 @@
 // config::authority and config::endpoint are also cloned from network.
 
 #include <memory>
+#include <thread>
 #include <bitcoin/system.hpp>
 
 #ifdef HAVE_MSC
     #include <windows.h>
+    // #define THREAD_PRIORITY_IDLE            -15
+    // #define THREAD_PRIORITY_LOWEST          -2
+    // #define THREAD_PRIORITY_BELOW_NORMAL    -1
+    // #define THREAD_PRIORITY_NORMAL           0
+    // #define THREAD_PRIORITY_ABOVE_NORMAL     1
+    // #define THREAD_PRIORITY_HIGHEST          2
+    // #define THREAD_PRIORITY_TIME_CRITICAL    15
+    // #define THREAD_PRIORITY_ERROR_RETURN    (MAXLONG)
 #else
     #include <unistd.h>
     #include <pthread.h>
     #include <sys/resource.h>
     #include <sys/types.h>
-    #ifndef PRIO_MAX
-        #define PRIO_MAX 20
-    #endif
-    #define THREAD_PRIORITY_ABOVE_NORMAL (-2)
-    #define THREAD_PRIORITY_NORMAL 0
-    #define THREAD_PRIORITY_BELOW_NORMAL 2
-    #define THREAD_PRIORITY_LOWEST PRIO_MAX
+    #define THREAD_PRIORITY_HIGHEST             -20
+    #define THREAD_PRIORITY_ABOVE_NORMAL        -2
+    #define THREAD_PRIORITY_NORMAL               0
+    #define THREAD_PRIORITY_BELOW_NORMAL         2
+    #define THREAD_PRIORITY_LOWEST               20
 #endif
 
 namespace libbitcoin {
@@ -62,6 +69,7 @@ class enable_shared_from_base
 
 enum class thread_priority
 {
+    highest,
     high,
     normal,
     low,
@@ -79,26 +87,43 @@ inline int get_priority(thread_priority priority) NOEXCEPT
             return THREAD_PRIORITY_BELOW_NORMAL;
         case thread_priority::high:
             return THREAD_PRIORITY_ABOVE_NORMAL;
+        case thread_priority::highest:
+            return THREAD_PRIORITY_HIGHEST;
         default:
         case thread_priority::normal:
             return THREAD_PRIORITY_NORMAL;
     }
 }
 
-// Set the thread priority (or process if thread priority is not available).
+// Set the thread priority.
+// TODO: handle error conditions.
+// TODO: handle potential lack of PRIO_THREAD
+// TODO: use proper non-win32 priority levels.
+// TODO: Linux: pthread_setschedprio()
+// TOOD: macOS: somethign else.
 inline void set_priority(thread_priority priority) NOEXCEPT
 {
     const auto prioritization = get_priority(priority);
 
-    BC_PUSH_WARNING(NO_THROW_IN_NOEXCEPT)
 #if defined(HAVE_MSC)
+    // learn.microsoft.com/en-us/windows/win32/api/processthreadsapi/
+    // nf-processthreadsapi-getthreadpriority
     SetThreadPriority(GetCurrentThread(), prioritization);
+
 #elif defined(PRIO_THREAD)
+    // lore.kernel.org/lkml/[email protected]/
     setpriority(PRIO_THREAD, pthread_self(), prioritization);
+
 #else
+    // BUGBUG: This will set all threads in the process.
+    // man7.org/linux/man-pages/man3/pthread_self.3.html
     setpriority(PRIO_PROCESS, getpid(), prioritization);
 #endif
-    BC_POP_WARNING()
+}
+
+inline size_t cores() NOEXCEPT
+{
+    return std::max(std::thread::hardware_concurrency(), 1_u32);
 }
 
 } // namespace protocol