The Tor Browser: mobile/android/base/sync/net/SyncStorageCollectionRequest.java@6474c204b198 (annotated)

mobile/android/base/sync/net/SyncStorageCollectionRequest.java@6474c204b198 (annotated)

mobile/android/base/sync/net/SyncStorageCollectionRequest.java

Wed, 31 Dec 2014 06:09:35 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Wed, 31 Dec 2014 06:09:35 +0100
changeset 0: 6474c204b198
permissions: -rw-r--r--

Cloned upstream origin tor-browser at tor-browser-31.3.0esr-4.5-1-build1
revision ID fc1c9ff7c1b2defdbc039f12214767608f46423f for hacking purpose.

 /* This Source Code Form is subject to the terms of the Mozilla Public
  * License, v. 2.0. If a copy of the MPL was not distributed with this
  * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
 package org.mozilla.gecko.sync.net;
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.net.URI;
 import org.mozilla.gecko.background.common.log.Logger;
 import ch.boye.httpclientandroidlib.Header;
 import ch.boye.httpclientandroidlib.HttpEntity;
 import ch.boye.httpclientandroidlib.HttpResponse;
 import ch.boye.httpclientandroidlib.client.methods.HttpRequestBase;
 import ch.boye.httpclientandroidlib.impl.client.DefaultHttpClient;
 /**
  * A request class that handles line-by-line responses. Eventually this will
  * handle real stream processing; for now, just parse the returned body
  * line-by-line.
  *
  * @author rnewman
  *
  */
 public class SyncStorageCollectionRequest extends SyncStorageRequest {
   private static final String LOG_TAG = "CollectionRequest";
   public SyncStorageCollectionRequest(URI uri) {
     super(uri);
   }
   protected volatile boolean aborting = false;
   /**
    * Instruct the request that it should process no more records,
    * and decline to notify any more delegate callbacks.
    */
   public void abort() {
     aborting = true;
     try {
       this.resource.request.abort();
     } catch (Exception e) {
       // Just in case.
       Logger.warn(LOG_TAG, "Got exception in abort: " + e);
     }
   }
   @Override
   protected BaseResourceDelegate makeResourceDelegate(SyncStorageRequest request) {
     return new SyncCollectionResourceDelegate((SyncStorageCollectionRequest) request);
   }
   // TODO: this is awful.
   public class SyncCollectionResourceDelegate extends
       SyncStorageResourceDelegate {
     private static final String CONTENT_TYPE_INCREMENTAL = "application/newlines";
     private static final int FETCH_BUFFER_SIZE = 16 * 1024;   // 16K chars.
     SyncCollectionResourceDelegate(SyncStorageCollectionRequest request) {
       super(request);
     }
     @Override
     public void addHeaders(HttpRequestBase request, DefaultHttpClient client) {
       super.addHeaders(request, client);
       request.setHeader("Accept", CONTENT_TYPE_INCREMENTAL);
       // Caller is responsible for setting full=1.
     }
     @Override
     public void handleHttpResponse(HttpResponse response) {
       if (aborting) {
         return;
       }
       if (response.getStatusLine().getStatusCode() != 200) {
         super.handleHttpResponse(response);
         return;
       }
       HttpEntity entity = response.getEntity();
       Header contentType = entity.getContentType();
       if (!contentType.getValue().startsWith(CONTENT_TYPE_INCREMENTAL)) {
         // Not incremental!
         super.handleHttpResponse(response);
         return;
       }
       // TODO: at this point we can access X-Weave-Timestamp, compare
       // that to our local timestamp, and compute an estimate of clock
       // skew. We can provide this to the incremental delegate, which
       // will allow it to seamlessly correct timestamps on the records
       // it processes. Bug 721887.
       // Line-by-line processing, then invoke success.
       SyncStorageCollectionRequestDelegate delegate = (SyncStorageCollectionRequestDelegate) this.request.delegate;
       InputStream content = null;
       BufferedReader br = null;
       try {
         content = entity.getContent();
         br = new BufferedReader(new InputStreamReader(content), FETCH_BUFFER_SIZE);
         String line;
         // This relies on connection timeouts at the HTTP layer.
         while (!aborting &&
                null != (line = br.readLine())) {
           try {
             delegate.handleRequestProgress(line);
           } catch (Exception ex) {
             delegate.handleRequestError(new HandleProgressException(ex));
             BaseResource.consumeEntity(entity);
             return;
           }
         }
         if (aborting) {
           // So we don't hit the success case below.
           return;
         }
       } catch (IOException ex) {
         if (!aborting) {
           delegate.handleRequestError(ex);
         }
         BaseResource.consumeEntity(entity);
         return;
       } finally {
         // Attempt to close the stream and reader.
         if (br != null) {
           try {
             br.close();
           } catch (IOException e) {
             // We don't care if this fails.
           }
         }
       }
       // We're done processing the entity. Don't let fetching the body succeed!
       BaseResource.consumeEntity(entity);
       delegate.handleRequestSuccess(new SyncStorageResponse(response));
     }
   }
 }

The Tor Browser / annotate

mobile/android/base/sync/net/SyncStorageCollectionRequest.java@6474c204b198 (annotated)

mobile/android/base/sync/net/SyncStorageCollectionRequest.java