package com.l7tech.server.log;

import com.l7tech.gateway.common.cluster.ClusterContext;
import com.l7tech.gateway.common.cluster.ClusterNodeInfo;
import com.l7tech.gateway.common.log.LogAccessAdmin;
import com.l7tech.gateway.common.log.LogFileInfo;
import com.l7tech.gateway.common.log.LogSinkData;
import com.l7tech.gateway.common.log.LogSinkQuery;
import com.l7tech.gateway.common.log.SinkConfiguration;
import com.l7tech.gateway.common.log.SinkConfiguration.SeverityThreshold;
import com.l7tech.gateway.common.log.SinkConfiguration.SinkType;
import com.l7tech.gateway.common.security.rbac.OperationType;
import com.l7tech.gateway.common.security.rbac.OtherOperationName;
import com.l7tech.gateway.common.security.rbac.Role;
import com.l7tech.objectmodel.EntityHeader;
import com.l7tech.objectmodel.EntityType;
import com.l7tech.objectmodel.FindException;
import com.l7tech.objectmodel.Goid;
import com.l7tech.objectmodel.SaveException;
import com.l7tech.objectmodel.UpdateException;
import com.l7tech.server.HibernateEntityManager;
import com.l7tech.server.ServerConfig;
import com.l7tech.server.cluster.ClusterContextFactory;
import com.l7tech.server.cluster.ClusterInfoManager;
import com.l7tech.server.event.EntityClassEvent;
import com.l7tech.server.log.syslog.SyslogManager;
import com.l7tech.server.log.syslog.SyslogProtocol;
import com.l7tech.server.security.rbac.RoleManager;
import com.l7tech.server.util.ApplicationEventProxy;
import com.l7tech.util.ConfigFactory;
import com.l7tech.util.ExceptionUtils;
import com.l7tech.util.Functions;
import com.l7tech.util.InetAddressUtil;
import com.l7tech.util.JdkLoggerConfigurator;
import com.l7tech.util.Option;
import com.l7tech.util.Pair;
import com.l7tech.util.TextUtils;
import com.l7tech.util.ValidationUtils;
import com.l7tech.util.Functions.UnaryThrows;
import java.beans.PropertyChangeEvent;
import java.beans.PropertyChangeListener;
import java.io.Closeable;
import java.io.File;
import java.io.IOException;
import java.io.StringReader;
import java.net.ConnectException;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Properties;
import java.util.Map.Entry;
import java.util.concurrent.CompletionException;
import java.util.logging.Handler;
import java.util.logging.Level;
import java.util.logging.LogManager;
import java.util.logging.Logger;
import java.util.regex.Pattern;
import javax.security.auth.Subject;
import org.jetbrains.annotations.NotNull;
import org.springframework.context.ApplicationEvent;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Throwable.class, noRollbackFor = FindException.class)
public class SinkManagerImpl extends HibernateEntityManager<SinkConfiguration, EntityHeader> implements SinkManager, PropertyChangeListener {
   static final String m;
   static final String n;
   static final String o;
   private static final Logger p;
   private static final String q;
   private static final String r;
   private static final String s;
   private static final String t;
   private static final long u = 1073741824L;
   private static final long v = 5368709120L;
   private static final String w;
   private static final String x;
   private final DispatchingMessageSink y = new DispatchingMessageSink();
   private final MessageSink z = new p(this.y);
   private final ServerConfig A;
   private final SyslogManager B;
   private final TrafficLogger C;
   private final ClusterInfoManager D;
   private ClusterContextFactory E;
   private final RoleManager F;
   private final Collection<Logger> G = new ArrayList<>();
   private static final String[] H;

   public SinkManagerImpl(ServerConfig var1, SyslogManager var2, TrafficLogger var3, ApplicationEventProxy var4, ClusterInfoManager var5, RoleManager var6) {
      if (var1 == null) {
         String[] var7 = H;
         throw new IllegalArgumentException(var7[53]);
      }

      try {
         if (var2 == null) {
            throw new IllegalArgumentException(H[65]);
         }
      } catch (IllegalArgumentException var8) {
         throw a(var8);
      }

      this.A = var1;
      this.B = var2;
      this.C = var3;
      this.D = var5;
      this.F = var6;
      var4.addApplicationListener(new g(this));
   }

   @Override
   public long getMaximumFileStorageSpace() {
      long var1 = 5368709120L;
      String[] var5 = H;
      String var3 = this.A.getProperty(var5[67]);
      if (var3 != null) {
         try {
            var1 = Long.parseLong(var3);
         } catch (NumberFormatException var6) {
            var5 = H;
            p.log(Level.WARNING, var5[12], new String[]{var5[88], var3});
         }
      }

      return var1;
   }

   @Override
   public long getReservedFileStorageSpace() {
      long var1 = 0L;

      for (SinkConfiguration var5 : this.h()) {
         try {
            if (!var5.isEnabled() || !this.a(var5)) {
               continue;
            }
         } catch (IllegalArgumentException var6) {
            throw a(var6);
         }

         var1 += this.c(var5);
      }

      return var1;
   }

   public Class<SinkConfiguration> getImpClass() {
      return SinkConfiguration.class;
   }

   @Override
   public Class<SinkConfiguration> getInterfaceClass() {
      return SinkConfiguration.class;
   }

   @Override
   public String getTableName() {
      return H[37];
   }

   @Override
   public boolean test(SinkConfiguration 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:
      // 000: bipush 1
      // 001: istore 3
      // 002: aload 1
      // 003: ifnull 166
      // 006: new java/util/ArrayList
      // 009: dup
      // 00a: bipush 10
      // 00c: invokespecial java/util/ArrayList.<init> (I)V
      // 00f: astore 4
      // 011: new com/l7tech/server/log/syslog/TestingSyslogManager
      // 014: dup
      // 015: aload 0
      // 016: getfield com/l7tech/server/log/SinkManagerImpl.A Lcom/l7tech/server/ServerConfig;
      // 019: invokespecial com/l7tech/server/log/syslog/TestingSyslogManager.<init> (Lcom/l7tech/server/ServerConfig;)V
      // 01c: astore 5
      // 01e: aload 4
      // 020: aload 5
      // 022: invokeinterface java/util/List.add (Ljava/lang/Object;)Z 2
      // 027: pop
      // 028: new com/l7tech/server/log/e
      // 02b: dup
      // 02c: aload 0
      // 02d: getfield com/l7tech/server/log/SinkManagerImpl.A Lcom/l7tech/server/ServerConfig;
      // 030: aload 1
      // 031: aload 5
      // 033: bipush 1
      // 034: invokespecial com/l7tech/server/log/e.<init> (Lcom/l7tech/server/ServerConfig;Lcom/l7tech/gateway/common/log/SinkConfiguration;Lcom/l7tech/server/log/syslog/SyslogManager;Z)V
      // 037: astore 6
      // 039: invokestatic com/l7tech/server/log/MessageCategory.values ()[Lcom/l7tech/server/log/MessageCategory;
      // 03c: astore 7
      // 03e: aload 7
      // 040: arraylength
      // 041: istore 8
      // 043: bipush 0
      // 044: istore 9
      // 046: iload 9
      // 048: iload 8
      // 04a: if_icmpge 106
      // 04d: aload 7
      // 04f: iload 9
      // 051: aaload
      // 052: astore 10
      // 054: aload 6
      // 056: aload 10
      // 058: invokevirtual com/l7tech/server/log/MessageSinkSupport.a (Lcom/l7tech/server/log/MessageCategory;)Z
      // 05b: ifeq 100
      // 05e: new java/util/logging/LogRecord
      // 061: dup
      // 062: getstatic java/util/logging/Level.INFO Ljava/util/logging/Level;
      // 065: aload 2
      // 066: ifnonnull 07d
      // 069: goto 070
      // 06c: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 06f: athrow
      // 070: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 073: bipush 47
      // 075: aaload
      // 076: goto 07e
      // 079: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 07c: athrow
      // 07d: aload 2
      // 07e: invokespecial java/util/logging/LogRecord.<init> (Ljava/util/logging/Level;Ljava/lang/String;)V
      // 081: astore 11
      // 083: aload 1
      // 084: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getSeverity ()Lcom/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold;
      // 087: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold.toLoggingLevel ()Ljava/util/logging/Level;
      // 08a: astore 12
      // 08c: aload 12
      // 08e: invokevirtual java/util/logging/Level.intValue ()I
      // 091: getstatic java/util/logging/Level.INFO Ljava/util/logging/Level;
      // 094: invokevirtual java/util/logging/Level.intValue ()I
      // 097: if_icmple 0a8
      // 09a: aload 11
      // 09c: aload 12
      // 09e: invokevirtual java/util/logging/LogRecord.setLevel (Ljava/util/logging/Level;)V
      // 0a1: goto 0a8
      // 0a4: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0a7: athrow
      // 0a8: aload 6
      // 0aa: aload 10
      // 0ac: aload 11
      // 0ae: invokevirtual com/l7tech/server/log/MessageSinkSupport.message (Lcom/l7tech/server/log/MessageCategory;Ljava/util/logging/LogRecord;)V
      // 0b1: aload 4
      // 0b3: aload 6
      // 0b5: invokeinterface java/util/List.add (Ljava/lang/Object;)Z 2
      // 0ba: pop
      // 0bb: bipush 1
      // 0bc: istore 13
      // 0be: iload 13
      // 0c0: aload 1
      // 0c1: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.syslogHostList ()Ljava/util/List;
      // 0c4: invokeinterface java/util/List.size ()I 1
      // 0c9: if_icmpge 0fd
      // 0cc: aload 5
      // 0ce: iload 13
      // 0d0: invokevirtual com/l7tech/server/log/syslog/TestingSyslogManager.setTestingHost (I)V
      // 0d3: new com/l7tech/server/log/e
      // 0d6: dup
      // 0d7: aload 0
      // 0d8: getfield com/l7tech/server/log/SinkManagerImpl.A Lcom/l7tech/server/ServerConfig;
      // 0db: aload 1
      // 0dc: aload 5
      // 0de: bipush 1
      // 0df: invokespecial com/l7tech/server/log/e.<init> (Lcom/l7tech/server/ServerConfig;Lcom/l7tech/gateway/common/log/SinkConfiguration;Lcom/l7tech/server/log/syslog/SyslogManager;Z)V
      // 0e2: astore 6
      // 0e4: aload 6
      // 0e6: aload 10
      // 0e8: aload 11
      // 0ea: invokevirtual com/l7tech/server/log/MessageSinkSupport.message (Lcom/l7tech/server/log/MessageCategory;Ljava/util/logging/LogRecord;)V
      // 0ed: aload 4
      // 0ef: aload 6
      // 0f1: invokeinterface java/util/List.add (Ljava/lang/Object;)Z 2
      // 0f6: pop
      // 0f7: iinc 13 1
      // 0fa: goto 0be
      // 0fd: goto 106
      // 100: iinc 9 1
      // 103: goto 046
      // 106: aload 0
      // 107: aload 4
      // 109: aload 4
      // 10b: invokeinterface java/util/List.size ()I 1
      // 110: anewarray 1256
      // 113: invokeinterface java/util/List.toArray ([Ljava/lang/Object;)[Ljava/lang/Object; 2
      // 118: checkcast [Ljava/io/Closeable;
      // 11b: ldc2_w 60000
      // 11e: invokevirtual com/l7tech/server/log/SinkManagerImpl.a ([Ljava/io/Closeable;J)V
      // 121: goto 166
      // 124: astore 6
      // 126: bipush 0
      // 127: istore 3
      // 128: aload 0
      // 129: aload 4
      // 12b: aload 4
      // 12d: invokeinterface java/util/List.size ()I 1
      // 132: anewarray 1256
      // 135: invokeinterface java/util/List.toArray ([Ljava/lang/Object;)[Ljava/lang/Object; 2
      // 13a: checkcast [Ljava/io/Closeable;
      // 13d: ldc2_w 60000
      // 140: invokevirtual com/l7tech/server/log/SinkManagerImpl.a ([Ljava/io/Closeable;J)V
      // 143: goto 166
      // 146: astore 14
      // 148: aload 0
      // 149: aload 4
      // 14b: aload 4
      // 14d: invokeinterface java/util/List.size ()I 1
      // 152: anewarray 1256
      // 155: invokeinterface java/util/List.toArray ([Ljava/lang/Object;)[Ljava/lang/Object; 2
      // 15a: checkcast [Ljava/io/Closeable;
      // 15d: ldc2_w 60000
      // 160: invokevirtual com/l7tech/server/log/SinkManagerImpl.a ([Ljava/io/Closeable;J)V
      // 163: aload 14
      // 165: athrow
      // 166: iload 3
      // 167: ireturn
      // try (67 -> 75): 76 com/l7tech/server/log/MessageSinkSupport$ConfigurationException
      // try (46 -> 58): 58 com/l7tech/server/log/MessageSinkSupport$ConfigurationException
      // try (42 -> 51): 52 com/l7tech/server/log/MessageSinkSupport$ConfigurationException
      // try (19 -> 118): 128 com/l7tech/server/log/MessageSinkSupport$ConfigurationException
      // try (19 -> 118): 141 null
      // try (128 -> 131): 141 null
      // try (141 -> 142): 141 null
   }

