diff --git a/fdbserver/Knobs.cpp b/fdbserver/Knobs.cpp index b0696b5efe..d9900f0d60 100644 --- a/fdbserver/Knobs.cpp +++ b/fdbserver/Knobs.cpp @@ -62,7 +62,7 @@ ServerKnobs::ServerKnobs(bool randomize, ClientKnobs* clientKnobs) { init( PEEK_TRACKER_EXPIRATION_TIME, 600 ); if( randomize && BUGGIFY ) PEEK_TRACKER_EXPIRATION_TIME = g_random->coinflip() ? 0.1 : 60; init( PARALLEL_GET_MORE_REQUESTS, 32 ); if( randomize && BUGGIFY ) PARALLEL_GET_MORE_REQUESTS = 2; init( MAX_QUEUE_COMMIT_BYTES, 15e6 ); if( randomize && BUGGIFY ) MAX_QUEUE_COMMIT_BYTES = 5000; - init( VERSIONS_PER_BATCH, VERSIONS_PER_SECOND/10 ); if( randomize && BUGGIFY ) VERSIONS_PER_BATCH = std::max(1,VERSIONS_PER_SECOND/1000); + init( VERSIONS_PER_BATCH, VERSIONS_PER_SECOND/20 ); if( randomize && BUGGIFY ) VERSIONS_PER_BATCH = std::max(1,VERSIONS_PER_SECOND/1000); // Data distribution queue init( HEALTH_POLL_TIME, 1.0 ); diff --git a/fdbserver/LogSystemPeekCursor.actor.cpp b/fdbserver/LogSystemPeekCursor.actor.cpp index 8b7ab92812..f39b58279c 100644 --- a/fdbserver/LogSystemPeekCursor.actor.cpp +++ b/fdbserver/LogSystemPeekCursor.actor.cpp @@ -988,6 +988,7 @@ ACTOR Future bufferedGetMore( ILogSystem::BufferedCursor* self, int taskID loaders.push_back(bufferedGetMoreLoader(self, cursor, targetVersion, taskID)); } Void _ = wait( waitForAll(loaders) ); + Void _ = wait(yield()); if(self->collectTags) { std::sort(self->messages.begin(), self->messages.end()); @@ -1001,6 +1002,8 @@ ACTOR Future bufferedGetMore( ILogSystem::BufferedCursor* self, int taskID if(self->collectTags) { self->combineMessages(); } + + Void _ = wait(yield()); return Void(); }