package com.squareup.okhttp;

import com.squareup.okhttp.internal.ConnectionSpecSelector;
import com.squareup.okhttp.internal.Platform;
import com.squareup.okhttp.internal.RouteDatabase;
import com.squareup.okhttp.internal.Util;
import com.squareup.okhttp.internal.Version;
import com.squareup.okhttp.internal.framed.FramedConnection;
import com.squareup.okhttp.internal.framed.FramedConnection.Builder;
import com.squareup.okhttp.internal.http.FramedTransport;
import com.squareup.okhttp.internal.http.HttpConnection;
import com.squareup.okhttp.internal.http.HttpEngine;
import com.squareup.okhttp.internal.http.HttpTransport;
import com.squareup.okhttp.internal.http.OkHeaders;
import com.squareup.okhttp.internal.http.RouteException;
import com.squareup.okhttp.internal.http.Transport;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Proxy;
import java.net.Proxy.Type;
import java.net.Socket;
import java.net.UnknownServiceException;
import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.net.SocketFactory;
import okio.BufferedSink;
import okio.BufferedSource;
import okio.Source;

public final class Connection
{
  private FramedConnection framedConnection;
  private Handshake handshake;
  private HttpConnection httpConnection;
  private long idleStartTimeNs;
  private Object owner;
  private final ConnectionPool pool;
  private Protocol protocol;
  private int recycleCount;
  private final Route route;
  private Socket socket;
  
  public Connection(ConnectionPool paramConnectionPool, Route paramRoute)
  {
    this.pool = paramConnectionPool;
    this.route = paramRoute;
  }
  
  private void connectSocket(int paramInt1, int paramInt2, int paramInt3, ConnectionSpecSelector paramConnectionSpecSelector)
    throws IOException
  {
    this.socket.setSoTimeout(paramInt2);
    Platform.get().connectSocket(this.socket, this.route.getSocketAddress(), paramInt1);
    if (this.route.address.getSslSocketFactory() != null) {
      connectTls(paramInt2, paramInt3, paramConnectionSpecSelector);
    }
    while ((this.protocol == Protocol.SPDY_3) || (this.protocol == Protocol.HTTP_2))
    {
      this.socket.setSoTimeout(0);
      this.framedConnection = new FramedConnection.Builder(this.route.address.uriHost, true, this.socket).protocol(this.protocol).build();
      this.framedConnection.sendConnectionPreface();
      return;
      this.protocol = Protocol.HTTP_1_1;
    }
    this.httpConnection = new HttpConnection(this.pool, this, this.socket);
  }
  
