etc/furnace
0
0
Fork 0
mirror of https://github.com/tildearrow/furnace.git synced 2024-11-16 01:35:07 +00:00
Code Issues Projects Releases Packages Wiki Activity

add stuff for diagnosis of hang problem

Browse source
This commit is contained in:
tildearrow 2022-01-12 17:02:48 -05:00
parent e7dc301d30
commit fa5b99b46a
1 changed files with 27 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
src/engine/playback.cpp
View file

@ -510,6 +510,7 @@ void DivEngine::processRow(int i, bool afterDelay) {
divider=((effect&0x3)<<8)|effectVal; divider=((effect&0x3)<<8)|effectVal;
if (divider<10) divider=10; if (divider<10) divider=10;
for (int i=0; i<song.systemLen; i++) { for (int i=0; i<song.systemLen; i++) {
disCont[i].cycles=disCont[i].dispatch->rate/divider;
disCont[i].clockDrift=0; disCont[i].clockDrift=0;
} }
break; break;
@ -898,27 +899,37 @@ void DivEngine::nextBuf(float** in, float** out, int inChans, int outChans, unsi
memset(metroTick,0,size); memset(metroTick,0,size);
int attempts=0; int attempts=0;
while (++attempts<1000) { logI("--------\n");
while (++attempts<100) {
logI("ATTEMPT %d\n",attempts);
bool allDone=true; bool allDone=true;
bool getOut=true; bool getOut=true;
// 1. check whether we are done with all buffers // 1. check whether we are done with all buffers
for (int i=0; i<song.systemLen; i++) { for (int i=0; i<song.systemLen; i++) {
logD("runLeft[%d]=%d\n",i,runLeft[i]);
if (runLeft[i]>0) { if (runLeft[i]>0) {
getOut=false; getOut=false;
logD("no getOut because runLeft[%d]=%d\n",i,runLeft[i]);
break; break;
} }
} }
if (getOut) break; if (getOut) {
logD("GETTING OUT\n");
break;
}
// 2. check whether we gonna tick // 2. check whether we gonna tick
for (int i=0; i<song.systemLen; i++) { for (int i=0; i<song.systemLen; i++) {
logD("disCont[%d].cycles=%d\n",i,disCont[i].cycles);
if (disCont[i].cycles>0) { if (disCont[i].cycles>0) {
allDone=false; allDone=false;
logD("not allDone because disCont[%d].cycles=%d\n",i,disCont[i].cycles);
break; break;
} }
} }
if (allDone) { if (allDone) {
// we have to tick // we have to tick
logD("ticking\n");
unsigned int realPos=(runPos[0]*size)/runtotal[0]; unsigned int realPos=(runPos[0]*size)/runtotal[0];
if (realPos>=size) realPos=size-1; if (realPos>=size) realPos=size-1;
if (song.hilightA>0) { if (song.hilightA>0) {
@ -937,18 +948,28 @@ void DivEngine::nextBuf(float** in, float** out, int inChans, int outChans, unsi
// 3. fill buffers as needed // 3. fill buffers as needed
for (int i=0; i<song.systemLen; i++) { for (int i=0; i<song.systemLen; i++) {
if (runLeft[i]<=0) continue; logD("filling buf %d...\n",i);
if (runLeft[i]<=0) {
logD("runLeft[%d]<=0\n",i,runLeft[i]);
continue;
}
int total=runLeft[i]; int total=runLeft[i];
if (total>disCont[i].cycles) total=disCont[i].cycles; if (total>disCont[i].cycles) {
logD("total set to cycles: %d\n",disCont[i].cycles);
total=disCont[i].cycles;
} else {
logD("total is %d\n",total);
}
runLeft[i]-=total; runLeft[i]-=total;
disCont[i].cycles-=total; disCont[i].cycles-=total;
disCont[i].acquire(runPos[i],total); disCont[i].acquire(runPos[i],total);
runPos[i]+=total; runPos[i]+=total;
logD("runPos is %d\n",runPos[i]);
} }
} }
logD("attempts: %d\n",attempts); logD("attempts: %d\n",attempts);
if (attempts>=1000) { if (attempts>=100) {
logE("hang detected! stopping!\n"); logE("hang detected! stopping! at %d seconds %d micro\n",totalSeconds,totalTicks);
freelance=false; freelance=false;
playing=false; playing=false;
extValuePresent=false; extValuePresent=false;