|
|
|
@ -363,9 +363,11 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem); " +
|
|
|
|
|
" redis.call('zrem', lastAccessTimeSetName, lruItem); " +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" local removedChannelName = KEYS[6]; " +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue); " +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg); " +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
@ -527,9 +529,11 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem);" +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem);" +
|
|
|
|
|
" redis.call('zrem', lastAccessTimeSetName, lruItem);" +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" local removedChannelName = KEYS[7];" +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue);" +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg);" +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end;" +
|
|
|
|
|
" end" +
|
|
|
|
|
" end;" +
|
|
|
|
@ -596,9 +600,11 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem); " +
|
|
|
|
|
" redis.call('zrem', lastAccessTimeSetName, lruItem); " +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" local removedChannelName = KEYS[6]; " +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue); " +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg); " +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
@ -672,9 +678,11 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem); " +
|
|
|
|
|
" redis.call('zrem', lastAccessTimeSetName, lruItem); " +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" local removedChannelName = KEYS[7]; " +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue); " +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg); " +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
@ -804,9 +812,11 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem); " +
|
|
|
|
|
" redis.call('zrem', lastAccessTimeSetName, lruItem); " +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" local removedChannelName = KEYS[7]; " +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue); " +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg); " +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
@ -936,6 +946,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" for index, lruItem in ipairs(lruItems) do " +
|
|
|
|
|
" if lruItem then " +
|
|
|
|
|
" local lruItemValue = redis.call('hget', KEYS[1], lruItem); " +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" redis.call('hdel', KEYS[1], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem); " +
|
|
|
|
@ -943,6 +954,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" local removedChannelName = KEYS[7]; " +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue); " +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg); " +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
@ -1335,6 +1347,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" for index, lruItem in ipairs(lruItems) do " +
|
|
|
|
|
" if lruItem then " +
|
|
|
|
|
" local lruItemValue = redis.call('hget', KEYS[1], lruItem); " +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" redis.call('hdel', KEYS[1], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem); " +
|
|
|
|
@ -1342,6 +1355,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" local removedChannelName = KEYS[7]; " +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue); " +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg); " +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
@ -1385,6 +1399,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" for index, lruItem in ipairs(lruItems) do " +
|
|
|
|
|
" if lruItem then " +
|
|
|
|
|
" local lruItemValue = redis.call('hget', KEYS[1], lruItem); " +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" redis.call('hdel', KEYS[1], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem); " +
|
|
|
|
@ -1392,6 +1407,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" local removedChannelName = KEYS[6]; " +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue); " +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg); " +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
@ -1529,6 +1545,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" for index, lruItem in ipairs(lruItems) do " +
|
|
|
|
|
" if lruItem then " +
|
|
|
|
|
" local lruItemValue = redis.call('hget', KEYS[1], lruItem); " +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" redis.call('hdel', KEYS[1], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem); " +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem); " +
|
|
|
|
@ -1536,6 +1553,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" local removedChannelName = KEYS[6]; " +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue); " +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg); " +
|
|
|
|
|
"end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
|
" end; " +
|
|
|
|
@ -1720,13 +1738,15 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
|
|
|
|
|
" for index, lruItem in ipairs(lruItems) do" +
|
|
|
|
|
" if lruItem then" +
|
|
|
|
|
" local lruItemValue = redis.call('hget', KEYS[1], lruItem);" +
|
|
|
|
|
" if lruItemValue ~= false then " +
|
|
|
|
|
" redis.call('hdel', KEYS[1], lruItem);" +
|
|
|
|
|
" redis.call('zrem', KEYS[2], lruItem);" +
|
|
|
|
|
" redis.call('zrem', KEYS[3], lruItem);" +
|
|
|
|
|
" redis.call('zrem', lastAccessTimeSetName, lruItem);" +
|
|
|
|
|
" local removedChannelName = KEYS[7];" +
|
|
|
|
|
" local msg = struct.pack('Lc0Lc0', string.len(lruItem), lruItem, string.len(lruItemValue), lruItemValue);" +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg);" +
|
|
|
|
|
" redis.call('publish', removedChannelName, msg);"
|
|
|
|
|
+ "end; " +
|
|
|
|
|
" end;" +
|
|
|
|
|
" end" +
|
|
|
|
|
" end;" +
|
|
|
|
|