diff options
Diffstat (limited to 'weed/operation/assign_file_id_test.go')
| -rw-r--r-- | weed/operation/assign_file_id_test.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/weed/operation/assign_file_id_test.go b/weed/operation/assign_file_id_test.go index f6362dceb..ac0f4eee6 100644 --- a/weed/operation/assign_file_id_test.go +++ b/weed/operation/assign_file_id_test.go @@ -1,6 +1,7 @@ package operation import ( + "context" "fmt" "github.com/seaweedfs/seaweedfs/weed/pb" "google.golang.org/grpc" @@ -11,7 +12,7 @@ import ( func BenchmarkWithConcurrency(b *testing.B) { concurrencyLevels := []int{1, 10, 100, 1000} - ap, _ := NewAssignProxy(func() pb.ServerAddress { + ap, _ := NewAssignProxy(func(_ context.Context) pb.ServerAddress { return pb.ServerAddress("localhost:9333") }, grpc.WithInsecure(), 16) @@ -47,7 +48,7 @@ func BenchmarkWithConcurrency(b *testing.B) { } func BenchmarkStreamAssign(b *testing.B) { - ap, _ := NewAssignProxy(func() pb.ServerAddress { + ap, _ := NewAssignProxy(func(_ context.Context) pb.ServerAddress { return pb.ServerAddress("localhost:9333") }, grpc.WithInsecure(), 16) for i := 0; i < b.N; i++ { @@ -59,7 +60,7 @@ func BenchmarkStreamAssign(b *testing.B) { func BenchmarkUnaryAssign(b *testing.B) { for i := 0; i < b.N; i++ { - Assign(func() pb.ServerAddress { + Assign(func(_ context.Context) pb.ServerAddress { return pb.ServerAddress("localhost:9333") }, grpc.WithInsecure(), &VolumeAssignRequest{ Count: 1, |