Merge branch 'blockable-affinity' into 'master'

[Blockable] Support worker affinity in PrivateSemaphore.signalFromAnywhere()

See merge request i4/manycore/emper!187

emper/Blockable.hpp

@@ -22,6 +22,8 @@ class Blockable : public Logger<logSubsystem> {
 
 	ContextManager& contextManager;
 
+	workeraffinity_t* affinity = nullptr;
+
 	Blockable(Runtime& runtime) : runtime(runtime), contextManager(runtime.getContextManager()) {}
 
 	// Older clang-tidy versions show a
@@ -47,7 +49,7 @@ class Blockable : public Logger<logSubsystem> {
 			blockedContexts.erase(context);
 		}
 
-		return Fiber::from([this, context]() { contextManager.discardAndResume(context); });
+		return Fiber::from([this, context]() { contextManager.discardAndResume(context); }, affinity);
 	}
 
 	template <CallerEnvironment callerEnvironment = CallerEnvironment::EMPER>

emper/PrivateSemaphore.hpp

@@ -46,7 +46,10 @@ class PrivateSemaphore : protected Blockable<LogSubsystem::PS> {
 		return nullptr;
 	}
 
-	void signalFromAnywhere() { signal<CallerEnvironment::ANYWHERE>(); }
+	void signalFromAnywhere(workeraffinity_t* affinity = nullptr) {
+		this->affinity = affinity;
+		signal<CallerEnvironment::ANYWHERE>();
+	}
 
 	void signalAndExit() {
 		if (Context* readyContext = signalInternal()) {

emper/io/Future.cpp

@@ -11,7 +11,6 @@
 #include "BinaryPrivateSemaphore.hpp"	 // for BPS
 #include "CallerEnvironment.hpp"			 // for CallerEnvironment
 #include "Debug.hpp"									 // for LOGD, LOGW
-#include "Runtime.hpp"								 // for Runtime
 #include "io/IoContext.hpp"						 // for IoContext
 #include "io/Stats.hpp"								 // for Stats, Operation