Skip to content

Commit

Permalink
fixing e2e tests
Browse files Browse the repository at this point in the history
Signed-off-by: alice-px <[email protected]>
  • Loading branch information
alicelyy committed Jan 19, 2024
1 parent 86f2842 commit 9f145b6
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 4 deletions.
2 changes: 1 addition & 1 deletion api/server/sdk/node_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -460,7 +460,7 @@ func TestSdkVolumeUsageByNode(t *testing.T) {

s.MockCluster().EXPECT().Enumerate().Return(cluster, nil).Times(1)
s.MockCluster().EXPECT().Inspect(nodeid).Return(node, nil).Times(2)
s.MockDriver().EXPECT().VolumeUsageByNode(context.TODO(), nodeid).Return(&volumeUsageInfo, nil).Times(1)
s.MockDriver().EXPECT().VolumeUsageByNode(context.Background(), nodeid).Return(&volumeUsageInfo, nil).Times(1)

// Setup client
c := api.NewOpenStorageNodeClient(s.Conn())
Expand Down
3 changes: 0 additions & 3 deletions pkg/loadbalancer/roundrobin.go
Original file line number Diff line number Diff line change
Expand Up @@ -149,9 +149,6 @@ func (rr *roundRobin) getTargetAndIncrement(filteredNodes []*api.Node, selfNodeI
return "", false
}
targetNodeNumber = rr.nextCreateNodeNumber % len(filteredNodes)
if rr.nextCreateNodeNumber != 0 {
targetNodeNumber = rr.nextCreateNodeNumber
}
targetNode := filteredNodes[targetNodeNumber]
if targetNode.Id != selfNodeID {
// NodeID set on the cluster object is this node's ID.
Expand Down

0 comments on commit 9f145b6

Please sign in to comment.