bashfest~.c

#include "MSPd.h"
#include "bashfest.h"
#include <string.h>

/* THIS IS PROBABLY THE LIMITING FACTOR FOR LARGE BUFFER SIZES
 SO, MAKE THIS A PARAMETER, -OR- BUFFER THE INPUT TRIGGER ITSELF!!!
 */
#define DEFAULT_MAX_OVERLAP (8) // number of overlapping instances allowed
#define ACTIVE 0
#define INACTIVE 1
#define MAX_VEC 2048
#define DEFAULT_BUFFER_SIZE 4000.0 // 4 second default buffer size * 2
#define DEFAULT_LATENCY 8192 //latency in samples after a trigger for note to start
#define MAX_PARAMETERS 2048
#define PROCESS_COUNT 20
#define CYCLE_MAX 1024

#define OBJECT_NAME "bashfest~"


static t_class *bashfest_class;

static void *bashfest_new(t_symbol *msg, int argc, t_atom *argv);
static t_int *bashfest_perform_hosed(t_int *w);
static void bashfest_dsp(t_bashfest *x, t_signal **sp);
static void bashfest_dsp_free(t_bashfest *x);
static int bashfest_set_parameters(t_bashfest *x,t_float *params);
static t_int *bashfest_perform(t_int *w);
static void bashfest_deploy_dsp(t_bashfest *x);
static void bashfest_copy_to_MSP_buffer(t_bashfest *x, int slot);
/*user messages*/
static void bashfest_stop(t_bashfest *x);
static void bashfest_info(t_bashfest *x);
static void bashfest_mute(t_bashfest *x, t_floatarg t);
static void bashfest_maximum_process(t_bashfest *x, t_floatarg n);
static void bashfest_minimum_process(t_bashfest *x, t_floatarg n);
static void bashfest_setbuf(t_bashfest *x, t_symbol *wavename);
static void bashfest_flatodds(t_bashfest *x);
static void bashfest_killproc(t_bashfest *x, long p);
static void bashfest_soloproc(t_bashfest *x, long p);
static void bashfest_latency(t_bashfest *x, long n);
static void bashfest_verbose(t_bashfest *x, long t);
static void bashfest_block_dsp(t_bashfest *x, t_floatarg t);
static void bashfest_gozero(t_bashfest *x);
static void bashfest_grab(t_bashfest *x);
static void bashfest_setodds(t_bashfest *x,t_symbol *msg, int argc, t_atom *argv);
static void bashfest_tcycle(t_bashfest *x,t_symbol *msg, int argc, t_atom *argv);
/* function code */

void lpp_killdc( t_float *inbuf, int in_frames, int channels, t_bashfest *x);
void lpp_ringmod(t_bashfest *x, int slot, int *pcount);
void lpp_retrograde(t_bashfest *x, int slot, int *pcount);
void lpp_comber(t_bashfest *x, int slot, int *pcount);
void lpp_transpose(t_bashfest *x, int slot, int *pcount);
void lpp_flange(t_bashfest *x, int slot, int *pcount);
void lpp_butterme(t_bashfest *x, int slot, int *pcount);
void lpp_truncateme(t_bashfest *x, int slot, int *pcount);
void lpp_sweepreson(t_bashfest *x, int slot, int *pcount);
void lpp_slidecomb(t_bashfest *x, int slot, int *pcount);
void lpp_reverb1(t_bashfest *x, int slot, int *pcount);
void lpp_ellipseme(t_bashfest *x, int slot, int *pcount);
void lpp_feed1me(t_bashfest *x, int slot, int *pcount);
void lpp_flam1(t_bashfest *x, int slot, int *pcount);
void lpp_flam2(t_bashfest *x, int slot, int *pcount);
void lpp_expflam(t_bashfest *x, int slot, int *pcount);
void lpp_comb4(t_bashfest *x, int slot, int *pcount);
void lpp_ringfeed(t_bashfest *x, int slot, int *pcount);
void lpp_resonadsr(t_bashfest *x, int slot, int *pcount);
void lpp_stv(t_bashfest *x, int slot, int *pcount);
void lpp_compdist(t_bashfest *x, int slot, int *pcount);


void atom_arg_getfloat(t_float *c, long idx, long ac, t_atom *av);
void atom_arg_getsym(t_symbol **c, long idx, long ac, t_atom *av);




void bashfest_tilde_setup(void)
{
    bashfest_class = class_new(gensym("bashfest~"),(t_newmethod)bashfest_new,(t_method)bashfest_dsp_free, sizeof(t_bashfest), 0, A_GIMME,0);
    CLASS_MAINSIGNALIN(bashfest_class,t_bashfest, x_f );
    class_addmethod(bashfest_class,(t_method)bashfest_dsp,gensym("dsp"),A_CANT,0);
    class_addmethod(bashfest_class,(t_method)bashfest_setbuf,gensym("setbuf"),A_SYMBOL,0);
    class_addmethod(bashfest_class,(t_method)bashfest_stop,gensym("stop"),0);
    class_addmethod(bashfest_class,(t_method)bashfest_flatodds,gensym("flatodds"),0);
    class_addmethod(bashfest_class,(t_method)bashfest_soloproc,gensym("soloproc"),A_FLOAT,0);
    class_addmethod(bashfest_class,(t_method)bashfest_killproc,gensym("killproc"),A_FLOAT,0);
    class_addmethod(bashfest_class,(t_method)bashfest_latency,gensym("latency"),A_FLOAT,0);
    class_addmethod(bashfest_class,(t_method)bashfest_mute,gensym("mute"),A_FLOAT,0);
    class_addmethod(bashfest_class,(t_method)bashfest_verbose,gensym("verbose"),A_FLOAT,0);
    class_addmethod(bashfest_class,(t_method)bashfest_setodds,gensym("setodds"),A_GIMME,0);
    class_addmethod(bashfest_class,(t_method)bashfest_tcycle,gensym("tcycle"),A_GIMME,0);
    class_addmethod(bashfest_class,(t_method)bashfest_gozero,gensym("gozero"),0);
    class_addmethod(bashfest_class,(t_method)bashfest_grab,gensym("grab"),0);
    class_addmethod(bashfest_class,(t_method)bashfest_maximum_process,gensym("maximum_process"),A_FLOAT,0);
    class_addmethod(bashfest_class,(t_method)bashfest_minimum_process,gensym("minimum_process"),A_FLOAT,0);
    class_addmethod(bashfest_class,(t_method)bashfest_block_dsp,gensym("block_dsp"),A_FLOAT,0);
    potpourri_announce(OBJECT_NAME);
}