   public void createRoles(SinkConfiguration var1) throws SaveException {
      String[] var4 = H;
      if (this.A.getBooleanProperty(var4[16], true)) {
         for (Role var3 : createRolesForSink(var1)) {
            p.info(H[85] + var3.getName());
            this.F.save(var3);
         }
      }
   }

   public static Collection<Role> createRolesForSink(SinkConfiguration var0) {
      String var1 = TextUtils.truncStringMiddle(var0.getName(), 50);
      String[] var4 = H;
      String var2 = MessageFormat.format(var4[17], var1, var0.getGoid());
      Role var3 = new Role();
      var3.setName(var2);
      var3.addEntityPermission(OperationType.READ, EntityType.LOG_SINK, var0.getId());
      var3.addEntityPermission(OperationType.READ, EntityType.CLUSTER_INFO, null);
      var3.addEntityOtherPermission(EntityType.LOG_SINK, var0.getId(), OtherOperationName.LOG_VIEWER.getOperationName());
      var3.setEntityType(EntityType.LOG_SINK);
      var3.setEntityGoid(var0.getGoid());
      var3.setDescription(var4[94]);
      return Collections.singletonList(var3);
   }

   public void updateRoles(SinkConfiguration var1) throws UpdateException {
   }

   public Goid save(SinkConfiguration var1) throws SaveException {
      Goid var2 = super.save(var1);
      var1.setGoid(var2);
      return var2;
   }

   @Override
   public Collection<LogFileInfo> findAllFilesForSinkByNode(@NotNull String var1, Goid var2) throws FindException {
      try {
         if (var1 == null) {
            b(0);
         }
      } catch (IOException var13) {
         throw a(var13);
      }

      ArrayList var3 = new ArrayList();
      if (this.a(var1)) {
         SinkConfiguration var17 = this.findByPrimaryKey(var2);

         try {
            if (var17 == null || !var17.getType().equals(SinkType.FILE)) {
               return var3;
            }
         } catch (IOException var14) {
            throw a(var14);
         }

         try {
            String var5 = this.getSinkFilePattern(var17);

            try {
               if (var5 == null) {
                  throw new FindException(var17.getName());
               }
            } catch (IOException var15) {
               throw a(var15);
            }

            String var6 = var5.substring(0, var5.lastIndexOf("/"));
            String var7 = var5.substring(var5.lastIndexOf("/") + 1);
            if (var17.isRollingEnabled()) {
               String var10000 = var17.getName();
               String var10001 = var17.getRollingInterval().getPattern();
               String[] var11 = H;
               var7 = var10000 + "." + var10001.replaceAll(var11[75], var11[4]) + var11[91];
            } else {
               String[] var21 = H;
               var7 = var7.replace(var21[90], var21[13]);
               var7 = var7.replace(var21[20], var21[93]);
               var7 = var7.replace(var21[56], "%");
            }

            Pattern var8 = Pattern.compile(var7);
            File var9 = new File(var6);
            if (var9.isDirectory()) {
               File[] var10 = var9.listFiles(new h(this, var8));
               var3.addAll(Functions.map(Arrays.asList(var10), new i(this)));
            }
         } catch (IOException var16) {
            p.warning(H[7] + var17.getName());
         }

         return var3;
      } else {
         Option var4 = this.a(var1, new j(this, var1, var2));

         try {
            if (var4.isSome()) {
               var3.addAll((Collection)var4.some());
            }

            return var3;
         } catch (IOException var12) {
            throw a(var12);
         }
      }
   }

