package com.l7tech.server.log.syslog.impl;

import com.l7tech.server.log.syslog.SyslogConfig;
import com.l7tech.server.log.syslog.SyslogConnectionListener;
import com.l7tech.util.Functions.BinaryVoid;
import com.l7tech.util.Functions.Unary;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.channels.UnresolvedAddressException;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import java.util.logging.Level;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.future.IoFuture;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

class b implements Runnable {
   private static final long a = 15L;
   private static final long b = 1000L;
   private static final int c = 1;
   private final boolean d;
   private int e;
   private final Object f;
   private d g;
   private SyslogConfig h;
   private IoConnector i;
   private g j;
   private final AtomicBoolean k;
   private final AtomicBoolean l;
   private final AtomicInteger m;
   private final AtomicReference<IoSession> n;
   private final AtomicReference<SyslogConnectionListener> o;
   private final boolean p;
   private final BlockingQueue<f> q;
   private int r;
   private String s;
   private static final String[] t;

   b(SyslogConfig param1, BlockingQueue<f> param2) {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 000: aload 0
      // 001: invokespecial java/lang/Object.<init> ()V
      // 004: aload 0
      // 005: new java/lang/Object
      // 008: dup
      // 009: invokespecial java/lang/Object.<init> ()V
      // 00c: putfield com/l7tech/server/log/syslog/impl/b.f Ljava/lang/Object;
      // 00f: aload 0
      // 010: new java/util/concurrent/atomic/AtomicBoolean
      // 013: dup
      // 014: bipush 1
      // 015: invokespecial java/util/concurrent/atomic/AtomicBoolean.<init> (Z)V
      // 018: putfield com/l7tech/server/log/syslog/impl/b.k Ljava/util/concurrent/atomic/AtomicBoolean;
      // 01b: aload 0
      // 01c: new java/util/concurrent/atomic/AtomicBoolean
      // 01f: dup
      // 020: bipush 1
      // 021: invokespecial java/util/concurrent/atomic/AtomicBoolean.<init> (Z)V
      // 024: putfield com/l7tech/server/log/syslog/impl/b.l Ljava/util/concurrent/atomic/AtomicBoolean;
      // 027: aload 0
      // 028: new java/util/concurrent/atomic/AtomicReference
      // 02b: dup
      // 02c: invokespecial java/util/concurrent/atomic/AtomicReference.<init> ()V
      // 02f: putfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 032: aload 0
      // 033: new java/util/concurrent/atomic/AtomicReference
      // 036: dup
      // 037: invokespecial java/util/concurrent/atomic/AtomicReference.<init> ()V
      // 03a: putfield com/l7tech/server/log/syslog/impl/b.o Ljava/util/concurrent/atomic/AtomicReference;
      // 03d: aload 0
      // 03e: aload 1
      // 03f: putfield com/l7tech/server/log/syslog/impl/b.h Lcom/l7tech/server/log/syslog/SyslogConfig;
      // 042: aload 0
      // 043: aload 2
      // 044: putfield com/l7tech/server/log/syslog/impl/b.q Ljava/util/concurrent/BlockingQueue;
      // 047: aload 0
      // 048: aload 1
      // 049: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getSyslogAddresses ()[Ljava/net/SocketAddress;
      // 04c: arraylength
      // 04d: bipush 1
      // 04e: if_icmple 055
      // 051: bipush 1
      // 052: goto 056
      // 055: bipush 0
      // 056: putfield com/l7tech/server/log/syslog/impl/b.d Z
      // 059: aload 0
      // 05a: aload 1
      // 05b: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.isSSL ()Z
      // 05e: putfield com/l7tech/server/log/syslog/impl/b.p Z
      // 061: aload 0
      // 062: new java/util/concurrent/atomic/AtomicInteger
      // 065: dup
      // 066: aload 1
      // 067: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getMaxReconnectAttempts ()I
      // 06a: bipush 1
      // 06b: iadd
      // 06c: invokespecial java/util/concurrent/atomic/AtomicInteger.<init> (I)V
      // 06f: putfield com/l7tech/server/log/syslog/impl/b.m Ljava/util/concurrent/atomic/AtomicInteger;
      // 072: aload 0
      // 073: invokevirtual com/l7tech/server/log/syslog/impl/b.p ()Lcom/l7tech/util/Functions$BinaryVoid;
      // 076: astore 3
      // 077: aload 0
      // 078: getfield com/l7tech/server/log/syslog/impl/b.p Z
      // 07b: ifeq 0e8
      // 07e: invokestatic com/l7tech/server/log/syslog/impl/SyslogSslClientSupport.isInitialized ()Z
      // 081: ifeq 183
      // 084: goto 08b
      // 087: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 08a: athrow
      // 08b: aload 0
      // 08c: new com/l7tech/server/log/syslog/impl/MinaSecureSyslogHandler
      // 08f: dup
      // 090: aload 3
      // 091: aload 0
      // 092: invokevirtual com/l7tech/server/log/syslog/impl/b.q ()Lcom/l7tech/util/Functions$Unary;
      // 095: aload 1
      // 096: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getSslKeystoreAlias ()Ljava/lang/String;
      // 099: aload 1
      // 09a: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getSslKeystoreId ()Lcom/l7tech/objectmodel/Goid;
      // 09d: aload 0
      // 09e: invokedynamic run (Lcom/l7tech/server/log/syslog/impl/b;)Ljava/lang/Runnable; bsm=java/lang/invoke/LambdaMetafactory.metafactory (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite; args=[ ()V, com/l7tech/server/log/syslog/impl/b.d ()V, ()V ]
      // 0a3: aload 1
      // 0a4: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.isValidateExtendedKeyUsage ()Z
      // 0a7: invokespecial com/l7tech/server/log/syslog/impl/MinaSecureSyslogHandler.<init> (Lcom/l7tech/util/Functions$BinaryVoid;Lcom/l7tech/util/Functions$Unary;Ljava/lang/String;Lcom/l7tech/objectmodel/Goid;Ljava/lang/Runnable;Z)V
      // 0aa: putfield com/l7tech/server/log/syslog/impl/b.j Lcom/l7tech/server/log/syslog/impl/g;
      // 0ad: aload 0
      // 0ae: new org/apache/mina/transport/socket/nio/NioSocketConnector
      // 0b1: dup
      // 0b2: invokespecial org/apache/mina/transport/socket/nio/NioSocketConnector.<init> ()V
      // 0b5: putfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 0b8: aload 0
      // 0b9: getfield com/l7tech/server/log/syslog/impl/b.j Lcom/l7tech/server/log/syslog/impl/g;
      // 0bc: checkcast com/l7tech/server/log/syslog/impl/MinaSecureSyslogHandler
      // 0bf: aload 0
      // 0c0: getfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 0c3: invokevirtual com/l7tech/server/log/syslog/impl/MinaSecureSyslogHandler.setupConnectorForSSL (Lorg/apache/mina/core/service/IoConnector;)V
      // 0c6: aload 0
      // 0c7: getfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 0ca: aload 0
      // 0cb: getfield com/l7tech/server/log/syslog/impl/b.j Lcom/l7tech/server/log/syslog/impl/g;
      // 0ce: invokeinterface org/apache/mina/core/service/IoConnector.setHandler (Lorg/apache/mina/core/service/IoHandler;)V 2
      // 0d3: aload 0
      // 0d4: getfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 0d7: aload 1
      // 0d8: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getConnectTimeOut ()I
      // 0db: i2l
      // 0dc: invokeinterface org/apache/mina/core/service/IoConnector.setConnectTimeoutMillis (J)V 3
      // 0e1: goto 183
      // 0e4: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0e7: athrow
      // 0e8: aload 0
      // 0e9: new com/l7tech/server/log/syslog/impl/g
      // 0ec: dup
      // 0ed: aload 3
      // 0ee: invokespecial com/l7tech/server/log/syslog/impl/g.<init> (Lcom/l7tech/util/Functions$BinaryVoid;)V
      // 0f1: putfield com/l7tech/server/log/syslog/impl/b.j Lcom/l7tech/server/log/syslog/impl/g;
      // 0f4: getstatic com/l7tech/server/log/syslog/impl/a.a [I
      // 0f7: aload 1
      // 0f8: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getProtocol ()Lcom/l7tech/server/log/syslog/SyslogProtocol;
      // 0fb: invokevirtual com/l7tech/server/log/syslog/SyslogProtocol.ordinal ()I
      // 0fe: iaload
      // 0ff: tableswitch 78 1 4 29 47 50 64
      // 11c: aload 0
      // 11d: new org/apache/mina/transport/socket/nio/NioSocketConnector
      // 120: dup
      // 121: invokespecial org/apache/mina/transport/socket/nio/NioSocketConnector.<init> ()V
      // 124: putfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 127: goto 168
      // 12a: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 12d: athrow
      // 12e: goto 168
      // 131: aload 0
      // 132: new org/apache/mina/transport/socket/nio/NioDatagramConnector
      // 135: dup
      // 136: invokespecial org/apache/mina/transport/socket/nio/NioDatagramConnector.<init> ()V
      // 139: putfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 13c: goto 168
      // 13f: aload 0
      // 140: new org/apache/mina/transport/vmpipe/VmPipeConnector
      // 143: dup
      // 144: invokespecial org/apache/mina/transport/vmpipe/VmPipeConnector.<init> ()V
      // 147: putfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 14a: goto 168
      // 14d: new java/lang/IllegalArgumentException
      // 150: dup
      // 151: aload 1
      // 152: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getProtocol ()Lcom/l7tech/server/log/syslog/SyslogProtocol;
      // 155: invokestatic java/lang/String.valueOf (Ljava/lang/Object;)Ljava/lang/String;
      // 158: getstatic com/l7tech/server/log/syslog/impl/b.t [Ljava/lang/String;
      // 15b: bipush 14
      // 15d: aaload
      // 15e: swap
      // 15f: invokedynamic makeConcatWithConstants (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; bsm=java/lang/invoke/StringConcatFactory.makeConcatWithConstants (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; args=[ "\u0001\u0001" ]
      // 164: invokespecial java/lang/IllegalArgumentException.<init> (Ljava/lang/String;)V
      // 167: athrow
      // 168: aload 0
      // 169: getfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 16c: aload 0
      // 16d: getfield com/l7tech/server/log/syslog/impl/b.j Lcom/l7tech/server/log/syslog/impl/g;
      // 170: invokeinterface org/apache/mina/core/service/IoConnector.setHandler (Lorg/apache/mina/core/service/IoHandler;)V 2
      // 175: aload 0
      // 176: getfield com/l7tech/server/log/syslog/impl/b.i Lorg/apache/mina/core/service/IoConnector;
      // 179: aload 1
      // 17a: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getConnectTimeOut ()I
      // 17d: i2l
      // 17e: invokeinterface org/apache/mina/core/service/IoConnector.setConnectTimeoutMillis (J)V 3
      // 183: return
      // try (61 -> 66): 67 java/lang/IllegalArgumentException
      // try (64 -> 108): 108 java/lang/IllegalArgumentException
      // try (110 -> 128): 128 java/lang/IllegalArgumentException
   }

