aboutsummaryrefslogtreecommitdiff
path: root/unmaintained
diff options
context:
space:
mode:
authorAleksey Kosov <rusyak777@list.ru>2025-05-28 21:34:02 +0300
committerGitHub <noreply@github.com>2025-05-28 11:34:02 -0700
commit283d9e0079d5deb57aefe9a7b30e8b9869ba8685 (patch)
tree87b09bebed2ee4afc9c2a4f711ac8598fe2949b7 /unmaintained
parent62aaaa18f3ea8b7600d28934580dc220ca95164a (diff)
downloadseaweedfs-283d9e0079d5deb57aefe9a7b30e8b9869ba8685.tar.xz
seaweedfs-283d9e0079d5deb57aefe9a7b30e8b9869ba8685.zip
Add context with request (#6824)
Diffstat (limited to 'unmaintained')
-rw-r--r--unmaintained/repeated_vacuum/repeated_vacuum.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/unmaintained/repeated_vacuum/repeated_vacuum.go b/unmaintained/repeated_vacuum/repeated_vacuum.go
index 1f89bd902..0a796a92f 100644
--- a/unmaintained/repeated_vacuum/repeated_vacuum.go
+++ b/unmaintained/repeated_vacuum/repeated_vacuum.go
@@ -1,13 +1,13 @@
package main
import (
+ "context"
"flag"
"fmt"
"github.com/seaweedfs/seaweedfs/weed/pb"
"log"
"math/rand"
"time"
- "context"
"google.golang.org/grpc"
@@ -56,7 +56,7 @@ func main() {
}
func genFile(grpcDialOption grpc.DialOption, i int) (*operation.AssignResult, string) {
- assignResult, err := operation.Assign(func(_ context.Context) pb.ServerAddress { return pb.ServerAddress(*master) }, grpcDialOption, &operation.VolumeAssignRequest{
+ assignResult, err := operation.Assign(context.Background(), func(_ context.Context) pb.ServerAddress { return pb.ServerAddress(*master) }, grpcDialOption, &operation.VolumeAssignRequest{
Count: 1,
Replication: *replication,
})
@@ -84,7 +84,7 @@ func genFile(grpcDialOption grpc.DialOption, i int) (*operation.AssignResult, st
log.Fatalf("upload: %v", err)
}
- _, err = uploader.UploadData(data, uploadOption)
+ _, err = uploader.UploadData(context.Background(), data, uploadOption)
if err != nil {
log.Fatalf("upload: %v", err)
}