The Tor Browser: mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/io/AbstractSessionOutputBuffer.java@fc2d59ddac77 (annotated)

mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/io/AbstractSessionOutputBuffer.java@fc2d59ddac77 (annotated)

mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/io/AbstractSessionOutputBuffer.java

Wed, 31 Dec 2014 07:22:50 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Wed, 31 Dec 2014 07:22:50 +0100
branch: TOR_BUG_3246
changeset 4: fc2d59ddac77
permissions: -rw-r--r--

Correct previous dual key logic pending first delivery installment.

 /*
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF licenses this file
  * to you under the Apache License, Version 2.0 (the
  * "License"); you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  * KIND, either express or implied.  See the License for the
  * specific language governing permissions and limitations
  * under the License.
  * ====================================================================
  *
  * This software consists of voluntary contributions made by many
  * individuals on behalf of the Apache Software Foundation.  For more
  * information on the Apache Software Foundation, please see
  * <http://www.apache.org/>.
  *
  */
 package ch.boye.httpclientandroidlib.impl.io;
 import java.io.IOException;
 import java.io.OutputStream;
 import ch.boye.httpclientandroidlib.io.BufferInfo;
 import ch.boye.httpclientandroidlib.io.SessionOutputBuffer;
 import ch.boye.httpclientandroidlib.io.HttpTransportMetrics;
 import ch.boye.httpclientandroidlib.params.CoreConnectionPNames;
 import ch.boye.httpclientandroidlib.params.HttpParams;
 import ch.boye.httpclientandroidlib.params.HttpProtocolParams;
 import ch.boye.httpclientandroidlib.protocol.HTTP;
 import ch.boye.httpclientandroidlib.util.ByteArrayBuffer;
 import ch.boye.httpclientandroidlib.util.CharArrayBuffer;
 /**
  * Abstract base class for session output buffers that stream data to
  * an arbitrary {@link OutputStream}. This class buffers small chunks of
  * output data in an internal byte array for optimal output performance.
  * <p>
  * {@link #writeLine(CharArrayBuffer)} and {@link #writeLine(String)} methods
  * of this class use CR-LF as a line delimiter.
  * <p>
  * The following parameters can be used to customize the behavior of this
  * class:
  * <ul>
  *  <li>{@link ch.boye.httpclientandroidlib.params.CoreProtocolPNames#HTTP_ELEMENT_CHARSET}</li>
  *  <li>{@link ch.boye.httpclientandroidlib.params.CoreConnectionPNames#MIN_CHUNK_LIMIT}</li>
  * </ul>
  * <p>
  *
  * @since 4.0
  */
 public abstract class AbstractSessionOutputBuffer implements SessionOutputBuffer, BufferInfo {
     private static final byte[] CRLF = new byte[] {HTTP.CR, HTTP.LF};
     private OutputStream outstream;
     private ByteArrayBuffer buffer;
     private String charset = HTTP.US_ASCII;
     private boolean ascii = true;
     private int minChunkLimit = 512;
     private HttpTransportMetricsImpl metrics;
     /**
      * Initializes this session output buffer.
      *
      * @param outstream the destination output stream.
      * @param buffersize the size of the internal buffer.
      * @param params HTTP parameters.
      */
     protected void init(final OutputStream outstream, int buffersize, final HttpParams params) {
         if (outstream == null) {
             throw new IllegalArgumentException("Input stream may not be null");
         }
         if (buffersize <= 0) {
             throw new IllegalArgumentException("Buffer size may not be negative or zero");
         }
         if (params == null) {
             throw new IllegalArgumentException("HTTP parameters may not be null");
         }
         this.outstream = outstream;
         this.buffer = new ByteArrayBuffer(buffersize);
         this.charset = HttpProtocolParams.getHttpElementCharset(params);
         this.ascii = this.charset.equalsIgnoreCase(HTTP.US_ASCII)
                      || this.charset.equalsIgnoreCase(HTTP.ASCII);
         this.minChunkLimit = params.getIntParameter(CoreConnectionPNames.MIN_CHUNK_LIMIT, 512);
         this.metrics = createTransportMetrics();
     }
     /**
      * @since 4.1
      */
     protected HttpTransportMetricsImpl createTransportMetrics() {
         return new HttpTransportMetricsImpl();
     }
     /**
      * @since 4.`1
      */
     public int capacity() {
         return this.buffer.capacity();
     }
     /**
      * @since 4.1
      */
     public int length() {
         return this.buffer.length();
     }
     /**
      * @since 4.1
      */
     public int available() {
         return capacity() - length();
     }
     protected void flushBuffer() throws IOException {
         int len = this.buffer.length();
         if (len > 0) {
             this.outstream.write(this.buffer.buffer(), 0, len);
             this.buffer.clear();
             this.metrics.incrementBytesTransferred(len);
         }
     }
     public void flush() throws IOException {
         flushBuffer();
         this.outstream.flush();
     }
     public void write(final byte[] b, int off, int len) throws IOException {
         if (b == null) {
             return;
         }
         // Do not want to buffer large-ish chunks
         // if the byte array is larger then MIN_CHUNK_LIMIT
         // write it directly to the output stream
         if (len > this.minChunkLimit || len > this.buffer.capacity()) {
             // flush the buffer
             flushBuffer();
             // write directly to the out stream
             this.outstream.write(b, off, len);
             this.metrics.incrementBytesTransferred(len);
         } else {
             // Do not let the buffer grow unnecessarily
             int freecapacity = this.buffer.capacity() - this.buffer.length();
             if (len > freecapacity) {
                 // flush the buffer
                 flushBuffer();
             }
             // buffer
             this.buffer.append(b, off, len);
         }
     }
     public void write(final byte[] b) throws IOException {
         if (b == null) {
             return;
         }
         write(b, 0, b.length);
     }
     public void write(int b) throws IOException {
         if (this.buffer.isFull()) {
             flushBuffer();
         }
         this.buffer.append(b);
     }
     /**
      * Writes characters from the specified string followed by a line delimiter
      * to this session buffer.
      * <p>
      * This method uses CR-LF as a line delimiter.
      *
      * @param      s   the line.
      * @exception  IOException  if an I/O error occurs.
      */
     public void writeLine(final String s) throws IOException {
         if (s == null) {
             return;
         }
         if (s.length() > 0) {
             write(s.getBytes(this.charset));
         }
         write(CRLF);
     }
     /**
      * Writes characters from the specified char array followed by a line
      * delimiter to this session buffer.
      * <p>
      * This method uses CR-LF as a line delimiter.
      *
      * @param      s the buffer containing chars of the line.
      * @exception  IOException  if an I/O error occurs.
      */
     public void writeLine(final CharArrayBuffer s) throws IOException {
         if (s == null) {
             return;
         }
         if (this.ascii) {
             int off = 0;
             int remaining = s.length();
             while (remaining > 0) {
                 int chunk = this.buffer.capacity() - this.buffer.length();
                 chunk = Math.min(chunk, remaining);
                 if (chunk > 0) {
                     this.buffer.append(s, off, chunk);
                 }
                 if (this.buffer.isFull()) {
                     flushBuffer();
                 }
                 off += chunk;
                 remaining -= chunk;
             }
         } else {
             // This is VERY memory inefficient, BUT since non-ASCII charsets are
             // NOT meant to be used anyway, there's no point optimizing it
             byte[] tmp = s.toString().getBytes(this.charset);
             write(tmp);
         }
         write(CRLF);
     }
     public HttpTransportMetrics getMetrics() {
         return this.metrics;
     }
 }

The Tor Browser / annotate

mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/io/AbstractSessionOutputBuffer.java@fc2d59ddac77 (annotated)

mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/io/AbstractSessionOutputBuffer.java