accurate data file suffix name

173409900 · Dec 1, 2015 · 01d32d7 · 01d32d7
1 parent 829a267
commit 01d32d7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/agent/agent_server.go b/agent/agent_server.go
@@ -89,9 +89,10 @@ func (r *AgentServer) Init() (err error) {
 
 	if *r.Option.CleanRestart {
 		if fileInfos, err := ioutil.ReadDir(r.storageBackend.dir); err == nil {
+			suffix := fmt.Sprintf("-%d.dat", r.Port)
 			for _, fi := range fileInfos {
 				name := fi.Name()
-				if !fi.IsDir() && strings.HasSuffix(name, ".dat") {
+				if !fi.IsDir() && strings.HasSuffix(name, suffix) {
 					// println("removing old dat file:", name)
 					os.Remove(filepath.Join(r.storageBackend.dir, name))
 				}