@@ -442,47 +442,6 @@ class ApplyMetadataMutationsImpl {
442442 txnStateStore->set (KeyValueRef (m.param1 , m.param2 ));
443443 }
444444
445- void checkSetChangeFeedPrefix (MutationRef m) {
446- if (!m.param1 .startsWith (changeFeedPrefix)) {
447- return ;
448- }
449- if (toCommit && keyInfo) {
450- KeyRange r = std::get<0 >(decodeChangeFeedValue (m.param2 ));
451- MutationRef privatized = m;
452- privatized.clearChecksumAndAccumulativeIndex ();
453- privatized.param1 = m.param1 .withPrefix (systemKeys.begin , arena);
454- auto ranges = keyInfo->intersectingRanges (r);
455- auto firstRange = ranges.begin ();
456- ++firstRange;
457- if (firstRange == ranges.end ()) {
458- ranges.begin ().value ().populateTags ();
459- if (acsBuilder != nullptr ) {
460- updateMutationWithAcsAndAddMutationToAcsBuilder (acsBuilder,
461- privatized,
462- ranges.begin ().value ().tags ,
463- accumulativeChecksumIndex,
464- epoch.get (),
465- version,
466- dbgid);
467- }
468- toCommit->addTags (ranges.begin ().value ().tags );
469- } else {
470- std::set<Tag> allSources;
471- for (auto r : ranges) {
472- r.value ().populateTags ();
473- allSources.insert (r.value ().tags .begin (), r.value ().tags .end ());
474- }
475- if (acsBuilder != nullptr ) {
476- updateMutationWithAcsAndAddMutationToAcsBuilder (
477- acsBuilder, privatized, allSources, accumulativeChecksumIndex, epoch.get (), version, dbgid);
478- }
479- toCommit->addTags (allSources);
480- }
481- TraceEvent (SevDebug, " SendingPrivatized_ChangeFeed" , dbgid).detail (" M" , privatized);
482- writeMutation (privatized);
483- }
484- }
485-
486445 void checkSetServerListPrefix (MutationRef m) {
487446 if (!m.param1 .startsWith (serverListPrefix)) {
488447 return ;
@@ -1596,8 +1555,7 @@ class ApplyMetadataMutationsImpl {
15961555 checkSetTenantMapPrefix (m);
15971556 checkSetOtherKeys (m);
15981557 break ;
1599- case ' \x02 ' : // 0x02 - Less common: \xff\x02/feed/, \xff\x02/cacheKeys/
1600- checkSetChangeFeedPrefix (m);
1558+ case ' \x02 ' : // 0x02 - Less common: \xff\x02/cacheKeys/
16011559 checkSetCacheKeysPrefix (m);
16021560 checkSetTenantMapPrefix (m);
16031561 checkSetOtherKeys (m);
0 commit comments