/* 
   Truth has a power like electricity
   When we dance in Truth,
   it is infectious,
   unmistakable. 
*/

/* Copyright 2004-2008 Jan Pekau (JP Mercury) <swirlee@vcn.bc.ca>
   
   This file is part of Freewheeling.
   
   Freewheeling 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.
   
   Freewheeling 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 Freewheeling.  If not, see <http://www.gnu.org/licenses/>. */

#include <sys/stat.h>
#include <sys/time.h>
#include <utime.h>

#include <stdio.h>
#include <errno.h>
#include <unistd.h>
#include <stdlib.h>

#include <math.h>
#include <string.h>

#include <pthread.h>
#include <sched.h>
#include <sys/mman.h>

#include <X11/Xlib.h>

#include <glob.h>

#include "fweelin_core.h"
#include "fweelin_fluidsynth.h"

const float Loop::MIN_VOL = 0.01;

// *********** CORE

Snapshot *Fweelin::getSNAP (int idx) {
  if (idx >= 0 && idx < cfg->GetMaxSnapshots())
    return &snaps[idx];
  else
    return 0;
}

void Snapshot::CreateSnapshot (char *name, LoopManager *lm, TriggerMap *tmap) {
  if (exists && this->name != 0 && name == 0) {
    // Preserve name of snapshot
    DeleteSnapshot(0);
  } else  
    DeleteSnapshot();

  exists = 1;
  if (this->name == 0 && name != 0) {
    this->name = new char[strlen(name)+1];
    strcpy(this->name,name);
  }

  if (lm != 0) {
    // Count all loops
    numls = tmap->CountLoops();
    if (numls > 0) {
      ls = new LoopSnapshot[numls];
      
      int idx = 0;
      for (int i = 0; i < tmap->GetMapSize(); i++) {
        if (tmap->GetMap(i) != 0) {
          Loop *l = tmap->GetMap(i);
          if (idx >= numls) {
            printf("CORE: ERROR: Loop count mismatch creating snapshot!\n");
            return;
          }
          
          ls[idx++] = LoopSnapshot(i,lm->GetStatus(i),
                                   l->vol,lm->GetTriggerVol(i));
        }
      }
    }
  }
};

// Trigger snapshot #idx - return nonzero on failure
char Fweelin::TriggerSnapshot (int idx) {
  Snapshot *s = getSNAP(idx);
  if (s != 0 && s->exists) {
    for (int i = 0; i < s->numls; i++) {
      LoopSnapshot *ls = &(s->ls[i]);

      loopmgr->SetLoopVolume(ls->l_idx,ls->l_vol);

      if (ls->status == T_LS_Off && loopmgr->IsActive(ls->l_idx)) {
        loopmgr->Deactivate(ls->l_idx);
      } else if (ls->status == T_LS_Playing || 
                 ls->status == T_LS_Overdubbing) {
        if (loopmgr->GetStatus(ls->l_idx) != T_LS_Playing) {
          // Loop not yet playing
          if (loopmgr->IsActive(ls->l_idx))
            loopmgr->Deactivate(ls->l_idx);
          loopmgr->Activate(ls->l_idx, 0, ls->t_vol);
        } else {
          // Loop already playing- adjust volume
          loopmgr->SetTriggerVol(ls->l_idx, ls->t_vol);
        }
      } 
    }

    return 0;
  } else
    return 1;
};

// Splits a saveable filename in the format 'basename-hash-objectname'
// into its base name, hash and object name components
//
// Returns zero on success
char Saveable::SplitFilename(char *filename, int baselen, char *basename, 
                             char *hash, char *objname,
                             int maxlen) {
  // Loop exists, use combination of time and hash as name
  char *slashptr = filename + baselen;

  if (slashptr < filename+strlen(filename)) {
    char *slashptr2 = strchr(slashptr+1,'-'),
      *extptr = strrchr(filename,'.');
    
    if (extptr == 0)
      extptr = filename+strlen(filename); // No extension
    
    // Extract base name
    int len = 0;
    if (basename != 0) {
      len = MIN(baselen,maxlen-1);
      memcpy(basename,filename,sizeof(char)*len);
      basename[len] = '\0';
    }

    // Extract hash
    char *breaker = (slashptr2 != 0 ? slashptr2 : extptr);
    if (strlen(slashptr+1) - strlen(breaker) == SAVEABLE_HASH_LENGTH*2) {
      if (hash != 0) {
        len = MIN(SAVEABLE_HASH_LENGTH*2,maxlen-1);
        memcpy(hash,slashptr+1,sizeof(char)*len);
        hash[len] = '\0';
      }
    } else {
      printf("SAVEABLE: Invalid hash within filename: '%s'\n",
             filename);
      return 1;
    }
    
    // Now check if the filename also contains an object name-
    // this would be placed after the hash
    if (objname != 0) {
      if (slashptr2 != 0) {
        // Name
        len = strlen(slashptr2+1) - strlen(extptr);
        len = MIN(len,maxlen-1);
        memcpy(objname,slashptr2+1,sizeof(char)*len);
        objname[len] = '\0';
      } else      
        strcpy(objname,"");
    }
  } else {
    printf("SAVEABLE: Invalid filename for extracting hash/name: '%s'\n",
           filename);
    return 1;
  }
  
  return 0;
};

void Saveable::RenameSaveable(char **filename_ptr, int baselen, 
                              char *newname, const char **exts, int num_exts) {
  // Parse filename to extract hash part
  char fn_base[FWEELIN_OUTNAME_LEN], 
    fn_hash[FWEELIN_OUTNAME_LEN],
    fn_name[FWEELIN_OUTNAME_LEN];
  if (Saveable::SplitFilename(*filename_ptr,baselen,fn_base,fn_hash,fn_name,
                              FWEELIN_OUTNAME_LEN))
    printf("SAVEABLE: Can't rename '%s'- poorly formatted filename.\n",
           *filename_ptr);
  else {
    char tmp[FWEELIN_OUTNAME_LEN];
    strncpy(tmp,*filename_ptr,FWEELIN_OUTNAME_LEN);
    tmp[FWEELIN_OUTNAME_LEN-1] = '\0';

    delete[] *filename_ptr;
    *filename_ptr = new char[strlen(fn_base)+1+
                             strlen(fn_hash)+1+
                             strlen(newname)+1];
    if (strlen(newname) > 0) 
      sprintf(*filename_ptr,"%s-%s-%s",
              fn_base,fn_hash,newname);
    else
      sprintf(*filename_ptr,"%s-%s",
              fn_base,fn_hash);

    char tmp_a[FWEELIN_OUTNAME_LEN],
      tmp_b[FWEELIN_OUTNAME_LEN];
    for (int i = 0; i < num_exts; i++) {
      // Add each type of extension provided and rename the file
      snprintf(tmp_a,FWEELIN_OUTNAME_LEN,"%s%s",tmp,exts[i]);
      snprintf(tmp_b,FWEELIN_OUTNAME_LEN,"%s%s",*filename_ptr,exts[i]);

      if (!rename(tmp_a,tmp_b))
        printf("SAVEABLE: Rename file '%s' -> '%s'\n",tmp_a,tmp_b);
      //else 
      //printf("SAVEABLE: File '%s' not found for rename\n",tmp_a);
    }
  }
};

// This is for renaming an item in memory, so that the disk corresponds
// with the new name
void Saveable::RenameSaveable(char *librarypath, char *basename, 
                              char *old_objname, char *nw_objname,
                              const char **exts, int num_exts,
                              char **old_filename, char **new_filename) {
  if (savestatus == SAVE_DONE) {
    // OK, we have to rename on disk

    // Get filename to rename
    GET_SAVEABLE_HASH_TEXT(GetSaveHash());

    *old_filename = new char[FWEELIN_OUTNAME_LEN];
    *new_filename = new char[FWEELIN_OUTNAME_LEN];

    for (int i = 0; i < num_exts; i++) {
      // Add each type of extension provided and rename the file

      if (old_objname == 0 || strlen(old_objname) == 0) 
        snprintf(*old_filename,FWEELIN_OUTNAME_LEN,"%s/%s-%s%s",
                 librarypath,basename,hashtext,exts[i]);
      else 
        snprintf(*old_filename,FWEELIN_OUTNAME_LEN,"%s/%s-%s-%s%s",
                 librarypath,basename,hashtext,old_objname,exts[i]);

      if (nw_objname == 0 || strlen(nw_objname) == 0) 
        snprintf(*new_filename,FWEELIN_OUTNAME_LEN,"%s/%s-%s%s",
                 librarypath,basename,hashtext,exts[i]);
      else 
        snprintf(*new_filename,FWEELIN_OUTNAME_LEN,"%s/%s-%s-%s%s",
                 librarypath,basename,hashtext,nw_objname,exts[i]);

      printf("SAVEABLE: Rename file '%s' -> '%s'\n",
             *old_filename,*new_filename);
      rename(*old_filename,*new_filename);
    }

    // Get names without extensions
    if (old_objname == 0) 
      snprintf(*old_filename,FWEELIN_OUTNAME_LEN,"%s/%s-%s",
               librarypath,basename,hashtext);
    else 
      snprintf(*old_filename,FWEELIN_OUTNAME_LEN,"%s/%s-%s-%s",
               librarypath,basename,hashtext,old_objname);
    
    if (nw_objname == 0) 
      snprintf(*new_filename,FWEELIN_OUTNAME_LEN,"%s/%s-%s",
               librarypath,basename,hashtext);
    else 
      snprintf(*new_filename,FWEELIN_OUTNAME_LEN,"%s/%s-%s-%s",
               librarypath,basename,hashtext,nw_objname);
  }
};

// Save loop
void Loop::Save(Fweelin *app) {
  // Queue save
  app->getLOOPMGR()->AddLoopToSaveQueue(this);
};

void LoopManager::AddToSaveQueue(Event *ev) {
  numsave++;
  EventManager::QueueEvent(&savequeue,ev);
};

void LoopManager::AddLoopToSaveQueue(Loop *l) {
  if (!autosave && l->GetSaveStatus() == NO_SAVE) {
    numsave++;

    LoopListEvent *ll = (LoopListEvent *) 
      Event::GetEventByType(T_EV_LoopList,1);
    ll->l = l;
        
    EventManager::QueueEvent(&savequeue,ll);
  }
};

void LoopManager::AddLoopToLoadQueue(char *filename, int index, float vol) {
  numload++;

  LoopListEvent *ll = (LoopListEvent *) 
    Event::GetEventByType(T_EV_LoopList,1);
  strcpy(ll->l_filename,filename);
  ll->l_idx = index;
  ll->l_vol = vol;
  
  EventManager::QueueEvent(&loadqueue,ll);
};

// Adds the loop with given filename to the loop browser br
void LoopManager::AddLoopToBrowser(Browser *br, char *filename) {
  char tmp[FWEELIN_OUTNAME_LEN];
  
  struct stat st;
  if (stat(filename,&st) == 0) {
    char default_name = 
      br->GetDisplayName(filename,&st.st_mtime,tmp,FWEELIN_OUTNAME_LEN);

    br->AddItem(new LoopBrowserItem(st.st_mtime,tmp,default_name,filename),1);
  }
};

// Populate the loop browser with any loops on disk
void LoopManager::SetupLoopBrowser() {
  Browser *br = app->getBROWSER(B_Loop);

  if (br != 0) {
    // Clear
    br->ClearAllItems();

    // Look for loops on disk 
    glob_t globbuf;
    char tmp[FWEELIN_OUTNAME_LEN];
    for (codec lformat = FIRST_FORMAT; lformat < END_OF_FORMATS; 
         lformat = (codec) (lformat+1)) {
      snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s/%s*%s",
             app->getCFG()->GetLibraryPath(),FWEELIN_OUTPUT_LOOP_NAME,
             app->getCFG()->GetAudioFileExt(lformat)); 
      printf("BROWSER: (Loop) Scanning for loops in library: %s\n",tmp);
      if (glob(tmp, 0, NULL, &globbuf) == 0) {
        for (size_t i = 0; i < globbuf.gl_pathc; i++) {
          //printf("BROWSER: (Loop) Loop: %s\n",globbuf.gl_pathv[i]);
          AddLoopToBrowser(br,globbuf.gl_pathv[i]);
        }

        br->AddDivisions(FWEELIN_FILE_BROWSER_DIVISION_TIME);
        br->MoveToBeginning();
        globfree(&globbuf);
      }
    }
  }
};

// Adds the scene with given filename to the scene browser br
SceneBrowserItem *LoopManager::AddSceneToBrowser(Browser *br, char *filename) {
  char tmp[FWEELIN_OUTNAME_LEN];
  SceneBrowserItem *ret = 0;

  struct stat st;
  if (stat(filename,&st) == 0) {
    char default_name = 
      br->GetDisplayName(filename,&st.st_mtime,tmp,FWEELIN_OUTNAME_LEN);

    br->AddItem(ret = 
                new SceneBrowserItem(st.st_mtime,tmp,default_name,filename),1);
  }

  return ret;
};

// Populate the scene browser with any scenes on disk
void LoopManager::SetupSceneBrowser() {
  Browser *br = app->getBROWSER(B_Scene);

  if (br != 0) {
    // Clear
    br->ClearAllItems();

    // Look for scenes on disk 
    glob_t globbuf;
    char tmp[FWEELIN_OUTNAME_LEN];
    snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s/%s*%s",
             app->getCFG()->GetLibraryPath(),FWEELIN_OUTPUT_SCENE_NAME,
             FWEELIN_OUTPUT_DATA_EXT);
    printf("BROWSER: (Scene) Scanning for scenes in library: %s\n",tmp);
    if (glob(tmp, 0, NULL, &globbuf) == 0) {
      for (size_t i = 0; i < globbuf.gl_pathc; i++) {
        // printf("BROWSER: (Scene) Scene: %s\n",globbuf.gl_pathv[i]);
        AddSceneToBrowser(br,globbuf.gl_pathv[i]);
      }
      br->AddDivisions(FWEELIN_FILE_BROWSER_DIVISION_TIME);
      br->MoveToBeginning();
      globfree(&globbuf);
    }
  }
};

void LoopManager::ItemBrowsed(BrowserItem *i) {};
void LoopManager::ItemSelected(BrowserItem *i) {
  switch (i->GetType()) {
  case B_Loop: 
    printf("DISK: Load '%s'\n",((LoopBrowserItem *) i)->filename);
    LoadLoop(((LoopBrowserItem *) i)->filename,loadloopid,
             newloopvol / GetOutputVolume());
    break;
    
  case B_Scene:
    printf("DISK: Load '%s'\n",((SceneBrowserItem *) i)->filename);
    LoadScene((SceneBrowserItem *) i);
    break;

  default:
    break;
  }
};
void LoopManager::ItemRenamed(BrowserItem *i) {
  switch (i->GetType()) {
  case B_Loop_Tray:
    // Change name inside the loop
    {
      LoopTrayItem *curl = (LoopTrayItem *) i;
      char *old_filename = 0, 
        *new_filename = 0;
      
      // Rename on disk
      const static char *exts[] = {app->getCFG()->GetAudioFileExt(curl->l->format),
                                   FWEELIN_OUTPUT_DATA_EXT};
      curl->l->RenameSaveable(app->getCFG()->GetLibraryPath(), 
                              FWEELIN_OUTPUT_LOOP_NAME,
                              curl->l->name, curl->name,
                              exts, 2,
                              &old_filename,
                              &new_filename);
    
      // We also need to rename in the loop browser
      if (app->getBROWSER(B_Loop) != 0) 
        app->getBROWSER(B_Loop)->
          ItemRenamedOnDisk(old_filename,new_filename,curl->name);
      
      if (old_filename != 0)
        delete[] old_filename;
      if (new_filename != 0)
        delete[] new_filename;

      // And in memory..
      RenameLoop(curl->l,curl->name);
    }
    break;

  case B_Loop:
    {
      // Name change on disk
      int baselen = strlen(app->getCFG()->GetLibraryPath()) + 1 +
        strlen(FWEELIN_OUTPUT_LOOP_NAME);

      // Add all audio format names + XML to extension list
      int numexts = END_OF_FORMATS + 1;
      char *exts[numexts];
      for (codec c = FIRST_FORMAT; c < END_OF_FORMATS; c = (codec) (c+1))
        exts[c] = app->getCFG()->GetAudioFileExt(c);
      exts[END_OF_FORMATS] = FWEELIN_OUTPUT_DATA_EXT;

      // Rename all possible audio files + XML metadata to new name
      printf("DISK: Rename '%s'\n",((LoopBrowserItem *) i)->filename);
      Saveable::RenameSaveable(&((LoopBrowserItem *) i)->filename,baselen,
                               i->name,(const char **) exts,numexts);

      // Is this loop loaded? If so, rename it

      // Find loop in memory (by hash, extracted from filename)
      char fn_hash[FWEELIN_OUTNAME_LEN];
      if (!Saveable::SplitFilename(((LoopBrowserItem *) i)->filename,
                                   baselen,0,fn_hash,0,FWEELIN_OUTNAME_LEN)) {
        // Convert text 'fn_hash' to binary hash and scan for it
        Saveable tmp;
        if (!(tmp.SetSaveableHashFromText(fn_hash))) {
          int foundidx;
          if ((foundidx = 
               app->getTMAP()->ScanForHash(tmp.GetSaveHash())) != -1) {
            // This loop -is- loaded, rename in map and in loop tray
            // printf("loop renamed is also in memory: %d\n",foundidx);
            Loop *foundloop = GetSlot(foundidx);
            
            // Rename in memory
            RenameLoop(foundloop,i->name);
            
            // We have to notify the LoopTray of the new name given
            LoopTray *tray = (LoopTray *) app->getBROWSER(B_Loop_Tray);
            if (tray != 0)
              tray->ItemRenamedFromOutside(foundloop,i->name);
          }     
        }
      }      
    }
    break;
    
  case B_Scene:
    {
      int baselen = strlen(app->getCFG()->GetLibraryPath()) + 1 +
        strlen(FWEELIN_OUTPUT_SCENE_NAME);
      const static char *exts[] = {FWEELIN_OUTPUT_DATA_EXT};
      
      printf("DISK: Rename '%s'\n",((SceneBrowserItem *) i)->filename);
      Saveable::RenameSaveable(&((SceneBrowserItem *) i)->filename,baselen,
                               i->name,exts,1);
    }
    break;

  default:
    break;
  }
};

