:star:HEADmain

1 files changed, 381 insertions, 0 deletions

diff --git a/NET/worlds/scape/CDDBLookup.java b/NET/worlds/scape/CDDBLookup.java
new file mode 100644
index 0000000..7a129e4
--- /dev/null
+++ b/NET/worlds/scape/CDDBLookup.java
@@ -0,0 +1,381 @@
+/*     */ package NET.worlds.scape;
+/*     */ 
+/*     */ import NET.worlds.core.Hashtable;
+/*     */ import NET.worlds.network.URL;
+/*     */ import java.io.IOException;
+/*     */ import java.net.InetAddress;
+/*     */ import java.net.UnknownHostException;
+/*     */ import java.util.NoSuchElementException;
+/*     */ import java.util.StringTokenizer;
+/*     */ import java.util.Vector;
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */ public class CDDBLookup
+/*     */   implements Runnable
+/*     */ {
+/*     */   public static final int STATUS_SERVERERROR = -3;
+/*     */   public static final int STATUS_NOTUNIQUE = -2;
+/*     */   public static final int STATUS_NOTFOUND = -1;
+/*     */   public static final int STATUS_LOOKING = 0;
+/*     */   public static final int STATUS_EXACTMATCH = 1;
+/*     */   public static final int STATUS_CLOSEMATCH = 2;
+/*     */   private static final boolean debug = false;
+/*     */   private static final String lookupThreadName = "lookup";
+/*     */   private static final String siteThreadName = "site";
+/*     */   private static final String pkgName = "gamma";
+/*     */   private static final String pkgVersion = "1.0";
+/*     */   private static final int TIMEOUT = 3000;
+/*     */   private static final String dbName = "home:cdcache.db";
+/*  37 */   private static CDDBHost siteHost = new CDDBHost("cddb.cddb.com", 888);
+/*     */   private static Vector<Object> sites;
+/*  39 */   private static Object siteMutex = new Object();
+/*  40 */   private static Object knownDisksMutex = new Object();
+/*     */   
+/*  42 */   private static Hashtable<Thread, Long> threadActivity = new Hashtable();
+/*     */   private static Hashtable<String, CDDBStatus> knownDisks;
+/*     */   private static String userName;
+/*     */   private static String hostName;
+/*     */   private CDTrackInfo tracks;
+/*     */   private String hash;
+/*     */   private CDDBStatus status;
+/*     */   private static final String discTitleKey = "DTITLE=";
+/*     */   private static final String trackTitleKey = "TTITLE";
+/*     */   
+/*     */   public CDDBLookup(CDTrackInfo tracks)
+/*     */   {
+/*  54 */     if (userName == null) {
+/*  55 */       userName = System.getProperty("user.name").replace(' ', '_');
+/*     */       try {
+/*  57 */         hostName = InetAddress.getLocalHost().getHostName();
+/*     */       } catch (UnknownHostException e) {
+/*  59 */         hostName = "unknown";
+/*     */       }
+/*     */     }
+/*  62 */     this.tracks = tracks;
+/*  63 */     this.hash = CDDBHash.hashString(tracks);
+/*  64 */     if ((this.status = dbLookup()) == null) {
+/*  65 */       runThread("lookup");
+/*     */     }
+/*     */   }
+/*     */   
+/*     */   public String getHash() {
+/*  70 */     return this.hash;
+/*     */   }
+/*     */   
+/*     */   public CDDiskInfo getDiskInfo()
+/*     */   {
+/*  75 */     return getDiskInfo(false);
+/*     */   }
+/*     */   
+/*     */   public synchronized CDDiskInfo getDiskInfo(boolean wait)
+/*     */   {
+/*  80 */     if (wait) {
+/*  81 */       while (this.status == null) {
+/*     */         try {
+/*  83 */           wait();
+/*     */         } catch (InterruptedException localInterruptedException) {}
+/*     */       }
+/*     */     }
+/*  87 */     if (this.status != null)
+/*  88 */       return this.status.getDiskInfo();
+/*  89 */     return null;
+/*     */   }
+/*     */   
+/*     */   public int getStatus()
+/*     */   {
+/*  94 */     if (this.status != null)
+/*  95 */       return this.status.getStatus();
+/*  96 */     return 0;
+/*     */   }
+/*     */   
+/*     */   public void run()
+/*     */   {
+/* 101 */     String name = Thread.currentThread().getName();
+/*     */     
+/*     */ 
+/* 104 */     if (name.equals("lookup")) {
+/* 105 */       maybeRunSiteThread();
+/* 106 */       for (int i = 0; i < sites.size(); i++) {
+/* 107 */         synchronized (this) {
+/* 108 */           Thread t = runThread(i);
+/*     */           try {
+/*     */             do {
+/* 111 */               wait(3000L);
+/* 112 */               if (this.status != null) break; } while (recentlyActive(t));
+/*     */           } catch (InterruptedException localInterruptedException) {}
+/* 114 */           forgetThread(t);
+/* 115 */           if (this.status != null)
+/*     */             break;
+/* 117 */           if (i == sites.size() - 1) {
+/* 118 */             this.status = new CDDBStatus(-3);
+/* 119 */             notifyAll();
+/*     */           }
+/*     */         }
+/*     */       }
+/*     */     } else {
+/* 124 */       if (name.equals("site")) {
+/* 125 */         Vector<Object> v = getSiteList();
+/* 126 */         synchronized (siteMutex) {
+/* 127 */           if (sites == null)
+/* 128 */             sites = v;
+/* 129 */           siteMutex.notifyAll();
+/*     */         }
+/*     */       }
+/*     */       
+/* 133 */       CDDBStatus newStatus = null;
+/* 134 */       int hostIndex = 0;
+/*     */       try {
+/* 136 */         hostIndex = Integer.parseInt(name);
+/*     */       } catch (NumberFormatException localNumberFormatException) {}
+/* 138 */       CDDBHost host = null;
+/* 139 */       synchronized (siteMutex) {
+/* 140 */         host = (CDDBHost)sites.elementAt(hostIndex);
+/*     */       }
+/* 142 */       newStatus = findDiskInfo(host);
+/* 143 */       synchronized (this) {
+/* 144 */         if ((this.status == null) && (newStatus != null)) {
+/* 145 */           this.status = newStatus;
+/* 146 */           if (hostIndex != 0) {
+/* 147 */             synchronized (siteMutex) {
+/* 148 */               Object site = sites.elementAt(hostIndex);
+/* 149 */               sites.removeElementAt(hostIndex);
+/* 150 */               sites.insertElementAt(site, 0);
+/*     */             }
+/*     */           }
+/* 153 */           notifyAll();
+/*     */         }
+/*     */       }
+/*     */     }
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */   private static void addSite(Vector<Object> v, String host, int port)
+/*     */   {
+/* 163 */     v.addElement(new CDDBHost(host, port));
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */   private static void defaultSites()
+/*     */   {
+/* 170 */     sites = new Vector();
+/* 171 */     addSite(sites, "cddb.moonsoft.com", 888);
+/* 172 */     addSite(sites, "cddb.moonsoft.com", 8880);
+/* 173 */     addSite(sites, "cddb.celestial.com", 888);
+/* 174 */     addSite(sites, "cddb.sonic.net", 888);
+/* 175 */     addSite(sites, "sunsite.unc.edu", 888);
+/* 176 */     addSite(sites, "cddb.netads.com", 888);
+/* 177 */     addSite(sites, "cddb.mattdm.org", 888);
+/* 178 */     addSite(sites, "cddb.dartmouth.edu", 888);
+/*     */   }
+/*     */   
+/*     */   private static Vector<Object> getSiteList()
+/*     */   {
+/* 183 */     CDDBConnection con = null;
+/*     */     
+/*     */     try
+/*     */     {
+/* 187 */       con = new CDDBConnection(siteHost, false);
+/* 188 */       con.command("sites").startsWith("210 ");
+/*     */       
+/* 190 */       Vector<Object> v = new Vector();
+/* 191 */       String line; while ((line = con.readBody()) != null) { String line;
+/* 192 */         StringTokenizer tok = new StringTokenizer(line, " ");
+/* 193 */         addSite(v, tok.nextToken(), 
+/* 194 */           Integer.parseInt(tok.nextToken()));
+/*     */       }
+/* 196 */       return v;
+/*     */ 
+/*     */     }
+/*     */     catch (IOException localIOException) {}catch (NumberFormatException localNumberFormatException) {}catch (NoSuchElementException localNoSuchElementException) {}finally
+/*     */     {
+/*     */ 
+/* 202 */       if (con != null)
+/* 203 */         con.close();
+/*     */     }
+/* 205 */     return null;
+/*     */   }
+/*     */   
+/*     */   private CDDBStatus findDiskInfo(CDDBHost host)
+/*     */   {
+/* 210 */     CDDBConnection con = null;
+/*     */     try {
+/* 212 */       con = new CDDBConnection(host, false);
+/*     */       
+/* 214 */       if (con.command("cddb hello " + userName + " " + hostName + " " + "gamma" + " " + "1.0").startsWith("200 ")) {
+/* 215 */         String resp = con.command("cddb query " + 
+/* 216 */           CDDBHash.lookupString(this.tracks));
+/* 217 */         StringTokenizer t = new StringTokenizer(resp, " ");
+/* 218 */         String code = t.nextToken();
+/* 219 */         CDDBStatus localCDDBStatus; if (code.equals("200"))
+/* 220 */           return dbAdd(new CDDBStatus(1, 
+/* 221 */             getCDDBEntry(con, t)));
+/* 222 */         if (code.equals("211")) {
+/* 223 */           String line = con.readBody();
+/*     */           
+/* 225 */           for (int extra = 0; con.readBody() != null; extra++) {}
+/*     */           
+/* 227 */           if (extra != 0)
+/* 228 */             return dbAdd(new CDDBStatus(-2));
+/* 229 */           return dbAdd(new CDDBStatus(2, 
+/* 230 */             getCDDBEntry(con, 
+/* 231 */             new StringTokenizer(line, 
+/* 232 */             " "))));
+/*     */         }
+/* 234 */         if (code.equals("202")) {
+/* 235 */           return new CDDBStatus(-1);
+/*     */         }
+/*     */       }
+/*     */     }
+/*     */     catch (IOException localIOException) {}catch (NoSuchElementException localNoSuchElementException) {}finally
+/*     */     {
+/* 241 */       if (con != null) {
+/* 242 */         con.close();
+/*     */       }
+/*     */     }
+/* 241 */     if (con != null) {
+/* 242 */       con.close();
+/*     */     }
+/* 244 */     return null;
+/*     */   }
+/*     */   
+/*     */   private Thread runThread(String name)
+/*     */   {
+/* 249 */     Thread t = new Thread(this, name);
+/* 250 */     t.setDaemon(true);
+/* 251 */     t.start();
+/* 252 */     return t;
+/*     */   }
+/*     */   
+/*     */   private void maybeRunSiteThread()
+/*     */   {
+/* 257 */     synchronized (siteMutex) {
+/* 258 */       if (sites == null) {
+/* 259 */         Thread t = runThread("site");
+/*     */         try {
+/*     */           do {
+/* 262 */             siteMutex.wait(3000L);
+/* 263 */             if (sites != null) break; } while (recentlyActive(t));
+/*     */         } catch (InterruptedException localInterruptedException) {}
+/* 265 */         forgetThread(t);
+/* 266 */         if (sites == null) {
+/* 267 */           defaultSites();
+/*     */         }
+/*     */       }
+/*     */     }
+/*     */   }
+/*     */   
+/*     */   private CDDiskInfo getCDDBEntry(CDDBConnection con, StringTokenizer t) {
+/*     */     try {
+/* 275 */       String cat = t.nextToken();
+/* 276 */       String id = t.nextToken();
+/* 277 */       if (con.command("cddb read " + cat + " " + id).startsWith("210 ")) {
+/* 278 */         return parseCDDBEntry(cat, con);
+/*     */       }
+/*     */     }
+/*     */     catch (IOException localIOException) {}catch (NoSuchElementException localNoSuchElementException) {}
+/* 282 */     return null;
+/*     */   }
+/*     */   
+/*     */ 
+/*     */ 
+/*     */ 
+/*     */   private CDDiskInfo parseCDDBEntry(String category, CDDBConnection con)
+/*     */     throws IOException
+/*     */   {
+/* 291 */     String artist = null;
+/* 292 */     String title = null;
+/* 293 */     String[] trackNames = new String[this.tracks.getNumTracks()];
+/* 294 */     for (int i = 0; i < trackNames.length; i++)
+/* 295 */       trackNames[i] = "";
+/*     */     String line;
+/* 297 */     while ((line = con.readBody()) != null) { String line;
+/* 298 */       if (line.startsWith("DTITLE=")) {
+/* 299 */         line = line.substring("DTITLE=".length());
+/* 300 */         int slashPos = line.indexOf('/');
+/* 301 */         if (slashPos == -1) {
+/* 302 */           artist = title = line.trim();
+/*     */         } else {
+/* 304 */           artist = line.substring(0, slashPos).trim();
+/* 305 */           title = line.substring(slashPos + 1).trim();
+/*     */         }
+/*     */       }
+/* 308 */       else if (line.startsWith("TTITLE")) {
+/* 309 */         int eqIndex = line.indexOf('=');
+/*     */         try {
+/* 311 */           int trackNum = 
+/* 312 */             Integer.parseInt(line.substring(
+/* 313 */             "TTITLE".length(), 
+/* 314 */             eqIndex)); int 
+/* 315 */             tmp163_161 = trackNum; String[] tmp163_159 = trackNames;tmp163_159[tmp163_161] = (tmp163_159[tmp163_161] + line.substring(eqIndex + 1));
+/*     */         }
+/*     */         catch (NumberFormatException localNumberFormatException) {}catch (IndexOutOfBoundsException localIndexOutOfBoundsException) {}
+/*     */       }
+/*     */     }
+/*     */     
+/* 321 */     return new CDDiskInfo(artist, title, category, trackNames);
+/*     */   }
+/*     */   
+/*     */   static void markActivity()
+/*     */   {
+/* 326 */     threadActivity.put(Thread.currentThread(), 
+/* 327 */       new Long(System.currentTimeMillis()));
+/*     */   }
+/*     */   
+/*     */   private boolean recentlyActive(Thread t)
+/*     */   {
+/* 332 */     Long l = (Long)threadActivity.get(t);
+/* 333 */     if (l != null)
+/* 334 */       return System.currentTimeMillis() - l.longValue() < 3000L;
+/* 335 */     return false;
+/*     */   }
+/*     */   
+/*     */   private void forgetThread(Thread t)
+/*     */   {
+/* 340 */     threadActivity.remove(t);
+/*     */   }
+/*     */   
+/*     */   private CDDBStatus dbAdd(CDDBStatus status)
+/*     */   {
+/* 345 */     synchronized (knownDisksMutex) {
+/* 346 */       if (knownDisks.get(this.hash) == null) {
+/* 347 */         knownDisks.put(this.hash, status);
+/*     */         try {
+/* 349 */           new Saver(new URL("home:cdcache.db")).save(knownDisks);
+/*     */         } catch (Exception localException) {}
+/*     */       }
+/*     */     }
+/* 353 */     return status;
+/*     */   }
+/*     */   
+/*     */ 
+/*     */   private CDDBStatus dbLookup()
+/*     */   {
+/* 359 */     synchronized (knownDisksMutex) {
+/* 360 */       if (knownDisks == null) {
+/*     */         try {
+/* 362 */           knownDisks = 
+/* 363 */             (Hashtable)new Restorer(new URL("home:cdcache.db")).restore();
+/*     */         } catch (Exception ex) {
+/* 365 */           knownDisks = new Hashtable();
+/*     */         }
+/*     */       }
+/* 368 */       return (CDDBStatus)knownDisks.get(this.hash);
+/*     */     }
+/*     */   }
+/*     */ }
+
+
+/* Location:              C:\Program Files (x86)\Worlds Inc\WorldsPlayer - Win7\lib\worlds.jar!\NET\worlds\scape\CDDBLookup.class
+ * Java compiler version: 6 (50.0)
+ * JD-Core Version:       0.7.1
+ */
\ No newline at end of file