fix for start hang

This commit is contained in:
Radu Ioan Fericean
2016-07-22 17:59:56 +03:00
parent 05f58e061d
commit c35a260003

View File

@@ -40,9 +40,9 @@ func (cs cacheDoubleStore) Put(key string, value interface{}) {
cs[prefix] = mp
}
mp[key] = value
if err := dumper.put(prefix, key, value); err != nil {
/*if err := dumper.put(prefix, key, value); err != nil {
utils.Logger.Info("<cache dumper> put error: " + err.Error())
}
}*/
}
func (cs cacheDoubleStore) Get(key string) (interface{}, error) {
@@ -84,18 +84,18 @@ func (cs cacheDoubleStore) Delete(key string) {
prefix, key := key[:PREFIX_LEN], key[PREFIX_LEN:]
if keyMap, ok := cs[prefix]; ok {
delete(keyMap, key)
if err := dumper.delete(prefix, key); err != nil {
/*if err := dumper.delete(prefix, key); err != nil {
utils.Logger.Info("<cache dumper> delete error: " + err.Error())
}
}*/
}
}
func (cs cacheDoubleStore) DeletePrefix(prefix string) {
delete(cs, prefix)
if err := dumper.deleteAll(prefix); err != nil {
/*if err := dumper.deleteAll(prefix); err != nil {
utils.Logger.Info("<cache dumper> delete all error: " + err.Error())
}
}*/
}
func (cs cacheDoubleStore) CountEntriesForPrefix(prefix string) int {