LoopManager::LoopManager (Fweelin *app) : 
  renamer(0), rename_loop(0), 
  savequeue(0), loadqueue(0), cursave(0), curload(0), numsave(0), numload(0),
  loadloopid(0), needs_saving_stamp(0),
  default_looprange(Range(0,app->getCFG()->GetNumTriggers())),

  autosave(0), app(app), newloopvol(1.0), subdivide(1), curpulseindex(-1) {
  pthread_mutex_init (&loops_lock,0);

  int mapsz = app->getTMAP()->GetMapSize();

  plist = new Processor *[mapsz];
  status = new LoopStatus[mapsz];
  waitactivate = new int[mapsz];
  waitactivate_shot = new char[mapsz];
  waitactivate_vol = new float[mapsz];
  waitactivate_od = new char[mapsz];
  waitactivate_od_fb = new float *[mapsz];

  numloops = 0;
  numrecordingloops = 0;
  
  lastrecidx = new int[LAST_REC_COUNT];
  memset(lastrecidx, 0, sizeof(int) * LAST_REC_COUNT);
  
  memset(plist, 0, sizeof(Processor *) * mapsz);
  int lst = T_LS_Off;
  memset(status, lst, sizeof(LoopStatus) * mapsz);
  memset(waitactivate, 0, sizeof(int) * mapsz);
  memset(waitactivate_shot, 0, sizeof(char) * mapsz);
  memset(waitactivate_vol, 0, sizeof(float) * mapsz);
  memset(waitactivate_od, 0, sizeof(char) * mapsz);
  memset(waitactivate_od_fb, 0, sizeof(float) * mapsz);
  memset(pulses, 0, sizeof(Pulse *) * MAX_PULSES);

  // Turn on block read/write managers for loading & saving loops
  bread = ::new BlockReadManager(0,this,app->getBMG(),
                                 app->getCFG()->loop_peaksavgs_chunksize);
  bwrite = ::new BlockWriteManager(0,this,app->getBMG());
  app->getBMG()->AddManager(bread);
  app->getBMG()->AddManager(bwrite);

  // Listen for important events
  app->getEMG()->ListenEvent(this,0,T_EV_EndRecord);
  app->getEMG()->ListenEvent(this,0,T_EV_ToggleDiskOutput);
  app->getEMG()->ListenEvent(this,0,T_EV_ToggleSelectLoop);
  app->getEMG()->ListenEvent(this,0,T_EV_SelectOnlyPlayingLoops);
  app->getEMG()->ListenEvent(this,0,T_EV_SelectAllLoops);
  app->getEMG()->ListenEvent(this,0,T_EV_InvertSelection);
  app->getEMG()->ListenEvent(this,0,T_EV_CreateSnapshot);
  app->getEMG()->ListenEvent(this,0,T_EV_RenameSnapshot);
  app->getEMG()->ListenEvent(this,0,T_EV_TriggerSnapshot);
  app->getEMG()->ListenEvent(this,0,T_EV_SetAutoLoopSaving);
  app->getEMG()->ListenEvent(this,0,T_EV_SaveLoop);
  app->getEMG()->ListenEvent(this,0,T_EV_SaveNewScene);
  app->getEMG()->ListenEvent(this,0,T_EV_SaveCurrentScene);
  app->getEMG()->ListenEvent(this,0,T_EV_SetLoadLoopId);
  app->getEMG()->ListenEvent(this,0,T_EV_SetDefaultLoopPlacement);

  app->getEMG()->ListenEvent(this,0,T_EV_SlideMasterInVolume);
  app->getEMG()->ListenEvent(this,0,T_EV_SlideMasterOutVolume);
  app->getEMG()->ListenEvent(this,0,T_EV_SlideInVolume);
  app->getEMG()->ListenEvent(this,0,T_EV_SetMasterInVolume);
  app->getEMG()->ListenEvent(this,0,T_EV_SetMasterOutVolume);
  app->getEMG()->ListenEvent(this,0,T_EV_SetInVolume);
  app->getEMG()->ListenEvent(this,0,T_EV_ToggleInputRecord);

  app->getEMG()->ListenEvent(this,0,T_EV_DeletePulse);
  app->getEMG()->ListenEvent(this,0,T_EV_SelectPulse);
  app->getEMG()->ListenEvent(this,0,T_EV_TapPulse);
  app->getEMG()->ListenEvent(this,0,T_EV_SwitchMetronome);
  app->getEMG()->ListenEvent(this,0,T_EV_SetSyncType);
  app->getEMG()->ListenEvent(this,0,T_EV_SetSyncSpeed);
  app->getEMG()->ListenEvent(this,0,T_EV_SetMidiSync);

  app->getEMG()->ListenEvent(this,0,T_EV_SetTriggerVolume);
  app->getEMG()->ListenEvent(this,0,T_EV_SlideLoopAmp);
  app->getEMG()->ListenEvent(this,0,T_EV_SetLoopAmp);
  app->getEMG()->ListenEvent(this,0,T_EV_AdjustLoopAmp);
  app->getEMG()->ListenEvent(this,0,T_EV_TriggerLoop);
  app->getEMG()->ListenEvent(this,0,T_EV_TriggerSelectedLoops);
  app->getEMG()->ListenEvent(this,0,T_EV_SetSelectedLoopsTriggerVolume);
  app->getEMG()->ListenEvent(this,0,T_EV_AdjustSelectedLoopsAmp);

  app->getEMG()->ListenEvent(this,0,T_EV_MoveLoop);
  app->getEMG()->ListenEvent(this,0,T_EV_RenameLoop);
  app->getEMG()->ListenEvent(this,0,T_EV_EraseLoop);
  app->getEMG()->ListenEvent(this,0,T_EV_EraseAllLoops);
  app->getEMG()->ListenEvent(this,0,T_EV_EraseSelectedLoops);
  app->getEMG()->ListenEvent(this,0,T_EV_SlideLoopAmpStopAll);
};

LoopManager::~LoopManager() { 
  // Stop block read/write managers
  bread->End(0);
  bwrite->End();
  app->getBMG()->DelManager(bread);
  app->getBMG()->DelManager(bwrite);

  // Stop listening
  app->getEMG()->UnlistenEvent(this,0,T_EV_EndRecord);
  app->getEMG()->UnlistenEvent(this,0,T_EV_ToggleDiskOutput);
  app->getEMG()->UnlistenEvent(this,0,T_EV_ToggleSelectLoop);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SelectOnlyPlayingLoops);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SelectAllLoops);
  app->getEMG()->UnlistenEvent(this,0,T_EV_InvertSelection);
  app->getEMG()->UnlistenEvent(this,0,T_EV_CreateSnapshot);
  app->getEMG()->UnlistenEvent(this,0,T_EV_RenameSnapshot);
  app->getEMG()->UnlistenEvent(this,0,T_EV_TriggerSnapshot);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetAutoLoopSaving);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SaveLoop);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SaveNewScene);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SaveCurrentScene);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetLoadLoopId);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetDefaultLoopPlacement);

  app->getEMG()->UnlistenEvent(this,0,T_EV_SlideMasterInVolume);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SlideMasterOutVolume);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SlideInVolume);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetMasterInVolume);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetMasterOutVolume);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetInVolume);
  app->getEMG()->UnlistenEvent(this,0,T_EV_ToggleInputRecord);

  app->getEMG()->UnlistenEvent(this,0,T_EV_DeletePulse);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SelectPulse);
  app->getEMG()->UnlistenEvent(this,0,T_EV_TapPulse);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SwitchMetronome);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetSyncType);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetSyncSpeed);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetMidiSync);

  app->getEMG()->UnlistenEvent(this,0,T_EV_SetTriggerVolume);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SlideLoopAmp);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetLoopAmp);
  app->getEMG()->UnlistenEvent(this,0,T_EV_AdjustLoopAmp);
  app->getEMG()->UnlistenEvent(this,0,T_EV_TriggerLoop);
  app->getEMG()->UnlistenEvent(this,0,T_EV_TriggerSelectedLoops);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SetSelectedLoopsTriggerVolume);
  app->getEMG()->UnlistenEvent(this,0,T_EV_AdjustSelectedLoopsAmp);

  app->getEMG()->UnlistenEvent(this,0,T_EV_MoveLoop);
  app->getEMG()->UnlistenEvent(this,0,T_EV_RenameLoop);
  app->getEMG()->UnlistenEvent(this,0,T_EV_EraseLoop);
  app->getEMG()->UnlistenEvent(this,0,T_EV_EraseAllLoops);
  app->getEMG()->UnlistenEvent(this,0,T_EV_EraseSelectedLoops);
  app->getEMG()->UnlistenEvent(this,0,T_EV_SlideLoopAmpStopAll);

  EventManager::DeleteQueue(savequeue);
  EventManager::DeleteQueue(loadqueue);

  // Let BMG know that we are ending
  app->getBMG()->RefDeleted((AutoWriteControl *) this);

  delete[] lastrecidx;

  delete[] plist; delete[] status; 
  delete[] waitactivate; delete[] waitactivate_shot; 
  delete[] waitactivate_vol; delete[] waitactivate_od;
  delete[] waitactivate_od_fb;

  pthread_mutex_destroy (&loops_lock);
};

// Get length returns the length of any loop on the specified index
nframes_t LoopManager::GetLength(int index) {
  if (status[index] == T_LS_Recording) {
    // Ooh, we are recording on this index. Get the current length
    return ((RecordProcessor *) plist[index])->GetRecordedLength();
  }
  else {
    Loop *cur = app->getTMAP()->GetMap(index);
    if (cur != 0)
      return cur->blocks->GetTotalLen();
  }

  return 0;
}

// Get length returns the length of any loop on the specified index
// Rounded to its currently quantized length
// Or 0 if the loop has no pulse
nframes_t LoopManager::GetRoundedLength(int index) {
  if (status[index] == T_LS_Recording) {
    // Return 0 when recording
    return 0;

    // Ooh, we are recording on this index. Get the current length
    // return ((RecordProcessor *) plist[index])->GetRecordedLength();
  }
  else {
    Loop *cur = app->getTMAP()->GetMap(index);
    if (cur != 0)
      if (cur->pulse != 0)
        return cur->pulse->QuantizeLength(cur->blocks->GetTotalLen());
      else
        return 0; // cur->blocks->GetTotalLen();
  }
  
  return 0;
}

float LoopManager::GetPos(int index) {
  if (status[index] == T_LS_Recording)
    return 0.0;
  else {
    Loop *cur = app->getTMAP()->GetMap(index);
    if (cur != 0 && plist[index] != 0) {
      nframes_t playedlen = 0;
      if (status[index] == T_LS_Playing)
        playedlen = ((PlayProcessor *) plist[index])->GetPlayedLength();
      else if (status[index] == T_LS_Overdubbing)
        playedlen = ((RecordProcessor *) plist[index])->GetRecordedLength();

      if (cur->pulse == 0) 
        return (float) playedlen / cur->blocks->GetTotalLen();
      else {
        if (cur->pulse->QuantizeLength(cur->blocks->GetTotalLen()) == 0) {
          printf("LoopManager: ERROR: Problem with quantize GetPos\n");
          exit(1);
        }
        return (float) playedlen / 
          cur->pulse->QuantizeLength(cur->blocks->GetTotalLen());
      }
    }
  }
  
  return 0.0;
}

// Get current # of samples into block chain with given index
nframes_t LoopManager::GetCurCnt(int index) {
  if (status[index] == T_LS_Recording)
    return 0;
  else {
    Loop *cur = app->getTMAP()->GetMap(index);
    if (cur != 0 && plist[index] != 0) {
      if (status[index] == T_LS_Playing)
        return ((PlayProcessor *) plist[index])->GetPlayedLength();
      else if (status[index] == T_LS_Overdubbing) 
        return ((RecordProcessor *) plist[index])->GetRecordedLength();
    }
  }
  
  return 0;
}

// Sets triggered volume on specified index
// If index is not playing, activates the index
void LoopManager::SetTriggerVol(int index, float vol) {
  if (status[index] == T_LS_Playing) 
    ((PlayProcessor *) plist[index])->SetPlayVol(vol);
  else if (status[index] == T_LS_Overdubbing) 
    ((RecordProcessor *) plist[index])->SetODPlayVol(vol);
}

// Gets trigger volume on specified index
// If index is not playing, returns 0
float LoopManager::GetTriggerVol(int index) {
  if (status[index] == T_LS_Playing)
    return ((PlayProcessor *) plist[index])->GetPlayVol();
  else if (status[index] == T_LS_Overdubbing) 
    return ((RecordProcessor *) plist[index])->GetODPlayVol();
  else
    return 0.0;
}

// Returns a loop with the specified index, if one exists
Loop *LoopManager::GetSlot(int index) {
  return app->getTMAP()->GetMap(index);
}

void LoopManager::AdjustOutputVolume(float adjust) {
  app->getRP()->AdjustOutputVolume(adjust);
}

void LoopManager::SetOutputVolume(float set, float logset) {
  if (set >= 0.)
    app->getRP()->SetOutputVolume(set);
  else if (logset >= 0.)
    app->getRP()->SetOutputVolume(DB2LIN(AudioLevel::fader_to_dB(logset, app->getCFG()->GetFaderMaxDB())));
}

float LoopManager::GetOutputVolume() {
  return app->getRP()->GetOutputVolume();
}

void LoopManager::AdjustInputVolume(float adjust) {
  app->getRP()->AdjustInputVolume(adjust);
}

void LoopManager::SetInputVolume(float set, float logset) {
  if (set >= 0.)
    app->getRP()->SetInputVolume(set);
  else if (logset >= 0.)
    app->getRP()->SetInputVolume(DB2LIN(AudioLevel::fader_to_dB(logset, app->getCFG()->GetFaderMaxDB())));
}

float LoopManager::GetInputVolume() {
  return app->getRP()->GetInputVolume();
}

void LoopManager::SetLoopVolume(int index, float val) {
  Loop *lp = app->getTMAP()->GetMap(index);
  if (lp != 0) {
    // First, preprocess for smoothing
    Processor *p = GetProcessor(index);
    if (p != 0) 
      p->dopreprocess();

    if (val >= 0.0)
      lp->vol = val;
    else
      lp->vol = 0.0;
  }
}