void bashfest_block_dsp(t_bashfest *x, t_floatarg t)
{
    
    x->block_dsp = (short)t;
    
}
void bashfest_maximum_process(t_bashfest *x, t_floatarg n)
{
    if(n < 0) {
        pd_error(0, "illegal val to maximum_process");
        return;
    }
    x->max_process_per_note = (int)n;
}

void bashfest_minimum_process(t_bashfest *x, t_floatarg n)
{
    if(n < 0) {
        pd_error(0, "illegal val to minimum_process");
        return;
    }
    x->min_process_per_note = (int)n;
}

void bashfest_verbose(t_bashfest *x, long t)
{
    x->verbose = t;
}
void bashfest_latency(t_bashfest *x, long n)
{
    if(n < x->vs) {
        pd_error(0, "latency cannot be less than %d",x->vs);
        return;
    }
    /*  if(n > x->latency_samples) {
     x->trigger_buffer = (t_float *) realloc(x->trigger_buffer, n * sizeof(t_float));
     }
     x->tb_inpt = 0;
     x->tb_outpt = x->latency_samples - x->vs;*/
    x->latency_samples = n;
}

void bashfest_stop(t_bashfest *x)
{
    int i;
    
    for(i = 0; i < x->overlap_max; i++) {
        x->events[i].status = INACTIVE;
    }
}


void bashfest_mute(t_bashfest *x, t_floatarg t)
{
    x->mute = (short)t;
}


void bashfest_grab(t_bashfest *x)
{
    x->grab = 1;
}

void bashfest_tcycle(t_bashfest *x,t_symbol *msg, int argc, t_atom *argv)
{
    t_cycle tcycle = x->tcycle;
    int i;
    t_float data=1.0;
    
    if(argc < 1) {
        pd_error(0, "no data for tcycle!");
        return;
    } else if(argc > CYCLE_MAX) {
        pd_error(0, "%d is the maximum size tcycle",CYCLE_MAX);
        return;
    }
    x->tcycle.len = argc;
    x->tcycle.p = 0;
    for(i=0;i<argc;i++) {
        atom_arg_getfloat(&data,i,argc,argv);
        if(data <= 0.0) {
            pd_error(0, "bad data for tcycle:%f",data);
        } else {
            tcycle.data[i] = data;
        }
    }
}

void bashfest_gozero(t_bashfest *x)
{
    x->tcycle.p = 0;
}

void bashfest_setodds(t_bashfest *x,t_symbol *msg, int argc, t_atom *argv)
{
    int i;
    
    if(argc > PROCESS_COUNT) {
        pd_error(0, "there are only %d processes",PROCESS_COUNT);
        return;
    }
    for(i=0;i<PROCESS_COUNT;i++) {
        x->odds[i] = 0.0;
    }
    
    
    for(i=0;i<argc;i++) {
        x->odds[i] = atom_getfloatarg(i,argc,argv);
    }
    
    lpp_setweights(x->odds,PROCESS_COUNT);
}

void bashfest_soloproc(t_bashfest *x, long p)
{
    int i;
    if(p < 0 || p >= PROCESS_COUNT) {
        pd_error(0, "bad %ld",p);
    }
    for(i=0;i<PROCESS_COUNT;i++) {
        x->odds[i] = 0.0;
    }
    x->odds[p] = 1.0;
    lpp_setweights(x->odds,PROCESS_COUNT);
}

void bashfest_killproc(t_bashfest *x, long p)
{
    int i;
    if(p < 0 || p >= PROCESS_COUNT) {
        pd_error(0, "bad %ld",p);
    }
    for(i=0;i<PROCESS_COUNT;i++) {
        x->odds[i] = 1.0;
    }
    x->odds[p] = 0.0;
    lpp_setweights(x->odds,PROCESS_COUNT);
}

void bashfest_flatodds(t_bashfest *x)
{
    int i;
    for(i=0;i<PROCESS_COUNT;i++) {
        x->odds[i] = 1.0;
    }
    lpp_setweights(x->odds,PROCESS_COUNT);
}