   @Override
   public void run() {
      this.h();
   }

   @Override
   public String toString() {
      try {
         if (this.s == null) {
            this.s = t[4] + this.h.getProtocol().name() + "-" + this.n();
         }
      } catch (IllegalArgumentException var1) {
         throw a(var1);
      }

      return this.s;
   }

   private void a(SyslogConnectionListener var1) {
      this.o.set(var1);
   }

   private void a() {
      this.k.set(false);
   }

   boolean b() {
      return this.k.get();
   }

   private void a(IoSession param1, String param2) {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 00: aload 1
      // 01: ifnonnull 37
      // 04: aload 0
      // 05: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 08: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 0b: ifnull 37
      // 0e: goto 15
      // 11: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 14: athrow
      // 15: aload 2
      // 16: aload 0
      // 17: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 1a: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 1d: checkcast org/apache/mina/core/session/IoSession
      // 20: invokeinterface org/apache/mina/core/session/IoSession.toString ()Ljava/lang/String; 1
      // 25: invokevirtual java/lang/String.equals (Ljava/lang/Object;)Z
      // 28: ifne 37
      // 2b: goto 32
      // 2e: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 31: athrow
      // 32: return
      // 33: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 36: athrow
      // 37: aload 1
      // 38: ifnonnull 6b
      // 3b: aload 0
      // 3c: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 3f: aconst_null
      // 40: invokevirtual java/util/concurrent/atomic/AtomicReference.set (Ljava/lang/Object;)V
      // 43: aload 0
      // 44: invokevirtual com/l7tech/server/log/syslog/impl/b.m ()V
      // 47: aload 0
      // 48: getfield com/l7tech/server/log/syslog/impl/b.h Lcom/l7tech/server/log/syslog/SyslogConfig;
      // 4b: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getReconnectInterval ()I
      // 4e: i2l
      // 4f: invokestatic java/lang/Thread.sleep (J)V
      // 52: aload 0
      // 53: getfield com/l7tech/server/log/syslog/impl/b.l Ljava/util/concurrent/atomic/AtomicBoolean;
      // 56: bipush 1
      // 57: invokevirtual java/util/concurrent/atomic/AtomicBoolean.set (Z)V
      // 5a: goto 90
      // 5d: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 60: athrow
      // 61: astore 3
      // 62: invokestatic java/lang/Thread.currentThread ()Ljava/lang/Thread;
      // 65: invokevirtual java/lang/Thread.interrupt ()V
      // 68: goto 90
      // 6b: aload 0
      // 6c: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 6f: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 72: ifnull 84
      // 75: aload 0
      // 76: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 79: aload 1
      // 7a: invokevirtual java/util/concurrent/atomic/AtomicReference.set (Ljava/lang/Object;)V
      // 7d: goto 90
      // 80: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 83: athrow
      // 84: aload 0
      // 85: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 88: aload 1
      // 89: invokevirtual java/util/concurrent/atomic/AtomicReference.set (Ljava/lang/Object;)V
      // 8c: aload 0
      // 8d: invokevirtual com/l7tech/server/log/syslog/impl/b.l ()V
      // 90: return
      // try (9 -> 21): 21 java/lang/InterruptedException
      // try (2 -> 17): 18 java/lang/InterruptedException
      // try (0 -> 6): 7 java/lang/InterruptedException
      // try (31 -> 40): 43 java/lang/InterruptedException
      // try (23 -> 41): 41 java/lang/IllegalArgumentException
      // try (47 -> 56): 56 java/lang/InterruptedException
   }

