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

FastRestore:Use new getBatchReplies that profile request latency

This commit is contained in:
Meng Xu 2020-02-21 15:59:57 -08:00
parent 505997ba0a
commit 4dd206b1b8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
fdbserver/RestoreCommon.actor.h
View File

@ -389,7 +389,7 @@ Future<Void> sendBatchRequests(RequestStream<Request> Interface::*channel, std::
// Similar to sendBatchRequests except that the caller expect to process the reply.
ACTOR template <class Interface, class Request>
Future<Void> getBatchRepliesV2(RequestStream<Request> Interface::*channel, std::map<UID, Interface> interfaces,
Future<Void> getBatchReplies(RequestStream<Request> Interface::*channel, std::map<UID, Interface> interfaces,
std::vector<std::pair<UID, Request>> requests, std::vector<REPLY_TYPE(Request)>* replies,
TaskPriority taskID = TaskPriority::Low, bool trackRequestLatency = true) {
if (requests.empty()) {
@ -492,7 +492,7 @@ Future<Void> getBatchRepliesV2(RequestStream<Request> Interface::*channel, std::
// Similar to sendBatchRequests except that the caller expect to process the reply.
// This actor can be combined with sendBatchRequests(...)
ACTOR template <class Interface, class Request>
Future<Void> getBatchReplies(RequestStream<Request> Interface::*channel, std::map<UID, Interface> interfaces,
Future<Void> getBatchRepliesToDelete(RequestStream<Request> Interface::*channel, std::map<UID, Interface> interfaces,
std::vector<std::pair<UID, Request>> requests, std::vector<REPLY_TYPE(Request)>* replies,
TaskPriority taskID = TaskPriority::Low) {