void *bashfest_new(t_symbol *msg, int argc, t_atom *argv)
{
    
    t_bashfest *x = (t_bashfest *)pd_new(bashfest_class);
    //  outlet_new(&x->x_obj, gensym("signal"));
    
    int i;
    long membytes = 0;
    t_float tmpfloat;
    srand(time(0));
    
    x->sr = sys_getsr();
    x->vs = sys_getblksize();
    if(! x->sr)
        x->sr = 44100;
    
    
    x->work_buffer_size = DEFAULT_BUFFER_SIZE;
    //  x->latency_samples = DEFAULT_LATENCY;
    //  x->overlap_max = DEFAULT_MAX_OVERLAP;
    
    /* argument list: buffer name, work buffer duration, latency in samples, number of overlaps */
    
    x->wavename = &s_;
    atom_arg_getsym(&x->wavename,0,argc,argv);
    atom_arg_getfloat(&x->work_buffer_size,1,argc,argv);
    tmpfloat = DEFAULT_LATENCY;
    atom_arg_getfloat(&tmpfloat,2,argc,argv);
    x->latency_samples = tmpfloat;
    tmpfloat = DEFAULT_MAX_OVERLAP;
    atom_arg_getfloat(&tmpfloat,3,argc,argv);
    x->overlap_max = tmpfloat;
    
    outlet_new(&x->x_obj, gensym("signal"));
    outlet_new(&x->x_obj, gensym("signal"));
    
    x->sinelen = 8192;
    
    x->verbose = 0;
    x->most_recent_event = 0;
    x->active_events = 0;
    x->increment = 1.0;
    x->block_dsp = 0;
    x->grab = 0;
    /*
     x->tb_inpt = 0;
     if(x->latency_samples < x->vs) {
     x->latency_samples = x->vs;//might need x->vs * 2 here
     pd_error(0, "latency forced to %d samples",x->vs);
     }
     x->tb_outpt = x->latency_samples - x->vs;
     */
    /* buffer contains space for both input and output, thus factor of 2 */
    x->buf_frames = 2 * x->work_buffer_size * .001 * x->sr;
    
    x->buf_samps = x->buf_frames * 2;
    x->halfbuffer = x->buf_samps / 2;
    
    x->maxdelay = 1.0; // in seconds
    /*memory allocation */
    x->events = (t_event *) t_getbytes(x->overlap_max * sizeof(t_event));
    x->trigger_vec = (t_float *) t_getbytes(MAX_VEC * sizeof(t_float));
    x->sinewave = t_getbytes(x->sinelen * sizeof(t_float));
    x->params = t_getbytes(MAX_PARAMETERS * sizeof(t_float));
    x->odds = t_getbytes(64 * sizeof(t_float));
    //  x->trigger_buffer = calloc(x->latency_samples, sizeof(t_float));
    
    for(i=0;i<64;i++)
    x->odds[i] = 0;
    lpp_putsine(x->sinewave, x->sinelen);
    for(i=0;i<x->overlap_max;i++) {
        x->events[i].workbuffer = (t_float *) t_getbytes(x->buf_samps * sizeof(t_float));
    }
    x->delayline1 = (t_float *) t_getbytes(x->maxdelay * x->sr * sizeof(t_float));
    x->delayline2 = (t_float *) t_getbytes(x->maxdelay * x->sr * sizeof(t_float));
    x->max_mini_delay = .25;
    x->eel = (LSTRUCT *) t_getbytes(MAXSECTS * sizeof(LSTRUCT));
    for( i = 0; i < 4 ; i++ ) {
        x->mini_delay[i] =
        (t_float *) t_getbytes(((int)(x->sr * x->max_mini_delay) + 1)  * sizeof(t_float));
    }
    x->reverb_ellipse_data = (t_float *) t_getbytes(16 * sizeof(t_float));
    
    x->ellipse_data = (t_float **) t_getbytes(MAXFILTER * sizeof(t_float *));
    for(i=0;i<MAXFILTER;i++) {
        x->ellipse_data[i] = (t_float *) t_getbytes(MAX_COEF * sizeof(t_float));
    }
    x->tf_len = 1;
    x->tf_len <<= 16;
    x->transfer_function = (t_float *) t_getbytes(x->tf_len * sizeof(t_float) );
    x->feedfunclen = 8192 ;
    x->feedfunc1 = (t_float *) t_getbytes( x->feedfunclen * sizeof(t_float) );
    x->feedfunc2 = (t_float *) t_getbytes( x->feedfunclen * sizeof(t_float) );
    x->feedfunc3 = (t_float *) t_getbytes( x->feedfunclen * sizeof(t_float) );
    x->feedfunc4 = (t_float *) t_getbytes( x->feedfunclen * sizeof(t_float) );
    x->flamfunc1len = 8192 ;
    x->flamfunc1 = (t_float *) t_getbytes( x->flamfunc1len * sizeof(t_float));
    lpp_setflamfunc1(x->flamfunc1,x->flamfunc1len);
    x->max_comb_lpt = 0.15 ;// watch out here
    x->combies = (CMIXCOMB *) t_getbytes(4 * sizeof(CMIXCOMB));
    for( i = 0; i < 4; i++ ) {
        x->combies[i].len = x->sr * x->max_comb_lpt + 2;
        x->combies[i].arr = (t_float *) t_getbytes(x->combies[i].len * sizeof(t_float));
    }
    x->adsr = (CMIXADSR *) t_getbytes(1 * sizeof(CMIXADSR));
    x->adsr->len = 32768 ;
    x->adsr->func = (t_float *) t_getbytes(x->adsr->len * sizeof(t_float) );
    x->dcflt = (t_float *) t_getbytes(16 * sizeof(t_float));
    x->tcycle.data = (t_float *) t_getbytes(CYCLE_MAX * sizeof(t_float));
    x->tcycle.len = 0;
    for(i=0;i<x->overlap_max;i++) {
        x->events[i].phasef = x->events[i].phase = 0.0;
    }
    
    membytes = x->overlap_max * sizeof(t_event);
    membytes += x->sinelen * sizeof(t_float);
    membytes += MAX_PARAMETERS * sizeof(t_float);
    membytes += 64 * sizeof(t_float);
    membytes += x->buf_samps * sizeof(t_float) * x->overlap_max;
    membytes += x->maxdelay * x->sr * sizeof(t_float) * 2;
    membytes += MAXSECTS * sizeof(LSTRUCT);
    membytes += ((int)(x->sr * x->max_mini_delay) + 1)  * sizeof(t_float) * 4;
    membytes += 16 * sizeof(t_float);
    membytes += MAXFILTER * sizeof(t_float *);
    membytes += MAX_COEF * sizeof(t_float) * MAXFILTER;
    membytes += x->tf_len * sizeof(t_float);
    membytes += x->feedfunclen * sizeof(t_float) * 4;
    membytes += x->flamfunc1len * sizeof(t_float);
    membytes += 4 * sizeof(CMIXCOMB);
    membytes += x->combies[0].len * sizeof(t_float) * 4;
    membytes += sizeof(CMIXADSR);
    membytes += x->adsr->len * sizeof(t_float);
    membytes += 16 * sizeof(t_float);
    membytes += CYCLE_MAX * sizeof(t_float);
    
    // post("total memory for this bashfest %.2f MBytes",(t_float)membytes/1000000.);
    
    /* be sure to finish clearing memory */
    lpp_set_dcflt(x->dcflt);
    lpp_init_reverb_data(x->reverb_ellipse_data);
    lpp_init_ellipse_data(x->ellipse_data);
    
    for(i=0;i<PROCESS_COUNT;i++) {
        x->odds[i] = 1;
    }
    
    
    x->max_process_per_note = 2;
    lpp_setweights(x->odds,PROCESS_COUNT);
    
    
    x->mute = 0;
    
    for(i = 0; i < x->overlap_max; i++) {
        x->events[i].status = INACTIVE;
    }
    return x;
}




void bashfest_setbuf(t_bashfest *x, t_symbol *wavename)
{
    t_garray *a;
    x->hosed = 0;
    x->b_frames = 0;
    x->b_nchans = 1;
    x->b_valid = 0;
    int b_frames;
    if (!(a = (t_garray *)pd_findbyclass(wavename, garray_class))) {
        if (*wavename->s_name) pd_error(x, "bashfest~: %s: no such array",
                                        wavename->s_name);
        x->b_samples = 0;
        x->hosed = 1;
    }
    else if (!garray_getfloatwords(a, &b_frames, &x->b_samples)) {
        pd_error(x, "%s: bad array for bashfest~", wavename->s_name);
        x->b_samples = 0;
        x->hosed = 1;
    }
    else  {
        x->b_frames = (long)b_frames;
        // post("%d frames in buffer %s",x->b_frames, wavename->s_name);
        garray_usedindsp(a);
        x->b_valid = 1;
    }
    
}