   private void c() {
      this.e = 0;
   }

   private void d() {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 00: aload 0
      // 01: getfield com/l7tech/server/log/syslog/impl/b.d Z
      // 04: ifeq 33
      // 07: aload 0
      // 08: getfield com/l7tech/server/log/syslog/impl/b.m Ljava/util/concurrent/atomic/AtomicInteger;
      // 0b: invokevirtual java/util/concurrent/atomic/AtomicInteger.get ()I
      // 0e: ifgt 33
      // 11: goto 18
      // 14: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 17: athrow
      // 18: aload 0
      // 19: invokevirtual com/l7tech/server/log/syslog/impl/b.e ()V
      // 1c: aload 0
      // 1d: getfield com/l7tech/server/log/syslog/impl/b.m Ljava/util/concurrent/atomic/AtomicInteger;
      // 20: aload 0
      // 21: getfield com/l7tech/server/log/syslog/impl/b.h Lcom/l7tech/server/log/syslog/SyslogConfig;
      // 24: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getMaxReconnectAttempts ()I
      // 27: bipush 1
      // 28: iadd
      // 29: invokevirtual java/util/concurrent/atomic/AtomicInteger.set (I)V
      // 2c: goto 3e
      // 2f: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 32: athrow
      // 33: aload 0
      // 34: getfield com/l7tech/server/log/syslog/impl/b.h Lcom/l7tech/server/log/syslog/SyslogConfig;
      // 37: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getReconnectInterval ()I
      // 3a: i2l
      // 3b: invokestatic java/lang/Thread.sleep (J)V
      // 3e: aload 0
      // 3f: getfield com/l7tech/server/log/syslog/impl/b.l Ljava/util/concurrent/atomic/AtomicBoolean;
      // 42: bipush 1
      // 43: invokevirtual java/util/concurrent/atomic/AtomicBoolean.set (Z)V
      // 46: aload 0
      // 47: invokevirtual com/l7tech/server/log/syslog/impl/b.o ()V
      // 4a: goto 54
      // 4d: astore 1
      // 4e: invokestatic java/lang/Thread.currentThread ()Ljava/lang/Thread;
      // 51: invokevirtual java/lang/Thread.interrupt ()V
      // 54: return
      // try (3 -> 21): 21 java/lang/InterruptedException
      // try (0 -> 7): 8 java/lang/InterruptedException
      // try (0 -> 34): 35 java/lang/InterruptedException
   }

