Skip to content
This repository was archived by the owner on Feb 19, 2025. It is now read-only.

Commit 742cddc

Browse files
author
takt
authored
Merge pull request #114 from rkosegi/issue/113
Check for error before deferring to close resource
2 parents 2b94619 + 742114d commit 742cddc

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

utils/utils.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -277,21 +277,21 @@ func UDPRoutine(name string, decodeFunc decoder.DecoderFunc, workers int, addr s
277277

278278
if sockReuse {
279279
pconn, err := reuseport.ListenPacket("udp", addrUDP.String())
280-
defer pconn.Close()
281280
if err != nil {
282281
return err
283282
}
283+
defer pconn.Close()
284284
var ok bool
285285
udpconn, ok = pconn.(*net.UDPConn)
286286
if !ok {
287287
return err
288288
}
289289
} else {
290290
udpconn, err = net.ListenUDP("udp", &addrUDP)
291-
defer udpconn.Close()
292291
if err != nil {
293292
return err
294293
}
294+
defer udpconn.Close()
295295
}
296296

297297
payload := make([]byte, 9000)

0 commit comments

Comments
 (0)