diff options
Diffstat (limited to 'weed/mq/broker')
| -rw-r--r-- | weed/mq/broker/broker_write.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/mq/broker/broker_write.go b/weed/mq/broker/broker_write.go index 9999529fb..9f3c7b50f 100644 --- a/weed/mq/broker/broker_write.go +++ b/weed/mq/broker/broker_write.go @@ -1,6 +1,7 @@ package broker import ( + "context" "fmt" "github.com/seaweedfs/seaweedfs/weed/filer" "github.com/seaweedfs/seaweedfs/weed/operation" @@ -20,7 +21,7 @@ func (b *MessageQueueBroker) appendToFile(targetFile string, data []byte) error // find out existing entry fullpath := util.FullPath(targetFile) dir, name := fullpath.DirAndName() - entry, err := filer_pb.GetEntry(b, fullpath) + entry, err := filer_pb.GetEntry(context.Background(), b, fullpath) var offset int64 = 0 if err == filer_pb.ErrNotFound { entry = &filer_pb.Entry{ @@ -45,7 +46,7 @@ func (b *MessageQueueBroker) appendToFile(targetFile string, data []byte) error // update the entry return b.WithFilerClient(false, func(client filer_pb.SeaweedFilerClient) error { - return filer_pb.CreateEntry(client, &filer_pb.CreateEntryRequest{ + return filer_pb.CreateEntry(context.Background(), client, &filer_pb.CreateEntryRequest{ Directory: dir, Entry: entry, }) |