   @Override
   public LogSinkData getSinkLogs(String param1, Goid param2, String param3, LogSinkQuery param4) throws FindException {
      // $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: aconst_null
      // 001: astore 5
      // 003: aload 0
      // 004: aload 1
      // 005: invokevirtual com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/String;)Z
      // 008: ifeq 341
      // 00b: aconst_null
      // 00c: astore 6
      // 00e: aconst_null
      // 00f: astore 7
      // 011: aconst_null
      // 012: astore 8
      // 014: aconst_null
      // 015: astore 9
      // 017: aload 0
      // 018: aload 2
      // 019: invokevirtual com/l7tech/server/log/SinkManagerImpl.findByPrimaryKey (Lcom/l7tech/objectmodel/Goid;)Lcom/l7tech/objectmodel/PersistentEntity;
      // 01c: checkcast com/l7tech/gateway/common/log/SinkConfiguration
      // 01f: astore 10
      // 021: aload 10
      // 023: ifnull 286
      // 026: getstatic com/l7tech/gateway/common/log/SinkConfiguration$SinkType.FILE Lcom/l7tech/gateway/common/log/SinkConfiguration$SinkType;
      // 029: aload 10
      // 02b: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getType ()Lcom/l7tech/gateway/common/log/SinkConfiguration$SinkType;
      // 02e: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration$SinkType.equals (Ljava/lang/Object;)Z
      // 031: ifeq 286
      // 034: goto 03b
      // 037: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 03a: athrow
      // 03b: aload 0
      // 03c: aload 10
      // 03e: invokevirtual com/l7tech/server/log/SinkManagerImpl.getSinkFilePattern (Lcom/l7tech/gateway/common/log/SinkConfiguration;)Ljava/lang/String;
      // 041: astore 11
      // 043: aload 11
      // 045: ifnonnull 069
      // 048: aconst_null
      // 049: astore 12
      // 04b: bipush 4
      // 04c: anewarray 1256
      // 04f: dup
      // 050: bipush 0
      // 051: aload 6
      // 053: aastore
      // 054: dup
      // 055: bipush 1
      // 056: aload 7
      // 058: aastore
      // 059: dup
      // 05a: bipush 2
      // 05b: aload 8
      // 05d: aastore
      // 05e: dup
      // 05f: bipush 3
      // 060: aload 9
      // 062: aastore
      // 063: invokestatic com/l7tech/util/ResourceUtils.closeQuietly ([Ljava/io/Closeable;)V
      // 066: aload 12
      // 068: areturn
      // 069: new java/io/File
      // 06c: dup
      // 06d: aload 11
      // 06f: invokespecial java/io/File.<init> (Ljava/lang/String;)V
      // 072: astore 12
      // 074: aload 12
      // 076: invokevirtual java/io/File.getParent ()Ljava/lang/String;
      // 079: astore 13
      // 07b: aload 12
      // 07d: invokevirtual java/io/File.getName ()Ljava/lang/String;
      // 080: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 083: astore 28
      // 085: aload 28
      // 087: bipush 11
      // 089: aaload
      // 08a: aload 28
      // 08c: bipush 93
      // 08e: aaload
      // 08f: invokevirtual java/lang/String.replace (Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/lang/String;
      // 092: aload 28
      // 094: bipush 49
      // 096: aaload
      // 097: aload 28
      // 099: bipush 93
      // 09b: aaload
      // 09c: invokevirtual java/lang/String.replace (Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/lang/String;
      // 09f: astore 14
      // 0a1: aload 10
      // 0a3: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.isRollingEnabled ()Z
      // 0a6: ifeq 0d2
      // 0a9: aload 10
      // 0ab: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getName ()Ljava/lang/String;
      // 0ae: aload 10
      // 0b0: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getRollingInterval ()Lcom/l7tech/gateway/common/log/SinkConfiguration$RollingInterval;
      // 0b3: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration$RollingInterval.getPattern ()Ljava/lang/String;
      // 0b6: aload 28
      // 0b8: bipush 26
      // 0ba: aaload
      // 0bb: aload 28
      // 0bd: bipush 34
      // 0bf: aaload
      // 0c0: invokevirtual java/lang/String.replaceAll (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
      // 0c3: ldc "."
      // 0c5: swap
      // 0c6: aload 28
      // 0c8: bipush 70
      // 0ca: aaload
      // 0cb: invokedynamic makeConcatWithConstants (Ljava/lang/String;Ljava/lang/String;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\u0001\u0001" ]
      // 0d0: astore 14
      // 0d2: aload 3
      // 0d3: aload 14
      // 0d5: invokevirtual java/lang/String.matches (Ljava/lang/String;)Z
      // 0d8: ifeq 266
      // 0db: new java/io/File
      // 0de: dup
      // 0df: aload 13
      // 0e1: aload 3
      // 0e2: invokespecial java/io/File.<init> (Ljava/lang/String;Ljava/lang/String;)V
      // 0e5: astore 15
      // 0e7: aload 0
      // 0e8: aload 4
      // 0ea: invokevirtual com/l7tech/gateway/common/log/LogSinkQuery.getLastRead ()J
      // 0ed: aload 3
      // 0ee: aload 13
      // 0f0: aload 12
      // 0f2: invokevirtual java/io/File.getName ()Ljava/lang/String;
      // 0f5: invokevirtual com/l7tech/server/log/SinkManagerImpl.a (JLjava/lang/String;Ljava/lang/String;Ljava/lang/String;)Z
      // 0f8: istore 16
      // 0fa: iload 16
      // 0fc: ifeq 107
      // 0ff: lconst_0
      // 100: goto 10c
      // 103: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 106: athrow
      // 107: aload 4
      // 109: invokevirtual com/l7tech/gateway/common/log/LogSinkQuery.getStartPosition ()J
      // 10c: lstore 17
      // 10e: aload 4
      // 110: invokevirtual com/l7tech/gateway/common/log/LogSinkQuery.isFromEnd ()Z
      // 113: ifeq 128
      // 116: lconst_0
      // 117: aload 15
      // 119: invokevirtual java/io/File.length ()J
      // 11c: lload 17
      // 11e: lsub
      // 11f: ldc2_w 16384
      // 122: lsub
      // 123: invokestatic java/lang/Math.max (JJ)J
      // 126: lstore 17
      // 128: aload 10
      // 12a: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getCategories ()Ljava/lang/String;
      // 12d: astore 19
      // 12f: bipush 0
      // 130: istore 20
      // 132: aload 19
      // 134: ifnull 1b9
      // 137: aload 19
      // 139: getstatic com/l7tech/gateway/common/log/SinkConfiguration.CATEGORY_SSPC_LOGS Ljava/lang/String;
      // 13c: invokevirtual java/lang/String.equals (Ljava/lang/Object;)Z
      // 13f: ifeq 1b9
      // 142: goto 149
      // 145: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 148: athrow
      // 149: aload 4
      // 14b: invokevirtual com/l7tech/gateway/common/log/LogSinkQuery.isFromEnd ()Z
      // 14e: ifeq 167
      // 151: goto 158
      // 154: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 157: athrow
      // 158: aload 15
      // 15a: invokevirtual java/io/File.length ()J
      // 15d: lload 17
      // 15f: lsub
      // 160: goto 16a
      // 163: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 166: athrow
      // 167: ldc2_w 131072
      // 16a: lstore 21
      // 16c: bipush 5
      // 16d: anewarray 421
      // 170: dup
      // 171: bipush 0
      // 172: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 175: astore 28
      // 177: aload 28
      // 179: bipush 1
      // 17a: aaload
      // 17b: aastore
      // 17c: dup
      // 17d: bipush 1
      // 17e: aload 28
      // 180: bipush 6
      // 182: aaload
      // 183: aastore
      // 184: dup
      // 185: bipush 2
      // 186: aload 15
      // 188: invokevirtual java/io/File.getAbsolutePath ()Ljava/lang/String;
      // 18b: aastore
      // 18c: dup
      // 18d: bipush 3
      // 18e: lload 17
      // 190: invokestatic java/lang/String.valueOf (J)Ljava/lang/String;
      // 193: aastore
      // 194: dup
      // 195: bipush 4
      // 196: lload 21
      // 198: invokestatic java/lang/String.valueOf (J)Ljava/lang/String;
      // 19b: aastore
      // 19c: astore 23
      // 19e: aload 23
      // 1a0: invokestatic com/l7tech/common/io/ProcUtils.exec ([Ljava/lang/String;)Lcom/l7tech/common/io/ProcResult;
      // 1a3: astore 24
      // 1a5: new java/io/ByteArrayInputStream
      // 1a8: dup
      // 1a9: aload 24
      // 1ab: invokevirtual com/l7tech/common/io/ProcResult.getOutput ()[B
      // 1ae: invokespecial java/io/ByteArrayInputStream.<init> ([B)V
      // 1b1: astore 6
      // 1b3: bipush 1
      // 1b4: istore 20
      // 1b6: goto 1c4
      // 1b9: new java/io/FileInputStream
      // 1bc: dup
      // 1bd: aload 15
      // 1bf: invokespecial java/io/FileInputStream.<init> (Ljava/io/File;)V
      // 1c2: astore 6
      // 1c4: lconst_0
      // 1c5: lstore 21
      // 1c7: iload 20
      // 1c9: ifne 1d5
      // 1cc: aload 6
      // 1ce: lload 17
      // 1d0: invokevirtual java/io/InputStream.skip (J)J
      // 1d3: lstore 21
      // 1d5: iload 20
      // 1d7: ifne 1fe
      // 1da: lload 21
      // 1dc: lload 17
      // 1de: lcmp
      // 1df: ifge 1fe
      // 1e2: goto 1e9
      // 1e5: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 1e8: athrow
      // 1e9: new com/l7tech/gateway/common/log/LogSinkData
      // 1ec: dup
      // 1ed: bipush 0
      // 1ee: newarray 8
      // 1f0: ldc2_w -1
      // 1f3: bipush 0
      // 1f4: lconst_0
      // 1f5: lconst_0
      // 1f6: invokespecial com/l7tech/gateway/common/log/LogSinkData.<init> ([BJZJJ)V
      // 1f9: astore 5
      // 1fb: goto 263
      // 1fe: new com/l7tech/util/TruncatingInputStream
      // 201: dup
      // 202: aload 6
      // 204: invokespecial com/l7tech/util/TruncatingInputStream.<init> (Ljava/io/InputStream;)V
      // 207: astore 7
      // 209: new com/l7tech/util/PoolByteArrayOutputStream
      // 20c: dup
      // 20d: ldc 131072
      // 20f: invokespecial com/l7tech/util/PoolByteArrayOutputStream.<init> (I)V
      // 212: astore 8
      // 214: new com/l7tech/server/log/t
      // 217: dup
      // 218: aload 0
      // 219: aload 8
      // 21b: sipush 16384
      // 21e: invokespecial com/l7tech/server/log/t.<init> (Lcom/l7tech/server/log/SinkManagerImpl;Ljava/io/OutputStream;I)V
      // 221: astore 9
      // 223: aload 7
      // 225: aload 9
      // 227: invokestatic com/l7tech/util/IOUtils.copyStream (Ljava/io/InputStream;Ljava/io/OutputStream;)J
      // 22a: pop2
      // 22b: invokestatic java/lang/System.currentTimeMillis ()J
      // 22e: lstore 23
      // 230: aload 7
      // 232: invokevirtual com/l7tech/util/TruncatingInputStream.getPosition ()J
      // 235: lstore 25
      // 237: lload 25
      // 239: lconst_0
      // 23a: lcmp
      // 23b: iflt 245
      // 23e: lload 25
      // 240: lload 21
      // 242: ladd
      // 243: lstore 25
      // 245: aload 9
      // 247: invokevirtual java/util/zip/GZIPOutputStream.finish ()V
      // 24a: new com/l7tech/gateway/common/log/LogSinkData
      // 24d: dup
      // 24e: aload 8
      // 250: invokevirtual com/l7tech/util/PoolByteArrayOutputStream.toByteArray ()[B
      // 253: lload 25
      // 255: iload 16
      // 257: lload 23
      // 259: aload 15
      // 25b: invokevirtual java/io/File.length ()J
      // 25e: invokespecial com/l7tech/gateway/common/log/LogSinkData.<init> ([BJZJJ)V
      // 261: astore 5
      // 263: goto 286
      // 266: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 269: aload 3
      // 26a: aload 14
      // 26c: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 26f: astore 28
      // 271: aload 28
      // 273: bipush 44
      // 275: aaload
      // 276: dup_x2
      // 277: pop
      // 278: aload 28
      // 27a: bipush 21
      // 27c: aaload
      // 27d: swap
      // 27e: invokedynamic makeConcatWithConstants (Ljava/lang/String;Ljava/lang/String;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\u0001\u0001" ]
      // 283: invokevirtual java/util/logging/Logger.warning (Ljava/lang/String;)V
      // 286: bipush 4
      // 287: anewarray 1256
      // 28a: dup
      // 28b: bipush 0
      // 28c: aload 6
      // 28e: aastore
      // 28f: dup
      // 290: bipush 1
      // 291: aload 7
      // 293: aastore
      // 294: dup
      // 295: bipush 2
      // 296: aload 8
      // 298: aastore
      // 299: dup
      // 29a: bipush 3
      // 29b: aload 9
      // 29d: aastore
      // 29e: invokestatic com/l7tech/util/ResourceUtils.closeQuietly ([Ljava/io/Closeable;)V
      // 2a1: goto 33e
      // 2a4: astore 10
      // 2a6: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 2a9: aload 10
      // 2ab: invokevirtual java/io/FileNotFoundException.getMessage ()Ljava/lang/String;
      // 2ae: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 2b1: astore 28
      // 2b3: aload 28
      // 2b5: bipush 31
      // 2b7: aaload
      // 2b8: swap
      // 2b9: 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" ]
      // 2be: invokevirtual java/util/logging/Logger.info (Ljava/lang/String;)V
      // 2c1: bipush 4
      // 2c2: anewarray 1256
      // 2c5: dup
      // 2c6: bipush 0
      // 2c7: aload 6
      // 2c9: aastore
      // 2ca: dup
      // 2cb: bipush 1
      // 2cc: aload 7
      // 2ce: aastore
      // 2cf: dup
      // 2d0: bipush 2
      // 2d1: aload 8
      // 2d3: aastore
      // 2d4: dup
      // 2d5: bipush 3
      // 2d6: aload 9
      // 2d8: aastore
      // 2d9: invokestatic com/l7tech/util/ResourceUtils.closeQuietly ([Ljava/io/Closeable;)V
      // 2dc: goto 33e
      // 2df: astore 10
      // 2e1: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 2e4: getstatic java/util/logging/Level.WARNING Ljava/util/logging/Level;
      // 2e7: aload 10
      // 2e9: invokevirtual java/io/IOException.getMessage ()Ljava/lang/String;
      // 2ec: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 2ef: bipush 28
      // 2f1: aaload
      // 2f2: swap
      // 2f3: 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" ]
      // 2f8: aload 10
      // 2fa: invokestatic com/l7tech/util/ExceptionUtils.getDebugException (Ljava/lang/Throwable;)Ljava/lang/Throwable;
      // 2fd: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
      // 300: bipush 4
      // 301: anewarray 1256
      // 304: dup
      // 305: bipush 0
      // 306: aload 6
      // 308: aastore
      // 309: dup
      // 30a: bipush 1
      // 30b: aload 7
      // 30d: aastore
      // 30e: dup
      // 30f: bipush 2
      // 310: aload 8
      // 312: aastore
      // 313: dup
      // 314: bipush 3
      // 315: aload 9
      // 317: aastore
      // 318: invokestatic com/l7tech/util/ResourceUtils.closeQuietly ([Ljava/io/Closeable;)V
      // 31b: goto 33e
      // 31e: astore 27
      // 320: bipush 4
      // 321: anewarray 1256
      // 324: dup
      // 325: bipush 0
      // 326: aload 6
      // 328: aastore
      // 329: dup
      // 32a: bipush 1
      // 32b: aload 7
      // 32d: aastore
      // 32e: dup
      // 32f: bipush 2
      // 330: aload 8
      // 332: aastore
      // 333: dup
      // 334: bipush 3
      // 335: aload 9
      // 337: aastore
      // 338: invokestatic com/l7tech/util/ResourceUtils.closeQuietly ([Ljava/io/Closeable;)V
      // 33b: aload 27
      // 33d: athrow
      // 33e: goto 35b
      // 341: aload 0
      // 342: aload 1
      // 343: new com/l7tech/server/log/k
      // 346: dup
      // 347: aload 0
      // 348: aload 1
      // 349: aload 2
      // 34a: aload 3
      // 34b: aload 4
      // 34d: invokespecial com/l7tech/server/log/k.<init> (Lcom/l7tech/server/log/SinkManagerImpl;Ljava/lang/String;Lcom/l7tech/objectmodel/Goid;Ljava/lang/String;Lcom/l7tech/gateway/common/log/LogSinkQuery;)V
      // 350: invokevirtual com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/String;Lcom/l7tech/util/Functions$UnaryThrows;)Lcom/l7tech/util/Option;
      // 353: invokevirtual com/l7tech/util/Option.toNull ()Ljava/lang/Object;
      // 356: checkcast com/l7tech/gateway/common/log/LogSinkData
      // 359: astore 5
      // 35b: aload 5
      // 35d: areturn
      // try (19 -> 26): 27 java/io/FileNotFoundException
      // try (14 -> 37): 337 java/io/FileNotFoundException
      // try (233 -> 239): 240 java/io/FileNotFoundException
      // try (161 -> 172): 172 java/io/FileNotFoundException
      // try (154 -> 164): 165 java/io/FileNotFoundException
      // try (152 -> 158): 159 java/io/FileNotFoundException
      // try (126 -> 130): 130 java/io/FileNotFoundException
      // try (58 -> 317): 337 java/io/FileNotFoundException
      // try (14 -> 37): 369 java/io/IOException
      // try (58 -> 317): 369 java/io/IOException
      // try (14 -> 37): 402 null
      // try (58 -> 317): 402 null
      // try (337 -> 349): 402 null
      // try (369 -> 382): 402 null
      // try (402 -> 403): 402 null
   }

   private boolean a(long param1, String param3, String param4, String param5) {
      // $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: lload 1
      // 01: lconst_0
      // 02: lcmp
      // 03: ifne 0c
      // 06: bipush 0
      // 07: ireturn
      // 08: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0b: athrow
      // 0c: aload 5
      // 0e: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 11: astore 13
      // 13: aload 13
      // 15: bipush 49
      // 17: aaload
      // 18: invokevirtual java/lang/String.indexOf (Ljava/lang/String;)I
      // 1b: istore 6
      // 1d: iload 6
      // 1f: ifge 24
      // 22: bipush 0
      // 23: ireturn
      // 24: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 27: bipush 61
      // 29: aaload
      // 2a: invokestatic java/util/regex/Pattern.compile (Ljava/lang/String;)Ljava/util/regex/Pattern;
      // 2d: astore 7
      // 2f: aload 7
      // 31: aload 3
      // 32: invokevirtual java/util/regex/Pattern.matcher (Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
      // 35: astore 8
      // 37: aload 8
      // 39: iload 6
      // 3b: invokevirtual java/util/regex/Matcher.find (I)Z
      // 3e: ifeq 8b
      // 41: aload 8
      // 43: invokevirtual java/util/regex/Matcher.group ()Ljava/lang/String;
      // 46: astore 9
      // 48: aload 9
      // 4a: invokestatic java/lang/Integer.parseInt (Ljava/lang/String;)I
      // 4d: istore 10
      // 4f: aload 3
      // 50: aload 9
      // 52: iload 10
      // 54: bipush 1
      // 55: iadd
      // 56: invokestatic java/lang/Integer.toString (I)Ljava/lang/String;
      // 59: invokevirtual java/lang/String.replaceFirst (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
      // 5c: astore 11
      // 5e: new java/io/File
      // 61: dup
      // 62: aload 4
      // 64: aload 11
      // 66: invokespecial java/io/File.<init> (Ljava/lang/String;Ljava/lang/String;)V
      // 69: astore 12
      // 6b: aload 12
      // 6d: ifnull 8b
      // 70: aload 12
      // 72: invokevirtual java/io/File.lastModified ()J
      // 75: lload 1
      // 76: lcmp
      // 77: ifle 89
      // 7a: goto 81
      // 7d: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 80: athrow
      // 81: bipush 1
      // 82: goto 8a
      // 85: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 88: athrow
      // 89: bipush 0
      // 8a: ireturn
      // 8b: goto 92
      // 8e: astore 6
      // 90: bipush 0
      // 91: ireturn
      // 92: bipush 0
      // 93: ireturn
      // try (0 -> 6): 6 java/lang/NumberFormatException
      // try (8 -> 19): 70 java/lang/NumberFormatException
      // try (55 -> 65): 65 java/lang/NumberFormatException
      // try (53 -> 60): 61 java/lang/NumberFormatException
      // try (20 -> 68): 70 java/lang/NumberFormatException
   }

   @Override
   public void propertyChange(PropertyChangeEvent var1) {
      try {
         if (H[5].equals(var1.getPropertyName())) {
            this.a((String)var1.getOldValue(), (String)var1.getNewValue());
            return;
         }
      } catch (IllegalArgumentException var3) {
         throw a(var3);
      }

      try {
         if (H[92].equals(var1.getPropertyName())) {
            this.f();
         }
      } catch (IllegalArgumentException var2) {
         throw a(var2);
      }
   }

   @Override
   public MessageSink getPublishingSink() {
      return this.z;
   }

   public static MessageSink getPublishingSink(Object var0) {
      return ((SinkManager)var0).getPublishingSink();
   }

