sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-09-01 04:21:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix lint issues

Browse Source
This commit is contained in:
Zoltán Papp
2024-08-15 11:09:47 +02:00
parent a8e1e5139b
commit 22f5ca8490
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
relay/testec2/turn.go
View File

@@ -103,11 +103,11 @@ func runTurnReading(d *tun.Device, durations chan time.Duration) {
if err != nil {
log.Fatalf("failed to listen on tcp: %s", err)
}
defer tcpListener.Close()
log := log.WithField("device", tcpListener.Addr())
tcpConn, err := tcpListener.Accept()
if err != nil {
_ = tcpListener.Close()
log.Fatalf("failed to accept connection: %s", err)
}
log.Infof("remote peer connected")
@@ -115,6 +115,7 @@ func runTurnReading(d *tun.Device, durations chan time.Duration) {
buf := make([]byte, 103)
n, err := tcpConn.Read(buf)
if err != nil {
_ = tcpListener.Close()
log.Fatalf(errMsgFailedReadTCP, err)
}
@@ -124,12 +125,14 @@ func runTurnReading(d *tun.Device, durations chan time.Duration) {
buf = make([]byte, 8192)
i, err := tcpConn.Read(buf)
if err != nil {
_ = tcpListener.Close()
log.Fatalf(errMsgFailedReadTCP, err)
}
now := time.Now()
for i < si.TransferSize {
n, err := tcpConn.Read(buf)
if err != nil {
_ = tcpListener.Close()
log.Fatalf(errMsgFailedReadTCP, err)
}
i += n