apps/pg
1
0
Fork 0
mirror of https://github.com/sigcn/pg.git synced 2025-10-29 09:42:37 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

disco: fix ws reconnect failed

Browse Source
This commit is contained in:
rkonfj
2024-02-04 12:47:44 +08:00
parent 4946daddc8
commit cc754ca826
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
disco/ws.go
View File

@@ -40,6 +40,7 @@ func DialPeermapServer(peermapServers peer.PeermapCluster, secret peer.NetworkSe
peermap, err := url.Parse(server)
if err != nil {
slog.Error("invalid server format", "server", server, "err", err)
continue
}
if peermap.Scheme == "http" {
@@ -55,6 +56,7 @@ func DialPeermapServer(peermapServers peer.PeermapCluster, secret peer.NetworkSe
return nil, 0, nil, fmt.Errorf("join network denied: %s", secret)
}
if err != nil {
slog.Error("dial server error", "server", server, "err", err)
continue
}
slog.Info("PeermapConnected", "server", server)
@@ -119,7 +121,7 @@ func (c *WSConn) runWebSocketEventLoop() {
c.stuns = stuns
break
}
return
continue
}
switch mt {
case websocket.PingMessage: