Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom@tomclegg.ca>
wsURL := cluster.Services.Websocket.ExternalURL
wsURL.Scheme = strings.Replace(wsURL.Scheme, "http", "ws", 1)
wsURL.Path = "/websocket"
wsURL := cluster.Services.Websocket.ExternalURL
wsURL.Scheme = strings.Replace(wsURL.Scheme, "http", "ws", 1)
wsURL.Path = "/websocket"
+ wsURLNoToken := wsURL.String()
wsURL.RawQuery = url.Values{"api_token": []string{client.AuthToken}}.Encode()
conn, err := websocket.Dial(wsURL.String(), "", cluster.Services.Controller.ExternalURL.String())
if err != nil {
wsURL.RawQuery = url.Values{"api_token": []string{client.AuthToken}}.Encode()
conn, err := websocket.Dial(wsURL.String(), "", cluster.Services.Controller.ExternalURL.String())
if err != nil {
time.Sleep(5 * time.Second)
continue reconnect
}
time.Sleep(5 * time.Second)
continue reconnect
}
- log.Printf("connected to websocket at %s", wsURL)
+ log.Printf("connected to websocket at %s", wsURLNoToken)
client.mtx.Lock()
client.wsconn = conn
client.mtx.Lock()
client.wsconn = conn