sleep to delay send data

ctripcorp · Dec 19, 2024 · 1133538 · 1133538
1 parent a195c95
commit 1133538
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/redis/package/redis-keeper-package/src/main/scripts/redis/template/master.conf b/redis/package/redis-keeper-package/src/main/scripts/redis/template/master.conf
@@ -16,7 +16,7 @@ client-output-buffer-limit slave 0 0 0
 repl-diskless-sync yes
 repl-diskless-sync-delay 3
 #protected-mode no
-maxmemory-policy volatile-lru
+maxmemory-policy allkeys-lru
 protected-mode no
 
 hz 1
diff --git a/...edis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/store/cmd/OffsetCommandReader.java b/...edis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/store/cmd/OffsetCommandReader.java
@@ -52,7 +52,8 @@ public ReferenceFileRegion doRead(long milliSeconds) throws IOException {
             if (null != replDelayConfig
                     && (delayBytes = replDelayConfig.getDelayBytes()) > 0 && (delayMilli = replDelayConfig.getDelayMilli()) > 0) {
                 logger.debug("[readDelay]{}:{}", delayBytes, delayMilli);
-                offsetNotifier.await(curPosition + delayBytes, delayMilli);
+                // offsetNotifier.await(curPosition, delayMilli);
+                Thread.sleep(delayMilli);
             } else if (milliSeconds >= 0) {
                 offsetNotifier.await(curPosition, milliSeconds);
             } else {
@@ -66,7 +67,7 @@ public ReferenceFileRegion doRead(long milliSeconds) throws IOException {
         }
 
         if (!referenceFileChannel.hasAnythingToRead()) return null;
-        ReferenceFileRegion referenceFileRegion = referenceFileChannel.readTilEnd();
+        ReferenceFileRegion referenceFileRegion = referenceFileChannel.readTilEndWithDelay(replDelayConfig.getDelayBytes());
 
         curPosition += referenceFileRegion.count();