public abstract class org.apache.dubbo.registry.support.AbstractRegistry extends java.lang.Object implements org.apache.dubbo.registry.Registry { private static final char URL_SEPARATOR; private static final java.lang.String URL_SPLIT; private static final int MAX_RETRY_TIMES_SAVE_PROPERTIES; protected final org.apache.dubbo.common.logger.Logger logger; private final java.util.Properties properties; private final java.util.concurrent.ExecutorService registryCacheExecutor; private boolean syncSaveFile; private final java.util.concurrent.atomic.AtomicLong lastCacheChanged; private final java.util.concurrent.atomic.AtomicInteger savePropertiesRetryTimes; private final java.util.Set registered; private final java.util.concurrent.ConcurrentMap subscribed; private final java.util.concurrent.ConcurrentMap notified; private org.apache.dubbo.common.URL registryUrl; private java.io.File file; public void (org.apache.dubbo.common.URL) { org.apache.dubbo.common.URL v; java.util.concurrent.atomic.AtomicInteger v; boolean v, v, v, v, v, v; java.util.concurrent.ConcurrentHashMap v, v; java.util.List v; org.apache.dubbo.common.utils.ConcurrentHashSet v; org.apache.dubbo.common.utils.NamedThreadFactory v; java.lang.String v, v, v, v, v, v, v; java.util.concurrent.ExecutorService v; java.util.Properties v; org.apache.dubbo.common.logger.Logger v; java.lang.IllegalArgumentException v; java.io.File v, v, v, v, v, v; java.util.concurrent.atomic.AtomicLong v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Class v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; specialinvoke v.()>(); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v = new java.util.Properties; specialinvoke v.()>(); v. = v; v = new org.apache.dubbo.common.utils.NamedThreadFactory; specialinvoke v.(java.lang.String,boolean)>("DubboSaveRegistryCache", 1); v = staticinvoke (1, v); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v. = v; v = new org.apache.dubbo.common.utils.ConcurrentHashSet; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; virtualinvoke v.(v); v = virtualinvoke v.("file.cache", 1); if v == 0 goto label; v = virtualinvoke v.("save.file", 0); v. = v; v = staticinvoke ("user.home"); v = virtualinvoke v.("application"); v = virtualinvoke v.(); v = virtualinvoke v.(":", "-"); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u0001/.dubbo/dubbo-registry-\u0001-\u.cache"); v = virtualinvoke v.("file", v); v = null; v = staticinvoke (v); if v == 0 goto label; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = v; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Invalid registry cache file \u, cause: Failed to create directory \u0001!"); specialinvoke v.(java.lang.String)>(v); throw v; label: v. = v; specialinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } protected static java.util.List filterEmpty(org.apache.dubbo.common.URL, java.util.List) { java.util.List v; org.apache.dubbo.common.URL v, v; boolean v; java.util.ArrayList v; v := @parameter: org.apache.dubbo.common.URL; v := @parameter: java.util.List; v = staticinvoke (v); if v == 0 goto label; v = new java.util.ArrayList; specialinvoke v.(int)>(1); v = virtualinvoke v.("empty"); interfaceinvoke v.(v); return v; label: return v; } public org.apache.dubbo.common.URL getUrl() { org.apache.dubbo.common.URL v; org.apache.dubbo.registry.support.AbstractRegistry v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; return v; } protected void setUrl(org.apache.dubbo.common.URL) { org.apache.dubbo.common.URL v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.IllegalArgumentException v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("registry url == null"); throw v; label: v. = v; return; } public java.util.Set getRegistered() { java.util.Set v, v; org.apache.dubbo.registry.support.AbstractRegistry v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; v = staticinvoke (v); return v; } public java.util.Map getSubscribed() { org.apache.dubbo.registry.support.AbstractRegistry v; java.util.Map v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; v = staticinvoke (v); return v; } public java.util.Map getNotified() { org.apache.dubbo.registry.support.AbstractRegistry v; java.util.Map v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; v = staticinvoke (v); return v; } public java.io.File getCacheFile() { org.apache.dubbo.registry.support.AbstractRegistry v; java.io.File v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; return v; } public java.util.Properties getCacheProperties() { org.apache.dubbo.registry.support.AbstractRegistry v; java.util.Properties v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; return v; } public java.util.concurrent.atomic.AtomicLong getLastCacheChanged() { java.util.concurrent.atomic.AtomicLong v; org.apache.dubbo.registry.support.AbstractRegistry v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; return v; } public void doSaveProperties(long) { java.io.RandomAccessFile v; java.nio.channels.FileLock v; org.apache.dubbo.registry.support.AbstractRegistry$SaveProperties v; byte v, v; java.util.concurrent.atomic.AtomicInteger v, v, v, v; boolean v, v; java.lang.Throwable v, v, v, v, v; long v, v, v, v; int v; java.lang.String v, v, v, v, v, v, v, v; java.util.concurrent.ExecutorService v; java.util.Properties v; org.apache.dubbo.common.logger.Logger v, v; java.io.FileOutputStream v; java.io.IOException v; java.io.File v, v, v, v, v, v, v; java.util.concurrent.atomic.AtomicLong v, v, v; org.apache.dubbo.registry.support.AbstractRegistry v; java.nio.channels.FileChannel v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; return; label: v = v.; if v != null goto label; return; label: v = new java.io.File; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.lock"); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); label: v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); label: v = virtualinvoke v.(); label: v = virtualinvoke v.(); if v != null goto label; v = new java.io.IOException; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Can not lock the registry cache file \u, ignore and retry later, maybe multi java process use the file, please config: dubbo.registry.file=xxx.properties"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(); label: v = new java.io.FileOutputStream; v = v.; specialinvoke v.(java.io.File)>(v); label: v = v.; virtualinvoke v.(v, "Dubbo Registry Cache"); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v < 3 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to save registry cache file after retrying 3 times, cause: \u0001"); interfaceinvoke v.(v, v); v = v.; virtualinvoke v.(0); return; label: v = v.; v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; v = v.; virtualinvoke v.(0); return; label: v = v.; v = new org.apache.dubbo.registry.support.AbstractRegistry$SaveProperties; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.dubbo.registry.support.AbstractRegistry,long)>(v, v); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to save registry cache file, will retry, cause: \u0001"); interfaceinvoke v.(v, v); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void loadProperties() { java.lang.Throwable v, v; java.lang.String v, v; boolean v, v; java.util.Properties v, v; org.apache.dubbo.common.logger.Logger v, v, v; java.io.FileInputStream v, v; java.io.File v, v, v, v, v; org.apache.dubbo.registry.support.AbstractRegistry v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = new java.io.FileInputStream; v = v.; specialinvoke v.(java.io.File)>(v); v = v.; virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Load registry cache file \u, data: \u0001"); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to load registry cache file \u0001"); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public java.util.List getCacheUrls(org.apache.dubbo.common.URL) { java.lang.String[] v; java.util.ArrayList v; org.apache.dubbo.common.URL v, v; int v, v; java.lang.String v, v, v; boolean v, v, v, v, v; java.util.Properties v; java.util.Iterator v; java.util.Set v; char v, v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v, v, v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(0); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(0); if v != 95 goto label; label: v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("\\s+"); v = new java.util.ArrayList; specialinvoke v.()>(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = staticinvoke (v); interfaceinvoke v.(v); v = v + 1; goto label; label: return v; label: return null; } public java.util.List lookup(org.apache.dubbo.common.URL) { java.util.concurrent.atomic.AtomicReference v; org.apache.dubbo.registry.NotifyListener v; java.util.ArrayList v; org.apache.dubbo.common.URL v; java.util.Map v; java.lang.String v, v, v, v; boolean v, v, v, v, v, v, v; java.util.Iterator v, v, v; java.util.Collection v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v, v, v, v, v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = staticinvoke (v); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = "empty"; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v); goto label; label: v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v); v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = "empty"; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v); goto label; label: return v; } public void register(org.apache.dubbo.common.URL) { org.apache.dubbo.common.logger.Logger v, v; java.util.Set v; java.lang.IllegalArgumentException v; org.apache.dubbo.common.URL v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.String v; boolean v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("register url == null"); throw v; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Register: \u0001"); interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(v); return; } public void unregister(org.apache.dubbo.common.URL) { org.apache.dubbo.common.logger.Logger v, v; java.util.Set v; java.lang.IllegalArgumentException v; org.apache.dubbo.common.URL v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.String v; boolean v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("unregister url == null"); throw v; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unregister: \u0001"); interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(v); return; } public void subscribe(org.apache.dubbo.common.URL, org.apache.dubbo.registry.NotifyListener) { org.apache.dubbo.common.logger.Logger v, v; java.lang.IllegalArgumentException v, v; java.util.function.Function v; org.apache.dubbo.registry.NotifyListener v; java.util.concurrent.ConcurrentMap v; org.apache.dubbo.common.URL v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; v := @parameter: org.apache.dubbo.registry.NotifyListener; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("subscribe url == null"); throw v; label: if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("subscribe listener == null"); throw v; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Subscribe: \u0001"); interfaceinvoke v.(v); label: v = v.; v = staticinvoke (); v = interfaceinvoke v.(v, v); interfaceinvoke v.(v); return; } public void unsubscribe(org.apache.dubbo.common.URL, org.apache.dubbo.registry.NotifyListener) { org.apache.dubbo.common.logger.Logger v, v; java.lang.IllegalArgumentException v, v; org.apache.dubbo.registry.NotifyListener v; java.util.concurrent.ConcurrentMap v, v; org.apache.dubbo.common.URL v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; v := @parameter: org.apache.dubbo.registry.NotifyListener; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("unsubscribe url == null"); throw v; label: if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("unsubscribe listener == null"); throw v; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unsubscribe: \u0001"); interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(v); return; } protected void recover() throws java.lang.Exception { java.util.HashMap v; java.util.HashSet v; java.util.Map v; java.lang.String v, v; boolean v, v, v, v, v, v, v; java.util.Iterator v, v, v; org.apache.dubbo.common.logger.Logger v, v, v, v; java.util.Set v, v, v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v, v, v, v, v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = new java.util.HashSet; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Recover register url \u0001"); interfaceinvoke v.(v); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = new java.util.HashMap; v = virtualinvoke v.(); specialinvoke v.(java.util.Map)>(v); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Recover subscribe url \u0001"); interfaceinvoke v.(v); label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v); goto label; label: return; } protected void notify(java.util.List) { java.lang.Throwable v; java.util.Map v; java.lang.String v, v; boolean v, v, v, v; java.util.Iterator v, v; org.apache.dubbo.common.logger.Logger v; java.util.Set v; java.util.List v, v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v, v, v, v, v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: java.util.List; v = staticinvoke (v); if v == 0 goto label; return; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(0); v = staticinvoke (v, v); if v == 0 goto label; v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: v = staticinvoke (v, v); virtualinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to notify registry event, urls: \u, cause: \u0001"); interfaceinvoke v.(v, v); goto label; label: return; catch java.lang.Throwable from label to label with label; } protected void notify(org.apache.dubbo.common.URL, org.apache.dubbo.registry.NotifyListener, java.util.List) { org.apache.dubbo.common.URL v; boolean v, v, v, v, v, v; java.util.Set v; java.util.List v; java.util.HashMap v; java.util.function.Function v, v; org.apache.dubbo.registry.NotifyListener v; java.util.concurrent.ConcurrentMap v; int v; java.lang.String v, v, v, v, v; java.util.Iterator v, v; org.apache.dubbo.common.logger.Logger v, v, v; java.lang.IllegalArgumentException v, v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v, v, v, v, v, v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; v := @parameter: org.apache.dubbo.registry.NotifyListener; v := @parameter: java.util.List; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("notify url == null"); throw v; label: if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("notify listener == null"); throw v; label: v = staticinvoke (v); if v == 0 goto label; v = "*"; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Ignore empty notify urls for subscribe url \u0001"); interfaceinvoke v.(v); return; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Notify urls for subscribe url \u, urls: \u0001"); interfaceinvoke v.(v); label: v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); if v == 0 goto label; v = virtualinvoke v.("category", "providers"); v = staticinvoke (); v = interfaceinvoke v.(v, v); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v != 0 goto label; return; label: v = v.; v = staticinvoke (); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(v); specialinvoke v.(v); goto label; label: return; } private void saveProperties(org.apache.dubbo.common.URL) { java.lang.Throwable v; long v; java.util.concurrent.ConcurrentMap v; org.apache.dubbo.registry.support.AbstractRegistry$SaveProperties v; org.apache.dubbo.common.URL v; int v; java.lang.String v, v, v, v; java.util.concurrent.ExecutorService v; boolean v, v, v; java.util.Properties v; java.util.Iterator v, v; org.apache.dubbo.common.logger.Logger v; java.util.Collection v; java.io.File v; java.util.concurrent.atomic.AtomicLong v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v, v, v; java.lang.StringBuilder v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v := @parameter: org.apache.dubbo.common.URL; v = v.; if v != null goto label; return; label: v = new java.lang.StringBuilder; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v <= 0 goto label; virtualinvoke v.(32); label: v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = v.; if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = v.; v = new org.apache.dubbo.registry.support.AbstractRegistry$SaveProperties; specialinvoke v.(org.apache.dubbo.registry.support.AbstractRegistry,long)>(v, v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: return; catch java.lang.Throwable from label to label with label; } public void destroy() { org.apache.dubbo.common.URL v, v, v; java.util.Map v; boolean v, v, v, v, v, v, v, v, v; java.util.Set v, v, v; java.lang.Throwable v, v; java.util.HashMap v; java.util.HashSet v, v; java.lang.String v, v, v, v, v, v, v; java.util.Iterator v, v, v; org.apache.dubbo.common.logger.Logger v, v, v, v, v, v, v, v; org.apache.dubbo.registry.support.AbstractRegistry v; java.lang.Object v, v, v, v, v; v := @this: org.apache.dubbo.registry.support.AbstractRegistry; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Destroy registry:\u0001"); interfaceinvoke v.(v); label: v = new java.util.HashSet; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); if v != 0 goto label; v = new java.util.HashSet; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.("dynamic", 1); if v == 0 goto label; label: virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Destroy unregister url \u0001"); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Failed to unregister url \u to registry \u on destroy, cause: \u0001"); interfaceinvoke v.(v, v); goto label; label: v = new java.util.HashMap; v = virtualinvoke v.(); specialinvoke v.(java.util.Map)>(v); v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Destroy unsubscribe url \u0001"); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Failed to unsubscribe url \u to registry \u on destroy, cause: \u0001"); interfaceinvoke v.(v, v); goto label; label: staticinvoke