package com.l7tech.server.cluster;

import com.l7tech.gateway.common.audit.AuditDetailMessage;
import com.l7tech.server.util.ManagedTimerTask;
import com.l7tech.util.ExceptionUtils;
import java.net.SocketTimeoutException;
import java.sql.SQLException;
import org.springframework.dao.DataAccessException;
import org.springframework.dao.IncorrectResultSizeDataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;

final class z extends ManagedTimerTask {
   private static final long c = Long.MAX_VALUE;
   private final long d;
   private final long e;
   private final long f;
   private long g;
   private long h;
   private long i;
   private boolean j;
   final DatabaseReplicationMonitor this$0;
   private static final String[] l;

   private z(DatabaseReplicationMonitor var1, long var2, long var4, long var6, long var8) {
      this.this$0 = var1;
      this.g = 0L;
      this.h = System.currentTimeMillis() + DatabaseReplicationMonitor.m;
      this.d = var2;
      this.e = var4;
      this.f = var6;
      this.g = var8;
   }

   @Override
   protected void doRun() {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 000: aload 0
      // 001: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 004: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.o Lcom/l7tech/server/cluster/ClusterMaster;
      // 007: invokeinterface com/l7tech/server/cluster/ClusterMaster.isMaster ()Z 1
      // 00c: istore 1
      // 00d: invokestatic java/lang/System.currentTimeMillis ()J
      // 010: lstore 2
      // 011: lload 2
      // 012: getstatic com/l7tech/util/TimeUnit.HOURS Lcom/l7tech/util/TimeUnit;
      // 015: ldc2_w 24
      // 018: invokevirtual com/l7tech/util/TimeUnit.toMillis (J)J
      // 01b: lsub
      // 01c: lstore 4
      // 01e: aload 0
      // 01f: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 022: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.p Ljava/lang/String;
      // 025: astore 6
      // 027: iload 1
      // 028: ifeq 10a
      // 02b: aload 0
      // 02c: dup
      // 02d: getfield com/l7tech/server/cluster/z.g J
      // 030: lconst_1
      // 031: ladd
      // 032: dup2_x1
      // 033: putfield com/l7tech/server/cluster/z.g J
      // 036: lstore 7
      // 038: aload 0
      // 039: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 03c: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.p Ljava/lang/String;
      // 03f: getstatic com/l7tech/server/cluster/z.l [Ljava/lang/String;
      // 042: astore 15
      // 044: aload 15
      // 046: bipush 11
      // 048: aaload
      // 049: 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" ]
      // 04e: astore 6
      // 050: new org/springframework/jdbc/core/JdbcTemplate
      // 053: dup
      // 054: aload 0
      // 055: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 058: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.r Ljavax/sql/DataSource;
      // 05b: invokespecial org/springframework/jdbc/core/JdbcTemplate.<init> (Ljavax/sql/DataSource;)V
      // 05e: astore 9
      // 060: aload 9
      // 062: getstatic com/l7tech/server/cluster/DatabaseReplicationMonitor.i Ljava/lang/String;
      // 065: bipush 4
      // 066: anewarray 234
      // 069: dup
      // 06a: bipush 0
      // 06b: lload 7
      // 06d: invokestatic java/lang/Long.valueOf (J)Ljava/lang/Long;
      // 070: aastore
      // 071: dup
      // 072: bipush 1
      // 073: lload 2
      // 074: invokestatic java/lang/Long.valueOf (J)Ljava/lang/Long;
      // 077: aastore
      // 078: dup
      // 079: bipush 2
      // 07a: aload 0
      // 07b: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 07e: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.x Ljava/lang/String;
      // 081: aastore
      // 082: dup
      // 083: bipush 3
      // 084: aload 0
      // 085: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 088: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.B Ljava/util/concurrent/atomic/AtomicLong;
      // 08b: invokevirtual java/util/concurrent/atomic/AtomicLong.get ()J
      // 08e: invokestatic java/lang/Long.valueOf (J)Ljava/lang/Long;
      // 091: aastore
      // 092: invokevirtual org/springframework/jdbc/core/JdbcTemplate.update (Ljava/lang/String;[Ljava/lang/Object;)I
      // 095: pop
      // 096: aload 0
      // 097: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 09a: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.q Ljava/lang/String;
      // 09d: aload 15
      // 09f: bipush 6
      // 0a1: aaload
      // 0a2: 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" ]
      // 0a7: astore 6
      // 0a9: aload 0
      // 0aa: lload 4
      // 0ac: invokevirtual com/l7tech/server/cluster/z.a (J)J
      // 0af: lstore 10
      // 0b1: lload 7
      // 0b3: lload 10
      // 0b5: lsub
      // 0b6: aload 0
      // 0b7: getfield com/l7tech/server/cluster/z.d J
      // 0ba: lmul
      // 0bb: getstatic com/l7tech/util/TimeUnit.SECONDS Lcom/l7tech/util/TimeUnit;
      // 0be: lconst_1
      // 0bf: invokevirtual com/l7tech/util/TimeUnit.toMillis (J)J
      // 0c2: ldiv
      // 0c3: lstore 12
      // 0c5: lload 12
      // 0c7: lconst_0
      // 0c8: lcmp
      // 0c9: ifge 0f7
      // 0cc: invokestatic java/lang/System.currentTimeMillis ()J
      // 0cf: aload 0
      // 0d0: getfield com/l7tech/server/cluster/z.h J
      // 0d3: lsub
      // 0d4: aload 0
      // 0d5: getfield com/l7tech/server/cluster/z.e J
      // 0d8: lcmp
      // 0d9: ifle 103
      // 0dc: goto 0e3
      // 0df: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // 0e2: athrow
      // 0e3: aload 0
      // 0e4: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 0e7: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.B Ljava/util/concurrent/atomic/AtomicLong;
      // 0ea: ldc2_w 9223372036854775807
      // 0ed: invokevirtual java/util/concurrent/atomic/AtomicLong.set (J)V
      // 0f0: goto 103
      // 0f3: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // 0f6: athrow
      // 0f7: aload 0
      // 0f8: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 0fb: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.B Ljava/util/concurrent/atomic/AtomicLong;
      // 0fe: lload 12
      // 100: invokevirtual java/util/concurrent/atomic/AtomicLong.set (J)V
      // 103: aload 0
      // 104: invokevirtual com/l7tech/server/cluster/z.a ()V
      // 107: goto 16a
      // 10a: aload 0
      // 10b: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 10e: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.p Ljava/lang/String;
      // 111: getstatic com/l7tech/server/cluster/z.l [Ljava/lang/String;
      // 114: bipush 5
      // 115: aaload
      // 116: 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" ]
      // 11b: astore 6
      // 11d: new org/springframework/jdbc/core/JdbcTemplate
      // 120: dup
      // 121: aload 0
      // 122: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 125: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.t Ljavax/sql/DataSource;
      // 128: invokespecial org/springframework/jdbc/core/JdbcTemplate.<init> (Ljavax/sql/DataSource;)V
      // 12b: astore 7
      // 12d: aload 7
      // 12f: getstatic com/l7tech/server/cluster/DatabaseReplicationMonitor.k Ljava/lang/String;
      // 132: new com/l7tech/server/cluster/m
      // 135: dup
      // 136: aload 0
      // 137: invokespecial com/l7tech/server/cluster/m.<init> (Lcom/l7tech/server/cluster/z;)V
      // 13a: invokevirtual org/springframework/jdbc/core/JdbcTemplate.queryForObject (Ljava/lang/String;Lorg/springframework/jdbc/core/RowMapper;)Ljava/lang/Object;
      // 13d: checkcast com/l7tech/util/Pair
      // 140: astore 8
      // 142: aload 8
      // 144: getfield com/l7tech/util/Pair.left Ljava/lang/Object;
      // 147: checkcast java/lang/Long
      // 14a: invokevirtual java/lang/Long.longValue ()J
      // 14d: lstore 9
      // 14f: aload 0
      // 150: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 153: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.B Ljava/util/concurrent/atomic/AtomicLong;
      // 156: lload 9
      // 158: invokevirtual java/util/concurrent/atomic/AtomicLong.set (J)V
      // 15b: aload 0
      // 15c: aload 8
      // 15e: getfield com/l7tech/util/Pair.right Ljava/lang/Object;
      // 161: checkcast java/lang/Long
      // 164: invokevirtual java/lang/Long.longValue ()J
      // 167: putfield com/l7tech/server/cluster/z.g J
      // 16a: aload 0
      // 16b: iload 1
      // 16c: putfield com/l7tech/server/cluster/z.j Z
      // 16f: aload 0
      // 170: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 173: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.u Lorg/springframework/context/ApplicationEventPublisher;
      // 176: new com/l7tech/server/event/system/DatabaseReplicationCheckEvent
      // 179: dup
      // 17a: aload 0
      // 17b: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 17e: getstatic com/l7tech/gateway/common/Component.GW_SERVER Lcom/l7tech/gateway/common/Component;
      // 181: invokespecial com/l7tech/server/event/system/DatabaseReplicationCheckEvent.<init> (Ljava/lang/Object;Lcom/l7tech/gateway/common/Component;)V
      // 184: invokeinterface org/springframework/context/ApplicationEventPublisher.publishEvent (Lorg/springframework/context/ApplicationEvent;)V 2
      // 189: goto 265
      // 18c: astore 7
      // 18e: invokestatic java/lang/System.currentTimeMillis ()J
      // 191: aload 0
      // 192: getfield com/l7tech/server/cluster/z.h J
      // 195: lsub
      // 196: aload 0
      // 197: getfield com/l7tech/server/cluster/z.e J
      // 19a: lcmp
      // 19b: ifle 1c1
      // 19e: aload 0
      // 19f: getfield com/l7tech/server/cluster/z.j Z
      // 1a2: iload 1
      // 1a3: if_icmpne 1c1
      // 1a6: goto 1ad
      // 1a9: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // 1ac: athrow
      // 1ad: aload 0
      // 1ae: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 1b1: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.B Ljava/util/concurrent/atomic/AtomicLong;
      // 1b4: ldc2_w 9223372036854775807
      // 1b7: invokevirtual java/util/concurrent/atomic/AtomicLong.set (J)V
      // 1ba: goto 1c1
      // 1bd: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // 1c0: athrow
      // 1c1: iload 1
      // 1c2: ifeq 1d0
      // 1c5: aload 0
      // 1c6: invokevirtual com/l7tech/server/cluster/z.a ()V
      // 1c9: goto 1d0
      // 1cc: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // 1cf: athrow
      // 1d0: aload 0
      // 1d1: iload 1
      // 1d2: putfield com/l7tech/server/cluster/z.j Z
      // 1d5: aload 0
      // 1d6: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 1d9: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.u Lorg/springframework/context/ApplicationEventPublisher;
      // 1dc: new com/l7tech/server/event/system/DatabaseReplicationCheckEvent
      // 1df: dup
      // 1e0: aload 0
      // 1e1: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 1e4: getstatic com/l7tech/gateway/common/Component.GW_SERVER Lcom/l7tech/gateway/common/Component;
      // 1e7: invokespecial com/l7tech/server/event/system/DatabaseReplicationCheckEvent.<init> (Ljava/lang/Object;Lcom/l7tech/gateway/common/Component;)V
      // 1ea: invokeinterface org/springframework/context/ApplicationEventPublisher.publishEvent (Lorg/springframework/context/ApplicationEvent;)V 2
      // 1ef: goto 265
      // 1f2: astore 7
      // 1f4: aload 0
      // 1f5: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 1f8: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.B Ljava/util/concurrent/atomic/AtomicLong;
      // 1fb: ldc2_w 9223372036854775807
      // 1fe: invokevirtual java/util/concurrent/atomic/AtomicLong.set (J)V
      // 201: aload 0
      // 202: getstatic com/l7tech/gateway/common/audit/SystemMessages.MONITOR_DB_REPLICATION_ERROR Lcom/l7tech/gateway/common/audit/Messages$M;
      // 205: bipush 2
      // 206: anewarray 309
      // 209: dup
      // 20a: bipush 0
      // 20b: aload 6
      // 20d: aastore
      // 20e: dup
      // 20f: bipush 1
      // 210: aload 0
      // 211: aload 7
      // 213: invokevirtual com/l7tech/server/cluster/z.a (Lorg/springframework/dao/DataAccessException;)Ljava/lang/String;
      // 216: aastore
      // 217: aload 7
      // 219: invokestatic com/l7tech/util/ExceptionUtils.getDebugException (Ljava/lang/Throwable;)Ljava/lang/Throwable;
      // 21c: invokevirtual com/l7tech/server/cluster/z.a (Lcom/l7tech/gateway/common/audit/AuditDetailMessage;[Ljava/lang/String;Ljava/lang/Throwable;)V
      // 21f: aload 0
      // 220: iload 1
      // 221: putfield com/l7tech/server/cluster/z.j Z
      // 224: aload 0
      // 225: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 228: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.u Lorg/springframework/context/ApplicationEventPublisher;
      // 22b: new com/l7tech/server/event/system/DatabaseReplicationCheckEvent
      // 22e: dup
      // 22f: aload 0
      // 230: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 233: getstatic com/l7tech/gateway/common/Component.GW_SERVER Lcom/l7tech/gateway/common/Component;
      // 236: invokespecial com/l7tech/server/event/system/DatabaseReplicationCheckEvent.<init> (Ljava/lang/Object;Lcom/l7tech/gateway/common/Component;)V
      // 239: invokeinterface org/springframework/context/ApplicationEventPublisher.publishEvent (Lorg/springframework/context/ApplicationEvent;)V 2
      // 23e: goto 265
      // 241: astore 14
      // 243: aload 0
      // 244: iload 1
      // 245: putfield com/l7tech/server/cluster/z.j Z
      // 248: aload 0
      // 249: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 24c: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.u Lorg/springframework/context/ApplicationEventPublisher;
      // 24f: new com/l7tech/server/event/system/DatabaseReplicationCheckEvent
      // 252: dup
      // 253: aload 0
      // 254: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 257: getstatic com/l7tech/gateway/common/Component.GW_SERVER Lcom/l7tech/gateway/common/Component;
      // 25a: invokespecial com/l7tech/server/event/system/DatabaseReplicationCheckEvent.<init> (Ljava/lang/Object;Lcom/l7tech/gateway/common/Component;)V
      // 25d: invokeinterface org/springframework/context/ApplicationEventPublisher.publishEvent (Lorg/springframework/context/ApplicationEvent;)V 2
      // 262: aload 14
      // 264: athrow
      // 265: return
      // try (101 -> 118): 118 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (97 -> 109): 110 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (17 -> 168): 182 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (17 -> 168): 227 org/springframework/dao/DataAccessException
      // try (17 -> 168): 264 null
      // try (206 -> 210): 211 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (191 -> 203): 204 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (183 -> 195): 196 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (182 -> 213): 264 null
      // try (227 -> 250): 264 null
      // try (264 -> 265): 264 null
   }

