From af63ada58ac7992bbae43d90b394e9ccfe9efe11 Mon Sep 17 00:00:00 2001 From: thushara wijeratna Date: Sun, 18 Dec 2022 19:13:52 -0800 Subject: [PATCH] fix redis warnings on pipelined usage --- redis-sampler.rb | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/redis-sampler.rb b/redis-sampler.rb index 34d7cea..1e2a855 100755 --- a/redis-sampler.rb +++ b/redis-sampler.rb @@ -56,9 +56,9 @@ def incr_freq_table(hash,item) def sample @samplesize.times { k = @redis.randomkey - p = @redis.pipelined { - @redis.type(k) - @redis.ttl(k) + p = @redis.pipelined {|pl| + pl.type(k) + pl.ttl(k) } t = p[0] x = p[1] @@ -67,27 +67,27 @@ def sample incr_freq_table(@expires,x) case t when 'zset' - p = @redis.pipelined { - @redis.zcard(k) - @redis.zrange(k,0,0) + p = @redis.pipelined {|pl| + pl.zcard(k) + pl.zrange(k,0,0) } card = p[0] ele = p[1][0] incr_freq_table(@zset_card,card) if card != 0 incr_freq_table(@zset_elesize,ele.length) if ele when 'set' - p = @redis.pipelined { - @redis.scard(k) - @redis.srandmember(k) + p = @redis.pipelined {|pl| + pl.scard(k) + pl.srandmember(k) } card = p[0] ele = p[1] incr_freq_table(@set_card,card) if card != 0 incr_freq_table(@set_elesize,ele.length) if ele when 'list' - p = @redis.pipelined { - @redis.llen(k) - @redis.lrange(k,0,0) + p = @redis.pipelined {|pl| + pl.llen(k) + pl.lrange(k,0,0) } len = p[0] ele = p[1][0]