mirror of
https://github.com/netbirdio/ice.git
synced 2026-05-22 17:10:58 -07:00
Fix linter warnings
Fix linter warnings
This commit is contained in:
@@ -328,10 +328,9 @@ func NewAgent(config *AgentConfig) (*Agent, error) { //nolint:gocognit
|
||||
}
|
||||
}
|
||||
|
||||
a.mDNSConn, mDNSMode, err = createMulticastDNS(a.net, mDNSMode, mDNSName, log)
|
||||
// Opportunistic mDNS: If we can't open the connection, that's ok: we
|
||||
// can continue without it.
|
||||
if err != nil {
|
||||
if a.mDNSConn, a.mDNSMode, err = createMulticastDNS(a.net, mDNSMode, mDNSName, log); err != nil {
|
||||
log.Warnf("Failed to initialize mDNS %s: %v", mDNSName, err)
|
||||
}
|
||||
closeMDNSConn := func() {
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
// Package ice ...
|
||||
//
|
||||
//nolint:dupl
|
||||
package ice
|
||||
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
// Package ice ...
|
||||
//
|
||||
//nolint:dupl
|
||||
package ice
|
||||
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
// Package main implements a simple example demonstrating a Pion-to-Pion ICE connection
|
||||
package main
|
||||
|
||||
import (
|
||||
@@ -14,7 +15,7 @@ import (
|
||||
"github.com/pion/randutil"
|
||||
)
|
||||
|
||||
//nolint
|
||||
// nolint:gochecknoglobals
|
||||
var (
|
||||
isControlling bool
|
||||
iceAgent *ice.Agent
|
||||
@@ -43,7 +44,7 @@ func remoteCandidate(w http.ResponseWriter, r *http.Request) {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
if err := iceAgent.AddRemoteCandidate(c); err != nil {
|
||||
if err := iceAgent.AddRemoteCandidate(c); err != nil { //nolint:contextcheck
|
||||
panic(err)
|
||||
}
|
||||
}
|
||||
@@ -69,7 +70,7 @@ func main() { //nolint
|
||||
http.HandleFunc("/remoteAuth", remoteAuth)
|
||||
http.HandleFunc("/remoteCandidate", remoteCandidate)
|
||||
go func() {
|
||||
if err = http.ListenAndServe(fmt.Sprintf(":%d", localHTTPPort), nil); err != nil {
|
||||
if err = http.ListenAndServe(fmt.Sprintf(":%d", localHTTPPort), nil); err != nil { //nolint:gosec
|
||||
panic(err)
|
||||
}
|
||||
}()
|
||||
|
||||
@@ -622,9 +622,9 @@ func (a *Agent) gatherCandidatesRelay(ctx context.Context, urls []*URL) { //noli
|
||||
relayProtocol = "dtls"
|
||||
locConn = &fakePacketConn{conn}
|
||||
case url.Proto == ProtoTypeTCP && url.Scheme == SchemeTypeTURNS:
|
||||
tcpAddr, err := a.net.ResolveTCPAddr(NetworkTypeTCP4.String(), TURNServerAddr)
|
||||
if err != nil {
|
||||
a.log.Warnf("Failed to resolve relay address %s: %v", TURNServerAddr, err)
|
||||
tcpAddr, resolvErr := a.net.ResolveTCPAddr(NetworkTypeTCP4.String(), TURNServerAddr)
|
||||
if resolvErr != nil {
|
||||
a.log.Warnf("Failed to resolve relay address %s: %v", TURNServerAddr, resolvErr)
|
||||
return
|
||||
}
|
||||
|
||||
@@ -638,9 +638,11 @@ func (a *Agent) gatherCandidatesRelay(ctx context.Context, urls []*URL) { //noli
|
||||
InsecureSkipVerify: a.insecureSkipVerify, //nolint:gosec
|
||||
})
|
||||
|
||||
if err := conn.HandshakeContext(ctx); err != nil {
|
||||
tcpConn.Close()
|
||||
a.log.Warnf("Failed to connect to relay: %v", dialErr)
|
||||
if hsErr := conn.HandshakeContext(ctx); hsErr != nil {
|
||||
if closeErr := tcpConn.Close(); closeErr != nil {
|
||||
a.log.Errorf("Failed to close relay connection: %v", closeErr)
|
||||
}
|
||||
a.log.Warnf("Failed to connect to relay: %v", hsErr)
|
||||
return
|
||||
}
|
||||
|
||||
|
||||
+1
-1
@@ -218,7 +218,7 @@ func UDPMuxFromPortWithLoopback() UDPMuxFromPortOption {
|
||||
}
|
||||
}
|
||||
|
||||
// UDPMuxFromPortWithLoopback set loopback interface should be included
|
||||
// UDPMuxFromPortWithNet set loopback interface should be included
|
||||
func UDPMuxFromPortWithNet(n transport.Net) UDPMuxFromPortOption {
|
||||
return &udpMuxFromPortOption{
|
||||
f: func(p *multiUDPMuxFromPortParam) {
|
||||
|
||||
Reference in New Issue
Block a user