Signed-off-by: Eric Zhao <sczyh16@gmail.com>master
@@ -65,14 +65,14 @@ public class SentinelGrpcClientInterceptorTest { | |||||
assertTrue(sendRequest(client)); | assertTrue(sendRequest(client)); | ||||
ClusterNode clusterNode = ClusterBuilderSlot.getClusterNode(resourceName, EntryType.OUT); | ClusterNode clusterNode = ClusterBuilderSlot.getClusterNode(resourceName, EntryType.OUT); | ||||
assertNotNull(clusterNode); | assertNotNull(clusterNode); | ||||
assertEquals(1, clusterNode.passQps()); | |||||
assertEquals(1, clusterNode.totalRequest() - clusterNode.blockRequest()); | |||||
// Not allowed to pass. | // Not allowed to pass. | ||||
configureFlowRule(0); | configureFlowRule(0); | ||||
// The second request will be blocked. | // The second request will be blocked. | ||||
assertFalse(sendRequest(client)); | assertFalse(sendRequest(client)); | ||||
assertEquals(1, clusterNode.blockQps()); | |||||
assertEquals(1, clusterNode.blockRequest()); | |||||
server.stop(); | server.stop(); | ||||
} | } | ||||
@@ -66,14 +66,14 @@ public class SentinelGrpcServerInterceptorTest { | |||||
assertTrue(sendRequest()); | assertTrue(sendRequest()); | ||||
ClusterNode clusterNode = ClusterBuilderSlot.getClusterNode(resourceName, EntryType.IN); | ClusterNode clusterNode = ClusterBuilderSlot.getClusterNode(resourceName, EntryType.IN); | ||||
assertNotNull(clusterNode); | assertNotNull(clusterNode); | ||||
assertEquals(1, clusterNode.passQps()); | |||||
assertEquals(1, clusterNode.totalRequest() - clusterNode.blockRequest()); | |||||
// Not allowed to pass. | // Not allowed to pass. | ||||
configureFlowRule(0); | configureFlowRule(0); | ||||
// The second request will be blocked. | // The second request will be blocked. | ||||
assertFalse(sendRequest()); | assertFalse(sendRequest()); | ||||
assertEquals(1, clusterNode.blockQps()); | |||||
assertEquals(1, clusterNode.blockRequest()); | |||||
server.stop(); | server.stop(); | ||||
} | } | ||||