Browse Source

wal: better log msg

Xiang Li 10 years ago
parent
commit
89242d4659
2 changed files with 3 additions and 3 deletions
  1. 1 1
      wal/util.go
  2. 2 2
      wal/wal.go

+ 1 - 1
wal/util.go

@@ -73,7 +73,7 @@ func checkWalNames(names []string) []string {
 	wnames := make([]string, 0)
 	wnames := make([]string, 0)
 	for _, name := range names {
 	for _, name := range names {
 		if _, _, err := parseWalName(name); err != nil {
 		if _, _, err := parseWalName(name); err != nil {
-			log.Printf("wal: parse %s error: %v", name, err)
+			log.Printf("wal: ignored file %v in wal", name)
 			continue
 			continue
 		}
 		}
 		wnames = append(wnames, name)
 		wnames = append(wnames, name)

+ 2 - 2
wal/wal.go

@@ -298,8 +298,8 @@ func (w *WAL) cut() error {
 	fpath := path.Join(w.dir, walName(w.seq+1, w.enti+1))
 	fpath := path.Join(w.dir, walName(w.seq+1, w.enti+1))
 	ftpath := fpath + ".tmp"
 	ftpath := fpath + ".tmp"
 
 
-	// create a temp wal file with name sequence + 1
-	ft, err := os.OpenFile(ftpath, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0600)
+	// create a temp wal file with name sequence + 1, or tuncate the existing one
+	ft, err := os.OpenFile(ftpath, os.O_WRONLY|os.O_APPEND|os.O_CREATE|os.O_TRUNC, 0600)
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}