diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-05-24 23:20:26 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-05-24 23:20:26 -0700 |
| commit | 7b81cf37628bfabc4ac6018c4b123dbd245ed158 (patch) | |
| tree | b26c167616d9a62e8f33b234b111fce4504fa60b /weed/filesys/filehandle.go | |
| parent | 9f4f8de9adf3115e08875a6ab4a9c51932fd3d4a (diff) | |
| download | seaweedfs-7b81cf37628bfabc4ac6018c4b123dbd245ed158.tar.xz seaweedfs-7b81cf37628bfabc4ac6018c4b123dbd245ed158.zip | |
better logs
Diffstat (limited to 'weed/filesys/filehandle.go')
| -rw-r--r-- | weed/filesys/filehandle.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/weed/filesys/filehandle.go b/weed/filesys/filehandle.go index c71f1ee36..7ab2513e1 100644 --- a/weed/filesys/filehandle.go +++ b/weed/filesys/filehandle.go @@ -143,9 +143,9 @@ func (fh *FileHandle) Write(ctx context.Context, req *fuse.WriteRequest, resp *f Collection: "", } - glog.V(1).Infof("assign volume: %v", request) resp, err := client.AssignVolume(ctx, request) if err != nil { + glog.V(0).Infof("assign volume failure %v: %v", request, err) return err } @@ -160,9 +160,11 @@ func (fh *FileHandle) Write(ctx context.Context, req *fuse.WriteRequest, resp *f bufReader := bytes.NewReader(req.Data) uploadResult, err := operation.Upload(fileUrl, fh.name, bufReader, false, "application/octet-stream", nil, "") if err != nil { + glog.V(0).Infof("upload data %v to %s: %v", req, fileUrl, err) return fmt.Errorf("upload data: %v", err) } if uploadResult.Error != "" { + glog.V(0).Infof("upload failure %v to %s: %v", req, fileUrl, err) return fmt.Errorf("upload result: %v", uploadResult.Error) } @@ -217,6 +219,9 @@ func (fh *FileHandle) Flush(ctx context.Context, req *fuse.FlushRequest) error { } glog.V(1).Infof("%s/%s set chunks: %v", fh.dirPath, fh.name, len(fh.Chunks)) + for i, chunk := range fh.Chunks { + glog.V(1).Infof("%s/%s chunks %d: %v [%d,%d)", fh.dirPath, fh.name, i, chunk.FileId, chunk.Offset, chunk.Offset+int64(chunk.Size)) + } if _, err := client.UpdateEntry(ctx, request); err != nil { return fmt.Errorf("update fh: %v", err) } |