t_int *bashfest_perform_hosed(t_int *w)
{
    
    //  t_bashfest *x = (t_bashfest *) (w[1]);
    //  t_float *trigger = (t_float *)(w[2]);
    t_float *outchanL = (t_float *)(w[3]);
    t_float *outchanR = (t_float *)(w[4]);
    int n = (int) w[5];
    
    // try bzero
    //  while(n--) *outchanL++ = *outchanR++ = 0.0;
    memset((char *)outchanL, 0, sizeof(t_float) * n);
    memset((char *)outchanR, 0, sizeof(t_float) * n);
    return(w+6);
    
}

/* modified for dsp turnoff*/

t_int *bashfest_perform(t_int *w)
{
    t_bashfest *x = (t_bashfest *) (w[1]);
    t_float *t_vec = (t_float *)(w[2]);
    t_float *outchanL = (t_float *)(w[3]);
    t_float *outchanR = (t_float *)(w[4]);
    int n = (int) w[5];
    
    t_word *b_samples;
    long b_nchans;
    //    long b_valid;
    long b_frames;
    
    t_event *events = x->events;
    //  int active_events = x->active_events;
    t_float increment = x->increment;
    int overlap_max = x->overlap_max;
    int iphase;
    int flimit;
    short insert_success;
    int new_insert;
    int i,j,k;
    t_cycle tcycle = x->tcycle;
    t_float gain;
    //  short bail;
    t_float frac;
    t_float samp1, samp2;
    t_float maxphase;
    int theft_candidate;
    int out_channels;
    t_float *processed_drum;
    char *sound_name = x->sound_name;
    
    int latency_samples = x->latency_samples;
    t_float *trigger_vec = x->trigger_vec;
    
    for(i = 0; i < n; i++)
    trigger_vec[i] = t_vec[i];
    
    if(x->mute || x->hosed) {
        while(n--) {
            *outchanL++ = *outchanR++ = 0.0;
        }
        return(w+6);
    }
    bashfest_setbuf(x, x->wavename);
    
    if(! x->b_valid) {
        while(n--) {
            *outchanL++ = *outchanR++ = 0.0;
        }
        return(w+6);
    }
    
    b_samples = x->b_samples;
    b_frames = x->b_frames;
    b_nchans = 1; // for Pd
    
    if(x->block_dsp) {
        /* computation savings if processing is blocked */
        
        
        /* preliminary transposition will be set here */
        
        if(tcycle.len > 0) {
            increment = tcycle.data[tcycle.p];
            // post("position %d, increment %f",tcycle.p,increment );
        } else {
            increment = 1.0;
            //error("increment default, len is zero");
        }
        // initial cleaning
        for(i=0; i<n; i++) {
            outchanL[i] = outchanR[i] = 0.0;
        }
        flimit = (b_frames - 1) * 2;
        for(i = 0; i < overlap_max; i++) {
            if(events[i].status == ACTIVE) {
                gain = events[i].gain;
                
                if(b_nchans == 1){ /* mono */
                    
                    flimit = (b_frames - 1);
                    for(j = 0; j < n; j++) {
                        if(events[i].countdown > 0) {
                            --events[i].countdown;
                        } else {
                            
                            iphase = events[i].phasef;
                            frac = events[i].phasef - iphase;
                            
                            if(increment > 0) {
                                if(iphase == flimit || increment == 1.0) {
                                    outchanL[j] += b_samples[iphase].w_float * gain;
                                    outchanR[j] += b_samples[iphase].w_float * gain;
                                } else {
                                    samp1 = b_samples[iphase].w_float;
                                    samp2 = b_samples[iphase+1].w_float;
                                    samp1 = gain * (samp1 + frac * (samp2-samp1));
                                    outchanL[j] += samp1;
                                    outchanR[j] += samp1;
                                }
                            } else { /*negative increment case (currently unused but might be useful)*/
                                if(iphase == 0.0 || increment == -1.0 ) {
                                    outchanL[j] += b_samples[iphase].w_float * gain;
                                    outchanR[j] += b_samples[iphase].w_float * gain;
                                } else {
                                    samp2 = b_samples[iphase].w_float;
                                    samp1 = b_samples[iphase-1].w_float;
                                    samp1 = gain * (samp1 + frac * (samp2-samp1));
                                    outchanL[j] += samp1;
                                    outchanR[j] += samp1;
                                }
                            }
                            events[i].phasef += increment;
                            
                            if( events[i].phasef < 0.0 || events[i].phasef >= b_frames) {
                                events[i].status = INACTIVE;
                                events[i].phasef = 0;
                                // post("valid exit mono note");
                                break;
                            }
                        }
                    }
                } else if(b_nchans == 2) {
                    /*
                     
                     for(j = 0; j < n; j++) {
                     if(events[i].countdown > 0) {
                     --events[i].countdown;
                     } else {
                     iphase = events[i].phasef;
                     frac = events[i].phasef - iphase;
                     iphase *= 2;
                     if(increment > 0) {
                     if(iphase == flimit || increment == 1.0) {
                     outchanL[j] += b_samples[iphase] * gain;
                     outchanR[j] += b_samples[iphase+1] * gain;
                     } else {
                     samp1 = b_samples[iphase];
                     samp2 = b_samples[iphase+2];
                     outchanL[j] += gain * (samp1 + frac * (samp2-samp1));
                     samp1 = b_samples[iphase+1];
                     samp2 = b_samples[iphase+3];
                     outchanR[j] += gain * (samp1 + frac * (samp2-samp1));
                     }
                     } else {
                     if(iphase == 0.0 || increment == -1.0 ) {
                     outchanL[j] += b_samples[iphase] * gain;
                     outchanR[j] += b_samples[iphase+1] * gain;
                     } else {
                     samp2 = b_samples[iphase];
                     samp1 = b_samples[iphase-2];
                     outchanL[j] += gain * (samp1 + frac * (samp2-samp1));
                     samp2 = b_samples[iphase+1];
                     samp1 = b_samples[iphase-1];
                     outchanR[j] += gain * (samp1 + frac * (samp2-samp1));
                     }
                     }
                     events[i].phasef += increment;
                     
                     if( events[i].phasef < 0.0 || events[i].phasef >= b_frames) {
                     events[i].status = INACTIVE;
                     break;
                     }
                     }
                     }*/
                }
            }
        }
        
        for(i=0; i<n; i++) {
            if(trigger_vec[i]) {
                gain = trigger_vec[i];
                
                insert_success = 0;
                for(j=0; j<overlap_max; j++) {
                    if(events[j].status == INACTIVE) {
                        events[j].status = ACTIVE;
                        events[j].gain = gain;
                        if(increment > 0) {
                            events[j].phasef = 0.0;
                        } else {
                            events[j].phasef = b_frames - 1;
                        }
                        insert_success = 1;
                        new_insert = j;
                        break;
                    }
                }
                
                if(!insert_success){ // steal a note
                    
                    maxphase = 0;
                    theft_candidate = 0;
                    for(k = 0; k < overlap_max; k++) {
                        if(events[k].phasef > maxphase) {
                            maxphase = events[k].phasef;
                            theft_candidate = k;
                        }
                    }
                    new_insert = theft_candidate;
                    events[new_insert].gain = gain;
                    if(increment > 0) {
                        events[new_insert].phasef = 0.0;
                    } else {
                        events[new_insert].phasef = b_frames - 1;
                    }
                    insert_success = 1;
                    post("stealing a note at %d for buffer %s", new_insert, sound_name);
                }
                events[new_insert].countdown = latency_samples;
                events[new_insert].status = ACTIVE;
                x->new_slot = new_insert;
                x->new_gain = gain;
                // post("new note at slot %d",new_insert);
                if(tcycle.len > 0) {
                    increment = tcycle.data[tcycle.p++];
                    if(tcycle.p >= tcycle.len) {
                        tcycle.p = 0;
                    }
                    x->tcycle.p = tcycle.p;
                } else {
                    increment = 1.0;
                }
                
                for(k=i; k<n; k++) {
                    //roll out for remaining portion of vector
                    if(events[new_insert].countdown > 0) {
                        --events[new_insert].countdown;
                    } else {
                        if(b_nchans == 1) {
                            
                            iphase = events[new_insert].phasef;
                            frac = events[new_insert].phasef - iphase;
                            if(iphase < 0 || iphase >= b_frames) {
                                pd_error(0, "aborting on phase %f",events[new_insert].phasef);
                                break;
                            }
                            if(increment > 0) {
                                if(iphase == flimit || increment == 1.0) {
                                    outchanL[k] += b_samples[iphase].w_float * gain;
                                    outchanR[k] += b_samples[iphase].w_float * gain;
                                } else {
                                    samp1 = b_samples[iphase].w_float;
                                    samp2 = b_samples[iphase+1].w_float;
                                    samp1 = gain * (samp1 + frac * (samp2-samp1));
                                    outchanL[k] += samp1;
                                    outchanR[k] += samp1;
                                }
                            } else { /*negative increment case (currently unused but might be useful)*/
                                if(iphase == 0.0 || increment == -1.0 ) {
                                    outchanL[k] += b_samples[iphase].w_float * gain;
                                    outchanR[k] += b_samples[iphase].w_float * gain;
                                } else {
                                    samp2 = b_samples[iphase].w_float;
                                    samp1 = b_samples[iphase-2].w_float;
                                    samp1 = gain * (samp1 + frac * (samp2-samp1));
                                    outchanL[k] += samp1;
                                    outchanR[k] += samp1;
                                }
                            }
                            events[new_insert].phasef += increment;
                            
                            if( events[new_insert].phasef < 0.0 || events[new_insert].phasef >= b_frames) {
                                events[new_insert].status = INACTIVE;
                                break;
                            }
                        } else if(b_nchans == 2)
                        { /*
                           iphase = events[new_insert].phasef;
                           frac = events[new_insert].phasef - iphase;
                           iphase *= 2;
                           if(increment > 0) {
                           if(iphase == flimit || increment == 1.0) {
                           outchanL[k] += b_samples[iphase] * gain;
                           outchanR[k] += b_samples[iphase+1] * gain;
                           } else {
                           samp1 = b_samples[iphase];
                           samp2 = b_samples[iphase+2];
                           outchanL[k] += gain * (samp1 + frac * (samp2-samp1));
                           samp1 = b_samples[iphase+1];
                           samp2 = b_samples[iphase+3];
                           outchanR[k] += gain * (samp1 + frac * (samp2-samp1));
                           }
                           } else {
                           if(iphase == 0.0 || increment == -1.0 ) {
                           outchanL[k] += b_samples[iphase] * gain;
                           outchanR[k] += b_samples[iphase+1] * gain;
                           } else {
                           samp2 = b_samples[iphase];
                           samp1 = b_samples[iphase-2];
                           outchanL[k] += gain * (samp1 + frac * (samp2-samp1));
                           samp2 = b_samples[iphase+1];
                           samp1 = b_samples[iphase-1];
                           outchanR[k] += gain * (samp1 + frac * (samp2-samp1));
                           }
                           }
                           events[new_insert].phasef += increment;
                           
                           if( events[new_insert].phasef < 0.0 || events[new_insert].phasef >= b_frames) {
                           events[new_insert].status = INACTIVE;
                           break;
                           } */
                        }
                    }
                }
            }
        }
        x->increment = increment;
        /*    x->tb_inpt = tb_inpt;
         x->tb_outpt = tb_outpt;*/
        return(w+6);
        /* end of block_dsp contingecy code */
    }
    
    /* main body of bashfest processing */
    
    
    for(i=0; i<n; i++){ /* pre-clean buffers*/
        outchanL[i] = outchanR[i] = 0.0;
    }
    
    /* add output from all active buffers into global outlet buffers */
    
    
    for(i = 0; i < overlap_max; i++) {
        if( events[i].status == ACTIVE) {
            out_channels = events[i].out_channels;
            /* assign the output part of work buffer to the local t_float buffer */
            
            processed_drum = events[i].workbuffer + events[i].in_start;
            
            for(j = 0; j < n; j++) {
                if(x->grab) {
                    x->grab = 0;
                    // if too slow, defend with defer_low()
                    bashfest_copy_to_MSP_buffer(x,i);
                }
                if(events[i].countdown > 0) {
                    --events[i].countdown;
                } else {
                    if(out_channels == 1) {
                        outchanL[j] += processed_drum[events[i].phase] * events[i].gainL;
                        outchanR[j] += processed_drum[events[i].phase] * events[i].gainR;
                    } else if(out_channels == 2) {
                        iphase = events[i].phase * 2;
                        outchanL[j] += processed_drum[iphase] * events[i].gainL;
                        outchanR[j] += processed_drum[iphase+1] * events[i].gainR;
                    }
                    
                    events[i].phase++;
                    
                    if(events[i].phase >= events[i].sample_frames) {
                        events[i].status = INACTIVE;
                        break;
                    }
                }
            }
        }
    }
    
    /* now check for initiation click. If found,
     add to list. If necessary, steal a note
     */
    for(i=0; i<n; i++) {
        if(trigger_vec[i]) {
            gain = trigger_vec[i];
            
            /*look for an open slot*/
            insert_success = 0;
            for(j=0; j<overlap_max; j++) {
                if(events[j].status == INACTIVE) {
                    events[j].status = ACTIVE;
                    events[j].gain = gain;
                    insert_success = 1;
                    new_insert = j;
                    break;
                }
            }
            
            if(!insert_success){ /* steal a note if necessary*/
                maxphase = 0;
                theft_candidate = 0;
                for(k = 0; k < overlap_max; k++) {
                    if(events[k].phase > maxphase) {
                        maxphase = events[k].phase;
                        theft_candidate = k;
                    }
                }
                if(x->verbose) {
                    post("stealing note at slot %d", theft_candidate);
                }
                post("stealing a note at %d for buffer %s", theft_candidate, sound_name);
                new_insert = theft_candidate;
                events[new_insert].gain = gain;
                insert_success = 1;
            }
            
            events[new_insert].countdown = x->latency_samples;
            x->new_slot = new_insert;
            x->new_gain = gain;
            
            bashfest_deploy_dsp(x);
            
            
            /* now begin output from the new note */
            
            out_channels = events[new_insert].out_channels;
            processed_drum = events[new_insert].workbuffer + events[new_insert].in_start;
            
            /* processed_drum = events[new_insert].workbuffer;  */
            for(j = i; j < n; j++) {
                if(events[new_insert].countdown > 0) {
                    --events[new_insert].countdown;
                } else{
                    iphase = events[new_insert].phase;
                    if(x->grab) {
                        x->grab = 0;
                        // if too slow, defend with defer_low()
                        bashfest_copy_to_MSP_buffer(x,i);
                    }
                    if(out_channels == 1) {
                        outchanL[j] += processed_drum[iphase] * events[new_insert].gainL;
                        outchanR[j] += processed_drum[iphase] * events[new_insert].gainR;
                    } else if(out_channels == 2) {
                        iphase = events[i].phase * 2;
                        outchanL[j] += processed_drum[iphase] * events[new_insert].gainL;
                        outchanR[j] += processed_drum[iphase+1] * events[new_insert].gainR;
                    }
                    
                    events[new_insert].phase++;
                    
                    if(events[new_insert].phase >= events[new_insert].sample_frames) {
                        events[new_insert].status = INACTIVE;
                        break;
                    }
                }
            }
        }
    }
    return (w+6);
}

