@@ -134,86 +134,86 @@ public void complete(String key, ResponseInfo info, JSONObject response) {
134134
135135
136136 /////模拟域名失败后,再重试的场景,需要手动修改zone域名无效来模拟/////
137- // @SmallTest
138- // public void testPutBytesWithFixedZoneUseBackupDomains() {
139- // //have changed old code , because token policy been changed
140- // //mime type
141- // final String mimeType = "text/plain";
142- // final UploadOptions options = new UploadOptions(null, mimeType, true, null, null);
143- // byte[] putData = "hello qiniu cloud storage".getBytes();
144- //
145- // for (Map.Entry<String, Zone> bucketZone : this.mockBucketZoneMap.entrySet()) {
146- // final CountDownLatch signal = new CountDownLatch(1);
147- // final String bucket = bucketZone.getKey();
148- // final Zone zone = bucketZone.getValue();
149- // final String upToken = this.bucketTokenMap.get(bucket);
150- // Log.e("qiniutest",upToken);
151- //
152- // final String expectKey = String.format("androidsdk/%s/qiniu_put_bytes_test.txt", bucket);
153- //
154- // Configuration cfg = new Configuration.Builder()
155- // .zone(zone)
156- // .useHttps(false)
157- // .build();
158- // UploadManager uploadManagerWithCfg = new UploadManager(cfg);
159- // uploadManagerWithCfg.put(putData, expectKey, upToken, new UpCompletionHandler() {
160- // public void complete(String key, ResponseInfo info, JSONObject response) {
161- // Log.i("Qiniu.TestPutBytes", "upload result of bucket " + bucket);
162- // Log.d("Qiniu.TestPutBytes", info.toString());
163- //
164- // responseBody = response;
165- // signal.countDown();
166- //
167- // }
168- // }, options);
169- //
170- // try {
171- // signal.await(120, TimeUnit.SECONDS);
172- // } catch (Exception ex) {
173- // Assert.fail("Qiniu.TestPutBytes timeout");
174- // }
175- // }
176- //
177- // //retry will success
178- // for (Map.Entry<String, Zone> bucketZone : this.mockBucketZoneMap.entrySet()) {
179- // final CountDownLatch signal = new CountDownLatch(1);
180- // final String bucket = bucketZone.getKey();
181- // final String upToken = this.bucketTokenMap.get(bucket);
182- // Log.e("qiniutest","retry:"+upToken);
183- // final String expectKey = String.format("androidsdk/%s/qiniu_put_bytes_test.txt", bucket);
184- //
185- // Configuration cfg = new Configuration.Builder()
186- // .useHttps(false)
187- // .build();
188- // UploadManager uploadManagerWithCfg = new UploadManager(cfg);
189- // uploadManagerWithCfg.put(putData, expectKey, upToken, new UpCompletionHandler() {
190- // public void complete(String key, ResponseInfo info, JSONObject response) {
191- // Log.i("Qiniu.TestPutBytes", "upload result of bucket " + bucket);
192- // Log.d("Qiniu.TestPutBytes", info.toString());
193- //
194- // responseBody = response;
195- // Log.e("qiniutest","responseBody:"+responseBody.toString());
196- // signal.countDown();
197- //
198- // }
199- // }, options);
200- //
201- // try {
202- // signal.await(120, TimeUnit.SECONDS);
203- // } catch (Exception ex) {
204- // Assert.fail("Qiniu.TestPutBytes timeout");
205- // }
206- //
207- // try {
208- // Log.e("qiniutest",responseBody.toString());
209- // Assert.assertEquals("Qiniu.TestPutBytes upload failed", expectKey,
210- // responseBody.getString("key"));
211- // } catch (Exception ex) {
212- // Assert.fail("Qiniu.TestPutBytes " + ex.getMessage());
213- // }
214- // }
215- //
216- //
217- // }
137+ @ SmallTest
138+ public void testPutBytesWithFixedZoneUseBackupDomains () {
139+ //have changed old code , because token policy been changed
140+ //mime type
141+ final String mimeType = "text/plain" ;
142+ final UploadOptions options = new UploadOptions (null , mimeType , true , null , null );
143+ byte [] putData = "hello qiniu cloud storage" .getBytes ();
144+
145+ for (Map .Entry <String , Zone > bucketZone : this .mockBucketZoneMap .entrySet ()) {
146+ final CountDownLatch signal = new CountDownLatch (1 );
147+ final String bucket = bucketZone .getKey ();
148+ final Zone zone = bucketZone .getValue ();
149+ final String upToken = this .bucketTokenMap .get (bucket );
150+ Log .e ("qiniutest" ,upToken );
151+
152+ final String expectKey = String .format ("androidsdk/%s/qiniu_put_bytes_test.txt" , bucket );
153+
154+ Configuration cfg = new Configuration .Builder ()
155+ .zone (zone )
156+ .useHttps (false )
157+ .build ();
158+ UploadManager uploadManagerWithCfg = new UploadManager (cfg );
159+ uploadManagerWithCfg .put (putData , expectKey , upToken , new UpCompletionHandler () {
160+ public void complete (String key , ResponseInfo info , JSONObject response ) {
161+ Log .i ("Qiniu.TestPutBytes" , "upload result of bucket " + bucket );
162+ Log .d ("Qiniu.TestPutBytes" , info .toString ());
163+
164+ responseBody = response ;
165+ signal .countDown ();
166+
167+ }
168+ }, options );
169+
170+ try {
171+ signal .await (120 , TimeUnit .SECONDS );
172+ } catch (Exception ex ) {
173+ Assert .fail ("Qiniu.TestPutBytes timeout" );
174+ }
175+ }
176+
177+ //retry will success
178+ for (Map .Entry <String , Zone > bucketZone : this .mockBucketZoneMap .entrySet ()) {
179+ final CountDownLatch signal = new CountDownLatch (1 );
180+ final String bucket = bucketZone .getKey ();
181+ final String upToken = this .bucketTokenMap .get (bucket );
182+ Log .e ("qiniutest" ,"retry:" +upToken );
183+ final String expectKey = String .format ("androidsdk/%s/qiniu_put_bytes_test.txt" , bucket );
184+
185+ Configuration cfg = new Configuration .Builder ()
186+ .useHttps (false )
187+ .build ();
188+ UploadManager uploadManagerWithCfg = new UploadManager (cfg );
189+ uploadManagerWithCfg .put (putData , expectKey , upToken , new UpCompletionHandler () {
190+ public void complete (String key , ResponseInfo info , JSONObject response ) {
191+ Log .i ("Qiniu.TestPutBytes" , "upload result of bucket " + bucket );
192+ Log .d ("Qiniu.TestPutBytes" , info .toString ());
193+
194+ responseBody = response ;
195+ Log .e ("qiniutest" ,"responseBody:" +responseBody .toString ());
196+ signal .countDown ();
197+
198+ }
199+ }, options );
200+
201+ try {
202+ signal .await (120 , TimeUnit .SECONDS );
203+ } catch (Exception ex ) {
204+ Assert .fail ("Qiniu.TestPutBytes timeout" );
205+ }
206+
207+ try {
208+ Log .e ("qiniutest" ,responseBody .toString ());
209+ Assert .assertEquals ("Qiniu.TestPutBytes upload failed" , expectKey ,
210+ responseBody .getString ("key" ));
211+ } catch (Exception ex ) {
212+ Assert .fail ("Qiniu.TestPutBytes " + ex .getMessage ());
213+ }
214+ }
215+
216+
217+ }
218218
219219}
0 commit comments