---

mziccard · mziccard · commit 6f46d92412b1 · 2016-02-25T17:20:18.000+01:00
yaml --- r: 4543 b: refs/heads/logging-alpha c: 28f4a18 h: refs/heads/master i: 4541: e4be59a 4539: f6e4c49 4535: 4c534c6 4527: 377f3f0 4511: 2f3d867 4479: 4d70bab
diff --git a/[refs] b/[refs]
@@ -12,7 +12,7 @@ refs/heads/compute-alpha: 969cba2627f1d53d352cc4a5ffe0879dacf65e6c
 refs/heads/dns-alpha: 2f90e7e338349287ace33375896907af0f032ca1
 refs/heads/dns-alpha-batch: 17442b07867021b85d0452f5f3eda29a3413288f
 refs/heads/gcs-nio: 283aeaf15efdcf3621eb6859f05e55ad7764375d
-refs/heads/logging-alpha: 332f99057b098429f95ce09ec0e6cfd40f4380d5
+refs/heads/logging-alpha: 28f4a18ae41148f82ffe11bbb311f92f50da180f
 refs/tags/v0.1.0: a615317f7424ed58621b1f65d5c4d8cbbe8a6ed8
 refs/tags/v0.1.1: 7a7f6985fe465e9dd6a075af55493f42b4933be0
 refs/tags/v0.1.2: 3eb3fe866ba22487686048f45d927b8c8638ea3f
diff --git a/branches/logging-alpha/gcloud-java-core/src/main/java/com/google/gcloud/BaseWriteChannel.java b/branches/logging-alpha/gcloud-java-core/src/main/java/com/google/gcloud/BaseWriteChannel.java
@@ -21,6 +21,7 @@
 import java.io.IOException;
 import java.io.Serializable;
 import java.nio.ByteBuffer;
+import java.nio.channels.ClosedChannelException;
 import java.util.Arrays;
 import java.util.Objects;
 
@@ -114,9 +115,9 @@ private void flush() {
     }
   }
 