   protected void initDao() {
      try {
         p.info(H[23]);
         if (this.applicationContext.containsBean(H[0])) {
            this.E = (ClusterContextFactory)this.applicationContext.getBean(H[24], ClusterContextFactory.class);
         }
      } catch (IllegalArgumentException var1) {
         throw a(var1);
      }

      this.a();
      this.a(null, (String)null);
      this.d();
      this.e();
      this.b();
      this.f();
      p.info(H[8]);
   }

   private void a(ApplicationEvent var1) {
      if (var1 instanceof EntityClassEvent var2) {
         try {
            if (SinkConfiguration.class.isAssignableFrom(var2.getEntityClass())) {
               this.f();
            }
         } catch (IllegalArgumentException var3) {
            throw a(var3);
         }
      }
   }

   private void a() {
      Logger var1 = Logger.getLogger("");
      var1.addHandler(new SinkHandler(this.y, MessageCategory.LOG));
      String[] var4 = H;
      Logger var2 = Logger.getLogger(var4[30]);
      var2.addHandler(new SinkHandler(this.y, MessageCategory.TRAFFIC));
      String var3 = LogManager.getLogManager().getProperty(var4[10]);

      try {
         if (var3 != null) {
            var2.setUseParentHandlers(Boolean.valueOf(var3));
         }
      } catch (IllegalArgumentException var5) {
         throw a(var5);
      }
   }

   private void b() {
      this.a(Logger.getLogger(""));
      this.a(JdkLogConfig.getInitialRootLogger());
   }

   private void a(Logger var1) {
      if (var1 != null) {
         for (Handler var5 : var1.getHandlers()) {
            try {
               if (var5 instanceof StartupAwareHandler) {
                  var1.removeHandler(var5);
                  var5.close();
               }
            } catch (IllegalArgumentException var6) {
               throw a(var6);
            }
         }
      }
   }

   private int c() {
      return ConfigFactory.getIntProperty(H[79], 2124);
   }

   private boolean a(String 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/SinkManagerImpl.D Lcom/l7tech/server/cluster/ClusterInfoManager;
      // 04: ifnull 1e
      // 07: aload 1
      // 08: aload 0
      // 09: getfield com/l7tech/server/log/SinkManagerImpl.D Lcom/l7tech/server/cluster/ClusterInfoManager;
      // 0c: invokeinterface com/l7tech/server/cluster/ClusterInfoManager.thisNodeId ()Ljava/lang/String; 1
      // 11: invokevirtual java/lang/String.equals (Ljava/lang/Object;)Z
      // 14: ifeq 26
      // 17: goto 1e
      // 1a: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 1d: athrow
      // 1e: bipush 1
      // 1f: goto 27
      // 22: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 25: athrow
      // 26: bipush 0
      // 27: ireturn
      // try (0 -> 9): 10 java/lang/IllegalArgumentException
      // try (3 -> 14): 14 java/lang/IllegalArgumentException
   }

   private void a(String var1, String var2) {
      synchronized (this.G) {
         String var4 = var2;
         if (var4 == null) {
            String[] var18 = H;
            var4 = this.A.getProperty(var18[87]);
         }

         try {
            Properties var5 = new Properties();
            var5.load(new StringReader(var4));
            Properties var6 = new Properties();

            try {
               if (var1 != null) {
                  var6.load(new StringReader(var1));
               }
            } catch (IllegalArgumentException var24) {
               throw a(var24);
            }

            Properties var7 = JdkLoggerConfigurator.getNonDefaultProperties();
            this.G.clear();

            for (Entry var9 : var5.entrySet()) {
               String var10 = (String)var9.getKey();
               String var11 = (String)var9.getValue();

               try {
                  if (!var10.endsWith(H[14]) || var7.getProperty(var10) != null) {
                     continue;
                  }
               } catch (IllegalArgumentException var23) {
                  throw a(var23);
               }

               String var12 = var10.substring(0, var10.length() - 6);

               try {
                  Level var13 = Level.parse(var11);
                  Logger var14 = Logger.getLogger(var12);
                  var14.setLevel(var13);
                  this.G.add(var14);
               } catch (IllegalArgumentException var21) {
                  String[] var34 = H;
                  p.log(Level.CONFIG, var34[43], new Object[]{var11, var12});
               }
            }

            LogManager var27 = LogManager.getLogManager();

            for (Object var29 : var6.keySet()) {
               String var30 = (String)var29;

               try {
                  if (!var30.endsWith(H[42]) || var5.getProperty(var30) != null) {
                     continue;
                  }
               } catch (IllegalArgumentException var22) {
                  throw a(var22);
               }

               String var31 = var30.substring(0, var30.length() - 6);
               Logger var32 = Logger.getLogger(var31);
               boolean var33 = false;
               String var15 = var27.getProperty(var30);
               if (var15 != null) {
                  try {
                     var32.setLevel(Level.parse(var15));
                     var33 = true;
                  } catch (IllegalArgumentException var20) {
                  }
               }

               try {
                  if (!var33) {
                     var32.setLevel(null);
                  }
               } catch (IllegalArgumentException var19) {
                  throw a(var19);
               }
            }
         } catch (IOException var25) {
            p.log(Level.WARNING, H[66], var25);
         }
      }
   }

   private void d() {
      LogManager.getLogManager().addConfigurationListener(() -> {
         this.a();
         this.a(null, (String)null);
      });
   }

   private void e() {
      this.B.setConnectionListener(new o(this, this.applicationContext));
   }

   private void f() {
      // $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: new java/util/ArrayList
      // 003: dup
      // 004: invokespecial java/util/ArrayList.<init> ()V
      // 007: astore 1
      // 008: aload 0
      // 009: getfield com/l7tech/server/log/SinkManagerImpl.y Lcom/l7tech/server/log/DispatchingMessageSink;
      // 00c: invokestatic java/util/Collections.emptySet ()Ljava/util/Set;
      // 00f: invokevirtual com/l7tech/server/log/DispatchingMessageSink.setMessageSinks (Ljava/util/Collection;)V
      // 012: aload 0
      // 013: invokevirtual com/l7tech/server/log/SinkManagerImpl.h ()Ljava/util/Collection;
      // 016: astore 2
      // 017: aload 2
      // 018: invokeinterface java/util/Collection.iterator ()Ljava/util/Iterator; 1
      // 01d: astore 3
      // 01e: aload 3
      // 01f: invokeinterface java/util/Iterator.hasNext ()Z 1
      // 024: ifeq 164
      // 027: aload 3
      // 028: invokeinterface java/util/Iterator.next ()Ljava/lang/Object; 1
      // 02d: checkcast com/l7tech/gateway/common/log/SinkConfiguration
      // 030: astore 4
      // 032: aload 4
      // 034: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.isEnabled ()Z
      // 037: ifeq 13a
      // 03a: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 03d: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 040: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 043: ifeq 068
      // 046: goto 04d
      // 049: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 04c: athrow
      // 04d: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 050: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 053: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 056: bipush 72
      // 058: aaload
      // 059: aload 4
      // 05b: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getName ()Ljava/lang/String;
      // 05e: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
      // 061: goto 068
      // 064: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 067: athrow
      // 068: aload 0
      // 069: aload 4
      // 06b: invokevirtual com/l7tech/server/log/SinkManagerImpl.a (Lcom/l7tech/gateway/common/log/SinkConfiguration;)Z
      // 06e: ifne 09f
      // 071: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 074: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 077: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 07a: ifeq 161
      // 07d: goto 084
      // 080: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 083: athrow
      // 084: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 087: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 08a: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 08d: bipush 25
      // 08f: aaload
      // 090: aload 4
      // 092: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getName ()Ljava/lang/String;
      // 095: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
      // 098: goto 161
      // 09b: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 09e: athrow
      // 09f: aload 4
      // 0a1: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getType ()Lcom/l7tech/gateway/common/log/SinkConfiguration$SinkType;
      // 0a4: getstatic com/l7tech/gateway/common/log/SinkConfiguration$SinkType.FILE Lcom/l7tech/gateway/common/log/SinkConfiguration$SinkType;
      // 0a7: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration$SinkType.equals (Ljava/lang/Object;)Z
      // 0aa: ifeq 0f3
      // 0ad: aload 0
      // 0ae: getfield com/l7tech/server/log/SinkManagerImpl.A Lcom/l7tech/server/ServerConfig;
      // 0b1: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 0b4: bipush 41
      // 0b6: aaload
      // 0b7: bipush 0
      // 0b8: invokevirtual com/l7tech/server/ServerConfig.getBooleanProperty (Ljava/lang/String;Z)Z
      // 0bb: ifeq 0f3
      // 0be: goto 0c5
      // 0c1: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0c4: athrow
      // 0c5: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 0c8: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 0cb: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 0ce: ifeq 161
      // 0d1: goto 0d8
      // 0d4: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0d7: athrow
      // 0d8: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 0db: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 0de: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 0e1: bipush 18
      // 0e3: aaload
      // 0e4: aload 4
      // 0e6: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getName ()Ljava/lang/String;
      // 0e9: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
      // 0ec: goto 161
      // 0ef: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0f2: athrow
      // 0f3: aload 0
      // 0f4: aload 4
      // 0f6: invokevirtual com/l7tech/server/log/SinkManagerImpl.b (Lcom/l7tech/gateway/common/log/SinkConfiguration;)Lcom/l7tech/server/log/MessageSinkSupport;
      // 0f9: astore 5
      // 0fb: aload 5
      // 0fd: ifnull 137
      // 100: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 103: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 106: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 109: ifeq 12e
      // 10c: goto 113
      // 10f: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 112: athrow
      // 113: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 116: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 119: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 11c: bipush 33
      // 11e: aaload
      // 11f: aload 4
      // 121: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getName ()Ljava/lang/String;
      // 124: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
      // 127: goto 12e
      // 12a: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 12d: athrow
      // 12e: aload 1
      // 12f: aload 5
      // 131: invokeinterface java/util/List.add (Ljava/lang/Object;)Z 2
      // 136: pop
      // 137: goto 161
      // 13a: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 13d: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 140: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 143: ifeq 161
      // 146: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 149: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 14c: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 14f: bipush 57
      // 151: aaload
      // 152: aload 4
      // 154: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getName ()Ljava/lang/String;
      // 157: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
      // 15a: goto 161
      // 15d: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 160: athrow
      // 161: goto 01e
      // 164: aload 0
      // 165: aload 1
      // 166: invokevirtual com/l7tech/server/log/SinkManagerImpl.a (Ljava/util/List;)V
      // 169: aload 0
      // 16a: aload 1
      // 16b: invokevirtual com/l7tech/server/log/SinkManagerImpl.c (Ljava/util/List;)V
      // 16e: aload 0
      // 16f: aload 1
      // 170: invokevirtual com/l7tech/server/log/SinkManagerImpl.d (Ljava/util/List;)V
      // 173: aload 0
      // 174: aload 1
      // 175: invokevirtual com/l7tech/server/log/SinkManagerImpl.b (Ljava/util/List;)V
      // 178: aload 0
      // 179: getfield com/l7tech/server/log/SinkManagerImpl.y Lcom/l7tech/server/log/DispatchingMessageSink;
      // 17c: aload 1
      // 17d: invokevirtual com/l7tech/server/log/DispatchingMessageSink.setMessageSinks (Ljava/util/Collection;)V
      // 180: return
      // try (21 -> 28): 29 java/lang/IllegalArgumentException
      // try (24 -> 39): 40 java/lang/IllegalArgumentException
      // try (42 -> 50): 51 java/lang/IllegalArgumentException
      // try (46 -> 62): 62 java/lang/IllegalArgumentException
      // try (64 -> 77): 78 java/lang/IllegalArgumentException
      // try (69 -> 84): 85 java/lang/IllegalArgumentException
      // try (80 -> 96): 96 java/lang/IllegalArgumentException
      // try (102 -> 108): 109 java/lang/IllegalArgumentException
      // try (104 -> 119): 120 java/lang/IllegalArgumentException
      // try (127 -> 139): 140 java/lang/IllegalArgumentException
   }

