diff options
| author | chris.lu@gmail.com <chris.lu@gmail.com@282b0af5-e82d-9cf1-ede4-77906d7719d0> | 2011-12-27 01:51:18 +0000 |
|---|---|---|
| committer | chris.lu@gmail.com <chris.lu@gmail.com@282b0af5-e82d-9cf1-ede4-77906d7719d0> | 2011-12-27 01:51:18 +0000 |
| commit | b2f4a4e7391cf0f9df655c036747a4d3c79f29fb (patch) | |
| tree | 01ed7ef85b98516d0221d51f2389cdf169af9dd8 /weed-fs/src/cmd | |
| parent | 3c98f1a119104f91b5c3ce7f3778e1b1a9a72717 (diff) | |
| download | seaweedfs-b2f4a4e7391cf0f9df655c036747a4d3c79f29fb.tar.xz seaweedfs-b2f4a4e7391cf0f9df655c036747a4d3c79f29fb.zip | |
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
Diffstat (limited to 'weed-fs/src/cmd')
| -rw-r--r-- | weed-fs/src/cmd/weedc.go | 4 | ||||
| -rw-r--r-- | 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) { |