float LoopManager::GetLoopVolume(int index) {
  Loop *lp = app->getTMAP()->GetMap(index);
  if (lp != 0)
    return lp->vol;
  else
    return 1.0;
}

void LoopManager::AdjustLoopVolume(int index, float adjust) {
  Loop *lp = app->getTMAP()->GetMap(index);
  if (lp != 0) {
    lp->dvol += adjust*app->getAUDIO()->GetTimeScale();
    if (lp->dvol < 0.0)
      lp->dvol = 0.0;
  }
}

void LoopManager::SetLoopdVolume(int index, float val) {
  Loop *lp = app->getTMAP()->GetMap(index);
  if (lp != 0)
    lp->dvol = val;
}

float LoopManager::GetLoopdVolume(int index) {
  Loop *lp = app->getTMAP()->GetMap(index);
  if (lp != 0)
    return lp->dvol;
  else
    return 1.0;
}

void LoopManager::SelectPulse (int pulseindex) {
  if (pulseindex == -1) {
    if (GetCurPulse() != 0) 
      GetCurPulse()->SetMIDIClock(0); // Stop MIDI clock
    
    //printf("**Select: No pulse\n");
    curpulseindex = -1;    
  } else if (pulseindex < 0 || pulseindex >= MAX_PULSES) {
    printf("CORE: Invalid pulse #%d, ignoring.\n",pulseindex);
    return;
  } else if (pulses[pulseindex] == 0) {
    //printf("New pulse[%d]: %d SUB: %d\n", pulseindex, lastindex, subdivide);
    CreatePulse(lastindex, pulseindex, subdivide);
  } else {
    //printf("Select pulse[%d]\n", pulseindex);
    curpulseindex = pulseindex;
    StripePulseOn(pulses[pulseindex]);
    
    // Select pulse, send MIDI start
    GetCurPulse()->SetMIDIClock(1);
  }
}

// Save a whole scene, with an optional filename-
// if none is given, saves a new scene
void TriggerMap::Save(Fweelin *app, char *filename) {
  if (GetSaveStatus() == NO_SAVE) {
    // Scene hash is generated from hash of all loops in the triggermap--
    // so start by saving all loops
    app->getLOOPMGR()->SetAutoLoopSaving(0);
    for (int i = 0; i < app->getCFG()->GetNumTriggers(); i++) 
      app->getLOOPMGR()->SaveLoop(i);

    // Now, we have to wait until all that saving is done.
    // Queue a scene marker event in the save queue
    SceneMarkerEvent *sEvt = (SceneMarkerEvent *) Event::GetEventByType(T_EV_SceneMarker,1);
    if (filename != 0)
      strncpy(sEvt->s_filename,filename,FWEELIN_OUTNAME_LEN);
    
    app->getLOOPMGR()->AddToSaveQueue(sEvt);
  }
};

void TriggerMap::SetMap (int index, Loop *smp) {
  if (index < 0 || index >= mapsize) {
    printf("SetMap: Invalid loop index!\n");
  }
  else {
    map[index] = smp;
    TouchMap();
    
    // Fire off a TriggerSet event
    TriggerSetEvent *tevt = (TriggerSetEvent *) 
      Event::GetEventByType(T_EV_TriggerSet);
    tevt->idx = index;
    tevt->nw = smp;
    app->getEMG()->BroadcastEventNow(tevt, this);
  }
};

void TriggerMap::GoSave(char *filename) {
  // All loops in the scene are now hashed and saved

  char newScene = (filename[0] == '\0');  // New scene or overwrite existing?
  if (newScene) {
    // Begin our save by generating a scene hash from the loop hashes
    // This will give us an appropriate scene filename
    MD5_CTX md5gen;
    MD5_Init(&md5gen);
    for (int i = 0; i < mapsize; i++)
      if (map[i] != 0) {
        if (map[i]->GetSaveStatus() == SAVE_DONE)
          // Update scene hash with hash from this loop
          MD5_Update(&md5gen,map[i]->GetSaveHash(),SAVEABLE_HASH_LENGTH);
        else
          printf("DISK: WARNING: Loop %d not saved yet but scene about to be "
                 "saved!\n",i);
      }
    
    // Done- compute our final hash
    MD5_Final(GetSaveHash(),&md5gen);
  }
  
  SetSaveStatus(SAVE_DONE);
    
  // Compose filenames & start writing
  char tmp[FWEELIN_OUTNAME_LEN];
  if (newScene) {
    GET_SAVEABLE_HASH_TEXT(GetSaveHash());
    snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s/%s-%s%s",
             app->getCFG()->GetLibraryPath(),FWEELIN_OUTPUT_SCENE_NAME,
             hashtext,FWEELIN_OUTPUT_DATA_EXT);
  } else
    snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s%s",
             filename,FWEELIN_OUTPUT_DATA_EXT);
             
  if (!newScene) {
    // Back up existing scene data
    struct stat st;
    if (stat(tmp,&st) == 0) {
      // First available backup filename
      char tmp2[FWEELIN_OUTNAME_LEN];
      int bCnt = 1;
      char go = 1;
      
      while (go) {
        snprintf(tmp2,FWEELIN_OUTNAME_LEN,"%s.backup.%d",tmp,bCnt);
        if (stat(tmp2,&st) != 0)
          go = 0; // Free backup filename
        else
          bCnt++;
      }
      
      char buf[FWEELIN_OUTNAME_LEN * 2 + 20];
      printf("INIT: Backup existing scene.\n");
      sprintf(buf,"mv \"%s\" \"%s\"",tmp,tmp2);
      printf("INIT: Executing: %s\n",buf);
      system(buf);      
    }
  }
  
  struct stat st;
  printf("DISK: Opening %s '%s' for saving.\n",
         (newScene ? "new scene" : "existing scene"),
         tmp);
  if (newScene && stat(tmp,&st) == 0) {
    printf("DISK: ERROR: MD5 collision while saving scene- file exists!\n");
  } else {
    // Save scene XML data
    xmlDocPtr ldat = xmlNewDoc((xmlChar *) "1.0");
    if (ldat != 0) {
      const static int XT_LEN = 10;
      char xmltmp[XT_LEN];
      
      // Scene
      ldat->children = xmlNewDocNode(ldat,0,
                                     (xmlChar *) FWEELIN_OUTPUT_SCENE_NAME,0);

      // Loops
      for (int i = 0; i < mapsize; i++)
        if (map[i] != 0 && map[i]->GetSaveStatus() == SAVE_DONE) {
          xmlNodePtr lp = xmlNewChild(ldat->children, 0, 
                                      (xmlChar *) FWEELIN_OUTPUT_LOOP_NAME, 0);

          // Loop index
          snprintf(xmltmp,XT_LEN,"%d",i);
          xmlSetProp(lp,(xmlChar *) "loopid",(xmlChar *) xmltmp);

          // Loop hash (used to find the loop on disk)
          unsigned char *sh = map[i]->GetSaveHash();
          GET_SAVEABLE_HASH_TEXT(sh);
          xmlSetProp(lp,(xmlChar *) "hash",(xmlChar *) hashtext);

          // Loop volume
          snprintf(xmltmp,XT_LEN,"%.5f",map[i]->vol);
          xmlSetProp(lp,(xmlChar *) "volume",(xmlChar *) xmltmp);
        }

      // Snapshots
      Snapshot *snaps = app->getSNAPS();
      for (int i = 0; i < app->getCFG()->GetMaxSnapshots(); i++) {
        if (snaps[i].exists) {
          Snapshot *s = &snaps[i];
          xmlNodePtr sp = xmlNewChild(ldat->children, 0, 
                                      (xmlChar *) FWEELIN_OUTPUT_SNAPSHOT_NAME, 0);

          // Snapshot index
          snprintf(xmltmp,XT_LEN,"%d",i);
          xmlSetProp(sp,(xmlChar *) "snapid",(xmlChar *) xmltmp);

          // Name
          if (s->name != 0)
            xmlSetProp(sp,(xmlChar *) "name",(xmlChar *) s->name);

          for (int j = 0; j < s->numls; j++) {
            LoopSnapshot *ls = &(s->ls[j]);
            xmlNodePtr slp = xmlNewChild(sp, 0, 
                                         (xmlChar *) FWEELIN_OUTPUT_LOOPSNAPSHOT_NAME, 0);
            
            // Loop index
            snprintf(xmltmp,XT_LEN,"%d",ls->l_idx);
            xmlSetProp(slp,(xmlChar *) "loopid",(xmlChar *) xmltmp);

            // Loop status
            snprintf(xmltmp,XT_LEN,"%d",ls->status);
            xmlSetProp(slp,(xmlChar *) "status",(xmlChar *) xmltmp);

            // Loop volume
            snprintf(xmltmp,XT_LEN,"%.5f",ls->l_vol);
            xmlSetProp(slp,(xmlChar *) "loopvol",(xmlChar *) xmltmp);

            // Trigger volume
            snprintf(xmltmp,XT_LEN,"%.5f",ls->t_vol);
            xmlSetProp(slp,(xmlChar *) "triggervol",(xmlChar *) xmltmp);
          }
        }
      }

      xmlSaveFormatFile(tmp,ldat,1);
      xmlFreeDoc(ldat);

      if (newScene) {
        // Add scene to browser so we can load it
        Browser *br = app->getBROWSER(B_Scene);
        if (br != 0) {
          app->setCURSCENE(app->getLOOPMGR()->AddSceneToBrowser(br,tmp));
          br->AddDivisions(FWEELIN_FILE_BROWSER_DIVISION_TIME);
        }
      }

      printf("DISK: Close output.\n");
    }
  }
};

// If we are autosaving, we have to maintain a list of new loops to be saved
void LoopManager::CheckSaveMap() {
  if (needs_saving_stamp != app->getTMAP()->GetLastUpdate()) {
    //printf("Rebuild save map.\n");

    // No, rebuild!
    numsave = 0;
    savequeue = EventManager::DeleteQueue(savequeue);

    // Scan for loops that haven't yet been saved, add them to our list
    TriggerMap *tmap = app->getTMAP();
    int mapsz = tmap->GetMapSize();
    for (int i = 0; i < mapsz; i++) {
      Loop *l = tmap->GetMap(i);
      if (l != 0 && l->GetSaveStatus() == NO_SAVE) {
        // Loop exists but not saved-- add to our map
        LoopListEvent *ll = (LoopListEvent *) 
          Event::GetEventByType(T_EV_LoopList,1);
        ll->l = l;
        
        numsave++;
        EventManager::QueueEvent(&savequeue,ll);
      }
    }

    // Now we've updated map
    needs_saving_stamp = tmap->GetLastUpdate();
  } else {
    //printf("Stamp match: %lf\n",needs_saving_stamp);
  }
}

// Saves loop XML data & prepares to save loop audio
void LoopManager::SetupSaveLoop(Loop *l, int l_idx, FILE **out, 
                                AudioBlock **b, 
                                AudioBlockIterator **i,
                                nframes_t *len) {
  const static nframes_t LOOP_HASH_CHUNKSIZE = 10000;

  if (l->GetSaveStatus() == NO_SAVE) {
    // Now return blocks from this loop to save
    *b = l->blocks;

#if 0
    if (l->pulse != 0)
      // Loop is syncronized to a pulse- quantize length
      *len = l->pulse->QuantizeLength(l->blocks->GetTotalLen());
    else
#endif

      // Take length from blocks
      *len = l->blocks->GetTotalLen();
    *i = 0;
    
    // Generate hash from audio data
    double hashtime = mygettime();

    // *** Hopefully this won't take so long- or we may have to split it up
    // as we split up the write phase
    AudioBlockIterator *hashi = new AudioBlockIterator(l->blocks,
                                                       LOOP_HASH_CHUNKSIZE);
    MD5_CTX md5gen;
    MD5_Init(&md5gen);
    char go = 1;
    char stereo = l->blocks->IsStereo();
    
    do {
      nframes_t pos = hashi->GetTotalLength2Cur(),
        remaining = *len-pos;
      nframes_t num = MIN(LOOP_HASH_CHUNKSIZE,remaining);
      
      sample_t *ibuf[2];
      if (stereo) {
        // Stereo
        hashi->GetFragment(&ibuf[0],&ibuf[1]);
        MD5_Update(&md5gen,ibuf[0],sizeof(sample_t) * num);
        MD5_Update(&md5gen,ibuf[1],sizeof(sample_t) * num);
      } else {
        // Mono
        hashi->GetFragment(&ibuf[0],0);
        MD5_Update(&md5gen,ibuf[0],sizeof(sample_t) * num);
      }
      
      if (remaining <= LOOP_HASH_CHUNKSIZE) {
        // Finished encoding
        go = 0;
      } else
        hashi->NextFragment();
    } while (go);
    
    // Done- compute final hash
    MD5_Final(l->GetSaveHash(),&md5gen);
    l->SetSaveStatus(SAVE_DONE);
    delete hashi;

    double dhashtime = mygettime()-hashtime;
    printf("HASH TIME: %f ms\n",dhashtime * 1000);

    // Compose filenames & start writing
    char tmp[FWEELIN_OUTNAME_LEN];
    GET_SAVEABLE_HASH_TEXT(l->GetSaveHash());
    if (l->name == 0 || strlen(l->name) == 0)
      snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s/%s-%s%s",
               app->getCFG()->GetLibraryPath(),FWEELIN_OUTPUT_LOOP_NAME,
               hashtext,
               app->getCFG()->GetAudioFileExt(app->getCFG()->GetLoopOutFormat()));
    else
      snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s/%s-%s-%s%s",
               app->getCFG()->GetLibraryPath(),FWEELIN_OUTPUT_LOOP_NAME,
               hashtext,l->name,
               app->getCFG()->GetAudioFileExt(app->getCFG()->GetLoopOutFormat()));

    struct stat st;
    printf("DISK: Opening '%s' for saving.\n",tmp);
    if (stat(tmp,&st) == 0) {
      printf("DISK: ERROR: MD5 collision while saving loop- file exists!\n");

      *b = 0;
      *len = 0;
      *i = 0;
      if (*out != 0) {
        fclose(*out);
        *out = 0;
      }
    } else {
      // Go save!
      *out = fopen(tmp,"wb");
      if (*out == 0) {
        printf("DISK: ERROR: Couldn't open file! Does the folder exist and "
               "do you have write permission?\n");
        *b = 0;
        *len = 0;
        *i = 0;
        if (*out != 0) {
          fclose(*out);
          *out = 0;
        }       
      } else {
        // Add loop to browser so we can load it
        Browser *br = app->getBROWSER(B_Loop);
        if (br != 0) {
          AddLoopToBrowser(br,tmp);
          br->AddDivisions(FWEELIN_FILE_BROWSER_DIVISION_TIME);
        }

        // Main file open, now save loop XML data
        if (l->name == 0 || strlen(l->name) == 0)
          snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s/%s-%s%s",
                   app->getCFG()->GetLibraryPath(),FWEELIN_OUTPUT_LOOP_NAME,
                   hashtext,FWEELIN_OUTPUT_DATA_EXT);
        else
          snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s/%s-%s-%s%s",
                   app->getCFG()->GetLibraryPath(),FWEELIN_OUTPUT_LOOP_NAME,
                   hashtext,l->name,FWEELIN_OUTPUT_DATA_EXT);

        xmlDocPtr ldat = xmlNewDoc((xmlChar *) "1.0");
        if (ldat != 0) {
          const static int XT_LEN = 10;
          char xmltmp[XT_LEN];

          ldat->children = xmlNewDocNode(ldat,0,
            (xmlChar *) FWEELIN_OUTPUT_LOOP_NAME,0);

          // version
          snprintf(xmltmp,XT_LEN,"%d",LOOP_SAVE_FORMAT_VERSION);
          xmlSetProp(ldat->children,(xmlChar *) "version",(xmlChar *) xmltmp);

          // # beats
          snprintf(xmltmp,XT_LEN,"%ld",l->nbeats);
          xmlSetProp(ldat->children,(xmlChar *) "nbeats",(xmlChar *) xmltmp);

          // pulse length
          if (l->pulse == 0)
            xmlSetProp(ldat->children,(xmlChar *) "pulselen",(xmlChar *) "0");
          else {
            snprintf(xmltmp,XT_LEN,"%d",l->pulse->GetLength());
            xmlSetProp(ldat->children,(xmlChar *) "pulselen",
                       (xmlChar *) xmltmp);
          }
          xmlSaveFormatFile(tmp,ldat,1);
          xmlFreeDoc(ldat);
        }
      }
    }
  } else {
    printf("DISK: WARNING: Loop marked already saved.\n");

    *b = 0;
    *len = 0;
    *i = 0;
    if (*out != 0) {
      fclose(*out);
      *out = 0;
    }
  }
};