   private void a(List<MessageSink> 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/SinkManagerImpl.A Lcom/l7tech/server/ServerConfig;
      // 04: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 07: astore 9
      // 09: aload 9
      // 0b: bipush 86
      // 0d: aaload
      // 0e: bipush 1
      // 0f: invokevirtual com/l7tech/server/ServerConfig.getLocalDirectoryProperty (Ljava/lang/String;Z)Ljava/io/File;
      // 12: astore 2
      // 13: new java/io/File
      // 16: dup
      // 17: aload 2
      // 18: aload 9
      // 1a: bipush 76
      // 1c: aaload
      // 1d: invokespecial java/io/File.<init> (Ljava/io/File;Ljava/lang/String;)V
      // 20: astore 3
      // 21: new java/util/ArrayList
      // 24: dup
      // 25: invokespecial java/util/ArrayList.<init> ()V
      // 28: astore 4
      // 2a: aload 1
      // 2b: invokeinterface java/util/List.iterator ()Ljava/util/Iterator; 1
      // 30: astore 5
      // 32: aload 5
      // 34: invokeinterface java/util/Iterator.hasNext ()Z 1
      // 39: ifeq 88
      // 3c: aload 5
      // 3e: invokeinterface java/util/Iterator.next ()Ljava/lang/Object; 1
      // 43: checkcast com/l7tech/server/log/MessageSink
      // 46: astore 6
      // 48: aload 6
      // 4a: instanceof com/l7tech/server/log/FileMessageSink
      // 4d: ifeq 85
      // 50: aload 6
      // 52: checkcast com/l7tech/server/log/FileMessageSink
      // 55: astore 7
      // 57: aload 7
      // 59: getstatic com/l7tech/server/log/MessageCategory.AUDIT Lcom/l7tech/server/log/MessageCategory;
      // 5c: invokevirtual com/l7tech/server/log/FileMessageSink.a (Lcom/l7tech/server/log/MessageCategory;)Z
      // 5f: ifne 74
      // 62: aload 7
      // 64: getstatic com/l7tech/server/log/MessageCategory.LOG Lcom/l7tech/server/log/MessageCategory;
      // 67: invokevirtual com/l7tech/server/log/FileMessageSink.a (Lcom/l7tech/server/log/MessageCategory;)Z
      // 6a: ifeq 85
      // 6d: goto 74
      // 70: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 73: athrow
      // 74: aload 4
      // 76: aload 7
      // 78: invokeinterface java/util/List.add (Ljava/lang/Object;)Z 2
      // 7d: pop
      // 7e: goto 85
      // 81: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 84: athrow
      // 85: goto 32
      // 88: aconst_null
      // 89: astore 5
      // 8b: new java/io/ObjectOutputStream
      // 8e: dup
      // 8f: new java/io/FileOutputStream
      // 92: dup
      // 93: aload 3
      // 94: invokespecial java/io/FileOutputStream.<init> (Ljava/io/File;)V
      // 97: invokespecial java/io/ObjectOutputStream.<init> (Ljava/io/OutputStream;)V
      // 9a: astore 5
      // 9c: aload 5
      // 9e: aload 4
      // a0: invokevirtual java/io/ObjectOutputStream.writeObject (Ljava/lang/Object;)V
      // a3: aload 5
      // a5: invokestatic com/l7tech/util/ResourceUtils.closeQuietly (Ljava/io/Closeable;)V
      // a8: goto e7
      // ab: astore 6
      // ad: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // b0: getstatic java/util/logging/Level.WARNING Ljava/util/logging/Level;
      // b3: aload 6
      // b5: invokestatic com/l7tech/util/ExceptionUtils.getMessage (Ljava/lang/Throwable;)Ljava/lang/String;
      // b8: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // bb: astore 9
      // bd: aload 9
      // bf: bipush 68
      // c1: aaload
      // c2: swap
      // c3: aload 9
      // c5: bipush 83
      // c7: aaload
      // c8: invokedynamic makeConcatWithConstants (Ljava/lang/String;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\u0001" ]
      // cd: aload 6
      // cf: invokestatic com/l7tech/util/ExceptionUtils.getDebugException (Ljava/lang/Throwable;)Ljava/lang/Throwable;
      // d2: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
      // d5: aload 5
      // d7: invokestatic com/l7tech/util/ResourceUtils.closeQuietly (Ljava/io/Closeable;)V
      // da: goto e7
      // dd: astore 8
      // df: aload 5
      // e1: invokestatic com/l7tech/util/ResourceUtils.closeQuietly (Ljava/io/Closeable;)V
      // e4: aload 8
      // e6: athrow
      // e7: return
      // try (42 -> 53): 54 java/io/IOException
      // try (38 -> 46): 47 java/io/IOException
      // try (59 -> 70): 73 java/io/IOException
      // try (59 -> 70): 94 null
      // try (73 -> 91): 94 null
      // try (94 -> 95): 94 null
   }

   private void b(List<MessageSink> var1) {
      if (this.C != null) {
         boolean var2 = false;

         for (MessageSink var4 : var1) {
            if (var4 instanceof MessageSinkSupport var5 && var5.a(MessageCategory.TRAFFIC)) {
               var2 = true;
               break;
            }
         }

         try {
            if (p.isLoggable(Level.CONFIG)) {
               p.log(Level.CONFIG, H[9] + var2 + ".");
            }
         } catch (IllegalArgumentException var6) {
            throw a(var6);
         }

         this.C.setEnabled(var2);
      }
   }

   void c(List<MessageSink> 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: getstatic com/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold.INFO Lcom/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold;
      // 03: astore 2
      // 04: aload 0
      // 05: getfield com/l7tech/server/log/SinkManagerImpl.A Lcom/l7tech/server/ServerConfig;
      // 08: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 0b: astore 8
      // 0d: aload 8
      // 0f: bipush 62
      // 11: aaload
      // 12: invokevirtual com/l7tech/server/ServerConfig.getProperty (Ljava/lang/String;)Ljava/lang/String;
      // 15: astore 3
      // 16: aload 3
      // 17: ifnull 21
      // 1a: aload 0
      // 1b: aload 3
      // 1c: aload 2
      // 1d: invokevirtual com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/String;Lcom/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold;)Lcom/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold;
      // 20: astore 2
      // 21: new com/l7tech/gateway/common/log/SinkConfiguration
      // 24: dup
      // 25: invokespecial com/l7tech/gateway/common/log/SinkConfiguration.<init> ()V
      // 28: astore 4
      // 2a: aload 4
      // 2c: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 2f: astore 8
      // 31: aload 8
      // 33: bipush 69
      // 35: aaload
      // 36: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.setName (Ljava/lang/String;)V
      // 39: aload 4
      // 3b: aload 2
      // 3c: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.setSeverity (Lcom/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold;)V
      // 3f: aload 4
      // 41: getstatic com/l7tech/gateway/common/log/SinkConfiguration.CATEGORY_AUDITS Ljava/lang/String;
      // 44: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.setCategories (Ljava/lang/String;)V
      // 47: aload 4
      // 49: getstatic com/l7tech/gateway/common/log/SinkConfiguration$SinkType.FILE Lcom/l7tech/gateway/common/log/SinkConfiguration$SinkType;
      // 4c: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.setType (Lcom/l7tech/gateway/common/log/SinkConfiguration$SinkType;)V
      // 4f: aload 8
      // 51: bipush 71
      // 53: aaload
      // 54: bipush 0
      // 55: invokestatic com/l7tech/util/SyspropUtil.getBoolean (Ljava/lang/String;Z)Z
      // 58: istore 5
      // 5a: invokestatic com/l7tech/server/log/ConsoleMessageSink.b ()Ljava/util/logging/Handler;
      // 5d: astore 6
      // 5f: iload 5
      // 61: ifeq b1
      // 64: aload 6
      // 66: ifnonnull 79
      // 69: goto 70
      // 6c: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 6f: athrow
      // 70: new com/l7tech/server/log/ConsoleMessageSink$L7ConsoleHandler
      // 73: dup
      // 74: invokespecial com/l7tech/server/log/ConsoleMessageSink$L7ConsoleHandler.<init> ()V
      // 77: astore 6
      // 79: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 7c: bipush 36
      // 7e: aaload
      // 7f: ldc ""
      // 81: invokestatic com/l7tech/util/SyspropUtil.getString (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
      // 84: astore 7
      // 86: aload 7
      // 88: ifnull a8
      // 8b: aload 7
      // 8d: invokevirtual java/lang/String.isEmpty ()Z
      // 90: ifne a8
      // 93: goto 9a
      // 96: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 99: athrow
      // 9a: aload 4
      // 9c: aload 7
      // 9e: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.setCategories (Ljava/lang/String;)V
      // a1: goto a8
      // a4: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // a7: athrow
      // a8: aload 6
      // aa: aload 2
      // ab: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold.toLoggingLevel ()Ljava/util/logging/Level;
      // ae: invokevirtual java/util/logging/Handler.setLevel (Ljava/util/logging/Level;)V
      // b1: new com/l7tech/server/log/ConsoleMessageSink
      // b4: dup
      // b5: aload 4
      // b7: aload 6
      // b9: invokespecial com/l7tech/server/log/ConsoleMessageSink.<init> (Lcom/l7tech/gateway/common/log/SinkConfiguration;Ljava/util/logging/Handler;)V
      // bc: astore 7
      // be: aload 1
      // bf: aload 7
      // c1: invokeinterface java/util/List.add (Ljava/lang/Object;)Z 2
      // c6: pop
      // c7: return
      // try (46 -> 50): 51 java/lang/IllegalArgumentException
      // try (63 -> 68): 69 java/lang/IllegalArgumentException
      // try (65 -> 74): 75 java/lang/IllegalArgumentException
   }

   private void d(List<MessageSink> 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: bipush 0
      // 01: istore 2
      // 02: aload 1
      // 03: invokeinterface java/util/List.iterator ()Ljava/util/Iterator; 1
      // 08: astore 3
      // 09: aload 3
      // 0a: invokeinterface java/util/Iterator.hasNext ()Z 1
      // 0f: ifeq 3f
      // 12: aload 3
      // 13: invokeinterface java/util/Iterator.next ()Ljava/lang/Object; 1
      // 18: checkcast com/l7tech/server/log/MessageSink
      // 1b: astore 4
      // 1d: aload 4
      // 1f: instanceof com/l7tech/server/log/MessageSinkSupport
      // 22: ifeq 3c
      // 25: aload 4
      // 27: checkcast com/l7tech/server/log/MessageSinkSupport
      // 2a: astore 5
      // 2c: aload 5
      // 2e: getstatic com/l7tech/server/log/MessageCategory.TRAFFIC Lcom/l7tech/server/log/MessageCategory;
      // 31: invokevirtual com/l7tech/server/log/MessageSinkSupport.a (Lcom/l7tech/server/log/MessageCategory;)Z
      // 34: ifeq 3c
      // 37: bipush 1
      // 38: istore 2
      // 39: goto 3f
      // 3c: goto 09
      // 3f: iload 2
      // 40: ifne 7d
      // 43: aload 0
      // 44: invokevirtual com/l7tech/server/log/SinkManagerImpl.g ()Lcom/l7tech/server/log/FileMessageSink;
      // 47: astore 3
      // 48: aload 3
      // 49: ifnull 7d
      // 4c: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 4f: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 52: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z
      // 55: ifeq 75
      // 58: goto 5f
      // 5b: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 5e: athrow
      // 5f: getstatic com/l7tech/server/log/SinkManagerImpl.p Ljava/util/logging/Logger;
      // 62: getstatic java/util/logging/Level.CONFIG Ljava/util/logging/Level;
      // 65: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 68: bipush 77
      // 6a: aaload
      // 6b: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;)V
      // 6e: goto 75
      // 71: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 74: athrow
      // 75: aload 1
      // 76: aload 3
      // 77: invokeinterface java/util/List.add (Ljava/lang/Object;)Z 2
      // 7c: pop
      // 7d: return
      // try (31 -> 37): 38 java/lang/IllegalArgumentException
      // try (33 -> 46): 47 java/lang/IllegalArgumentException
   }

   private FileMessageSink g() {
      FileMessageSink var1 = null;
      String[] var8 = H;
      boolean var2 = this.A.getBooleanProperty(var8[45], false);
      String var3 = this.A.getProperty(var8[54]);
      String var4 = this.A.getProperty(var8[15]);
      String var5 = this.A.getProperty(var8[2]);
      if (var2) {
         try {
            String var6 = new File(var3).getName();
            if (var6.endsWith(var8[35])) {
               var6 = var6.substring(0, var6.length() - var8[48].length());
            }

            var6 = var6.replace('%', '_');
            SinkConfiguration var7 = new SinkConfiguration();
            var7.setName(var6);
            var7.setType(SinkType.FILE);
            var7.setSeverity(SeverityThreshold.INFO);
            var7.setCategories(SinkConfiguration.CATEGORY_TRAFFIC_LOGS);
            var7.setProperty(SinkConfiguration.PROP_FILE_MAX_SIZE, var4);
            var7.setProperty(SinkConfiguration.PROP_FILE_LOG_COUNT, var5);
            var7.setProperty(SinkConfiguration.PROP_FILE_FORMAT, SinkConfiguration.FILE_FORMAT_RAW);
            var1 = new FileMessageSink(this.A, var7);
         } catch (MessageSinkSupport.ConfigurationException var9) {
            p.log(Level.WARNING, H[51], var9);
         }
      }

      return var1;
   }

   private Collection<SinkConfiguration> h() {
      Collection var1 = Collections.emptyList();

      try {
         var1 = this.findAll();
      } catch (FindException var3) {
         p.log(Level.WARNING, H[73], var3);
      }

      return var1;
   }

