Browse Source

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
pull/2/head
chris.lu@gmail.com 13 years ago
parent
commit
b2f4a4e739
  1. 4
      weed-fs/src/cmd/weedc.go
  2. 2
      weed-fs/src/cmd/weeds.go

4
weed-fs/src/cmd/weedc.go

@ -8,6 +8,7 @@ import (
"json" "json"
"log" "log"
"mime" "mime"
"rand"
"strconv" "strconv"
"strings" "strings"
"time" "time"
@ -136,7 +137,8 @@ func main() {
go func() { go func() {
for { for {
store.Join(*metaServer) store.Join(*metaServer)
time.Sleep(int64(*pulse) * 1e9)
ns := int64(*pulse) * 1e9
time.Sleep(ns + rand.Int63()%ns)
} }
}() }()
log.Println("store joined at", *metaServer) log.Println("store joined at", *metaServer)

2
weed-fs/src/cmd/weeds.go

@ -43,7 +43,7 @@ func dirJoinHandler(w http.ResponseWriter, r *http.Request) {
publicUrl := r.FormValue("publicUrl") publicUrl := r.FormValue("publicUrl")
volumes := new([]storage.VolumeInfo) volumes := new([]storage.VolumeInfo)
json.Unmarshal([]byte(r.FormValue("volumes")), volumes) 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)) mapper.Add(*directory.NewMachine(s, publicUrl, *volumes))
} }
func dirStatusHandler(w http.ResponseWriter, r *http.Request) { func dirStatusHandler(w http.ResponseWriter, r *http.Request) {

Loading…
Cancel
Save