home *** CD-ROM | disk | FTP | other *** search
/ CD Actual 14 / CDACTUAL.iso / ie4 / IE4 / JAVI386.CAB / classr.exe / sun / audio / AudioDevice.class (.txt) < prev    next >
Encoding:
Java Class File  |  1997-01-31  |  6.8 KB  |  271 lines

  1. package sun.audio;
  2.  
  3. import java.io.IOException;
  4. import java.io.InputStream;
  5. import java.util.Enumeration;
  6. import java.util.Vector;
  7.  
  8. public class AudioDevice {
  9.    private Vector streams;
  10.    private byte[] ulaw;
  11.    private int[] linear;
  12.    private int dev;
  13.    private static final int MSCLICK = 50;
  14.    private static final int MSMARGIN = 16;
  15.    private static final int BYTES_PER_SAMPLE = 1;
  16.    private static final int SAMPLE_RATE = 8000;
  17.    private static final int ULAW_BIAS = 132;
  18.    private static final int ULAW_CLIP = 32635;
  19.    private static final int[] ULAW_TAB = new int[]{-32124, -31100, -30076, -29052, -28028, -27004, -25980, -24956, -23932, -22908, -21884, -20860, -19836, -18812, -17788, -16764, -15996, -15484, -14972, -14460, -13948, -13436, -12924, -12412, -11900, -11388, -10876, -10364, -9852, -9340, -8828, -8316, -7932, -7676, -7420, -7164, -6908, -6652, -6396, -6140, -5884, -5628, -5372, -5116, -4860, -4604, -4348, -4092, -3900, -3772, -3644, -3516, -3388, -3260, -3132, -3004, -2876, -2748, -2620, -2492, -2364, -2236, -2108, -1980, -1884, -1820, -1756, -1692, -1628, -1564, -1500, -1436, -1372, -1308, -1244, -1180, -1116, -1052, -988, -924, -876, -844, -812, -780, -748, -716, -684, -652, -620, -588, -556, -524, -492, -460, -428, -396, -372, -356, -340, -324, -308, -292, -276, -260, -244, -228, -212, -196, -180, -164, -148, -132, -120, -112, -104, -96, -88, -80, -72, -64, -56, -48, -40, -32, -24, -16, -8, 0, 32124, 31100, 30076, 29052, 28028, 27004, 25980, 24956, 23932, 22908, 21884, 20860, 19836, 18812, 17788, 16764, 15996, 15484, 14972, 14460, 13948, 13436, 12924, 12412, 11900, 11388, 10876, 10364, 9852, 9340, 8828, 8316, 7932, 7676, 7420, 7164, 6908, 6652, 6396, 6140, 5884, 5628, 5372, 5116, 4860, 4604, 4348, 4092, 3900, 3772, 3644, 3516, 3388, 3260, 3132, 3004, 2876, 2748, 2620, 2492, 2364, 2236, 2108, 1980, 1884, 1820, 1756, 1692, 1628, 1564, 1500, 1436, 1372, 1308, 1244, 1180, 1116, 1052, 988, 924, 876, 844, 812, 780, 748, 716, 684, 652, 620, 588, 556, 524, 492, 460, 428, 396, 372, 356, 340, 324, 308, 292, 276, 260, 244, 228, 212, 196, 180, 164, 148, 132, 120, 112, 104, 96, 88, 80, 72, 64, 56, 48, 40, 32, 24, 16, 8, 0};
  20.    private static final int[] ULAW_LUT = new int[]{0, 0, 1, 1, 2, 2, 2, 2, 3, 3, 3, 3, 3, 3, 3, 3, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7};
  21.    public static final AudioDevice device = new AudioDevice();
  22.  
  23.    private native int audioOpen();
  24.  
  25.    private native void audioClose();
  26.  
  27.    private synchronized native void audioWrite(byte[] var1, int var2);
  28.  
  29.    private AudioDevice() {
  30.       try {
  31.          System.loadLibrary("msawt");
  32.       } catch (UnsatisfiedLinkError var2) {
  33.          System.out.println("could not find/load the mmedia library");
  34.       }
  35.  
  36.       this.streams = new Vector();
  37.       short var1 = 400;
  38.       this.ulaw = new byte[var1];
  39.       this.linear = new int[var1];
  40.    }
  41.  
  42.    public synchronized void openChannel(InputStream var1) {
  43.       this.streams.insertElementAt(var1, 0);
  44.       this.notify();
  45.    }
  46.  
  47.    public synchronized void closeChannel(InputStream var1) {
  48.       if (this.streams.removeElement(var1)) {
  49.          try {
  50.             var1.close();
  51.          } catch (IOException var2) {
  52.          }
  53.       }
  54.  
  55.    }
  56.  
  57.    public synchronized void open() {
  58.       int var1 = 1;
  59.       byte var2 = 5;
  60.  
  61.       while(this.dev == 0) {
  62.          this.dev = this.audioOpen();
  63.          if (this.dev < 0) {
  64.             System.out.println("no audio device");
  65.             return;
  66.          }
  67.  
  68.          if (this.dev == 0) {
  69.             System.out.println("audio device busy (attempt " + var1 + " out of " + var2 + ")");
  70.             if (this.streams.size() != 0) {
  71.                ++var1;
  72.                if (var1 <= var2) {
  73.                   try {
  74.                      this.wait(3000L);
  75.                      continue;
  76.                   } catch (InterruptedException var3) {
  77.                      this.closeStreams();
  78.                      return;
  79.                   }
  80.                }
  81.             }
  82.  
  83.             this.closeStreams();
  84.             return;
  85.          }
  86.       }
  87.  
  88.    }
  89.  
  90.    public synchronized void close() {
  91.       if (this.dev != 0) {
  92.          this.audioClose();
  93.          this.dev = 0;
  94.       }
  95.  
  96.       this.closeStreams();
  97.    }
  98.  
  99.    private synchronized void mix() {
  100.       int var1 = this.ulaw.length;
  101.       byte[] var2 = this.ulaw;
  102.       switch (this.streams.size()) {
  103.          case 0:
  104.             for(int var18 = var1; var18-- > 0; var2[var18] = 127) {
  105.             }
  106.             break;
  107.          case 1:
  108.             InputStream var3 = (InputStream)this.streams.elementAt(0);
  109.             int var4 = 0;
  110.  
  111.             try {
  112.                var4 = var3.read(var2, 0, var1);
  113.             } catch (IOException var17) {
  114.                var4 = -1;
  115.             }
  116.  
  117.             if (var4 <= 0) {
  118.                this.streams.removeElementAt(0);
  119.                var4 = 0;
  120.  
  121.                try {
  122.                   var3.close();
  123.                } catch (IOException var16) {
  124.                }
  125.             }
  126.  
  127.             while(var4 < var1) {
  128.                var2[var4] = 127;
  129.                ++var4;
  130.             }
  131.             break;
  132.          default:
  133.             int[] var19 = ULAW_TAB;
  134.             int[] var21 = this.linear;
  135.             int var5 = this.streams.size() - 1;
  136.             InputStream var6 = (InputStream)this.streams.elementAt(var5);
  137.             int var7 = 0;
  138.  
  139.             try {
  140.                var7 = var6.read(var2, 0, var1);
  141.             } catch (IOException var15) {
  142.                var7 = -1;
  143.             }
  144.  
  145.             if (var7 <= 0) {
  146.                this.streams.removeElementAt(var5);
  147.                var7 = 0;
  148.  
  149.                try {
  150.                   var6.close();
  151.                } catch (IOException var14) {
  152.                }
  153.             }
  154.  
  155.             for(int var8 = 0; var8 < var7; ++var8) {
  156.                var21[var8] = var19[var2[var8] & 255];
  157.             }
  158.  
  159.             while(var7 < var1) {
  160.                var21[var7] = 0;
  161.                ++var7;
  162.             }
  163.  
  164.             while(var5-- > 0) {
  165.                var6 = (InputStream)this.streams.elementAt(var5);
  166.  
  167.                try {
  168.                   var7 = var6.read(var2, 0, var1);
  169.                } catch (IOException var13) {
  170.                   var7 = -1;
  171.                }
  172.  
  173.                if (var7 <= 0) {
  174.                   this.streams.removeElementAt(var5);
  175.                   var7 = 0;
  176.  
  177.                   try {
  178.                      var6.close();
  179.                   } catch (IOException var12) {
  180.                   }
  181.                }
  182.  
  183.                while(var7-- > 0) {
  184.                   var21[var7] += var19[var2[var7] & 255];
  185.                }
  186.             }
  187.  
  188.             int[] var26 = ULAW_LUT;
  189.  
  190.             int var28;
  191.             for(int var25 = var1; var25-- > 0; var2[var25] = (byte)var28) {
  192.                var28 = var21[var25];
  193.                if (var28 >= 0) {
  194.                   if (var28 > 32635) {
  195.                      var28 = 32635;
  196.                   }
  197.  
  198.                   var28 += 132;
  199.                   int var10 = var26[var28 >> 7];
  200.                   int var11 = var28 >> var10 + 3 & 15;
  201.                   var28 = (var10 << 4 | var11) ^ 255;
  202.                } else {
  203.                   var28 = -var28;
  204.                   if (var28 > 32635) {
  205.                      var28 = 32635;
  206.                   }
  207.  
  208.                   var28 += 132;
  209.                   int var31 = var26[var28 >> 7];
  210.                   int var32 = var28 >> var31 + 3 & 15;
  211.                   var28 = (var31 << 4 | var32) ^ 127;
  212.                }
  213.             }
  214.       }
  215.  
  216.    }
  217.  
  218.    private synchronized boolean waitForData() throws InterruptedException {
  219.       if (this.streams.size() == 0) {
  220.          this.close();
  221.          this.wait();
  222.          this.open();
  223.          return true;
  224.       } else {
  225.          return false;
  226.       }
  227.    }
  228.  
  229.    public void play() {
  230.       try {
  231.          long var1 = System.currentTimeMillis() - 16L;
  232.  
  233.          while(this.dev > 0) {
  234.             if (this.waitForData()) {
  235.                var1 = System.currentTimeMillis() - 16L;
  236.             }
  237.  
  238.             this.mix();
  239.             this.audioWrite(this.ulaw, this.ulaw.length);
  240.             var1 += 50L;
  241.             long var3 = var1 - System.currentTimeMillis();
  242.             if (var3 > 0L) {
  243.                Thread.currentThread();
  244.                Thread.sleep(var3);
  245.             } else {
  246.                var1 = System.currentTimeMillis() - 16L;
  247.             }
  248.          }
  249.       } catch (InterruptedException var5) {
  250.       }
  251.  
  252.    }
  253.  
  254.    public synchronized void closeStreams() {
  255.       Enumeration var1 = this.streams.elements();
  256.  
  257.       while(var1.hasMoreElements()) {
  258.          try {
  259.             ((InputStream)var1.nextElement()).close();
  260.          } catch (IOException var2) {
  261.          }
  262.       }
  263.  
  264.       this.streams = new Vector();
  265.    }
  266.  
  267.    public int openChannels() {
  268.       return this.streams.size();
  269.    }
  270. }
  271.