public abstract class bj

  implements bg

{

  private static final int a = 32;

  private static final ThreadLocal b = new ThreadLocal()

  {

    protected char[] a()

    {

      return new char['?'];

    }

  };

  private static final char[] a(char[] paramArrayOfChar, int paramInt1, int paramInt2)

  {

    char[] arrayOfChar = new char[paramInt2];

    if (paramInt1 > 0) {

      System.arraycopy(paramArrayOfChar, 0, arrayOfChar, 0, paramInt1);

    }

    return arrayOfChar;

  }

  protected static final int b(CharSequence paramCharSequence, int paramInt1, int paramInt2)

  {

    if (paramInt1 < paramInt2)

    {

      int j = paramInt1 + 1;

      int i = paramCharSequence.charAt(paramInt1);

      if ((i < 55296) || (i > 57343)) {

        return i;

      }

      if (i <= 56319)

      {

        if (j == paramInt2) {

          return -i;

        }

        char c = paramCharSequence.charAt(j);

        if (Character.isLowSurrogate(c)) {

          return Character.toCodePoint(i, c);

        }

        throw new IllegalArgumentException("Expected low surrogate but got char '" + c + "' with value " + c + " at index " + j);

      }

      throw new IllegalArgumentException("Unexpected low surrogate character '" + i + "' with value " + i + " at index " + (j - 1));

    }

    throw new IndexOutOfBoundsException("Index exceeds specified range");

  }

  protected int a(CharSequence paramCharSequence, int paramInt1, int paramInt2)

  {

    if (paramInt1 < paramInt2)

    {

      i = b(paramCharSequence, paramInt1, paramInt2);

      if ((i >= 0) && (a(i) == null)) {}

    }

    else

    {

      return paramInt1;

    }

    if (Character.isSupplementaryCodePoint(i)) {}

    for (int i = 2;; i = 1)

    {

      paramInt1 += i;

      break;

    }

  }

  public Appendable a(final Appendable paramAppendable)

  {

    bi.a(paramAppendable);

    new Appendable()

    {

      int a = -1;

      char[] b = new char[2];

      private void a(char[] paramAnonymousArrayOfChar, int paramAnonymousInt)

      {

        int i = 0;

        while (i < paramAnonymousInt)

        {

          paramAppendable.append(paramAnonymousArrayOfChar[i]);

          i += 1;

        }

      }

      public Appendable append(char paramAnonymousChar)

      {

        if (this.a != -1)

        {

          if (!Character.isLowSurrogate(paramAnonymousChar)) {

            throw new IllegalArgumentException("Expected low surrogate character but got '" + paramAnonymousChar + "' with value " + paramAnonymousChar);

          }

          arrayOfChar = bj.this.a(Character.toCodePoint((char)this.a, paramAnonymousChar));

          if (arrayOfChar != null) {

            a(arrayOfChar, arrayOfChar.length);

          }

          for (;;)

          {

            this.a = -1;

            return this;

            paramAppendable.append((char)this.a);

            paramAppendable.append(paramAnonymousChar);

          }

        }

        if (Character.isHighSurrogate(paramAnonymousChar))

        {

          this.a = paramAnonymousChar;

          return this;

        }

        if (Character.isLowSurrogate(paramAnonymousChar)) {

          throw new IllegalArgumentException("Unexpected low surrogate character '" + paramAnonymousChar + "' with value " + paramAnonymousChar);

        }

        char[] arrayOfChar = bj.this.a(paramAnonymousChar);

        if (arrayOfChar != null)

        {

          a(arrayOfChar, arrayOfChar.length);

          return this;

        }

        paramAppendable.append(paramAnonymousChar);

        return this;

      }

      public Appendable append(CharSequence paramAnonymousCharSequence)

      {

        return append(paramAnonymousCharSequence, 0, paramAnonymousCharSequence.length());

      }

      public Appendable append(CharSequence paramAnonymousCharSequence, int paramAnonymousInt1, int paramAnonymousInt2)

      {

        int i;

        char[] arrayOfChar;

        if (paramAnonymousInt1 < paramAnonymousInt2)

        {

          if (this.a == -1) {

            break label257;

          }

          i = paramAnonymousInt1 + 1;

          char c1 = paramAnonymousCharSequence.charAt(paramAnonymousInt1);

          if (!Character.isLowSurrogate(c1)) {

            throw new IllegalArgumentException("Expected low surrogate character but got " + c1);

          }

          arrayOfChar = bj.this.a(Character.toCodePoint((char)this.a, c1));

          if (arrayOfChar == null) {

            break label146;

          }

          a(arrayOfChar, arrayOfChar.length);

          paramAnonymousInt1 += 1;

          this.a = -1;

        }

        for (;;)

        {

          i = bj.this.a(paramAnonymousCharSequence, i, paramAnonymousInt2);

          if (i > paramAnonymousInt1) {

            paramAppendable.append(paramAnonymousCharSequence, paramAnonymousInt1, i);

          }

          if (i == paramAnonymousInt2)

          {

            return this;

            label146:

            paramAppendable.append((char)this.a);

            break;

          }

          paramAnonymousInt1 = bj.b(paramAnonymousCharSequence, i, paramAnonymousInt2);

          if (paramAnonymousInt1 < 0)

          {

            this.a = (-paramAnonymousInt1);

            return this;

          }

          arrayOfChar = bj.this.a(paramAnonymousInt1);

          if (arrayOfChar != null)

          {

            a(arrayOfChar, arrayOfChar.length);

            label208:

            if (!Character.isSupplementaryCodePoint(paramAnonymousInt1)) {

              break label252;

            }

          }

          label252:

          for (paramAnonymousInt1 = 2;; paramAnonymousInt1 = 1)

          {

            paramAnonymousInt1 = i + paramAnonymousInt1;

            i = paramAnonymousInt1;

            break;

            int j = Character.toChars(paramAnonymousInt1, this.b, 0);

            a(this.b, j);

            break label208;

          }

          label257:

          i = paramAnonymousInt1;

        }

      }

    };

  }

  public String a(String paramString)

  {

    int i = paramString.length();

    int j = a(paramString, 0, i);

    if (j == i) {

      return paramString;

    }

    return a(paramString, j);

  }

  protected final String a(String paramString, int paramInt)

  {

    int n = paramString.length();

    Object localObject1 = (char[])b.get();

    int m = 0;

    int i = 0;

    int k = paramInt;

    paramInt = i;

    if (k < n)

    {

      int i1 = b(paramString, k, n);

      if (i1 < 0) {

        throw new IllegalArgumentException("Trailing high surrogate at end of input");

      }

      char[] arrayOfChar = a(i1);

      i = paramInt;

      Object localObject3 = localObject1;

      if (arrayOfChar != null)

      {

        i = k - m;

        j = paramInt + i + arrayOfChar.length;

        localObject2 = localObject1;

        if (localObject1.length < j) {

          localObject2 = a((char[])localObject1, paramInt, j + (n - k) + 32);

        }

        j = paramInt;

        if (i > 0)

        {

          paramString.getChars(m, k, (char[])localObject2, paramInt);

          j = paramInt + i;

        }

        i = j;

        localObject3 = localObject2;

        if (arrayOfChar.length > 0)

        {

          System.arraycopy(arrayOfChar, 0, localObject2, j, arrayOfChar.length);

          i = j + arrayOfChar.length;

          localObject3 = localObject2;

        }

      }

      if (Character.isSupplementaryCodePoint(i1)) {}

      for (paramInt = 2;; paramInt = 1)

      {

        m = paramInt + k;

        k = a(paramString, m, n);

        paramInt = i;

        localObject1 = localObject3;

        break;

      }

    }

    int j = n - m;

    i = paramInt;

    Object localObject2 = localObject1;

    if (j > 0)

    {

      i = j + paramInt;

      localObject2 = localObject1;

      if (localObject1.length < i) {

        localObject2 = a((char[])localObject1, paramInt, i);

      }

      paramString.getChars(m, n, (char[])localObject2, paramInt);

    }

    return new String((char[])localObject2, 0, i);

  }

  protected abstract char[] a(int paramInt);

}

