diff --git a/fdbserver/LogRouter.actor.cpp b/fdbserver/LogRouter.actor.cpp index 6f33c9f9f6..4a81554d1b 100644 --- a/fdbserver/LogRouter.actor.cpp +++ b/fdbserver/LogRouter.actor.cpp @@ -179,7 +179,7 @@ ACTOR Future pullAsyncData( LogRouterData *self ) { loop { loop { choose { - when(Void _ = wait( r ? r->getMore() : Never() ) ) { + when(Void _ = wait( r ? r->getMore(TaskTLogCommit) : Never() ) ) { break; } when( Void _ = wait( dbInfoChange ) ) { //FIXME: does this actually happen? @@ -336,7 +336,7 @@ ACTOR Future logRouterPop( LogRouterData* self, TLogPopRequest req ) { while(!self->messageBlocks.empty() && self->messageBlocks.front().first < minPopped) { self->messageBlocks.pop_front(); - Void _ = wait(yield(TaskUpdateStorage)); + Void _ = wait(yield(TaskTLogPop)); } if(self->logSystem->get() && self->allowPops) {