:star:HEADmain

1 files changed, 955 insertions, 0 deletions

diff --git a/NET/worlds/network/Cache.java b/NET/worlds/network/Cache.java
new file mode 100644
index 0000000..7a2f3e9
--- /dev/null
+++ b/NET/worlds/network/Cache.java
@@ -0,0 +1,955 @@
+/*     */ package NET.worlds.network;
+/*     */ 
+/*     */ import NET.worlds.console.Gamma;
+/*     */ import NET.worlds.console.Main;
+/*     */ import NET.worlds.console.MainCallback;
+/*     */ import NET.worlds.console.MainTerminalCallback;
+/*     */ import NET.worlds.core.IniFile;
+/*     */ import NET.worlds.core.Std;
+/*     */ import java.io.File;
+/*     */ import java.io.FileOutputStream;
+/*     */ import java.io.IOException;
+/*     */ import java.io.InputStream;
+/*     */ import java.io.ObjectOutputStream;
+/*     */ import java.io.PrintStream;
+/*     */ import java.io.Serializable;
+/*     */ import java.util.Collection;
+/*     */ import java.util.Date;
+/*     */ import java.util.Enumeration;
+/*     */ import java.util.Hashtable;
+/*     */ import java.util.Iterator;
+/*     */ import java.util.Vector;
+/*     */ import java.util.zip.ZipEntry;
+/*     */ import java.util.zip.ZipFile;
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ public class Cache
+/*     */   implements MainCallback, MainTerminalCallback, Serializable
+/*     */ {
+/*     */   private static final long serialVersionUID = -7557149391688293661L;
+/*     */   private static final long CACHE_VERSION = 0L;
+/*  56 */   private static String CACHE_DIR = Gamma.earlyURLUnalias("home:cachedir/")
+/*  57 */     .replace('/', '\\');
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*  63 */   static final int CACHE_MIN_CHANGE = IniFile.gamma().getIniInt("NetCacheMinChange", 50);
+/*     */   
+/*     */ 
+/*  66 */   static final long CACHE_MAX_DELAY = IniFile.gamma().getIniInt("NetCacheMaxDelay", 5) * 1000L * 60L;
+/*  67 */   private Date lastCacheSave = new Date();
+/*     */   
+/*     */ 
+/*  70 */   static transient Cache cache = initLoad();
+/*     */   
+/*  72 */   private transient Hashtable<Object, CacheEntry> table = new Hashtable();
+/*     */   
+/*     */ 
+/*     */ 
+/*  76 */   private transient CacheEntry terminator = new CacheEntry();
+/*     */   
+/*     */   transient long totalBytes;
+/*     */   
+/*     */   transient int hasChanged;
+/*     */   
+/*  82 */   private int nextAvailable = 1;
+/*     */   
+/*     */   public static void ClearCustomAvatars()
+/*     */   {
+/*  86 */     Collection<CacheEntry> c = cache.table.values();
+/*     */     
+/*  88 */     Iterator<CacheEntry> it = c.iterator();
+/*     */     
+/*  90 */     Vector<CacheEntry> tmp = new Vector();
+/*     */     
+/*  92 */     while (it.hasNext())
+/*     */     {
+/*  94 */       CacheEntry ce = (CacheEntry)it.next();
+/*  95 */       if ((ce != null) && (ce.url.toString().contains("custom")))
+/*     */       {
+/*  97 */         tmp.add(ce);
+/*     */       }
+/*     */     }
+/*     */     
+/* 101 */     for (int i = 0; i < tmp.size(); i++) {
+/* 102 */       removeEntry((CacheEntry)tmp.get(i));
+/*     */     }
+/*     */   }
+/*     */   
+/*     */   /* Error */
+/*     */   static Cache initLoad()
+/*     */   {
+/*     */     // Byte code:
+/*     */     //   0: getstatic 163	java/lang/System:out	Ljava/io/PrintStream;
+/*     */     //   3: ldc -87
+/*     */     //   5: invokevirtual 171	java/io/PrintStream:println	(Ljava/lang/String;)V
+/*     */     //   8: new 1	NET/worlds/network/Cache
+/*     */     //   11: dup
+/*     */     //   12: invokespecial 177	NET/worlds/network/Cache:<init>	()V
+/*     */     //   15: astore_0
+/*     */     //   16: aconst_null
+/*     */     //   17: astore_1
+/*     */     //   18: aconst_null
+/*     */     //   19: astore_2
+/*     */     //   20: getstatic 163	java/lang/System:out	Ljava/io/PrintStream;
+/*     */     //   23: ldc -78
+/*     */     //   25: invokevirtual 171	java/io/PrintStream:println	(Ljava/lang/String;)V
+/*     */     //   28: new 180	java/io/File
+/*     */     //   31: dup
+/*     */     //   32: new 182	java/lang/StringBuilder
+/*     */     //   35: dup
+/*     */     //   36: getstatic 54	NET/worlds/network/Cache:CACHE_DIR	Ljava/lang/String;
+/*     */     //   39: invokestatic 184	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
+/*     */     //   42: invokespecial 188	java/lang/StringBuilder:<init>	(Ljava/lang/String;)V
+/*     */     //   45: ldc -66
+/*     */     //   47: invokevirtual 192	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
+/*     */     //   50: invokevirtual 196	java/lang/StringBuilder:toString	()Ljava/lang/String;
+/*     */     //   53: invokespecial 197	java/io/File:<init>	(Ljava/lang/String;)V
+/*     */     //   56: astore_3
+/*     */     //   57: aload_3
+/*     */     //   58: invokevirtual 198	java/io/File:exists	()Z
+/*     */     //   61: ifne +68 -> 129
+/*     */     //   64: new 180	java/io/File
+/*     */     //   67: dup
+/*     */     //   68: new 182	java/lang/StringBuilder
+/*     */     //   71: dup
+/*     */     //   72: getstatic 54	NET/worlds/network/Cache:CACHE_DIR	Ljava/lang/String;
+/*     */     //   75: invokestatic 184	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
+/*     */     //   78: invokespecial 188	java/lang/StringBuilder:<init>	(Ljava/lang/String;)V
+/*     */     //   81: ldc -55
+/*     */     //   83: invokevirtual 192	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
+/*     */     //   86: invokevirtual 196	java/lang/StringBuilder:toString	()Ljava/lang/String;
+/*     */     //   89: invokespecial 197	java/io/File:<init>	(Ljava/lang/String;)V
+/*     */     //   92: astore_3
+/*     */     //   93: aload_3
+/*     */     //   94: invokevirtual 198	java/io/File:exists	()Z
+/*     */     //   97: ifne +32 -> 129
+/*     */     //   100: new 180	java/io/File
+/*     */     //   103: dup
+/*     */     //   104: new 182	java/lang/StringBuilder
+/*     */     //   107: dup
+/*     */     //   108: getstatic 54	NET/worlds/network/Cache:CACHE_DIR	Ljava/lang/String;
+/*     */     //   111: invokestatic 184	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
+/*     */     //   114: invokespecial 188	java/lang/StringBuilder:<init>	(Ljava/lang/String;)V
+/*     */     //   117: ldc -53
+/*     */     //   119: invokevirtual 192	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
+/*     */     //   122: invokevirtual 196	java/lang/StringBuilder:toString	()Ljava/lang/String;
+/*     */     //   125: invokespecial 197	java/io/File:<init>	(Ljava/lang/String;)V
+/*     */     //   128: astore_3
+/*     */     //   129: new 205	java/io/FileInputStream
+/*     */     //   132: dup
+/*     */     //   133: aload_3
+/*     */     //   134: invokespecial 207	java/io/FileInputStream:<init>	(Ljava/io/File;)V
+/*     */     //   137: astore_1
+/*     */     //   138: new 210	java/io/ObjectInputStream
+/*     */     //   141: dup
+/*     */     //   142: aload_1
+/*     */     //   143: invokespecial 212	java/io/ObjectInputStream:<init>	(Ljava/io/InputStream;)V
+/*     */     //   146: astore_2
+/*     */     //   147: aload_2
+/*     */     //   148: invokevirtual 215	java/io/ObjectInputStream:readLong	()J
+/*     */     //   151: lstore 4
+/*     */     //   153: lload 4
+/*     */     //   155: lconst_0
+/*     */     //   156: lcmp
+/*     */     //   157: ifeq +13 -> 170
+/*     */     //   160: new 219	java/lang/Exception
+/*     */     //   163: dup
+/*     */     //   164: ldc -35
+/*     */     //   166: invokespecial 223	java/lang/Exception:<init>	(Ljava/lang/String;)V
+/*     */     //   169: athrow
+/*     */     //   170: aload_2
+/*     */     //   171: invokevirtual 224	java/io/ObjectInputStream:readObject	()Ljava/lang/Object;
+/*     */     //   174: checkcast 1	NET/worlds/network/Cache
+/*     */     //   177: astore_0
+/*     */     //   178: aload_0
+/*     */     //   179: new 112	NET/worlds/network/CacheEntry
+/*     */     //   182: dup
+/*     */     //   183: invokespecial 227	NET/worlds/network/CacheEntry:<init>	()V
+/*     */     //   186: putfield 228	NET/worlds/network/Cache:terminator	LNET/worlds/network/CacheEntry;
+/*     */     //   189: aload_0
+/*     */     //   190: new 90	java/util/Hashtable
+/*     */     //   193: dup
+/*     */     //   194: invokespecial 230	java/util/Hashtable:<init>	()V
+/*     */     //   197: putfield 87	NET/worlds/network/Cache:table	Ljava/util/Hashtable;
+/*     */     //   200: goto +55 -> 255
+/*     */     //   203: aload 6
+/*     */     //   205: instanceof 112
+/*     */     //   208: ifeq +57 -> 265
+/*     */     //   211: aload 6
+/*     */     //   213: checkcast 112	NET/worlds/network/CacheEntry
+/*     */     //   216: getfield 114	NET/worlds/network/CacheEntry:url	LNET/worlds/network/URL;
+/*     */     //   219: ifnull +36 -> 255
+/*     */     //   222: aload 6
+/*     */     //   224: checkcast 112	NET/worlds/network/CacheEntry
+/*     */     //   227: getfield 231	NET/worlds/network/CacheEntry:localName	Ljava/lang/String;
+/*     */     //   230: ifnull +25 -> 255
+/*     */     //   233: aload 6
+/*     */     //   235: checkcast 112	NET/worlds/network/CacheEntry
+/*     */     //   238: getfield 234	NET/worlds/network/CacheEntry:state	I
+/*     */     //   241: bipush 7
+/*     */     //   243: if_icmplt +12 -> 255
+/*     */     //   246: aload_0
+/*     */     //   247: aload 6
+/*     */     //   249: checkcast 112	NET/worlds/network/CacheEntry
+/*     */     //   252: invokevirtual 237	NET/worlds/network/Cache:add	(LNET/worlds/network/CacheEntry;)V
+/*     */     //   255: aload_2
+/*     */     //   256: invokevirtual 224	java/io/ObjectInputStream:readObject	()Ljava/lang/Object;
+/*     */     //   259: dup
+/*     */     //   260: astore 6
+/*     */     //   262: ifnonnull -59 -> 203
+/*     */     //   265: aload_2
+/*     */     //   266: invokevirtual 239	java/io/ObjectInputStream:close	()V
+/*     */     //   269: aconst_null
+/*     */     //   270: astore_2
+/*     */     //   271: aload_1
+/*     */     //   272: invokevirtual 242	java/io/FileInputStream:close	()V
+/*     */     //   275: aconst_null
+/*     */     //   276: astore_1
+/*     */     //   277: getstatic 163	java/lang/System:out	Ljava/io/PrintStream;
+/*     */     //   280: ldc -13
+/*     */     //   282: invokevirtual 171	java/io/PrintStream:println	(Ljava/lang/String;)V
+/*     */     //   285: goto +163 -> 448
+/*     */     //   288: astore_3
+/*     */     //   289: aload_2
+/*     */     //   290: ifnull +14 -> 304
+/*     */     //   293: aload_2
+/*     */     //   294: invokevirtual 239	java/io/ObjectInputStream:close	()V
+/*     */     //   297: goto +5 -> 302
+/*     */     //   300: astore 8
+/*     */     //   302: aconst_null
+/*     */     //   303: astore_2
+/*     */     //   304: aload_1
+/*     */     //   305: ifnull +173 -> 478
+/*     */     //   308: aload_1
+/*     */     //   309: invokevirtual 242	java/io/FileInputStream:close	()V
+/*     */     //   312: goto +5 -> 317
+/*     */     //   315: astore 8
+/*     */     //   317: aconst_null
+/*     */     //   318: astore_1
+/*     */     //   319: goto +159 -> 478
+/*     */     //   322: astore_3
+/*     */     //   323: getstatic 163	java/lang/System:out	Ljava/io/PrintStream;
+/*     */     //   326: aload_3
+/*     */     //   327: invokevirtual 245	java/io/PrintStream:println	(Ljava/lang/Object;)V
+/*     */     //   330: getstatic 163	java/lang/System:out	Ljava/io/PrintStream;
+/*     */     //   333: ldc -8
+/*     */     //   335: invokevirtual 171	java/io/PrintStream:println	(Ljava/lang/String;)V
+/*     */     //   338: new 180	java/io/File
+/*     */     //   341: dup
+/*     */     //   342: new 182	java/lang/StringBuilder
+/*     */     //   345: dup
+/*     */     //   346: getstatic 54	NET/worlds/network/Cache:CACHE_DIR	Ljava/lang/String;
+/*     */     //   349: invokestatic 184	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
+/*     */     //   352: invokespecial 188	java/lang/StringBuilder:<init>	(Ljava/lang/String;)V
+/*     */     //   355: ldc -66
+/*     */     //   357: invokevirtual 192	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
+/*     */     //   360: invokevirtual 196	java/lang/StringBuilder:toString	()Ljava/lang/String;
+/*     */     //   363: invokespecial 197	java/io/File:<init>	(Ljava/lang/String;)V
+/*     */     //   366: astore 4
+/*     */     //   368: aload 4
+/*     */     //   370: invokevirtual 250	java/io/File:mkdirs	()Z
+/*     */     //   373: pop
+/*     */     //   374: aload 4
+/*     */     //   376: invokevirtual 253	java/io/File:delete	()Z
+/*     */     //   379: pop
+/*     */     //   380: aload_2
+/*     */     //   381: ifnull +14 -> 395
+/*     */     //   384: aload_2
+/*     */     //   385: invokevirtual 239	java/io/ObjectInputStream:close	()V
+/*     */     //   388: goto +5 -> 393
+/*     */     //   391: astore 8
+/*     */     //   393: aconst_null
+/*     */     //   394: astore_2
+/*     */     //   395: aload_1
+/*     */     //   396: ifnull +82 -> 478
+/*     */     //   399: aload_1
+/*     */     //   400: invokevirtual 242	java/io/FileInputStream:close	()V
+/*     */     //   403: goto +5 -> 408
+/*     */     //   406: astore 8
+/*     */     //   408: aconst_null
+/*     */     //   409: astore_1
+/*     */     //   410: goto +68 -> 478
+/*     */     //   413: astore 7
+/*     */     //   415: aload_2
+/*     */     //   416: ifnull +14 -> 430
+/*     */     //   419: aload_2
+/*     */     //   420: invokevirtual 239	java/io/ObjectInputStream:close	()V
+/*     */     //   423: goto +5 -> 428
+/*     */     //   426: astore 8
+/*     */     //   428: aconst_null
+/*     */     //   429: astore_2
+/*     */     //   430: aload_1
+/*     */     //   431: ifnull +14 -> 445
+/*     */     //   434: aload_1
+/*     */     //   435: invokevirtual 242	java/io/FileInputStream:close	()V
+/*     */     //   438: goto +5 -> 443
+/*     */     //   441: astore 8
+/*     */     //   443: aconst_null
+/*     */     //   444: astore_1
+/*     */     //   445: aload 7
+/*     */     //   447: athrow
+/*     */     //   448: aload_2
+/*     */     //   449: ifnull +14 -> 463
+/*     */     //   452: aload_2
+/*     */     //   453: invokevirtual 239	java/io/ObjectInputStream:close	()V
+/*     */     //   456: goto +5 -> 461
+/*     */     //   459: astore 8
+/*     */     //   461: aconst_null
+/*     */     //   462: astore_2
+/*     */     //   463: aload_1
+/*     */     //   464: ifnull +14 -> 478
+/*     */     //   467: aload_1
+/*     */     //   468: invokevirtual 242	java/io/FileInputStream:close	()V
+/*     */     //   471: goto +5 -> 476
+/*     */     //   474: astore 8
+/*     */     //   476: aconst_null
+/*     */     //   477: astore_1
+/*     */     //   478: new 180	java/io/File
+/*     */     //   481: dup
+/*     */     //   482: getstatic 54	NET/worlds/network/Cache:CACHE_DIR	Ljava/lang/String;
+/*     */     //   485: invokespecial 197	java/io/File:<init>	(Ljava/lang/String;)V
+/*     */     //   488: invokevirtual 256	java/io/File:list	()[Ljava/lang/String;
+/*     */     //   491: astore_3
+/*     */     //   492: new 90	java/util/Hashtable
+/*     */     //   495: dup
+/*     */     //   496: invokespecial 230	java/util/Hashtable:<init>	()V
+/*     */     //   499: astore 4
+/*     */     //   501: aload_3
+/*     */     //   502: ifnull +84 -> 586
+/*     */     //   505: iconst_0
+/*     */     //   506: istore 5
+/*     */     //   508: goto +41 -> 549
+/*     */     //   511: aload 4
+/*     */     //   513: new 182	java/lang/StringBuilder
+/*     */     //   516: dup
+/*     */     //   517: getstatic 54	NET/worlds/network/Cache:CACHE_DIR	Ljava/lang/String;
+/*     */     //   520: invokestatic 184	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
+/*     */     //   523: invokespecial 188	java/lang/StringBuilder:<init>	(Ljava/lang/String;)V
+/*     */     //   526: aload_3
+/*     */     //   527: iload 5
+/*     */     //   529: aaload
+/*     */     //   530: invokevirtual 192	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
+/*     */     //   533: invokevirtual 196	java/lang/StringBuilder:toString	()Ljava/lang/String;
+/*     */     //   536: invokevirtual 260	java/lang/String:toUpperCase	()Ljava/lang/String;
+/*     */     //   539: ldc_w 263
+/*     */     //   542: invokevirtual 265	java/util/Hashtable:put	(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
+/*     */     //   545: pop
+/*     */     //   546: iinc 5 1
+/*     */     //   549: iload 5
+/*     */     //   551: aload_3
+/*     */     //   552: arraylength
+/*     */     //   553: if_icmplt -42 -> 511
+/*     */     //   556: aload 4
+/*     */     //   558: new 182	java/lang/StringBuilder
+/*     */     //   561: dup
+/*     */     //   562: getstatic 54	NET/worlds/network/Cache:CACHE_DIR	Ljava/lang/String;
+/*     */     //   565: invokestatic 184	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
+/*     */     //   568: invokespecial 188	java/lang/StringBuilder:<init>	(Ljava/lang/String;)V
+/*     */     //   571: ldc -66
+/*     */     //   573: invokevirtual 192	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
+/*     */     //   576: invokevirtual 196	java/lang/StringBuilder:toString	()Ljava/lang/String;
+/*     */     //   579: invokevirtual 260	java/lang/String:toUpperCase	()Ljava/lang/String;
+/*     */     //   582: invokevirtual 269	java/util/Hashtable:remove	(Ljava/lang/Object;)Ljava/lang/Object;
+/*     */     //   585: pop
+/*     */     //   586: aload_0
+/*     */     //   587: lconst_0
+/*     */     //   588: putfield 273	NET/worlds/network/Cache:totalBytes	J
+/*     */     //   591: aload_0
+/*     */     //   592: iconst_0
+/*     */     //   593: putfield 275	NET/worlds/network/Cache:hasChanged	I
+/*     */     //   596: aload_0
+/*     */     //   597: getfield 228	NET/worlds/network/Cache:terminator	LNET/worlds/network/CacheEntry;
+/*     */     //   600: getfield 277	NET/worlds/network/CacheEntry:next	LNET/worlds/network/CacheEntry;
+/*     */     //   603: astore 5
+/*     */     //   605: goto +101 -> 706
+/*     */     //   608: aload 5
+/*     */     //   610: astore 6
+/*     */     //   612: aload 5
+/*     */     //   614: getfield 277	NET/worlds/network/CacheEntry:next	LNET/worlds/network/CacheEntry;
+/*     */     //   617: astore 5
+/*     */     //   619: aload 6
+/*     */     //   621: getfield 231	NET/worlds/network/CacheEntry:localName	Ljava/lang/String;
+/*     */     //   624: invokevirtual 260	java/lang/String:toUpperCase	()Ljava/lang/String;
+/*     */     //   627: astore 7
+/*     */     //   629: aload 4
+/*     */     //   631: aload 7
+/*     */     //   633: invokevirtual 279	java/util/Hashtable:get	(Ljava/lang/Object;)Ljava/lang/Object;
+/*     */     //   636: ifnull +7 -> 643
+/*     */     //   639: iconst_1
+/*     */     //   640: goto +4 -> 644
+/*     */     //   643: iconst_0
+/*     */     //   644: istore 8
+/*     */     //   646: aload 4
+/*     */     //   648: aload 7
+/*     */     //   650: invokevirtual 269	java/util/Hashtable:remove	(Ljava/lang/Object;)Ljava/lang/Object;
+/*     */     //   653: pop
+/*     */     //   654: aload_0
+/*     */     //   655: dup
+/*     */     //   656: getfield 273	NET/worlds/network/Cache:totalBytes	J
+/*     */     //   659: aload 6
+/*     */     //   661: getfield 281	NET/worlds/network/CacheEntry:bytes	I
+/*     */     //   664: i2l
+/*     */     //   665: ladd
+/*     */     //   666: putfield 273	NET/worlds/network/Cache:totalBytes	J
+/*     */     //   669: aload 6
+/*     */     //   671: invokevirtual 284	NET/worlds/network/CacheEntry:done	()Z
+/*     */     //   674: ifeq +8 -> 682
+/*     */     //   677: iload 8
+/*     */     //   679: ifne +27 -> 706
+/*     */     //   682: aload_0
+/*     */     //   683: aload 6
+/*     */     //   685: invokevirtual 287	NET/worlds/network/Cache:remove	(LNET/worlds/network/CacheEntry;)V
+/*     */     //   688: iload 8
+/*     */     //   690: ifeq +16 -> 706
+/*     */     //   693: new 180	java/io/File
+/*     */     //   696: dup
+/*     */     //   697: aload 7
+/*     */     //   699: invokespecial 197	java/io/File:<init>	(Ljava/lang/String;)V
+/*     */     //   702: invokevirtual 253	java/io/File:delete	()Z
+/*     */     //   705: pop
+/*     */     //   706: aload 5
+/*     */     //   708: aload_0
+/*     */     //   709: getfield 228	NET/worlds/network/Cache:terminator	LNET/worlds/network/CacheEntry;
+/*     */     //   712: if_acmpne -104 -> 608
+/*     */     //   715: aload 4
+/*     */     //   717: invokevirtual 289	java/util/Hashtable:keys	()Ljava/util/Enumeration;
+/*     */     //   720: astore 5
+/*     */     //   722: goto +24 -> 746
+/*     */     //   725: new 180	java/io/File
+/*     */     //   728: dup
+/*     */     //   729: aload 5
+/*     */     //   731: invokeinterface 293 1 0
+/*     */     //   736: checkcast 49	java/lang/String
+/*     */     //   739: invokespecial 197	java/io/File:<init>	(Ljava/lang/String;)V
+/*     */     //   742: invokevirtual 253	java/io/File:delete	()Z
+/*     */     //   745: pop
+/*     */     //   746: aload 5
+/*     */     //   748: invokeinterface 298 1 0
+/*     */     //   753: ifne -28 -> 725
+/*     */     //   756: new 180	java/io/File
+/*     */     //   759: dup
+/*     */     //   760: ldc_w 301
+/*     */     //   763: invokespecial 197	java/io/File:<init>	(Ljava/lang/String;)V
+/*     */     //   766: astore 5
+/*     */     //   768: aload 5
+/*     */     //   770: invokevirtual 198	java/io/File:exists	()Z
+/*     */     //   773: ifeq +15 -> 788
+/*     */     //   776: aload_0
+/*     */     //   777: putstatic 82	NET/worlds/network/Cache:cache	LNET/worlds/network/Cache;
+/*     */     //   780: aload 5
+/*     */     //   782: ldc_w 303
+/*     */     //   785: invokestatic 305	NET/worlds/network/Cache:InjectZipFile	(Ljava/io/File;Ljava/lang/String;)V
+/*     */     //   788: aload_0
+/*     */     //   789: new 309	java/util/Date
+/*     */     //   792: dup
+/*     */     //   793: invokespecial 311	java/util/Date:<init>	()V
+/*     */     //   796: putfield 312	NET/worlds/network/Cache:lastCacheSave	Ljava/util/Date;
+/*     */     //   799: aload_0
+/*     */     //   800: invokestatic 314	NET/worlds/console/Main:register	(LNET/worlds/console/MainCallback;)V
+/*     */     //   803: aload_0
+/*     */     //   804: areturn
+/*     */     // Line number table:
+/*     */     //   Java source line #109	-> byte code offset #0
+/*     */     //   Java source line #111	-> byte code offset #8
+/*     */     //   Java source line #112	-> byte code offset #16
+/*     */     //   Java source line #113	-> byte code offset #18
+/*     */     //   Java source line #130	-> byte code offset #20
+/*     */     //   Java source line #132	-> byte code offset #28
+/*     */     //   Java source line #133	-> byte code offset #57
+/*     */     //   Java source line #134	-> byte code offset #64
+/*     */     //   Java source line #135	-> byte code offset #93
+/*     */     //   Java source line #136	-> byte code offset #100
+/*     */     //   Java source line #139	-> byte code offset #129
+/*     */     //   Java source line #140	-> byte code offset #138
+/*     */     //   Java source line #141	-> byte code offset #147
+/*     */     //   Java source line #142	-> byte code offset #153
+/*     */     //   Java source line #143	-> byte code offset #160
+/*     */     //   Java source line #145	-> byte code offset #170
+/*     */     //   Java source line #147	-> byte code offset #178
+/*     */     //   Java source line #148	-> byte code offset #189
+/*     */     //   Java source line #152	-> byte code offset #200
+/*     */     //   Java source line #153	-> byte code offset #203
+/*     */     //   Java source line #155	-> byte code offset #211
+/*     */     //   Java source line #158	-> byte code offset #246
+/*     */     //   Java source line #152	-> byte code offset #255
+/*     */     //   Java source line #167	-> byte code offset #265
+/*     */     //   Java source line #168	-> byte code offset #269
+/*     */     //   Java source line #169	-> byte code offset #271
+/*     */     //   Java source line #170	-> byte code offset #275
+/*     */     //   Java source line #188	-> byte code offset #277
+/*     */     //   Java source line #191	-> byte code offset #285
+/*     */     //   Java source line #207	-> byte code offset #289
+/*     */     //   Java source line #209	-> byte code offset #293
+/*     */     //   Java source line #210	-> byte code offset #297
+/*     */     //   Java source line #213	-> byte code offset #302
+/*     */     //   Java source line #215	-> byte code offset #304
+/*     */     //   Java source line #217	-> byte code offset #308
+/*     */     //   Java source line #218	-> byte code offset #312
+/*     */     //   Java source line #221	-> byte code offset #317
+/*     */     //   Java source line #196	-> byte code offset #322
+/*     */     //   Java source line #197	-> byte code offset #323
+/*     */     //   Java source line #198	-> byte code offset #330
+/*     */     //   Java source line #203	-> byte code offset #338
+/*     */     //   Java source line #204	-> byte code offset #368
+/*     */     //   Java source line #205	-> byte code offset #374
+/*     */     //   Java source line #207	-> byte code offset #380
+/*     */     //   Java source line #209	-> byte code offset #384
+/*     */     //   Java source line #210	-> byte code offset #388
+/*     */     //   Java source line #213	-> byte code offset #393
+/*     */     //   Java source line #215	-> byte code offset #395
+/*     */     //   Java source line #217	-> byte code offset #399
+/*     */     //   Java source line #218	-> byte code offset #403
+/*     */     //   Java source line #221	-> byte code offset #408
+/*     */     //   Java source line #206	-> byte code offset #413
+/*     */     //   Java source line #207	-> byte code offset #415
+/*     */     //   Java source line #209	-> byte code offset #419
+/*     */     //   Java source line #210	-> byte code offset #423
+/*     */     //   Java source line #213	-> byte code offset #428
+/*     */     //   Java source line #215	-> byte code offset #430
+/*     */     //   Java source line #217	-> byte code offset #434
+/*     */     //   Java source line #218	-> byte code offset #438
+/*     */     //   Java source line #221	-> byte code offset #443
+/*     */     //   Java source line #223	-> byte code offset #445
+/*     */     //   Java source line #207	-> byte code offset #448
+/*     */     //   Java source line #209	-> byte code offset #452
+/*     */     //   Java source line #210	-> byte code offset #456
+/*     */     //   Java source line #213	-> byte code offset #461
+/*     */     //   Java source line #215	-> byte code offset #463
+/*     */     //   Java source line #217	-> byte code offset #467
+/*     */     //   Java source line #218	-> byte code offset #471
+/*     */     //   Java source line #221	-> byte code offset #476
+/*     */     //   Java source line #230	-> byte code offset #478
+/*     */     //   Java source line #231	-> byte code offset #492
+/*     */     //   Java source line #232	-> byte code offset #501
+/*     */     //   Java source line #233	-> byte code offset #505
+/*     */     //   Java source line #234	-> byte code offset #511
+/*     */     //   Java source line #233	-> byte code offset #546
+/*     */     //   Java source line #236	-> byte code offset #556
+/*     */     //   Java source line #242	-> byte code offset #586
+/*     */     //   Java source line #243	-> byte code offset #591
+/*     */     //   Java source line #244	-> byte code offset #596
+/*     */     //   Java source line #245	-> byte code offset #608
+/*     */     //   Java source line #246	-> byte code offset #612
+/*     */     //   Java source line #248	-> byte code offset #619
+/*     */     //   Java source line #249	-> byte code offset #629
+/*     */     //   Java source line #250	-> byte code offset #646
+/*     */     //   Java source line #252	-> byte code offset #654
+/*     */     //   Java source line #254	-> byte code offset #669
+/*     */     //   Java source line #255	-> byte code offset #682
+/*     */     //   Java source line #256	-> byte code offset #688
+/*     */     //   Java source line #257	-> byte code offset #693
+/*     */     //   Java source line #244	-> byte code offset #706
+/*     */     //   Java source line #263	-> byte code offset #715
+/*     */     //   Java source line #264	-> byte code offset #725
+/*     */     //   Java source line #263	-> byte code offset #746
+/*     */     //   Java source line #268	-> byte code offset #756
+/*     */     //   Java source line #269	-> byte code offset #768
+/*     */     //   Java source line #270	-> byte code offset #776
+/*     */     //   Java source line #271	-> byte code offset #780
+/*     */     //   Java source line #274	-> byte code offset #788
+/*     */     //   Java source line #275	-> byte code offset #799
+/*     */     //   Java source line #276	-> byte code offset #803
+/*     */     // Local variable table:
+/*     */     //   start	length	slot	name	signature
+/*     */     //   15	789	0	c	Cache
+/*     */     //   17	461	1	in	java.io.FileInputStream
+/*     */     //   19	444	2	s	java.io.ObjectInputStream
+/*     */     //   56	78	3	fi	File
+/*     */     //   288	1	3	localOptionalDataException	java.io.OptionalDataException
+/*     */     //   322	5	3	e	Exception
+/*     */     //   491	61	3	names	String[]
+/*     */     //   151	3	4	version	long
+/*     */     //   366	9	4	findex	File
+/*     */     //   499	217	4	files	Hashtable<String, String>
+/*     */     //   506	44	5	i	int
+/*     */     //   603	104	5	p	CacheEntry
+/*     */     //   720	27	5	e	Enumeration<String>
+/*     */     //   766	15	5	f	File
+/*     */     //   203	45	6	obj	Object
+/*     */     //   260	3	6	obj	Object
+/*     */     //   610	74	6	e	CacheEntry
+/*     */     //   413	33	7	localObject1	Object
+/*     */     //   627	71	7	name	String
+/*     */     //   300	1	8	localException1	Exception
+/*     */     //   315	1	8	localException2	Exception
+/*     */     //   391	1	8	localException3	Exception
+/*     */     //   406	1	8	localException4	Exception
+/*     */     //   426	1	8	localException5	Exception
+/*     */     //   441	1	8	localException6	Exception
+/*     */     //   459	1	8	localException7	Exception
+/*     */     //   474	1	8	localException8	Exception
+/*     */     //   644	45	8	isFile	boolean
+/*     */     // Exception table:
+/*     */     //   from	to	target	type
+/*     */     //   20	285	288	java/io/OptionalDataException
+/*     */     //   293	297	300	java/lang/Exception
+/*     */     //   308	312	315	java/lang/Exception
+/*     */     //   20	285	322	java/lang/Exception
+/*     */     //   384	388	391	java/lang/Exception
+/*     */     //   399	403	406	java/lang/Exception
+/*     */     //   20	289	413	finally
+/*     */     //   322	380	413	finally
+/*     */     //   419	423	426	java/lang/Exception
+/*     */     //   434	438	441	java/lang/Exception
+/*     */     //   452	456	459	java/lang/Exception
+/*     */     //   467	471	474	java/lang/Exception
+/*     */   }
+/*     */   
+/*     */   public static CacheFile getFile(URL url, boolean forceRecheck)
+/*     */   {
+/* 287 */     return cache.getAFile(url, forceRecheck);
+/*     */   }
+/*     */   
+/*     */   public static CacheFile getFile(URL url) {
+/* 291 */     return cache.getAFile(url, false);
+/*     */   }
+/*     */   
+/*     */   public static CacheFile getFile(String url) {
+/* 295 */     return cache.getAFile(URL.make(url), false);
+/*     */   }
+/*     */   
+/*     */   public static CacheEntry getEntry(URL url) {
+/* 299 */     return cache.get(url);
+/*     */   }
+/*     */   
+/*     */   public static void removeEntry(CacheEntry ce) {
+/* 303 */     cache.remove(ce);
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */   public static void InjectZipFile(File zipFile, String urlPrefix)
+/*     */   {
+/* 313 */     long timeStamp = zipFile.lastModified();
+/*     */     try
+/*     */     {
+/* 316 */       ZipFile zf = new ZipFile(zipFile);
+/* 317 */       System.out.println("Adding " + zf.size() + " entries from " + 
+/* 318 */         zipFile);
+/* 319 */       Enumeration<?> e = zf.entries();
+/* 320 */       InputStream is; while (e.hasMoreElements()) {
+/* 321 */         ZipEntry ze = (ZipEntry)e.nextElement();
+/* 322 */         is = zf.getInputStream(ze);
+/* 323 */         URL remoteName = URL.make(urlPrefix + ze.getName());
+/*     */         
+/*     */ 
+/* 326 */         CacheEntry ce = cache.get(remoteName);
+/* 327 */         if (ce == null)
+/*     */         {
+/* 329 */           String localName = assignLocalName(remoteName);
+/* 330 */           FileOutputStream fos = new FileOutputStream(localName);
+/* 331 */           byte[] buffer = new byte['က'];
+/*     */           try {
+/*     */             for (;;) {
+/* 334 */               int bytesRead = is.read(buffer);
+/* 335 */               if (bytesRead == -1) {
+/*     */                 break;
+/*     */               }
+/* 338 */               fos.write(buffer, 0, bytesRead);
+/*     */             }
+/*     */             
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/* 354 */             is.close();
+/*     */           }
+/*     */           catch (IOException localIOException)
+/*     */           {
+/* 343 */             fos.close();
+/*     */             
+/*     */ 
+/* 346 */             ce = new CacheEntry();
+/* 347 */             ce.localName = new String(localName);
+/* 348 */             ce.url = remoteName;
+/* 349 */             ce.state = 4;
+/* 350 */             ce.remoteTime = timeStamp;
+/* 351 */             ce.checkTime = new Date();
+/* 352 */             cache.add(ce);
+/*     */           }
+/*     */         }
+/*     */       }
+/*     */       
+/* 357 */       zf.close();
+/*     */ 
+/*     */     }
+/*     */     catch (Exception e)
+/*     */     {
+/*     */ 
+/* 363 */       System.out.println("Error processing cache zip file: " + e);
+/*     */     }
+/*     */   }
+/*     */   
+/*     */   private synchronized CacheFile getAFile(URL url, boolean forceRecheck) {
+/* 368 */     CacheEntry e = null;
+/*     */     
+/*     */ 
+/*     */ 
+/* 372 */     if (url.isRemote())
+/*     */     {
+/* 374 */       e = cache.get(url);
+/* 375 */       if (e == null)
+/*     */       {
+/*     */ 
+/* 378 */         e = new CacheEntry(url);
+/* 379 */         cache.add(e);
+/* 380 */       } else if (forceRecheck) {
+/* 381 */         e.forceRecheck();
+/*     */       }
+/*     */     }
+/* 384 */     return new CacheFile(url, e);
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */   public void mainCallback() {}
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */   public synchronized void resyncIndex()
+/*     */   {
+/* 398 */     if ((this.hasChanged >= CACHE_MIN_CHANGE) || (this.lastCacheSave.before(new Date(new Date().getTime() - CACHE_MAX_DELAY)))) {
+/* 399 */       saveIndex();
+/*     */     }
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */   public void saveIndex()
+/*     */   {
+/*     */     try
+/*     */     {
+/* 409 */       System.out.println("Marking cache as open...");
+/*     */       
+/*     */ 
+/*     */ 
+/* 413 */       File fin = new File(CACHE_DIR + "cache.index.new");
+/* 414 */       FileOutputStream o = new FileOutputStream(fin);
+/* 415 */       ObjectOutputStream s = new ObjectOutputStream(o);
+/* 416 */       s.writeLong(0L);
+/* 417 */       s.writeObject(this);
+/*     */       
+/*     */ 
+/*     */ 
+/* 421 */       for (CacheEntry e = this.terminator.next; e != this.terminator; e = e.next) {
+/* 422 */         if ((e.url != null) && (e.localName != null)) {
+/* 423 */           s.writeObject(e);
+/*     */         }
+/*     */       }
+/*     */       
+/*     */ 
+/* 428 */       s.writeInt(0);
+/*     */       
+/* 430 */       s.flush();
+/* 431 */       s.close();
+/* 432 */       o.close();
+/* 433 */       this.lastCacheSave = new Date();
+/* 434 */       this.hasChanged = 0;
+/*     */       
+/* 436 */       System.out.println("Marking cache as closed...");
+/* 437 */       File fi = new File(CACHE_DIR + "cache.index");
+/* 438 */       File fio = new File(CACHE_DIR + "cache.index.old");
+/* 439 */       fi.renameTo(fio);
+/* 440 */       fin.renameTo(fi);
+/* 441 */       fio.delete();
+/*     */     }
+/*     */     catch (Exception e) {
+/* 444 */       System.out.println("Error writing cache index: " + e);
+/*     */     }
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */   public synchronized void terminalCallback()
+/*     */   {
+/* 453 */     Main.unregister(this);
+/*     */     
+/* 455 */     saveIndex();
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */   static String assignLocalName(URL url)
+/*     */   {
+/* 466 */     String remoteName = url.unalias();
+/*     */     
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/* 473 */     String ext = ".temp";
+/* 474 */     int lastDot = remoteName.lastIndexOf('.');
+/* 475 */     if ((lastDot > remoteName.lastIndexOf('/')) && 
+/* 476 */       (remoteName.indexOf("?", lastDot) < 0) && 
+/* 477 */       (remoteName.indexOf("#", lastDot) < 0)) {
+/* 478 */       ext = remoteName.substring(lastDot);
+/*     */     }
+/*     */     
+/*     */ 
+/* 482 */     if (url.endsWith(".gr2")) {
+/* 483 */       return CACHE_DIR + url.getBase();
+/*     */     }
+/* 485 */     return CACHE_DIR + Integer.toString(cache.nextAvailable++, 36) + ext;
+/*     */   }
+/*     */   
+/*     */   public synchronized void add(CacheEntry e)
+/*     */   {
+/* 490 */     this.table.put(e.url, e);
+/* 491 */     CacheEntry p = this.terminator.prev;
+/* 492 */     p.next = e;
+/* 493 */     e.prev = p;
+/* 494 */     e.next = this.terminator;
+/* 495 */     this.terminator.prev = e;
+/* 496 */     this.hasChanged += 1;
+/*     */   }
+/*     */   
+/*     */   public int numEntries()
+/*     */   {
+/* 501 */     return this.table.size();
+/*     */   }
+/*     */   
+/*     */ 
+/*     */   public synchronized CacheEntry get(URL url)
+/*     */   {
+/* 507 */     CacheEntry e = (CacheEntry)this.table.get(url);
+/*     */     
+/*     */ 
+/* 510 */     if (e != null) {
+/* 511 */       markUsed(e);
+/*     */     }
+/*     */     
+/* 514 */     return e;
+/*     */   }
+/*     */   
+/*     */ 
+/*     */   private void markUsed(CacheEntry e)
+/*     */   {
+/* 520 */     if ((e == null) || (e.next == this.terminator))
+/*     */     {
+/* 522 */       return;
+/*     */     }
+/* 524 */     e.prev.next = e.next;
+/* 525 */     e.next.prev = e.prev;
+/* 526 */     this.terminator.prev.next = e;
+/* 527 */     e.prev = this.terminator.prev;
+/* 528 */     e.next = this.terminator;
+/* 529 */     this.terminator.prev = e;
+/*     */   }
+/*     */   
+/*     */ 
+/*     */   public void remove(CacheEntry e)
+/*     */   {
+/* 535 */     this.totalBytes -= e.bytes;
+/* 536 */     e.prev.next = e.next;
+/* 537 */     e.next.prev = e.prev;
+/* 538 */     e.prev = null;
+/* 539 */     e.next = null;
+/* 540 */     this.table.remove(e.url);
+/* 541 */     this.hasChanged += 1;
+/*     */     
+/* 543 */     new File(e.localName.toUpperCase()).delete();
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */   private CacheEntry freeLRU()
+/*     */   {
+/* 554 */     for (CacheEntry e = this.terminator.next; e != this.terminator; e = e.next) {
+/* 555 */       if (!e.inUse()) {
+/* 556 */         remove(e);
+/* 557 */         return e;
+/*     */       }
+/*     */     }
+/* 560 */     return null;
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */   public synchronized void makeSpaceFor(int incomingSize)
+/*     */   {
+/* 570 */     while (cache.numEntries() > CacheEntry.CACHE_MAX_ENTRIES) {
+/* 571 */       if (freeLRU() == null) {
+/*     */         break;
+/*     */       }
+/*     */     }
+/*     */     
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/* 580 */     while ((this.totalBytes + 2L * incomingSize) / 1024L > 
+/* 581 */       Std.GetDiskFreeSpace())
+/*     */     {
+/* 583 */       if (Std.GetDiskFreeSpace() <= -1L) {
+/*     */         break;
+/*     */       }
+/*     */       
+/* 587 */       CacheEntry freed = freeLRU();
+/* 588 */       if (freed == null) {
+/*     */         break;
+/*     */       }
+/*     */     }
+/*     */   }
+/*     */ }
+
+
+/* Location:              C:\Program Files (x86)\Worlds Inc\WorldsPlayer - Win7\lib\worlds.jar!\NET\worlds\network\Cache.class
+ * Java compiler version: 6 (50.0)
+ * JD-Core Version:       0.7.1
+ */
\ No newline at end of file