diff --git a/cmd/main.go b/cmd/main.go index 1ce3727b..7209e05a 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -72,7 +72,11 @@ func initializeWorker() { } l.Close() - http.Handle("/metrics", promhttp.Handler()) + if port == 9000 { + // only turn on metric for the first worker to avoid overlap + http.Handle("/metrics", promhttp.Handler()) + } + http.ListenAndServe(":"+strconv.Itoa(port), nil) } } diff --git a/cws/cws.go b/cws/cws.go index eb4df532..2a5abebb 100644 --- a/cws/cws.go +++ b/cws/cws.go @@ -2,7 +2,6 @@ package cws import ( "encoding/json" - "fmt" "log" "sync" "time" @@ -158,10 +157,6 @@ func (c *Client) Listen() { } wspacket := WSPacket{} err = json.Unmarshal(rawMsg, &wspacket) - fmt.Println(wspacket) - if wspacket.ID == "checkLatency" { - fmt.Println("!!!!!!") - } if err != nil { continue diff --git a/overlord/handlers.go b/overlord/handlers.go index d8e5fa0e..9669267a 100644 --- a/overlord/handlers.go +++ b/overlord/handlers.go @@ -193,6 +193,7 @@ func (o *Server) findBestServerFromBrowser(client *BrowserClient) (string, error // TODO: Add timeout log.Println("Ping worker to get latency for ", client) latencies := o.getLatencyMapFromBrowser(client) + log.Println("Latency map", latencies) if len(latencies) == 0 { return "", errors.New("No server found")