uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Updated index for internalDB

Browse Source
This commit is contained in:
Trial97
2021-07-08 11:29:56 +03:00
committed by Dan Christian Bogos
parent 7ef629e930
commit e1398c57b3
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
engine/libindex_health.go
View File

@@ -533,7 +533,6 @@ func GetFltrIdxHealth(dm *DataManager, fltrCache, fltrIdxCache, objCache *ltcach
splt := utils.SplitConcatenatedKey(dataID) // tntCtx:filterType:fieldName:fieldVal
lsplt := len(splt)
if lsplt < 4 {
fmt.Println(idxPrfx)
err = fmt.Errorf("WRONG_IDX_KEY_FORMAT<%s>", dataID)
return
}

9
engine/storage_internal_datadb.go
View File

@@ -795,7 +795,6 @@ func (iDB *InternalDB) RemAccountActionPlansDrv(acntID string) (err error) {
iDB.db.Remove(utils.CacheAccountActionPlans, acntID,
true, utils.NonTransactional)
return
return
}
func (iDB *InternalDB) PushTask(t *Task) (err error) {
@@ -928,7 +927,7 @@ func (iDB *InternalDB) GetFilterIndexesDrv(cacheID, tntCtx, filterType string,
if !ok || x == nil {
continue
}
dbKey = strings.TrimPrefix(dbKey, utils.CacheInstanceToPrefix[cacheID]+tntCtx+utils.CONCATENATED_KEY_SEP)
dbKey = strings.TrimPrefix(dbKey, tntCtx+utils.CONCATENATED_KEY_SEP)
indexes[dbKey] = x.(utils.StringMap).Clone()
}
if len(indexes) == 0 {
@@ -939,7 +938,7 @@ func (iDB *InternalDB) GetFilterIndexesDrv(cacheID, tntCtx, filterType string,
indexes = make(map[string]utils.StringMap)
for fldName, fldVal := range fldNameVal {
idxKey := utils.ConcatenatedKey(filterType, fldName, fldVal)
dbKey := utils.ConcatenatedKey(utils.CacheInstanceToPrefix[cacheID]+tntCtx, idxKey)
dbKey := utils.ConcatenatedKey(tntCtx, idxKey)
x, ok := iDB.db.Get(cacheID, dbKey)
if !ok || x == nil {
return nil, utils.ErrNotFound
@@ -977,7 +976,7 @@ func (iDB *InternalDB) SetFilterIndexesDrv(cacheID, tntCtx string,
return
}
for idxKey, indx := range indexes {
dbKey := utils.ConcatenatedKey(utils.CacheInstanceToPrefix[cacheID]+tntCtx, idxKey)
dbKey := utils.ConcatenatedKey(tntCtx, idxKey)
if transactionID != utils.EmptyString {
dbKey = "tmp_" + utils.ConcatenatedKey(dbKey, transactionID)
}
@@ -1004,7 +1003,7 @@ func (iDB *InternalDB) RemoveFilterIndexesDrv(cacheID, tntCtx string) (err error
func (iDB *InternalDB) MatchFilterIndexDrv(cacheID, tntCtx,
filterType, fieldName, fieldVal string) (itemIDs utils.StringMap, err error) {
dbKey := utils.ConcatenatedKey(utils.CacheInstanceToPrefix[cacheID]+tntCtx, filterType, fieldName, fieldVal)
dbKey := utils.ConcatenatedKey(tntCtx, filterType, fieldName, fieldVal)
x, ok := iDB.db.Get(cacheID, dbKey)
if !ok || x == nil {
return nil, utils.ErrNotFound