From ea508727de13c74b82adf35b79fb42de0a14a829 Mon Sep 17 00:00:00 2001
From: patterniha <71074308+patterniha@users.noreply.github.com>
Date: Sun, 31 Aug 2025 01:37:12 +0330
Subject: [PATCH] add buffer

---
 proxy/trojan/server.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/proxy/trojan/server.go b/proxy/trojan/server.go
index 8ed3b0e6..02c36f2e 100644
--- a/proxy/trojan/server.go
+++ b/proxy/trojan/server.go
@@ -253,6 +253,7 @@ func (s *Server) handleUDPPayload(ctx context.Context, sessionPolicy policy.Sess
 	defer cancel()
 	timer := signal.CancelAfterInactivity(ctx, cancel, sessionPolicy.Timeouts.ConnectionIdle)
 	defer timer.SetTimeout(0)
+	ctx = policy.ContextWithBufferPolicy(ctx, sessionPolicy.Buffer)
 	udpServer := udp.NewDispatcher(dispatcher, func(ctx context.Context, packet *udp_proto.Packet) {
 		udpPayload := packet.Payload
 		if udpPayload.UDP == nil {