Add optional admin port to volume server, to seperate admin operations from normal file operations.

1 files changed, 6 insertions, 6 deletions

diff --git a/go/topology/topology_vacuum.go b/go/topology/topology_vacuum.go
index d6fa2213e..0aeb9f132 100644
--- a/go/topology/topology_vacuum.go
+++ b/go/topology/topology_vacuum.go
@@ -23,7 +23,7 @@ func batchVacuumVolumeCheck(vl *VolumeLayout, vid storage.VolumeId, locationlist
 				//glog.V(0).Infoln(index, "Checked vacuuming", vid, "on", url, "needVacuum", ret)
 				ch <- ret
 			}
-		}(index, dn.Url(), vid)
+		}(index, dn.AdminUrl(), vid)
 	}
 	isCheckSuccess := true
 	for _ = range locationlist.list {
@@ -50,7 +50,7 @@ func batchVacuumVolumeCompact(vl *VolumeLayout, vid storage.VolumeId, locationli
 				glog.V(0).Infoln(index, "Complete vacuuming", vid, "on", url)
 				ch <- true
 			}
-		}(index, dn.Url(), vid)
+		}(index, dn.AdminUrl(), vid)
 	}
 	isVacuumSuccess := true
 	for _ = range locationlist.list {
@@ -66,12 +66,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 {
-		glog.V(0).Infoln("Start Commiting vacuum", vid, "on", dn.Url())
-		if e := vacuumVolume_Commit(dn.Url(), vid); e != nil {
-			glog.V(0).Infoln("Error when committing vacuum", vid, "on", dn.Url(), e)
+		glog.V(0).Infoln("Start Commiting vacuum", vid, "on", dn.AdminUrl())
+		if e := vacuumVolume_Commit(dn.AdminUrl(), vid); e != nil {
+			glog.V(0).Infoln("Error when committing vacuum", vid, "on", dn.AdminUrl(), e)
 			isCommitSuccess = false
 		} else {
-			glog.V(0).Infoln("Complete Commiting vacuum", vid, "on", dn.Url())
+			glog.V(0).Infoln("Complete Commiting vacuum", vid, "on", dn.AdminUrl())
 		}
 		if isCommitSuccess {
 			vl.SetVolumeAvailable(dn, vid)