From a8b323acdd2236fb3f984cee6829395829196d14 Mon Sep 17 00:00:00 2001
From: Arceliar <Arceliar@users.noreply.github.com>
Date: Tue, 27 Aug 2019 20:01:37 -0500
Subject: [PATCH] have an actor manage the crypto worker pool instead of each
 session trying to use it directly, this should result in a fairer round-robin
 behavior in cases where crypto congestion is the bottleneck

---
 src/yggdrasil/session.go | 16 ++++++++++++++--
 1 file changed, 14 insertions(+), 2 deletions(-)

diff --git a/src/yggdrasil/session.go b/src/yggdrasil/session.go
index 06780e65..9abfeca6 100644
--- a/src/yggdrasil/session.go
+++ b/src/yggdrasil/session.go
@@ -482,6 +482,18 @@ func (ss *sessions) reset() {
 //////////////////////////// Worker Functions Below ////////////////////////////
 ////////////////////////////////////////////////////////////////////////////////
 
+type sessionCryptoManager struct {
+	phony.Inbox
+}
+
+func (m *sessionCryptoManager) workerGo(from phony.Actor, f func()) {
+	m.Act(from, func() {
+		util.WorkerGo(f)
+	})
+}
+
+var manager = sessionCryptoManager{}
+
 type FlowKeyMessage struct {
 	FlowKey uint64
 	Message []byte
@@ -527,7 +539,7 @@ func (sinfo *sessionInfo) _recvPacket(p *wire_trafficPacket) {
 		sinfo.checkCallbacks()
 	}
 	sinfo.callbacks = append(sinfo.callbacks, ch)
-	util.WorkerGo(poolFunc)
+	manager.workerGo(sinfo, poolFunc)
 }
 
 func (sinfo *sessionInfo) _send(msg FlowKeyMessage) {
@@ -570,7 +582,7 @@ func (sinfo *sessionInfo) _send(msg FlowKeyMessage) {
 		sinfo.checkCallbacks()
 	}
 	sinfo.callbacks = append(sinfo.callbacks, ch)
-	util.WorkerGo(poolFunc)
+	manager.workerGo(sinfo, poolFunc)
 }
 
 func (sinfo *sessionInfo) checkCallbacks() {