mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-16 21:59:53 +05:00
Mongo counter private
This commit is contained in:
@@ -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) {
|
||||
|
||||
@@ -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()
|
||||
|
||||
Reference in New Issue
Block a user