Add test case and Address Ping Comment

Signed-off-by: hwware <[email protected]>

Author: hwware

src/config.c

@@ -2509,7 +2509,7 @@ static int updateMaxmemoryReserved(const char **err) {
             server.maxmemory_reserved_scale = 60;
         }
     }
-    calculateMaxAvailableMemory();
+    updateMaxAvailableMemory();
     return 1;
 }
 
@@ -2524,7 +2524,7 @@ static int updateMaxmemory(const char **err) {
                       "depending on the maxmemory-policy.",
                       server.maxmemory, used);
         }
-        calculateMaxAvailableMemory();
+        updateMaxAvailableMemory();
         startEvictionTimeProc();
     }
     return 1;

src/evict.c

@@ -398,16 +398,12 @@ int getMaxmemoryState(size_t *total, size_t *logical, size_t *tofree, float *lev
     if (total) *total = mem_reported;
 
     /* We may return ASAP if there is no need to compute the level. */
-    if (!server.maxmemory) {
+    if (!server.maxmemory_available) {
         if (level) *level = 0;
         return C_OK;
     }
 
-    if (server.maxmemory_reserved_scale) {
-        if (mem_reported <= server.maxmemory_available && !level) return C_OK;
-    } else if (mem_reported <= server.maxmemory && !level) {
-        return C_OK;
-    }
+    if (mem_reported <= server.maxmemory_available && !level) return C_OK;
 
     /* Remove the size of replicas output buffers and AOF buffer from the
      * count of used memory. */

src/server.c

@@ -2622,7 +2622,7 @@ void initServer(void) {
     resetReplicationBuffer();
 
     if (server.maxmemory) {
-        calculateMaxAvailableMemory();
+        updateMaxAvailableMemory();
     }
 
     /* Make sure the locale is set on startup based on the config file. */

src/server.h

@@ -3012,7 +3012,7 @@ void trimStringObjectIfNeeded(robj *o, int trim_small_values);
 static inline int canUseSharedObject(void) {
     return server.maxmemory == 0 || !(server.maxmemory_policy & MAXMEMORY_FLAG_NO_SHARED_INTEGERS);
 }
-static inline void calculateMaxAvailableMemory(void) {
+static inline void updateMaxAvailableMemory(void) {
     server.maxmemory_available = (unsigned long long)server.maxmemory / 100.0 * (100 - server.maxmemory_reserved_scale);
 }
 #define sdsEncodedObject(objptr) (objptr->encoding == OBJ_ENCODING_RAW || objptr->encoding == OBJ_ENCODING_EMBSTR)

tests/unit/maxmemory.tcl

@@ -145,6 +145,25 @@ start_server {tags {"maxmemory" "external:skip"}} {
 }
 
 start_server {tags {"maxmemory external:skip"}} {
+
+    test "maxmemory-reserved-scale" {
+        r flushdb
+	r config set maxmemory 10mb
+        set  current_dbsize 0
+
+	foreach scale_value {30 10 0} {
+	    r config set maxmemory-reserved-scale $scale_value
+	    # fill 20mb using 200 keys of 100kb
+            catch { for {set j 0} {$j < 200} {incr j} {
+                r setrange $j 100000 x
+            }} e
+	    assert_match {*OOM*} $e
+	    assert_lessthan $current_dbsize [r dbsize]
+	    set current_dbsize [r dbsize]
+	}
+	r flushdb
+    }
+
     test "Without maxmemory small integers are shared" {
         r config set maxmemory 0
         r set a 1