This commit is contained in:
DanB
2015-06-15 19:31:24 +02:00
2 changed files with 2 additions and 7 deletions

View File

@@ -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 {

View File

@@ -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
}