   private void e() {
      try {
         if (this.e > this.h.getSyslogAddresses().length) {
            MinaManagedSyslog.d.log(Level.WARNING, t[2]);
         }
      } catch (IllegalArgumentException var5) {
         throw a(var5);
      }

      String var1 = this.toString();
      synchronized (this.f) {
         this.s = null;
         this.e++;
         this.r = (this.r + 1) % this.h.getSyslogAddresses().length;
         MinaManagedSyslog.d.log(Level.WARNING, t[8], new Object[]{var1, this.toString()});
      }
   }

   void f() {
      this.l.set(false);
      this.i.setConnectTimeoutMillis(this.h.getConnectTimeOut());

      try {
         String var1 = this.toString();
         ConnectFuture var2 = this.i.connect(this.n());
         var2.addListener(this::lambda$connect$0);
      } catch (UnresolvedAddressException var3) {
         this.m();
         this.d();
      }
   }

   private void g() {
      try {
         if (this.n.get() != null) {
            this.n.get().closeNow();
         }
      } catch (UnresolvedAddressException var7) {
         throw a(var7);
      }

      label49: {
         try {
            if (this.i != null) {
               break label49;
            }

            if (!SyslogSslClientSupport.isInitialized()) {
               return;
            }
         } catch (UnresolvedAddressException var10) {
            throw a(var10);
         }

         MinaSecureSyslogHandler var1 = new MinaSecureSyslogHandler(
            this.p(), this.q(), this.h.getSslKeystoreAlias(), this.h.getSslKeystoreId(), this::d, this.h.isValidateExtendedKeyUsage()
         );
         this.j = var1;
         this.i = new NioSocketConnector();
         var1.setupConnectorForSSL(this.i);
         this.i.setHandler(this.j);
         this.i.setConnectTimeoutMillis(this.h.getConnectTimeOut());
      }

      this.l.set(false);

      try {
         long var11 = System.currentTimeMillis();
         ConnectFuture var3 = this.i.connect(this.n()).addListener(this::lambda$connectSSL$1);

         try {
            var3.awaitUninterruptibly(1000L);
            if (!MinaManagedSyslog.d.isLoggable(Level.FINE) || !var3.isDone()) {
               return;
            }
         } catch (UnresolvedAddressException var8) {
            throw a(var8);
         }

         String[] var6 = t;
         StringBuilder var4 = new StringBuilder(var6[9]);
         var4.append(System.currentTimeMillis() - var11).append("\n");
         IoSession var5 = var3.getSession();
         var4.append(var6[15]).append(var5.getCreationTime()).append("\n");
         var4.append(var6[5]).append(var5.isConnected()).append("\n");
         var4.append(var6[1]).append(var5.isClosing()).append("\n");
         var4.append(var6[10]).append(var5.getTransportMetadata().getName()).append("\n");
         var4.append(var6[6]).append(((MinaSecureSyslogHandler)this.j).a(var5)).append("\n");
         var4.append(var6[16]).append(this.n()).append("\n");
         var4.append(var6[3]).append(this.a(this.n()));
         MinaManagedSyslog.d.fine(var4.toString());
      } catch (UnresolvedAddressException var9) {
         this.m();
         this.d();
      }
   }

   private Set<IoSession> a(SocketAddress var1) {
      Map var2 = this.i.getManagedSessions();
      HashSet var3 = new HashSet();

      for (IoSession var5 : var2.values()) {
         try {
            if (var5.getRemoteAddress().equals(var1)) {
               var3.add(var5);
            }
         } catch (IllegalArgumentException var6) {
            throw a(var6);
         }
      }

      return var3;
   }

