diff options
| author | Aleksey Kosov <rusyak777@list.ru> | 2025-05-22 19:46:49 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-05-22 09:46:49 -0700 |
| commit | 165af32d6b738daa14b84fb6e3c8891f4b46135b (patch) | |
| tree | 7e6128d2fda753abc031c6461ae9709b284afcdf /weed/server/webdav_server.go | |
| parent | 5182d46e22d2458b16f1f2fb0358f6b5f3e18b5d (diff) | |
| download | seaweedfs-165af32d6b738daa14b84fb6e3c8891f4b46135b.tar.xz seaweedfs-165af32d6b738daa14b84fb6e3c8891f4b46135b.zip | |
added context to filer_client method calls (#6808)
Co-authored-by: akosov <a.kosov@kryptonite.ru>
Diffstat (limited to 'weed/server/webdav_server.go')
| -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, |
