diff options
| author | chrislu <chris.lu@gmail.com> | 2021-12-28 18:27:16 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2021-12-28 18:27:16 -0800 |
| commit | 2095ddcf9b6ce65125281071ae572dd1d5f2e53f (patch) | |
| tree | c90cb1cba72d253f4412d0b94eee51e1040dee93 /pkg/driver | |
| parent | 5820165dae963df6bb905d3ffd531b1ccb3ad26b (diff) | |
| download | seaweedfs-csi-driver-2095ddcf9b6ce65125281071ae572dd1d5f2e53f.tar.xz seaweedfs-csi-driver-2095ddcf9b6ce65125281071ae572dd1d5f2e53f.zip | |
upgrade to latest seaweedfs version
Diffstat (limited to 'pkg/driver')
| -rw-r--r-- | pkg/driver/driver.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go index 0286a92..061a269 100644 --- a/pkg/driver/driver.go +++ b/pkg/driver/driver.go @@ -128,7 +128,7 @@ func (d *SeaweedFsDriver) ValidateControllerServiceRequest(c csi.ControllerServi var _ = filer_pb.FilerClient(&SeaweedFsDriver{}) -func (d *SeaweedFsDriver) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error { +func (d *SeaweedFsDriver) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) error { return util.Retry("filer grpc", func() error { @@ -137,7 +137,7 @@ func (d *SeaweedFsDriver) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) e var err error for x := 0; x < n; x++ { - err = pb.WithCachedGrpcClient(func(grpcConnection *grpc.ClientConn) error { + err = pb.WithGrpcClient(streamingMode, func(grpcConnection *grpc.ClientConn) error { client := filer_pb.NewSeaweedFilerClient(grpcConnection) return fn(client) }, d.filers[i].ToGrpcAddress(), d.grpcDialOption) |