Fix UDP buffer size

bzEq · Dec 15, 2023 · ab80acd · ab80acd
1 parent bfe6890
commit ab80acd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/port.go b/core/port.go
@@ -64,7 +64,7 @@ func (self *RawNetPort) Unpack(b *iovec.IoVec) error {
 	if err := self.C.SetReadDeadline(time.Now().Add(self.timeout)); err != nil {
 		return err
 	}
-	if self.lastRead == 0 {
+	if self.lastRead == 0 || self.lastRead < DEFAULT_UDP_BUFFER_SIZE {
 		self.lastRead = DEFAULT_BUFFER_SIZE
 	}
 	buf := make([]byte, self.lastRead*6/5)