Skip to content

Commit d002b8f

Browse files
andyzhangxandyzhangx
committed
chore: fix ut
fix golint test: skip go vet check on test file fix fix golint
1 parent 739696b commit d002b8f

File tree

2 files changed

+24
-24
lines changed

2 files changed

+24
-24
lines changed

‎pkg/blob/nodeserver.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -552,9 +552,9 @@ func (d *Driver) NodeGetVolumeStats(_ context.Context, req *csi.NodeGetVolumeSta
552552
return nil, status.Errorf(codes.Internal, "%v", err)
553553
}
554554
if cache != nil {
555-
resp := cache.(csi.NodeGetVolumeStatsResponse)
555+
resp := cache.(*csi.NodeGetVolumeStatsResponse)
556556
klog.V(6).Infof("NodeGetVolumeStats: volume stats for volume %s path %s is cached", req.VolumeId, req.VolumePath)
557-
return &resp, nil
557+
return resp, nil
558558
}
559559

560560
mc := metrics.NewMetricContext(blobCSIDriverName, "node_get_volume_stats", d.cloud.ResourceGroup, "", d.Name)
@@ -624,7 +624,7 @@ func (d *Driver) NodeGetVolumeStats(_ context.Context, req *csi.NodeGetVolumeSta
624624
isOperationSucceeded = true
625625
klog.V(6).Infof("NodeGetVolumeStats: volume stats for volume %s path %s is %v", req.VolumeId, req.VolumePath, resp)
626626
// cache the volume stats per volume
627-
d.volStatsCache.Set(req.VolumeId, *resp)
627+
d.volStatsCache.Set(req.VolumeId, resp)
628628
return resp, nil
629629
}
630630

‎pkg/blob/nodeserver_test.go