   private boolean a(SinkConfiguration 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:
      // 000: aload 1
      // 001: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getName ()Ljava/lang/String;
      // 004: astore 3
      // 005: aload 1
      // 006: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getType ()Lcom/l7tech/gateway/common/log/SinkConfiguration$SinkType;
      // 009: astore 4
      // 00b: aload 1
      // 00c: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getSeverity ()Lcom/l7tech/gateway/common/log/SinkConfiguration$SeverityThreshold;
      // 00f: astore 5
      // 011: aload 3
      // 012: ifnull 051
      // 015: aload 4
      // 017: ifnull 051
      // 01a: goto 021
      // 01d: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 020: athrow
      // 021: aload 5
      // 023: ifnull 051
      // 026: goto 02d
      // 029: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 02c: athrow
      // 02d: aload 3
      // 02e: getstatic com/l7tech/util/ValidationUtils.ALPHA_NUMERIC Ljava/lang/String;
      // 031: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 034: bipush 52
      // 036: aaload
      // 037: 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" ]
      // 03c: invokestatic com/l7tech/util/ValidationUtils.isValidCharacters (Ljava/lang/CharSequence;Ljava/lang/String;)Z
      // 03f: ifeq 051
      // 042: goto 049
      // 045: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 048: athrow
      // 049: bipush 1
      // 04a: goto 052
      // 04d: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 050: athrow
      // 051: bipush 0
      // 052: istore 2
      // 053: iload 2
      // 054: ifeq 184
      // 057: getstatic com/l7tech/server/log/n.a [I
      // 05a: aload 4
      // 05c: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration$SinkType.ordinal ()I
      // 05f: iaload
      // 060: lookupswitch 292 2 1 32 2 141
      // 07c: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 07f: athrow
      // 080: aload 1
      // 081: getstatic com/l7tech/gateway/common/log/SinkConfiguration.PROP_FILE_FORMAT Ljava/lang/String;
      // 084: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getProperty (Ljava/lang/String;)Ljava/lang/String;
      // 087: astore 6
      // 089: aload 1
      // 08a: getstatic com/l7tech/gateway/common/log/SinkConfiguration.PROP_FILE_LOG_COUNT Ljava/lang/String;
      // 08d: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getProperty (Ljava/lang/String;)Ljava/lang/String;
      // 090: astore 7
      // 092: aload 1
      // 093: getstatic com/l7tech/gateway/common/log/SinkConfiguration.PROP_FILE_MAX_SIZE Ljava/lang/String;
      // 096: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getProperty (Ljava/lang/String;)Ljava/lang/String;
      // 099: astore 8
      // 09b: aload 6
      // 09d: ifnull 0e8
      // 0a0: aload 7
      // 0a2: ifnull 0e8
      // 0a5: goto 0ac
      // 0a8: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0ab: athrow
      // 0ac: aload 8
      // 0ae: ifnull 0e8
      // 0b1: goto 0b8
      // 0b4: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0b7: athrow
      // 0b8: aload 7
      // 0ba: bipush 0
      // 0bb: lconst_1
      // 0bc: ldc2_w 1000
      // 0bf: invokestatic com/l7tech/util/ValidationUtils.isValidLong (Ljava/lang/String;ZJJ)Z
      // 0c2: ifeq 0e8
      // 0c5: goto 0cc
      // 0c8: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0cb: athrow
      // 0cc: aload 8
      // 0ce: bipush 0
      // 0cf: lconst_1
      // 0d0: ldc2_w 2147483648
      // 0d3: invokestatic com/l7tech/util/ValidationUtils.isValidLong (Ljava/lang/String;ZJJ)Z
      // 0d6: ifeq 0e8
      // 0d9: goto 0e0
      // 0dc: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0df: athrow
      // 0e0: bipush 1
      // 0e1: goto 0e9
      // 0e4: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 0e7: athrow
      // 0e8: bipush 0
      // 0e9: istore 2
      // 0ea: goto 184
      // 0ed: aload 1
      // 0ee: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.syslogHostList ()Ljava/util/List;
      // 0f1: astore 9
      // 0f3: aload 1
      // 0f4: getstatic com/l7tech/gateway/common/log/SinkConfiguration.PROP_SYSLOG_PROTOCOL Ljava/lang/String;
      // 0f7: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getProperty (Ljava/lang/String;)Ljava/lang/String;
      // 0fa: astore 10
      // 0fc: aload 1
      // 0fd: getstatic com/l7tech/gateway/common/log/SinkConfiguration.PROP_SYSLOG_FACILITY Ljava/lang/String;
      // 100: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getProperty (Ljava/lang/String;)Ljava/lang/String;
      // 103: astore 11
      // 105: aload 10
      // 107: ifnull 151
      // 10a: aload 11
      // 10c: ifnull 151
      // 10f: goto 116
      // 112: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 115: athrow
      // 116: aload 11
      // 118: bipush 0
      // 119: bipush 0
      // 11a: bipush 124
      // 11c: invokestatic com/l7tech/util/ValidationUtils.isValidInteger (Ljava/lang/String;ZII)Z
      // 11f: ifeq 151
      // 122: goto 129
      // 125: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 128: athrow
      // 129: aload 0
      // 12a: aload 10
      // 12c: invokevirtual com/l7tech/server/log/SinkManagerImpl.b (Ljava/lang/String;)Z
      // 12f: ifeq 151
      // 132: goto 139
      // 135: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 138: athrow
      // 139: aload 0
      // 13a: aload 9
      // 13c: invokevirtual com/l7tech/server/log/SinkManagerImpl.e (Ljava/util/List;)Z
      // 13f: ifeq 151
      // 142: goto 149
      // 145: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 148: athrow
      // 149: bipush 1
      // 14a: goto 152
      // 14d: invokestatic com/l7tech/server/log/SinkManagerImpl.a (Ljava/lang/Exception;)Ljava/lang/Exception;
      // 150: athrow
      // 151: bipush 0
      // 152: istore 2
      // 153: iload 2
      // 154: ifeq 184
      // 157: aload 1
      // 158: getstatic com/l7tech/gateway/common/log/SinkConfiguration.PROP_SYSLOG_CHAR_SET Ljava/lang/String;
      // 15b: invokevirtual com/l7tech/gateway/common/log/SinkConfiguration.getProperty (Ljava/lang/String;)Ljava/lang/String;
      // 15e: astore 12
      // 160: getstatic com/l7tech/server/log/SinkManagerImpl.H [Ljava/lang/String;
      // 163: astore 13
      // 165: aload 13
      // 167: bipush 60
      // 169: aaload
      // 16a: aload 12
      // 16c: invokevirtual java/lang/String.equals (Ljava/lang/Object;)Z
      // 16f: ifeq 17e
      // 172: aload 13
      // 174: bipush 22
      // 176: aaload
      // 177: invokestatic java/nio/charset/Charset.isSupported (Ljava/lang/String;)Z
      // 17a: istore 2
      // 17b: goto 184
      // 17e: aload 12
      // 180: invokestatic java/nio/charset/Charset.isSupported (Ljava/lang/String;)Z
      // 183: istore 2
      // 184: iload 2
      // 185: ireturn
      // try (9 -> 13): 14 java/lang/IllegalArgumentException
      // try (11 -> 18): 19 java/lang/IllegalArgumentException
      // try (16 -> 29): 30 java/lang/IllegalArgumentException
      // try (21 -> 34): 34 java/lang/IllegalArgumentException
      // try (38 -> 45): 45 java/lang/IllegalArgumentException
      // try (59 -> 63): 64 java/lang/IllegalArgumentException
      // try (61 -> 68): 69 java/lang/IllegalArgumentException
      // try (66 -> 77): 78 java/lang/IllegalArgumentException
      // try (71 -> 86): 87 java/lang/IllegalArgumentException
      // try (80 -> 91): 91 java/lang/IllegalArgumentException
      // try (107 -> 111): 112 java/lang/IllegalArgumentException
      // try (109 -> 120): 121 java/lang/IllegalArgumentException
      // try (114 -> 127): 128 java/lang/IllegalArgumentException
      // try (123 -> 134): 135 java/lang/IllegalArgumentException
      // try (130 -> 139): 139 java/lang/IllegalArgumentException
   }

   private MessageSinkSupport b(SinkConfiguration var1) {
      MessageSinkSupport var2 = null;
      SinkType var3 = var1.getType();

      try {
         switch (com.l7tech.server.log.n.a[var3.ordinal()]) {
            case 1:
               String var4 = var1.getCategories();

               try {
                  if (var4 == null || var4.equals(SinkConfiguration.CATEGORY_SSPC_LOGS)) {
                     break;
                  }
               } catch (MessageSinkSupport.ConfigurationException var6) {
                  throw a(var6);
               }

               var2 = new FileMessageSink(this.A, var1);
               break;
            case 2:
               var2 = new e(this.A, var1, this.B);
               break;
            default:
               String[] var8 = H;
               p.log(Level.WARNING, var8[89], var3);
         }
      } catch (MessageSinkSupport.ConfigurationException var7) {
         Logger var10000 = p;
         Level var10001 = Level.WARNING;
         String var10002 = var1.getName();
         String[] var5 = H;
         var10000.log(var10001, var5[46] + var10002 + var5[80], var7);
      }

      return var2;
   }

   private long c(SinkConfiguration var1) {
      long var2 = 0L;
      SinkType var4 = var1.getType();

      try {
         if (var4 == null) {
            return var2;
         }

         switch (com.l7tech.server.log.n.a[var4.ordinal()]) {
            case 1:
               break;
            default:
               return var2;
         }
      } catch (IllegalArgumentException var9) {
         throw a(var9);
      }

      long var5 = Long.parseLong(var1.getProperty(SinkConfiguration.PROP_FILE_LOG_COUNT));
      long var7 = Long.parseLong(var1.getProperty(SinkConfiguration.PROP_FILE_MAX_SIZE));
      var2 += var5 * var7 * 1024L;
      return var2;
   }

   private boolean b(String var1) {
      boolean var2;
      try {
         SyslogProtocol.valueOf(var1);
         var2 = true;
      } catch (IllegalArgumentException var4) {
         var2 = false;
      }

      return var2;
   }

   private boolean e(List<String> var1) {
      boolean var2 = true;

      try {
         if (var1 == null || var1.isEmpty()) {
            return false;
         }
      } catch (IllegalArgumentException var7) {
         throw a(var7);
      }

      for (String var4 : var1) {
         Pair var5 = InetAddressUtil.getHostAndPort(var4, null);

         try {
            if (!ValidationUtils.isValidDomain(InetAddressUtil.stripIpv6Brackets((String)var5.left))
               || !ValidationUtils.isValidInteger((String)var5.right, false, 1, 65535)) {
               return false;
            }
         } catch (IllegalArgumentException var6) {
            throw a(var6);
         }
      }

      return var2;
   }

   private SeverityThreshold a(String var1, SeverityThreshold var2) {
      SeverityThreshold var3 = var2;

      try {
         var3 = SeverityThreshold.valueOf(var1);
      } catch (IllegalArgumentException var5) {
      }

      return var3;
   }

   private void a(Closeable[] var1, long var2) {
      Thread var4 = new Thread(new l(this, var2, var1), H[95]);
      var4.setDaemon(true);
      var4.start();
   }

   protected String getSinkFilePattern(SinkConfiguration var1) throws IOException {
      String var2 = null;
      String var3 = var1.getCategories();

      label48: {
         try {
            if (var1.isEnabled() && !var3.equals(SinkConfiguration.CATEGORY_SSPC_LOGS)) {
               break label48;
            }
         } catch (IOException var8) {
            throw a(var8);
         }

         String[] var6 = H;
         String var4 = var1.getProperty(var6[50]);

         label29: {
            try {
               if (var3 == null || !var3.equals(SinkConfiguration.CATEGORY_SSPC_LOGS)) {
                  break label29;
               }
            } catch (IOException var7) {
               throw a(var7);
            }

            var6 = H;
            var4 = ConfigFactory.getProperty(var6[64]) + var6[63];
         }

         var2 = com.l7tech.server.log.d.a(this.A, var1.getName(), var4, false);
         return var2;
      }

      MessageSinkSupport var9 = this.y.getMessageSink(var1);
      FileMessageSink var5 = (FileMessageSink)var9;
      if (var5 != null) {
         var2 = var5.getFilePattern();
      }

      return var2;
   }

