gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

adjust logs

Browse Source
This commit is contained in:
Chris Lu
2020-01-24 20:06:58 -08:00
parent d4cde5df49
commit b6e6ca8595
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
weed/filer2/filer.go
View File

@@ -74,6 +74,8 @@ func (f *Filer) RollbackTransaction(ctx context.Context) error {
func (f *Filer) CreateEntry(ctx context.Context, entry *Entry, o_excl bool) error { func (f *Filer) CreateEntry(ctx context.Context, entry *Entry, o_excl bool) error {
glog.V(4).Infof("CreateEntry create %s", entry.FullPath)
if string(entry.FullPath) == "/" { if string(entry.FullPath) == "/" {
return nil return nil
} }
@@ -127,6 +129,7 @@ func (f *Filer) CreateEntry(ctx context.Context, entry *Entry, o_excl bool) erro
} }
} else if !dirEntry.IsDirectory() { } else if !dirEntry.IsDirectory() {
glog.Errorf("CreateEntry %s: %s should be a directory", entry.FullPath, dirPath)
return fmt.Errorf("%s is a file", dirPath) return fmt.Errorf("%s is a file", dirPath)
} }
@@ -141,6 +144,7 @@ func (f *Filer) CreateEntry(ctx context.Context, entry *Entry, o_excl bool) erro
} }
if lastDirectoryEntry == nil { if lastDirectoryEntry == nil {
glog.Errorf("CreateEntry %s: lastDirectoryEntry is nil", entry.FullPath)
return fmt.Errorf("parent folder not found: %v", entry.FullPath) return fmt.Errorf("parent folder not found: %v", entry.FullPath)
} }
@@ -169,6 +173,8 @@ func (f *Filer) CreateEntry(ctx context.Context, entry *Entry, o_excl bool) erro
} }
} }
// glog.V(4).Infof("CreateEntry %s: created", entry.FullPath)
f.NotifyUpdateEvent(oldEntry, entry, true) f.NotifyUpdateEvent(oldEntry, entry, true)
f.deleteChunksIfNotNew(oldEntry, entry) f.deleteChunksIfNotNew(oldEntry, entry)

2
weed/storage/volume_read_write.go
View File

@@ -64,7 +64,7 @@ func (v *Volume) Destroy() (err error) {
} }
func (v *Volume) writeNeedle(n *needle.Needle) (offset uint64, size uint32, isUnchanged bool, err error) { func (v *Volume) writeNeedle(n *needle.Needle) (offset uint64, size uint32, isUnchanged bool, err error) {
glog.V(4).Infof("writing needle %s", needle.NewFileIdFromNeedle(v.Id, n).String()) // glog.V(4).Infof("writing needle %s", needle.NewFileIdFromNeedle(v.Id, n).String())
v.dataFileAccessLock.Lock() v.dataFileAccessLock.Lock()
defer v.dataFileAccessLock.Unlock() defer v.dataFileAccessLock.Unlock()
if v.isFileUnchanged(n) { if v.isFileUnchanged(n) {