Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <[email protected]>
  • Loading branch information
rleungx committed Oct 9, 2024
1 parent 34b0620 commit 41384b9
Showing 1 changed file with 10 additions and 9 deletions.
19 changes: 10 additions & 9 deletions tests/server/server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -175,11 +175,12 @@ func TestGRPCRateLimit(t *testing.T) {
Header: &pdpb.RequestHeader{ClusterId: leaderServer.GetClusterID()},
RegionKey: []byte(""),
})
re.NoError(err)
re.Empty(resp.GetHeader().GetError())
if i == 0 {
re.Empty(resp.GetHeader().GetError())
re.NoError(err)
} else {
re.Contains(resp.GetHeader().GetError().GetMessage(), "rate limit exceeded")
re.Error(err)
re.Contains(err.Error(), "rate limit exceeded")
}
}

Expand Down Expand Up @@ -219,9 +220,9 @@ func TestGRPCRateLimit(t *testing.T) {
Header: &pdpb.RequestHeader{ClusterId: leaderServer.GetClusterID()},
RegionKey: []byte(""),
})
re.NoError(err)
if resp.GetHeader().GetError() != nil {
errCh <- resp.GetHeader().GetError().GetMessage()
re.Empty(resp.GetHeader().GetError())
if err != nil {
errCh <- err.Error()
} else {
okCh <- struct{}{}
}
Expand All @@ -234,9 +235,9 @@ func TestGRPCRateLimit(t *testing.T) {
Header: &pdpb.RequestHeader{ClusterId: leaderServer.GetClusterID()},
RegionKey: []byte(""),
})
re.NoError(err)
if resp.GetHeader().GetError() != nil {
errCh <- resp.GetHeader().GetError().GetMessage()
re.Empty(resp.GetHeader().GetError())
if err != nil {
errCh <- err.Error()
} else {
okCh <- struct{}{}
}
Expand Down

0 comments on commit 41384b9

Please sign in to comment.