import com.gtomato.talkbox.TalkBoxApplication;

import java.io.BufferedOutputStream;

import java.io.IOException;

import java.net.Socket;

import java.nio.ByteBuffer;

import java.nio.channels.SelectableChannel;

import java.nio.channels.SelectionKey;

import java.nio.channels.Selector;

import java.nio.channels.SocketChannel;

import java.util.LinkedList;

import java.util.Queue;

import java.util.concurrent.ConcurrentLinkedQueue;

import java.util.concurrent.atomic.AtomicBoolean;

public class fa

  extends et

  implements Runnable

{

  private static final int r = 30000;

  private static final int s = 10000;

  private static final int t = 1;

  private static final int u = 3;

  private static final int v = 10;

  private static final short w = 6;

  private static final short x = 7;

  private static final byte[] y;

  private Selector A;

  private Socket B;

  private fa.b C;

  private Thread D;

  private final Object E = new Object();

  private final Object F = new Object();

  private volatile boolean G;

  private AtomicBoolean H = new AtomicBoolean(false);

  private AtomicBoolean I = new AtomicBoolean(false);

  private gt J = gt.a();

  private TalkBoxApplication K = gx.b;

  private ByteBuffer L = ByteBuffer.allocate(8192);

  private byte[] M = null;

  private SocketChannel z;

  static

  {

    if (!fa.class.desiredAssertionStatus()) {}

    for (boolean bool = true;; bool = false)

    {

      q = bool;

      byte[] arrayOfByte = new byte[2];

      arrayOfByte[0] = 1;

      y = arrayOfByte;

      return;

    }

  }

  public fa(gj paramgj)

  {

    super(paramgj);

  }

  private void a(fl paramfl)

  {

    if ((!q) && (paramfl == null)) {

      throw new AssertionError();

    }

    this.K.a(paramfl.c(), paramfl.a(), paramfl.b(), paramfl.d(), paramfl.e());

  }

  private void a(SelectionKey paramSelectionKey)

  {

    boolean bool = true;

    SocketChannel localSocketChannel = (SocketChannel)paramSelectionKey.channel();

    this.L.clear();

    int i;

    try

    {

      i = localSocketChannel.read(this.L);

      if (i == -1)

      {

        paramSelectionKey.channel().close();

        paramSelectionKey.cancel();

        throw new IOException();

      }

    }

    catch (Exception localException)

    {

      paramSelectionKey.cancel();

      localSocketChannel.close();

      throw localException;

    }

    paramSelectionKey = this.J;

    long l = i;

    byte[] arrayOfByte2;

    if (gx.d() == 1)

    {

      paramSelectionKey.b(l, bool);

      paramSelectionKey = (byte[])null;

      paramSelectionKey = (byte[])null;

      if (this.M != null) {

        paramSelectionKey = (byte[])this.M.clone();

      }

      arrayOfByte2 = this.L.array();

      if (paramSelectionKey == null) {

        break label192;

      }

      byte[] arrayOfByte1 = new byte[paramSelectionKey.length + i];

      System.arraycopy(paramSelectionKey, 0, arrayOfByte1, 0, paramSelectionKey.length);

      System.arraycopy(arrayOfByte2, 0, arrayOfByte1, paramSelectionKey.length, i);

      paramSelectionKey = arrayOfByte1;

    }

    for (;;)

    {

      paramSelectionKey = a(paramSelectionKey, localSocketChannel);

      if (paramSelectionKey == null) {

        break label208;

      }

      this.M = ((byte[])paramSelectionKey.clone());

      return;

      bool = false;

      break;

      label192:

      paramSelectionKey = new byte[i];

      System.arraycopy(arrayOfByte2, 0, paramSelectionKey, 0, i);

    }

    label208:

    this.M = null;

  }

  private boolean a(ez paramez)

  {

    paramez = paramez.a();

    if (paramez != null) {}

    switch (paramez.a())

    {

    case 3:

    default:

      return true;

    }

    return false;

  }

  private byte[] a(byte[] paramArrayOfByte, SocketChannel paramSocketChannel)

  {

    if (paramArrayOfByte == null) {

      paramSocketChannel = null;

    }

    do

    {

      return paramSocketChannel;

      paramSocketChannel = paramArrayOfByte;

    } while (paramArrayOfByte.length < 2);

    paramArrayOfByte = (byte[])paramArrayOfByte.clone();

    if (paramArrayOfByte.length < 2) {}

    for (;;)

    {

      return paramArrayOfByte;

      byte[] arrayOfByte = new byte[2];

      paramArrayOfByte = (byte[])paramArrayOfByte.clone();

      System.arraycopy(paramArrayOfByte, 0, arrayOfByte, 0, 2);

      if (paramArrayOfByte.length > 2)

      {

        paramSocketChannel = new byte[paramArrayOfByte.length - 2];

        System.arraycopy(paramArrayOfByte, 2, paramSocketChannel, 0, paramArrayOfByte.length - 2);

      }

      int i;

      for (;;)

      {

        i = fn.b(arrayOfByte);

        if (i != 0) {

          break label112;

        }

        gu.c("[PC] HeartBeat Received...");

        this.k = System.currentTimeMillis();

        paramArrayOfByte = paramSocketChannel;

        break;

        paramSocketChannel = new byte[0];

      }

      label112:

      if (i == 6)

      {

        paramArrayOfByte = fn.a(gx.a(String.valueOf(this.h.c())) + ";2");

        arrayOfByte = new byte[paramArrayOfByte.length + 2];

        System.arraycopy(fn.c(fn.c(paramArrayOfByte.length)), 0, arrayOfByte, 0, 2);

        System.arraycopy(paramArrayOfByte, 0, arrayOfByte, 2, paramArrayOfByte.length);

        this.C.a(arrayOfByte);

        paramArrayOfByte = paramSocketChannel;

        break;

      }

      paramArrayOfByte = paramSocketChannel;

      if (i == 7) {

        break;

      }

      if (paramSocketChannel.length >= i)

      {

        paramArrayOfByte = new byte[i];

        System.arraycopy(paramSocketChannel, 0, paramArrayOfByte, 0, i);

        this.C.a(y);

        a(fl.a(paramArrayOfByte));

        if (paramSocketChannel.length - i > 0)

        {

          paramArrayOfByte = new byte[paramSocketChannel.length - i];

          System.arraycopy(paramSocketChannel, i, paramArrayOfByte, 0, paramSocketChannel.length - i);

          paramArrayOfByte = (byte[])paramArrayOfByte.clone();

          break;

        }

        paramArrayOfByte = new byte[0];

        break;

      }

      paramArrayOfByte = new byte[paramSocketChannel.length + 2];

      System.arraycopy(arrayOfByte, 0, paramArrayOfByte, 0, 2);

      if (paramSocketChannel.length > 0) {

        System.arraycopy(paramSocketChannel, 0, paramArrayOfByte, 2, paramSocketChannel.length);

      }

      paramArrayOfByte = (byte[])paramArrayOfByte.clone();

    }

  }

  /* Error */

  private void c(int paramInt)

  {

    // Byte code:

    //   0: iload_1

    //   1: iconst_3

    //   2: if_icmpgt +29 -> 31

    //   5: new 224    java/lang/StringBuilder

    //   8: dup

    //   9: ldc_w 282

    //   12: invokespecial 245    java/lang/StringBuilder:<init>    (Ljava/lang/String;)V

    //   15: iload_1

    //   16: invokevirtual 285    java/lang/StringBuilder:append    (I)Ljava/lang/StringBuilder;

    //   19: ldc_w 287

    //   22: invokevirtual 251    java/lang/StringBuilder:append    (Ljava/lang/String;)Ljava/lang/StringBuilder;

    //   25: invokevirtual 254    java/lang/StringBuilder:toString    ()Ljava/lang/String;

    //   28: invokestatic 215    gu:c    (Ljava/lang/String;)V

    //   31: aload_0

    //   32: getfield 289    fa:G    Z

    //   35: ifeq +64 -> 99

    //   38: aload_0

    //   39: invokespecial 292    fa:n    ()V

    //   42: iload_1

    //   43: iconst_3

    //   44: if_icmple +71 -> 115

    //   47: aload_0

    //   48: monitorenter

    //   49: aload_0

    //   50: getfield 289    fa:G    Z

    //   53: ifeq +25 -> 78

    //   56: aload_0

    //   57: getfield 97    fa:H    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   60: iconst_0

    //   61: invokevirtual 295    java/util/concurrent/atomic/AtomicBoolean:set    (Z)V

    //   64: aload_0

    //   65: getfield 99    fa:I    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   68: iconst_0

    //   69: invokevirtual 295    java/util/concurrent/atomic/AtomicBoolean:set    (Z)V

    //   72: aload_0

    //   73: iconst_0

    //   74: aconst_null

    //   75: invokevirtual 298    fa:a    (ILey;)V

    //   78: aload_0

    //   79: monitorexit

    //   80: aload_0

    //   81: getfield 78    fa:E    Ljava/lang/Object;

    //   84: astore 4

    //   86: aload 4

    //   88: monitorenter

    //   89: aload_0

    //   90: getfield 78    fa:E    Ljava/lang/Object;

    //   93: invokevirtual 301    java/lang/Object:notify    ()V

    //   96: aload 4

    //   98: monitorexit

    //   99: return

    //   100: astore 4

    //   102: aload_0

    //   103: monitorexit

    //   104: aload 4

    //   106: athrow

    //   107: astore 5

    //   109: aload 4

    //   111: monitorexit

    //   112: aload 5

    //   114: athrow

    //   115: aload_0

    //   116: monitorenter

    //   117: aload_0

    //   118: getfield 289    fa:G    Z

    //   121: ifeq +9 -> 130

    //   124: aload_0

    //   125: iconst_2

    //   126: aconst_null

    //   127: invokevirtual 298    fa:a    (ILey;)V

    //   130: aload_0

    //   131: monitorexit

    //   132: iload_1

    //   133: sipush 5000

    //   136: imul

    //   137: i2l

    //   138: lstore_2

    //   139: lload_2

    //   140: invokestatic 307    java/lang/Thread:sleep    (J)V

    //   143: aload_0

    //   144: getfield 289    fa:G    Z

    //   147: ifeq -48 -> 99

    //   150: aload_0

    //   151: invokespecial 310    fa:l    ()V

    //   154: aload_0

    //   155: getfield 289    fa:G    Z

    //   158: ifeq -59 -> 99

    //   161: new 224    java/lang/StringBuilder

    //   164: dup

    //   165: ldc_w 312

    //   168: invokespecial 245    java/lang/StringBuilder:<init>    (Ljava/lang/String;)V

    //   171: aload_0

    //   172: getfield 115    fa:B    Ljava/net/Socket;

    //   175: invokevirtual 318    java/net/Socket:getInetAddress    ()Ljava/net/InetAddress;

    //   178: invokevirtual 321    java/lang/StringBuilder:append    (Ljava/lang/Object;)Ljava/lang/StringBuilder;

    //   181: ldc_w 323

    //   184: invokevirtual 251    java/lang/StringBuilder:append    (Ljava/lang/String;)Ljava/lang/StringBuilder;

    //   187: aload_0

    //   188: getfield 115    fa:B    Ljava/net/Socket;

    //   191: invokevirtual 326    java/net/Socket:getPort    ()I

    //   194: invokevirtual 285    java/lang/StringBuilder:append    (I)Ljava/lang/StringBuilder;

    //   197: invokevirtual 254    java/lang/StringBuilder:toString    ()Ljava/lang/String;

    //   200: invokestatic 215    gu:c    (Ljava/lang/String;)V

    //   203: aload_0

    //   204: ldc_w 327

    //   207: invokevirtual 329    fa:b    (I)V

    //   210: aload_0

    //   211: getfield 265    fa:C    Lfa$b;

    //   214: invokevirtual 331    fa$b:b    ()Z

    //   217: pop

    //   218: aload_0

    //   219: aconst_null

    //   220: putfield 90    fa:M    [B

    //   223: aload_0

    //   224: getfield 88    fa:L    Ljava/nio/ByteBuffer;

    //   227: invokevirtual 156    java/nio/ByteBuffer:clear    ()Ljava/nio/Buffer;

    //   230: pop

    //   231: aload_0

    //   232: getfield 276    fa:z    Ljava/nio/channels/SocketChannel;

    //   235: aload_0

    //   236: getfield 333    fa:A    Ljava/nio/channels/Selector;

    //   239: iconst_1

    //   240: invokevirtual 337    java/nio/channels/SocketChannel:register    (Ljava/nio/channels/Selector;I)Ljava/nio/channels/SelectionKey;

    //   243: pop

    //   244: aload_0

    //   245: monitorenter

    //   246: aload_0

    //   247: getfield 289    fa:G    Z

    //   250: ifeq +25 -> 275

    //   253: aload_0

    //   254: getfield 97    fa:H    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   257: iconst_0

    //   258: invokevirtual 295    java/util/concurrent/atomic/AtomicBoolean:set    (Z)V

    //   261: aload_0

    //   262: getfield 99    fa:I    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   265: iconst_0

    //   266: invokevirtual 295    java/util/concurrent/atomic/AtomicBoolean:set    (Z)V

    //   269: aload_0

    //   270: iconst_3

    //   271: aconst_null

    //   272: invokevirtual 298    fa:a    (ILey;)V

    //   275: aload_0

    //   276: monitorexit

    //   277: return

    //   278: astore 4

    //   280: aload_0

    //   281: monitorexit

    //   282: aload 4

    //   284: athrow

    //   285: astore 4

    //   287: aload_0

    //   288: aload 4

    //   290: invokespecial 339    fa:a    (Lez;)Z

    //   293: ifeq +18 -> 311

    //   296: aload_0

    //   297: iload_1

    //   298: iconst_1

    //   299: iadd

    //   300: invokespecial 341    fa:c    (I)V

    //   303: return

    //   304: astore 4

    //   306: aload_0

    //   307: monitorexit

    //   308: aload 4

    //   310: athrow

    //   311: aload_0

    //   312: aload 4

    //   314: invokevirtual 200    ez:a    ()Ley;

    //   317: invokevirtual 344    fa:a    (Ley;)V

    //   320: return

    //   321: astore 4

    //   323: invokestatic 345    gx:b    ()Z

    //   326: ifeq +11 -> 337

    //   329: aload_0

    //   330: iload_1

    //   331: iconst_1

    //   332: iadd

    //   333: invokespecial 341    fa:c    (I)V

    //   336: return

    //   337: aload_0

    //   338: invokevirtual 348    fa:i    ()V

    //   341: return

    //   342: astore 4

    //   344: goto -201 -> 143

    // Local variable table:

    //   start    length    slot    name    signature

    //   0    347    0    this    fa

    //   0    347    1    paramInt    int

    //   138    2    2    l    long

    //   84    13    4    localObject1    Object

    //   100    10    4    localObject2    Object

    //   278    5    4    localObject3    Object

    //   285    4    4    localez    ez

    //   304    9    4    localObject4    Object

    //   321    1    4    localException    Exception

    //   342    1    4    localInterruptedException    InterruptedException

    //   107    6    5    localObject5    Object

    // Exception table:

    //   from    to    target    type

    //   49    78    100    finally

    //   78    80    100    finally

    //   102    104    100    finally

    //   89    99    107    finally

    //   109    112    107    finally

    //   246    275    278    finally

    //   275    277    278    finally

    //   280    282    278    finally

    //   150    246    285    ez

    //   282    285    285    ez

    //   117    130    304    finally

    //   130    132    304    finally

    //   306    308    304    finally

    //   150    246    321    java/lang/Exception

    //   282    285    321    java/lang/Exception

    //   139    143    342    java/lang/InterruptedException

  }

  private void l()

  {

    System.setProperty("java.net.preferIPv4Stack", "true");

    System.setProperty("java.net.preferIPv6Addresses", "false");

    if (this.A != null) {}

    try

    {

      if (this.A.isOpen()) {

        this.A.close();

      }

      this.A = Selector.open();

      if (this.z != null) {}

      try

      {

        this.z.close();

        this.z = SocketChannel.open();

        de localde;

        if (this.G)

        {

          if (!gx.b()) {

            break label163;

          }

          localde = dd.a(gx.a(String.valueOf(this.h.c())));

          if (localde.e()) {

            a(localde.a().replace("http://", ""), localde.b());

          }

        }

        else

        {

          if (this.G) {

            break label185;

          }

          return;

        }

        this.i = null;

        throw new ez(new ey(3, localde.f()));

        label163:

        gu.d("No network connection. Please check and reconnect.");

        throw new ez(new ey(2));

        label185:

        this.z.connect(this.i);

        this.z.configureBlocking(false);

        this.B = this.z.socket();

        this.C = new fa.b(new BufferedOutputStream(this.B.getOutputStream()));

        this.C.start();

        return;

      }

      catch (Exception localException1)

      {

        for (;;) {}

      }

    }

    catch (Exception localException2)

    {

      for (;;) {}

    }

  }

  private void m()

  {

    if (gx.b())

    {

      try

      {

        if (!this.G) {

          return;

        }

        if (this.H.get()) {

          return;

        }

      }

      finally {}

      this.H.set(true);

      c(1);

      return;

    }

    a(new ey(2));

  }

  private void n()

  {

    gu.c("stop main network connection");

    f();

    if (this.C != null)

    {

      this.C.a();

      this.C = null;

    }

    if ((gx.l() >= 8) && (this.A != null)) {}

    try

    {

      this.A.close();

    }

    catch (Exception localException1)

    {

      for (;;)

      {

        gu.d("Error in closing socketSelector");

        localException1.printStackTrace();

        this.A = null;

      }

    }

    finally

    {

      this.A = null;

    }

    if (this.B != null) {}

    try

    {

      this.B.close();

    }

    catch (Exception localException2)

    {

      for (;;)

      {

        gu.d("Error in closing socket");

        localException2.printStackTrace();

        this.B = null;

      }

    }

    finally

    {

      this.B = null;

    }

    if (this.z != null) {}

    try

    {

      this.z.close();

      SelectionKey localSelectionKey = this.z.keyFor(this.A);

      if (localSelectionKey != null) {

        localSelectionKey.cancel();

      }

    }

    catch (Exception localException3)

    {

      for (;;)

      {

        gu.d("Error in closing socketChannel");

        localException3.printStackTrace();

        this.z = null;

      }

    }

    finally

    {

      this.z = null;

    }

    this.j.clear();

    a(0, null);

  }

  /* Error */

  public void a(ey arg1)

  {

    // Byte code:

    //   0: aload_0

    //   1: monitorenter

    //   2: aload_0

    //   3: getfield 289    fa:G    Z

    //   6: istore_2

    //   7: iload_2

    //   8: ifne +6 -> 14

    //   11: aload_0

    //   12: monitorexit

    //   13: return

    //   14: aload_0

    //   15: iconst_0

    //   16: putfield 289    fa:G    Z

    //   19: aload_0

    //   20: getfield 97    fa:H    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   23: iconst_0

    //   24: invokevirtual 295    java/util/concurrent/atomic/AtomicBoolean:set    (Z)V

    //   27: aload_0

    //   28: getfield 99    fa:I    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   31: iconst_0

    //   32: invokevirtual 295    java/util/concurrent/atomic/AtomicBoolean:set    (Z)V

    //   35: aload_0

    //   36: iconst_0

    //   37: aload_1

    //   38: invokevirtual 298    fa:a    (ILey;)V

    //   41: aload_0

    //   42: getfield 479    fa:D    Ljava/lang/Thread;

    //   45: ifnull +26 -> 71

    //   48: aload_0

    //   49: getfield 479    fa:D    Ljava/lang/Thread;

    //   52: invokevirtual 482    java/lang/Thread:interrupt    ()V

    //   55: aload_0

    //   56: getfield 78    fa:E    Ljava/lang/Object;

    //   59: astore_1

    //   60: aload_1

    //   61: monitorenter

    //   62: aload_0

    //   63: getfield 78    fa:E    Ljava/lang/Object;

    //   66: invokevirtual 301    java/lang/Object:notify    ()V

    //   69: aload_1

    //   70: monitorexit

    //   71: ldc_w 484

    //   74: invokestatic 215    gu:c    (Ljava/lang/String;)V

    //   77: goto -66 -> 11

    //   80: astore_1

    //   81: aload_0

    //   82: monitorexit

    //   83: aload_1

    //   84: athrow

    //   85: astore_3

    //   86: aload_1

    //   87: monitorexit

    //   88: aload_3

    //   89: athrow

    // Local variable table:

    //   start    length    slot    name    signature

    //   0    90    0    this    fa

    //   6    2    2    bool    boolean

    //   85    4    3    localObject    Object

    // Exception table:

    //   from    to    target    type

    //   2    7    80    finally

    //   14    62    80    finally

    //   71    77    80    finally

    //   88    90    80    finally

    //   62    71    85    finally

    //   86    88    85    finally

  }

  public void g()

  {

    try

    {

      if ((this.D != null) && (!this.D.isInterrupted())) {

        return;

      }

      if (this.H.get()) {

        return;

      }

    }

    finally {}

    this.H.set(true);

    synchronized (this.F)

    {

      Thread localThread = this.D;

      if (localThread != null) {}

      try

      {

        this.F.wait();

        this.D = null;

        try

        {

          this.I.set(false);

          a(2, null);

          this.G = true;

          this.D = new Thread(this);

          this.D.start();

          return;

        }

        finally {}

      }

      catch (InterruptedException localInterruptedException)

      {

        for (;;)

        {

          localInterruptedException.printStackTrace();

        }

      }

    }

  }

  /* Error */

  public void h()

  {

    // Byte code:

    //   0: aload_0

    //   1: monitorenter

    //   2: aload_0

    //   3: getfield 97    fa:H    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   6: invokevirtual 447    java/util/concurrent/atomic/AtomicBoolean:get    ()Z

    //   9: ifeq +6 -> 15

    //   12: aload_0

    //   13: monitorexit

    //   14: return

    //   15: aload_0

    //   16: getfield 479    fa:D    Ljava/lang/Thread;

    //   19: ifnull +17 -> 36

    //   22: aload_0

    //   23: getfield 479    fa:D    Ljava/lang/Thread;

    //   26: invokevirtual 488    java/lang/Thread:isInterrupted    ()Z

    //   29: ifne +7 -> 36

    //   32: aload_0

    //   33: invokevirtual 348    fa:i    ()V

    //   36: aload_0

    //   37: getfield 97    fa:H    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   40: iconst_1

    //   41: invokevirtual 295    java/util/concurrent/atomic/AtomicBoolean:set    (Z)V

    //   44: aload_0

    //   45: monitorexit

    //   46: aload_0

    //   47: getfield 80    fa:F    Ljava/lang/Object;

    //   50: astore_1

    //   51: aload_1

    //   52: monitorenter

    //   53: aload_0

    //   54: getfield 479    fa:D    Ljava/lang/Thread;

    //   57: astore_2

    //   58: aload_2

    //   59: ifnull +10 -> 69

    //   62: aload_0

    //   63: getfield 80    fa:F    Ljava/lang/Object;

    //   66: invokevirtual 491    java/lang/Object:wait    ()V

    //   69: aload_0

    //   70: aconst_null

    //   71: putfield 479    fa:D    Ljava/lang/Thread;

    //   74: aload_1

    //   75: monitorexit

    //   76: aload_0

    //   77: monitorenter

    //   78: aload_0

    //   79: getfield 99    fa:I    Ljava/util/concurrent/atomic/AtomicBoolean;

    //   82: iconst_0

    //   83: invokevirtual 295    java/util/concurrent/atomic/AtomicBoolean:set    (Z)V

    //   86: aload_0

    //   87: iconst_2

    //   88: aconst_null

    //   89: invokevirtual 298    fa:a    (ILey;)V

    //   92: aload_0

    //   93: iconst_1

    //   94: putfield 289    fa:G    Z

    //   97: aload_0

    //   98: new 303    java/lang/Thread

    //   101: dup

    //   102: aload_0

    //   103: invokespecial 494    java/lang/Thread:<init>    (Ljava/lang/Runnable;)V

    //   106: putfield 479    fa:D    Ljava/lang/Thread;

    //   109: aload_0

    //   110: getfield 479    fa:D    Ljava/lang/Thread;

    //   113: invokevirtual 495    java/lang/Thread:start    ()V

    //   116: ldc_w 498

    //   119: invokestatic 215    gu:c    (Ljava/lang/String;)V

    //   122: aload_0

    //   123: monitorexit

    //   124: return

    //   125: astore_1

    //   126: aload_0

    //   127: monitorexit

    //   128: aload_1

    //   129: athrow

    //   130: astore_1

    //   131: aload_0

    //   132: monitorexit

    //   133: aload_1

    //   134: athrow

    //   135: astore_2

    //   136: aload_2

    //   137: invokevirtual 496    java/lang/InterruptedException:printStackTrace    ()V

    //   140: goto -71 -> 69

    //   143: astore_2

    //   144: aload_1

    //   145: monitorexit

    //   146: aload_2

    //   147: athrow

    // Local variable table:

    //   start    length    slot    name    signature

    //   0    148    0    this    fa

    //   125    4    1    localObject2    Object

    //   130    15    1    localObject3    Object

    //   57    2    2    localThread    Thread

    //   135    2    2    localInterruptedException    InterruptedException

    //   143    4    2    localObject4    Object

    // Exception table:

    //   from    to    target    type

    //   78    124    125    finally

    //   126    128    125    finally

    //   2    14    130    finally

    //   15    36    130    finally

    //   36    46    130    finally

    //   131    133    130    finally

    //   62    69    135    java/lang/InterruptedException

    //   53    58    143    finally

    //   62    69    143    finally

    //   69    76    143    finally

    //   136    140    143    finally

    //   144    146    143    finally

  }

  public void i()

  {

    try

    {

      a(null);

      return;

    }

    finally

    {

      localObject = finally;

      throw ((Throwable)localObject);

    }

  }

  protected void j()

  {

    gu.c("Heart beat timeout. Close and reconnect.");

    gu.f("Push connection heart beat timeout");

    if (this.G) {

      m();

    }

  }

  public boolean k()

  {

    boolean bool = false;

    for (;;)

    {

      try

      {

        int i = this.e;

        if (i != 3) {

          return bool;

        }

        if (this.k != 0L)

        {

          if (System.currentTimeMillis() - this.k > 600000L) {

            j();

          }

        }

        else {

          this.k = System.currentTimeMillis();