void bashfest_copy_to_MSP_buffer(t_bashfest *x, int slot)
{
    int i; //,j;
    t_event *events = x->events;
    long b_nchans = x->b_nchans;
    long b_frames = x->b_frames;
    t_word *b_samples = x->b_samples;
    t_float *processed_drum;
    
    processed_drum = events[slot].workbuffer + events[slot].in_start;
    
    if(events[slot].out_channels == b_nchans) {
        if(b_nchans == 1) {
            for(i=0;i<b_frames;i++) {
                b_samples[i].w_float = processed_drum[i];
            }
        } else if(b_nchans == 2) {
            /*for(i=0;i<b_frames*2;i+=2) {
             b_samples[i].w_float = processed_drum[i];
             b_samples[i+1] = processed_drum[i+1];
             }*/
        }else{
            pd_error(0, "bashfest copy: channel mismatch");
            //fixable but first let's try these
        }
    }
}
void bashfest_deploy_dsp(t_bashfest *x)
{
    t_word *b_samples = x->b_samples;
    long b_nchans = x->b_nchans;
    long b_frames = x->b_frames;
    t_event *events = x->events;
    t_float pan;
    int i; //,j;
    t_float *params = x->params;
    int pcount;
    int buf_samps = x->buf_samps;
    int curarg = 0;
    t_float maxamp;
    t_float rescale;
    t_float *inbuf;
    int slot = x->new_slot;
    t_float gain = x->new_gain;
    
    events[slot].completed = 1;// for testing only
    
    if(b_nchans <1 || b_nchans > 2) {
        pd_error(0, "illegal channels in buffer:%ld",b_nchans);
        return;
        x->hosed = 1;
    }
    if(b_frames > x->buf_frames / 2) {
        pd_error(0, "sample in buffer %s is to large for work buffer",x->sound_name);
        return;
        x->hosed = 1;
    }
    
    pan = lpp_boundrand(0.1, 0.9);
    events[slot].gainL = cos(PIOVERTWO * pan) * gain;
    events[slot].gainR = sin(PIOVERTWO * pan) * gain;
    events[slot].phase = 0;
    events[slot].status = ACTIVE;
    /*  if(x->verbose)
     post("initiating note at slot %d, gain %f, pan %f,inchans %d",slot,gain,pan,b_nchans);
     */
    if(x->sound_lock) {
        return;// of course should finally copy good stuff to MSP buffer
    }
    events[slot].out_channels = b_nchans;
    events[slot].sample_frames = b_frames;
    for(i=0; i<b_frames*b_nchans; i++) {
        events[slot].workbuffer[i] = b_samples[i].w_float;
    }
    
    // clean rest of work buffer
    for(i=b_frames*b_nchans; i<buf_samps; i++) {
        events[slot].workbuffer[i] = 0.0;
    }
    events[slot].in_start = 0;
    events[slot].out_start = x->halfbuffer;
    pcount = bashfest_set_parameters(x, params);
    
    while(curarg < pcount) {
        if(params[curarg] == TRANSPOSE) {
            lpp_transpose(x, slot, &curarg);
        }
        else if(params[curarg] == RINGMOD) {
            lpp_ringmod(x, slot, &curarg);
        }
        else if(params[curarg] == RETRO) {
            lpp_retrograde(x, slot, &curarg);
        }
        else if(params[curarg] == COMB) {
            lpp_comber(x, slot, &curarg);
        }
        else if(params[curarg] == FLANGE) {
            lpp_flange(x, slot, &curarg);
        }
        else if(params[curarg] == BUTTER) {
            lpp_butterme(x, slot, &curarg);
        }
        else if(params[curarg] == TRUNCATE) {
            lpp_truncateme(x, slot, &curarg);
        }
        else if(params[curarg] == SWEEPRESON) {
            lpp_sweepreson(x, slot, &curarg);
        }
        else if(params[curarg] == SLIDECOMB) {
            lpp_slidecomb(x, slot, &curarg);
        }
        else if(params[curarg] == REVERB1) {
            lpp_reverb1(x, slot, &curarg);
        }
        else if(params[curarg] == ELLIPSE) {
            lpp_ellipseme(x, slot, &curarg);
        }
        else if(params[curarg] == FEED1) {
            lpp_feed1me(x, slot, &curarg);
        }
        else if(params[curarg] == FLAM1) {
            lpp_flam1(x, slot, &curarg);
        }
        else if(params[curarg] == FLAM2) {
            lpp_flam2(x, slot, &curarg);
        }
        else if(params[curarg] == EXPFLAM) {
            lpp_expflam(x, slot, &curarg);
        }
        else if(params[curarg] == COMB4) {
            lpp_comb4(x, slot, &curarg);
        }
        else if(params[curarg] == COMPDIST) {
            lpp_compdist(x, slot, &curarg);
        }
        else if(params[curarg] == RINGFEED) {
            lpp_ringfeed(x, slot, &curarg);
        }
        else if(params[curarg] == RESONADSR) {
            lpp_resonadsr(x, slot, &curarg);
        }
        else if(params[curarg] == STV) {
            lpp_stv(x, slot, &curarg);
        }
        else {
            pd_error(0, "deploy missing branch");
        }
    }
    
    maxamp = 0.0;
    inbuf = events[slot].workbuffer + events[slot].in_start;
    b_nchans = events[slot].out_channels;
    b_frames = events[slot].sample_frames;
    for(i=0; i< b_frames * b_nchans; i++) {
        if(maxamp < fabs(inbuf[i])) {
            maxamp = fabs(inbuf[i]);
        }
    }
    if(maxamp>0) {
        rescale = 1.0/maxamp;
        for(i=0; i< b_frames * b_nchans; i++) {
            inbuf[i] *= rescale;
        }
    }
    else{
        if(x->verbose)
            pd_error(0, "zero maxamp detected");
    }
    
    if(events[slot].countdown <= 0)
        pd_error(0, "deploy_dsp: failed to conclude in time; need more latency");
}

