chore(fs): remove prints

This commit is contained in:
hexxa 2021-09-16 21:15:41 +08:00 committed by Hexxa
parent 1b0bf9c5fd
commit 5ad0a073ce

View file

@ -101,7 +101,6 @@ func (fs *LocalFS) closeOpens(iterateAll, forced bool, exclude map[string]bool)
batch-- batch--
if forced || info.lastAccess.Add(fs.readerTTL).Before(time.Now()) { if forced || info.lastAccess.Add(fs.readerTTL).Before(time.Now()) {
fmt.Println("closing reader2", id, forced)
var err error var err error
if err = info.fd.Sync(); err != nil { if err = info.fd.Sync(); err != nil {
return closed, err return closed, err
@ -383,7 +382,6 @@ func (fs *LocalFS) GetFileReader(path string) (fs.ReadCloseSeeker, uint64, error
lastAccess: time.Now(), lastAccess: time.Now(),
} }
fmt.Println("new reader", id, path, fs.readers)
return fd, id, nil return fd, id, nil
} }
@ -391,8 +389,6 @@ func (fs *LocalFS) CloseReader(id string) error {
fs.opensMtx.Lock() fs.opensMtx.Lock()
defer fs.opensMtx.Unlock() defer fs.opensMtx.Unlock()
fmt.Println("close reader", id)
info, ok := fs.readers[id] info, ok := fs.readers[id]
if !ok { if !ok {
return fmt.Errorf("reader not found: %s %v", id, fs.readers) return fmt.Errorf("reader not found: %s %v", id, fs.readers)