fixed incorrect priorities on the log router

This commit is contained in:
Evan Tschannen 2018-06-18 17:36:40 -07:00
parent 0bdd25df23
commit eaca0fb2ea
1 changed files with 2 additions and 2 deletions

View File

@ -179,7 +179,7 @@ ACTOR Future<Void> 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<Void> 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) {