|
|
@ -158,7 +158,7 @@ func PostHandler(w http.ResponseWriter, r *http.Request) { |
|
|
|
needToReplicate := !store.HasVolume(volumeId) |
|
|
|
if ret > 0 { |
|
|
|
needToReplicate = needToReplicate || store.GetVolume(volumeId).NeedToReplicate() |
|
|
|
}else{ |
|
|
|
} else { |
|
|
|
errorStatus = "Failed to write to local disk" |
|
|
|
} |
|
|
|
if !needToReplicate && ret > 0 { |
|
|
@ -316,8 +316,19 @@ func runVolume(cmd *Command, args []string) bool { |
|
|
|
http.HandleFunc("/admin/vacuum_volume_commit", vacuumVolumeCommitHandler) |
|
|
|
|
|
|
|
go func() { |
|
|
|
connected := true |
|
|
|
for { |
|
|
|
store.Join(*masterNode) |
|
|
|
err := store.Join(*masterNode) |
|
|
|
if err == nil { |
|
|
|
if !connected { |
|
|
|
connected = true |
|
|
|
log.Println("Reconnected with master") |
|
|
|
} |
|
|
|
} else { |
|
|
|
if connected { |
|
|
|
connected = false |
|
|
|
} |
|
|
|
} |
|
|
|
time.Sleep(time.Duration(float32(*vpulse*1e3)*(1+rand.Float32())) * time.Millisecond) |
|
|
|
} |
|
|
|
}() |
|
|
|