Repository: jclouds
Updated Branches:
  refs/heads/master d649c90d9 -> f8ebbfdf8


Fixes an intermittently failing swift live test.


Project: http://git-wip-us.apache.org/repos/asf/jclouds/repo
Commit: http://git-wip-us.apache.org/repos/asf/jclouds/commit/f8ebbfdf
Tree: http://git-wip-us.apache.org/repos/asf/jclouds/tree/f8ebbfdf
Diff: http://git-wip-us.apache.org/repos/asf/jclouds/diff/f8ebbfdf

Branch: refs/heads/master
Commit: f8ebbfdf8a43a716f49cb910ff773d62c3daa894
Parents: d649c90
Author: Zack Shoylev <[email protected]>
Authored: Mon Mar 7 13:48:37 2016 -0600
Committer: Zack Shoylev <[email protected]>
Committed: Tue Mar 8 12:38:13 2016 -0600

----------------------------------------------------------------------
 .../swift/v1/features/StaticLargeObjectApiLiveTest.java       | 5 +++++
 .../openstack/swift/v1/internal/BaseSwiftApiLiveTest.java     | 7 +++++++
 2 files changed, 12 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/jclouds/blob/f8ebbfdf/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/features/StaticLargeObjectApiLiveTest.java
----------------------------------------------------------------------
diff --git 
a/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/features/StaticLargeObjectApiLiveTest.java
 
b/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/features/StaticLargeObjectApiLiveTest.java
index 6eca88c..e558291 100644
--- 
a/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/features/StaticLargeObjectApiLiveTest.java
+++ 
b/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/features/StaticLargeObjectApiLiveTest.java
@@ -62,9 +62,11 @@ public class StaticLargeObjectApiLiveTest extends 
BaseSwiftApiLiveTest<SwiftApi>
          ObjectApi objectApi = api.getObjectApi(regionId, containerName);
 
          String etag1s = objectApi.put(name + "/1", 
newByteSourcePayload(ByteSource.wrap(megOf1s)));
+         awaitConsistency();
          assertMegabyteAndETagMatches(regionId, name + "/1", etag1s);
 
          String etag2s = objectApi.put(name + "/2", 
newByteSourcePayload(ByteSource.wrap(megOf2s)));
+         awaitConsistency();
          assertMegabyteAndETagMatches(regionId, name + "/2", etag2s);
 
          List<Segment> segments = ImmutableList.<Segment> builder()
@@ -76,11 +78,14 @@ public class StaticLargeObjectApiLiveTest extends 
BaseSwiftApiLiveTest<SwiftApi>
                      .build())
                      .build();
 
+         awaitConsistency();
          String etagOfEtags = api.getStaticLargeObjectApi(regionId, 
containerName).replaceManifest(
                name, segments, ImmutableMap.of("myfoo", "Bar"));
 
          assertNotNull(etagOfEtags);
 
+         awaitConsistency();
+
          SwiftObject bigObject = api.getObjectApi(regionId, 
containerName).get(name);
          assertEquals(bigObject.getETag(), etagOfEtags);
          
assertEquals(bigObject.getPayload().getContentMetadata().getContentLength(), 
Long.valueOf(2 * 1024 * 1024));

http://git-wip-us.apache.org/repos/asf/jclouds/blob/f8ebbfdf/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/internal/BaseSwiftApiLiveTest.java
----------------------------------------------------------------------
diff --git 
a/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/internal/BaseSwiftApiLiveTest.java
 
b/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/internal/BaseSwiftApiLiveTest.java
index a5cf538..b995583 100644
--- 
a/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/internal/BaseSwiftApiLiveTest.java
+++ 
b/apis/openstack-swift/src/test/java/org/jclouds/openstack/swift/v1/internal/BaseSwiftApiLiveTest.java
@@ -48,6 +48,13 @@ public abstract class BaseSwiftApiLiveTest<A extends 
SwiftApi> extends BaseApiLi
       provider = "openstack-swift";
    }
 
+   protected static final int AWAIT_CONSISTENCY_TIMEOUT_SECONDS = 
Integer.parseInt(System.getProperty(
+         "test.blobstore.await-consistency-timeout-seconds", "10"));
+
+   protected void awaitConsistency() {
+      Uninterruptibles.sleepUninterruptibly(AWAIT_CONSISTENCY_TIMEOUT_SECONDS, 
TimeUnit.SECONDS);
+   }
+
    @Override
    @BeforeClass(groups = "live")
    public void setup() {

Reply via email to