From 15ac2595aa96a0c1a29fe6a1927a4366dd03f3f4 Mon Sep 17 00:00:00 2001
From: Arceliar <Arceliar@users.noreply.github.com>
Date: Sun, 17 May 2020 08:22:02 -0500
Subject: [PATCH] use a dedicated per-stream writer goroutine, send messages to
 it over a 1-buffered channel, this eliminates most of the false positive
 blocking that causes drops

---
 src/yggdrasil/link.go | 21 +++++++++++++++++++--
 1 file changed, 19 insertions(+), 2 deletions(-)

diff --git a/src/yggdrasil/link.go b/src/yggdrasil/link.go
index 8098950..d439c30 100644
--- a/src/yggdrasil/link.go
+++ b/src/yggdrasil/link.go
@@ -256,6 +256,11 @@ func (intf *linkInterface) handler() error {
 		intf.link.core.log.Infof("Disconnected %s: %s, source %s",
 			strings.ToUpper(intf.info.linkType), themString, intf.info.local)
 	}
+	intf.writer.Act(nil, func() {
+		if intf.writer.worker != nil {
+			close(intf.writer.worker)
+		}
+	})
 	return err
 }
 
@@ -428,7 +433,8 @@ func (intf *linkInterface) notifyDoKeepAlive() {
 
 type linkWriter struct {
 	phony.Inbox
-	intf *linkInterface
+	intf   *linkInterface
+	worker chan [][]byte
 }
 
 func (w *linkWriter) sendFrom(from phony.Actor, bss [][]byte, isLinkTraffic bool) {
@@ -437,8 +443,19 @@ func (w *linkWriter) sendFrom(from phony.Actor, bss [][]byte, isLinkTraffic bool
 		for _, bs := range bss {
 			size += len(bs)
 		}
+		if w.worker == nil {
+			w.worker = make(chan [][]byte, 1)
+			go func() {
+				for bss := range w.worker {
+					w.intf.msgIO.writeMsgs(bss)
+				}
+			}()
+		}
 		w.intf.notifySending(size, isLinkTraffic)
-		w.intf.msgIO.writeMsgs(bss)
+		func() {
+			defer func() { recover() }()
+			w.worker <- bss
+		}()
 		w.intf.notifySent(size, isLinkTraffic)
 	})
 }