You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@dubbo.apache.org by al...@apache.org on 2021/04/01 02:31:26 UTC
[dubbo-samples] branch master updated: update CacheService for LRU2
(#292)
This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-samples.git
The following commit(s) were added to refs/heads/master by this push:
new 1265b01 update CacheService for LRU2 (#292)
1265b01 is described below
commit 1265b011cbcfe013e71f88ce5a820c677ae8e1bf
Author: gcx <18...@163.com>
AuthorDate: Thu Apr 1 10:31:15 2021 +0800
update CacheService for LRU2 (#292)
---
.../org/apache/dubbo/samples/cache/CacheConsumer.java | 2 ++
.../org/apache/dubbo/samples/cache/CacheServiceIT.java | 17 ++++++++++++++---
2 files changed, 16 insertions(+), 3 deletions(-)
diff --git a/dubbo-samples-cache/src/main/java/org/apache/dubbo/samples/cache/CacheConsumer.java b/dubbo-samples-cache/src/main/java/org/apache/dubbo/samples/cache/CacheConsumer.java
index 3160f1a..c4b87c7 100644
--- a/dubbo-samples-cache/src/main/java/org/apache/dubbo/samples/cache/CacheConsumer.java
+++ b/dubbo-samples-cache/src/main/java/org/apache/dubbo/samples/cache/CacheConsumer.java
@@ -34,6 +34,7 @@ public class CacheConsumer {
// verify cache, same result is returned for different invocations (in fact, the return value increases
// on every invocation on the server side)
String fix = null;
+ cacheService.findCache("0");
for (int i = 0; i < 5; i++) {
String result = cacheService.findCache("0");
if (fix == null || fix.equals(result)) {
@@ -48,6 +49,7 @@ public class CacheConsumer {
// default cache.size is 1000 for LRU, should have cache expired if invoke more than 1001 times
for (int n = 0; n < 1001; n++) {
String pre = null;
+ cacheService.findCache(String.valueOf(n));
for (int i = 0; i < 10; i++) {
String result = cacheService.findCache(String.valueOf(n));
if (pre != null && !pre.equals(result)) {
diff --git a/dubbo-samples-cache/src/test/java/org/apache/dubbo/samples/cache/CacheServiceIT.java b/dubbo-samples-cache/src/test/java/org/apache/dubbo/samples/cache/CacheServiceIT.java
index 0878689..55a8d9d 100644
--- a/dubbo-samples-cache/src/test/java/org/apache/dubbo/samples/cache/CacheServiceIT.java
+++ b/dubbo-samples-cache/src/test/java/org/apache/dubbo/samples/cache/CacheServiceIT.java
@@ -42,12 +42,23 @@ public class CacheServiceIT {
@Test
public void verifyLRU() throws Exception {
+ // this test is for LRU-2 cache only.
+ // verify cache, same result is returned for multiple invocations (in fact, the return value increases
+ // on every invocation on the server side)
String value = service.findCache("0");
for (int n = 0; n < 1001; n++) {
- TestCase.assertEquals(service.findCache(String.valueOf(n)), service.findCache(String.valueOf(n)));
+ // default cache.size is 1000 for LRU, should have cache expired if invoke more than 1001 times
+ String pre = null;
+ service.findCache(String.valueOf(n));
+ for (int i = 0; i < 10; i++) {
+ String result = service.findCache(String.valueOf(n));
+ TestCase.assertTrue(pre == null || pre.equals(result));
+ pre = result;
+ }
}
- Assert.assertEquals(service.findCache("0"), service.findCache("0"));
- Assert.assertNotEquals(value, service.findCache("0"));
+ // verify if the first cache item is expired in LRU cache
+ TestCase.assertFalse(value.equals(service.findCache("0")));
+ TestCase.assertEquals(service.findCache("0"), service.findCache("0"));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@dubbo.apache.org
For additional commands, e-mail: notifications-help@dubbo.apache.org