Fixes missing consistency waits in testDirectory

This commit is contained in:
Zack Shoylev 2015-03-17 19:09:27 -05:00
parent e25a44eab9
commit a26208b9f4
1 changed files with 4 additions and 0 deletions

View File

@ -252,6 +252,8 @@ public class BaseContainerIntegrationTest extends BaseBlobStoreIntegrationTest {
assert view.getBlobStore().directoryExists(containerName, directory + "/" + directory); assert view.getBlobStore().directoryExists(containerName, directory + "/" + directory);
view.getBlobStore().clearContainer(containerName, inDirectory(directory)); view.getBlobStore().clearContainer(containerName, inDirectory(directory));
awaitConsistency();
assert view.getBlobStore().directoryExists(containerName, directory); assert view.getBlobStore().directoryExists(containerName, directory);
assert view.getBlobStore().directoryExists(containerName, directory + "/" + directory); assert view.getBlobStore().directoryExists(containerName, directory + "/" + directory);
@ -262,6 +264,8 @@ public class BaseContainerIntegrationTest extends BaseBlobStoreIntegrationTest {
view.getBlobStore().createDirectory(containerName, directory + "/" + directory); view.getBlobStore().createDirectory(containerName, directory + "/" + directory);
awaitConsistency();
container = view.getBlobStore().list(containerName, inDirectory(directory).recursive()); container = view.getBlobStore().list(containerName, inDirectory(directory).recursive());
assert container.getNextMarker() == null; assert container.getNextMarker() == null;
assert container.size() == 1 : container; assert container.size() == 1 : container;