int bashfest_set_parameters(t_bashfest *x,t_float *params)
{
    t_float rval;
    int pcount = 0;
    int events;
    int i, j;
    int type;
    t_float cf;//, bw;
    t_float *odds = x->odds;
    int maxproc  = x->max_process_per_note;
    int minproc = x->min_process_per_note;
    t_float tval;
    t_cycle tcycle = x->tcycle;
    
    /* preliminary transposition will be set here */
    
    if(tcycle.len > 0) {
        params[pcount++] = TRANSPOSE;
        params[pcount++] = tcycle.data[tcycle.p++];
        if(tcycle.p >= tcycle.len) {
            tcycle.p = 0;
        }
        x->tcycle.p = tcycle.p;
    }
    
    
    if(maxproc <= 0) {
        return pcount;
    }
    
    events = minproc + rand() % (1+(maxproc-minproc));
    
    for(i = 0; i < events; i++) {
        rval = lpp_boundrand(0.0,1.0);
        j = 0;
        while(rval > odds[j]) {
            j++;
        }
        
        
        if(j == RETRO) {
            params[pcount++] = RETRO;
        }
        else if(j == COMB) {
            params[pcount++] = COMB;
            params[pcount++] = lpp_boundrand(.001,.035);// delaytime
            params[pcount++] = lpp_boundrand(.25,.98);//feedback
            params[pcount++] = lpp_boundrand(.05,.5);//hangtime
        }
        else if(j == RINGMOD) {
            params[pcount++] = RINGMOD;
            params[pcount++] = lpp_boundrand(100.0,2000.0); //need a log version
        }
        else if(j == TRANSPOSE) {
            params[pcount++] = TRANSPOSE;
            params[pcount++] = lpp_boundrand(0.25,3.0);
        }
        else if(j == FLANGE) {
            params[pcount++] = FLANGE;
            params[pcount++] = lpp_boundrand(100.0,400.0);
            params[pcount++] = lpp_boundrand(600.0,4000.0);
            params[pcount++] = lpp_boundrand(0.1,2.0);
            params[pcount++] = lpp_boundrand(0.1,0.95);
            params[pcount++] = lpp_boundrand(0.0,0.9);
        }
        else if(j == BUTTER) {
            params[pcount++] = BUTTER;
            type = rand() % 3;
            params[pcount++] = type;
            cf = lpp_boundrand(70.0,3000.0);
            params[pcount++] = cf;
            if(type == BANDPASS) {
                params[pcount++] = cf * lpp_boundrand(0.05,0.6);
            }
        }
        else if(j == TRUNCATE) {
            params[pcount++] = TRUNCATE;
            params[pcount++] = lpp_boundrand(.05,.15);
            params[pcount++] = lpp_boundrand(.01,.05);
        }
        else if(j == SWEEPRESON) {
            params[pcount++] = SWEEPRESON;
            params[pcount++] = lpp_boundrand(100.0,300.0);
            params[pcount++] = lpp_boundrand(600.0,6000.0);
            params[pcount++] = lpp_boundrand(0.01,0.2);
            params[pcount++] = lpp_boundrand(0.05,2.0);
            params[pcount++] = lpp_boundrand(0.0,1.0);
        }
        else if(j == SLIDECOMB) {
            params[pcount++] = SLIDECOMB;
            params[pcount++] = lpp_boundrand(.001,.03);
            params[pcount++] = lpp_boundrand(.001,.03);
            params[pcount++] = lpp_boundrand(0.05,0.95);
            params[pcount++] = lpp_boundrand(0.05,0.5);
        }
        else if(j == REVERB1) {
            params[pcount++] = REVERB1;
            params[pcount++] = lpp_boundrand(0.25,0.99);
            params[pcount++] = lpp_boundrand(0.1,1.0);
            params[pcount++] = lpp_boundrand(0.2,0.8);
        }
        else if(j == ELLIPSE) {
            params[pcount++] = ELLIPSE;
            params[pcount++] = rand() % ELLIPSE_FILTER_COUNT;
        }
        else if(j == FEED1) {
            params[pcount++] = FEED1;
            tval = lpp_boundrand(.001,0.1);
            params[pcount++] = tval;
            params[pcount++] = lpp_boundrand(tval,0.1);
            tval = lpp_boundrand(.01,0.5);
            params[pcount++] = tval;
            params[pcount++] = lpp_boundrand(tval,0.5);
            params[pcount++] = lpp_boundrand(.05,1.0);
        }
        else if(j == FLAM1) {
            params[pcount++] = FLAM1;
            params[pcount++] = 4 + (rand() % 20);
            params[pcount++] = lpp_boundrand(0.3,0.8);
            params[pcount++] = lpp_boundrand(0.5,1.2);
            params[pcount++] = lpp_boundrand(.025,0.15);
        }
        else if(j == FLAM2) {
            params[pcount++] = FLAM2;
            params[pcount++] = 4 + (rand() % 20);
            params[pcount++] = lpp_boundrand(0.1,0.9);
            params[pcount++] = lpp_boundrand(0.2,1.2);
            params[pcount++] = lpp_boundrand(.025,0.15);
            params[pcount++] = lpp_boundrand(.025,0.15);
        }
        else if(j == EXPFLAM) {
            params[pcount++] = EXPFLAM;
            params[pcount++] = 4 + (rand() % 20);
            params[pcount++] = lpp_boundrand(0.1,0.9);
            params[pcount++] = lpp_boundrand(0.2,1.2);
            params[pcount++] = lpp_boundrand(.025,0.15);
            params[pcount++] = lpp_boundrand(.025,0.15);
            params[pcount++] = lpp_boundrand(-5.0,5.0);
        }
        else if(j == COMB4) {
            params[pcount++] = COMB4;
            params[pcount++] = lpp_boundrand(100.0,900.0);
            params[pcount++] = lpp_boundrand(100.0,900.0);
            params[pcount++] = lpp_boundrand(100.0,900.0);
            params[pcount++] = lpp_boundrand(100.0,900.0);
            tval = lpp_boundrand(.5,0.99);
            params[pcount++] = tval;
            params[pcount++] = tval;
        }
        else if(j == COMPDIST) {
            params[pcount++] = COMPDIST;
            params[pcount++] = tval = lpp_boundrand(.01,.25);
            params[pcount++] = lpp_boundrand(tval,.9);
            params[pcount++] = 1;
        }
        else if(j == RINGFEED) {
            params[pcount++] = RINGFEED;
            params[pcount++] = lpp_boundrand(90.0,1500.0);
            params[pcount++] = lpp_boundrand(90.0,1500.0);
            params[pcount++] = lpp_boundrand(0.2,0.95);
            params[pcount++] = lpp_boundrand(90.0,1500.0);
            params[pcount++] = lpp_boundrand(.01,.4);
            params[pcount++] = lpp_boundrand(.05,1.0);
        }
        else if(j == RESONADSR) {
            params[pcount++] = RESONADSR;
            params[pcount++] = lpp_boundrand(.01,.1);
            params[pcount++] = lpp_boundrand(.01,.05);
            params[pcount++] = lpp_boundrand(.05,.5);
            params[pcount++] = lpp_boundrand(150.0,4000.0);
            params[pcount++] = lpp_boundrand(150.0,4000.0);
            params[pcount++] = lpp_boundrand(150.0,4000.0);
            params[pcount++] = lpp_boundrand(150.0,4000.0);
            params[pcount++] = lpp_boundrand(.03,.7);
        }
        else if(j == STV) {
            params[pcount++] = STV;
            params[pcount++] = lpp_boundrand(.025,0.5);
            params[pcount++] = lpp_boundrand(.025,0.5);
            params[pcount++] = lpp_boundrand(.001,.01);
        }
        else {
            pd_error(0, "could not find a process for %d",j);
            return 0;
        }
    }
    return pcount;
}