   private void h() {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 000: bipush 1
      // 001: istore 1
      // 002: aload 0
      // 003: getfield com/l7tech/server/log/syslog/impl/b.k Ljava/util/concurrent/atomic/AtomicBoolean;
      // 006: invokevirtual java/util/concurrent/atomic/AtomicBoolean.get ()Z
      // 009: ifeq 0fa
      // 00c: aload 0
      // 00d: getfield com/l7tech/server/log/syslog/impl/b.l Ljava/util/concurrent/atomic/AtomicBoolean;
      // 010: invokevirtual java/util/concurrent/atomic/AtomicBoolean.get ()Z
      // 013: ifeq 03d
      // 016: aload 0
      // 017: getfield com/l7tech/server/log/syslog/impl/b.m Ljava/util/concurrent/atomic/AtomicInteger;
      // 01a: invokevirtual java/util/concurrent/atomic/AtomicInteger.decrementAndGet ()I
      // 01d: pop
      // 01e: aload 0
      // 01f: getfield com/l7tech/server/log/syslog/impl/b.p Z
      // 022: ifeq 037
      // 025: goto 02c
      // 028: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 02b: athrow
      // 02c: aload 0
      // 02d: invokevirtual com/l7tech/server/log/syslog/impl/b.g ()V
      // 030: goto 03b
      // 033: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 036: athrow
      // 037: aload 0
      // 038: invokevirtual com/l7tech/server/log/syslog/impl/b.f ()V
      // 03b: bipush 1
      // 03c: istore 1
      // 03d: aload 0
      // 03e: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 041: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 044: checkcast org/apache/mina/core/session/IoSession
      // 047: astore 2
      // 048: aload 0
      // 049: invokevirtual com/l7tech/server/log/syslog/impl/b.j ()Z
      // 04c: ifeq 0b4
      // 04f: aload 0
      // 050: aload 2
      // 051: invokevirtual com/l7tech/server/log/syslog/impl/b.a (Lorg/apache/mina/core/session/IoSession;)Z
      // 054: ifeq 0b4
      // 057: goto 05e
      // 05a: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 05d: athrow
      // 05e: aload 0
      // 05f: invokevirtual com/l7tech/server/log/syslog/impl/b.k ()Lcom/l7tech/server/log/syslog/impl/d;
      // 062: astore 3
      // 063: aload 3
      // 064: ifnull 0b1
      // 067: aload 2
      // 068: aload 3
      // 069: invokeinterface org/apache/mina/core/session/IoSession.write (Ljava/lang/Object;)Lorg/apache/mina/core/future/WriteFuture; 2
      // 06e: astore 4
      // 070: aload 0
      // 071: getfield com/l7tech/server/log/syslog/impl/b.p Z
      // 074: ifeq 0af
      // 077: iload 1
      // 078: ifeq 0af
      // 07b: goto 082
      // 07e: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 081: athrow
      // 082: aload 4
      // 084: ldc2_w 1000
      // 087: invokeinterface org/apache/mina/core/future/WriteFuture.awaitUninterruptibly (J)Z 3
      // 08c: pop
      // 08d: aload 4
      // 08f: invokeinterface org/apache/mina/core/future/WriteFuture.isWritten ()Z 1
      // 094: ifeq 0a3
      // 097: goto 09e
      // 09a: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 09d: athrow
      // 09e: bipush 0
      // 09f: istore 1
      // 0a0: goto 0b1
      // 0a3: aload 0
      // 0a4: aload 3
      // 0a5: putfield com/l7tech/server/log/syslog/impl/b.g Lcom/l7tech/server/log/syslog/impl/d;
      // 0a8: aload 0
      // 0a9: invokevirtual com/l7tech/server/log/syslog/impl/b.d ()V
      // 0ac: goto 0b1
      // 0af: bipush 0
      // 0b0: istore 1
      // 0b1: goto 0ba
      // 0b4: ldc2_w 15
      // 0b7: invokestatic java/lang/Thread.sleep (J)V
      // 0ba: goto 002
      // 0bd: astore 2
      // 0be: aload 0
      // 0bf: getfield com/l7tech/server/log/syslog/impl/b.k Ljava/util/concurrent/atomic/AtomicBoolean;
      // 0c2: bipush 0
      // 0c3: invokevirtual java/util/concurrent/atomic/AtomicBoolean.set (Z)V
      // 0c6: goto 0fa
      // 0c9: astore 2
      // 0ca: getstatic com/l7tech/server/log/syslog/impl/MinaManagedSyslog.d Ljava/util/logging/Logger;
      // 0cd: getstatic java/util/logging/Level.WARNING Ljava/util/logging/Level;
      // 0d0: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 0d3: ifeq 0f7
      // 0d6: getstatic com/l7tech/server/log/syslog/impl/MinaManagedSyslog.d Ljava/util/logging/Logger;
      // 0d9: getstatic java/util/logging/Level.WARNING Ljava/util/logging/Level;
      // 0dc: aload 0
      // 0dd: invokestatic java/lang/String.valueOf (Ljava/lang/Object;)Ljava/lang/String;
      // 0e0: getstatic com/l7tech/server/log/syslog/impl/b.t [Ljava/lang/String;
      // 0e3: bipush 13
      // 0e5: aaload
      // 0e6: swap
      // 0e7: invokedynamic makeConcatWithConstants (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; bsm=java/lang/invoke/StringConcatFactory.makeConcatWithConstants (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; args=[ "\u0001\u0001" ]
      // 0ec: aload 2
      // 0ed: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
      // 0f0: goto 0f7
      // 0f3: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0f6: athrow
      // 0f7: goto 002
      // 0fa: aload 0
      // 0fb: getfield com/l7tech/server/log/syslog/impl/b.k Ljava/util/concurrent/atomic/AtomicBoolean;
      // 0fe: invokevirtual java/util/concurrent/atomic/AtomicBoolean.get ()Z
      // 101: ifeq 133
      // 104: getstatic com/l7tech/server/log/syslog/impl/MinaManagedSyslog.d Ljava/util/logging/Logger;
      // 107: getstatic java/util/logging/Level.WARNING Ljava/util/logging/Level;
      // 10a: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 10d: ifeq 1b4
      // 110: goto 117
      // 113: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 116: athrow
      // 117: getstatic com/l7tech/server/log/syslog/impl/MinaManagedSyslog.d Ljava/util/logging/Logger;
      // 11a: aload 0
      // 11b: invokestatic java/lang/String.valueOf (Ljava/lang/Object;)Ljava/lang/String;
      // 11e: getstatic com/l7tech/server/log/syslog/impl/b.t [Ljava/lang/String;
      // 121: bipush 0
      // 122: aaload
      // 123: swap
      // 124: invokedynamic makeConcatWithConstants (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; bsm=java/lang/invoke/StringConcatFactory.makeConcatWithConstants (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; args=[ "\u0001\u0001" ]
      // 129: invokevirtual java/util/logging/Logger.warning (Ljava/lang/String;)V
      // 12c: goto 1b4
      // 12f: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 132: athrow
      // 133: aload 0
      // 134: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 137: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 13a: ifnull 1b4
      // 13d: aload 0
      // 13e: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 141: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 144: checkcast org/apache/mina/core/session/IoSession
      // 147: invokeinterface org/apache/mina/core/session/IoSession.closeNow ()Lorg/apache/mina/core/future/CloseFuture; 1
      // 14c: pop
      // 14d: goto 1b4
      // 150: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 153: athrow
      // 154: astore 5
      // 156: aload 0
      // 157: getfield com/l7tech/server/log/syslog/impl/b.k Ljava/util/concurrent/atomic/AtomicBoolean;
      // 15a: invokevirtual java/util/concurrent/atomic/AtomicBoolean.get ()Z
      // 15d: ifeq 190
      // 160: getstatic com/l7tech/server/log/syslog/impl/MinaManagedSyslog.d Ljava/util/logging/Logger;
      // 163: getstatic java/util/logging/Level.WARNING Ljava/util/logging/Level;
      // 166: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 169: ifeq 1b1
      // 16c: goto 173
      // 16f: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 172: athrow
      // 173: getstatic com/l7tech/server/log/syslog/impl/MinaManagedSyslog.d Ljava/util/logging/Logger;
      // 176: aload 0
      // 177: invokestatic java/lang/String.valueOf (Ljava/lang/Object;)Ljava/lang/String;
      // 17a: getstatic com/l7tech/server/log/syslog/impl/b.t [Ljava/lang/String;
      // 17d: bipush 7
      // 17f: aaload
      // 180: swap
      // 181: invokedynamic makeConcatWithConstants (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; bsm=java/lang/invoke/StringConcatFactory.makeConcatWithConstants (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; args=[ "\u0001\u0001" ]
      // 186: invokevirtual java/util/logging/Logger.warning (Ljava/lang/String;)V
      // 189: goto 1b1
      // 18c: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 18f: athrow
      // 190: aload 0
      // 191: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 194: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 197: ifnull 1b1
      // 19a: aload 0
      // 19b: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 19e: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 1a1: checkcast org/apache/mina/core/session/IoSession
      // 1a4: invokeinterface org/apache/mina/core/session/IoSession.closeNow ()Lorg/apache/mina/core/future/CloseFuture; 1
      // 1a9: pop
      // 1aa: goto 1b1
      // 1ad: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 1b0: athrow
      // 1b1: aload 5
      // 1b3: athrow
      // 1b4: return
      // try (56 -> 68): 69 java/lang/InterruptedException
      // try (53 -> 58): 59 java/lang/InterruptedException
      // try (34 -> 41): 42 java/lang/InterruptedException
      // try (10 -> 23): 23 java/lang/InterruptedException
      // try (6 -> 17): 18 java/lang/InterruptedException
      // try (6 -> 85): 86 java/lang/InterruptedException
      // try (6 -> 85): 92 java/lang/Exception
      // try (93 -> 108): 109 java/lang/InterruptedException
      // try (0 -> 112): 148 null
      // try (135 -> 146): 146 java/lang/InterruptedException
      // try (116 -> 133): 133 java/lang/InterruptedException
      // try (112 -> 120): 121 java/lang/InterruptedException
      // try (148 -> 149): 148 null
      // try (149 -> 157): 158 java/lang/InterruptedException
      // try (153 -> 170): 170 java/lang/InterruptedException
      // try (172 -> 182): 183 java/lang/InterruptedException
   }

