Optimize fast write strategy

Author: mohanson

protocol/czar/mux.go

@@ -1,6 +1,7 @@
 package czar
 
 import (
+	"cmp"
 	"encoding/binary"
 	"io"
 	"sync"
@@ -12,7 +13,7 @@ import (
 
 // A Stream managed by the multiplexer.
 type Stream struct {
-	fwu time.Time
+	cat time.Time
 	idx uint8
 	mux *Mux
 	rbf []byte
@@ -87,7 +88,7 @@ func (s *Stream) Write(p []byte) (int, error) {
 		buf []byte
 		l   = 0
 		n   = 0
-		z   = 1
+		z   = 0
 	)
 	for {
 		switch {
@@ -105,9 +106,9 @@ func (s *Stream) Write(p []byte) (int, error) {
 		binary.BigEndian.PutUint16(buf[2:4], uint16(l))
 		copy(buf[4:], p[:l])
 		p = p[l:]
-		if time.Now().After(s.fwu) {
-			z = 2
-		}
+		z = 2 - max(cmp.Compare(Conf.FastWriteDuration-time.Since(s.cat), 0), 0)
+		doa.Doa(z >= 1)
+		doa.Doa(z <= 2)
 		err := s.mux.pri.Pri(z, func() error {
 			if err := s.wer.Get(); err != nil {
 				return err
@@ -129,7 +130,7 @@ func (s *Stream) Write(p []byte) (int, error) {
 // NewStream returns a new Stream.
 func NewStream(idx uint8, mux *Mux) *Stream {
 	return &Stream{
-		fwu: time.Now().Add(Conf.FastWriteDuration),
+		cat: time.Now(),
 		idx: idx,
 		mux: mux,
 		rbf: make([]byte, 0),