aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/test/java/com
diff options
context:
space:
mode:
authorGravatar jart <jart@google.com>2017-03-28 22:33:27 +0000
committerGravatar Philipp Wollermann <philwo@google.com>2017-03-29 14:22:22 +0200
commit0e866a8b732e31df1a4ddfd13c4870d4721de70b (patch)
treee120356f560c1f97edf55dee9c9c4a9f8354568b /src/test/java/com
parent1419ddac5fb5b7d6aec9ac0e3d27dfcd53692bb7 (diff)
Fix downloader so reset connections can resume
RELNOTES: A downloader bug was fixed that prevented RFC 7233 Range connection resumes from working with certain HTTP servers PiperOrigin-RevId: 151508000
Diffstat (limited to 'src/test/java/com')
-rw-r--r--src/test/java/com/google/devtools/build/lib/bazel/repository/downloader/RetryingInputStreamTest.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/test/java/com/google/devtools/build/lib/bazel/repository/downloader/RetryingInputStreamTest.java b/src/test/java/com/google/devtools/build/lib/bazel/repository/downloader/RetryingInputStreamTest.java
index 10f0923dcb..781222642e 100644
--- a/src/test/java/com/google/devtools/build/lib/bazel/repository/downloader/RetryingInputStreamTest.java
+++ b/src/test/java/com/google/devtools/build/lib/bazel/repository/downloader/RetryingInputStreamTest.java
@@ -110,7 +110,7 @@ public class RetryingInputStreamTest {
when(connection.getHeaderField("Content-Range")).thenReturn("bytes 1-42/42");
assertThat(stream.read()).isEqualTo(1);
assertThat(stream.read()).isEqualTo(2);
- verify(reconnector).connect(any(Throwable.class), eq(ImmutableMap.of("Range", "bytes 1-")));
+ verify(reconnector).connect(any(Throwable.class), eq(ImmutableMap.of("Range", "bytes=1-")));
verify(delegate, times(2)).read();
verify(delegate).close();
verify(newDelegate).read();
@@ -165,7 +165,7 @@ public class RetryingInputStreamTest {
} catch (SocketTimeoutException e) {
assertThat(e.getSuppressed()).hasLength(3);
verify(reconnector, times(3))
- .connect(any(Throwable.class), eq(ImmutableMap.of("Range", "bytes 1-")));
+ .connect(any(Throwable.class), eq(ImmutableMap.of("Range", "bytes=1-")));
verify(delegate, times(5)).read();
verify(delegate, times(3)).close();
}