   private <R> Option<R> a(String var1, UnaryThrows<R, LogAccessAdmin, FindException> var2) throws FindException {
      Option var3 = Option.none();
      long var4 = System.currentTimeMillis();

      ClusterNodeInfo var10000;
      label66: {
         try {
            if (this.D != null) {
               var10000 = (ClusterNodeInfo)Functions.grepFirst(this.D.retrieveClusterStatus(), new m(this, var1));
               break label66;
            }
         } catch (CompletionException var16) {
            throw a(var16);
         }

         var10000 = null;
      }

      ClusterNodeInfo var6 = var10000;

      label58: {
         try {
            if (this.E == null || var6 == null) {
               break label58;
            }
         } catch (CompletionException var15) {
            throw a(var15);
         }

         try {
            var3 = Option.optional(Subject.callAs(null, () -> {
               ClusterContext var3x = this.E.buildClusterContext(var6.getAddress(), this.c());
               LogAccessAdmin var4x = var3x.getLogAccessAdmin();
               return var2.call(var4x);
            }));
         } catch (CompletionException var13) {
            label70: {
               Throwable var8 = var13.getCause();

               try {
                  if (var8 instanceof FindException) {
                     throw (FindException)var8;
                  }
               } catch (CompletionException var11) {
                  throw a(var11);
               }

               try {
                  if (ExceptionUtils.causedBy(var8, ConnectException.class)) {
                     p.log(Level.INFO, H[81] + var1 + H[55]);
                     break label70;
                  }
               } catch (CompletionException var12) {
                  throw a(var12);
               }

               String[] var17 = H;
               p.log(Level.WARNING, var17[27] + var1 + "'", var8);
            }
         } catch (Exception var14) {
            Logger var18 = p;
            Level var10001 = Level.WARNING;
            String var10003 = ExceptionUtils.getMessage(var14);
            String[] var9 = H;
            var18.log(var10001, var9[19] + var1 + var9[32] + var10003, ExceptionUtils.getDebugException(var14));
         }
      }

      try {
         if (p.isLoggable(Level.FINEST)) {
            p.finest(H[29] + (System.currentTimeMillis() - var4) + H[78]);
         }

         return var3;
      } catch (CompletionException var10) {
         throw a(var10);
      }
   }

