/* -*-mode:java; c-basic-offset:2; indent-tabs-mode:nil -*- */
/* JOrbis
 * Copyright (C) 2000 ymnk, JCraft,Inc.
 *  
 * Written by: 2000 ymnk<ymnk@jcraft.com>
 *   
 * Many thanks to 
 *   Monty <monty@xiph.org> and 
 *   The XIPHOPHORUS Company http://www.xiph.org/ .
 * JOrbis has been based on their awesome works, Vorbis codec.
 *   
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Library 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 Library General Public License for more details.
 * 
 * You should have received a copy of the GNU Library General Public
 * License along with this program; if not, write to the Free Software
 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

package client.audio.jorbis;

public class DspState{
  static final float M_PI=3.1415926539f;
  static final int VI_TRANSFORMB=1;
  static final int VI_WINDOWB=1;

  int analysisp;
  Info vi;
  int modebits;

  float[][] pcm;
  int pcm_storage;
  int pcm_current;
  int pcm_returned;

  float[] multipliers;
  int envelope_storage;
  int envelope_current;

  int eofflag;

  int lW;
  int W;
  int nW;
  int centerW;

  long granulepos;
  long sequence;

  long glue_bits;
  long time_bits;
  long floor_bits;
  long res_bits;

  // local lookup storage
  float[][][][][] window; // block, leadin, leadout, type
  Object[][] transform;
  CodeBook[] fullbooks;
  // backend lookups are tied to the mode, not the backend or naked mapping
  Object[] mode;

  // local storage, only used on the encoding side.  This way the
  // application does not need to worry about freeing some packets'
  // memory and not others'; packet storage is always tracked.
  // Cleared next call to a _dsp_ function
  byte[] header;
  byte[] header1;
  byte[] header2;

  public DspState(){
    transform=new Object[2][];
    window=new float[2][][][][];
    window[0]=new float[2][][][];
    window[0][0]=new float[2][][];
    window[0][1]=new float[2][][];
    window[0][0][0]=new float[2][];
    window[0][0][1]=new float[2][];
    window[0][1][0]=new float[2][];
    window[0][1][1]=new float[2][];
    window[1]=new float[2][][][];
    window[1][0]=new float[2][][];
    window[1][1]=new float[2][][];
    window[1][0][0]=new float[2][];
    window[1][0][1]=new float[2][];
    window[1][1][0]=new float[2][];
    window[1][1][1]=new float[2][];
  }

  static float[] window(int type, int window, int left, int right){
    float[] ret=new float[window];
    switch(type){
      case 0:
        // The 'vorbis window' (window 0) is sin(sin(x)*sin(x)*2pi)
      {
        int leftbegin=window/4-left/2;
        int rightbegin=window-window/4-right/2;

        for(int i=0; i<left; i++){
          float x=(float)((i+.5)/left*M_PI/2.);
          x=(float)Math.sin(x);
          x*=x;
          x*=M_PI/2.;
          x=(float)Math.sin(x);
          ret[i+leftbegin]=x;
        }

        for(int i=leftbegin+left; i<rightbegin; i++){
          ret[i]=1.f;
        }

        for(int i=0; i<right; i++){
          float x=(float)((right-i-.5)/right*M_PI/2.);
          x=(float)Math.sin(x);
          x*=x;
          x*=M_PI/2.;
          x=(float)Math.sin(x);
          ret[i+rightbegin]=x;
        }
      }
        break;
      default:
        //free(ret);
        return (null);
    }
    return (ret);
  }

  // Analysis side code, but directly related to blocking.  Thus it's
  // here and not in analysis.c (which is for analysis transforms only).
  // The init is here because some of it is shared

  int init(Info vi, boolean encp){
    this.vi=vi;
    modebits=Util.ilog2(vi.modes);

    transform[0]=new Object[VI_TRANSFORMB];
    transform[1]=new Object[VI_TRANSFORMB];

    // MDCT is tranform 0

    transform[0][0]=new Mdct();
    transform[1][0]=new Mdct();
    ((Mdct)transform[0][0]).init(vi.blocksizes[0]);
    ((Mdct)transform[1][0]).init(vi.blocksizes[1]);

    window[0][0][0]=new float[VI_WINDOWB][];
    window[0][0][1]=window[0][0][0];
    window[0][1][0]=window[0][0][0];
    window[0][1][1]=window[0][0][0];
    window[1][0][0]=new float[VI_WINDOWB][];
    window[1][0][1]=new float[VI_WINDOWB][];
    window[1][1][0]=new float[VI_WINDOWB][];
    window[1][1][1]=new float[VI_WINDOWB][];

    for(int i=0; i<VI_WINDOWB; i++){
      window[0][0][0][i]=window(i, vi.blocksizes[0], vi.blocksizes[0]/2,
          vi.blocksizes[0]/2);
      window[1][0][0][i]=window(i, vi.blocksizes[1], vi.blocksizes[0]/2,
          vi.blocksizes[0]/2);
      window[1][0][1][i]=window(i, vi.blocksizes[1], vi.blocksizes[0]/2,
          vi.blocksizes[1]/2);
      window[1][1][0][i]=window(i, vi.blocksizes[1], vi.blocksizes[1]/2,
          vi.blocksizes[0]/2);
      window[1][1][1][i]=window(i, vi.blocksizes[1], vi.blocksizes[1]/2,
          vi.blocksizes[1]/2);
    }

    fullbooks=new CodeBook[vi.books];
    for(int i=0; i<vi.books; i++){
      fullbooks[i]=new CodeBook();
      fullbooks[i].init_decode(vi.book_param[i]);
    }

    // initialize the storage vectors to a decent size greater than the
    // minimum

    pcm_storage=8192; // we'll assume later that we have
    // a minimum of twice the blocksize of
    // accumulated samples in analysis
    pcm=new float[vi.channels][];
    {
      for(int i=0; i<vi.channels; i++){
        pcm[i]=new float[pcm_storage];
      }
    }

    // all 1 (large block) or 0 (small block)
    // explicitly set for the sake of clarity
    lW=0; // previous window size
    W=0; // current window size

    // all vector indexes; multiples of samples_per_envelope_step
    centerW=vi.blocksizes[1]/2;

    pcm_current=centerW;

    // initialize all the mapping/backend lookups
    mode=new Object[vi.modes];
    for(int i=0; i<vi.modes; i++){
      int mapnum=vi.mode_param[i].mapping;
      int maptype=vi.map_type[mapnum];
      mode[i]=FuncMapping.mapping_P[maptype].look(this, vi.mode_param[i],
          vi.map_param[mapnum]);
    }
    return (0);
  }

  public int synthesis_init(Info vi){
    init(vi, false);
    // Adjust centerW to allow an easier mechanism for determining output
    pcm_returned=centerW;
    centerW-=vi.blocksizes[W]/4+vi.blocksizes[lW]/4;
    granulepos=-1;
    sequence=-1;
    return (0);
  }

  DspState(Info vi){
    this();
    init(vi, false);
    // Adjust centerW to allow an easier mechanism for determining output
    pcm_returned=centerW;
    centerW-=vi.blocksizes[W]/4+vi.blocksizes[lW]/4;
    granulepos=-1;
    sequence=-1;
  }

  // Unike in analysis, the window is only partially applied for each
  // block.  The time domain envelope is not yet handled at the point of
  // calling (as it relies on the previous block).

  public int synthesis_blockin(Block vb){
    // Shift out any PCM/multipliers that we returned previously
    // centerW is currently the center of the last block added
    if(centerW>vi.blocksizes[1]/2&&pcm_returned>8192){
      // don't shift too much; we need to have a minimum PCM buffer of
      // 1/2 long block

      int shiftPCM=centerW-vi.blocksizes[1]/2;
      shiftPCM=(pcm_returned<shiftPCM ? pcm_returned : shiftPCM);

      pcm_current-=shiftPCM;
      centerW-=shiftPCM;
      pcm_returned-=shiftPCM;
      if(shiftPCM!=0){
        for(int i=0; i<vi.channels; i++){
          System.arraycopy(pcm[i], shiftPCM, pcm[i], 0, pcm_current);
        }
      }
    }

    lW=W;
    W=vb.W;
    nW=-1;

    glue_bits+=vb.glue_bits;
    time_bits+=vb.time_bits;
    floor_bits+=vb.floor_bits;
    res_bits+=vb.res_bits;

    if(sequence+1!=vb.sequence)
      granulepos=-1; // out of sequence; lose count

    sequence=vb.sequence;

    {
      int sizeW=vi.blocksizes[W];
      int _centerW=centerW+vi.blocksizes[lW]/4+sizeW/4;
      int beginW=_centerW-sizeW/2;
      int endW=beginW+sizeW;
      int beginSl=0;
      int endSl=0;

      // Do we have enough PCM/mult storage for the block?
      if(endW>pcm_storage){
        // expand the storage
        pcm_storage=endW+vi.blocksizes[1];
        for(int i=0; i<vi.channels; i++){
          float[] foo=new float[pcm_storage];
          System.arraycopy(pcm[i], 0, foo, 0, pcm[i].length);
          pcm[i]=foo;
        }
      }

      // overlap/add PCM
      switch(W){
        case 0:
          beginSl=0;
          endSl=vi.blocksizes[0]/2;
          break;
        case 1:
          beginSl=vi.blocksizes[1]/4-vi.blocksizes[lW]/4;
          endSl=beginSl+vi.blocksizes[lW]/2;
          break;
      }

      for(int j=0; j<vi.channels; j++){
        int _pcm=beginW;
        // the overlap/add section
        int i=0;
        for(i=beginSl; i<endSl; i++){
          pcm[j][_pcm+i]+=vb.pcm[j][i];
        }
        // the remaining section
        for(; i<sizeW; i++){
          pcm[j][_pcm+i]=vb.pcm[j][i];
        }
      }

      // track the frame number... This is for convenience, but also
      // making sure our last packet doesn't end with added padding.  If
      // the last packet is partial, the number of samples we'll have to
      // return will be past the vb->granulepos.
      //       
      // This is not foolproof!  It will be confused if we begin
      // decoding at the last page after a seek or hole.  In that case,
      // we don't have a starting point to judge where the last frame
      // is.  For this reason, vorbisfile will always try to make sure
      // it reads the last two marked pages in proper sequence

      if(granulepos==-1){
        granulepos=vb.granulepos;
      }
      else{
        granulepos+=(_centerW-centerW);
        if(vb.granulepos!=-1&&granulepos!=vb.granulepos){
          if(granulepos>vb.granulepos&&vb.eofflag!=0){
            // partial last frame.  Strip the padding off
            _centerW-=(granulepos-vb.granulepos);
          }// else{ Shouldn't happen *unless* the bitstream is out of
          // spec.  Either way, believe the bitstream }
          granulepos=vb.granulepos;
        }
      }

      // Update, cleanup

      centerW=_centerW;
      pcm_current=endW;
      if(vb.eofflag!=0)
        eofflag=1;
    }
    return (0);
  }

  // pcm==NULL indicates we just want the pending samples, no more
  public int synthesis_pcmout(float[][][] _pcm, int[] index){
    if(pcm_returned<centerW){
      if(_pcm!=null){
        for(int i=0; i<vi.channels; i++){
          index[i]=pcm_returned;
        }
        _pcm[0]=pcm;
      }
      return (centerW-pcm_returned);
    }
    return (0);
  }

  public int synthesis_read(int bytes){
    if(bytes!=0&&pcm_returned+bytes>centerW)
      return (-1);
    pcm_returned+=bytes;
    return (0);
  }

  public void clear(){
  }
}