sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-07-16 19:49:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Open peer connection directly in PeerConnOpen

Browse Source
This commit is contained in:
Viktor Liu
2026-06-29 17:12:36 +02:00
parent e01c828f35
commit 57170cdaca
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
client/internal/peerstore/store.go
View File

@@ -81,7 +81,16 @@ func (s *Store) PeerConn(pubKey string) (*peer.Conn, bool) {
}
func (s *Store) PeerConnOpen(ctx context.Context, pubKey string) {
s.PeerConnOpenWithFirstPacket(ctx, pubKey, nil)
s.peerConnsMu.RLock()
defer s.peerConnsMu.RUnlock()
p, ok := s.peerConns[pubKey]
if !ok {
return
}
if err := p.Open(ctx); err != nil {
p.Log.Errorf("failed to open peer connection: %v", err)
}
}
// PeerConnOpenWithFirstPacket opens the peer connection and stashes a first packet to be
@@ -94,7 +103,6 @@ func (s *Store) PeerConnOpenWithFirstPacket(ctx context.Context, pubKey string,
if !ok {
return
}
// this can be blocked because of the connect open limiter semaphore
if err := p.OpenWithFirstPacket(ctx, firstPacket); err != nil {
p.Log.Errorf("failed to open peer connection: %v", err)
}