+21-21
Original file line numberDiff line numberDiff line change
@@ -161,37 +161,37 @@ func TestNodePublishVolume(t *testing.T) {
161161
tests := []struct {
162162
desc string
163163
setup func(*Driver)
164-
req csi.NodePublishVolumeRequest
164+
req *csi.NodePublishVolumeRequest
165165
expectedErr error
166166
cleanup func(*Driver)
167167
}{
168168
{
169169
desc: "Volume capabilities missing",
170-
req: csi.NodePublishVolumeRequest{},
170+
req: &csi.NodePublishVolumeRequest{},
171171
expectedErr: status.Error(codes.InvalidArgument, "Volume capability missing in request"),
172172
},
173173
{
174174
desc: "Volume ID missing",
175-
req: csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap}},
175+
req: &csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap}},
176176
expectedErr: status.Error(codes.InvalidArgument, "Volume ID missing in request"),
177177
},
178178
{
179179
desc: "Stage path missing",
180-
req: csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
180+
req: &csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
181181
VolumeId: "vol_1",
182182
TargetPath: sourceTest},
183183
expectedErr: status.Error(codes.InvalidArgument, "Staging target not provided"),
184184
},
185185
{
186186
desc: "Stage target path missing",
187-
req: csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
187+
req: &csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
188188
VolumeId: "vol_1",
189189
StagingTargetPath: sourceTest},
190190
expectedErr: status.Error(codes.InvalidArgument, "Target path not provided"),
191191
},
192192
{
193193
desc: "Valid request read only",
194-
req: csi.NodePublishVolumeRequest{
194+
req: &csi.NodePublishVolumeRequest{
195195
VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
196196
VolumeId: "vol_1",
197197
TargetPath: targetTest,
@@ -205,7 +205,7 @@ func TestNodePublishVolume(t *testing.T) {
205205
},
206206
{
207207
desc: "Error creating directory",
208-
req: csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
208+
req: &csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
209209
VolumeId: "vol_1",
210210
TargetPath: "./azure.go",
211211
StagingTargetPath: sourceTest,
@@ -214,7 +214,7 @@ func TestNodePublishVolume(t *testing.T) {
214214
},
215215
{
216216
desc: "Error mounting resource busy",
217-
req: csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
217+
req: &csi.NodePublishVolumeRequest{VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
218218
VolumeId: "vol_1",
219219
TargetPath: targetTest,
220220
StagingTargetPath: sourceTest,
@@ -223,7 +223,7 @@ func TestNodePublishVolume(t *testing.T) {
223223
},
224224
{
225225
desc: "[Error] invalid mountPermissions",
226-
req: csi.NodePublishVolumeRequest{
226+
req: &csi.NodePublishVolumeRequest{
227227
VolumeCapability: &csi.VolumeCapability{AccessMode: &volumeCap},
228228
VolumeId: "vol_1",
229229
TargetPath: targetTest,
@@ -253,7 +253,7 @@ func TestNodePublishVolume(t *testing.T) {
253253
if test.setup != nil {
254254
test.setup(d)
255255
}
256-
_, err := d.NodePublishVolume(context.Background(), &test.req)
256+
_, err := d.NodePublishVolume(context.Background(), test.req)
257257

258258
if !reflect.DeepEqual(err, test.expectedErr) {
259259
t.Errorf("Desc: %s - Unexpected error: %v - Expected: %v", test.desc, err, test.expectedErr)
@@ -323,23 +323,23 @@ func TestNodeUnpublishVolume(t *testing.T) {
323323
tests := []struct {
324324
desc string
325325
setup func(*Driver)
326-
req csi.NodeUnpublishVolumeRequest
326+
req *csi.NodeUnpublishVolumeRequest
327327
expectedErr error
328328
cleanup func(*Driver)
329329
}{
330330
{
331331
desc: "Volume ID missing",
332-
req: csi.NodeUnpublishVolumeRequest{TargetPath: targetTest},
332+
req: &csi.NodeUnpublishVolumeRequest{TargetPath: targetTest},
333333
expectedErr: status.Error(codes.InvalidArgument, "Volume ID missing in request"),
334334
},
335335
{
336336
desc: "Target missing",
337-
req: csi.NodeUnpublishVolumeRequest{VolumeId: "vol_1"},
337+
req: &csi.NodeUnpublishVolumeRequest{VolumeId: "vol_1"},
338338
expectedErr: status.Error(codes.InvalidArgument, "Target path missing in request"),
339339
},
340340
{
341341
desc: "Valid request",
342-
req: csi.NodeUnpublishVolumeRequest{TargetPath: "./abc.go", VolumeId: "vol_1"},
342+
req: &csi.NodeUnpublishVolumeRequest{TargetPath: "./abc.go", VolumeId: "vol_1"},
343343
expectedErr: nil,
344344
},
345345
}
@@ -360,7 +360,7 @@ func TestNodeUnpublishVolume(t *testing.T) {
360360
if test.setup != nil {
361361
test.setup(d)
362362
}
363-
_, err := d.NodeUnpublishVolume(context.Background(), &test.req)
363+
_, err := d.NodeUnpublishVolume(context.Background(), test.req)
364364

365365
if !reflect.DeepEqual(err, test.expectedErr) {
366366
t.Errorf("Unexpected error: %v", err)
@@ -706,27 +706,27 @@ func TestNodeGetVolumeStats(t *testing.T) {
706706

707707
tests := []struct {
708708
desc string
709-
req csi.NodeGetVolumeStatsRequest
709+
req *csi.NodeGetVolumeStatsRequest
710710
expectedErr error
711711
}{
712712
{
713713
desc: "[Error] Volume ID missing",
714-
req: csi.NodeGetVolumeStatsRequest{VolumePath: targetTest},
714+
req: &csi.NodeGetVolumeStatsRequest{VolumePath: targetTest},
715715
expectedErr: status.Error(codes.InvalidArgument, "NodeGetVolumeStats volume ID was empty"),
716716
},
717717
{
718718
desc: "[Error] VolumePath missing",
719-
req: csi.NodeGetVolumeStatsRequest{VolumeId: "vol_1"},
719+
req: &csi.NodeGetVolumeStatsRequest{VolumeId: "vol_1"},
720720
expectedErr: status.Error(codes.InvalidArgument, "NodeGetVolumeStats volume path was empty"),
721721
},
722722
{
723723
desc: "[Error] Incorrect volume path",
724-
req: csi.NodeGetVolumeStatsRequest{VolumePath: nonexistedPath, VolumeId: "vol_1"},
724+
req: &csi.NodeGetVolumeStatsRequest{VolumePath: nonexistedPath, VolumeId: "vol_1"},
725725
expectedErr: status.Errorf(codes.NotFound, "path /not/a/real/directory does not exist"),
726726
},
727727
{
728728
desc: "[Success] Standard success",
729-
req: csi.NodeGetVolumeStatsRequest{VolumePath: fakePath, VolumeId: "vol_1"},
729+
req: &csi.NodeGetVolumeStatsRequest{VolumePath: fakePath, VolumeId: "vol_1"},
730730
expectedErr: nil,
731731
},
732732
}
@@ -736,7 +736,7 @@ func TestNodeGetVolumeStats(t *testing.T) {
736736
d := NewFakeDriver()
737737

738738
for _, test := range tests {
739-
_, err := d.NodeGetVolumeStats(context.Background(), &test.req)
739+
_, err := d.NodeGetVolumeStats(context.Background(), test.req)
740740
//t.Errorf("[debug] error: %v\n metrics: %v", err, metrics)
741741
if !reflect.DeepEqual(err, test.expectedErr) {
742742
t.Errorf("desc: %v, expected error: %v, actual error: %v", test.desc, test.expectedErr, err)

0 commit comments

Comments
 (0)