org.apache.httpcomponents/httpclient/4.5.10 : org/apache/http/impl/client/HttpRequestTaskCallable.class

HttpRequestTaskCallable
http://hc.apache.org/httpcomponents-client: Apache HttpComponents Client (The Apache Software Foundation)
Apache License, Version 2.0
Julius Davies
Andrea Selva
Steffen Pingel
Quintin Beukes
Marc Beyerle
James Abley
Michajlo Matijkiw
Ortwin Glueck ()
Oleg Kalnichevski
Asankha C. Perera
Sebastian Bazley
Erik Abele
Ant Elder
Paul Fremantle
Roland Weber
Sam Berlin
Sean C. Sullivan
Jonathan Moore
Gary Gregory
William Speirs
Karl Wright
Francois-Xavier Bonnet
class org.apache.http.impl.client.HttpRequestTaskCallable<V> implements java.util.concurrent.Callable<V>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.http.impl.client.HttpRequestTaskCallable
  super_class: java.lang.Object
{
  private final org.apache.http.client.methods.HttpUriRequest request;
    descriptor: Lorg/apache/http/client/methods/HttpUriRequest;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.http.client.HttpClient httpclient;
    descriptor: Lorg/apache/http/client/HttpClient;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicBoolean cancelled;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long scheduled;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private long started;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  private long ended;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  private final org.apache.http.protocol.HttpContext context;
    descriptor: Lorg/apache/http/protocol/HttpContext;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.http.client.ResponseHandler<V> responseHandler;
    descriptor: Lorg/apache/http/client/ResponseHandler;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lorg/apache/http/client/ResponseHandler<TV;>;

  private final org.apache.http.concurrent.FutureCallback<V> callback;
    descriptor: Lorg/apache/http/concurrent/FutureCallback;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lorg/apache/http/concurrent/FutureCallback<TV;>;

  private final org.apache.http.impl.client.FutureRequestExecutionMetrics metrics;
    descriptor: Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  void <init>(org.apache.http.client.HttpClient, org.apache.http.client.methods.HttpUriRequest, org.apache.http.protocol.HttpContext, org.apache.http.client.ResponseHandler<V>, org.apache.http.concurrent.FutureCallback<V>, org.apache.http.impl.client.FutureRequestExecutionMetrics);
    descriptor: (Lorg/apache/http/client/HttpClient;Lorg/apache/http/client/methods/HttpUriRequest;Lorg/apache/http/protocol/HttpContext;Lorg/apache/http/client/ResponseHandler;Lorg/apache/http/concurrent/FutureCallback;Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=7, args_size=7
        start local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
        start local 1 // org.apache.http.client.HttpClient httpClient
        start local 2 // org.apache.http.client.methods.HttpUriRequest request
        start local 3 // org.apache.http.protocol.HttpContext context
        start local 4 // org.apache.http.client.ResponseHandler responseHandler
        start local 5 // org.apache.http.concurrent.FutureCallback callback
        start local 6 // org.apache.http.impl.client.FutureRequestExecutionMetrics metrics
         0: .line 54
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 42
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
         2: .line 44
            aload 0 /* this */
            invokestatic java.lang.System.currentTimeMillis:()J
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.scheduled:J
         3: .line 45
            aload 0 /* this */
            ldc -1
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
         4: .line 46
            aload 0 /* this */
            ldc -1
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.ended:J
         5: .line 61
            aload 0 /* this */
            aload 1 /* httpClient */
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.httpclient:Lorg/apache/http/client/HttpClient;
         6: .line 62
            aload 0 /* this */
            aload 4 /* responseHandler */
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.responseHandler:Lorg/apache/http/client/ResponseHandler;
         7: .line 63
            aload 0 /* this */
            aload 2 /* request */
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.request:Lorg/apache/http/client/methods/HttpUriRequest;
         8: .line 64
            aload 0 /* this */
            aload 3 /* context */
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.context:Lorg/apache/http/protocol/HttpContext;
         9: .line 65
            aload 0 /* this */
            aload 5 /* callback */
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.callback:Lorg/apache/http/concurrent/FutureCallback;
        10: .line 66
            aload 0 /* this */
            aload 6 /* metrics */
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
        11: .line 67
            return
        end local 6 // org.apache.http.impl.client.FutureRequestExecutionMetrics metrics
        end local 5 // org.apache.http.concurrent.FutureCallback callback
        end local 4 // org.apache.http.client.ResponseHandler responseHandler
        end local 3 // org.apache.http.protocol.HttpContext context
        end local 2 // org.apache.http.client.methods.HttpUriRequest request
        end local 1 // org.apache.http.client.HttpClient httpClient
        end local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   12     0             this  Lorg/apache/http/impl/client/HttpRequestTaskCallable<TV;>;
            0   12     1       httpClient  Lorg/apache/http/client/HttpClient;
            0   12     2          request  Lorg/apache/http/client/methods/HttpUriRequest;
            0   12     3          context  Lorg/apache/http/protocol/HttpContext;
            0   12     4  responseHandler  Lorg/apache/http/client/ResponseHandler<TV;>;
            0   12     5         callback  Lorg/apache/http/concurrent/FutureCallback<TV;>;
            0   12     6          metrics  Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
    Signature: (Lorg/apache/http/client/HttpClient;Lorg/apache/http/client/methods/HttpUriRequest;Lorg/apache/http/protocol/HttpContext;Lorg/apache/http/client/ResponseHandler<TV;>;Lorg/apache/http/concurrent/FutureCallback<TV;>;Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;)V
    MethodParameters:
                 Name  Flags
      httpClient       final
      request          final
      context          final
      responseHandler  final
      callback         final
      metrics          final

  public long getScheduled();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
         0: .line 70
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.scheduled:J
            lreturn
        end local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/http/impl/client/HttpRequestTaskCallable<TV;>;

  public long getStarted();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
         0: .line 74
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
            lreturn
        end local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/http/impl/client/HttpRequestTaskCallable<TV;>;

  public long getEnded();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
         0: .line 78
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.ended:J
            lreturn
        end local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/http/impl/client/HttpRequestTaskCallable<TV;>;

  public V call();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=1
        start local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
         0: .line 83
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ifne 25
         1: .line 85
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getActiveConnections:()Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.incrementAndGet:()J
            pop2
         2: .line 86
            aload 0 /* this */
            invokestatic java.lang.System.currentTimeMillis:()J
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
         3: .line 88
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getScheduledConnections:()Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.decrementAndGet:()J
            pop2
         4: .line 89
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.httpclient:Lorg/apache/http/client/HttpClient;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.request:Lorg/apache/http/client/methods/HttpUriRequest;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.responseHandler:Lorg/apache/http/client/ResponseHandler;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.context:Lorg/apache/http/protocol/HttpContext;
            invokeinterface org.apache.http.client.HttpClient.execute:(Lorg/apache/http/client/methods/HttpUriRequest;Lorg/apache/http/client/ResponseHandler;Lorg/apache/http/protocol/HttpContext;)Ljava/lang/Object;
            astore 1 /* result */
        start local 1 // java.lang.Object result
         5: .line 90
            aload 0 /* this */
            invokestatic java.lang.System.currentTimeMillis:()J
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.ended:J
         6: .line 91
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getSuccessfulConnections:()Lorg/apache/http/impl/client/FutureRequestExecutionMetrics$DurationCounter;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics$DurationCounter.increment:(J)V
         7: .line 92
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.callback:Lorg/apache/http/concurrent/FutureCallback;
            ifnull 9
         8: .line 93
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.callback:Lorg/apache/http/concurrent/FutureCallback;
            aload 1 /* result */
            invokeinterface org.apache.http.concurrent.FutureCallback.completed:(Ljava/lang/Object;)V
         9: .line 95
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 1 /* result */
            astore 3
        10: .line 105
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getRequests:()Lorg/apache/http/impl/client/FutureRequestExecutionMetrics$DurationCounter;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics$DurationCounter.increment:(J)V
        11: .line 106
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getTasks:()Lorg/apache/http/impl/client/FutureRequestExecutionMetrics$DurationCounter;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics$DurationCounter.increment:(J)V
        12: .line 107
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getActiveConnections:()Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.decrementAndGet:()J
            pop2
        13: .line 95
            aload 3
            areturn
        end local 1 // java.lang.Object result
        14: .line 96
      StackMap locals: org.apache.http.impl.client.HttpRequestTaskCallable
      StackMap stack: java.lang.Exception
            astore 1 /* e */
        start local 1 // java.lang.Exception e
        15: .line 97
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getFailedConnections:()Lorg/apache/http/impl/client/FutureRequestExecutionMetrics$DurationCounter;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics$DurationCounter.increment:(J)V
        16: .line 98
            aload 0 /* this */
            invokestatic java.lang.System.currentTimeMillis:()J
            putfield org.apache.http.impl.client.HttpRequestTaskCallable.ended:J
        17: .line 99
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.callback:Lorg/apache/http/concurrent/FutureCallback;
            ifnull 19
        18: .line 100
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.callback:Lorg/apache/http/concurrent/FutureCallback;
            aload 1 /* e */
            invokeinterface org.apache.http.concurrent.FutureCallback.failed:(Ljava/lang/Exception;)V
        19: .line 102
      StackMap locals: java.lang.Exception
      StackMap stack:
            aload 1 /* e */
            athrow
        end local 1 // java.lang.Exception e
        20: .line 104
      StackMap locals: org.apache.http.impl.client.HttpRequestTaskCallable
      StackMap stack: java.lang.Throwable
            astore 2
        21: .line 105
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getRequests:()Lorg/apache/http/impl/client/FutureRequestExecutionMetrics$DurationCounter;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics$DurationCounter.increment:(J)V
        22: .line 106
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getTasks:()Lorg/apache/http/impl/client/FutureRequestExecutionMetrics$DurationCounter;
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.started:J
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics$DurationCounter.increment:(J)V
        23: .line 107
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.metrics:Lorg/apache/http/impl/client/FutureRequestExecutionMetrics;
            invokevirtual org.apache.http.impl.client.FutureRequestExecutionMetrics.getActiveConnections:()Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.decrementAndGet:()J
            pop2
        24: .line 108
            aload 2
            athrow
        25: .line 110
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalStateException
            dup
            new java.lang.StringBuilder
            dup
            ldc "call has been cancelled for request "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.request:Lorg/apache/http/client/methods/HttpUriRequest;
            invokeinterface org.apache.http.client.methods.HttpUriRequest.getURI:()Ljava/net/URI;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   26     0    this  Lorg/apache/http/impl/client/HttpRequestTaskCallable<TV;>;
            5   14     1  result  TV;
           15   20     1       e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           3    10      14  Class java.lang.Exception
           1    10      20  any
          14    20      20  any
    Exceptions:
      throws java.lang.Exception
    Signature: ()TV;

  public void cancel();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
         0: .line 114
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
         1: .line 115
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.callback:Lorg/apache/http/concurrent/FutureCallback;
            ifnull 3
         2: .line 116
            aload 0 /* this */
            getfield org.apache.http.impl.client.HttpRequestTaskCallable.callback:Lorg/apache/http/concurrent/FutureCallback;
            invokeinterface org.apache.http.concurrent.FutureCallback.cancelled:()V
         3: .line 118
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.apache.http.impl.client.HttpRequestTaskCallable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/apache/http/impl/client/HttpRequestTaskCallable<TV;>;
}
Signature: <V:Ljava/lang/Object;>Ljava/lang/Object;Ljava/util/concurrent/Callable<TV;>;
SourceFile: "HttpRequestTaskCallable.java"
InnerClasses:
  DurationCounter = org.apache.http.impl.client.FutureRequestExecutionMetrics$DurationCounter of org.apache.http.impl.client.FutureRequestExecutionMetrics
/

org.apache.httpcomponents/ httpclient/ 4.5.10/ org/apache/http/impl/client/HttpRequestTaskCallable.class
