From 4a597fdcce643c7d724590de667410bde91fc86d Mon Sep 17 00:00:00 2001 From: Evan Tschannen Date: Tue, 5 Nov 2019 15:03:41 -0800 Subject: [PATCH] increase the task priority of popping --- fdbserver/TagPartitionedLogSystem.actor.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fdbserver/TagPartitionedLogSystem.actor.cpp b/fdbserver/TagPartitionedLogSystem.actor.cpp index 9a62d8b99e..c052552d80 100644 --- a/fdbserver/TagPartitionedLogSystem.actor.cpp +++ b/fdbserver/TagPartitionedLogSystem.actor.cpp @@ -1032,7 +1032,7 @@ struct TagPartitionedLogSystem : ILogSystem, ReferenceCounted popFromLog( TagPartitionedLogSystem* self, Reference>> log, Tag tag, double time ) { state Version last = 0; loop { - wait( delay(time) ); + wait( delay(time, TaskPriority::TLogPop) ); state std::pair to = self->outstandingPops[ std::make_pair(log->get().id(),tag) ]; @@ -1044,7 +1044,7 @@ struct TagPartitionedLogSystem : ILogSystem, ReferenceCountedget().present() ) return Void(); - wait(log->get().interf().popMessages.getReply( TLogPopRequest( to.first, to.second, tag ) ) ); + wait(log->get().interf().popMessages.getReply( TLogPopRequest( to.first, to.second, tag ), TaskPriority::TLogPop ) ); last = to.first; } catch (Error& e) {