diff options
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/webdav_server.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/weed/server/webdav_server.go b/weed/server/webdav_server.go index dbe6dfed5..2b7493ee6 100644 --- a/weed/server/webdav_server.go +++ b/weed/server/webdav_server.go @@ -209,7 +209,7 @@ func (fs *WebDavFileSystem) Mkdir(ctx context.Context, fullDirPath string, perm } glog.V(1).Infof("mkdir: %v", request) - if err := filer_pb.CreateEntry(client, request); err != nil { + if err := filer_pb.CreateEntry(context.Background(), client, request); err != nil { return fmt.Errorf("mkdir %s/%s: %v", dir, name, err) } @@ -240,7 +240,7 @@ func (fs *WebDavFileSystem) OpenFile(ctx context.Context, fullFilePath string, f dir, name := util.FullPath(fullFilePath).DirAndName() err = fs.WithFilerClient(false, func(client filer_pb.SeaweedFilerClient) error { - if err := filer_pb.CreateEntry(client, &filer_pb.CreateEntryRequest{ + if err := filer_pb.CreateEntry(context.Background(), client, &filer_pb.CreateEntryRequest{ Directory: dir, Entry: &filer_pb.Entry{ Name: name, @@ -299,7 +299,7 @@ func (fs *WebDavFileSystem) removeAll(ctx context.Context, fullFilePath string) dir, name := util.FullPath(fullFilePath).DirAndName() - return filer_pb.Remove(fs, dir, name, true, false, false, false, []int32{fs.signature}) + return filer_pb.Remove(context.Background(), fs, dir, name, true, false, false, false, []int32{fs.signature}) } @@ -371,7 +371,7 @@ func (fs *WebDavFileSystem) stat(ctx context.Context, fullFilePath string) (os.F fullpath := util.FullPath(fullFilePath) var fi FileInfo - entry, err := filer_pb.GetEntry(fs, fullpath) + entry, err := filer_pb.GetEntry(context.Background(), fs, fullpath) if err != nil { if err == filer_pb.ErrNotFound { return nil, os.ErrNotExist @@ -452,7 +452,7 @@ func (f *WebDavFile) Write(buf []byte) (int, error) { var getErr error ctx := context.Background() if f.entry == nil { - f.entry, getErr = filer_pb.GetEntry(f.fs, fullPath) + f.entry, getErr = filer_pb.GetEntry(context.Background(), f.fs, fullPath) } if f.entry == nil { @@ -543,7 +543,7 @@ func (f *WebDavFile) Read(p []byte) (readSize int, err error) { glog.V(2).Infof("WebDavFileSystem.Read %v", f.name) if f.entry == nil { - f.entry, err = filer_pb.GetEntry(f.fs, util.FullPath(f.name)) + f.entry, err = filer_pb.GetEntry(context.Background(), f.fs, util.FullPath(f.name)) } if f.entry == nil { return 0, err @@ -583,7 +583,7 @@ func (f *WebDavFile) Readdir(count int) (ret []os.FileInfo, err error) { dir, _ := util.FullPath(f.name).DirAndName() - err = filer_pb.ReadDirAllEntries(f.fs, util.FullPath(dir), "", func(entry *filer_pb.Entry, isLast bool) error { + err = filer_pb.ReadDirAllEntries(context.Background(), f.fs, util.FullPath(dir), "", func(entry *filer_pb.Entry, isLast bool) error { fi := FileInfo{ size: int64(filer.FileSize(entry)), name: entry.Name, |