/*     */ package NET.worlds.scape;
/*     */ 
/*     */ import NET.worlds.network.URL;
/*     */ import java.io.DataInputStream;
/*     */ import java.io.FileInputStream;
/*     */ import java.io.IOException;
/*     */ import java.util.Hashtable;
/*     */ import java.util.Vector;
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ public class URLSelfLoader
/*     */   implements BGLoaded
/*     */ {
/*  61 */   private static Hashtable<URL, URLSelf> loaded = new Hashtable();
/*     */   
/*  63 */   private static Hashtable<URL, URLSelfLoader> loading = new Hashtable();
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */   private URL url;
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */   public static void load(URL url, LoadedURLSelf callback)
/*     */   {
/*  75 */     load(url, callback, false);
/*     */   }
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   public static void load(URL url, LoadedURLSelf callback, boolean isHighPriority)
/*     */   {
/*  86 */     URLSelf o = (URLSelf)loaded.get(url);
/*  87 */     if (o != null) {
/*  88 */       o.incRef();
/*  89 */       callback.loadedURLSelf(o, url, null);
/*  90 */       return;
/*     */     }
/*     */     
/*     */ 
/*  94 */     URLSelfLoader cl = (URLSelfLoader)loading.get(url);
/*  95 */     if (cl != null) {
/*  96 */       cl.callbacks.addElement(callback);
/*  97 */       return;
/*     */     }
/*     */     
/*     */ 
/* 101 */     new URLSelfLoader(url, callback, isHighPriority);
/*     */   }
/*     */   
/*     */   public static void unload(URLSelf self) {
/* 105 */     loaded.remove(self.getSourceURL());
/*     */   }
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   public static void immediateLoad(IncrementalRestorer o, Restorer r)
/*     */     throws IOException, TooNewException
/*     */   {
/* 118 */     new URLSelfLoader(o, r);
/*     */   }
/*     */   
/*     */   private URLSelfLoader(IncrementalRestorer o, Restorer r) throws IOException, TooNewException
/*     */   {
/* 123 */     this.url = null;
/*     */     
/* 125 */     while (this.state != -1) {
/*     */       try {
/* 127 */         this.state = o.incRestore(this.state, r, this);
/*     */       } catch (Exception e) {
/* 129 */         e.printStackTrace(System.out);
/* 130 */         if (!$assertionsDisabled) { throw new AssertionError();
/*     */         }
/*     */       }
/*     */     }
/*     */   }
/*     */   
/* 136 */   private Vector<LoadedURLSelf> callbacks = new Vector();
/*     */   private static final int INIT = 0;
/*     */   
/* 139 */   public URL getURL() { return this.url; }
/*     */   
/*     */ 
/*     */   private URLSelfLoader(URL url, LoadedURLSelf callback, boolean isHighPriority)
/*     */   {
/* 144 */     loading.put(url, this);
/* 145 */     this.url = url;
/* 146 */     this.callbacks.addElement(callback);
/*     */     
/* 148 */     BackgroundLoader.get(this, url, isHighPriority);
/*     */   }
/*     */   
/*     */ 
/*     */ 
/*     */   private static final int DONE = -1;
/*     */   
/* 155 */   private int state = 0;
/*     */   
/*     */   private DataInputStream inFile;
/*     */   
/*     */   private Restorer restorer;
/*     */   
/*     */   private URLSelf loadedObj;
/*     */   
/*     */   public Object otemp1;
/*     */   
/*     */   public Object otemp2;
/*     */   
/*     */   public int itemp1;
/*     */   public int itemp2;
/*     */   
/*     */   public Object asyncBackgroundLoad(String localName, URL remoteName)
/*     */   {
/* 172 */     if (localName == null) {
/* 173 */       return "Can't find file " + this.url;
/*     */     }
/*     */     try {
/* 176 */       return new DataInputStream(new FileInputStream(localName));
/*     */     } catch (IOException e) {}
/* 178 */     return "Can't load file " + this.url;
/*     */   }
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   public boolean syncBackgroundLoad(Object obj, URL remoteURL)
/*     */   {
/* 188 */     if ((obj instanceof String)) {
/* 189 */       doneLoading(null, (String)obj);
/* 190 */       return false;
/*     */     }
/*     */     
/* 193 */     assert (this.state != -1);
/*     */     
/* 195 */     if (this.state == 0)
/*     */     {
/* 197 */       this.inFile = ((DataInputStream)obj);
/*     */       
/* 199 */       Object o = null;
/*     */       try {
/* 201 */         this.restorer = new Restorer(this.inFile, this.url);
/* 202 */         o = this.restorer.restore(false);
/* 203 */         this.loadedObj = ((URLSelf)o);
/*     */         
/* 205 */         this.loadedObj.setSourceURL(getURL());
/*     */         
/* 207 */         if (!(this.loadedObj instanceof IncrementalRestorer)) {
/* 208 */           this.loadedObj.restoreState(this.restorer);
/* 209 */           this.restorer.done();
/* 210 */           return doneLoading(this.loadedObj, null);
/*     */         }
/*     */       } catch (Exception e) {
/* 213 */         e.printStackTrace(System.out);
/* 214 */         return doneLoading(null, "Can't restore from file " + this.url + 
/* 215 */           ": " + e.toString());
/*     */       }
/*     */     }
/*     */     try
/*     */     {
/* 220 */       this.state = ((IncrementalRestorer)this.loadedObj).incRestore(this.state, 
/* 221 */         this.restorer, this);
/*     */     } catch (Exception e) {
/* 223 */       e.printStackTrace(System.out);
/* 224 */       return doneLoading(null, e.toString());
/*     */     }
/*     */     
/* 227 */     if (this.state == -1) {
/*     */       try {
/* 229 */         this.restorer.done();
/*     */       } catch (IOException e) {
/* 231 */         e.printStackTrace(System.out);
/* 232 */         return doneLoading(null, e.toString());
/*     */       }
/* 234 */       if ((this.restorer.version() < 3) && ((this.loadedObj instanceof Camera)))
/*     */       {
/* 236 */         Camera cam = (Camera)this.loadedObj;
/* 237 */         World w = cam.getWorld();
/* 238 */         w.setSourceURL(cam.getSourceURL());
/*     */       }
/*     */       
/* 241 */       return doneLoading(this.loadedObj, null);
/*     */     }
/*     */     
/* 244 */     return true;
/*     */   }
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   private boolean doneLoading(URLSelf o, String err)
/*     */   {
/* 256 */     if (this.inFile != null) {
/*     */       try {
/* 258 */         this.inFile.close();
/* 259 */         this.inFile = null;
/*     */       } catch (Exception ex) {
/* 261 */         this.inFile = null;
/*     */       }
/*     */     }
/*     */     
/* 265 */     loading.remove(this.url);
/*     */     
/*     */ 
/*     */ 
/* 269 */     if (o != null) {
/* 270 */       if ((this.restorer.version() < 4) && ((o instanceof Camera))) {
/* 271 */         Camera c = (Camera)o;
/* 272 */         o = c.getWorld();
/* 273 */         c.detach();
/*     */       }
/*     */       
/* 276 */       loaded.put(this.url, o);
/*     */     }
/*     */     
/* 279 */     int end = this.callbacks.size();
/* 280 */     for (int i = 0; i < end; i++) {
/* 281 */       LoadedURLSelf callback = (LoadedURLSelf)this.callbacks.elementAt(i);
/* 282 */       if (o != null)
/* 283 */         o.incRef();
/* 284 */       callback.loadedURLSelf(o, this.url, err);
/*     */     }
/*     */     
/* 287 */     this.state = -1;
/* 288 */     return false;
/*     */   }
/*     */   
/*     */   public Room getBackgroundLoadRoom() {
/* 292 */     return null;
/*     */   }
/*     */ }


/* Location:              C:\Program Files (x86)\Worlds Inc\WorldsPlayer - Win7\lib\worlds.jar!\NET\worlds\scape\URLSelfLoader.class
 * Java compiler version: 6 (50.0)
 * JD-Core Version:       0.7.1
 */