  /* Error */
  private void connectTls(int paramInt1, int paramInt2, ConnectionSpecSelector paramConnectionSpecSelector)
    throws IOException
  {
    // Byte code:
    //   0: aconst_null
    //   1: astore 4
    //   3: aconst_null
    //   4: astore 7
    //   6: aconst_null
    //   7: astore 6
    //   9: aload_0
    //   10: getfield 33	com/squareup/okhttp/Connection:route	Lcom/squareup/okhttp/Route;
    //   13: invokevirtual 125	com/squareup/okhttp/Route:requiresTunnel	()Z
    //   16: ifeq +9 -> 25
    //   19: aload_0
    //   20: iload_1
    //   21: iload_2
    //   22: invokespecial 129	com/squareup/okhttp/Connection:createTunnel	(II)V
    //   25: aload_0
    //   26: getfield 33	com/squareup/okhttp/Connection:route	Lcom/squareup/okhttp/Route;
    //   29: invokevirtual 133	com/squareup/okhttp/Route:getAddress	()Lcom/squareup/okhttp/Address;
    //   32: astore 8
    //   34: aload 8
    //   36: invokevirtual 71	com/squareup/okhttp/Address:getSslSocketFactory	()Ljavax/net/ssl/SSLSocketFactory;
    //   39: astore 5
    //   41: aload 5
    //   43: aload_0
    //   44: getfield 40	com/squareup/okhttp/Connection:socket	Ljava/net/Socket;
    //   47: aload 8
    //   49: invokevirtual 137	com/squareup/okhttp/Address:getUriHost	()Ljava/lang/String;
    //   52: aload 8
    //   54: invokevirtual 141	com/squareup/okhttp/Address:getUriPort	()I
    //   57: iconst_1
    //   58: invokevirtual 147	javax/net/ssl/SSLSocketFactory:createSocket	(Ljava/net/Socket;Ljava/lang/String;IZ)Ljava/net/Socket;
    //   61: checkcast 149	javax/net/ssl/SSLSocket
    //   64: astore 5
    //   66: aload_3
    //   67: aload 5
    //   69: invokevirtual 155	com/squareup/okhttp/internal/ConnectionSpecSelector:configureSecureSocket	(Ljavax/net/ssl/SSLSocket;)Lcom/squareup/okhttp/ConnectionSpec;
    //   72: astore 6
    //   74: aload 6
    //   76: invokevirtual 160	com/squareup/okhttp/ConnectionSpec:supportsTlsExtensions	()Z
    //   79: ifeq +21 -> 100
    //   82: invokestatic 52	com/squareup/okhttp/internal/Platform:get	()Lcom/squareup/okhttp/internal/Platform;
    //   85: aload 5
    //   87: aload 8
    //   89: invokevirtual 137	com/squareup/okhttp/Address:getUriHost	()Ljava/lang/String;
    //   92: aload 8
    //   94: invokevirtual 164	com/squareup/okhttp/Address:getProtocols	()Ljava/util/List;
    //   97: invokevirtual 168	com/squareup/okhttp/internal/Platform:configureTlsExtensions	(Ljavax/net/ssl/SSLSocket;Ljava/lang/String;Ljava/util/List;)V
    //   100: aload 5
    //   102: invokevirtual 171	javax/net/ssl/SSLSocket:startHandshake	()V
    //   105: aload 5
    //   107: invokevirtual 175	javax/net/ssl/SSLSocket:getSession	()Ljavax/net/ssl/SSLSession;
    //   110: invokestatic 180	com/squareup/okhttp/Handshake:get	(Ljavax/net/ssl/SSLSession;)Lcom/squareup/okhttp/Handshake;
    //   113: astore 4
    //   115: aload 8
    //   117: invokevirtual 184	com/squareup/okhttp/Address:getHostnameVerifier	()Ljavax/net/ssl/HostnameVerifier;
    //   120: aload 8
    //   122: invokevirtual 137	com/squareup/okhttp/Address:getUriHost	()Ljava/lang/String;
    //   125: aload 5
    //   127: invokevirtual 175	javax/net/ssl/SSLSocket:getSession	()Ljavax/net/ssl/SSLSession;
    //   130: invokeinterface 190 3 0
    //   135: ifne +141 -> 276
    //   138: aload 4
    //   140: invokevirtual 193	com/squareup/okhttp/Handshake:peerCertificates	()Ljava/util/List;
    //   143: iconst_0
    //   144: invokeinterface 198 2 0
    //   149: checkcast 200	java/security/cert/X509Certificate
    //   152: astore_3
    //   153: new 202	javax/net/ssl/SSLPeerUnverifiedException
    //   156: dup
    //   157: new 204	java/lang/StringBuilder
    //   160: dup
    //   161: ldc -50
    //   163: invokespecial 209	java/lang/StringBuilder:<init>	(Ljava/lang/String;)V
    //   166: aload 8
    //   168: invokevirtual 137	com/squareup/okhttp/Address:getUriHost	()Ljava/lang/String;
    //   171: invokevirtual 213	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   174: ldc -41
    //   176: invokevirtual 213	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   179: aload_3
    //   180: invokestatic 221	com/squareup/okhttp/CertificatePinner:pin	(Ljava/security/cert/Certificate;)Ljava/lang/String;
    //   183: invokevirtual 213	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   186: ldc -33
    //   188: invokevirtual 213	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   191: aload_3
    //   192: invokevirtual 227	java/security/cert/X509Certificate:getSubjectDN	()Ljava/security/Principal;
    //   195: invokeinterface 232 1 0
    //   200: invokevirtual 213	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   203: ldc -22
    //   205: invokevirtual 213	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   208: aload_3
    //   209: invokestatic 240	com/squareup/okhttp/internal/tls/OkHostnameVerifier:allSubjectAltNames	(Ljava/security/cert/X509Certificate;)Ljava/util/List;
    //   212: invokevirtual 243	java/lang/StringBuilder:append	(Ljava/lang/Object;)Ljava/lang/StringBuilder;
    //   215: invokevirtual 246	java/lang/StringBuilder:toString	()Ljava/lang/String;
    //   218: invokespecial 247	javax/net/ssl/SSLPeerUnverifiedException:<init>	(Ljava/lang/String;)V
    //   221: athrow
    //   222: astore 4
    //   224: aload 5
    //   226: astore_3
    //   227: aload 4
    //   229: astore 5
    //   231: aload_3
    //   232: astore 4
    //   234: aload 5
    //   236: invokestatic 253	com/squareup/okhttp/internal/Util:isAndroidGetsocknameError	(Ljava/lang/AssertionError;)Z
    //   239: ifeq +122 -> 361
    //   242: aload_3
    //   243: astore 4
    //   245: new 38	java/io/IOException
    //   248: dup
    //   249: aload 5
    //   251: invokespecial 256	java/io/IOException:<init>	(Ljava/lang/Throwable;)V
    //   254: athrow
    //   255: astore_3
    //   256: aload 4
    //   258: ifnull +11 -> 269
    //   261: invokestatic 52	com/squareup/okhttp/internal/Platform:get	()Lcom/squareup/okhttp/internal/Platform;
    //   264: aload 4
    //   266: invokevirtual 260	com/squareup/okhttp/internal/Platform:afterHandshake	(Ljavax/net/ssl/SSLSocket;)V
    //   269: aload 4
    //   271: invokestatic 264	com/squareup/okhttp/internal/Util:closeQuietly	(Ljava/net/Socket;)V
    //   274: aload_3
    //   275: athrow
    //   276: aload 8
    //   278: invokevirtual 268	com/squareup/okhttp/Address:getCertificatePinner	()Lcom/squareup/okhttp/CertificatePinner;
    //   281: aload 8
    //   283: invokevirtual 137	com/squareup/okhttp/Address:getUriHost	()Ljava/lang/String;
    //   286: aload 4
    //   288: invokevirtual 193	com/squareup/okhttp/Handshake:peerCertificates	()Ljava/util/List;
    //   291: invokevirtual 272	com/squareup/okhttp/CertificatePinner:check	(Ljava/lang/String;Ljava/util/List;)V
    //   294: aload 7
    //   296: astore_3
    //   297: aload 6
    //   299: invokevirtual 160	com/squareup/okhttp/ConnectionSpec:supportsTlsExtensions	()Z
    //   302: ifeq +12 -> 314
    //   305: invokestatic 52	com/squareup/okhttp/internal/Platform:get	()Lcom/squareup/okhttp/internal/Platform;
    //   308: aload 5
    //   310: invokevirtual 276	com/squareup/okhttp/internal/Platform:getSelectedProtocol	(Ljavax/net/ssl/SSLSocket;)Ljava/lang/String;
    //   313: astore_3
    //   314: aload_0
    //   315: aload 5
    //   317: putfield 40	com/squareup/okhttp/Connection:socket	Ljava/net/Socket;
    //   320: aload_0
    //   321: aload 4
    //   323: putfield 278	com/squareup/okhttp/Connection:handshake	Lcom/squareup/okhttp/Handshake;
    //   326: aload_3
    //   327: ifnull +27 -> 354
    //   330: aload_3
    //   331: invokestatic 281	com/squareup/okhttp/Protocol:get	(Ljava/lang/String;)Lcom/squareup/okhttp/Protocol;
    //   334: astore_3
    //   335: aload_0
    //   336: aload_3
    //   337: putfield 77	com/squareup/okhttp/Connection:protocol	Lcom/squareup/okhttp/Protocol;
    //   340: aload 5
    //   342: ifnull +11 -> 353
    //   345: invokestatic 52	com/squareup/okhttp/internal/Platform:get	()Lcom/squareup/okhttp/internal/Platform;
    //   348: aload 5
    //   350: invokevirtual 260	com/squareup/okhttp/internal/Platform:afterHandshake	(Ljavax/net/ssl/SSLSocket;)V
    //   353: return
    //   354: getstatic 111	com/squareup/okhttp/Protocol:HTTP_1_1	Lcom/squareup/okhttp/Protocol;
    //   357: astore_3
    //   358: goto -23 -> 335
    //   361: aload_3
    //   362: astore 4
    //   364: aload 5
    //   366: athrow
    //   367: astore_3
    //   368: aload 5
    //   370: astore 4
    //   372: goto -116 -> 256
    //   375: astore 5
    //   377: aload 6
    //   379: astore_3
    //   380: goto -149 -> 231
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	383	0	this	Connection
    //   0	383	1	paramInt1	int
    //   0	383	2	paramInt2	int
    //   0	383	3	paramConnectionSpecSelector	ConnectionSpecSelector
    //   1	138	4	localHandshake	Handshake
    //   222	6	4	localAssertionError1	AssertionError
    //   232	139	4	localObject1	Object
    //   39	330	5	localObject2	Object
    //   375	1	5	localAssertionError2	AssertionError
    //   7	371	6	localConnectionSpec	ConnectionSpec
    //   4	291	7	localObject3	Object
    //   32	250	8	localAddress	Address
    // Exception table:
    //   from	to	target	type
    //   66	100	222	java/lang/AssertionError
    //   100	222	222	java/lang/AssertionError
    //   276	294	222	java/lang/AssertionError
    //   297	314	222	java/lang/AssertionError
    //   314	326	222	java/lang/AssertionError
    //   330	335	222	java/lang/AssertionError
    //   335	340	222	java/lang/AssertionError
    //   354	358	222	java/lang/AssertionError
    //   41	66	255	finally
    //   234	242	255	finally
    //   245	255	255	finally
    //   364	367	255	finally
    //   66	100	367	finally
    //   100	222	367	finally
    //   276	294	367	finally
    //   297	314	367	finally
    //   314	326	367	finally
    //   330	335	367	finally
    //   335	340	367	finally
    //   354	358	367	finally
    //   41	66	375	java/lang/AssertionError
  }
  
