thread.join();
}
assertTrueEventually(new AssertTask() {
@Override
public void run() throws Exception {
<BUG>for (int i = 0; i < cacheSize; i++) {
</BUG>
Integer valueSeenFromMember = memberCache.get(i);
Integer valueSeenFromClient = clientCache.get(i);
String msg = createFailureMessage(i);

thread.join();
}
assertTrueEventually(new AssertTask() {
@Override
public void run() throws Exception {
for (int i = 0; i < KEY_COUNT; i++) {
Integer valueSeenFromMember = memberCache.get(i);
Integer valueSeenFromClient = clientCache.get(i);
String msg = createFailureMessage(i);
