---

pongad · web-flow · commit 14f300a775a6 · 2018-02-15T09:00:42.000+11:00
yaml --- r: 8719 b: refs/heads/master c: 21e7f4c h: refs/heads/master i: 8717: 15b868f 8715: de822bf 8711: db970b5 8703: 95fc0ab
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: f2a238733cf05a82df39d4331d2f3d41b0adc89e
+refs/heads/master: 21e7f4ccaf7016e81130915f83bf0e4ad88580ac
 refs/heads/travis: 47e4fee4fd5af9b2a8ce46f23c72ec95f9b195b2
 refs/heads/gh-pages: 6daca92127d91b7c2c99490080ecf8a13fa94cde
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-core/src/main/java/com/google/cloud/BaseWriteChannel.java b/trunk/google-cloud-core/src/main/java/com/google/cloud/BaseWriteChannel.java
@@ -104,8 +104,9 @@ protected int getChunkSize() {
 
   @Override
   public final void setChunkSize(int chunkSize) {
-    chunkSize = (chunkSize / getMinChunkSize()) * getMinChunkSize();
-    this.chunkSize = Math.max(getMinChunkSize(), chunkSize);
+    int minSize = getMinChunkSize();
+
+    this.chunkSize = Math.max(minSize, (chunkSize + minSize - 1) / minSize * minSize);
   }
 
   @InternalApi("This class should only be extended within google-cloud-java")
@@ -173,7 +174,6 @@ public final void close() throws IOException {
   public RestorableState<WriteChannel> capture() {
     byte[] bufferToSave = null;
     if (isOpen) {
-      flush();
       bufferToSave = Arrays.copyOf(buffer, limit);
     }
     return stateBuilder()
diff --git a/trunk/google-cloud-core/src/main/java/com/google/cloud/WriteChannel.java b/trunk/google-cloud-core/src/main/java/com/google/cloud/WriteChannel.java
@@ -23,13 +23,11 @@
  * A channel for writing data to Google Cloud services.
  *
  * <p>Implementations of this class may further buffer data internally to reduce remote calls.
- * Written data will only be visible after calling {@link #close()}. This interface implements
+ * Written data might not be visible until calling {@link #close()}. This interface implements
  * {@link Restorable} to allow saving the writer's state to continue writing afterwards.
- * </p>
  */
 public interface WriteChannel extends WritableByteChannel, Closeable, Restorable<WriteChannel> {
 
-
   /**
    * Sets the minimum size that will be written by a single RPC.
    * Written data will be buffered and only flushed upon reaching this size or closing the channel.
diff --git a/trunk/google-cloud-core/src/test/java/com/google/cloud/BaseWriteChannelTest.java b/trunk/google-cloud-core/src/test/java/com/google/cloud/BaseWriteChannelTest.java
@@ -16,25 +16,24 @@
 
 package com.google.cloud;
 
+import static com.google.common.truth.Truth.assertThat;
 import static junit.framework.TestCase.assertFalse;
 import static junit.framework.TestCase.assertTrue;
 import static org.junit.Assert.assertArrayEquals;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNull;
 
 import com.google.cloud.spi.ServiceRpcFactory;
-
-import org.junit.Before;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.rules.ExpectedException;
-
 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;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
 
 public class BaseWriteChannelTest {
 
@@ -111,11 +110,16 @@ public void testValidateOpen() throws IOException {
   @Test
   public void testChunkSize() {
     channel.setChunkSize(42);
-    assertEquals(MIN_CHUNK_SIZE, channel.getChunkSize());
+    assertThat(channel.getChunkSize() >= MIN_CHUNK_SIZE).isTrue();
+    assertThat(channel.getChunkSize() % MIN_CHUNK_SIZE).isEqualTo(0);
+
     channel.setChunkSize(2 * MIN_CHUNK_SIZE);
-    assertEquals(2 * MIN_CHUNK_SIZE, channel.getChunkSize());
-    channel.setChunkSize(512 * 1025);
-    assertEquals(2 * MIN_CHUNK_SIZE, channel.getChunkSize());
+    assertThat(channel.getChunkSize() >= MIN_CHUNK_SIZE).isTrue();
+    assertThat(channel.getChunkSize() % MIN_CHUNK_SIZE).isEqualTo(0);
+
+    channel.setChunkSize(2 * MIN_CHUNK_SIZE + 1);
+    assertThat(channel.getChunkSize() >= MIN_CHUNK_SIZE).isTrue();
+    assertThat(channel.getChunkSize() % MIN_CHUNK_SIZE).isEqualTo(0);
   }
 
   @Test