// Loads loop XML data & prepares to load loop audio
int LoopManager::SetupLoadLoop(FILE **in, char *smooth_end, Loop **new_loop, 
                               int l_idx, float l_vol, char *l_filename) {
  // Open up right file and begin loading
  char tmp[FWEELIN_OUTNAME_LEN];
  codec format = UNKNOWN;
  // Try exact filename with all format types
  for (codec i = FIRST_FORMAT; i < END_OF_FORMATS; i = (codec) (i+1))
  {
    snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s%s",l_filename,
             app->getCFG()->GetAudioFileExt(i));
    *in = fopen(tmp,"rb");
    if (*in != 0) {
      printf("DISK: Open loop '%s'\n",tmp);
      bread->SetLoopType(i);
      format = i;
      break;
    }
  } 

  if (*in == 0) {
    // No go, try wildcard search with all format types
    for (codec i = FIRST_FORMAT; i < END_OF_FORMATS; i = (codec) (i+1)) {
      snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s*%s",l_filename,
               app->getCFG()->GetAudioFileExt(i));
      glob_t globbuf;
      if (glob(tmp, 0, NULL, &globbuf) == 0) {
        for (size_t j = 0; *in == 0 && j < globbuf.gl_pathc; j++) {
          printf("DISK: Open loop '%s'\n",globbuf.gl_pathv[j]);
          *in = fopen(globbuf.gl_pathv[j],"rb");
        }
        globfree(&globbuf);
      }
      if (*in != 0) {
        bread->SetLoopType(i);
        format = i;
        break;
      } 
    }
    if (*in == 0) {
      printf("DISK: ERROR: Couldn't open loop '%s'!\n",tmp);
      return 1;
    }
  }

  // Main file open, now load loop XML data
  snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s%s",
           l_filename,FWEELIN_OUTPUT_DATA_EXT);
  
  // Create loop data
  *new_loop = new Loop(0,0,1.0,l_vol,0,format);

  struct stat st;
  int result = 1;
  if (stat(tmp,&st) != 0) {
    // Try loading with wildcard
    snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s*%s",
             l_filename,FWEELIN_OUTPUT_DATA_EXT);
    glob_t globbuf;

    if (glob(tmp, 0, NULL, &globbuf) == 0) {
      for (size_t i = 0; result != 0 && i < globbuf.gl_pathc; i++) {
        result = stat(globbuf.gl_pathv[i],&st);
        if (result == 0)
          strncpy(tmp,globbuf.gl_pathv[i],
                  FWEELIN_OUTNAME_LEN); // Save the name for later
      }
      globfree(&globbuf);
    }

    if (result != 0)
      printf("DISK: WARNING: Loop data '%s' missing!\n"
             "I will load just the raw audio.\n",tmp);
  } else
    result = 0;

  xmlDocPtr ldat = 0;
  if (result == 0)
    ldat = xmlParseFile(tmp);
  if (ldat == 0)
    printf("DISK: WARNING: Loop data '%s' invalid!\n"
           "I will load just the raw audio.\n",tmp);
  else {
    xmlNode *root = xmlDocGetRootElement(ldat);
    
    // Extract hash from filename
    char fn_hash[FWEELIN_OUTNAME_LEN],
      loopname[FWEELIN_OUTNAME_LEN];
    int baselen = strlen(app->getCFG()->GetLibraryPath()) + 1 +
      strlen(FWEELIN_OUTPUT_LOOP_NAME);
    if (!Saveable::SplitFilename(tmp,baselen,0,fn_hash,loopname,
                                 FWEELIN_OUTNAME_LEN)) {
      // Set hash from filename
      (*new_loop)->SetSaveableHashFromText(fn_hash);
      
      // GET_SAVEABLE_HASH_TEXT((*new_loop)->GetSaveHash());
      // printf("md5: %s\n",hashtext);
      
      // First, check if this loop has already been loaded
      // by scanning for another loop with the same hash
      int dupidx;
      if ((dupidx = 
           app->getTMAP()->ScanForHash((*new_loop)->GetSaveHash())) != -1) {
        printf("DISK: (DUPLICATE) Loop to load is already loaded at "
               "ID #%d.\n",dupidx);
        
        delete (*new_loop);
        *new_loop = 0;
        fclose(*in);
        *in = 0;
        
        return 1;
      }
      
      // Set loop name from filename
      (*new_loop)->name = new char[strlen(loopname)+1];
      strcpy((*new_loop)->name,loopname);
    } else
      printf("DISK: Loop filename '%s' missing hash!\n",l_filename);
    
    // version
    xmlChar *n = xmlGetProp(root, (const xmlChar *) "version");
    if (n != 0) {
      if (atoi((char *) n) >= 1)
        // New format of loop save, so smooth end
        *smooth_end = 1;
      else
        *smooth_end = 0;
      
      xmlFree(n);
    } else {
      *smooth_end = 0;
      printf("DISK: Old format loop '%s'- loading with length fix.\n",
             l_filename);
    }
    
    // # beats
    n = xmlGetProp(root, (const xmlChar *) "nbeats");
    if (n != 0) {
      (*new_loop)->nbeats = atoi((char *) n);
      xmlFree(n);
    }
    
    // pulse length
    if ((n = xmlGetProp(root, (const xmlChar *) "pulselen")) != 0) {
      int plen = atoi((char *) n);
      if (plen != 0) {
        // Loop should be syncronized to a pulse of given length-
        (*new_loop)->pulse = CreatePulse(plen);
      }
      xmlFree(n);
    }
    
    xmlFreeDoc(ldat);
    // Don't call cleanup because another thread may have xml open
    // xmlCleanupParser();
  }

  return 0;
};

// Starts an interactive rename for a loop in memory
void LoopManager::RenameLoop(int loopid) {
  if (renamer == 0) {
    Loop *l = GetSlot(loopid);
    if (l != 0) {
      if (CRITTERS)
        printf("RENAME: Loop: %p\n",l);
      rename_loop = l;
      renamer = new ItemRenamer(app,this,l->name);
      if (!renamer->IsRenaming()) {
        delete renamer;
        renamer = 0;
        rename_loop = 0;
      }
    }
  }
};

void LoopManager::ItemRenamed(char *nw) {
  if (nw != 0) {
    // Rename on disk
    const static char *exts[] = {app->getCFG()->GetAudioFileExt(rename_loop->format), 
                                 FWEELIN_OUTPUT_DATA_EXT};
    char *old_filename = 0, 
      *new_filename = 0;
    rename_loop->RenameSaveable(app->getCFG()->GetLibraryPath(), 
                                FWEELIN_OUTPUT_LOOP_NAME,
                                rename_loop->name, nw,
                                exts, 2,
                                &old_filename,
                                &new_filename);
    
    // We also need to rename in the loop browser
    if (app->getBROWSER(B_Loop) != 0) 
      app->getBROWSER(B_Loop)->
        ItemRenamedOnDisk(old_filename,new_filename,nw);
    
    if (old_filename != 0)
      delete[] old_filename;
    if (new_filename != 0)
      delete[] new_filename;
    
    // Rename in memory
    RenameLoop(rename_loop,nw);

    // We have to notify the LoopTray of the new name given
    LoopTray *tray = (LoopTray *) app->getBROWSER(B_Loop_Tray);
    if (tray != 0)
      tray->ItemRenamedFromOutside(rename_loop,nw);
        
    delete renamer;
    renamer = 0;
    rename_loop = 0;
  } else {
    // Rename was aborted
    delete renamer;
    renamer = 0;
    rename_loop = 0;
  }
};

void LoopManager::GetWriteBlock(FILE **out, AudioBlock **b, 
                                AudioBlockIterator **i,
                                nframes_t *len) {
  // If we are autosaving, check that our list is up to date
  if (autosave)
    CheckSaveMap();

  // Do we have a loop to save?
  Event *cur = savequeue,
    *prev = 0;

  if (cursave >= numsave) {
    numsave = 0;
    cursave = 0;
  }

  int l_idx = 0;  
  char go = 1, advance = 1;
  while (cur != 0 && go) {
    if (cur->GetType() == T_EV_LoopList) {
      // Loop in save queue- does it exist and is it ready to save?
      if ((l_idx = app->getTMAP()->SearchMap(((LoopListEvent *) cur)->l)) == -1
          || GetStatus(l_idx) == T_LS_Overdubbing
          || GetStatus(l_idx) == T_LS_Recording) {
        if (l_idx == -1) {
          printf("DEBUG: Loop no longer exists- abort save!\n");
          EventManager::RemoveEvent(&savequeue,prev,&cur);
          advance = 0;
        }

        // If we are overdubbing or recording, just ignore this loop
        // we will come back to it
      } else {
        go = 0; // Found a suitable loop to save- stop!
        advance = 0;
      }
    } else {
      if (cur->GetType() == T_EV_SceneMarker) {
        // Scene marker in queue indicates we need to save a scene-
        if (cur == savequeue) {
          // No loops are waiting to be saved.. go
          app->getTMAP()->GoSave(((SceneMarkerEvent *) cur)->s_filename);
          EventManager::RemoveEvent(&savequeue,prev,&cur);
          cursave++;
          advance = 0;
        } 
      }
    }

    // Move to next item
    if (advance) {
      prev = cur; 
      cur = cur->next;
    }
    else 
      advance = 1;
  }

  if (cur != 0) {
    if (cur->GetType() != T_EV_LoopList) {
      printf("DISK: ERROR: LoopList event type mismatch!\n");
      EventManager::RemoveEvent(&savequeue,prev,&cur);
    } else {
      // Remove from list
      Loop *curl = ((LoopListEvent *) cur)->l;
      EventManager::RemoveEvent(&savequeue,prev,&cur);

      // Open up right files, save data & setup for audio save
      SetupSaveLoop(curl,l_idx,out,b,i,len);
      cursave++;
    }
  } else {
    // No loops to save right now
    *b = 0;
    *len = 0;
    *i = 0;
    if (*out != 0) {
      fclose(*out);
      *out = 0;
    }
  }
}

// We receive calls periodically for loading of loops-
void LoopManager::GetReadBlock(FILE **in, char *smooth_end) {
  if (curload >= numload) {
    numload = 0;
    curload = 0;
  }

  // Do we have a loop to load?
  Event *cur = loadqueue;
  if (cur != 0) {
    if (cur->GetType() == T_EV_LoopList) {
      // Open up right files, load data & setup for audio load
      LoopListEvent *ll = (LoopListEvent *) cur;
      if (SetupLoadLoop(in,smooth_end,
                        &ll->l,ll->l_idx,ll->l_vol,ll->l_filename)) {
        // Not a loop or there was an error in loading
        EventManager::RemoveEvent(&loadqueue,0,&cur);
        curload++;
      }
    } else {
      // Not a loop- remove
      EventManager::RemoveEvent(&loadqueue,0,&cur);
      curload++;
    }
  } else {
    // Nothing to load right now
    if (*in != 0) {
      printf("DISK: (Load) Nothing to load- close input!\n");
      fclose(*in);
      *in = 0;
    }
  }
}

void LoopManager::ReadComplete(AudioBlock *b) {
  curload++;

  // Add loop to triggermap and remove from load queue
  Event *cur = loadqueue;
  if (cur == 0 || cur->GetType() != T_EV_LoopList)
    printf("DISK: ERROR: Load list mismatch!\n");
  else {
    if (b == 0)
      printf("DISK: ERROR: .. during load!\n");
    else {
      LoopListEvent *ll = (LoopListEvent *) cur;

      // Put blocks into loop
      ll->l->blocks = b;

      if (app->getTMAP()->GetMap(ll->l_idx) != 0) {
        // Loop ID is full. Choose another
        int newidx = app->getTMAP()->GetFirstFree(default_looprange.lo,
                                                  default_looprange.hi);
        
        if (newidx != -1) {
          printf("LOOP MANAGER: LoopID #%d full, got new ID: #%d!\n",
                 ll->l_idx,newidx);
          ll->l_idx = newidx;
        } else {
          printf("LOOP MANAGER: No free loopids in default placement range.\n"
                 "I will erase the loop at id #%d.\n",ll->l_idx);
          DeleteLoop(ll->l_idx);
        }
      }

      // Add loop to our map
      app->getTMAP()->SetMap(ll->l_idx,ll->l);
      lastindex = ll->l_idx; // Set this so we can make a pulse from this loop
    }

    // And remove from load list
    EventManager::RemoveEvent(&loadqueue,0,&cur);
  }
}

void LoopManager::StripePulseOn(Pulse *pulse) {
  app->getBMG()->StripeBlockOn(pulse,app->getAMPEAKS(),
                               app->getAMPEAKSI());
  app->getBMG()->StripeBlockOn(pulse,app->getAUDIOMEM(),
                               app->getAUDIOMEMI());
}

void LoopManager::StripePulseOff(Pulse *pulse) {
  app->getBMG()->StripeBlockOff(pulse,app->getAMPEAKS());
  app->getBMG()->StripeBlockOff(pulse,app->getAUDIOMEM());
}

// Creates a pulse of the given length in the first available slot,
// if none already exists of the right length
Pulse *LoopManager::CreatePulse(nframes_t len) {
  // First, check to see if we have a pulse of the right length-
  int i;
  for (i = 0; i < MAX_PULSES && 
         (pulses[i] == 0 || pulses[i]->GetLength() != len); i++);
  if (i < MAX_PULSES)
    // Found it, use this pulse
    return pulses[i];
  else {
    // No pulse found of right length-- create a new one
    for (i = 0; i < MAX_PULSES && pulses[i] != 0; i++);
    if (i < MAX_PULSES) {
      app->getRP()->AddChild(pulses[i] = 
                             new Pulse(app,len,0),
                             ProcessorItem::TYPE_HIPRIORITY);
      StripePulseOn(pulses[i]);
      curpulseindex = i;

      // Send MIDI start for pulse
      GetCurPulse()->SetMIDIClock(1);
      
      return pulses[i];
    } else
      // No space for a new pulse!
      return 0;
  }
};

// Create a time pulse around the specified index
// The length of the loop on the specified index becomes
// a time constant around which other loops center themselves
// subdivide the length of the loop by subdivide to get the core pulse
void LoopManager::CreatePulse(int index, int pulseindex, int sub) {
  Loop *cur = app->getTMAP()->GetMap(index);
  if (cur != 0 && (status[index] == T_LS_Off ||
                   status[index] == T_LS_Playing ||
                   status[index] == T_LS_Overdubbing)) {
    // Set pulse length based on loop length
    nframes_t len = GetLength(index);
    if (len != 0) {
      // Create iterator
      len /= sub; // Length subdivide
      nframes_t startpos = 0;
      // So set the starting pulse position based on where loop is playing
      if (status[index] == T_LS_Playing)
        startpos = ((PlayProcessor *) plist[index])->GetPlayedLength() % len;
      else if (status[index] == T_LS_Overdubbing)
        startpos = ((RecordProcessor *) plist[index])->
          GetRecordedLength() % len;
      
      app->getRP()->AddChild(cur->pulse = pulses[pulseindex] = 
                             new Pulse(app,len,startpos),
                             ProcessorItem::TYPE_HIPRIORITY);
      StripePulseOn(cur->pulse);
      curpulseindex = pulseindex;
      cur->nbeats = sub; // Set # of beats in the loop

      // Send MIDI start for pulse
      GetCurPulse()->SetMIDIClock(1);
      
      // Now reconfigure processor on this index to be synced to the new pulse
      if (status[index] == T_LS_Playing) 
        ((PlayProcessor *) plist[index])->SyncUp();
      else if (status[index] == T_LS_Overdubbing)
        ((RecordProcessor *) plist[index])->SyncUp();
    }
  }
}

