playfile.java

java ogg player library. for play back ogg audio

/* -*-mode:java; c-basic-offset:2; -*- */
/* JRoar -- pure Java streaming server for Ogg 
 *
 * Copyright (C) 2001,2002 ymnk, JCraft,Inc.
 *
 * Written by: 2001,2002 ymnk<[e-mail]>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

package com.jcraft.jroar;
import java.io.*;
import java.net.*;
import java.util.*;

import com.jcraft.jogg.*;

class PlayFile extends Source implements Runnable{
  static final int BUFSIZE=4096*2;

  private InputStream bitStream=null;

  private SyncState oy;
  private com.jcraft.jogg.Page og;
  
  private byte[] buffer=null;
  private int bytes=0;

  private Thread me=null;
  private String file=null;
  private String[] files=null;

  PlayFile(String mountpoint, String[] files){
    super(mountpoint);
HttpServer.source_connections++;
    this.source="playlist";
    this.files=files;
  }
  PlayFile(String mountpoint, String file){
    super(mountpoint);
HttpServer.source_connections++;
    this.source="playlist";
    if(file.startsWith("http://") && 
       file.endsWith(".m3u")){
      Vector foo=JRoar.fetch_m3u(file);
      if(foo.size()>0){
        this.files=new String[foo.size()];
        for(int i=0; i<foo.size(); i++){
          this.files[i]=(String)foo.elementAt(i);
	} 
        this.source=file;
      }
      else{
        drop();
HttpServer.source_connections--;
      }
    }
    else if(JRoar.running_as_applet){
      drop();
HttpServer.source_connections--;
    }
    else if(file.equals("-")){
      this.files=new String[1];
      this.files[0]=file;
    }
    else if(file.endsWith(".ogg") || file.endsWith(".spx")){
      this.files=new String[1];
      this.files[0]=file;
      if(file.startsWith("http://")){
        this.source=file;
      }
    }
    else {
      this.file=file;
      try{
	updateFiles(file);
      }
      catch(Exception e){
System.out.println(e);
        drop();
HttpServer.source_connections--;
      }
    }
  }

  long file_lastm=0;
  private void updateFiles(String file) throws java.io.FileNotFoundException{
System.out.println("loadPlaylist: "+file);
    File _file=new File(file);
    file_lastm=_file.lastModified();
    BufferedReader d
      = new BufferedReader(new InputStreamReader(new FileInputStream(_file)));
    Vector v=new Vector();
    try{
      while(true){
	String s=d.readLine();
	if(s==null)break;
	if(s.startsWith("#")) continue;
	if(!s.startsWith("http://") && 
	   !s.endsWith(".ogg") && 
	   !s.endsWith(".spx")) 
	  continue;
System.out.println("playFile ("+s+")");
        v.addElement(s);
      }
      d.close();
    }
    catch(Exception ee){}
    this.files=new String[v.size()];
    for(int i=0; i<v.size(); i++){
      this.files[i]=(String)v.elementAt(i);
    }
  }

  void init_ogg(){
    oy=new SyncState();
    og=new com.jcraft.jogg.Page();
    buffer=null;
    bytes=0;
    oy.init();
  }

  public void kick(){

    if(me!=null){
	/*
      int size=listeners.size();
      Client c=null;
        c=(Client)(listeners.elementAt(1));
System.out.println(c);
        if(System.currentTimeMillis()-c.lasttime>1000){
          try{
            ((HttpClient)c).ms.close();
	  }
          catch(Exception e){}
	}
	*/
      return;
    }
    me=new Thread(this);
    me.start();
  }

