Browse Source

Update redis.go

master
yuriy0803 5 years ago
parent
commit
21da34da39
  1. 13
      storage/redis.go

13
storage/redis.go

@ -440,15 +440,10 @@ func (r *RedisClient) WriteBlock(login, id string, params []string, diff, roundD
} }
func (r *RedisClient) writeShare(tx *redis.Multi, ms, ts int64, login, id string, diff int64, expire time.Duration) { func (r *RedisClient) writeShare(tx *redis.Multi, ms, ts int64, login, id string, diff int64, expire time.Duration) {
/* # Note To Me: times := int(diff / 1000000000)
Will have to write to get from redis the current value for round for i := 0; i < times; i++ {
shares and increase by 1, then include the new number to be added to redis tx.LPush(r.formatKey("lastshares"), login)
*/ }
// Moved get hostname to stratums
tx.LPush(r.formatKey("lastshares"), login)
tx.LTrim(r.formatKey("lastshares"), 0, r.pplns) tx.LTrim(r.formatKey("lastshares"), 0, r.pplns)
tx.HIncrBy(r.formatKey("shares", "roundCurrent"), login, diff) tx.HIncrBy(r.formatKey("shares", "roundCurrent"), login, diff)
tx.ZAdd(r.formatKey("hashrate"), redis.Z{Score: float64(ts), Member: join(diff, login, id, ms)}) tx.ZAdd(r.formatKey("hashrate"), redis.Z{Score: float64(ts), Member: join(diff, login, id, ms)})

Loading…
Cancel
Save