  private void createTunnel(int paramInt1, int paramInt2)
    throws IOException
  {
    Object localObject1 = createTunnelRequest();
    HttpConnection localHttpConnection = new HttpConnection(this.pool, this, this.socket);
    localHttpConnection.setTimeouts(paramInt1, paramInt2);
    Object localObject2 = ((Request)localObject1).httpUrl();
    String str = "CONNECT " + ((HttpUrl)localObject2).host() + ":" + ((HttpUrl)localObject2).port() + " HTTP/1.1";
    do
    {
      localHttpConnection.writeRequest(((Request)localObject1).headers(), str);
      localHttpConnection.flush();
      localObject1 = localHttpConnection.readResponse().request((Request)localObject1).build();
      long l2 = OkHeaders.contentLength((Response)localObject1);
      long l1 = l2;
      if (l2 == -1L) {
        l1 = 0L;
      }
      localObject2 = localHttpConnection.newFixedLengthSource(l1);
      Util.skipAll((Source)localObject2, Integer.MAX_VALUE, TimeUnit.MILLISECONDS);
      ((Source)localObject2).close();
      switch (((Response)localObject1).code())
      {
      default: 
        throw new IOException("Unexpected response code for CONNECT: " + ((Response)localObject1).code());
      case 200: 
        if (localHttpConnection.bufferSize() <= 0L) {
          break;
        }
        throw new IOException("TLS tunnel buffered too many bytes!");
      case 407: 
        localObject2 = OkHeaders.processAuthHeader(this.route.getAddress().getAuthenticator(), (Response)localObject1, this.route.getProxy());
        localObject1 = localObject2;
      }
    } while (localObject2 != null);
    throw new IOException("Failed to authenticate with proxy");
  }
  
