uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-22 07:38:45 +05:00
Code Issues Packages Projects Releases Wiki Activity

try to release memory

Browse Source
This commit is contained in:
Radu Ioan Fericean
2015-11-16 19:55:03 +02:00
parent 7f76e66ef8
commit 8d9df1232c
3 changed files with 29 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
engine/tp_reader.go
View File

@@ -47,23 +47,8 @@ func NewTpReader(rs RatingStorage, as AccountingStorage, lr LoadReader, tpid, ti
ratingStorage: rs,
accountingStorage: as,
lr: lr,
actions: make(map[string][]*Action),
actionPlans: make(map[string][]*ActionPlan),
actionsTriggers: make(map[string]ActionTriggers),
rates: make(map[string]*utils.TPRate),
destinations: make(map[string]*Destination),
destinationRates: make(map[string]*utils.TPDestinationRate),
timings: make(map[string]*utils.TPTiming),
ratingPlans: make(map[string]*RatingPlan),
ratingProfiles: make(map[string]*RatingProfile),
sharedGroups: make(map[string]*SharedGroup),
lcrs: make(map[string]*LCR),
accountActions: make(map[string]*Account),
cdrStats: make(map[string]*CdrStats),
users: make(map[string]*UserProfile),
aliases: make(map[string]*Alias),
derivedChargers: make(map[string]*utils.DerivedChargers),
}
tpr.Init()
//add *any and *asap timing tag (in case of no timings file)
tpr.timings[utils.ANY] = &utils.TPTiming{
TimingId: utils.ANY,
@@ -86,6 +71,25 @@ func NewTpReader(rs RatingStorage, as AccountingStorage, lr LoadReader, tpid, ti
return tpr
}
func (tpr *TpReader) Init() {
tpr.actions = make(map[string][]*Action)
tpr.actionPlans = make(map[string][]*ActionPlan)
tpr.actionsTriggers = make(map[string]ActionTriggers)
tpr.rates = make(map[string]*utils.TPRate)
tpr.destinations = make(map[string]*Destination)
tpr.destinationRates = make(map[string]*utils.TPDestinationRate)
tpr.timings = make(map[string]*utils.TPTiming)
tpr.ratingPlans = make(map[string]*RatingPlan)
tpr.ratingProfiles = make(map[string]*RatingProfile)
tpr.sharedGroups = make(map[string]*SharedGroup)
tpr.lcrs = make(map[string]*LCR)
tpr.accountActions = make(map[string]*Account)
tpr.cdrStats = make(map[string]*CdrStats)
tpr.users = make(map[string]*UserProfile)
tpr.aliases = make(map[string]*Alias)
tpr.derivedChargers = make(map[string]*utils.DerivedChargers)
}
func (tpr *TpReader) LoadDestinationsFiltered(tag string) (bool, error) {
tpDests, err := tpr.lr.GetTpDestinations(tpr.tpid, tag)