   boolean i() {
      return this.l.get();
   }

   private boolean a(IoSession param1) {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 00: aload 1
      // 01: ifnull 3c
      // 04: aload 1
      // 05: invokeinterface org/apache/mina/core/session/IoSession.isConnected ()Z 1
      // 0a: ifeq 3c
      // 0d: goto 14
      // 10: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 13: athrow
      // 14: aload 1
      // 15: invokeinterface org/apache/mina/core/session/IoSession.isClosing ()Z 1
      // 1a: ifne 3c
      // 1d: goto 24
      // 20: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 23: athrow
      // 24: aload 1
      // 25: invokeinterface org/apache/mina/core/session/IoSession.isActive ()Z 1
      // 2a: ifeq 3c
      // 2d: goto 34
      // 30: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 33: athrow
      // 34: bipush 1
      // 35: goto 3d
      // 38: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 3b: athrow
      // 3c: bipush 0
      // 3d: ireturn
      // try (0 -> 5): 6 java/lang/IllegalArgumentException
      // try (2 -> 11): 12 java/lang/IllegalArgumentException
      // try (8 -> 17): 18 java/lang/IllegalArgumentException
      // try (14 -> 22): 22 java/lang/IllegalArgumentException
   }

   private boolean j() {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 00: aload 0
      // 01: getfield com/l7tech/server/log/syslog/impl/b.q Ljava/util/concurrent/BlockingQueue;
      // 04: invokeinterface java/util/concurrent/BlockingQueue.isEmpty ()Z 1
      // 09: ifeq 1a
      // 0c: aload 0
      // 0d: getfield com/l7tech/server/log/syslog/impl/b.g Lcom/l7tech/server/log/syslog/impl/d;
      // 10: ifnull 22
      // 13: goto 1a
      // 16: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 19: athrow
      // 1a: bipush 1
      // 1b: goto 23
      // 1e: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 21: athrow
      // 22: bipush 0
      // 23: ireturn
      // try (0 -> 7): 8 java/lang/IllegalArgumentException
      // try (4 -> 12): 12 java/lang/IllegalArgumentException
   }

   private d k() throws InterruptedException {
      if (this.g != null) {
         d var3 = this.g;
         this.g = null;
         return var3;
      } else {
         f var1 = this.q.poll(100L, TimeUnit.MILLISECONDS);
         if (var1 != null) {
            String var2 = MinaManagedSyslog.access$000(
               var1.a(),
               var1.getFacility(),
               var1.getSeverity(),
               var1.getPriority(),
               var1.getHost(),
               var1.getProcess(),
               var1.getThreadId(),
               var1.getTime(),
               var1.getMessage()
            );
            return new d(var1.a().getCharset(), var1.a().getDelimiter(), var1.a().getMaxLength(), var2);
         } else {
            return null;
         }
      }
   }

