mirror of
https://github.com/siyuan-note/siyuan.git
synced 2025-12-17 15:10:12 +01:00
🎨 Improve ws reconnect
This commit is contained in:
parent
82157cba9e
commit
552eb9bec6
1 changed files with 4 additions and 1 deletions
|
|
@ -695,6 +695,10 @@ func connectSyncWebSocket() {
|
||||||
reconnected := false
|
reconnected := false
|
||||||
for retries := 0; retries < 7; retries++ {
|
for retries := 0; retries < 7; retries++ {
|
||||||
time.Sleep(7 * time.Second)
|
time.Sleep(7 * time.Second)
|
||||||
|
if nil == Conf.User {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
//logging.LogInfof("reconnecting sync websocket...")
|
//logging.LogInfof("reconnecting sync websocket...")
|
||||||
webSocketConn, dialErr = dialSyncWebSocket()
|
webSocketConn, dialErr = dialSyncWebSocket()
|
||||||
if nil != dialErr {
|
if nil != dialErr {
|
||||||
|
|
@ -743,7 +747,6 @@ func connectSyncWebSocket() {
|
||||||
var KernelID = gulu.Rand.String(7)
|
var KernelID = gulu.Rand.String(7)
|
||||||
|
|
||||||
func dialSyncWebSocket() (c *websocket.Conn, err error) {
|
func dialSyncWebSocket() (c *websocket.Conn, err error) {
|
||||||
//endpoint := "ws://127.0.0.1:64388" + "/apis/siyuan/dejavu/ws"
|
|
||||||
endpoint := util.GetCloudWebSocketServer() + "/apis/siyuan/dejavu/ws"
|
endpoint := util.GetCloudWebSocketServer() + "/apis/siyuan/dejavu/ws"
|
||||||
header := http.Header{
|
header := http.Header{
|
||||||
"x-siyuan-uid": []string{Conf.User.UserId},
|
"x-siyuan-uid": []string{Conf.User.UserId},
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue