Browse Source

Add defer

RPRX 5 years ago
parent
commit
8c2e8e9db9
1 changed files with 3 additions and 0 deletions
  1. 3 0
      proxy/vless/inbound/inbound.go

+ 3 - 0
proxy/vless/inbound/inbound.go

@@ -167,6 +167,8 @@ func (h *Handler) Process(ctx context.Context, network net.Network, connection i
 	} else {
 	} else {
 		request, requestAddons, err, pre = encoding.DecodeRequestHeader(reader, h.validator)
 		request, requestAddons, err, pre = encoding.DecodeRequestHeader(reader, h.validator)
 		if pre == nil {
 		if pre == nil {
+			defer pre.Release()
+		} else {
 			isfb = false
 			isfb = false
 		}
 		}
 	}
 	}
@@ -286,6 +288,7 @@ func (h *Handler) Process(ctx context.Context, network net.Network, connection i
 						}
 						}
 					}
 					}
 					pro := buf.New()
 					pro := buf.New()
+					defer pro.Release()
 					switch fb.Xver {
 					switch fb.Xver {
 					case 1:
 					case 1:
 						if ipv4 {
 						if ipv4 {