   private void l() {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 00: aload 0
      // 01: getfield com/l7tech/server/log/syslog/impl/b.o Ljava/util/concurrent/atomic/AtomicReference;
      // 04: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 07: checkcast com/l7tech/server/log/syslog/SyslogConnectionListener
      // 0a: astore 1
      // 0b: aload 1
      // 0c: ifnull 34
      // 0f: getstatic com/l7tech/server/log/syslog/SyslogProtocol.UDP Lcom/l7tech/server/log/syslog/SyslogProtocol;
      // 12: aload 0
      // 13: getfield com/l7tech/server/log/syslog/impl/b.h Lcom/l7tech/server/log/syslog/SyslogConfig;
      // 16: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getProtocol ()Lcom/l7tech/server/log/syslog/SyslogProtocol;
      // 19: if_acmpeq 34
      // 1c: goto 23
      // 1f: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 22: athrow
      // 23: aload 1
      // 24: aload 0
      // 25: invokevirtual com/l7tech/server/log/syslog/impl/b.n ()Ljava/net/SocketAddress;
      // 28: invokeinterface com/l7tech/server/log/syslog/SyslogConnectionListener.notifyConnected (Ljava/net/SocketAddress;)V 2
      // 2d: goto 34
      // 30: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 33: athrow
      // 34: return
      // try (5 -> 12): 13 java/lang/IllegalArgumentException
      // try (7 -> 19): 20 java/lang/IllegalArgumentException
   }

   private void m() {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 00: aload 0
      // 01: getfield com/l7tech/server/log/syslog/impl/b.o Ljava/util/concurrent/atomic/AtomicReference;
      // 04: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 07: checkcast com/l7tech/server/log/syslog/SyslogConnectionListener
      // 0a: astore 1
      // 0b: aload 1
      // 0c: ifnull 34
      // 0f: getstatic com/l7tech/server/log/syslog/SyslogProtocol.UDP Lcom/l7tech/server/log/syslog/SyslogProtocol;
      // 12: aload 0
      // 13: getfield com/l7tech/server/log/syslog/impl/b.h Lcom/l7tech/server/log/syslog/SyslogConfig;
      // 16: invokevirtual com/l7tech/server/log/syslog/SyslogConfig.getProtocol ()Lcom/l7tech/server/log/syslog/SyslogProtocol;
      // 19: if_acmpeq 34
      // 1c: goto 23
      // 1f: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 22: athrow
      // 23: aload 1
      // 24: aload 0
      // 25: invokevirtual com/l7tech/server/log/syslog/impl/b.n ()Ljava/net/SocketAddress;
      // 28: invokeinterface com/l7tech/server/log/syslog/SyslogConnectionListener.notifyDisconnected (Ljava/net/SocketAddress;)V 2
      // 2d: goto 34
      // 30: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 33: athrow
      // 34: return
      // try (5 -> 12): 13 java/lang/IllegalArgumentException
      // try (7 -> 19): 20 java/lang/IllegalArgumentException
   }

   private SocketAddress n() {
      return this.h.getSyslogAddresses()[this.r];
   }

   private void o() {
      InetSocketAddress var1 = (InetSocketAddress)this.n();
      this.h.getSyslogAddresses()[this.r] = new InetSocketAddress(var1.getHostName(), var1.getPort());
      this.s = null;
   }

   private BinaryVoid<IoSession, String> p() {
      return this::a;
   }

   private Unary<Boolean, IoSession> q() {
      return this::lambda$getCurrentSessionCallback$2;
   }

   private Boolean lambda$getCurrentSessionCallback$2(IoSession param1) {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 00: aload 0
      // 01: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 04: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 07: ifnull 2c
      // 0a: aload 0
      // 0b: getfield com/l7tech/server/log/syslog/impl/b.n Ljava/util/concurrent/atomic/AtomicReference;
      // 0e: invokevirtual java/util/concurrent/atomic/AtomicReference.get ()Ljava/lang/Object;
      // 11: checkcast org/apache/mina/core/session/IoSession
      // 14: aload 1
      // 15: invokeinterface org/apache/mina/core/session/IoSession.equals (Ljava/lang/Object;)Z 2
      // 1a: ifeq 2c
      // 1d: goto 24
      // 20: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 23: athrow
      // 24: bipush 1
      // 25: goto 2d
      // 28: invokestatic com/l7tech/server/log/syslog/impl/b.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 2b: athrow
      // 2c: bipush 0
      // 2d: invokestatic java/lang/Boolean.valueOf (Z)Ljava/lang/Boolean;
      // 30: areturn
      // try (0 -> 11): 12 java/lang/IllegalArgumentException
      // try (4 -> 16): 16 java/lang/IllegalArgumentException
   }

   private void lambda$connectSSL$1(IoFuture var1) {
      try {
         if (!((ConnectFuture)var1).isConnected()) {
            MinaManagedSyslog.d.log(Level.WARNING, t[12] + this.toString() + ")");
            this.d();
         }
      } catch (IllegalArgumentException var2) {
         throw a(var2);
      }
   }

   private void lambda$connect$0(ConnectFuture var1, String var2, IoFuture var3) {
      try {
         if (!var1.isConnected()) {
            MinaManagedSyslog.d.log(Level.WARNING, t[11] + var2 + ")");
            this.d();
            return;
         }
      } catch (IllegalArgumentException var4) {
         throw a(var4);
      }

      this.c();
   }

   private static Exception a(Exception var0) {
      return var0;
   }

