diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-05-28 22:45:52 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-05-28 22:45:52 -0700 |
| commit | c4b92e17d033df1e348d3ab83c1ba5603e473a4f (patch) | |
| tree | b3576ce0385272a4b0b58e4a315bd96adb11e24f /weed/filesys/filehandle.go | |
| parent | 74332e1a619b3be449994e38f26247e4cdf883ef (diff) | |
| download | seaweedfs-c4b92e17d033df1e348d3ab83c1ba5603e473a4f.tar.xz seaweedfs-c4b92e17d033df1e348d3ab83c1ba5603e473a4f.zip | |
fix isPerfectAppend
Diffstat (limited to 'weed/filesys/filehandle.go')
| -rw-r--r-- | weed/filesys/filehandle.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/weed/filesys/filehandle.go b/weed/filesys/filehandle.go index 52df2824c..9fa971236 100644 --- a/weed/filesys/filehandle.go +++ b/weed/filesys/filehandle.go @@ -39,7 +39,7 @@ var _ = fs.HandleReleaser(&FileHandle{}) func (fh *FileHandle) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error { - glog.V(3).Infof("%v/%v read fh: [%d,%d)", fh.f.dir.Path, fh.f.Name, req.Offset, req.Offset+int64(req.Size)) + glog.V(4).Infof("%v/%v read fh: [%d,%d)", fh.f.dir.Path, fh.f.Name, req.Offset, req.Offset+int64(req.Size)) if len(fh.f.Chunks) == 0 { glog.V(0).Infof("empty fh %v/%v", fh.f.dir.Path, fh.f.Name) @@ -73,7 +73,7 @@ func (fh *FileHandle) Read(ctx context.Context, req *fuse.ReadRequest, resp *fus }) if err != nil { - glog.V(3).Infof("%v/%v read fh lookup volume ids: %v", fh.f.dir.Path, fh.f.Name, err) + glog.V(4).Infof("%v/%v read fh lookup volume ids: %v", fh.f.dir.Path, fh.f.Name, err) return fmt.Errorf("failed to lookup volume ids %v: %v", vids, err) } @@ -84,7 +84,7 @@ func (fh *FileHandle) Read(ctx context.Context, req *fuse.ReadRequest, resp *fus go func(chunkView *filer2.ChunkView) { defer wg.Done() - glog.V(3).Infof("read fh reading chunk: %+v", chunkView) + glog.V(4).Infof("read fh reading chunk: %+v", chunkView) locations := vid2Locations[volumeId(chunkView.FileId)] if locations == nil || len(locations.Locations) == 0 { @@ -109,7 +109,7 @@ func (fh *FileHandle) Read(ctx context.Context, req *fuse.ReadRequest, resp *fus return } - glog.V(3).Infof("read fh read %d bytes: %+v", n, chunkView) + glog.V(4).Infof("read fh read %d bytes: %+v", n, chunkView) totalRead += n }(chunkView) @@ -126,7 +126,7 @@ func (fh *FileHandle) Write(ctx context.Context, req *fuse.WriteRequest, resp *f // write the request to volume servers - glog.V(3).Infof("%+v/%v write fh: [%d,%d)", fh.f.dir.Path, fh.f.Name, req.Offset, req.Offset+int64(len(req.Data))) + glog.V(4).Infof("%+v/%v write fh: [%d,%d)", fh.f.dir.Path, fh.f.Name, req.Offset, req.Offset+int64(len(req.Data))) chunk, err := fh.dirtyPages.AddPage(ctx, req.Offset, req.Data) if err != nil { @@ -146,7 +146,7 @@ func (fh *FileHandle) Write(ctx context.Context, req *fuse.WriteRequest, resp *f func (fh *FileHandle) Release(ctx context.Context, req *fuse.ReleaseRequest) error { - glog.V(3).Infof("%+v/%v release fh", fh.f.dir.Path, fh.f.Name) + glog.V(4).Infof("%+v/%v release fh", fh.f.dir.Path, fh.f.Name) fh.f.isOpen = false @@ -158,7 +158,7 @@ func (fh *FileHandle) Release(ctx context.Context, req *fuse.ReleaseRequest) err func (fh *FileHandle) Flush(ctx context.Context, req *fuse.FlushRequest) error { // fflush works at fh level // send the data to the OS - glog.V(3).Infof("%s/%s fh flush %v", fh.f.dir.Path, fh.f.Name, req) + glog.V(4).Infof("%s/%s fh flush %v", fh.f.dir.Path, fh.f.Name, req) chunk, err := fh.dirtyPages.FlushToStorage(ctx) if err != nil { |