   static {
      String[] var5 = new String[96];
      int var3 = 0;
      String var2 = "iV\u000bp6\u0005\fIU\u0010w'\u0018\nL[\u001dw-\u0012\u0007\u0004yO\u001al\u0012~H\u001fe$\t\u001dFU\u0019d'\u0012=eO\u0010w!xX\u001f`l\u0001\u000b~U,l.\u0005P|S\u001bt\u0011\t\u0010a\u0014\u001fv6\u000f=x_\u001fw'\bVf\u001axpLJw\tfU\u0019O'\u0016\u001bfI0%U\u000ewm3\u001biO\ff\u0011\u0010\u001fd\u0015?s2\f\u0017kT\u001dfm\f\u0017h_\u0006f!O\ry]Su+\u0005\tfU\u0019-1\b\"FU\u0019#1\t\u0010a\u001a\u0018j.\u0005\r*T\u0011wb\u0006\u0011\u007fT\u001a#$\u000f\f*I\u0017m)Z+X_\u001aj0\u0005\u001d~_\u001a#.\u000f\u0019mS\u0010db\u0014\u0011*Y\u0011m$\t\u0019\u007fH\u001bgb\f\u0011m\u001a\rj,\u000b\r$5_J\u001ab6\t\u0010m\u001a\nq#\u0006\u0018cY^o-\u0007\u0019cT\u0019#'\u000e\u001fhV\u001bgb\u0013\nkN\u001b/b\u000e\u001b}\u001a\bb.\u0015\u001b*S\r#$iU\u0013-.W\noY\u0016-6\u0012\u001fl\\\u0017`l\u0015\roj\u001fq'\u000e\nB[\u0010g.\u0005\fy\u0002/O=OH\fl0@\u000ekH\rj,\u0007^zH\u0011s'\u0012\ns\u001aY$9P\u0003-\u001dR#5\t\nb\u001a\bb.\u0015\u001b*\u001dYxs\u001dY-\u001a\u001fpb\u000e\u000bgX\u001bql\u0006Q\nS:\u001fK\u0006$V\u001bu'\f\u0012~H\u001fe$\t\u001dFU\u0019d'\u00122cW\u0017w!xX\u001f`l\u0001\u000b~U,l.\u0005P|S\u001bt\u0011\t\u0010a\u0014\u001fv6\u000f=x_\u001fw'\u0018\\S\u001btb\u001bNw\u001a2l%@-cT\u0015#jC\u0005;GWFKV\u0012#$\t\u0012o\u001a\u0012l%\u0013^yS\u0010h1@\u001acI\u001fa.\u0005\u001a$\u001a7d,\u000f\fcT\u0019#.\u000f\u0019*I\u0017m)@\u001deT\u0018j%\u0015\fkN\u0017l,@Y-AN~eGP8_T\u001b{2\u0005\u001d~_\u001a#'\u0012\feH^g7\u0012\u0017d]^o-\u0007^fS\rwm\u0012\u001bk^^e0\u000f\u0013*H\u001bn-\u0014\u001b*T\u0011g'@Y\u0002/]!&\u001a\u0010l6@\u0013kN\u001dk+\u000e\u0019*I\u0017m)@\u0018cV\u001b#2\u0001\n~_\fmb\nCi1.zXK3\u0017O,X_\u001aj0\u0005\u001d~S\u0010db\f\u0011m]\u0017m%@\ne\u001a\u001dl,\u0006\u0017mO\ff&@\u0012e]^p+\u000e\u0015y\u0014\u0015iV\u000bp6\u0005\fIU\u0010w'\u0018\nL[\u001dw-\u0012\u00070C]\u0010l0\t\u0010m\u001a\u0017m4\u0001\u0012c^^o-\u0007^yS\u0010hb\u0003\u0011d\\\u0017d7\u0012\u001f~S\u0011mbGYq\n\u0003$eN\u0007VM\u00051nT\u0003-OH\fl0@\u001a\u007fH\u0017m%@\u0012e]^o+\u0013\n%H\u001bb&@\u0018xU\u0013#0\u0005\u0013eN\u001b#,\u000f\u001ao\u001aY\u001dOH\fl0@\fo[\u001aj,\u0007^lH\u0011nb\f\u0011m\u001a\u0018j.\u0005D*+M_\nw+\u000e\u0019*I\u0017m)@\u001deT\u0018j%\u0015\fkN\u0017l,\u0013^lH\u0011nb.1N\u007f^w-\u000f\u0015*\u0012iU\u0013-.W\noY\u0016-6\u0012\u001fl\\\u0017`\u0014FU\u0019#$\t\u0012o\u001a\u0010l6@\u0018eO\u0010gx@\u0002-\u0000\u001cCT\rw#\f\u0012cT\u0019#.\u000f\u0019*I\u0017m)@Y-AN~eGP\bVf\u001axpLJw\nU\u001f\u0019\\g\u0015PfU\u0019'iU\u0013-.W\noY\u0016-1\u0005\f|_\f-.\u000f\u0019$Y\u0011m1\u000f\u0012o\u0014\u001b{6\u0012\u001fI[\np\u000byS\u0010h\u001d\u0003\u0011d\\\u0017d>KH\u0019v/\u0005\u0010~\u001a\u0018l0@>DU\nM7\f\u0012*J\u001fq#\r\u001b~_\f#eE\r-\u001a\u0011ebE\r$\u001f\r#/\u0015\r~\u001a\u0010l6@\u001co\u001a\u0010v.\f\u0019lS\u0010g\u0003\f\u0012LS\u0012f1&\u0011xi\u0017m)\"\u0007DU\u001af\u0018\\S\u001btb\u001bNw\u001a2l%@-cT\u0015#jC\u0005;GW%iU\u0013-.W\noY\u0016-1\u0005\f|_\f-&\t\rkX\u0012f\u0004\t\u0012ov\u0011d1\t\u0010aI\u0006$V\u001bu'\f3C]\u0010l0\t\u0010m\u001a\u0017m4\u0001\u0012c^^o'\u0016\u001bf\u001aY$9P\u0003-\u001dR#$\u000f\f*V\u0011d%\u0005\f*\u001dYxs\u001dY-\u0014\u0019KN\nf/\u0010\n*N\u0011#0\u0005\u001fn\u001a\u0012l%@\u0018cV\u001b#\u0014~H\u001fe$\t\u001dFU\u0019d'\u0012;d[\u001co'\u0004\u0019OH\fl0@\u001dx_\u001fw+\u000e\u0019*V\u0011db\u0013\u0017dQ^$\r^_\rwb\r\u001byI\u001fd'N\nU\u001f\u0019\\g\u0015PfU\u0019\u0002/]\flS\u0012fl\f\u0011mj\u001fw*2OH\fl0@\u001dx_\u001fw+\u000e\u0019*N\fb$\u0006\u0017i\u001a\u0012l%@\u0018eH^`.\u0015\r~_\f#2\u0012\u0011z_\fw+\u0005\r$\u0002'e\u001dy_\fu'\u0012=eT\u0018j%@\u0013\u007fI\n#,\u000f\n*X\u001b#,\u0015\u0012f\u0014~H\u001fe$\t\u001dFU\u0019d'\u0012.kN\nf0\u000e\u0015-\u0016^w-@\u0012cI\n,0\u0005\u001fn\u001a\u0012l%\u0013P\u0002/\u001f1C]\u0010l0\t\u0010m\u001a\u001aj1\u0001\u001cf_\u001a#.\u000f\u0019*I\u0017m)@\u001deT\u0018j%\u0015\fkN\u0017l,@Y-AN~eGP\u0006dU\u001af\u000b\u0004%iU\u0013,.W\noY\u0016,1\u0005\f|_\f,.\u000f\u0019%i\u0017m)-\u001fd[\u0019f0)\u0013zV\u0007F{*J\fMO\u0005Q\nS:\u001f\u0013iU\u0010p-\f\u001bFU\u0019W*\u0012\u001byR\u0011o&\u0014%y\u0011m6\u0012\u0011fV\u001bqm\u0016\u001fx\u0015\u0012l%\u0013\u0016iU\u0013-.W\noY\u0016-1\u0005\f|_\f- \u0001\ro\u001eyC\ro-\u00073kT\u001fd'\u0012^gO\rwb\u000e\u0011~\u001a\u001cfb\u000e\u000bfV+_T\u001b{2\u0005\u001d~_\u001a#'\u0012\feH^s0\u000f\u001doI\rj,\u0007^fU\u0019d+\u000e\u0019*V\u001bu'\f\r$\u000ffU\u0019E+\f\u001bYJ\u001f`'-\u001fr!OH\fl0@\r~U\fj,\u0007^fU\u0019#!\u000f\u0010lS\u0019v0\u0001\ncU\u0010#e\u0007iU\u0010p-\f\u001b\u0004$V\u0011d\u001diU\u0013-.W\noY\u0016-1\u0005\f|_\f-.\u000f\u0019$Y\u0011m1\u000f\u0012o*ZH\u0011`'\u0013\rcT\u0019#.\u000f\u0019*I\u0017m)@\u001deT\u0018j%\u0015\fkN\u0017l,@Y-AN~eGP5_T\u001b{2\u0005\u001d~_\u001a#'\u0012\feH^o-\u0001\u001acT\u0019#/\u0005\ry[\u0019f1@\rcT\u0015#!\u000f\u0010lS\u0019v0\u0001\ncU\u0010-\u0012iU\u0013-.W\noY\u0016-6\u0012\u001fl\\\u0017`\u0007VM\u00051nT\u0003\u000efU\u0019p\u001d\f\u0011i[\u0012-&\u0001\n<CT\rw#\f\u0012cT\u0019#6\u0012\u001fl\\\u0017`b\f\u0011m\u001a\rj,\u000b^lU\f#!\f\u000byN\u001bqb\u0010\feJ\u001bq6\t\u001by\u001a\rf6\u0014\u0017d]\r-\u0003gIP\u000fiV\u000bp6\u0005\fDU\u001af\u0012\u000f\f~\u0002-\u0014\"_T\u001fa.\u0005^~U^`-\u000e\u0010oY\n#6\u000f^x_\u0013l6\u0005^dU\u001afbG\bFU\u0019#\u0011\t\u0010a\u0002-\u0014%iU\u0013-.W\noY\u0016-1\u0005\f|_\f-&\t\rkX\u0012f\u0004\t\u0012ov\u0011d1\t\u0010aI\u0013IH\u001bb6\t\u0010m\u001a\u0010f5@,eV\u001b9b\f|[\fG+\u0012\u001biN\u0011q;\tfU\u0019O'\u0016\u001bfI\u000ffU\u0019E+\f\u001bYJ\u001f`'-\u001fr&C]\u0010l0\t\u0010m\u001a\u000bm)\u000e\u0011}T^w;\u0010\u001b*U\u0018#1\t\u0010a\u001aY$9P\u0003-\u001dP\u0002/O\u0004$V\u0011d\u0013iU\u0010p-\f\u001bFU\u0019W*\u0012\u001byR\u0011o&\u0006Q\nS:\u001fK";
      int var4 = "iV\u000bp6\u0005\fIU\u0010w'\u0018\nL[\u001dw-\u0012\u0007\u0004yO\u001al\u0012~H\u001fe$\t\u001dFU\u0019d'\u0012=eO\u0010w!xX\u001f`l\u0001\u000b~U,l.\u0005P|S\u001bt\u0011\t\u0010a\u0014\u001fv6\u000f=x_\u001fw'\bVf\u001axpLJw\tfU\u0019O'\u0016\u001bfI0%U\u000ewm3\u001biO\ff\u0011\u0010\u001fd\u0015?s2\f\u0017kT\u001dfm\f\u0017h_\u0006f!O\ry]Su+\u0005\tfU\u0019-1\b\"FU\u0019#1\t\u0010a\u001a\u0018j.\u0005\r*T\u0011wb\u0006\u0011\u007fT\u001a#$\u000f\f*I\u0017m)Z+X_\u001aj0\u0005\u001d~_\u001a#.\u000f\u0019mS\u0010db\u0014\u0011*Y\u0011m$\t\u0019\u007fH\u001bgb\f\u0011m\u001a\rj,\u000b\r$5_J\u001ab6\t\u0010m\u001a\nq#\u0006\u0018cY^o-\u0007\u0019cT\u0019#'\u000e\u001fhV\u001bgb\u0013\nkN\u001b/b\u000e\u001b}\u001a\bb.\u0015\u001b*S\r#$iU\u0013-.W\noY\u0016-6\u0012\u001fl\\\u0017`l\u0015\roj\u001fq'\u000e\nB[\u0010g.\u0005\fy\u0002/O=OH\fl0@\u000ekH\rj,\u0007^zH\u0011s'\u0012\ns\u001aY$9P\u0003-\u001dR#5\t\nb\u001a\bb.\u0015\u001b*\u001dYxs\u001dY-\u001a\u001fpb\u000e\u000bgX\u001bql\u0006Q\nS:\u001fK\u0006$V\u001bu'\f\u0012~H\u001fe$\t\u001dFU\u0019d'\u00122cW\u0017w!xX\u001f`l\u0001\u000b~U,l.\u0005P|S\u001bt\u0011\t\u0010a\u0014\u001fv6\u000f=x_\u001fw'\u0018\\S\u001btb\u001bNw\u001a2l%@-cT\u0015#jC\u0005;GWFKV\u0012#$\t\u0012o\u001a\u0012l%\u0013^yS\u0010h1@\u001acI\u001fa.\u0005\u001a$\u001a7d,\u000f\fcT\u0019#.\u000f\u0019*I\u0017m)@\u001deT\u0018j%\u0015\fkN\u0017l,@Y-AN~eGP8_T\u001b{2\u0005\u001d~_\u001a#'\u0012\feH^g7\u0012\u0017d]^o-\u0007^fS\rwm\u0012\u001bk^^e0\u000f\u0013*H\u001bn-\u0014\u001b*T\u0011g'@Y\u0002/]!&\u001a\u0010l6@\u0013kN\u001dk+\u000e\u0019*I\u0017m)@\u0018cV\u001b#2\u0001\n~_\fmb\nCi1.zXK3\u0017O,X_\u001aj0\u0005\u001d~S\u0010db\f\u0011m]\u0017m%@\ne\u001a\u001dl,\u0006\u0017mO\ff&@\u0012e]^p+\u000e\u0015y\u0014\u0015iV\u000bp6\u0005\fIU\u0010w'\u0018\nL[\u001dw-\u0012\u00070C]\u0010l0\t\u0010m\u001a\u0017m4\u0001\u0012c^^o-\u0007^yS\u0010hb\u0003\u0011d\\\u0017d7\u0012\u001f~S\u0011mbGYq\n\u0003$eN\u0007VM\u00051nT\u0003-OH\fl0@\u001a\u007fH\u0017m%@\u0012e]^o+\u0013\n%H\u001bb&@\u0018xU\u0013#0\u0005\u0013eN\u001b#,\u000f\u001ao\u001aY\u001dOH\fl0@\fo[\u001aj,\u0007^lH\u0011nb\f\u0011m\u001a\u0018j.\u0005D*+M_\nw+\u000e\u0019*I\u0017m)@\u001deT\u0018j%\u0015\fkN\u0017l,\u0013^lH\u0011nb.1N\u007f^w-\u000f\u0015*\u0012iU\u0013-.W\noY\u0016-6\u0012\u001fl\\\u0017`\u0014FU\u0019#$\t\u0012o\u001a\u0010l6@\u0018eO\u0010gx@\u0002-\u0000\u001cCT\rw#\f\u0012cT\u0019#.\u000f\u0019*I\u0017m)@Y-AN~eGP\bVf\u001axpLJw\nU\u001f\u0019\\g\u0015PfU\u0019'iU\u0013-.W\noY\u0016-1\u0005\f|_\f-.\u000f\u0019$Y\u0011m1\u000f\u0012o\u0014\u001b{6\u0012\u001fI[\np\u000byS\u0010h\u001d\u0003\u0011d\\\u0017d>KH\u0019v/\u0005\u0010~\u001a\u0018l0@>DU\nM7\f\u0012*J\u001fq#\r\u001b~_\f#eE\r-\u001a\u0011ebE\r$\u001f\r#/\u0015\r~\u001a\u0010l6@\u001co\u001a\u0010v.\f\u0019lS\u0010g\u0003\f\u0012LS\u0012f1&\u0011xi\u0017m)\"\u0007DU\u001af\u0018\\S\u001btb\u001bNw\u001a2l%@-cT\u0015#jC\u0005;GW%iU\u0013-.W\noY\u0016-1\u0005\f|_\f-&\t\rkX\u0012f\u0004\t\u0012ov\u0011d1\t\u0010aI\u0006$V\u001bu'\f3C]\u0010l0\t\u0010m\u001a\u0017m4\u0001\u0012c^^o'\u0016\u001bf\u001aY$9P\u0003-\u001dR#$\u000f\f*V\u0011d%\u0005\f*\u001dYxs\u001dY-\u0014\u0019KN\nf/\u0010\n*N\u0011#0\u0005\u001fn\u001a\u0012l%@\u0018cV\u001b#\u0014~H\u001fe$\t\u001dFU\u0019d'\u0012;d[\u001co'\u0004\u0019OH\fl0@\u001dx_\u001fw+\u000e\u0019*V\u0011db\u0013\u0017dQ^$\r^_\rwb\r\u001byI\u001fd'N\nU\u001f\u0019\\g\u0015PfU\u0019\u0002/]\flS\u0012fl\f\u0011mj\u001fw*2OH\fl0@\u001dx_\u001fw+\u000e\u0019*N\fb$\u0006\u0017i\u001a\u0012l%@\u0018eH^`.\u0015\r~_\f#2\u0012\u0011z_\fw+\u0005\r$\u0002'e\u001dy_\fu'\u0012=eT\u0018j%@\u0013\u007fI\n#,\u000f\n*X\u001b#,\u0015\u0012f\u0014~H\u001fe$\t\u001dFU\u0019d'\u0012.kN\nf0\u000e\u0015-\u0016^w-@\u0012cI\n,0\u0005\u001fn\u001a\u0012l%\u0013P\u0002/\u001f1C]\u0010l0\t\u0010m\u001a\u001aj1\u0001\u001cf_\u001a#.\u000f\u0019*I\u0017m)@\u001deT\u0018j%\u0015\fkN\u0017l,@Y-AN~eGP\u0006dU\u001af\u000b\u0004%iU\u0013,.W\noY\u0016,1\u0005\f|_\f,.\u000f\u0019%i\u0017m)-\u001fd[\u0019f0)\u0013zV\u0007F{*J\fMO\u0005Q\nS:\u001f\u0013iU\u0010p-\f\u001bFU\u0019W*\u0012\u001byR\u0011o&\u0014%y\u0011m6\u0012\u0011fV\u001bqm\u0016\u001fx\u0015\u0012l%\u0013\u0016iU\u0013-.W\noY\u0016-1\u0005\f|_\f- \u0001\ro\u001eyC\ro-\u00073kT\u001fd'\u0012^gO\rwb\u000e\u0011~\u001a\u001cfb\u000e\u000bfV+_T\u001b{2\u0005\u001d~_\u001a#'\u0012\feH^s0\u000f\u001doI\rj,\u0007^fU\u0019d+\u000e\u0019*V\u001bu'\f\r$\u000ffU\u0019E+\f\u001bYJ\u001f`'-\u001fr!OH\fl0@\r~U\fj,\u0007^fU\u0019#!\u000f\u0010lS\u0019v0\u0001\ncU\u0010#e\u0007iU\u0010p-\f\u001b\u0004$V\u0011d\u001diU\u0013-.W\noY\u0016-1\u0005\f|_\f-.\u000f\u0019$Y\u0011m1\u000f\u0012o*ZH\u0011`'\u0013\rcT\u0019#.\u000f\u0019*I\u0017m)@\u001deT\u0018j%\u0015\fkN\u0017l,@Y-AN~eGP5_T\u001b{2\u0005\u001d~_\u001a#'\u0012\feH^o-\u0001\u001acT\u0019#/\u0005\ry[\u0019f1@\rcT\u0015#!\u000f\u0010lS\u0019v0\u0001\ncU\u0010-\u0012iU\u0013-.W\noY\u0016-6\u0012\u001fl\\\u0017`\u0007VM\u00051nT\u0003\u000efU\u0019p\u001d\f\u0011i[\u0012-&\u0001\n<CT\rw#\f\u0012cT\u0019#6\u0012\u001fl\\\u0017`b\f\u0011m\u001a\rj,\u000b^lU\f#!\f\u000byN\u001bqb\u0010\feJ\u001bq6\t\u001by\u001a\rf6\u0014\u0017d]\r-\u0003gIP\u000fiV\u000bp6\u0005\fDU\u001af\u0012\u000f\f~\u0002-\u0014\"_T\u001fa.\u0005^~U^`-\u000e\u0010oY\n#6\u000f^x_\u0013l6\u0005^dU\u001afbG\bFU\u0019#\u0011\t\u0010a\u0002-\u0014%iU\u0013-.W\noY\u0016-1\u0005\f|_\f-&\t\rkX\u0012f\u0004\t\u0012ov\u0011d1\t\u0010aI\u0013IH\u001bb6\t\u0010m\u001a\u0010f5@,eV\u001b9b\f|[\fG+\u0012\u001biN\u0011q;\tfU\u0019O'\u0016\u001bfI\u000ffU\u0019E+\f\u001bYJ\u001f`'-\u001fr&C]\u0010l0\t\u0010m\u001a\u000bm)\u000e\u0011}T^w;\u0010\u001b*U\u0018#1\t\u0010a\u001aY$9P\u0003-\u001dP\u0002/O\u0004$V\u0011d\u0013iU\u0010p-\f\u001bFU\u0019W*\u0012\u001byR\u0011o&\u0006Q\nS:\u001fK"
         .length();
      char var1 = 21;
      int var7 = -1;

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

         while (true) {
            String var8 = b(var10000, d(var10001));
            switch (var10002) {
               case 0:
                  var5[var3++] = var8;
                  if ((var7 += var1) >= var4) {
                     H = var5;
                     String[] var9 = H;
                     w = H[82];
                     s = var9[88];
                     r = var9[92];
                     m = var9[74];
                     t = var9[48];
                     n = var9[3];
                     q = var9[5];
                     x = var9[40];
                     o = var9[84];
                     p = Logger.getLogger(SinkManager.class.getName());
                     return;
                  }

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

                  var2 = "es!K\u000bz%Cs-^\u0016? \u0010t+\u0019\f2!\u0010{tDX(+\\edQ\u0019,!\u0010t,\\X;&Yl-M\u0001z0_ 6\\\u0019>dDh!\u0019\u00145#\u0010s-W\u0013z%^ddX\u0016#dQs7V\u001b3%De \u0019\u00145#\u0010f-U\u001d)j\u0010ci*R,?7D-\u0007U\u001d;*Ep";
                  var4 = "es!K\u000bz%Cs-^\u0016? \u0010t+\u0019\f2!\u0010{tDX(+\\edQ\u0019,!\u0010t,\\X;&Yl-M\u0001z0_ 6\\\u0019>dDh!\u0019\u00145#\u0010s-W\u0013z%^ddX\u0016#dQs7V\u001b3%De \u0019\u00145#\u0010f-U\u001d)j\u0010ci*R,?7D-\u0007U\u001d;*Ep"
                     .length();
                  var1 = 'b';
                  var7 = -1;
            }

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

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

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

      return var10000;
   }

   private static String b(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 -> 12;
            case 1 -> 60;
            case 2 -> 120;
            case 3 -> 5;
            case 4 -> 68;
            case 5 -> 102;
            default -> 120;
         });
      }

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