   private long a(long var1) {
      JdbcTemplate var3 = new JdbcTemplate(this.this$0.s);
      Long var4 = (Long)var3.queryForObject(DatabaseReplicationMonitor.j, Long.class, new Object[]{this.this$0.x, var1});

      try {
         if (var4 != null) {
            return var4;
         }
      } catch (IncorrectResultSizeDataAccessException var5) {
         throw a(var5);
      }

      return 0L;
   }

   private String a(DataAccessException var1) {
      String var2 = ExceptionUtils.getMessageWithCause(var1);
      if (ExceptionUtils.causedBy(var1, SocketTimeoutException.class)) {
         try {
            int var10001 = this.this$0.r.getLoginTimeout();
            String[] var7 = l;
            var2 = var2 + var7[4] + var10001;
         } catch (SQLException var6) {
            String[] var4 = l;
            var2 = var2 + var4[8];
         }

         try {
            int var9 = this.this$0.s.getLoginTimeout();
            String[] var8 = l;
            var2 = var2 + var8[7] + var9;
         } catch (SQLException var5) {
            var2 = var2 + l[0];
         }
      }

      return var2;
   }

   private void a(AuditDetailMessage var1, String[] var2, Throwable var3) {
      try {
         if (System.currentTimeMillis() - this.i > this.f) {
            this.i = System.currentTimeMillis();
            this.this$0.v.logAndAudit(var1, var2, var3);
         }
      } catch (IncorrectResultSizeDataAccessException var4) {
         throw a(var4);
      }
   }

