OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 package org.chromium.net; | 5 package org.chromium.net; |
6 | 6 |
7 import android.test.suitebuilder.annotation.SmallTest; | 7 import android.test.suitebuilder.annotation.SmallTest; |
8 | 8 |
9 import org.chromium.base.test.util.Feature; | 9 import org.chromium.base.test.util.Feature; |
10 | 10 |
11 import java.io.ByteArrayInputStream; | 11 import java.io.ByteArrayInputStream; |
12 import java.io.IOException; | 12 import java.io.IOException; |
13 import java.io.InputStream; | 13 import java.io.InputStream; |
14 import java.nio.ByteBuffer; | 14 import java.nio.ByteBuffer; |
15 import java.nio.channels.Channels; | 15 import java.nio.channels.Channels; |
16 import java.nio.channels.ReadableByteChannel; | 16 import java.nio.channels.ReadableByteChannel; |
17 import java.util.HashMap; | 17 import java.util.HashMap; |
18 import java.util.concurrent.Executors; | 18 import java.util.concurrent.Executors; |
19 | 19 |
20 /** | 20 /** |
21 * Test fixture to test upload APIs. Uses an in-process test server. | 21 * Test fixture to test upload APIs. Uses an in-process test server. |
22 */ | 22 */ |
23 @SuppressWarnings("deprecation") | 23 @SuppressWarnings("deprecation") |
24 public class UploadTest extends CronetTestBase { | 24 public class UploadTest extends CronetTestBase { |
25 private static final String UPLOAD_DATA = "Nifty upload data!"; | 25 private static final String UPLOAD_DATA = "Nifty upload data!"; |
26 private static final String UPLOAD_CHANNEL_DATA = "Upload channel data"; | 26 private static final String UPLOAD_CHANNEL_DATA = "Upload channel data"; |
27 | 27 |
28 private CronetTestFramework mTestFramework; | 28 private CronetTestFramework mTestFramework; |
29 | 29 |
30 // @Override | 30 @Override |
31 protected void setUp() throws Exception { | 31 protected void setUp() throws Exception { |
32 super.setUp(); | 32 super.setUp(); |
33 mTestFramework = startCronetTestFramework(); | 33 mTestFramework = startCronetTestFrameworkForLegacyApi(null); |
34 assertNotNull(mTestFramework); | 34 assertNotNull(mTestFramework); |
35 assertTrue(NativeTestServer.startNativeTestServer(getContext())); | 35 assertTrue(NativeTestServer.startNativeTestServer(getContext())); |
36 } | 36 } |
37 | 37 |
38 private HttpUrlRequest createRequest( | 38 private HttpUrlRequest createRequest( |
39 String url, HttpUrlRequestListener listener) { | 39 String url, HttpUrlRequestListener listener) { |
40 HashMap<String, String> headers = new HashMap<String, String>(); | 40 HashMap<String, String> headers = new HashMap<String, String>(); |
41 return mTestFramework.mRequestFactory.createRequest( | 41 return mTestFramework.mRequestFactory.createRequest( |
42 url, HttpUrlRequest.REQUEST_PRIORITY_MEDIUM, headers, listener); | 42 url, HttpUrlRequest.REQUEST_PRIORITY_MEDIUM, headers, listener); |
43 } | 43 } |
(...skipping 295 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
339 // Upload a single empty chunk. | 339 // Upload a single empty chunk. |
340 ByteBuffer byteBuffer = ByteBuffer.allocateDirect(0); | 340 ByteBuffer byteBuffer = ByteBuffer.allocateDirect(0); |
341 request.appendChunk(byteBuffer, true); | 341 request.appendChunk(byteBuffer, true); |
342 | 342 |
343 listener.blockForComplete(); | 343 listener.blockForComplete(); |
344 | 344 |
345 assertEquals(200, listener.mHttpStatusCode); | 345 assertEquals(200, listener.mHttpStatusCode); |
346 assertEquals("", listener.mResponseAsString); | 346 assertEquals("", listener.mResponseAsString); |
347 } | 347 } |
348 } | 348 } |
OLD | NEW |