   static {
      String[] var5 = new String[17];
      int var3 = 0;
      String var2 = "\u0005(\u001aKNor$#\u001b\u0013[xc?4_@[du9(\u0018\u0013Msb<)\u0018\u0013Sob#'\u0018VM&1##\u0011W[x15>\u0016GWdvp\u000b95<_Qyx>!E\u0013-\u0011*\u0013\u0013msb<)\u0018\u0013Xkx<)\tVL*y?5\u000b@\u001ebp&#_Q[o\u007fp'\u000bG[ga$#\u001b\u0016\u0003#\f@We\u007f#f\u0019\\L*p4\"\rVMy+p\u000e\u001d#\f@_mt\u0003#\u0011W[x<\u000b\u0013)\u0011][ie5\"E\u0013\f\u0003\u00153`[yb9)\u0011\t\u001e9\u0005(\u001aKNor$#\u001b\u0013[xc?4_@[du9(\u0018\u0013Msb<)\u0018\u0013Sob#'\u0018VM&1##\u0011W[x15>\u0016GWdvp\u001d\u0003?\f_Qm16'\u0016_Q|t\"|_H\u000ew1m{B\r\u001eq -\u0019\u0013)\u0011][ie9)\u0011\u0013]e| *\u001aG[&1$2\u001c\u000e\u000b\u00044\u001e]Mz~\"2E\u0013\"\u0003?\f_Qm13)\u0011][ie9)\u0011\u0013_~e5+\u000fG\u001elp9*\u001aW\u001e\"&\u0003?\f_Qm1\u0003\u00153\u0013]e\u007f>#\u001cGWe\u007fp'\u000bG[ga$f\u0019RWft4fW)\u0005(\u001aKNor$#\u001b\u0013[xc?4_@[du9(\u0018\u0013Msb<)\u0018\u0013Sob#'\u0018VM*\u00119(\tRRcup6\r\\Jer?*_";
      int var4 = "\u0005(\u001aKNor$#\u001b\u0013[xc?4_@[du9(\u0018\u0013Msb<)\u0018\u0013Sob#'\u0018VM&1##\u0011W[x15>\u0016GWdvp\u000b95<_Qyx>!E\u0013-\u0011*\u0013\u0013msb<)\u0018\u0013Xkx<)\tVL*y?5\u000b@\u001ebp&#_Q[o\u007fp'\u000bG[ga$#\u001b\u0016\u0003#\f@We\u007f#f\u0019\\L*p4\"\rVMy+p\u000e\u001d#\f@_mt\u0003#\u0011W[x<\u000b\u0013)\u0011][ie5\"E\u0013\f\u0003\u00153`[yb9)\u0011\t\u001e9\u0005(\u001aKNor$#\u001b\u0013[xc?4_@[du9(\u0018\u0013Msb<)\u0018\u0013Sob#'\u0018VM&1##\u0011W[x15>\u0016GWdvp\u001d\u0003?\f_Qm16'\u0016_Q|t\"|_H\u000ew1m{B\r\u001eq -\u0019\u0013)\u0011][ie9)\u0011\u0013]e| *\u001aG[&1$2\u001c\u000e\u000b\u00044\u001e]Mz~\"2E\u0013\"\u0003?\f_Qm13)\u0011][ie9)\u0011\u0013_~e5+\u000fG\u001elp9*\u001aW\u001e\"&\u0003?\f_Qm1\u0003\u00153\u0013]e\u007f>#\u001cGWe\u007fp'\u000bG[ga$f\u0019RWft4fW)\u0005(\u001aKNor$#\u001b\u0013[xc?4_@[du9(\u0018\u0013Msb<)\u0018\u0013Sob#'\u0018VM*\u00119(\tRRcup6\r\\Jer?*_"
         .length();
      char var1 = '9';
      int var7 = -1;

      label24:
      while (true) {
         byte var10000 = 12;
         String var10001 = var2.substring(++var7, var7 + var1);
         byte var10002 = -1;

         while (true) {
            String var8 = a(var10000, a(var10001));
            switch (var10002) {
               case 0:
                  var5[var3++] = var8;
                  if ((var7 += var1) >= var4) {
                     t = var5;
                     return;
                  }

                  var1 = var2.charAt(var7);
                  break;
               default:
                  var5[var3++] = var8;
                  if ((var7 += var1) < var4) {
                     var1 = var2.charAt(var7);
                     continue label24;
                  }

                  var2 = "GgH\u0004\u0013!;Wp^\u0016\u000e+o4\u000fGmX\u001c\u001f:\u0014pfI\u0012\t=o4";
                  var4 = "GgH\u0004\u0013!;Wp^\u0016\u000e+o4\u000fGmX\u001c\u001f:\u0014pfI\u0012\t=o4".length();
                  var1 = 15;
                  var7 = -1;
            }

            var10000 = 72;
            var10001 = var2.substring(++var7, var7 + var1);
            var10002 = 0;
         }
      }
   }

   private static char[] a(String var0) {
      char[] var10000 = var0.toCharArray();
      if (var10000.length < 2) {
         var10000[0] = (char)(var10000[0] ^ 29);
      }

      return var10000;
   }

   private static String a(int var0, char[] var1) {
      int var10003 = var1.length;
      int var10002 = var0;
      char[] var10001 = var1;
      int var10000 = var10003;

      for (int var2 = 0; var10000 > var2; var2++) {
         var10001[var2] = (char)(var10001[var2] ^ var10002 ^ switch (var2 % 7) {
            case 0 -> 92;
            case 1 -> 74;
            case 2 -> 115;
            case 3 -> 63;
            case 4 -> 50;
            case 5 -> 6;
            default -> 29;
         });
      }

      return new String(var10001).intern();
   }
}