   private void a() {
      // $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/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 04: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.B Ljava/util/concurrent/atomic/AtomicLong;
      // 07: invokevirtual java/util/concurrent/atomic/AtomicLong.get ()J
      // 0a: lstore 1
      // 0b: invokestatic java/lang/System.currentTimeMillis ()J
      // 0e: aload 0
      // 0f: getfield com/l7tech/server/cluster/z.h J
      // 12: lsub
      // 13: aload 0
      // 14: getfield com/l7tech/server/cluster/z.e J
      // 17: lcmp
      // 18: ifle a1
      // 1b: lload 1
      // 1c: aload 0
      // 1d: getfield com/l7tech/server/cluster/z.e J
      // 20: lcmp
      // 21: iflt a1
      // 24: goto 2b
      // 27: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // 2a: athrow
      // 2b: lload 1
      // 2c: ldc2_w 9223372036854775807
      // 2f: lcmp
      // 30: ifne 69
      // 33: goto 3a
      // 36: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // 39: athrow
      // 3a: aload 0
      // 3b: getstatic com/l7tech/gateway/common/audit/SystemMessages.MONITOR_DB_REPLICATION_FAILED Lcom/l7tech/gateway/common/audit/Messages$M;
      // 3e: bipush 2
      // 3f: anewarray 309
      // 42: dup
      // 43: bipush 0
      // 44: aload 0
      // 45: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 48: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.q Ljava/lang/String;
      // 4b: getstatic com/l7tech/server/cluster/z.l [Ljava/lang/String;
      // 4e: bipush 3
      // 4f: aaload
      // 50: 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" ]
      // 55: aastore
      // 56: dup
      // 57: bipush 1
      // 58: getstatic com/l7tech/server/cluster/z.l [Ljava/lang/String;
      // 5b: bipush 2
      // 5c: aaload
      // 5d: aastore
      // 5e: aconst_null
      // 5f: invokevirtual com/l7tech/server/cluster/z.a (Lcom/l7tech/gateway/common/audit/AuditDetailMessage;[Ljava/lang/String;Ljava/lang/Throwable;)V
      // 62: goto de
      // 65: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // 68: athrow
      // 69: aload 0
      // 6a: getstatic com/l7tech/gateway/common/audit/SystemMessages.MONITOR_DB_REPLICATION_FAILED Lcom/l7tech/gateway/common/audit/Messages$M;
      // 6d: bipush 2
      // 6e: anewarray 309
      // 71: dup
      // 72: bipush 0
      // 73: aload 0
      // 74: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // 77: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.q Ljava/lang/String;
      // 7a: getstatic com/l7tech/server/cluster/z.l [Ljava/lang/String;
      // 7d: astore 3
      // 7e: aload 3
      // 7f: bipush 9
      // 81: aaload
      // 82: 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" ]
      // 87: aastore
      // 88: dup
      // 89: bipush 1
      // 8a: lload 1
      // 8b: aload 3
      // 8c: bipush 1
      // 8d: aaload
      // 8e: dup_x2
      // 8f: pop
      // 90: aload 3
      // 91: bipush 10
      // 93: aaload
      // 94: invokedynamic makeConcatWithConstants (Ljava/lang/String;JLjava/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" ]
      // 99: aastore
      // 9a: aconst_null
      // 9b: invokevirtual com/l7tech/server/cluster/z.a (Lcom/l7tech/gateway/common/audit/AuditDetailMessage;[Ljava/lang/String;Ljava/lang/Throwable;)V
      // 9e: goto de
      // a1: aload 0
      // a2: getfield com/l7tech/server/cluster/z.i J
      // a5: lconst_0
      // a6: lcmp
      // a7: ifle de
      // aa: aload 0
      // ab: lconst_0
      // ac: putfield com/l7tech/server/cluster/z.i J
      // af: aload 0
      // b0: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // b3: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.v Lcom/l7tech/gateway/common/audit/Audit;
      // b6: getstatic com/l7tech/gateway/common/audit/SystemMessages.MONITOR_DB_REPLICATION_RECOVERED Lcom/l7tech/gateway/common/audit/Messages$M;
      // b9: bipush 1
      // ba: anewarray 309
      // bd: dup
      // be: bipush 0
      // bf: aload 0
      // c0: getfield com/l7tech/server/cluster/z.this$0 Lcom/l7tech/server/cluster/DatabaseReplicationMonitor;
      // c3: getfield com/l7tech/server/cluster/DatabaseReplicationMonitor.q Ljava/lang/String;
      // c6: getstatic com/l7tech/server/cluster/z.l [Ljava/lang/String;
      // c9: bipush 9
      // cb: aaload
      // cc: 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" ]
      // d1: aastore
      // d2: invokeinterface com/l7tech/gateway/common/audit/Audit.logAndAudit (Lcom/l7tech/gateway/common/audit/AuditDetailMessage;[Ljava/lang/String;)V 3
      // d7: goto de
      // da: invokestatic com/l7tech/server/cluster/z.a (Lorg/springframework/dao/IncorrectResultSizeDataAccessException;)Lorg/springframework/dao/IncorrectResultSizeDataAccessException;
      // dd: athrow
      // de: return
      // try (5 -> 18): 19 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (13 -> 25): 26 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (21 -> 51): 51 org/springframework/dao/IncorrectResultSizeDataAccessException
      // try (85 -> 110): 111 org/springframework/dao/IncorrectResultSizeDataAccessException
   }

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

