fix: log routers were starting one version too late

This commit is contained in:
Evan Tschannen 2018-04-17 00:29:16 -07:00
parent 3e40505f4a
commit 093908b83f
1 changed files with 1 additions and 1 deletions

View File

@ -154,7 +154,7 @@ void commitMessages( LogRouterData* self, Version version, const std::vector<Tag
ACTOR Future<Void> pullAsyncData( LogRouterData *self, Tag tag ) { ACTOR Future<Void> pullAsyncData( LogRouterData *self, Tag tag ) {
state Future<Void> dbInfoChange = Void(); state Future<Void> dbInfoChange = Void();
state Reference<ILogSystem::IPeekCursor> r; state Reference<ILogSystem::IPeekCursor> r;
state Version tagAt = self->version.get()+1; state Version tagAt = self->version.get();
state Version tagPopped = 0; state Version tagPopped = 0;
state Version lastVer = 0; state Version lastVer = 0;
state std::vector<int> tags; state std::vector<int> tags;