diff --git a/fdbserver/ApplyMetadataMutation.cpp b/fdbserver/ApplyMetadataMutation.cpp index 1bfb29bb57..2ab63d9413 100644 --- a/fdbserver/ApplyMetadataMutation.cpp +++ b/fdbserver/ApplyMetadataMutation.cpp @@ -319,7 +319,7 @@ void applyMetadataMutations(SpanID const& spanContext, UID const& dbgid, Arena& if (firstRange == ranges.end()) { ranges.begin().value().populateTags(); TraceEvent("RangeFeedTags1").detail("Tags", describe(ranges.begin().value().tags)); - //toCommit->addTags(ranges.begin().value().tags); + toCommit->addTags(ranges.begin().value().tags); } else { std::set allSources; @@ -328,9 +328,9 @@ void applyMetadataMutations(SpanID const& spanContext, UID const& dbgid, Arena& allSources.insert(r.value().tags.begin(), r.value().tags.end()); } TraceEvent("RangeFeedTags2").detail("Tags", describe(allSources)); - //toCommit->addTags(allSources); + toCommit->addTags(allSources); } - //toCommit->writeTypedMessage(privatized); + toCommit->writeTypedMessage(privatized); } } } else if (m.param2.size() > 1 && m.param2[0] == systemKeys.begin[0] && m.type == MutationRef::ClearRange) { diff --git a/fdbserver/storageserver.actor.cpp b/fdbserver/storageserver.actor.cpp index ebbf4e68de..7f6e5dd9d2 100644 --- a/fdbserver/storageserver.actor.cpp +++ b/fdbserver/storageserver.actor.cpp @@ -2883,7 +2883,6 @@ private: Key rangeFeedId = m.param1.removePrefix(rangeFeedPrivatePrefix); KeyRange rangeFeedRange = decodeRangeFeedValue( m.param2 ); TraceEvent("AddingRangeFeed", data->thisServerID).detail("RangeID", rangeFeedId.printable()).detail("Range", rangeFeedRange.toString()); - /* Reference rangeFeedInfo( new RangeFeedInfo() ); rangeFeedInfo->range = rangeFeedRange; rangeFeedInfo->id = rangeFeedId; @@ -2893,7 +2892,6 @@ private: r->value().push_back( rangeFeedInfo ); } data->keyRangeFeed.coalesce( rangeFeedRange.contents() ); - */ } else { ASSERT(false); // Unknown private mutation }