From 769edb94ffbf10f349307a56ab6bada0d46271df Mon Sep 17 00:00:00 2001 From: TeoV Date: Mon, 11 Nov 2019 11:36:44 +0200 Subject: [PATCH] Sync GetKeysForPrefix for InternalDB with other DataDBs --- engine/storage_internal_datadb.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/engine/storage_internal_datadb.go b/engine/storage_internal_datadb.go index cb4ce1fab..ea9dcb860 100644 --- a/engine/storage_internal_datadb.go +++ b/engine/storage_internal_datadb.go @@ -81,17 +81,13 @@ func (iDB *InternalDB) SelectDatabase(dbName string) (err error) { return nil } -func (iDB *InternalDB) GetKeysForPrefix(prefix string) (ids []string, err error) { +func (iDB *InternalDB) GetKeysForPrefix(prefix string) ([]string, error) { keyLen := len(utils.DESTINATION_PREFIX) if len(prefix) < keyLen { return nil, fmt.Errorf("unsupported prefix in GetKeysForPrefix: %s", prefix) } category := prefix[:keyLen] // prefix length - ids = iDB.db.GetItemIDs(utils.CachePrefixToInstance[category], prefix) - if len(ids) == 0 { - return nil, utils.ErrNotFound - } - return + return iDB.db.GetItemIDs(utils.CachePrefixToInstance[category], prefix), nil } func (iDB *InternalDB) RebuildReverseForPrefix(prefix string) (err error) {