/* * Decompiled with CFR 0.152. * * Could not load the following classes: * com.l7tech.util.Config * com.l7tech.util.ConfigFactory * com.l7tech.util.ExceptionUtils * com.l7tech.util.Triple * org.springframework.dao.DataAccessException * org.springframework.jdbc.core.JdbcTemplate * org.springframework.jdbc.core.RowMapper * org.springframework.transaction.PlatformTransactionManager * org.springframework.transaction.TransactionException * org.springframework.transaction.support.TransactionCallback * org.springframework.transaction.support.TransactionTemplate */ package com.l7tech.server.cluster; import com.l7tech.server.cluster.ClusterMaster; import com.l7tech.server.cluster.i; import com.l7tech.server.cluster.j; import com.l7tech.util.Config; import com.l7tech.util.ConfigFactory; import com.l7tech.util.ExceptionUtils; import com.l7tech.util.Triple; import java.sql.SQLException; import java.util.Timer; import java.util.TimerTask; import java.util.concurrent.atomic.AtomicBoolean; import java.util.logging.Level; import java.util.logging.Logger; import javax.sql.DataSource; import org.springframework.dao.DataAccessException; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.RowMapper; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.TransactionException; import org.springframework.transaction.support.TransactionCallback; import org.springframework.transaction.support.TransactionTemplate; public class ClusterMasterImpl implements ClusterMaster { private static final Logger a; private static final long b; private static final long c; private final AtomicBoolean d = new AtomicBoolean(false); public ClusterMasterImpl(PlatformTransactionManager platformTransactionManager, DataSource dataSource, Config config, Timer timer, String string) { timer.schedule((TimerTask)new MasterCheckTask(platformTransactionManager, dataSource, config, this.d, string), 0L, b); } @Override public boolean isMaster() { return this.d.get(); } /* * Enabled aggressive block sorting */ static { String[] stringArray = new String[2]; int n2 = 0; String string = "|:'\u00020-6z6\"\u0002/\u007f0i08\u0002?v7l!/^rw#l!/^\bs/z:?X(|:'\u00020-6z6\"\u0002/\u007f0i08\u0002?v7l!/^rw#l!/^\u0015t6z'= n3) { a = Logger.getLogger(ClusterMasterImpl.class.getName()); b = ConfigFactory.getLongProperty((String)stringArray[1], (long)10000L); c = ConfigFactory.getLongProperty((String)stringArray[0], (long)40000L); return; } n4 = string.charAt(n5); } } private static char[] a(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0x22); } return cArray; } /* * Handled impossible loop by duplicating code * Enabled aggressive block sorting */ private static String a(int n2, char[] cArray) { char[] cArray2; block11: { int n3; int n4; int n5; block10: { n5 = n2; cArray2 = cArray; n4 = cArray.length; n3 = 0; if (!true) break block10; n4 = n4; if (n4 <= n3) break block11; } do { n5 = n5; cArray2 = cArray2; int n6 = n3; cArray2[n6] = (char)(cArray2[n6] ^ (n5 ^ (switch (n3 % 7) { case 0 -> 127; case 1 -> 53; case 2 -> 42; case 3 -> 76; case 4 -> 60; case 5 -> 122; default -> 34; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } private static final class MasterCheckTask extends TimerTask { private final Config a; private final PlatformTransactionManager b; private final JdbcTemplate c; private final AtomicBoolean d; private final String e; private static final String[] f; MasterCheckTask(PlatformTransactionManager platformTransactionManager, DataSource dataSource, Config config, AtomicBoolean atomicBoolean, String string) { this.a = config; this.b = platformTransactionManager; this.c = new JdbcTemplate(dataSource); this.d = atomicBoolean; this.e = string; } @Override public void run() { block16: { block17: { boolean bl2 = this.d.get(); TransactionTemplate transactionTemplate = new TransactionTemplate(this.b); try { Boolean bl3 = (Boolean)transactionTemplate.execute((TransactionCallback)new i(this)); try { if (bl3 != null) { this.d.set(bl3); } } catch (TransactionException transactionException) { throw MasterCheckTask.a(transactionException); } } catch (TransactionException transactionException) { String[] stringArray = f; a.log(Level.FINE, stringArray[3] + ExceptionUtils.getMessage((Throwable)transactionException) + stringArray[9], ExceptionUtils.getDebugException((Throwable)transactionException)); } catch (DataAccessException dataAccessException) { block15: { SQLException sQLException = (SQLException)ExceptionUtils.getCauseIfCausedBy((Throwable)dataAccessException, SQLException.class); try { try { if (sQLException == null || sQLException.getErrorCode() != 1317) break block15; } catch (TransactionException transactionException) { throw MasterCheckTask.a(transactionException); } a.log(Level.FINE, f[2] + ExceptionUtils.getMessage((Throwable)sQLException) + f[1], ExceptionUtils.getDebugException((Throwable)sQLException)); } catch (TransactionException transactionException) { throw MasterCheckTask.a(transactionException); } } String[] stringArray = f; a.log(Level.WARNING, stringArray[8], dataAccessException); } try { try { if (bl2 == this.d.get()) break block16; if (!bl2) break block17; } catch (TransactionException transactionException) { throw MasterCheckTask.a(transactionException); } a.info(f[4]); break block16; } catch (TransactionException transactionException) { throw MasterCheckTask.a(transactionException); } } a.info(f[6]); } } public boolean updateMasterTimestamp(int n2) { boolean bl2; try { bl2 = 1 == this.c.update(f[0], new Object[]{System.currentTimeMillis(), n2 + 1, n2}); } catch (TransactionException transactionException) { throw MasterCheckTask.a(transactionException); } return bl2; } public boolean isMasterStale(long l2) { boolean bl2; try { bl2 = System.currentTimeMillis() - l2 > c; } catch (TransactionException transactionException) { throw MasterCheckTask.a(transactionException); } return bl2; } public MasterInfo getMasterInfo() { return (MasterInfo)((Object)this.c.queryForObject(f[7], (RowMapper)new j(this))); } public boolean becomeMaster(int n2) { boolean bl2; try { bl2 = 1 == this.c.update(f[5], new Object[]{this.e, System.currentTimeMillis(), n2 + 1, n2}); } catch (TransactionException transactionException) { throw MasterCheckTask.a(transactionException); } return bl2; } private static TransactionException a(TransactionException transactionException) { return transactionException; } /* * Unable to fully structure code */ static { block10: { block9: { var5 = new String[10]; var3_1 = 0; var2_2 = "c\u001eR\u0015L\u007fSU\"c'l_\u0001i#w'l_\u0001\u0016\u001dS\u00008N\u001cC-~1|e\u0007_#si'\u0016S@+d'qU\u001d\u000bq6\u0003P\u007f!sn`1jI\u001aY 6i8\u0005\u0002\u0011`\r\u007f b1jH\u0006F:s08\u001d\u001bb 17; case 1 -> 105; case 2 -> 49; case 3 -> 115; case 4 -> 63; case 5 -> 29; default -> 84; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } private static class MasterInfo extends Triple { static final long serialVersionUID = -8226327523357831605L; MasterInfo(String string, Long l2, Integer n2) { super((Object)string, (Object)l2, (Object)n2); } public String getMasterNodeId() { return (String)this.left; } public long getTimestamp() { return (Long)this.middle; } public int getVersion() { return (Integer)this.right; } } } }