wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fixed the build

This commit is contained in:
Evan Tschannen 2021-07-28 14:02:12 -07:00
parent 406562b282
commit e9409b02fe
2 changed files with 27 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fdbclient/NativeAPI.actor.cpp
View File

@ -6532,7 +6532,7 @@ ACTOR Future<Standalone<VectorRef<MutationRefAndVersion>>> getRangeFeedMutations
wait(getKeyRangeLocations(cx,
keys,
100,
false,
Reverse::False,
&StorageServerInterface::rangeFeed,
TransactionInfo(TaskPriority::DefaultEndpoint, span.context)));
@ -6548,7 +6548,7 @@ ACTOR Future<Standalone<VectorRef<MutationRefAndVersion>>> getRangeFeedMutations
&StorageServerInterface::rangeFeed,
req,
TaskPriority::DefaultPromiseEndpoint,
false,
AtMostOnce::False,
cx->enableLocalityLoadBalance ? &cx->queueModel : nullptr));
return Standalone<VectorRef<MutationRefAndVersion>>(rep.mutations, rep.arena);
}
@ -6571,7 +6571,7 @@ ACTOR Future<Void> popRangeFeedMutationsActor(Reference<DatabaseContext> db, Str
wait(getKeyRangeLocations(cx,
keys,
100,
false,
Reverse::False,
&StorageServerInterface::rangeFeed,
TransactionInfo(TaskPriority::DefaultEndpoint, span.context)));

24
fdbclient/StorageServerInterface.cpp
View File

@ -296,6 +296,27 @@ void TSS_traceMismatch(TraceEvent& event,
ASSERT(false);
}
// split range
template <>
bool TSS_doCompare(const RangeFeedReply& src, const RangeFeedReply& tss) {
ASSERT(false);
return true;
}
template <>
const char* TSS_mismatchTraceName(const RangeFeedRequest& req) {
ASSERT(false);
return "";
}
template <>
void TSS_traceMismatch(TraceEvent& event,
const RangeFeedRequest& req,
const RangeFeedReply& src,
const RangeFeedReply& tss) {
ASSERT(false);
}
// only record metrics for data reads
template <>
@ -334,6 +355,9 @@ void TSSMetrics::recordLatency(const SplitRangeRequest& req, double ssLatency, d
template <>
void TSSMetrics::recordLatency(const GetKeyValuesStreamRequest& req, double ssLatency, double tssLatency) {}
template <>
void TSSMetrics::recordLatency(const RangeFeedRequest& req, double ssLatency, double tssLatency) {}
// -------------------
TEST_CASE("/StorageServerInterface/TSSCompare/TestComparison") {