home *** CD-ROM | disk | FTP | other *** search
/ PC Pro 1999 April / DPPCPRO0499.ISO / April / Notes / 50b2wic.exe / DATA1.CAB / NotesProgramFilesJavaSupport / rt.jar / sun / audio / AudioDevice.class (.txt) < prev    next >
Encoding:
Java Class File  |  1998-04-23  |  11.5 KB  |  272 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("mmedia");
  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.    public synchronized void open() {
  57.       int var1 = 1;
  58.       byte var2 = 5;
  59.  
  60.       while(this.dev == 0) {
  61.          this.dev = this.audioOpen();
  62.          if (this.dev < 0) {
  63.             System.out.println("no audio device");
  64.             return;
  65.          }
  66.  
  67.          if (this.dev == 0) {
  68.             System.out.println("audio device busy (attempt " + var1 + " out of " + var2 + ")");
  69.             if (this.streams.size() != 0) {
  70.                ++var1;
  71.                if (var1 <= var2) {
  72.                   try {
  73.                      this.wait(3000L);
  74.                      continue;
  75.                   } catch (InterruptedException var3) {
  76.                      this.closeStreams();
  77.                      return;
  78.                   }
  79.                }
  80.             }
  81.  
  82.             this.closeStreams();
  83.             return;
  84.          }
  85.       }
  86.  
  87.    }
  88.  
  89.    public synchronized void close() {
  90.       if (this.dev != 0) {
  91.          this.audioClose();
  92.          this.dev = 0;
  93.       }
  94.  
  95.       this.closeStreams();
  96.    }
  97.  
  98.    private synchronized void mix() {
  99.       int var1 = this.ulaw.length;
  100.       byte[] var2 = this.ulaw;
  101.       switch (this.streams.size()) {
  102.          case 0:
  103.             for(int var19 = var1; var19-- > 0; var2[var19] = 127) {
  104.             }
  105.  
  106.             return;
  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 var14) {
  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 var13) {
  124.                }
  125.             }
  126.  
  127.             while(var4 < var1) {
  128.                var2[var4] = 127;
  129.                ++var4;
  130.             }
  131.  
  132.             return;
  133.          default:
  134.             int[] var20 = ULAW_TAB;
  135.             int[] var22 = this.linear;
  136.             int var5 = this.streams.size() - 1;
  137.             InputStream var6 = (InputStream)this.streams.elementAt(var5);
  138.             int var7 = 0;
  139.  
  140.             try {
  141.                var7 = var6.read(var2, 0, var1);
  142.             } catch (IOException var18) {
  143.                var7 = -1;
  144.             }
  145.  
  146.             if (var7 <= 0) {
  147.                this.streams.removeElementAt(var5);
  148.                var7 = 0;
  149.  
  150.                try {
  151.                   var6.close();
  152.                } catch (IOException var17) {
  153.                }
  154.             }
  155.  
  156.             for(int var8 = 0; var8 < var7; ++var8) {
  157.                var22[var8] = var20[var2[var8] & 255];
  158.             }
  159.  
  160.             while(var7 < var1) {
  161.                var22[var7] = 0;
  162.                ++var7;
  163.             }
  164.  
  165.             while(var5-- > 0) {
  166.                var6 = (InputStream)this.streams.elementAt(var5);
  167.  
  168.                try {
  169.                   var7 = var6.read(var2, 0, var1);
  170.                } catch (IOException var16) {
  171.                   var7 = -1;
  172.                }
  173.  
  174.                if (var7 <= 0) {
  175.                   this.streams.removeElementAt(var5);
  176.                   var7 = 0;
  177.  
  178.                   try {
  179.                      var6.close();
  180.                   } catch (IOException var15) {
  181.                   }
  182.                }
  183.  
  184.                while(var7-- > 0) {
  185.                   var22[var7] += var20[var2[var7] & 255];
  186.                }
  187.             }
  188.  
  189.             int[] var9 = ULAW_LUT;
  190.  
  191.             int var28;
  192.             for(int var26 = var1; var26-- > 0; var2[var26] = (byte)var28) {
  193.                var28 = var22[var26];
  194.                if (var28 >= 0) {
  195.                   if (var28 > 32635) {
  196.                      var28 = 32635;
  197.                   }
  198.  
  199.                   var28 += 132;
  200.                   int var11 = var9[var28 >> 7];
  201.                   int var12 = var28 >> var11 + 3 & 15;
  202.                   var28 = (var11 << 4 | var12) ^ 255;
  203.                } else {
  204.                   var28 = -var28;
  205.                   if (var28 > 32635) {
  206.                      var28 = 32635;
  207.                   }
  208.  
  209.                   var28 += 132;
  210.                   int var31 = var9[var28 >> 7];
  211.                   int var32 = var28 >> var31 + 3 & 15;
  212.                   var28 = (var31 << 4 | var32) ^ 127;
  213.                }
  214.             }
  215.  
  216.       }
  217.    }
  218.  
  219.    private synchronized boolean waitForData() throws InterruptedException {
  220.       if (this.streams.size() == 0) {
  221.          this.close();
  222.          this.wait();
  223.          this.open();
  224.          return true;
  225.       } else {
  226.          return false;
  227.       }
  228.    }
  229.  
  230.    public void play() {
  231.       try {
  232.          long var1 = System.currentTimeMillis() - 16L;
  233.  
  234.          while(this.dev > 0) {
  235.             if (this.waitForData()) {
  236.                var1 = System.currentTimeMillis() - 16L;
  237.             }
  238.  
  239.             this.mix();
  240.             this.audioWrite(this.ulaw, this.ulaw.length);
  241.             var1 += 50L;
  242.             long var3 = var1 - System.currentTimeMillis();
  243.             if (var3 > 0L) {
  244.                Thread.currentThread();
  245.                Thread.sleep(var3);
  246.             } else {
  247.                var1 = System.currentTimeMillis() - 16L;
  248.             }
  249.          }
  250.  
  251.       } catch (InterruptedException var5) {
  252.       }
  253.    }
  254.  
  255.    public synchronized void closeStreams() {
  256.       Enumeration var1 = this.streams.elements();
  257.  
  258.       while(var1.hasMoreElements()) {
  259.          try {
  260.             ((InputStream)var1.nextElement()).close();
  261.          } catch (IOException var2) {
  262.          }
  263.       }
  264.  
  265.       this.streams = new Vector();
  266.    }
  267.  
  268.    public int openChannels() {
  269.       return this.streams.size();
  270.    }
  271. }
  272.