From e776bc4fb40c816557f6d49d064031048d60e0ad Mon Sep 17 00:00:00 2001
From: amichelo <andrea.michelotti@lnf.infn.it>
Date: Wed, 27 Oct 2021 16:32:22 +0200
Subject: [PATCH] try debug
---
ChaosMetadataService/QueryDataMsgPSConsumer.cpp | 3 ++-
chaos/common/caching_system/CacheDriver.cpp | 14 +++++++-------
2 files changed, 9 insertions(+), 8 deletions(-)
diff --git a/ChaosMetadataService/QueryDataMsgPSConsumer.cpp b/ChaosMetadataService/QueryDataMsgPSConsumer.cpp
index 5e5182208..5ea4d176d 100644
--- a/ChaosMetadataService/QueryDataMsgPSConsumer.cpp
+++ b/ChaosMetadataService/QueryDataMsgPSConsumer.cpp
@@ -128,7 +128,8 @@ void QueryDataMsgPSConsumer::messageHandler(const chaos::common::message::ele_t&
}
- }}
+ }
+ }
QueryDataConsumer::consumePutEvent(kp, (uint8_t)st, meta_tag_set, *(data.cd.get()));
}
diff --git a/chaos/common/caching_system/CacheDriver.cpp b/chaos/common/caching_system/CacheDriver.cpp
index 2108baf6e..c2bc8705e 100644
--- a/chaos/common/caching_system/CacheDriver.cpp
+++ b/chaos/common/caching_system/CacheDriver.cpp
@@ -52,10 +52,10 @@ void CacheDriver::deinit() {
first_level_cache.clear();
}
chaos::common::data::CDWShrdPtr CacheDriver::getData(const std::string& key) {
- if ((enable_cache_for_ms.count(key)) && (first_level_cache.count(key))) {
+ if ((enable_cache_for_ms.find(key)!=enable_cache_for_ms.end()) && (first_level_cache.find(key)!=first_level_cache.end())) {
uint64_t now = chaos::common::utility::TimingUtil::getTimeStamp();
if ((now - first_level_cache[key].first) < enable_cache_for_ms[key]) {
- // LDBG_ << "retrive from caching:" << key;
+ LDBG_ << "retrive from caching:" << key;
return first_level_cache[key].second;
}
@@ -66,9 +66,9 @@ chaos::common::data::CDWShrdPtr CacheDriver::getData(const std::string& key) {
if (d.get() && d->size()) {
chaos::common::data::CDataWrapper* tmp = new chaos::common::data::CDataWrapper(d->data(), d->size());
ret.reset(tmp);
- if (enable_cache_for_ms.count(key)) {
+ if (enable_cache_for_ms.find(key)!=enable_cache_for_ms.end()) {
uint64_t now = chaos::common::utility::TimingUtil::getTimeStamp();
- // LDBG_ << "mupdate caching:" << key;
+ LDBG_ << "mupdate caching:" << key;
first_level_cache[key] = {now, ret};
}
}
@@ -98,7 +98,7 @@ std::vector<chaos::common::data::CDWShrdPtr> CacheDriver::getData(const ChaosStr
} else {
ChaosStringVector nocached;
for (ChaosStringVector::const_iterator i = keys.begin(); i != keys.end(); i++) {
- if ((enable_cache_for_ms.count(*i)) && (first_level_cache.count(*i))) {
+ if ((enable_cache_for_ms.find(*i)!=enable_cache_for_ms.end()) && (first_level_cache.find(*i)!=first_level_cache.end())) {
if ((now - first_level_cache[*i].first) < enable_cache_for_ms[*i]) {
is_cached[*i] = true;
} else {
@@ -124,9 +124,9 @@ std::vector<chaos::common::data::CDWShrdPtr> CacheDriver::getData(const ChaosStr
} else {
chaos::common::data::CDWShrdPtr r = chaos::common::data::CDWShrdPtr(new chaos::common::data::CDataWrapper(cached_element->data(), cached_element->size()));
ret.push_back(r);
- if (enable_cache_for_ms.count(*it)) {
+ if (enable_cache_for_ms.find(*it)!=enable_cache_for_ms.end()) {
if (enable_cache_for_ms[*it] > 0) {
- // LDBG_ << "mupdate caching:" << *it;
+ LDBG_ << "mupdate caching:" << *it;
first_level_cache[*it] = {now, r};
}
}
--
GitLab