-  private void validateOpen() throws IOException {
+  private void validateOpen() throws ClosedChannelException {
     if (!isOpen) {
-      throw new IOException("stream is closed");
+      throw new ClosedChannelException();
     }
   }
 
diff --git a/branches/logging-alpha/gcloud-java-core/src/test/java/com/google/gcloud/BaseWriteChannelTest.java b/branches/logging-alpha/gcloud-java-core/src/test/java/com/google/gcloud/BaseWriteChannelTest.java
@@ -32,6 +32,7 @@
 import java.io.IOException;
 import java.io.Serializable;
 import java.nio.ByteBuffer;
+import java.nio.channels.ClosedChannelException;
 import java.util.Arrays;
 import java.util.Random;
 
@@ -102,8 +103,7 @@ public void testClose() throws IOException {
   @Test
   public void testValidateOpen() throws IOException {
     channel.close();
-    thrown.expect(IOException.class);
-    thrown.expectMessage("stream is closed");
+    thrown.expect(ClosedChannelException.class);
     channel.write(ByteBuffer.allocate(42));
   }
 
diff --git a/branches/logging-alpha/gcloud-java-storage/src/main/java/com/google/gcloud/storage/BlobReadChannel.java b/branches/logging-alpha/gcloud-java-storage/src/main/java/com/google/gcloud/storage/BlobReadChannel.java
@@ -29,6 +29,7 @@
 import java.io.IOException;
 import java.io.Serializable;
 import java.nio.ByteBuffer;
+import java.nio.channels.ClosedChannelException;
 import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.Callable;
@@ -55,7 +56,7 @@ class BlobReadChannel implements ReadChannel {
   private byte[] buffer;
 
   BlobReadChannel(StorageOptions serviceOptions, BlobId blob,
-                  Map<StorageRpc.Option, ?> requestOptions) {
+      Map<StorageRpc.Option, ?> requestOptions) {
     this.serviceOptions = serviceOptions;
     this.blob = blob;
     this.requestOptions = requestOptions;
@@ -91,9 +92,9 @@ public void close() {
     }
   }
 
-  private void validateOpen() throws IOException {
+  private void validateOpen() throws ClosedChannelException {
     if (!isOpen) {
-      throw new IOException("stream is closed");
+      throw new ClosedChannelException();
     }
   }
 
diff --git a/branches/logging-alpha/gcloud-java-storage/src/test/java/com/google/gcloud/storage/BlobReadChannelTest.java b/branches/logging-alpha/gcloud-java-storage/src/test/java/com/google/gcloud/storage/BlobReadChannelTest.java
@@ -39,6 +39,7 @@
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
+import java.nio.channels.ClosedChannelException;
 import java.util.Arrays;
 import java.util.Map;
 import java.util.Random;
@@ -156,15 +157,15 @@ public void testClose() {
   }
 
   @Test
-  public void testReadClosed() {
+  public void testReadClosed() throws IOException {
     replay(storageRpcMock);
     reader = new BlobReadChannel(options, BLOB_ID, EMPTY_RPC_OPTIONS);
     reader.close();
     try {
       ByteBuffer readBuffer = ByteBuffer.allocate(DEFAULT_CHUNK_SIZE);
       reader.read(readBuffer);
-      fail("Expected BlobReadChannel read to throw IOException");
-    } catch (IOException ex) {
+      fail("Expected BlobReadChannel read to throw ClosedChannelException");
+    } catch (ClosedChannelException ex) {
       // expected
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -21,6 +21,7 @@`
`21`	`21`	`import java.io.IOException;`
`22`	`22`	`import java.io.Serializable;`
`23`	`23`	`import java.nio.ByteBuffer;`
	`24`	`+import java.nio.channels.ClosedChannelException;`
`24`	`25`	`import java.util.Arrays;`
`25`	`26`	`import java.util.Objects;`
`26`	`27`
`@@ -114,9 +115,9 @@ private void flush() {`
`114`	`115`	`}`
`115`	`116`	`}`
`116`	`117`
`117`		`- private void validateOpen() throws IOException {`
	`118`	`+ private void validateOpen() throws ClosedChannelException {`
`118`	`119`	`if (!isOpen) {`
`119`		`- throw new IOException("stream is closed");`
	`120`	`+ throw new ClosedChannelException();`
`120`	`121`	`}`
`121`	`122`	`}`
`122`	`123`
Original file line number	Diff line number	Diff line change
`@@ -29,6 +29,7 @@`
`29`	`29`	`import java.io.IOException;`
`30`	`30`	`import java.io.Serializable;`
`31`	`31`	`import java.nio.ByteBuffer;`
	`32`	`+import java.nio.channels.ClosedChannelException;`
`32`	`33`	`import java.util.Map;`
`33`	`34`	`import java.util.Objects;`
`34`	`35`	`import java.util.concurrent.Callable;`
`@@ -55,7 +56,7 @@ class BlobReadChannel implements ReadChannel {`
`55`	`56`	`private byte[] buffer;`
`56`	`57`
`57`	`58`	`BlobReadChannel(StorageOptions serviceOptions, BlobId blob,`
`58`		`- Map<StorageRpc.Option, ?> requestOptions) {`
	`59`	`+ Map<StorageRpc.Option, ?> requestOptions) {`
`59`	`60`	`this.serviceOptions = serviceOptions;`
`60`	`61`	`this.blob = blob;`
`61`	`62`	`this.requestOptions = requestOptions;`
`@@ -91,9 +92,9 @@ public void close() {`
`91`	`92`	`}`
`92`	`93`	`}`
`93`	`94`
`94`		`- private void validateOpen() throws IOException {`
	`95`	`+ private void validateOpen() throws ClosedChannelException {`
`95`	`96`	`if (!isOpen) {`
`96`		`- throw new IOException("stream is closed");`
	`97`	`+ throw new ClosedChannelException();`
`97`	`98`	`}`
`98`	`99`	`}`
`99`	`100`