void bashfest_dsp_free(t_bashfest *x)
{
    int i;
    
    t_freebytes(x->sinewave, x->sinelen * sizeof(t_float));
    t_freebytes(x->params, MAX_PARAMETERS * sizeof(t_float));
    t_freebytes(x->odds, 64 * sizeof(t_float));
    t_freebytes(x->delayline1, x->maxdelay * x->sr * sizeof(t_float));
    t_freebytes(x->delayline2, x->maxdelay * x->sr * sizeof(t_float));
    
    for(i=0;i<x->overlap_max;i++) {
        t_freebytes(x->events[i].workbuffer, x->buf_samps * sizeof(t_float));
    }
    t_freebytes(x->events, x->overlap_max * sizeof(t_event));
    
    t_freebytes(x->eel,MAXSECTS * sizeof(LSTRUCT));
    for( i = 0; i < 4 ; i++ ) {
        t_freebytes(x->mini_delay[i], ((int)(x->sr * x->max_mini_delay) + 1) * sizeof(t_float));
    }
    t_freebytes(x->reverb_ellipse_data, 16 * sizeof(t_float));
    for(i=0;i<MAXFILTER;i++) {
        t_freebytes(x->ellipse_data[i], MAX_COEF * sizeof(t_float));
    }
    t_freebytes(x->ellipse_data, MAXFILTER * sizeof(t_float *));
    t_freebytes(x->transfer_function,x->tf_len * sizeof(t_float));
    t_freebytes(x->feedfunc1, x->feedfunclen * sizeof(t_float));
    t_freebytes(x->feedfunc2, x->feedfunclen * sizeof(t_float));
    t_freebytes(x->feedfunc3, x->feedfunclen * sizeof(t_float));
    t_freebytes(x->feedfunc4, x->feedfunclen * sizeof(t_float));
    t_freebytes(x->flamfunc1, x->flamfunc1len * sizeof(t_float));
    for( i = 0; i < 4; i++ ) {
        t_freebytes(x->combies[i].arr, x->combies[i].len * sizeof(t_float));
    }
    t_freebytes(x->combies,4 * sizeof(CMIXCOMB));
    t_freebytes(x->adsr->func, x->adsr->len * sizeof(t_float));
    t_freebytes(x->adsr,sizeof(CMIXADSR));
    t_freebytes(x->tcycle.data,CYCLE_MAX * sizeof(t_float));
    t_freebytes(x->trigger_vec, MAX_VEC * sizeof(t_float));
}

void bashfest_dsp(t_bashfest *x, t_signal **sp)
{
    bashfest_setbuf(x, x->wavename);
    
    if( x->hosed ) {
        pd_error(0, "bashfest~ needs a valid buffer");
    }
    /* if vector size changes, we also need to deal, thanks to
     the trigger buffer inter-delay
     */
    if(x->sr != sp[0]->s_sr) {
        x->sr = sp[0]->s_sr;
        if(!x->sr) {
            post("warning: zero sampling rate!");
            x->sr = 44100;
        }
    }
    if(x->b_frames <= 0) {
        post("empty buffer, hosing down");
        x->hosed = 1;
    }
    
    if(x->hosed) {
        dsp_add(bashfest_perform_hosed, 5, x,
                sp[0]->s_vec, sp[1]->s_vec, sp[2]->s_vec, (t_int)sp[0]->s_n);
    } else {
        dsp_add(bashfest_perform, 5, x,
                sp[0]->s_vec, sp[1]->s_vec, sp[2]->s_vec, (t_int)sp[0]->s_n);
    }
}