diff --git a/proxy/socks/server_udp.go b/proxy/socks/server_udp.go index bc4da3c2f..34f5d2aeb 100644 --- a/proxy/socks/server_udp.go +++ b/proxy/socks/server_udp.go @@ -53,7 +53,7 @@ func (this *Server) handleUDPPayload(payload *alloc.Buffer, source v2net.Destina } log.Info("Socks: Writing back UDP response with ", payload.Len(), " bytes to ", destination) - udpMessage := alloc.NewSmallBuffer().Clear() + udpMessage := alloc.NewLocalBuffer(2048).Clear() response.Write(udpMessage) this.udpMutex.RLock() diff --git a/proxy/vmess/outbound/outbound.go b/proxy/vmess/outbound/outbound.go index 6ab99177c..bcdc6b124 100644 --- a/proxy/vmess/outbound/outbound.go +++ b/proxy/vmess/outbound/outbound.go @@ -108,7 +108,7 @@ func (this *VMessOutboundHandler) handleRequest(session *encoding.ClientSession, } if request.Option.Has(protocol.RequestOptionChunkStream) { - err := streamWriter.Write(alloc.NewSmallBuffer().Clear()) + err := streamWriter.Write(alloc.NewLocalBuffer(32).Clear()) if err != nil { conn.SetReusable(false) }