add buffer for udp read&write channel

nknorg · Aug 18, 2023 · e800a74 · e800a74
1 parent 2aef8b0
commit e800a74
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/entry.go b/entry.go
@@ -95,10 +95,6 @@ func NewTunaEntry(service Service, serviceInfo ServiceInfo, wallet *nkn.Wallet,
 		serviceConn:  make(map[byte]*net.UDPConn),
 		clientAddr:   cache.New(time.Duration(config.UDPTimeout)*time.Second, time.Second),
 	}
-
-	te.SetServerUDPReadChan(make(chan []byte))
-	te.SetServerUDPWriteChan(make(chan []byte))
-
 	return te, nil
 }
 

diff --git a/tuna.go b/tuna.go
@@ -248,8 +248,8 @@ func NewCommon(
 		reverseBytesEntryToExit: make(map[string][]uint64),
 		reverseBytesExitToEntry: make(map[string][]uint64),
 
-		udpReadChan:  make(chan []byte),
-		udpWriteChan: make(chan []byte),
+		udpReadChan:  make(chan []byte, 64),
+		udpWriteChan: make(chan []byte, 64),
 	}
 	c.minBalance, err = common.StringToFixed64(minBalance)
 	if err != nil {