// Taps a pulse- starting at the downbeat- if newlen is nonzero, the pulse's
// length is adjusted to reflect the length between taps- and a new pulse
// is created if none exists
void LoopManager::TapPulse(int pulseindex, char newlen) {
  // If more than TIMEOUT_RATIO * the current pulse length
  // frames have passed since the last tap, a new length is not defined
  const static float TAP_NEWLEN_TIMEOUT_RATIO = 5.0, //2.0,
    // Higher graduation makes tempo more stable against changes
    TAP_NEWLEN_GRADUATION = 0.0, //0.5,
    // Tolerance for rejecting tap tempo changes- as fraction of current length
    TAP_NEWLEN_REJECT_TOLERANCE = 1.0; //0.3;

  if (pulseindex >= 0 || pulseindex < MAX_PULSES) {
    Pulse *cur = pulses[pulseindex];
    if (cur == 0) {
      if (newlen) {
        // New pulse- tap now!- set zero length for now
        cur = pulses[pulseindex] = new Pulse(app,0,0);
        cur->stopped = 1;
        cur->prevtap = app->getRP()->GetSampleCnt();
        //cur->SwitchMetronome(1);
        app->getRP()->AddChild(cur,ProcessorItem::TYPE_HIPRIORITY);
        
        StripePulseOn(cur);
        curpulseindex = pulseindex;
      }
    } else {
      // Test position of axis
      char nextdownbeat = 0;
      if (cur->GetPct() >= 0.5)
        nextdownbeat = 1;

      // Old pulse- tap now!
      if (newlen) {
        // Redefine length from tap
        nframes_t oldlen = cur->GetLength(),
          newtap = app->getRP()->GetSampleCnt(),
          newlen = newtap - cur->prevtap;

        // .. only if the new length isn't outrageous
        if (oldlen < 64)
          cur->SetLength(newlen);
        else if (newlen < oldlen * TAP_NEWLEN_TIMEOUT_RATIO) {
          // 2nd outrageous length check
          float ratio = (float) MIN(newlen,oldlen)/MAX(newlen,oldlen);
          if (ratio > 1.0-TAP_NEWLEN_REJECT_TOLERANCE)
            cur->SetLength((nframes_t) (oldlen*TAP_NEWLEN_GRADUATION +
                                        newlen*(1-TAP_NEWLEN_GRADUATION)));
        }

        cur->prevtap = newtap;
        //cur->SwitchMetronome(1);
        cur->stopped = 0;
      }

      if (nextdownbeat)
        // Tap to beginning- with wrap
        cur->Wrap();
      else
        // Tap to beginning- no wrap
        cur->SetPos(0);

      // Notify external transport that we have moved
      app->getAUDIO()->RelocateTransport(0);
    }
  } else
    printf("CORE: Invalid pulse #%d, ignoring.\n",pulseindex);
}

void LoopManager::SwitchMetronome(int pulseindex, char active) {
  if (pulseindex >= 0 || pulseindex < MAX_PULSES) {
    Pulse *cur = pulses[pulseindex];
    if (cur != 0)
      cur->SwitchMetronome(active);
    else
      printf("CORE: No pulse at #%d, ignoring.\n",pulseindex);
  } else
    printf("CORE: Invalid pulse #%d, ignoring.\n",pulseindex);
}

void LoopManager::DeletePulse(int pulseindex) {
  if (pulseindex < 0 || pulseindex >= MAX_PULSES) {
    printf("CORE: Invalid pulse #%d, ignoring.\n",pulseindex);
    return;
  }

  if (pulses[pulseindex] != 0) {
    // Stop striping beats from this pulse
    StripePulseOff(pulses[pulseindex]);

    // Erase all loops which are attached to this pulse-- or we'll have
    // references pointing to the deleted pulse
    int nt = app->getCFG()->GetNumTriggers();
    for (int i = 0; i < nt; i++)
      if (GetPulse(i) == pulses[pulseindex]) 
        DeleteLoop(i);

    // Erase this pulse
    app->getRP()->DelChild(pulses[pulseindex]);
    pulses[pulseindex] = 0;
  }
}

Pulse *LoopManager::GetPulse(int index) {
  Loop *lp = GetSlot(index);
  if (lp != 0)
    return lp->pulse;
  else
    return 0;
}

// Move the loop at specified index to another index
// only works if target index is empty
// returns 1 if success
int LoopManager::MoveLoop (int src, int tgt) {
  Loop *srloop = app->getTMAP()->GetMap(src);
  if (srloop != 0) {
    Loop *tgtloop = app->getTMAP()->GetMap(tgt);
    if (tgtloop == 0) {
      app->getTMAP()->SetMap(tgt,srloop);
      app->getTMAP()->SetMap(src,0);
      plist[tgt] = plist[src];
      plist[src] = 0;
      status[tgt] = status[src];
      status[src] = T_LS_Off;
      waitactivate[tgt] = waitactivate[src];
      waitactivate[src] = 0;
      waitactivate_shot[tgt] = waitactivate_shot[src];
      waitactivate_shot[src] = 0;
      waitactivate_vol[tgt] = waitactivate_vol[src];
      waitactivate_vol[src] = 0.;
      waitactivate_od[tgt] = waitactivate_od[src];
      waitactivate_od[src] = 0;
      waitactivate_od_fb[tgt] = waitactivate_od_fb[src];
      waitactivate_od_fb[src] = 0;
      for (int i = 0; i < LAST_REC_COUNT; i++)  
        if (lastrecidx[i] == src)
          lastrecidx[i] = tgt;

      if (lastindex == src)
        lastindex = tgt;
      
      UpdateLoopLists_ItemMoved(src,tgt);
    }
    else 
      return 0;
  }
  else
    return 0;
  
  return 1;
}

// Delete the loop at the specified index..
// Not RT safe!
// Threadsafe
void LoopManager::DeleteLoop (int index) {
  LockLoops();

  Loop *lp = app->getTMAP()->GetMap(index);
  if (lp != 0) {
    // First, zero the map at the given index
    // To prevent anybody from attaching to the loop as we delete it
    app->getTMAP()->SetMap(index, 0);
  }

  if (plist[index] != 0) {
    // We have a processor on this loop! Stop it!
    if (status[index] == T_LS_Recording) {
      RecordProcessor *recp = (RecordProcessor *) plist[index];
      recp->AbortRecording();
      AudioBlock *recblk = recp->GetFirstRecordedBlock();
      if (recblk != 0) {
        app->getBMG()->RefDeleted(recblk);
        recblk->DeleteChain(); // *** Not RT Safe
        if (lp != 0)
          lp->blocks = 0;
      }

      numrecordingloops--;
    } else if (status[index] == T_LS_Overdubbing)
      numrecordingloops--;

    // Remove the record/play processor
    app->getRP()->DelChild(plist[index]);
    plist[index] = 0;
    status[index] = T_LS_Off;
    waitactivate[index] = 0;
    waitactivate_shot[index] = 0;
    waitactivate_vol[index] = 0.;
    waitactivate_od[index] = 0;
    waitactivate_od_fb[index] = 0;
  }
    
  if (lp != 0) {
    if (lp->blocks != 0) {
      // Notify any blockmanagers working on this loop's audio to end!
      app->getBMG()->RefDeleted(lp->blocks);
      lp->blocks->DeleteChain(); // *** Not RT Safe
    }

    delete lp;                   // *** Not RT Safe
    numloops--;
    
    // Update looplists/scenes to ensure that loop is removed from them
    UpdateLoopLists_ItemRemoved(index);
  }

  UnlockLoops();
}

void LoopManager::UpdateLoopLists_ItemAdded (int l_idx) {
  // Update...

  // Snapshots
  Snapshot *snaps = app->getSNAPS();
  for (int i = 0; i < app->getCFG()->GetMaxSnapshots(); i++) {
    if (snaps[i].exists) {
      Snapshot *s = &snaps[i];
      char go = 1;
      for (int j = 0; go && j < s->numls; j++) 
        if (s->ls[j].l_idx == l_idx)
          go = 0;

      if (go) {
        // Loop index not present in snapshot- add, defaulting to loop off
        LoopSnapshot *newls = 0;
        newls = new LoopSnapshot[s->numls+1];

        memcpy(newls,s->ls,sizeof(LoopSnapshot) * s->numls);
        LoopSnapshot *n = &newls[s->numls];

        n->l_idx = l_idx;
        n->status = T_LS_Off;
        n->l_vol = GetLoopVolume(l_idx);
        n->t_vol = 0.;

        delete[] s->ls;
        s->ls = newls;
        s->numls = s->numls+1;
      }
    }
  }
};

void LoopManager::UpdateLoopLists_ItemRemoved (int l_idx) {
  // Update...

  // Selection sets
  for (int i = 0; i < NUM_LOOP_SELECTION_SETS; i++) {
    LoopList **ll = app->getLOOPSEL(i);
    *ll = LoopList::Remove(*ll,l_idx);
  }

  // Snapshots
  Snapshot *snaps = app->getSNAPS();
  for (int i = 0; i < app->getCFG()->GetMaxSnapshots(); i++) {
    if (snaps[i].exists) {
      Snapshot *s = &snaps[i];
      char go = 1;
      for (int j = 0; go && j < s->numls; j++) 
        if (s->ls[j].l_idx == l_idx) {
          // Remove loop from list
          LoopSnapshot *newls = 0;
          if (s->numls > 1) {
            newls = new LoopSnapshot[s->numls-1];

            // All elements preceding j
            memcpy(newls,s->ls,sizeof(LoopSnapshot) * j);
            // & following
            memcpy(&newls[j],&(s->ls[j+1]),
                   sizeof(LoopSnapshot) * (s->numls-j-1));
          }

          delete[] s->ls;
          s->ls = newls;
          s->numls = s->numls-1;
          go = 0; // No more checking in this snapshot
        }
    }
  }
};

void LoopManager::UpdateLoopLists_ItemMoved (int l_idx_old, int l_idx_new) {
  // Update...

  // Selection sets
  for (int i = 0; i < NUM_LOOP_SELECTION_SETS; i++) {
    LoopList **ll = app->getLOOPSEL(i),
      *prev,
      *found = LoopList::Scan(*ll,l_idx_old,&prev);
    
    // Update index
    if (found != 0)
      found->l_idx = l_idx_new;
  }

  // Snapshots
  Snapshot *snaps = app->getSNAPS();
  for (int i = 0; i < app->getCFG()->GetMaxSnapshots(); i++) {
    if (snaps[i].exists) {
      Snapshot *s = &snaps[i];
      for (int j = 0; j < s->numls; j++) 
        if (s->ls[j].l_idx == l_idx_old)
          s->ls[j].l_idx = l_idx_new;
    }
  }
};

// Trigger the loop at index within the map
// The exact behavior varies depending on what is already happening with
// this loop and the settings passed- see .fweelin.rc
// *** Not RT Safe
void LoopManager::Activate (int index, char shot, float vol, nframes_t ofs, 
                            char overdub, float *od_feedback) {
  // printf("ACTIVATE plist %p status %d\n",plist[index],status[index]);

  if (plist[index] != 0) {
    // We have a problem, we already have a processor on this index.
    // Queue the requested activate
    waitactivate[index] = 1;
    waitactivate_shot[index] = shot;
    waitactivate_vol[index] = vol;
    waitactivate_od[index] = overdub;
    waitactivate_od_fb[index] = od_feedback;
    return;
  }
  
  Loop *lp = app->getTMAP()->GetMap(index);
  if (lp == 0) {
    // Record a new loop
    float *inputvol = &(app->getRP()->inputvol); // Where to get input vol from
    app->getRP()->AddChild(plist[index] =
                           new RecordProcessor(app,app->getISET(),inputvol,
                                               GetCurPulse(),
                                               app->getAUDIOMEM(),
                                               app->getAUDIOMEMI(),
                                               app->getCFG()->
                                               loop_peaksavgs_chunksize));
    
    numrecordingloops++;
    status[index] = T_LS_Recording;
    // Keep track of this index in our record of last recorded indexes
    for (int i = LAST_REC_COUNT-1; i > 0; i--)
      lastrecidx[i] = lastrecidx[i-1];
    lastrecidx[0] = index;
  } else {
    // A loop exists at that index
    if (overdub) {
      // Overdub
      float *inputvol = &(app->getRP()->inputvol); // Get input vol from main
      app->getRP()->AddChild(plist[index] = 
                             new RecordProcessor(app,
                                                 app->getISET(),inputvol,
                                                 lp,vol,ofs,od_feedback));
      numrecordingloops++;
      status[index] = T_LS_Overdubbing;
    } else {
      // Play
      app->getRP()->AddChild(plist[index] = 
                             new PlayProcessor(app,lp,vol,ofs));
      status[index] = T_LS_Playing;
    }
  }
}

// *** Not RT Safe
void LoopManager::Deactivate (int index) {
  if (plist[index] == 0) {
    // We have a problem, there is supposed to be a processor here!
    printf("Nothing happening on index %d to deactivate\n",index);
    return;
  }
  
  // If we recorded something new to this index, store it in the map
  if (status[index] == T_LS_Recording && 
      app->getTMAP()->GetMap(index) == 0) {
    // *** Perhaps make a function in RecordProcessor called
    // ** 'createloop'.. which does the encapsulation from the blocks
    Pulse *curpulse = 0;
    if (curpulseindex != -1)
      curpulse = pulses[curpulseindex];

    // Adjust newloop volume so that it will match the volume
    // it was heard as-- since output volume does not scale
    // the initial monitor but does scale loops, we need to adjust
    float adjustednewloopvol = newloopvol / GetOutputVolume(); 

    //printf("newlp from plist: %p\n",plist[index]);
    Loop *newlp = new
      Loop(((RecordProcessor *) plist[index])->GetFirstRecordedBlock(),
           curpulse,1.0,adjustednewloopvol,
           ((RecordProcessor *) plist[index])->GetNBeats(),
           app->getCFG()->GetLoopOutFormat());
    app->getTMAP()->SetMap(index, newlp);
    UpdateLoopLists_ItemAdded(index);
    numloops++;
    lastindex = index;

    // Record processor will broadcast when it is ready to end!
    ((RecordProcessor *) plist[index])->End();
  } else if (status[index] == T_LS_Overdubbing) {
    // Overdubbing record processor will end immediately and broadcast 
    // EndRecord event
    ((RecordProcessor *) plist[index])->End();
  } else if (status[index] == T_LS_Playing) {
    // Stop playing/overdubbing
    app->getRP()->DelChild(plist[index]);
    plist[index] = 0;
    status[index] = T_LS_Off;    
  }
}

void LoopManager::SaveLoop(int index) {
  Loop *l = app->getTMAP()->GetMap(index);
  if (l != 0)
    l->Save(app);
};

// Saves a new scene
void LoopManager::SaveNewScene() {
  TriggerMap *tm = app->getTMAP();
  if (tm != 0)
    tm->Save(app);
};

// Saves over current scene
void LoopManager::SaveCurScene() {
  if (app->getCURSCENE() == 0)
    SaveNewScene();
  else {
    TriggerMap *tm = app->getTMAP();
    if (tm != 0)
      tm->Save(app,app->getCURSCENE()->filename);
  }
};

// Load loop from disk into the given index
void LoopManager::LoadLoop(char *filename, int index, float vol) {
  AddLoopToLoadQueue(filename,index,vol);
};

