Add time-based fast write strategy for czar

Author: mohanson

protocol/czar/mux.go

@@ -4,6 +4,7 @@ import (
 	"encoding/binary"
 	"io"
 	"sync"
+	"time"
 
 	"github.com/mohanson/daze/lib/doa"
 	"github.com/mohanson/daze/lib/priority"
@@ -13,6 +14,7 @@ import (
 type Stream struct {
 	idx uint8
 	mux *Mux
+	qtw time.Time
 	rbf []byte
 	rch chan []byte
 	rer *Err
@@ -85,6 +87,7 @@ func (s *Stream) Write(p []byte) (int, error) {
 		buf []byte
 		l   = 0
 		n   = 0
+		z   = 0
 	)
 	for {
 		switch {
@@ -102,7 +105,13 @@ func (s *Stream) Write(p []byte) (int, error) {
 		binary.BigEndian.PutUint16(buf[2:4], uint16(l))
 		copy(buf[4:], p[:l])
 		p = p[l:]
-		err := s.mux.pri.Pri(1, func() error {
+		z = func() int {
+			if time.Now().After(s.qtw) {
+				return 2
+			}
+			return 1
+		}()
+		err := s.mux.pri.Pri(z, func() error {
 			if err := s.wer.Get(); err != nil {
 				return err
 			}
@@ -125,6 +134,7 @@ func NewStream(idx uint8, mux *Mux) *Stream {
 	return &Stream{
 		idx: idx,
 		mux: mux,
+		qtw: time.Now().Add(time.Second * 8),
 		rbf: make([]byte, 0),
 		rch: make(chan []byte, 32),
 		rer: NewErr(),
@@ -254,7 +264,7 @@ func NewMux(conn io.ReadWriteCloser) *Mux {
 		ach: make(chan *Stream),
 		con: conn,
 		idp: NewSip(),
-		pri: priority.NewPriority(2),
+		pri: priority.NewPriority(3),
 		rer: NewErr(),
 		usb: make([]*Stream, 256),
 	}