  private Request createTunnelRequest()
    throws IOException
  {
    HttpUrl localHttpUrl = new HttpUrl.Builder().scheme("https").host(this.route.address.uriHost).port(this.route.address.uriPort).build();
    return new Request.Builder().url(localHttpUrl).header("Host", Util.hostHeader(localHttpUrl)).header("Proxy-Connection", "Keep-Alive").header("User-Agent", Version.userAgent()).build();
  }
  
  final boolean clearOwner()
  {
    synchronized (this.pool)
    {
      if (this.owner == null) {
        return false;
      }
      this.owner = null;
      return true;
    }
  }
  
  final void closeIfOwnedBy(Object paramObject)
    throws IOException
  {
    if (isFramed()) {
      throw new IllegalStateException();
    }
    synchronized (this.pool)
    {
      if (this.owner != paramObject) {
        return;
      }
      this.owner = null;
      if (this.socket != null)
      {
        this.socket.close();
        return;
      }
    }
  }
  
  final void connect(int paramInt1, int paramInt2, int paramInt3, List<ConnectionSpec> paramList, boolean paramBoolean)
    throws RouteException
  {
    if (this.protocol != null) {
      throw new IllegalStateException("already connected");
    }
    ConnectionSpecSelector localConnectionSpecSelector = new ConnectionSpecSelector(paramList);
    Proxy localProxy = this.route.getProxy();
    Address localAddress = this.route.getAddress();
    if ((this.route.address.getSslSocketFactory() == null) && (!paramList.contains(ConnectionSpec.CLEARTEXT))) {
      throw new RouteException(new UnknownServiceException("CLEARTEXT communication not supported: " + paramList));
    }
    for (;;)
    {
      try
      {
        localObject = new Socket(localProxy);
        this.socket = ((Socket)localObject);
        connectSocket(paramInt1, paramInt2, paramInt3, localConnectionSpecSelector);
      }
      catch (IOException localIOException)
      {
        Util.closeQuietly(this.socket);
        this.socket = null;
        this.handshake = null;
        this.protocol = null;
        this.httpConnection = null;
        this.framedConnection = null;
        if (paramList != null) {
          continue;
        }
        Object localObject = new RouteException(localIOException);
        if (!paramBoolean) {
          continue;
        }
        paramList = (List<ConnectionSpec>)localObject;
        if (localConnectionSpecSelector.connectionFailed(localIOException)) {
          continue;
        }
        throw ((Throwable)localObject);
        paramList.addConnectException(localIOException);
        localObject = paramList;
        continue;
      }
      if (this.protocol == null)
      {
        if ((localProxy.type() == Proxy.Type.DIRECT) || (localProxy.type() == Proxy.Type.HTTP)) {
          localObject = localAddress.getSocketFactory().createSocket();
        }
      }
      else
      {
        return;
        paramList = null;
      }
    }
  }
  