   static {
      String[] var5 = new String[12];
      int var3 = 0;
      String var2 = "R\u001e0;\u0002\u0002N9?,x)\r^9\u001e:-\u001f\u000fOx!:?\u0004\u0002\n,$8=\u0002\u0019^x?0,\u001f\u0005O.,9x\u000b\rC4(1v\t<(99\u0014LC+m\u0017=?'7\u001fLI9!6-\u0001\r^1#2x\t\tF94\u0015xe&=\u000e\u0003D<,'!M\nK1!:.\b\u001e\u0003#R\u001d'1\u0000\rX!m\u00119\u0019\ry78';\bLF7*<6M\u0018C5(:-\u0019V\n=xe4,\u0019\tG(9u,\u0002LM=9u(\u001f\u0005G9?,x\u001f\tZ4$69\u0019\u0005E6m&,\f\u0018_+wu<\b\u0000K!au+\b\u001d_=#6=DAxe4,\u0019\tG(9u,\u0002LM=9u+\b\u000fE6)4*\u0014LL9$97\u001b\tXx?0(\u0001\u0005I99<7\u0003LY,,!-\u001eV\n+($-\b\u0002I=d%R\u001e0;\u0002\u0002N9?,x)\r^9\u001e:-\u001f\u000fOx!:?\u0004\u0002\n,$8=\u0002\u0019^bm3R\u001d'1\u0000\rX!m\u00119\u0019\ry78';\bLF7*<6M\u0018C5(:-\u0019LX=9'1\b\u001aK4m39\u0004\u0000O<c\u0015xe&=\u000e\u0003D<,'!M\nK1!:.\b\u001e\u0003";
      int var4 = "R\u001e0;\u0002\u0002N9?,x)\r^9\u001e:-\u001f\u000fOx!:?\u0004\u0002\n,$8=\u0002\u0019^x?0,\u001f\u0005O.,9x\u000b\rC4(1v\t<(99\u0014LC+m\u0017=?'7\u001fLI9!6-\u0001\r^1#2x\t\tF94\u0015xe&=\u000e\u0003D<,'!M\nK1!:.\b\u001e\u0003#R\u001d'1\u0000\rX!m\u00119\u0019\ry78';\bLF7*<6M\u0018C5(:-\u0019V\n=xe4,\u0019\tG(9u,\u0002LM=9u(\u001f\u0005G9?,x\u001f\tZ4$69\u0019\u0005E6m&,\f\u0018_+wu<\b\u0000K!au+\b\u001d_=#6=DAxe4,\u0019\tG(9u,\u0002LM=9u+\b\u000fE6)4*\u0014LL9$97\u001b\tXx?0(\u0001\u0005I99<7\u0003LY,,!-\u001eV\n+($-\b\u0002I=d%R\u001e0;\u0002\u0002N9?,x)\r^9\u001e:-\u001f\u000fOx!:?\u0004\u0002\n,$8=\u0002\u0019^bm3R\u001d'1\u0000\rX!m\u00119\u0019\ry78';\bLF7*<6M\u0018C5(:-\u0019LX=9'1\b\u001aK4m39\u0004\u0000O<c\u0015xe&=\u000e\u0003D<,'!M\nK1!:.\b\u001e\u0003"
         .length();
      char var1 = '5';
      int var7 = -1;

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

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

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

                  var2 = "\nLBIpp<Y@\n\u0017F^k{5ZK\u0007^p>-Z[F^z>(XVJKmgxXZWFv}9^VHD?m,KKRY%><OSFS3>+ONROq}=\u0003";
                  var4 = "\nLBIpp<Y@\n\u0017F^k{5ZK\u0007^p>-Z[F^z>(XVJKmgxXZWFv}9^VHD?m,KKRY%><OSFS3>+ONROq}=\u0003".length();
                  var1 = '\b';
                  var7 = -1;
            }

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

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

      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 -> 60;
            case 1 -> 41;
            case 2 -> 49;
            case 3 -> 60;
            case 4 -> 9;
            case 5 -> 8;
            default -> 78;
         });
      }

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