Skip to content

Conversation

@etschannen
Copy link
Contributor

This PR still has some correctness problems that need to be fixed.

self->cursor = self->logSystem->peekTxs( UID(), self->recoveryLoc, self->peekLocality ? self->peekLocality->get().primaryLocality : tagLocalityInvalid, self->peekLocality ? self->peekLocality->get().knownCommittedVersion : invalidVersion );
self->localityChanged = self->peekLocality->onChange();
}
}
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I had to put a wait(delay(0)) above the continue; on line 69, because getMore returns when there's a message, or when the version changes, and it appears we now have a very large number of version changes in a row. When that happens, there's a loop of wait(getMore) -> break -> !hasMessage() -> continue -> wait(getMore) that overflows the stack.

@etschannen etschannen marked this pull request as ready for review July 10, 2019 20:51
# Conflicts:
#	fdbserver/TagPartitionedLogSystem.actor.cpp
localSets.push_back(log);
if(log->locality == tagLocalitySatellite) {
bestSatelliteSet = localSets.size() - 1;
} else {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Typo s/sattelite/satellite

@alexmiller-apple alexmiller-apple self-assigned this Jul 11, 2019
@alexmiller-apple alexmiller-apple merged commit c8e94e6 into apple:master Jul 15, 2019
@etschannen etschannen deleted the feature-fast-txs-recovery branch July 31, 2019 02:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants