Skip to content

Commit 8ec3640

Browse files
committed
Remove unused context.
1 parent 866960c commit 8ec3640

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

service/udp.go

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515
package service
1616

1717
import (
18-
"context"
1918
"errors"
2019
"fmt"
2120
"net"
@@ -121,7 +120,7 @@ func (h *packetHandler) Handle(clientConn net.PacketConn) {
121120

122121
for {
123122
status := "OK"
124-
keyID, clientInfo, proxyMetrics, connErr := h.handleConnection(context.TODO(), clientConn)
123+
keyID, clientInfo, proxyMetrics, connErr := h.handleConnection(clientConn)
125124
if connErr != nil {
126125
if errors.Is(connErr.Cause, net.ErrClosed) {
127126
break
@@ -159,7 +158,7 @@ func (h *packetHandler) authenticate(clientConn net.PacketConn) (net.Addr, *Ciph
159158
return clientAddr, cipherEntry, textData, clientProxyBytes, nil
160159
}
161160

162-
func (h *packetHandler) proxyConnection(ctx context.Context, clientAddr net.Addr, tgtAddr net.Addr, clientConn net.PacketConn, cipherEntry CipherEntry, payload []byte, proxyMetrics *metrics.ProxyMetrics) (ipinfo.IPInfo, *onet.ConnectionError) {
161+
func (h *packetHandler) proxyConnection(clientAddr net.Addr, tgtAddr net.Addr, clientConn net.PacketConn, cipherEntry CipherEntry, payload []byte, proxyMetrics *metrics.ProxyMetrics) (ipinfo.IPInfo, *onet.ConnectionError) {
163162
tgtConn := h.nm.Get(clientAddr.String())
164163
if tgtConn == nil {
165164
clientInfo, locErr := ipinfo.GetIPInfoFromAddr(h.m, clientAddr)
@@ -183,7 +182,7 @@ func (h *packetHandler) proxyConnection(ctx context.Context, clientAddr net.Addr
183182
return tgtConn.clientInfo, nil
184183
}
185184

186-
func (h *packetHandler) handleConnection(ctx context.Context, clientConn net.PacketConn) (string, ipinfo.IPInfo, metrics.ProxyMetrics, *onet.ConnectionError) {
185+
func (h *packetHandler) handleConnection(clientConn net.PacketConn) (string, ipinfo.IPInfo, metrics.ProxyMetrics, *onet.ConnectionError) {
187186
defer func() {
188187
if r := recover(); r != nil {
189188
logger.Errorf("Panic in UDP loop: %v. Continuing to listen.", r)
@@ -204,7 +203,7 @@ func (h *packetHandler) handleConnection(ctx context.Context, clientConn net.Pac
204203
}
205204
debugUDPAddr(clientAddr, "Proxy exit %s", tgtAddr.String())
206205

207-
clientInfo, err := h.proxyConnection(ctx, clientAddr, tgtAddr, clientConn, *cipherEntry, payload, &proxyMetrics)
206+
clientInfo, err := h.proxyConnection(clientAddr, tgtAddr, clientConn, *cipherEntry, payload, &proxyMetrics)
208207
return cipherEntry.ID, clientInfo, proxyMetrics, err
209208
}
210209

0 commit comments

Comments
 (0)