---

Ajay Kannan · Ajay Kannan · commit ff2e15e56e82 · 2016-01-11T14:38:33.000-08:00
yaml --- r: 2153 b: refs/heads/pubsub-alpha c: 33f6ad8 h: refs/heads/master i: 2151: 7480caa
diff --git a/[refs] b/[refs]
@@ -3,7 +3,7 @@ refs/heads/master: 689bbb466df4b2d5d2483d6edb8ac5c7c7f7c6fa
 refs/heads/travis: e21ee7b88a5edc3f3d8c71f90c3fc32abf7e8dd6
 refs/heads/gh-pages: 4e0561bb4504bf647db669a14417b2b2c87ba45d
 refs/heads/bigquery: 762fa5830e6c398c0396177e3e7fd243bd62cfc3
-refs/heads/pubsub-alpha: 863c57270d177fd0ccbc0dd6b84083ab2777f983
+refs/heads/pubsub-alpha: 33f6ad862077eb45a9dec040e45a899cc462cbf6
 refs/heads/resource-manager: ebf4adc5ee835cd2086c4ac5b4e78d01a5a005a7
 refs/heads/update-datastore: 482954f2c5055231e5b3122ea91d2ba00ce8187c
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/branches/pubsub-alpha/gcloud-java-storage/src/main/java/com/google/gcloud/storage/testing/RemoteGcsHelper.java b/branches/pubsub-alpha/gcloud-java-storage/src/main/java/com/google/gcloud/storage/testing/RemoteGcsHelper.java
@@ -65,7 +65,10 @@ public StorageOptions options() {
 
   /**
    * Deletes a bucket, even if non-empty. Objects in the bucket are listed and deleted until bucket
-   * deletion succeeds or {@code timeout} expires.
+   * deletion succeeds or {@code timeout} expires. To allow for the timeout, this method uses a
+   * separate thread to send the delete requests. Use
+   * {@link #forceDelete(Storage storage, String bucket)} if spawning an additional thread is
+   * undesirable, such as in the App Engine production runtime.
    *
    * @param storage the storage service to be used to issue requests
    * @param bucket the bucket to be deleted
@@ -89,20 +92,14 @@ public static Boolean forceDelete(Storage storage, String bucket, long timeout,
   }
 
   /**
-   * Deletes a bucket, even if non-empty. Objects in the bucket are listed and deleted until bucket
-   * deletion succeeds. This method can be used to delete buckets from within App Engine.  Note that
-   * this method does not set a timeout.
+   * Deletes a bucket, even if non-empty. This method blocks until the deletion completes or fails.
    *
    * @param storage the storage service to be used to issue requests
    * @param bucket the bucket to be deleted
    * @throws StorageException if an exception is encountered during bucket deletion
    */
-  public static void forceDelete(Storage storage, String bucket) throws StorageException {
-    try {
-      new DeleteBucketTask(storage, bucket).call();
-    } catch (Exception e) {
-      throw (StorageException) e;
-    }
+  public static void forceDelete(Storage storage, String bucket) {
+    new DeleteBucketTask(storage, bucket).call();
   }
 
   /**
@@ -174,7 +171,7 @@ public DeleteBucketTask(Storage storage, String bucket) {
     }
 
     @Override
-    public Boolean call() throws Exception {
+    public Boolean call() {
       while (true) {
         for (BlobInfo info : storage.list(bucket).values()) {
           storage.delete(bucket, info.name());
@@ -184,7 +181,12 @@ public Boolean call() throws Exception {
           return true;
         } catch (StorageException e) {
           if (e.code() == 409) {
-            Thread.sleep(500);
+            try {
+              Thread.sleep(500);
+            } catch (InterruptedException interruptedException) {
+              Thread.currentThread().interrupt();
+              throw e;
+            }
           } else {
             throw e;
           }
diff --git a/branches/pubsub-alpha/gcloud-java-storage/src/test/java/com/google/gcloud/storage/RemoteGcsHelperTest.java b/branches/pubsub-alpha/gcloud-java-storage/src/test/java/com/google/gcloud/storage/RemoteGcsHelperTest.java
@@ -140,9 +140,8 @@ public void testForceDeleteFail() throws InterruptedException, ExecutionExceptio
     }
   }
 
-
   @Test
-  public void testForceDeleteNoTimeout() throws Exception {
+  public void testForceDeleteNoTimeout() {
     Storage storageMock = EasyMock.createMock(Storage.class);
     EasyMock.expect(storageMock.list(BUCKET_NAME)).andReturn(BLOB_PAGE);
     for (BlobInfo info : BLOB_LIST) {
@@ -155,7 +154,7 @@ public void testForceDeleteNoTimeout() throws Exception {
   }
 
   @Test
-  public void testForceDeleteNoTimeoutFail() throws Exception {
+  public void testForceDeleteNoTimeoutFail() {
     Storage storageMock = EasyMock.createMock(Storage.class);
     EasyMock.expect(storageMock.list(BUCKET_NAME)).andReturn(BLOB_PAGE);
     for (BlobInfo info : BLOB_LIST) {

Original file line number	Diff line number	Diff line change
`@@ -140,9 +140,8 @@ public void testForceDeleteFail() throws InterruptedException, ExecutionExceptio`
`140`	`140`	`}`
`141`	`141`	`}`
`142`	`142`
`143`		`-`
`144`	`143`	`@Test`
`145`		`- public void testForceDeleteNoTimeout() throws Exception {`
	`144`	`+ public void testForceDeleteNoTimeout() {`
`146`	`145`	`Storage storageMock = EasyMock.createMock(Storage.class);`
`147`	`146`	`EasyMock.expect(storageMock.list(BUCKET_NAME)).andReturn(BLOB_PAGE);`
`148`	`147`	`for (BlobInfo info : BLOB_LIST) {`
`@@ -155,7 +154,7 @@ public void testForceDeleteNoTimeout() throws Exception {`
`155`	`154`	`}`
`156`	`155`
`157`	`156`	`@Test`
`158`		`- public void testForceDeleteNoTimeoutFail() throws Exception {`
	`157`	`+ public void testForceDeleteNoTimeoutFail() {`
`159`	`158`	`Storage storageMock = EasyMock.createMock(Storage.class);`
`160`	`159`	`EasyMock.expect(storageMock.list(BUCKET_NAME)).andReturn(BLOB_PAGE);`
`161`	`160`	`for (BlobInfo info : BLOB_LIST) {`