// Load scene from disk
void LoopManager::LoadScene(SceneBrowserItem *i) {
  char *filename = i->filename;

  // Load XML data for scene
  char tmp[FWEELIN_OUTNAME_LEN],
    tmp2[FWEELIN_OUTNAME_LEN];
  snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s%s",
           filename,FWEELIN_OUTPUT_DATA_EXT);
  
  xmlDocPtr dat = xmlParseFile(tmp);
  if (dat == 0)
    printf("DISK: ERROR: Scene data '%s' invalid or missing!\n",tmp);
  else {
    xmlNode *root = xmlDocGetRootElement(dat);
    if (!root || !root->name ||
        xmlStrcmp(root->name,(const xmlChar *) FWEELIN_OUTPUT_SCENE_NAME))
      printf("DISK: ERROR: Scene data '%s' bad format!\n",tmp);
    else {
      for (xmlNode *cur_node = root->children; cur_node != NULL; 
           cur_node = cur_node->next) {
        if ((!xmlStrcmp(cur_node->name, 
                        (const xmlChar *) FWEELIN_OUTPUT_LOOP_NAME))) {
          // Loop within scene-- read
          int l_idx = loadloopid;
          float vol = 1.0;

          // Loopid
          xmlChar *n = xmlGetProp(cur_node, (const xmlChar *) "loopid");
          if (n != 0) {
            l_idx = atoi((char *) n);
            xmlFree(n);
          }

          // Volume
          if ((n = xmlGetProp(cur_node, (const xmlChar *) "volume")) != 0) {
            vol = atof((char *) n);
            xmlFree(n);
          }

          // Hash
          if ((n = xmlGetProp(cur_node, (const xmlChar *) "hash")) != 0) {
            // Compose loop filename from hash
            snprintf(tmp2,FWEELIN_OUTNAME_LEN,"%s/%s-%s",
                     app->getCFG()->GetLibraryPath(),
                     FWEELIN_OUTPUT_LOOP_NAME,n);
            xmlFree(n);

            // Load the loop into the specified index
            printf(" (loopid %d vol %.5f filename %s)\n",
                   l_idx,vol,tmp2);
            LoadLoop(tmp2,l_idx,vol);
            // sleep(2);
          } else 
            printf("DISK: Scene definition for loop (id %d) has missing "
                   "hash!\n",l_idx);
        } else if ((!xmlStrcmp(cur_node->name, 
                               (const xmlChar *) FWEELIN_OUTPUT_SNAPSHOT_NAME))) {
          // Snapshot within scene-- read
          int snapid = 0;
          char sgo = 1;

          // Snapshot index
          xmlChar *n = xmlGetProp(cur_node, (const xmlChar *) "snapid");
          if (n != 0) {
            snapid = atoi((char *) n);
            xmlFree(n);
          }

          // Check if snapshot exists- if so, find another slot
          if (app->getSNAP(snapid) == 0 || app->getSNAP(snapid)->exists) {
            Snapshot *snaps = app->getSNAPS();
            char go = 1;
            int i = 0; 
            while (go && i < app->getCFG()->GetMaxSnapshots()) {
              if (!snaps[i].exists) 
                go = 0;
              else
                i++;
            }
            
            if (go) {
              printf("DISK: No space to load snapshot in scene-\n"
                     "please raise maximum # of snapshots in configuration!\n");
              sgo = 0;
            } else
              snapid = i;
          }

          if (sgo) {
            // Name
            n = xmlGetProp(cur_node, (const xmlChar *) "name");

            printf(" (snapshot: %s)\n",n);
            Snapshot *s = app->LoadSnapshot(snapid,(char *) n);
            if (n != 0)
              xmlFree(n);

            // Now, count loop snapshots given in snapshot
            if (s != 0) {
              int numls = 0;
              for (xmlNode *ls_node = cur_node->children; ls_node != NULL; 
                   ls_node = ls_node->next) {
                if ((!xmlStrcmp(ls_node->name, 
                                (const xmlChar *) FWEELIN_OUTPUT_LOOPSNAPSHOT_NAME))) {
                  numls++;
                }
              }
              
              printf("  (%d loops in snapshot)\n",numls);

              // Setup & load loop snapshots
              s->numls = numls;
              if (numls > 0)
                s->ls = new LoopSnapshot[numls];
              else
                s->ls = 0;

              int i = 0;
              for (xmlNode *ls_node = cur_node->children; ls_node != NULL; 
                   ls_node = ls_node->next) {
                if ((!xmlStrcmp(ls_node->name, 
                                (const xmlChar *) FWEELIN_OUTPUT_LOOPSNAPSHOT_NAME))) {
                  LoopSnapshot *ls = &(s->ls[i]);

                  // Loop index
                  xmlChar *nn = xmlGetProp(ls_node, (const xmlChar *) "loopid");
                  if (nn != 0) {
                    ls->l_idx = atoi((char *) nn);
                    xmlFree(nn);
                  }

                  // Loop status
                  nn = xmlGetProp(ls_node, (const xmlChar *) "status");
                  if (nn != 0) {
                    ls->status = (LoopStatus) atoi((char *) nn);
                    xmlFree(nn);
                  }

                  // Loop volume
                  nn = xmlGetProp(ls_node, (const xmlChar *) "loopvol");
                  if (nn != 0) {
                    ls->l_vol = atof((char *) nn);
                    xmlFree(nn);
                  }

                  // Trigger volume
                  nn = xmlGetProp(ls_node, (const xmlChar *) "triggervol");
                  if (nn != 0) {
                    ls->t_vol = atof((char *) nn);
                    xmlFree(nn);
                  }

                  i++;
                }
              }
            }
          }
        }
      }

      // Now, remember this scene is loaded
      app->setCURSCENE(i);
    }
  }

  xmlFreeDoc(dat);
  // Don't call cleanup because another thread may have xml open
  // xmlCleanupParser();
};

