From af787149e2ceef29c9d284d2b59810fb07dfb44c Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Mon, 15 Jun 2015 19:05:42 +0300 Subject: [PATCH 1/2] fix for redis password issue --- engine/storage_redis.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/engine/storage_redis.go b/engine/storage_redis.go index 96dadb77c..ccd7e4f2d 100644 --- a/engine/storage_redis.go +++ b/engine/storage_redis.go @@ -39,12 +39,7 @@ type RedisStorage struct { } func NewRedisStorage(address string, db int, pass, mrshlerStr string) (*RedisStorage, error) { - ndb := &redis.Client{Addr: address, Db: db} - if pass != "" { - if err := ndb.Auth(pass); err != nil { - return nil, err - } - } + ndb := &redis.Client{Addr: address, Db: db, Password: pass} var mrshler Marshaler if mrshlerStr == utils.MSGPACK { From dd089225384af97b3524ceddd253a522e6279842 Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Mon, 15 Jun 2015 20:18:35 +0300 Subject: [PATCH 2/2] fix for #88 shared groups werw not writtent to redis --- engine/tp_reader.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/engine/tp_reader.go b/engine/tp_reader.go index 5c56c4242..a9b704770 100644 --- a/engine/tp_reader.go +++ b/engine/tp_reader.go @@ -1087,7 +1087,7 @@ func (tpr *TpReader) WriteToDatabase(flush, verbose bool) (err error) { log.Print("Shared Groups:") } for k, sg := range tpr.sharedGroups { - err = accountingStorage.SetSharedGroup(sg) + err = tpr.accountingStorage.SetSharedGroup(sg) if err != nil { return err }