diff --git a/engine/storage_mongo_datadb.go b/engine/storage_mongo_datadb.go index 04aad0010..7889d7a26 100644 --- a/engine/storage_mongo_datadb.go +++ b/engine/storage_mongo_datadb.go @@ -112,7 +112,7 @@ func NewMongoStorage(host, port, db, user, pass, storageType string, cdrsIndexes return nil, err } } - ms.Counter = utils.NewCounterGen(1000) + ms.cnter = utils.NewCounterGen(1000) return } @@ -124,7 +124,7 @@ type MongoStorage struct { cacheCfg *config.CacheConfig loadHistorySize int cdrsIndexes []string - Counter *utils.CounterGen + cnter *utils.CounterGen } func (ms *MongoStorage) conn(col string) (*mgo.Session, *mgo.Collection) { diff --git a/engine/storage_mongo_stordb.go b/engine/storage_mongo_stordb.go index 55318ab95..3791d60d7 100644 --- a/engine/storage_mongo_stordb.go +++ b/engine/storage_mongo_stordb.go @@ -883,7 +883,7 @@ func (ms *MongoStorage) GetSMCosts(cgrid, runid, originHost, originIDPrefix stri func (ms *MongoStorage) SetCDR(cdr *CDR, allowUpdate bool) (err error) { if cdr.OrderID == 0 { - cdr.OrderID = time.Now().UnixNano() + ms.Counter.Gen() + cdr.OrderID = time.Now().UnixNano() + ms.cnter.Gen() } session, col := ms.conn(utils.TBL_CDRS) defer session.Close()