static String status="status0";
//static String file="??";

  public void run(){
    Vector http_header=new Vector();
    http_header.addElement("HTTP/1.0 200 OK");
    http_header.addElement("Content-Type: application/x-ogg");

    int ii=-1;
  loop:
    while(me!=null){
      ii++;
      if(this.file!=null &&
	 file_lastm<(new File(this.file)).lastModified()){
	try{
	  updateFiles(file);
	}
	catch(Exception e){
	  break;
	}
      }
      if(ii>=files.length)ii=0;

status="status1";

//System.out.println("status: "+status+" files.length="+files.length);

      bitStream=null;
      if(files[ii].startsWith("http://")){
        try{
          URL url=new URL(files[ii]);
          URLConnection urlc=url.openConnection();

          setURLProperties(urlc);        // for jroar 

          bitStream=urlc.getInputStream();
	}
	catch(Exception e){
          System.out.println(e);
	}
      }
      else if(files[ii].equals("-")){
        bitStream=System.in;
      }

//System.out.println("bitStream: "+bitStream);

      if(bitStream==null){
        try{ bitStream=new FileInputStream(files[ii]); }	
        catch(Exception e){
        System.out.println(e);
	}
      }

//System.out.println("bitStream: "+bitStream);

      if(bitStream==null){
        files[ii]=null;
        String[] foo=new String[files.length-1];
        if(ii>0)
          System.arraycopy(files, 0, foo, 0, ii);
        if(ii!=files.length-1)
          System.arraycopy(files, ii+1, foo, ii, files.length-1-ii);
        files=foo;
	ii--;
        if(files.length==0){
          break;
	}
        continue;
      }

//System.out.println("bitStream: "+bitStream);

file=files[ii];
status="status2";

//System.out.println("file: "+file);

      init_ogg();

      int serialno=-1;
      long granulepos=-1;

      long start_time=-1;
      long last_sample=0;
      long time=0;

      ByteArrayOutputStream _header=new ByteArrayOutputStream();
      byte[] header=null;
      com.jcraft.jogg.Page[] pages=new com.jcraft.jogg.Page[10];
      int page_count=0;

      boolean eos=false;
      while(!eos){
status="status3";
        if(me==null) break;
status="status4";
        int index=oy.buffer(BUFSIZE);
        buffer=oy.data;
        try{ bytes=bitStream.read(buffer, index, BUFSIZE); }
        catch(Exception e){
          System.err.println(e);
          eos=true;
          continue;
        }
        if(bytes==-1)break;
        if(bytes==0)break;
status="status5";
        oy.wrote(bytes);

        while(!eos){
status="status6";
          if(me==null) break;
status="status7";
          int result=oy.pageout(og);

	  if(result==0)break; // need more data
	  if(result==-1){ // missing or corrupt data at this page position
//	    System.err.println("Corrupt or missing data in bitstream; continuing...");
	  }
	  else{
	    /*
  	    if(serialno!=og.serialno()){
              header=null;
              serialno=og.serialno();
	    }
	    */
	    serialno=og.serialno();
	    granulepos=og.granulepos();
status="status8";          

//System.out.println("og: "+og+", pos="+og.granulepos());

            if((granulepos==0)
               ||(granulepos==-1)          // hack for Speex
	       ){

	      if(pages.length<=page_count){
		com.jcraft.jogg.Page[] foo=new com.jcraft.jogg.Page[pages.length*2];
		System.arraycopy(pages, 0, foo, 0, pages.length);
		pages=foo;
	      }
	      pages[page_count++]=og.copy();
	    }
            else{
              if(header==null){
		parseHeader(pages, page_count);
//System.out.println("rate: "+current_info.rate);
		com.jcraft.jogg.Page foo;
		for(int i=0;i< page_count; i++){
		  foo=pages[i];
		  _header.write(foo.header_base, foo.header, foo.header_len);
		  _header.write(foo.body_base, foo.body, foo.body_len);
		}
                header=_header.toByteArray();
                _header.reset();

		page_count=0;
                start_time=System.currentTimeMillis();
                last_sample=0;
                time=0;
	      }
	    }

status="status9";          
//            synchronized(listeners){  // In some case, c.write will block.
status="status99";          
  	      int size=listeners.size();

              Client c=null;
              for(int i=0; i<size;){
status="status10";
                try{
   	          c=(Client)(listeners.elementAt(i));
                  c.write(http_header, header,
		          og.header_base, og.header, og.header_len,
			  og.body_base, og.body, og.body_len);
                }
		catch(Exception e){
                  c.close();
                  removeListener(c);
                  size--;
                  continue;
                }
                i++;
	      }
//	    }
status="status11";
            if(granulepos!=0 &&
	       key_serialno==serialno){
status="status111";
                if(last_sample==0){
  	          time=(System.currentTimeMillis()-start_time)*1000;
                }
                else{
 		  time+= (long)(((granulepos-last_sample)*1000000)/
			        ((current_info.rate)));
		}
                last_sample=granulepos;
                long sleep=(time/1000)-(System.currentTimeMillis()-start_time);
//System.out.println("sleep="+sleep);
//if(sleep>10000){sleep=0; time=(System.currentTimeMillis()-start_time);}
status="status112";
                if(sleep>0){
//System.out.println("sleep: "+sleep);
  	          try{ Thread.sleep(sleep); }
    	          catch(Exception e){}
		} 
status="status12";
	    }

            // sleep for green thread.
            try{ Thread.sleep(1); }
            catch(Exception e){}

status="status13";

//	    if(og.eos()!=0)eos=true;

	  }
status="status14";
        }
status="status15";
      }
      oy.clear();
      try { if(bitStream!=null)bitStream.close(); } 
      catch(Exception e) { }
      bitStream=null;
status="status16";
    }

    oy.clear();
    try { if(bitStream!=null)bitStream.close(); } 
    catch(Exception e) { }
    bitStream=null;
status="status14";

    drop();
  }

  private void setURLProperties(URLConnection urlc){
    if(HttpServer.myURL!=null){
      urlc.setRequestProperty("jroar-proxy", HttpServer.myURL+mountpoint);
      //System.out.println(HttpServer.myURL+mountpoint);
      if(JRoar.comment!=null)
        urlc.setRequestProperty("jroar-comment", JRoar.comment);
    }
  }

  public void stop(){
    if(me!=null){
      if(oy!=null) oy.clear();
      try {
       if(bitStream!=null)bitStream.close();
      } 
      catch(Exception e) { }
      bitStream=null;
      me=null;
    }
    drop_clients();
  }

  void drop_clients(){
    Client c=null;
    synchronized(listeners){
      int size=listeners.size();
      for(int i=0; i<size;i++){
        c=(Client)(listeners.elementAt(i));
        try{ c.close();}
        catch(Exception e){}
      }
      listeners.removeAllElements();
    }
  }

  void drop(){
    stop();
    //drop_clients();
    super.drop();
  }
}