diff options
Diffstat (limited to 'weed/filer')
| -rw-r--r-- | weed/filer/read_write.go | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/weed/filer/read_write.go b/weed/filer/read_write.go index dc4f3d0d8..66f4c0bf8 100644 --- a/weed/filer/read_write.go +++ b/weed/filer/read_write.go @@ -2,6 +2,7 @@ package filer import ( "bytes" + "context" "time" "github.com/seaweedfs/seaweedfs/weed/pb/filer_pb" @@ -14,7 +15,7 @@ func ReadEntry(masterClient *wdclient.MasterClient, filerClient filer_pb.Seaweed Directory: dir, Name: name, } - respLookupEntry, err := filer_pb.LookupEntry(filerClient, request) + respLookupEntry, err := filer_pb.LookupEntry(context.Background(), filerClient, request) if err != nil { return err } @@ -32,7 +33,7 @@ func ReadInsideFiler(filerClient filer_pb.SeaweedFilerClient, dir, name string) Directory: dir, Name: name, } - respLookupEntry, err := filer_pb.LookupEntry(filerClient, request) + respLookupEntry, err := filer_pb.LookupEntry(context.Background(), filerClient, request) if err != nil { return } @@ -42,13 +43,13 @@ func ReadInsideFiler(filerClient filer_pb.SeaweedFilerClient, dir, name string) func SaveInsideFiler(client filer_pb.SeaweedFilerClient, dir, name string, content []byte) error { - resp, err := filer_pb.LookupEntry(client, &filer_pb.LookupDirectoryEntryRequest{ + resp, err := filer_pb.LookupEntry(context.Background(), client, &filer_pb.LookupDirectoryEntryRequest{ Directory: dir, Name: name, }) if err == filer_pb.ErrNotFound { - err = filer_pb.CreateEntry(client, &filer_pb.CreateEntryRequest{ + err = filer_pb.CreateEntry(context.Background(), client, &filer_pb.CreateEntryRequest{ Directory: dir, Entry: &filer_pb.Entry{ Name: name, @@ -68,7 +69,7 @@ func SaveInsideFiler(client filer_pb.SeaweedFilerClient, dir, name string, conte entry.Content = content entry.Attributes.Mtime = time.Now().Unix() entry.Attributes.FileSize = uint64(len(content)) - err = filer_pb.UpdateEntry(client, &filer_pb.UpdateEntryRequest{ + err = filer_pb.UpdateEntry(context.Background(), client, &filer_pb.UpdateEntryRequest{ Directory: dir, Entry: entry, }) |