Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
   * Copyright 2010-2015, Inc. or its affiliates. All Rights Reserved.
   * Licensed under the Apache License, Version 2.0 (the "License").
   * You may not use this file except in compliance with the License.
   * A copy of the License is located at
  * or in the "license" file accompanying this file. This file is distributed
  * express or implied. See the License for the specific language governing
  * permissions and limitations under the License.
 package com.amazonaws.http;
Custom implementation of RequestEntity that delegates to an InputStreamRequestEntity, with the one notable difference, that if the underlying InputStream supports being reset, this RequestEntity will report that it is repeatable and will reset the stream on all subsequent attempts to write out the request.
True if the request entity hasn't been written out yet
     private boolean firstAttempt = true;

The underlying InputStreamEntity being delegated to
     private InputStreamEntity inputStreamRequestEntity;

The InputStream containing the content to write out
     private InputStream content;
     private static final Log log = LogFactory

Record the original exception if we do attempt a retry, so that if the retry fails, we can report the original exception. Otherwise, we're most likely masking the real exception with an error about not being able to reset far enough back in the input stream.
     private IOException originalException;

Creates a new RepeatableInputStreamRequestEntity using the information from the specified request. If the input stream containing the request's contents is repeatable, then this RequestEntity will report as being repeatable.

request The details of the request being written out (content type, content length, and content).
     RepeatableInputStreamRequestEntity(final Request<?> request) {
          * If we don't specify a content length when we instantiate our
          * InputStreamRequestEntity, then HttpClient will attempt to
          * buffer the entire stream contents into memory to determine
          * the content length.
          * TODO: It'd be nice to have easier access to content length and
          *       content type from the request, instead of having to look
          *       directly into the headers.
         long contentLength = -1;
         try {
             String contentLengthString = request.getHeaders().get("Content-Length");
             if (contentLengthString != null) {
                 contentLength = Long.parseLong(contentLengthString);
         } catch (NumberFormatException nfe) {
             .warn("Unable to parse content length from request.  " +
                     "Buffering contents in memory.");
         String contentType = request.getHeaders().get("Content-Type");
         ThroughputMetricType type = ServiceMetricTypeGuesser
        if (type == null) {
                new InputStreamEntity(request.getContent(), contentLength);
        } else {
                new MetricInputStreamEntity(typerequest.getContent(), contentLength);
         = request.getContent();
    public boolean isChunked() {
        return false;

Returns true if the underlying InputStream supports marking/reseting or if the underlying InputStreamRequestEntity is repeatable (i.e. its content length has been set to InputStreamRequestEntity and therefore its entire contents will be buffered in memory and can be repeated).

See also:
    public boolean isRepeatable() {

Resets the underlying InputStream if this isn't the first attempt to write out the request, otherwise simply delegates to InputStreamRequestEntity to write out the data.

If an error is encountered the first time we try to write the request entity, we remember the original exception, and report that as the root cause if we continue to encounter errors, rather than masking the original error.

See also:
org.apache.commons.httpclient.methods.RequestEntity#writeRequest( )
    public void writeTo(OutputStream outputthrows IOException {
        try {
            if (! && isRepeatable()) .reset();
             = false;
        } catch (IOException ioe) {
            if ( == null = ioe;
            throw ;
New to GrepCode? Check out our FAQ X