  final void connectAndSetOwner(OkHttpClient paramOkHttpClient, Object paramObject)
    throws RouteException
  {
    setOwner(paramObject);
    if (!isConnected())
    {
      paramObject = this.route.address.getConnectionSpecs();
      connect(paramOkHttpClient.getConnectTimeout(), paramOkHttpClient.getReadTimeout(), paramOkHttpClient.getWriteTimeout(), (List)paramObject, paramOkHttpClient.getRetryOnConnectionFailure());
      if (isFramed()) {
        paramOkHttpClient.getConnectionPool().share(this);
      }
      paramOkHttpClient.routeDatabase().connected(getRoute());
    }
    setTimeouts(paramOkHttpClient.getReadTimeout(), paramOkHttpClient.getWriteTimeout());
  }
  
  public final Handshake getHandshake()
  {
    return this.handshake;
  }
  
  final long getIdleStartTimeNs()
  {
    if (this.framedConnection == null) {
      return this.idleStartTimeNs;
    }
    return this.framedConnection.getIdleStartTimeNs();
  }
  
  final Object getOwner()
  {
    synchronized (this.pool)
    {
      Object localObject1 = this.owner;
      return localObject1;
    }
  }
  
  public final Protocol getProtocol()
  {
    if (this.protocol != null) {
      return this.protocol;
    }
    return Protocol.HTTP_1_1;
  }
  
