dynamic priority for memory reservation; first buffer is an always.

libp2p · Feb 28, 2022 · abd728e · abd728e
1 parent 3b7b43d
commit abd728e
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/multiplex.go b/multiplex.go
@@ -116,7 +116,16 @@ func NewMultiplex(con net.Conn, initiator bool, memoryManager MemoryManager) (*M
 	bufs := 0
 	var err error
 	for i := 0; i < MaxBuffers; i++ {
-		if err = mp.memoryManager.ReserveMemory(2*MaxMessageSize, 128); err != nil {
+		var prio uint8
+		switch bufs {
+		case 0:
+			prio = 255
+		case 1:
+			prio = 192
+		default:
+			prio = 128
+		}
+		if err = mp.memoryManager.ReserveMemory(2*MaxMessageSize, prio); err != nil {
 			break
 		}
 		bufs++