From 947b4dec64bc9c27921eb0a7afad49cd0f508476 Mon Sep 17 00:00:00 2001
From: Miki <mikif70@gmail.com>
Date: Mon, 6 Jun 2016 10:21:47 +0200
Subject: [PATCH] .

---
 consumer.go | 6 +++---
 main.go     | 2 +-
 producer.go | 4 ----
 3 files changed, 4 insertions(+), 8 deletions(-)

diff --git a/consumer.go b/consumer.go
index ce173eb..8369227 100644
--- a/consumer.go
+++ b/consumer.go
@@ -37,7 +37,7 @@ func consumer(id int) {
 			user:   prod.user,
 			logins: make([]string, 0),
 			error:  false,
-			empty:  true,
+			empty:  false,
 		}
 
 		start := time.Now()
@@ -102,8 +102,8 @@ func consumer(id int) {
 
 		count.AddLog(len(prod.logins))
 
-		if opts.MaxLogins > -1 && len(prod.logins) < opts.MaxLogins {
-			cons.empty = false
+		if opts.MaxLogins == -1 || len(prod.logins) < opts.MaxLogins {
+			cons.empty = true
 		}
 
 		if opts.Debug {
diff --git a/main.go b/main.go
index 244e308..ea1c871 100644
--- a/main.go
+++ b/main.go
@@ -11,7 +11,7 @@ import (
 )
 
 const (
-	_VERSION = "v2.8.1"
+	_VERSION = "v2.8.2"
 )
 
 var (
diff --git a/producer.go b/producer.go
index 5fac3b4..f738018 100644
--- a/producer.go
+++ b/producer.go
@@ -47,10 +47,6 @@ func producer(id int) {
 			}
 			log.Printf("LRANGE: %+v - %+v\n", err, logs)
 		}
-		//		if opts.Debug {
-		//			fmt.Printf("LRANGE: %s - %d\n", user, len(logs))
-		//			log.Printf("LRANGE: %s - %d\n", user, len(logs))
-		//		}
 
 		if opts.Debug {
 			fmt.Printf("PROD (%d): user=%s login=%d in %v - conn=%d\n", id, user, len(logs), time.Since(start), dbs.rdb.ActiveCount())