From b2f4a4e7391cf0f9df655c036747a4d3c79f29fb Mon Sep 17 00:00:00 2001 From: "chris.lu@gmail.com" Date: Tue, 27 Dec 2011 01:51:18 +0000 Subject: [PATCH] adjust weedc heartbeat to be randomly between (1*pulse, 2*pulse) seconds git-svn-id: https://weed-fs.googlecode.com/svn/trunk@29 282b0af5-e82d-9cf1-ede4-77906d7719d0 --- weed-fs/src/cmd/weedc.go | 4 +++- weed-fs/src/cmd/weeds.go | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) 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) {