From cb9a6b94137f6fd983de0c20c0faf079b5bbb869 Mon Sep 17 00:00:00 2001 From: Zack Shoylev Date: Mon, 12 Aug 2013 16:18:26 -0500 Subject: [PATCH] Reduces parallelism to make test work better with slower connections Adjusts test timing to work properly and reliably --- .../integration/internal/BaseBlobIntegrationTest.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseBlobIntegrationTest.java b/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseBlobIntegrationTest.java index c55c49f256..7b14793ccc 100644 --- a/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseBlobIntegrationTest.java +++ b/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseBlobIntegrationTest.java @@ -44,6 +44,7 @@ import java.util.Map; import java.util.Random; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; +import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicInteger; import java.util.zip.GZIPInputStream; @@ -86,6 +87,7 @@ import com.google.common.io.Files; import com.google.common.io.InputSupplier; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; +import com.google.common.util.concurrent.Uninterruptibles; /** * @author Adrian Cole @@ -147,7 +149,7 @@ public class BaseBlobIntegrationTest extends BaseBlobStoreIntegrationTest { final String container = getContainerName(); try { Map> responses = Maps.newHashMap(); - for (int i = 0; i < 10; i++) { + for (int i = 0; i < 3; i++) { responses.put(i, this.exec.submit(new Callable() { @@ -325,10 +327,11 @@ public class BaseBlobIntegrationTest extends BaseBlobStoreIntegrationTest { String name = "apples"; - Date before = new Date(System.currentTimeMillis() - 1000); + Date before = new Date(System.currentTimeMillis() - 5000); addObjectAndValidateContent(container, name); - Date after = new Date(System.currentTimeMillis() + 1000); + Date after = new Date(System.currentTimeMillis() + 5000); + Uninterruptibles.sleepUninterruptibly(5, TimeUnit.SECONDS); view.getBlobStore().getBlob(container, name, ifUnmodifiedSince(after)); validateContent(container, name);