void LoopManager::ReceiveEvent(Event *ev, EventProducer *from) {
  switch (ev->GetType()) {
  case T_EV_EndRecord :
    // Recording has ended on one of the RecordProcessors- find it!
    for (int i = 0; i < app->getTMAP()->GetMapSize(); i++) 
      if (plist[i] == from) {
        // Should we keep this recording
        if (!((EndRecordEvent *) ev)->keeprecord) {
          DeleteLoop(i); // No
        }
        else {
          nframes_t playofs = 0;
          if (status[i] == T_LS_Recording) {
            // Adjust number of beats in loop based on the recording
            app->getTMAP()->GetMap(i)->nbeats = 
              ((RecordProcessor *) plist[i])->GetNBeats();

            Pulse *recsync = ((RecordProcessor *) plist[i])->GetPulse();
            // Sync recording may have ended late, so start play where we
            // left off
            if (recsync != 0)
              playofs = recsync->GetPos();
          } else if (status[i] == T_LS_Overdubbing) {
            // Start play at position where overdub left off
            playofs = ((RecordProcessor *) plist[i])->GetRecordedLength();
          }

          // Remove recordprocessor from chain
          app->getRP()->DelChild(plist[i]);
          numrecordingloops--;
          status[i] = T_LS_Off;
          plist[i] = 0;

          // Check if we need to activate a playprocessor
          if (waitactivate[i]) {
            waitactivate[i] = 0;
            // Activate is not RT safe (new processor alloc)
            // So this event thread had better be nonRT!
            Activate(i,waitactivate_shot[i],waitactivate_vol[i],
                     playofs,
                     waitactivate_od[i],waitactivate_od_fb[i]);
          }
        }
      }
    break;

  case T_EV_ToggleDiskOutput :
    {
      // OK!
      if (CRITTERS)
        printf("CORE: Received ToggleDiskOutputEvent\n");
      app->ToggleDiskOutput();
    }
    break;

  case T_EV_ToggleSelectLoop :
    {
      ToggleSelectLoopEvent *sev = (ToggleSelectLoopEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received ToggleSelectLoopEvent: Set %d Loop ID %d\n",
               sev->setid,sev->loopid);
      
      LoopList **ll = app->getLOOPSEL(sev->setid);
      if (ll != 0) {
        // Get loop with id
        Loop *l = app->getTMAP()->GetMap(sev->loopid);
        if (l != 0) {
          LoopList *prev;
          LoopList *exists = LoopList::Scan(*ll,sev->loopid,&prev);
          if (exists != 0) {
            // printf("REMOVE!\n");
            *ll = LoopList::Remove(*ll,exists,prev);
            l->ChangeSelectedCount(-1);
          } else {
            // printf("ADD!\n");
            *ll = LoopList::AddBegin(*ll,sev->loopid);
            l->ChangeSelectedCount(1);
          }
        }
      } else 
        printf("CORE: Invalid set id #%d when selecting loop\n",sev->setid);
    }
    break;

  case T_EV_SelectOnlyPlayingLoops :
    {
      SelectOnlyPlayingLoopsEvent *sev = (SelectOnlyPlayingLoopsEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SelectOnlyPlayingLoopsEvent: Set %d [%s]\n",
               sev->setid,(sev->playing ? "PLAYING" : "IDLE"));
      
      LoopList **ll = app->getLOOPSEL(sev->setid);
      if (ll != 0) {
        // Scan all loops for playing loops
        for (int i = 0; i < app->getCFG()->GetNumTriggers(); i++) {
          Loop *l = app->getTMAP()->GetMap(i);
          if (GetStatus(i) == T_LS_Overdubbing ||
              GetStatus(i) == T_LS_Playing) {
            if (l != 0) {
              // Loop exists, and it's playing!
              LoopList *prev;
              LoopList *exists = LoopList::Scan(*ll,i,&prev);
              if (!sev->playing && exists != 0) {
                // printf("REMOVE!\n");
                *ll = LoopList::Remove(*ll,exists,prev);
                l->ChangeSelectedCount(-1);
              } else if (sev->playing && exists == 0) {
                // printf("ADD!\n");
                *ll = LoopList::AddBegin(*ll,i);
                l->ChangeSelectedCount(1);
              }
            }
          } else if (app->getTMAP()->GetMap(i) != 0) {
            // Loop exists, but not playing/overdubbing
            LoopList *prev;
            LoopList *exists = LoopList::Scan(*ll,i,&prev);
            if (sev->playing && exists != 0) {
              // printf("REMOVE!\n");
              *ll = LoopList::Remove(*ll,exists,prev);
              l->ChangeSelectedCount(-1);
            } else if (!sev->playing && exists == 0) {
              // printf("ADD!\n");
              *ll = LoopList::AddBegin(*ll,i);
              l->ChangeSelectedCount(1);
            }
          }
        }
      } else 
        printf("CORE: Invalid set id #%d when selecting loop\n",sev->setid);
    }
    break;

  case T_EV_SelectAllLoops :
    {
      SelectAllLoopsEvent *sev = (SelectAllLoopsEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SelectAllLoopsEvent: Set %d [%s]\n",
               sev->setid,(sev->select ? "SELECT" : "UNSELECT"));
      
      LoopList **ll = app->getLOOPSEL(sev->setid);
      if (ll != 0) {
        // Scan all loops
        for (int i = 0; i < app->getCFG()->GetNumTriggers(); i++) {
          Loop *l = app->getTMAP()->GetMap(i);
          if (l != 0) {
            // Loop exists in map
            LoopList *prev;
            LoopList *exists = LoopList::Scan(*ll,i,&prev);
            if (!sev->select && exists != 0) {
              // Unselect loops- remove loop from list
              // printf("REMOVE!\n");
              *ll = LoopList::Remove(*ll,exists,prev);
              l->ChangeSelectedCount(-1);
            } else if (sev->select && exists == 0) {
              // Select loops- add loop to list
              // printf("ADD!\n");
              *ll = LoopList::AddBegin(*ll,i);
              l->ChangeSelectedCount(1);
            }
          }
        }
      } else 
        printf("CORE: Invalid set id #%d when selecting loop\n",sev->setid);
    }
    break;

  case T_EV_InvertSelection :
    {
      InvertSelectionEvent *sev = (InvertSelectionEvent *) ev;
      
      // OK!
      if (CRITTERS)
        printf("CORE: Received InvertSelectionEvent: Set %d\n",sev->setid);

      LoopList **ll = app->getLOOPSEL(sev->setid);
      if (ll != 0) {
        // Scan all loops
        for (int i = 0; i < app->getCFG()->GetNumTriggers(); i++) {
          Loop *l = app->getTMAP()->GetMap(i);
          if (l != 0) {
            // Loop exists in map
            LoopList *prev;
            LoopList *exists = LoopList::Scan(*ll,i,&prev);
            if (exists != 0) {
              // Loop exists in list- remove
              // printf("REMOVE!\n");
              *ll = LoopList::Remove(*ll,exists,prev);
              l->ChangeSelectedCount(-1);
            } else if (exists == 0) {
              // Loop not in list- add
              // printf("ADD!\n");
              *ll = LoopList::AddBegin(*ll,i);
              l->ChangeSelectedCount(1);
            }
          }
        }
      } else 
        printf("CORE: Invalid set id #%d when selecting loop\n",sev->setid);
    }
    break;

  case T_EV_TriggerSnapshot :
    {
      TriggerSnapshotEvent *sev = (TriggerSnapshotEvent *) ev;
      
      // OK!
      if (CRITTERS)
        printf("CORE: Received TriggerSnapshotEvent: Snapshot #%d\n",
               sev->snapid);

      if (app->TriggerSnapshot(sev->snapid))
        printf("CORE: Invalid snapshot #%d- can't trigger\n",sev->snapid);
    }
    break;

  case T_EV_CreateSnapshot :
    {
      CreateSnapshotEvent *sev = (CreateSnapshotEvent *) ev;
      
      // OK!
      if (CRITTERS)
        printf("CORE: Received CreateSnapshotEvent: Snapshot #%d\n",
               sev->snapid);

      if (app->CreateSnapshot(sev->snapid) == 0)
        printf("CORE: Invalid snapshot #%d- can't create\n",sev->snapid);
    }
    break;

  case T_EV_RenameSnapshot :
    {
      RenameSnapshotEvent *sev = (RenameSnapshotEvent *) ev;
      
      // OK!
      if (CRITTERS)
        printf("CORE: Received RenameSnapshotEvent: Snapshot #%d\n",
               sev->snapid);

      FloDisplaySnapshots *sdisp = (FloDisplaySnapshots *) app->getCFG()->GetDisplayByType(FD_Snapshots);
      if (sdisp != 0)
        sdisp->Rename(sev->snapid);
    }
    break;

  case T_EV_SetSelectedLoopsTriggerVolume :
    {
      SetSelectedLoopsTriggerVolumeEvent *sev = (SetSelectedLoopsTriggerVolumeEvent *) ev;
      
      // OK!
      if (CRITTERS)
        printf("CORE: Received SetSelectedLoopsTriggerVolumeEvent: Set %d: Volume %f\n",
               sev->setid,sev->vol);
      
      LoopList **ll = app->getLOOPSEL(sev->setid);
      if (ll != 0) {
        LoopList *cur = *ll;
        while (cur != 0) {
          SetTriggerVol(cur->l_idx,sev->vol);
          cur = cur->next;
        }
        
      } else 
        printf("CORE: Invalid set id #%d when selecting loop\n",sev->setid);
    }
    break;

  case T_EV_AdjustSelectedLoopsAmp :
    {
      AdjustSelectedLoopsAmpEvent *sev = (AdjustSelectedLoopsAmpEvent *) ev;
      
      // OK!
      if (CRITTERS)
        printf("CORE: Received AdjustSelectedLoopsAmpEvent: Set %d: "
               "Amp factor %f\n",
               sev->setid,sev->ampfactor);
      
      LoopList **ll = app->getLOOPSEL(sev->setid);
      if (ll != 0) {
        LoopList *cur = *ll;
        while (cur != 0) {
          SetLoopVolume(cur->l_idx,
                        sev->ampfactor * GetLoopVolume(cur->l_idx));
          cur = cur->next;
        }
        
      } else 
        printf("CORE: Invalid set id #%d when selecting loop\n",sev->setid);
    }
    break;

  case T_EV_EraseSelectedLoops :
    {
      EraseSelectedLoopsEvent *sev = (EraseSelectedLoopsEvent *) ev;
      
      // OK!
      if (CRITTERS)
        printf("CORE: Received EraseSelectedLoopsEvent: Set: %d\n",sev->setid);
      
      LoopList **ll = app->getLOOPSEL(sev->setid);
      if (ll != 0) {
        LoopList *cur = *ll;
        while (cur != 0) {
          DeleteLoop(cur->l_idx);
          cur = cur->next;
        }       
      } else 
        printf("CORE: Invalid set id #%d when erasing selected loops\n",
               sev->setid);
    }
    break;
    
  case T_EV_SetAutoLoopSaving :
    {
      SetAutoLoopSavingEvent *sev = (SetAutoLoopSavingEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetAutoLoopSavingEvent (%s)\n",
               (sev->save ? "on" : "off"));
      SetAutoLoopSaving(sev->save);
    }
    break;

  case T_EV_SaveLoop :
    {
      SaveLoopEvent *sev = (SaveLoopEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SaveLoopEvent (%d)\n",sev->index);
      SaveLoop(sev->index);
    }
    break;

  case T_EV_SaveNewScene :
    {
      // OK!
      if (CRITTERS)
        printf("CORE: Received SaveNewSceneEvent\n");
      SaveNewScene();
    }
    break;

  case T_EV_SaveCurrentScene :
    {
      // OK!
      if (CRITTERS)
        printf("CORE: Received SaveCurrentSceneEvent\n");
      SaveCurScene();
    }
    break;
    
  case T_EV_SetLoadLoopId :
    {
      SetLoadLoopIdEvent *sev = (SetLoadLoopIdEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetLoadLoopIdEvent (%d)\n",sev->index);
      loadloopid = sev->index;
    }
    break;

  case T_EV_SetDefaultLoopPlacement :
    {
      SetDefaultLoopPlacementEvent *sev = (SetDefaultLoopPlacementEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetDefaultLoopPlacementEvent (%d>%d)\n",
               sev->looprange.lo,sev->looprange.hi);
      default_looprange = sev->looprange;
    }
    break;

  case T_EV_SlideMasterInVolume :
    {
      SlideMasterInVolumeEvent *vev = (SlideMasterInVolumeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SlideMasterInVolumeEvent(%f)\n", vev->slide);
      AdjustInputVolume(vev->slide);
    }
    break;

  case T_EV_SlideMasterOutVolume :
    {
      SlideMasterOutVolumeEvent *vev = (SlideMasterOutVolumeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SlideMasterOutVolumeEvent(%f)\n", vev->slide);
      AdjustOutputVolume(vev->slide);
    }
    break;

  case T_EV_SlideInVolume :
    {
      SlideInVolumeEvent *vev = (SlideInVolumeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SlideInVolumeEvent(%d: %f)\n", vev->input, vev->slide);
      app->getISET()->AdjustInputVol(vev->input-1, vev->slide);
    }
    break;

  case T_EV_SetMasterInVolume :
    {
      SetMasterInVolumeEvent *vev = (SetMasterInVolumeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetMasterInVolumeEvent(%f, %f)\n", vev->vol, vev->fadervol);
      SetInputVolume(vev->vol,vev->fadervol);
    }
    break;

  case T_EV_SetMasterOutVolume :
    {
      SetMasterOutVolumeEvent *vev = (SetMasterOutVolumeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetMasterOutVolumeEvent(%f, %f)\n", vev->vol, vev->fadervol);
      SetOutputVolume(vev->vol,vev->fadervol);
    }
    break;

  case T_EV_SetInVolume :
    {
      SetInVolumeEvent *vev = (SetInVolumeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetInVolumeEvent(%d: %f, %f)\n", vev->input, vev->vol, vev->fadervol);
      app->getISET()->SetInputVol(vev->input-1, vev->vol, vev->fadervol);
    }
    break;

  case T_EV_ToggleInputRecord :
    {
      ToggleInputRecordEvent *vev = (ToggleInputRecordEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received ToggleInputRecordEvent(%d)\n", vev->input);
      app->getISET()->SelectInput(vev->input-1,(app->getISET()->InputSelected(vev->input-1) == 0 ? 1 : 0));
    }
    break;

  case T_EV_DeletePulse :
    {
      DeletePulseEvent *dev = (DeletePulseEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received DeletePulse(%d)\n", dev->pulse);
      DeletePulse(dev->pulse);
    }
    break;

  case T_EV_SelectPulse :
    {
      SelectPulseEvent *sev = (SelectPulseEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SelectPulse(%d)\n", sev->pulse);
      SelectPulse(sev->pulse);
    }
    break;

  case T_EV_TapPulse :
    {
      TapPulseEvent *tev = (TapPulseEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received TapPulse(%d) %s\n", tev->pulse,
               (tev->newlen ? "[new length]" : ""));
      TapPulse(tev->pulse,tev->newlen);
    }
    break;

  case T_EV_SwitchMetronome :
    {
      SwitchMetronomeEvent *swev = (SwitchMetronomeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SwitchMetronome(%d) %s\n", swev->pulse,
               (swev->metronome ? "[on]" : "[off]"));
      SwitchMetronome(swev->pulse,swev->metronome);
    }
    break;

  case T_EV_SetSyncType :
    {
      SetSyncTypeEvent *sev = (SetSyncTypeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetSyncType(%d)\n", sev->stype);
      app->SetSyncType(sev->stype);
    }
    break;

  case T_EV_SetSyncSpeed :
    {
      SetSyncSpeedEvent *sev = (SetSyncSpeedEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetSyncSpeed(%d)\n", sev->sspd);
      app->SetSyncSpeed(sev->sspd);
    }
    break;

  case T_EV_SetMidiSync :
    {
      SetMidiSyncEvent *sev = (SetMidiSyncEvent *) ev;
      
      // OK!
      if (CRITTERS)
        printf("CORE: Received SetMidiSync(%d)\n", sev->midisync);
      app->getMIDI()->SetMIDISyncTransmit(sev->midisync);
    }
    break;
    
  case T_EV_SetTriggerVolume :
    {
      SetTriggerVolumeEvent *laev = (SetTriggerVolumeEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetTriggerVolume(%d,%f)\n", laev->index, 
               laev->vol);
      SetTriggerVol(laev->index,laev->vol);
    }
    break;

  case T_EV_SlideLoopAmp :
    {
      SlideLoopAmpEvent *laev = (SlideLoopAmpEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SlideLoopAmp(%d,%f)\n", laev->index, 
               laev->slide);
      AdjustLoopVolume(laev->index,laev->slide);
    }
    break;

  case T_EV_SetLoopAmp :
    {
      SetLoopAmpEvent *laev = (SetLoopAmpEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received SetLoopAmp(%d,%f)\n", laev->index, laev->amp);
      SetLoopVolume(laev->index,laev->amp);
    }
    break;

  case T_EV_AdjustLoopAmp :
    {
      AdjustLoopAmpEvent *laev = (AdjustLoopAmpEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received AdjustLoopAmp(%d,%f)\n", laev->index, 
               laev->ampfactor);
      SetLoopVolume(laev->index,
                    laev->ampfactor * GetLoopVolume(laev->index));
    }
    break;

  case T_EV_TriggerLoop :
    {
      TriggerLoopEvent *tev = (TriggerLoopEvent *) ev;
      int index = tev->index,
        engage = tev->engage;
      float vol = tev->vol;
      char od = tev->od,
        shot = tev->shot;
      UserVariable *od_fb = tev->od_fb;
      float *od_fb_ptr = 0;
      if (od_fb != 0) {
        if (od_fb->GetType() == T_float)
          od_fb_ptr = (float *) od_fb->GetValue();
        else 
          printf("CORE: ERROR: Overdub feedback assigned to variable '%s'- but that variable is not a 'float'!\n",od_fb->GetName());
      }
      
      // OK!
      if (CRITTERS) {
        printf("CORE: Received TriggerLoop(%d,%.2f)", index, vol);
        if (od) {
          printf(" [overdub]");
          if (od_fb != 0) {
            printf(" (feedback ");
            od_fb->Print();
            printf(")\n");
          } else
            printf("\n");
        }
        if (shot)
          printf(" (shot)");
        if (engage != -1)
          printf(" (%s)\n",(engage ? "force on" : "force off"));
        else
          printf("\n");
      }

      if ((engage == -1 || engage == 1) &&
          (GetStatus(index) == T_LS_Recording || 
           GetStatus(index) == T_LS_Overdubbing ||
           (GetStatus(index) == T_LS_Playing && od == 1))) {
        // Stop-start case
        nframes_t ofs = 0;
        if (GetStatus(index) == T_LS_Overdubbing && od == 1) {
          // Don't allow retrigger from overdub to overdub-- override to play
          od = 0;
        } else if (GetStatus(index) == T_LS_Playing) {
          // Play->overdub case- start overdub where play left off
          ofs = ((PlayProcessor *) plist[index])->GetPlayedLength();
        }

        Deactivate(index);                // Stop
        Activate(index,shot,vol,ofs,od,od_fb_ptr); // Start
      } else if ((engage == -1 || engage == 0) && IsActive(index)) {
        // Stop case (play and no overdub)
        Deactivate(index);
      }
      else if (engage == -1 || engage == 1) {
        // Start case (record)
        Activate(index,shot,vol,0,od,od_fb_ptr);
      }
    }
    break;

  case T_EV_TriggerSelectedLoops :
    {
      TriggerSelectedLoopsEvent *tev = (TriggerSelectedLoopsEvent *) ev;

      if (CRITTERS)
        printf("CORE: Received TriggerSelectedLoops(set #%d,%.2f)\n", 
               tev->setid,tev->vol);

      LoopList **ll = app->getLOOPSEL(tev->setid);
      if (ll != 0) {
        // Get all loops from this set
        LoopList *cur = *ll;
        while (cur != 0) {
          if (IsActive(cur->l_idx)) {
            // Overdub/play on this loop
            if (tev->toggleloops)
              Deactivate(cur->l_idx);
          } else {
            // Loop idle-- start play
            // No overdub/shot/etc, just straight play
            Activate(cur->l_idx,0,tev->vol,0,0,0);
          }

          cur = cur->next;
        }
      } else 
        printf("CORE: Invalid set id #%d when triggering selected loops\n",
               tev->setid);      
    }
    break;

  case T_EV_MoveLoop :
    {
      MoveLoopEvent *mev = (MoveLoopEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received MoveLoop(%d->%d)\n", mev->oldloopid, 
               mev->newloopid);
      MoveLoop(mev->oldloopid,mev->newloopid);
    }
    break;

  case T_EV_RenameLoop :
    {
      RenameLoopEvent *rev = (RenameLoopEvent *) ev;

      if (rev->in == 1) {
        RenameLoop(rev->loopid);
        if (CRITTERS)
          printf("LOOPMGR: Received RenameLoop(loopid: %d)\n",rev->loopid);
      }
    }
    break;

  case T_EV_EraseLoop :
    {
      EraseLoopEvent *eev = (EraseLoopEvent *) ev;

      // OK!
      if (CRITTERS)
        printf("CORE: Received EraseLoop(%d)\n", eev->index);
      DeleteLoop(eev->index);
    }
    break;

  case T_EV_EraseAllLoops :
    {
      // OK!
      if (CRITTERS)
        printf("CORE: Received EraseAllLoops\n");

      // Erase scene settings
      app->setCURSCENE(0);

      // Erase all loops!
      // printf("DEBUG: ERASE LOOPS!\n");
      for (int i = 0; i < app->getCFG()->GetNumTriggers(); i++) 
        DeleteLoop(i);
      // And all pulses!
      // printf("DEBUG: ERASE PULSES!\n");
      for (int i = 0; i < MAX_PULSES; i++)
        DeletePulse(i);
      // printf("DEBUG: DONE!\n\n");
      // And all snapshots!
      Snapshot *s = app->getSNAPS();
      for (int i = 0; i < app->getCFG()->GetMaxSnapshots(); i++)
        s[i].DeleteSnapshot();
    }
    break;

  case T_EV_SlideLoopAmpStopAll :
    {
      // OK!
      if (CRITTERS)
        printf("CORE: Received SlideLoopAmpStopAll\n");

      for (int i = 0; i < app->getCFG()->GetNumTriggers(); i++) 
        SetLoopdVolume(i,1.0);
    }
    break;

  default:
    break;
  }
}

int Fweelin::go()
{
  running = 1;

  // Broadcast start session event!
  Event *proto = Event::GetEventByType(T_EV_StartSession);
  if (proto == 0) {
    printf("GO: Can't get start event prototype!\n");
  } else {
    Event *cpy = (Event *) proto->RTNew();
    if (cpy == 0)
      printf("CORE: WARNING: Can't send event- RTNew() failed\n");
    else 
      emg->BroadcastEventNow(cpy, this);
  }

  // Broadcast events for starting all interfaces!
  cfg->StartInterfaces();

  // Encourage the user!
  printf("\n-- ** OKIE DOKIE, KIDDO! ** --\n");

  // *** SDL IO is now done in main thread- Mac OS X SDL requires it, and on Linux it's one less thread
  SDLIO::run_sdl_thread(sdlio);

  // Old method
#if 0
  // Now just wait.. the threads will take care of everything 
  while (sdlio->IsActive()) {
    usleep(100000);
  };
#endif
  
  // Cleanup
  if (vid != 0)
    vid->close();
  sdlio->close();
  midi->close();
  audio->close();
  if (vid != 0)
    delete vid;
  delete sdlio;
  delete midi;
  delete audio;
  delete iset;
  delete abufs;
  delete[] snaps;

#if USE_FLUIDSYNTH
  delete fluidp;
#endif

  delete[] browsers;

  printf("MAIN: end stage 1\n");

  //sleep(1);

  // Manually reset audio memory to its original state-
  // not preallocated!
  getAMPEAKS()->SetupPreallocated(0,Preallocated::PREALLOC_BASE_INSTANCE);
  getAMAVGS()->SetupPreallocated(0,Preallocated::PREALLOC_BASE_INSTANCE);
  audiomem->SetupPreallocated(0,Preallocated::PREALLOC_BASE_INSTANCE);

  // And main classes..
  delete tmap;
  printf(" 1\n");
  delete loopmgr;
  printf(" 2\n");
  delete rp; 
  printf(" 3\n");
  delete bmg;
  printf(" 4\n");

  printf("MAIN: end stage 2\n");

  //::delete audiomem;
  delete[] scope;

  printf("MAIN: end stage 3\n");

  // Delete preallocated type managers
  delete pre_audioblock;
  delete pre_extrachannel;
  delete pre_timemarker;

  printf("MAIN: end stage 4\n");
  //sleep(2);

  delete cfg;
  printf(" 1\n");
  //sleep(2);
  delete emg;
  //sleep(2);
  printf(" 2\n");
  delete mmg;

  SDL_Quit();
  
  SRMWRingBuffer_Writers::CloseAll();

  printf("MAIN: end\n");

  return 0;
}

BED_MarkerPoints *Fweelin::getAMPEAKSPULSE() { 
  AudioBlock *peaks = getAMPEAKS();
  if (peaks != 0)
    return dynamic_cast<BED_MarkerPoints *>
      (getAMPEAKS()->GetExtendedData(T_BED_MarkerPoints));
  else
    return 0;
};

AudioBlock *Fweelin::getAMPEAKS() { 
  return 
    dynamic_cast<PeaksAvgsManager *>(bmg->GetBlockManager(audiomem,
                                                          T_MC_PeaksAvgs))->
    GetPeaks();
};

AudioBlock *Fweelin::getAMAVGS() { 
  return 
    dynamic_cast<PeaksAvgsManager *>(bmg->GetBlockManager(audiomem,
                                                          T_MC_PeaksAvgs))->
    GetAvgs();
  };

AudioBlockIterator *Fweelin::getAMPEAKSI() { 
  return
    dynamic_cast<PeaksAvgsManager *>(bmg->GetBlockManager(audiomem,
                                                          T_MC_PeaksAvgs))->
    GetPeaksI();
};

AudioBlockIterator *Fweelin::getAMAVGSI() { 
  return
    dynamic_cast<PeaksAvgsManager *>(bmg->GetBlockManager(audiomem,
                                                          T_MC_PeaksAvgs))->
    GetAvgsI();
};

AudioBlockIterator *Fweelin::getAUDIOMEMI() {
  return amrec->GetIterator();
};

Browser *Fweelin::GetBrowserFromConfig(BrowserItemType b) {
  FloDisplay *cur = cfg->displays;
  while (cur != 0) {
    if (cur->GetFloDisplayType() == FD_Browser &&
        ((Browser *) cur)->GetType() == b)
      return (Browser *) cur;
    cur = cur->next;
  }
  return 0;
};

void Fweelin::ToggleDiskOutput()
{
  if (fs->GetStatus() == FileStreamer::STATUS_STOPPED) {
    // Create appropriate filename for output
    char tmp[FWEELIN_OUTNAME_LEN];
    char go = 1;
    do {
      snprintf(tmp,FWEELIN_OUTNAME_LEN,"%s/%s%d%s",
               cfg->GetLibraryPath(),FWEELIN_OUTPUT_STREAM_NAME,writenum,
               getCFG()->GetAudioFileExt(getCFG()->GetStreamOutFormat()));
      struct stat st;
      printf("DISK: Opening '%s' for streaming.\n",tmp);
      if (stat(tmp,&st) == 0) {
        printf("DISK: File exists, trying another.\n");
        writenum++;
      } else {
        // Also check for timing data file- don't overwrite that
        snprintf(timingname,FWEELIN_OUTNAME_LEN,"%s/%s%d%s",
                 cfg->GetLibraryPath(),FWEELIN_OUTPUT_STREAM_NAME,
                 writenum,FWEELIN_OUTPUT_TIMING_EXT);
        if (stat(timingname,&st) == 0) {
          printf("DISK: Timing file exists, trying another.\n");
          writenum++;
        } else
          go = 0;
      }
    } while (go);

    // Compose filename & start writing
    strcpy(streamoutname,tmp);
    snprintf(timingname,FWEELIN_OUTNAME_LEN,"%s/%s%d%s",
             cfg->GetLibraryPath(),FWEELIN_OUTPUT_STREAM_NAME,
             writenum,FWEELIN_OUTPUT_TIMING_EXT);
    fs->StartWriting(streamoutname,timingname,getCFG()->GetStreamOutFormat());
  } else {
    // Stop disk output
    fs->StopWriting();
    strcpy(streamoutname,"");
    strcpy(timingname,"");

    // Advance to next logical filename
    writenum++;
  }
};

int Fweelin::setup()
{
  char tmp[255];

  // Keep all memory inline
  mlockall(MCL_CURRENT | MCL_FUTURE);

  SRMWRingBuffer_Writers::InitAll();
  
  // Initialize vars
  for (int i = 0; i < NUM_LOOP_SELECTION_SETS; i++)
    loopsel[i] = 0;

#ifndef __MACOSX__
  if (!XInitThreads()) {
    printf("MAIN: ERROR: FreeWheeling requires threaded Xlib support\n");
    return 0;
  }
#else  
  FweelinMac::LinkFweelin(this);
#endif
  
  /* Initialize SDL- this happens here because it is common to video, keys &
     config */ 
  // SDL_INIT_NOPARACHUTE
  /* (SDL_INIT_JOYSTICK | SDL_INIT_EVENTTHREAD) < 0) { */
  if ( SDL_Init(SDL_INIT_VIDEO | SDL_INIT_JOYSTICK) < 0 ) {
    printf("MAIN: ERROR: Can't initialize SDL: %s\n",SDL_GetError());
    return 0;
  }
  atexit(SDL_Quit);

  // Memory manager
  mmg = new MemoryManager();

  // Load configuration from .rc file
  cfg = new FloConfig(this);

  // Create system variables so that config will have them first!
  UserVariable *tmpv;
  tmpv = cfg->AddEmptyVariable("BROWSE_loop");
  tmpv->type = T_int;
  *tmpv = (int) B_Loop;
  tmpv = cfg->AddEmptyVariable("BROWSE_scene");
  tmpv->type = T_int;
  *tmpv = (int) B_Scene;
  tmpv = cfg->AddEmptyVariable("BROWSE_loop_tray");
  tmpv->type = T_int;
  *tmpv = (int) B_Loop_Tray;
  tmpv = cfg->AddEmptyVariable("BROWSE_scene_tray");
  tmpv->type = T_int;
  *tmpv = (int) B_Scene_Tray;
  tmpv = cfg->AddEmptyVariable("BROWSE_patch");
  tmpv->type = T_int;
  *tmpv = (int) B_Patch;
  cfg->AddEmptyVariable("SYSTEM_num_midi_outs");
  cfg->AddEmptyVariable("SYSTEM_midi_transpose");
  cfg->AddEmptyVariable("SYSTEM_master_in_volume");
  cfg->AddEmptyVariable("SYSTEM_master_out_volume");
  cfg->AddEmptyVariable("SYSTEM_cur_pitchbend");
  cfg->AddEmptyVariable("SYSTEM_bender_tune");
  cfg->AddEmptyVariable("SYSTEM_cur_limiter_gain");
  cfg->AddEmptyVariable("SYSTEM_audio_cpu_load");
  cfg->AddEmptyVariable("SYSTEM_sync_active");
  cfg->AddEmptyVariable("SYSTEM_sync_transmit");
  cfg->AddEmptyVariable("SYSTEM_midisync_transmit");
#if USE_FLUIDSYNTH
  cfg->AddEmptyVariable("SYSTEM_fluidsynth_enabled");
#endif
  cfg->AddEmptyVariable("SYSTEM_num_help_pages");
  cfg->AddEmptyVariable("SYSTEM_num_loops_in_map");
  cfg->AddEmptyVariable("SYSTEM_num_recording_loops_in_map");
  cfg->AddEmptyVariable("SYSTEM_num_patchbanks");
  cfg->AddEmptyVariable("SYSTEM_cur_patchbank_tag");
  cfg->AddEmptyVariable("SYSTEM_num_switchable_interfaces");
  cfg->AddEmptyVariable("SYSTEM_snapshot_page_firstidx");
  for (int i = 0; i < LAST_REC_COUNT; i++) {
    sprintf(tmp,"SYSTEM_loopid_lastrecord_%d",i);
    cfg->AddEmptyVariable(tmp);
  }

  // Now parse and setup config
  cfg->Parse();

  // Event manager
  emg = new EventManager();

  vid = new VideoIO(this);
  if (vid->activate()) {
    printf("MAIN: ERROR: Can't start video handler!\n");
    return 1;
  }
  while (!vid->IsActive())
    usleep(100000);

  abufs = new AudioBuffers(this);
  iset = new InputSettings(this,abufs->numins);
  audio = new AudioIO(this);
  if (audio->open()) {
    printf("MAIN: ERROR: Can't start system level audio!\n");
    return 1;
  }  
  fragmentsize = audio->getbufsz();
  printf("MAIN: Core block size: %d\n",fragmentsize);

  // Linkup to browsers
  browsers = new Browser *[(int) B_Last];
  memset(browsers,0,sizeof(Browser *) * (int) B_Last);

  // Setup patch browser, if defined in config
  {
    Browser *br = GetBrowserFromConfig(B_Patch);
    if (br != 0) {
      browsers[B_Patch] = br;
      br->Setup(this,this); // We handle callbacks ourselves for patch browser
    }
  }

  // FluidSynth
#if USE_FLUIDSYNTH
  // Create synth
  printf("MAIN: Creating integrated FluidSynth.\n");
  fluidp = new FluidSynthProcessor(this,cfg->GetFluidStereo());
  
  // Setup patch names
  fluidp->SetupPatches();
#endif

  // Setup sample buffer for visual scope
  scope = new sample_t[fragmentsize];
  scope_len = fragmentsize;

  // Block manager
  bmg = new BlockManager(this);

  // Preallocated type managers
  pre_audioblock = new PreallocatedType(mmg, ::new AudioBlock(),
                                        sizeof(AudioBlock),
                                        FloConfig::
                                        NUM_PREALLOCATED_AUDIO_BLOCKS);

  if (cfg->IsStereoMaster()) 
    // Only preallocate for stereo blocks if we are running in stereo
    pre_extrachannel = new PreallocatedType(mmg, ::new BED_ExtraChannel(),
                                            sizeof(BED_ExtraChannel),
                                            FloConfig::
                                            NUM_PREALLOCATED_AUDIO_BLOCKS);
  else 
    pre_extrachannel = 0;
  pre_timemarker = new PreallocatedType(mmg,::new TimeMarker(),
                                        sizeof(TimeMarker),
                                        FloConfig::
                                        NUM_PREALLOCATED_TIME_MARKERS);

  rp = new RootProcessor(this,iset);
  // Add monitor mix
  float *inputvol = &(rp->inputvol); // Where to get input vol from
  rp->AddChild(new PassthroughProcessor(this,iset,inputvol),
               ProcessorItem::TYPE_GLOBAL);
  // Add disk writer
  rp->AddChild(fs = new FileStreamer(this),
               ProcessorItem::TYPE_FINAL);
  writenum = 1;
  strcpy(streamoutname,"");
  curscene = 0;
#if 0
  strcpy(scenedispname,"");
  strcpy(scenefilename,"");
#endif
  strcpy(timingname,"");

  // Fixed audio memory
  nframes_t memlen = (nframes_t) (audio->get_srate() * 
                                  cfg->AUDIO_MEMORY_LEN),
    scopelen = cfg->GetScopeSampleLen(),
    chunksize = memlen/scopelen;
  // Note here we bypass using Preallocated RTNew because we want
  // a single block of our own size, not many preallocated blocks
  // chained together..
  audiomem = ::new AudioBlock(memlen);
  if (audiomem == 0) {
    printf("CORE: ERROR: Can't create audio memory!\n");
    exit(1);
  }
  audiomem->Zero();
  // If we are running in stereo, create a custom right channel to match
  // our left channel audio memory
  if (cfg->IsStereoMaster()) {
    BED_ExtraChannel *audiomem_r = ::new BED_ExtraChannel(memlen);
    if (audiomem_r == 0) {
      printf("CORE: ERROR: Can't create audio memory (right channel)!\n");
      exit(1);
    }
    
    audiomem->AddExtendedData(audiomem_r);
  }

  // So we have to set a pointer manually to the manager..
  // Because some functions depend on using audiomem as a basis
  // to access RTNew
  audiomem->SetupPreallocated(pre_audioblock,
                              Preallocated::PREALLOC_BASE_INSTANCE);

  // Begin recording into audio memory (use mono/stereo memory as appropriate)
  amrec = new RecordProcessor(this,iset,inputvol,audiomem,
                              cfg->IsStereoMaster());
  if (amrec == 0) {
    printf("CORE: ERROR: Can't create core RecordProcessor!\n");
    exit(1);
  }
  rp->AddChild(amrec,ProcessorItem::TYPE_HIPRIORITY);
  // Compute running peaks and averages from audio mem (for scope)
  AudioBlock *peaks = ::new AudioBlock(scopelen),
    *avgs = ::new AudioBlock(scopelen);
  if (peaks == 0 || avgs == 0) {
    printf("CORE: ERROR: Can't create peaks/averages memory!\n");
    exit(1);
  }
  peaks->Zero();
  avgs->Zero();
  // **BUG-- small leak-- the above two are never deleted
  peaks->SetupPreallocated(pre_audioblock,
                           Preallocated::PREALLOC_BASE_INSTANCE);
  avgs->SetupPreallocated(pre_audioblock,
                          Preallocated::PREALLOC_BASE_INSTANCE);
  audiomem->AddExtendedData(new BED_PeaksAvgs(peaks,avgs,chunksize));
  bmg->PeakAvgOn(audiomem,amrec->GetIterator());

  int nt = cfg->GetNumTriggers();
  tmap = new TriggerMap(this,nt);
  loopmgr = new LoopManager(this);

  // Setup loop & scene browsers & trays, if defined in config
  {
    Browser *br = GetBrowserFromConfig(B_Loop);
    if (br != 0) {
      browsers[B_Loop] = br;
      br->Setup(this,loopmgr);
    }
    loopmgr->SetupLoopBrowser();

    br = GetBrowserFromConfig(B_Scene);
    if (br != 0) {
      browsers[B_Scene] = br;
      br->Setup(this,loopmgr);
    }
    loopmgr->SetupSceneBrowser();

    br = GetBrowserFromConfig(B_Loop_Tray);
    if (br != 0) {
      browsers[B_Loop_Tray] = br;
      br->Setup(this,loopmgr);
    }
  }

  // Create snapshots
  snaps = new Snapshot[cfg->GetMaxSnapshots()];

  // Input methods 
  sdlio = new SDLIO(this);
  midi = new MidiIO(this);

  if (sdlio->activate()) {
    printf("(start) cant start keyboard handler\n");
    return 1;
  }
  if (midi->activate()) {
    printf("(start) cant start midi\n");
    return 1;
  }
  
  // Linkup system variables
  cfg->LinkSystemVariable("SYSTEM_num_midi_outs",T_int,
                          (char *) &(cfg->midiouts));
  cfg->LinkSystemVariable("SYSTEM_midi_transpose",T_int,
                          (char *) &(cfg->transpose));
  cfg->LinkSystemVariable("SYSTEM_master_in_volume",T_float,
                          (char *) &(rp->inputvol));
  cfg->LinkSystemVariable("SYSTEM_master_out_volume",T_float,
                          (char *) &(rp->outputvol));
  cfg->LinkSystemVariable("SYSTEM_cur_pitchbend",T_int,
                          (char *) &(midi->curbender));
  cfg->LinkSystemVariable("SYSTEM_bender_tune",T_int,
                          (char *) &(midi->bendertune));
  cfg->LinkSystemVariable("SYSTEM_cur_limiter_gain",T_float,
                          (char *) &(rp->curlimitvol));
  cfg->LinkSystemVariable("SYSTEM_audio_cpu_load",T_float,
                          (char *) &(audio->cpuload));
  cfg->LinkSystemVariable("SYSTEM_sync_active",T_char,
                          (char *) &(audio->sync_active));
  cfg->LinkSystemVariable("SYSTEM_sync_transmit",T_char,
                          (char *) &(audio->timebase_master));
  cfg->LinkSystemVariable("SYSTEM_midisync_transmit",T_char,
                          (char *) &(midi->midisyncxmit));
#if USE_FLUIDSYNTH
  cfg->LinkSystemVariable("SYSTEM_fluidsynth_enabled",T_char,
                          (char *) &(fluidp->enable));
#endif
  cfg->LinkSystemVariable("SYSTEM_num_help_pages",T_int,
                          (char *) &(vid->numhelppages));
  cfg->LinkSystemVariable("SYSTEM_num_loops_in_map",T_int,
                          (char *) &(loopmgr->numloops));
  cfg->LinkSystemVariable("SYSTEM_num_recording_loops_in_map",T_int,
                          (char *) &(loopmgr->numrecordingloops));
  cfg->LinkSystemVariable("SYSTEM_num_recording_loops_in_map",T_int,
                          (char *) &(loopmgr->numrecordingloops));
  if (browsers[B_Patch] != 0) {
    cfg->LinkSystemVariable("SYSTEM_num_patchbanks",T_int,
                          (char *) &(((PatchBrowser *) browsers[B_Patch])->
                                     num_pb));
    cfg->LinkSystemVariable("SYSTEM_cur_patchbank_tag",T_int,
                          (char *) &(((PatchBrowser *) browsers[B_Patch])->
                                     pb_cur_tag));
  }
  cfg->LinkSystemVariable("SYSTEM_num_switchable_interfaces",T_int,
                          (char *) &(cfg->numinterfaces));
  for (int i = 0; i < LAST_REC_COUNT; i++) {
    sprintf(tmp,"SYSTEM_loopid_lastrecord_%d",i);
    cfg->LinkSystemVariable(tmp,T_int,
                            (char *) &(loopmgr->lastrecidx[i]));
  }
  for (int i = 0; i < iset->numins; i++) {
    snprintf(tmp,255,"SYSTEM_in_%d_volume",i+1);
    cfg->LinkSystemVariable(tmp,T_float,
                            (char *) &(iset->invols[i]));
    snprintf(tmp,255,"SYSTEM_in_%d_peak",i+1);
    cfg->LinkSystemVariable(tmp,T_float,
                            (char *) &(iset->inpeak[i]));
    snprintf(tmp,255,"SYSTEM_in_%d_record",i+1);
    cfg->LinkSystemVariable(tmp,T_char,
                            (char *) &(iset->selins[i]));
  }
  {
    FloDisplaySnapshots *sn = 
      (FloDisplaySnapshots *) cfg->GetDisplayByType(FD_Snapshots);
    if (sn != 0)
      cfg->LinkSystemVariable("SYSTEM_snapshot_page_firstidx",T_int,
                              (char *) &(sn->firstidx));
  }

  // Finally, final Config start
  cfg->Start();

  // Now start signal processing
  if (audio->activate(rp)) {
    printf("MAIN: Error with signal processing start!\n");
    return 1;
  }

  return 0;
}

void Fweelin::ItemSelected(BrowserItem *i) { 
  if (i->GetType() != B_Patch) 
    printf("CORE: ERROR- Patch Browser contains items of invalid type!\n");
  else {
    PatchBrowser *br = (PatchBrowser *) getBROWSER(B_Patch);

    if (br != 0) {
      PatchBank *pb = br->GetCurPatchBank();
      if (pb->port == 0) {
        // We are selecting in a Fluidsynth bank-- send patch change
#if USE_FLUIDSYNTH
        getFLUIDP()->SendPatchChange((PatchItem *) i);
#else
        printf("CORE: ERROR: Can't change FluidSynth patches- no FluidSynth "
               "support!\n");
#endif
      } else {
        // Check if change messages to be sent?
        if (!pb->suppresschg) {
          // Tell MIDI to send out bank/program change(s) for new patch
          getMIDI()->SendBankProgramChange((PatchItem *) i);
        }
      }
    }
  }
};