  public final Route getRoute()
  {
    return this.route;
  }
  
  public final Socket getSocket()
  {
    return this.socket;
  }
  
  final void incrementRecycleCount()
  {
    this.recycleCount += 1;
  }
  
  final boolean isAlive()
  {
    return (!this.socket.isClosed()) && (!this.socket.isInputShutdown()) && (!this.socket.isOutputShutdown());
  }
  
  final boolean isConnected()
  {
    return this.protocol != null;
  }
  
  final boolean isFramed()
  {
    return this.framedConnection != null;
  }
  
  final boolean isIdle()
  {
    return (this.framedConnection == null) || (this.framedConnection.isIdle());
  }
  
  final boolean isReadable()
  {
    if (this.httpConnection != null) {
      return this.httpConnection.isReadable();
    }
    return true;
  }
  
  final Transport newTransport(HttpEngine paramHttpEngine)
    throws IOException
  {
    if (this.framedConnection != null) {
      return new FramedTransport(paramHttpEngine, this.framedConnection);
    }
    return new HttpTransport(paramHttpEngine, this.httpConnection);
  }
  
  final BufferedSink rawSink()
  {
    if (this.httpConnection == null) {
      throw new UnsupportedOperationException();
    }
    return this.httpConnection.rawSink();
  }
  
  final BufferedSource rawSource()
  {
    if (this.httpConnection == null) {
      throw new UnsupportedOperationException();
    }
    return this.httpConnection.rawSource();
  }
  
  final int recycleCount()
  {
    return this.recycleCount;
  }
  
  final void resetIdleStartTime()
  {
    if (this.framedConnection != null) {
      throw new IllegalStateException("framedConnection != null");
    }
    this.idleStartTimeNs = System.nanoTime();
  }
  
  final void setOwner(Object paramObject)
  {
    if (isFramed()) {
      return;
    }
    synchronized (this.pool)
    {
      if (this.owner != null) {
        throw new IllegalStateException("Connection already has an owner!");
      }
    }
    this.owner = paramObject;
  }
  
  final void setTimeouts(int paramInt1, int paramInt2)
    throws RouteException
  {
    if (this.protocol == null) {
      throw new IllegalStateException("not connected");
    }
    if (this.httpConnection != null) {}
    try
    {
      this.socket.setSoTimeout(paramInt1);
      this.httpConnection.setTimeouts(paramInt1, paramInt2);
      return;
    }
    catch (IOException localIOException)
    {
      throw new RouteException(localIOException);
    }
  }
  
  public final String toString()
  {
    StringBuilder localStringBuilder = new StringBuilder("Connection{").append(this.route.address.uriHost).append(":").append(this.route.address.uriPort).append(", proxy=").append(this.route.proxy).append(" hostAddress=").append(this.route.inetSocketAddress.getAddress().getHostAddress()).append(" cipherSuite=");
    if (this.handshake != null) {}
    for (String str = this.handshake.cipherSuite();; str = "none") {
      return str + " protocol=" + this.protocol + '}';
    }
  }
}


/* Location:              /home/merong/decompile/hackery-dex2jar.jar!/com/squareup/okhttp/Connection.class
 * Java compiler version: 6 (50.0)
 * JD-Core Version:       0.7.1
 */