diff options
Diffstat (limited to 'go/topology/topology_compact.go')
| -rw-r--r-- | go/topology/topology_compact.go | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/go/topology/topology_compact.go b/go/topology/topology_compact.go index 1e5c4dd11..45ddda174 100644 --- a/go/topology/topology_compact.go +++ b/go/topology/topology_compact.go @@ -5,7 +5,7 @@ import ( "code.google.com/p/weed-fs/go/util" "encoding/json" "errors" - "log" + "code.google.com/p/weed-fs/go/glog" "net/url" "time" ) @@ -14,12 +14,12 @@ func batchVacuumVolumeCheck(vl *VolumeLayout, vid storage.VolumeId, locationlist ch := make(chan bool, locationlist.Length()) for index, dn := range locationlist.list { go func(index int, url string, vid storage.VolumeId) { - //log.Println(index, "Check vacuuming", vid, "on", dn.Url()) + //glog.V(0).Infoln(index, "Check vacuuming", vid, "on", dn.Url()) if e, ret := vacuumVolume_Check(url, vid, garbageThreshold); e != nil { - //log.Println(index, "Error when checking vacuuming", vid, "on", url, e) + //glog.V(0).Infoln(index, "Error when checking vacuuming", vid, "on", url, e) ch <- false } else { - //log.Println(index, "Checked vacuuming", vid, "on", url, "needVacuum", ret) + //glog.V(0).Infoln(index, "Checked vacuuming", vid, "on", url, "needVacuum", ret) ch <- ret } }(index, dn.Url(), vid) @@ -41,12 +41,12 @@ func batchVacuumVolumeCompact(vl *VolumeLayout, vid storage.VolumeId, locationli ch := make(chan bool, locationlist.Length()) for index, dn := range locationlist.list { go func(index int, url string, vid storage.VolumeId) { - log.Println(index, "Start vacuuming", vid, "on", url) + glog.V(0).Infoln(index, "Start vacuuming", vid, "on", url) if e := vacuumVolume_Compact(url, vid); e != nil { - log.Println(index, "Error when vacuuming", vid, "on", url, e) + glog.V(0).Infoln(index, "Error when vacuuming", vid, "on", url, e) ch <- false } else { - log.Println(index, "Complete vacuuming", vid, "on", url) + glog.V(0).Infoln(index, "Complete vacuuming", vid, "on", url) ch <- true } }(index, dn.Url(), vid) @@ -65,12 +65,12 @@ func batchVacuumVolumeCompact(vl *VolumeLayout, vid storage.VolumeId, locationli func batchVacuumVolumeCommit(vl *VolumeLayout, vid storage.VolumeId, locationlist *VolumeLocationList) bool { isCommitSuccess := true for _, dn := range locationlist.list { - log.Println("Start Commiting vacuum", vid, "on", dn.Url()) + glog.V(0).Infoln("Start Commiting vacuum", vid, "on", dn.Url()) if e := vacuumVolume_Commit(dn.Url(), vid); e != nil { - log.Println("Error when committing vacuum", vid, "on", dn.Url(), e) + glog.V(0).Infoln("Error when committing vacuum", vid, "on", dn.Url(), e) isCommitSuccess = false } else { - log.Println("Complete Commiting vacuum", vid, "on", dn.Url()) + glog.V(0).Infoln("Complete Commiting vacuum", vid, "on", dn.Url()) } } if isCommitSuccess { @@ -104,7 +104,7 @@ func vacuumVolume_Check(urlLocation string, vid storage.VolumeId, garbageThresho values.Add("garbageThreshold", garbageThreshold) jsonBlob, err := util.Post("http://"+urlLocation+"/admin/vacuum_volume_check", values) if err != nil { - log.Println("parameters:", values) + glog.V(0).Infoln("parameters:", values) return err, false } var ret VacuumVolumeResult |