Initial commit

1 files changed, 83 insertions, 0 deletions

diff --git a/NET/worlds/scape/ASFThread.java b/NET/worlds/scape/ASFThread.java
new file mode 100644
index 0000000..a9e043f
--- /dev/null
+++ b/NET/worlds/scape/ASFThread.java
@@ -0,0 +1,83 @@
+package NET.worlds.scape;
+
+import NET.worlds.network.Cache;
+import NET.worlds.network.CacheFile;
+import NET.worlds.network.URL;
+
+class ASFThread extends Thread {
+   private URL url;
+   private ASFSoundPlayer player;
+   private static ASFThread asfThread;
+   private static boolean paused;
+
+   ASFThread(URL url, ASFSoundPlayer player) {
+      this.url = url;
+      this.player = player;
+      setASF(this);
+   }
+
+   @Override
+   public void run() {
+      CacheFile cf = Cache.getFile(this.url);
+      cf.waitUntilLoaded();
+      if (cf.error()) {
+         this.player.running = 3;
+         releaseASF(this);
+      } else if (!paused) {
+         String localName = cf.getLocalName().replace('/', '\\');
+         if (!ASFSoundPlayer.nativePlay(localName)) {
+            this.player.running = 3;
+         }
+
+         releaseASF(this);
+      }
+   }
+
+   static synchronized void pauseASF() {
+      if (!paused && asfThread != null) {
+         ASFThread t = asfThread;
+         stopASF();
+         paused = true;
+         new ASFThread(t.url, t.player);
+      }
+
+      paused = true;
+   }
+
+   static synchronized void resumeASF() {
+      if (paused) {
+         ASFThread t = asfThread;
+         paused = false;
+         if (t != null) {
+            new ASFThread(t.url, t.player);
+         }
+      }
+   }
+
+   static synchronized void releaseASF(ASFThread t) {
+      if (asfThread == t) {
+         asfThread = null;
+      }
+   }
+
+   static synchronized void setASF(ASFThread t) {
+      if (asfThread == null || !asfThread.url.equals(t.url)) {
+         asfThread = t;
+         asfThread.setDaemon(true);
+         asfThread.start();
+      }
+   }
+
+   static synchronized void stopASF() {
+      if (asfThread != null) {
+         asfThread = null;
+         if (!paused) {
+            ASFSoundPlayer.nativePlay("");
+         }
+      }
+   }
+
+   static boolean isActive() {
+      return asfThread != null;
+   }
+}