diff --git a/weed-fs/src/cmd/weedc.go b/weed-fs/src/cmd/weedc.go index 9336c1775..6d40b9586 100644 --- a/weed-fs/src/cmd/weedc.go +++ b/weed-fs/src/cmd/weedc.go @@ -8,6 +8,7 @@ import ( "json" "log" "mime" + "rand" "strconv" "strings" "time" @@ -136,7 +137,8 @@ func main() { go func() { for { store.Join(*metaServer) - time.Sleep(int64(*pulse) * 1e9) + ns := int64(*pulse) * 1e9 + time.Sleep(ns + rand.Int63()%ns) } }() log.Println("store joined at", *metaServer) diff --git a/weed-fs/src/cmd/weeds.go b/weed-fs/src/cmd/weeds.go index 4eab3fe73..065813ae1 100644 --- a/weed-fs/src/cmd/weeds.go +++ b/weed-fs/src/cmd/weeds.go @@ -43,7 +43,7 @@ func dirJoinHandler(w http.ResponseWriter, r *http.Request) { publicUrl := r.FormValue("publicUrl") volumes := new([]storage.VolumeInfo) json.Unmarshal([]byte(r.FormValue("volumes")), volumes) - log.Println("Recieved updates from", s, "volumes", r.FormValue("volumes")) + log.Println(s, "volumes", r.FormValue("volumes")) mapper.Add(*directory.NewMachine(s, publicUrl, *volumes)) } func dirStatusHandler(w http.ResponseWriter, r *http.Request) {