2727#include < algorithm>
2828#include < limits>
2929
30+ // Unfortunately, turning on logging for the tests is limited to debug
31+ // mode. While we are in the midst of dropping in magma, this provides
32+ // a simple way to change all the logging->trace calls to logging->debug
33+ // by changing trace to debug..
34+ // Once magma has been completed, we can remove this #define and change
35+ // all the logging calls back to trace.
36+ #define TRACE trace
37+
3038using namespace magma ;
3139using namespace std ::chrono_literals;
3240
@@ -229,16 +237,16 @@ class MagmaRequest : public IORequest {
229237 *
230238 * @param item Item instance to be persisted
231239 * @param callback Persistence Callback
232- * @param logger Used for trace logging
240+ * @param logger Used for logging
233241 */
234242 MagmaRequest (const Item& item,
235243 MutationRequestCallback callback,
236244 std::shared_ptr<BucketLogger> logger)
237245 : IORequest(item.getVBucketId(), std::move(callback), DiskDocKey{item}),
238246 docMeta (magmakv::MetaData(item)),
239247 docBody(item.getValue()) {
240- if (logger->should_log (spdlog::level::trace )) {
241- logger->trace (" Request:{}" , to_string ());
248+ if (logger->should_log (spdlog::level::TRACE )) {
249+ logger->TRACE (" Request:{}" , to_string ());
242250 }
243251 }
244252
@@ -581,7 +589,7 @@ bool MagmaKVStore::commit(Collections::VB::Flush& collectionsFlush) {
581589 }
582590
583591 pendingReqs->clear ();
584- logger->trace (" MagmaKVStore::commit success:{}" , success);
592+ logger->TRACE (" MagmaKVStore::commit success:{}" , success);
585593
586594 return success;
587595}
@@ -618,7 +626,7 @@ void MagmaKVStore::commitCallback(int errCode, kvstats_ctx&) {
618626 st.delTimeHisto .add (req.getDelta ());
619627 }
620628
621- logger->trace (" commitCallback {} errCode:{} getDelCallback rv:{}" ,
629+ logger->TRACE (" commitCallback {} errCode:{} getDelCallback rv:{}" ,
622630 pendingReqs->front ().getVbID (),
623631 errCode,
624632 to_string (rv));
@@ -643,7 +651,7 @@ void MagmaKVStore::commitCallback(int errCode, kvstats_ctx&) {
643651 }
644652 req.getSetCallback ()(*transactionCtx, mutationSetStatus);
645653
646- logger->trace (
654+ logger->TRACE (
647655 " commitCallback {} errCode:{} getSetCallback rv:{} "
648656 " insertion:{}" ,
649657 pendingReqs->front ().getVbID (),
@@ -938,10 +946,10 @@ int MagmaKVStore::saveDocs(Collections::VB::Flush& collectionsFlush,
938946 continue ;
939947 }
940948
941- if (logger->should_log (spdlog::level::debug )) {
949+ if (logger->should_log (spdlog::level::TRACE )) {
942950 std::string hex, ascii;
943951 hexdump (key.Data (), key.Len (), hex, ascii);
944- logger->debug (
952+ logger->TRACE (
945953 " MagmaKVStore::saveDocs {} key:{} {} seqno:{} delete:{} "
946954 " found:{} "
947955 " tombstone:{}" ,
@@ -1094,9 +1102,9 @@ vbucket_state* MagmaKVStore::getVBucketState(Vbid vbid) {
10941102 vbstate = cachedVBStates[vbid.get ()].get ();
10951103 }
10961104
1097- if (logger->should_log (spdlog::level::trace )) {
1105+ if (logger->should_log (spdlog::level::TRACE )) {
10981106 auto j = encodeVBState (*vbstate, getMagmaInfo (vbid));
1099- logger->trace (" getVBucketState {} vbstate:{}" , vbid, j.dump ());
1107+ logger->TRACE (" getVBucketState {} vbstate:{}" , vbid, j.dump ());
11001108 }
11011109 return vbstate;
11021110}
@@ -1129,7 +1137,7 @@ magma::Status MagmaKVStore::readVBStateFromDisk(Vbid vbid) {
11291137 }
11301138
11311139 vbucket_state vbstate = j;
1132- logger->trace (" readVBStateFromDisk {} vbstate:{}" , vbid, j.dump ());
1140+ logger->TRACE (" readVBStateFromDisk {} vbstate:{}" , vbid, j.dump ());
11331141
11341142 auto vbs = std::make_unique<vbucket_state>(vbstate);
11351143 cachedVBStates[vbid.get ()] = std::move (vbs);
@@ -1158,7 +1166,7 @@ magma::Status MagmaKVStore::writeVBStateToDisk(
11581166 }
11591167
11601168 auto jstr = encodeVBState (*vbs, *minfo).dump ();
1161- logger->trace (" writeVBStateToDisk {} vbstate:{}" , vbid, jstr);
1169+ logger->TRACE (" writeVBStateToDisk {} vbstate:{}" , vbid, jstr);
11621170 return setLocalDoc (commitBatch, vbstateKey, jstr, false );
11631171}
11641172
@@ -1220,7 +1228,7 @@ std::pair<Status, std::string> MagmaKVStore::readLocalDoc(
12201228 vbid,
12211229 keySlice.ToString ());
12221230 } else {
1223- logger->trace (" MagmaKVStore::readLocalDoc({} key:{})" ,
1231+ logger->TRACE (" MagmaKVStore::readLocalDoc({} key:{})" ,
12241232 vbid,
12251233 keySlice.ToString ());
12261234 }
@@ -1240,7 +1248,7 @@ Status MagmaKVStore::setLocalDoc(Magma::CommitBatch& commitBatch,
12401248 // Store in localDB
12411249 Slice valSlice = {valString.c_str (), valString.size ()};
12421250
1243- logger->trace (" MagmaKVStore::setLocalDoc({} key:{})" ,
1251+ logger->TRACE (" MagmaKVStore::setLocalDoc({} key:{})" ,
12441252 commitBatch.GetkvID (),
12451253 const_cast <Slice&>(keySlice).ToString ());
12461254
0 commit comments