aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/aac_decode.c5
-rw-r--r--src/audiofile_decode.c1
-rw-r--r--src/decode.c413
-rw-r--r--src/decode.h3
-rw-r--r--src/flac_decode.c1
-rw-r--r--src/mp3_decode.c1
-rw-r--r--src/mp4_decode.c5
-rw-r--r--src/ogg_decode.c1
8 files changed, 228 insertions, 202 deletions
diff --git a/src/aac_decode.c b/src/aac_decode.c
index ddc8b62d9..cc3b8ee69 100644
--- a/src/aac_decode.c
+++ b/src/aac_decode.c
@@ -341,13 +341,12 @@ int aac_decode(OutputBuffer * cb, DecoderControl * dc) {
sampleRate = frameInfo.samplerate;
#endif
- if(dc->start) {
+ if(dc->state != DECODE_STATE_DECODE) {
dc->audioFormat.channels = frameInfo.channels;
dc->audioFormat.sampleRate = sampleRate;
getOutputAudioFormat(&(dc->audioFormat),
&(cb->audioFormat));
dc->state = DECODE_STATE_DECODE;
- dc->start = 0;
}
advanceAacBuffer(&b,frameInfo.bytesconsumed);
@@ -382,7 +381,7 @@ int aac_decode(OutputBuffer * cb, DecoderControl * dc) {
closeInputStream(b.inStream);
if(b.buffer) free(b.buffer);
- if(dc->start) return -1;
+ if(dc->state != DECODE_STATE_DECODE) return -1;
if(!dc->stop && !dc->seek && chunkLen>0) {
cb->chunkSize[cb->end] = chunkLen;
diff --git a/src/audiofile_decode.c b/src/audiofile_decode.c
index 20c05f426..38ca591dc 100644
--- a/src/audiofile_decode.c
+++ b/src/audiofile_decode.c
@@ -91,7 +91,6 @@ int audiofile_decode(OutputBuffer * cb, DecoderControl * dc) {
fs = (int)afGetFrameSize(af_fp, AF_DEFAULT_TRACK,1);
dc->state = DECODE_STATE_DECODE;
- dc->start = 0;
{
int ret, eof = 0, current = 0;
unsigned char chunk[CHUNK_SIZE];
diff --git a/src/decode.c b/src/decode.c
index 5a04c780f..f77a9b999 100644
--- a/src/decode.c
+++ b/src/decode.c
@@ -79,7 +79,7 @@ void decodeSigHandler(int sig) {
void stopDecode(DecoderControl * dc) {
if(decode_pid && *decode_pid>0 &&
- (dc->start || dc->state==DECODE_STATE_DECODE))
+ (dc->start || dc->state!=DECODE_STATE_STOP))
{
dc->stop = 1;
while(decode_pid && *decode_pid>0 && dc->stop) my_usleep(1000);
@@ -112,7 +112,29 @@ int calculateCrossFadeChunks(PlayerControl * pc, AudioFormat * af) {
return (int)chunks;
}
-int waitOnDecode(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb) {
+#define handleDecodeStart() \
+ if(decodeWaitedOn && dc->state==DECODE_STATE_DECODE) { \
+ decodeWaitedOn = 1; \
+ if(openAudioDevice(&(cb->audioFormat))<0) { \
+ strncpy(pc->erroredFile,pc->file,MAXPATHLEN); \
+ pc->erroredFile[MAXPATHLEN] = '\0'; \
+ pc->error = PLAYER_ERROR_AUDIO; \
+ quitDecode(pc,dc); \
+ return; \
+ } \
+ pc->totalTime = dc->totalTime; \
+ pc->sampleRate = dc->audioFormat.sampleRate; \
+ pc->bits = dc->audioFormat.bits; \
+ pc->channels = dc->audioFormat.channels; \
+ } \
+ else { \
+ my_usleep(10); \
+ continue; \
+ }
+
+int waitOnDecode(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb,
+ int * decodeWaitedOn)
+{
while(decode_pid && *decode_pid>0 && dc->start) my_usleep(1000);
if(dc->start || dc->error!=DECODE_ERROR_NOERROR) {
@@ -123,28 +145,25 @@ int waitOnDecode(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb) {
return -1;
}
- if(openAudioDevice(&(cb->audioFormat))<0) {
- strncpy(pc->erroredFile,pc->file,MAXPATHLEN);
- pc->erroredFile[MAXPATHLEN] = '\0';
- pc->error = PLAYER_ERROR_AUDIO;
- quitDecode(pc,dc);
- return -1;
- }
-
- pc->totalTime = dc->totalTime;
- pc->elapsedTime = 0;
- pc->bitRate = 0;
- pc->sampleRate = dc->audioFormat.sampleRate;
- pc->bits = dc->audioFormat.bits;
- pc->channels = dc->audioFormat.channels;
+ pc->totalTime = pc->fileTime;
+ pc->elapsedTime = 0;
+ pc->bitRate = 0;
+ pc->sampleRate = 0;
+ pc->bits = 0;
+ pc->channels = 0;
+ *decodeWaitedOn = 1;
return 0;
}
-void decodeSeek(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb) {
+int decodeSeek(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb,
+ int * decodeWaitedOn)
+{
+ int ret = -1;
+
if(decode_pid && *decode_pid>0) {
cb->next = -1;
- if(dc->state!=DECODE_STATE_DECODE || dc->error ||
+ if(dc->state==DECODE_STATE_STOP || dc->error ||
strcmp(dc->file,pc->file)!=0)
{
stopDecode(dc);
@@ -153,9 +172,9 @@ void decodeSeek(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb) {
cb->wrap = 0;
dc->error = 0;
dc->start = 1;
- waitOnDecode(pc,dc,cb);
+ waitOnDecode(pc,dc,cb,decodeWaitedOn);
}
- if(*decode_pid>0 && dc->state==DECODE_STATE_DECODE) {
+ if(*decode_pid>0 && dc->state!=DECODE_STATE_STOP) {
dc->seekWhere = pc->seekWhere > pc->totalTime-0.1 ?
pc->totalTime-0.1 :
pc->seekWhere;
@@ -164,10 +183,15 @@ void decodeSeek(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb) {
dc->seek = 1;
pc->bitRate = 0;
while(*decode_pid>0 && dc->seek) my_usleep(1000);
- if(!dc->seekError) pc->elapsedTime = dc->seekWhere;
+ if(!dc->seekError) {
+ ret = 0;
+ pc->elapsedTime = dc->seekWhere;
+ }
}
}
pc->seek = 0;
+
+ return ret;
}
#define processDecodeInput() \
@@ -202,11 +226,12 @@ void decodeSeek(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb) {
} \
if(pc->seek) { \
pc->totalPlayTime+= pc->elapsedTime-pc->beginTime; \
- decodeSeek(pc,dc,cb); \
- pc->beginTime = pc->elapsedTime; \
- doCrossFade = 0; \
- nextChunk = -1; \
- bbp = 0; \
+ if(decodeSeek(pc,dc,cb,&decodeWaitedOn) == 0) { \
+ pc->beginTime = pc->elapsedTime; \
+ doCrossFade = 0; \
+ nextChunk = -1; \
+ bbp = 0; \
+ } \
} \
if(pc->stop) { \
pc->totalPlayTime+= pc->elapsedTime-pc->beginTime; \
@@ -229,7 +254,17 @@ void decodeStart(PlayerControl * pc, OutputBuffer * cb, DecoderControl * dc) {
return;
}
- while(!inputStreamAtEOF(&inStream) && bufferInputStream(&inStream) < 0);
+ dc->state = DECODE_STATE_START;
+ dc->start = 0;
+
+ while(!inputStreamAtEOF(&inStream) && bufferInputStream(&inStream) < 0
+ && !dc->stop);
+
+ if(dc->stop) {
+ dc->state = DECODE_STATE_STOP;
+ dc->stop = 0;
+ return;
+ }
switch(pc->decodeType) {
case DECODE_TYPE_URL:
@@ -339,112 +374,86 @@ int decoderInit(PlayerControl * pc, OutputBuffer * cb, DecoderControl * dc) {
return 0;
}
-/* decode w/ buffering
- * this will fork another process
- * child process does decoding
- * parent process does playing audio
- */
-void decode() {
- OutputBuffer * cb;
- PlayerControl * pc;
- DecoderControl * dc;
+void decodeParent(PlayerControl * pc, DecoderControl * dc, OutputBuffer * cb) {
+ int pause = 0;
+ int quit = 0;
+ int bbp = buffered_before_play;
+ int doCrossFade = 0;
+ int crossFadeChunks = 0;
+ int fadePosition;
+ int nextChunk = -1;
+ int test;
+ int decodeWaitedOn = 0;
+ char silence[CHUNK_SIZE];
- cb = &(getPlayerData()->buffer);
+ memset(silence,0,CHUNK_SIZE);
- cb->begin = 0;
- cb->end = 0;
- cb->wrap = 0;
- pc = &(getPlayerData()->playerControl);
- dc = &(getPlayerData()->decoderControl);
- dc->error = 0;
- dc->start = 1;
- cb->next = -1;
+ if(waitOnDecode(pc,dc,cb,&decodeWaitedOn)<0) return;
- if(decode_pid==NULL || *decode_pid<=0) {
- if(decoderInit(pc,cb,dc)<0) return;
+ pc->state = PLAYER_STATE_PLAY;
+ pc->play = 0;
+ pc->beginTime = pc->elapsedTime;
+ kill(getppid(),SIGUSR1);
+
+ while(*decode_pid>0 && !cb->wrap && cb->end-cb->begin<bbp &&
+ dc->state!=DECODE_STATE_STOP)
+ {
+ processDecodeInput();
+ if(quit) return;
+ my_usleep(10000);
}
- {
- /* PARENT */
- int pause = 0;
- int quit = 0;
- int bbp = buffered_before_play;
- int doCrossFade = 0;
- int crossFadeChunks = 0;
- int fadePosition;
- int nextChunk = -1;
- int test;
- char silence[CHUNK_SIZE];
-
- memset(silence,0,CHUNK_SIZE);
-
- if(waitOnDecode(pc,dc,cb)<0) return;
-
- pc->state = PLAYER_STATE_PLAY;
- pc->play = 0;
- pc->beginTime = pc->elapsedTime;
- kill(getppid(),SIGUSR1);
-
- while(*decode_pid>0 && !cb->wrap && cb->end-cb->begin<bbp &&
- dc->state==DECODE_STATE_DECODE)
+ while(!quit) {
+ processDecodeInput();
+ handleDecodeStart();
+ if(dc->state==DECODE_STATE_STOP &&
+ pc->queueState==PLAYER_QUEUE_FULL &&
+ pc->queueLockState==PLAYER_QUEUE_UNLOCKED)
{
- processDecodeInput();
- if(quit) return;
- my_usleep(1000);
+ cb->next = cb->end;
+ dc->start = 1;
+ pc->queueState = PLAYER_QUEUE_DECODE;
+ kill(getppid(),SIGUSR1);
}
-
- while(!quit) {
- processDecodeInput();
- if(dc->state==DECODE_STATE_STOP &&
- pc->queueState==PLAYER_QUEUE_FULL &&
- pc->queueLockState==PLAYER_QUEUE_UNLOCKED)
- {
- cb->next = cb->end;
- dc->start = 1;
- pc->queueState = PLAYER_QUEUE_DECODE;
- kill(getppid(),SIGUSR1);
- }
- if(cb->next>=0 && doCrossFade==0 && !dc->start) {
- nextChunk = -1;
- if(isCurrentAudioFormat(&(cb->audioFormat))) {
- doCrossFade = 1;
- crossFadeChunks =
- calculateCrossFadeChunks(pc,
- &(cb->audioFormat));
- if(!crossFadeChunks ||
+ if(cb->next>=0 && doCrossFade==0 && !dc->start) {
+ nextChunk = -1;
+ if(isCurrentAudioFormat(&(cb->audioFormat))) {
+ doCrossFade = 1;
+ crossFadeChunks =
+ calculateCrossFadeChunks(pc,
+ &(cb->audioFormat));
+ if(!crossFadeChunks ||
pc->crossFade>=dc->totalTime)
- {
- doCrossFade = -1;
- }
+ {
+ doCrossFade = -1;
}
- else doCrossFade = -1;
}
- if(pause) my_usleep(10000);
- else if((cb->begin!=cb->end || cb->wrap) &&
+ else doCrossFade = -1;
+ }
+ if(pause) my_usleep(10000);
+ else if((cb->begin!=cb->end || cb->wrap) &&
cb->begin!=cb->next)
- {
- if(doCrossFade==1 && cb->next>=0 &&
+ {
+ if(doCrossFade==1 && cb->next>=0 &&
((cb->next>cb->begin &&
(fadePosition=cb->next-cb->begin)
<=crossFadeChunks) ||
(cb->begin>cb->next &&
(fadePosition=cb->next-cb->begin+
buffered_chunks)<=crossFadeChunks)))
- {
- if(nextChunk<0) {
- crossFadeChunks = fadePosition;
+ {
+ if(nextChunk<0) {
+ crossFadeChunks = fadePosition;
+ }
+ test = cb->end;
+ if(cb->wrap) test+=buffered_chunks;
+ nextChunk = cb->begin+crossFadeChunks;
+ if(nextChunk<test) {
+ if(nextChunk>=buffered_chunks)
+ {
+ nextChunk -= buffered_chunks;
}
- test = cb->end;
- if(cb->wrap) test+=buffered_chunks;
- nextChunk = cb->begin+crossFadeChunks;
- if(nextChunk<test) {
- if(nextChunk>=buffered_chunks)
- {
- nextChunk-=
- buffered_chunks;
- }
- pcm_mix(cb->chunks+cb->begin*
- CHUNK_SIZE,
+ pcm_mix(cb->chunks+cb->begin*CHUNK_SIZE,
cb->chunks+nextChunk*
CHUNK_SIZE,
cb->chunkSize[
@@ -454,101 +463,123 @@ void decode() {
&(cb->audioFormat),
((float)fadePosition)/
crossFadeChunks);
- if(cb->chunkSize[nextChunk]>
+ if(cb->chunkSize[nextChunk]>
cb->chunkSize[cb->begin]
)
- {
- cb->chunkSize[cb->begin]
+ {
+ cb->chunkSize[cb->begin]
= cb->chunkSize
[nextChunk];
- }
}
- else {
- if(dc->state==DECODE_STATE_STOP)
- {
- doCrossFade = -1;
- }
- else continue;
- }
- }
- pc->elapsedTime = cb->times[cb->begin];
- pc->bitRate = cb->bitRate[cb->begin];
- pcm_volumeChange(cb->chunks+cb->begin*
- CHUNK_SIZE,
- cb->chunkSize[cb->begin],
- &(cb->audioFormat),
- pc->softwareVolume);
- if(playAudio(cb->chunks+cb->begin*CHUNK_SIZE,
- cb->chunkSize[cb->begin])<0)
- {
- quit = 1;
}
- cb->begin++;
- if(cb->begin>=buffered_chunks) {
- cb->begin = 0;
- cb->wrap = 0;
+ else {
+ if(dc->state==DECODE_STATE_STOP)
+ {
+ doCrossFade = -1;
+ }
+ else continue;
}
}
- else if(cb->next==cb->begin) {
- pc->totalPlayTime+= pc->elapsedTime-
- pc->beginTime;
- if(doCrossFade==1 && nextChunk>=0) {
- nextChunk = cb->begin+crossFadeChunks;
- test = cb->end;
- if(cb->wrap) test+=buffered_chunks;
- if(nextChunk<test) {
- if(nextChunk>=buffered_chunks)
- {
- nextChunk-=
- buffered_chunks;
- }
- cb->begin = nextChunk;
- }
- }
- while(pc->queueState==PLAYER_QUEUE_DECODE ||
- pc->queueLockState==PLAYER_QUEUE_LOCKED)
- {
- processDecodeInput();
- if(quit) {
- quitDecode(pc,dc);
- return;
+ pc->elapsedTime = cb->times[cb->begin];
+ pc->bitRate = cb->bitRate[cb->begin];
+ pcm_volumeChange(cb->chunks+cb->begin*
+ CHUNK_SIZE,
+ cb->chunkSize[cb->begin],
+ &(cb->audioFormat),
+ pc->softwareVolume);
+ if(playAudio(cb->chunks+cb->begin*CHUNK_SIZE,
+ cb->chunkSize[cb->begin])<0)
+ {
+ quit = 1;
+ }
+ cb->begin++;
+ if(cb->begin>=buffered_chunks) {
+ cb->begin = 0;
+ cb->wrap = 0;
+ }
+ }
+ else if(cb->next==cb->begin) {
+ pc->totalPlayTime+= pc->elapsedTime-
+ pc->beginTime;
+ if(doCrossFade==1 && nextChunk>=0) {
+ nextChunk = cb->begin+crossFadeChunks;
+ test = cb->end;
+ if(cb->wrap) test+=buffered_chunks;
+ if(nextChunk<test) {
+ if(nextChunk>=buffered_chunks)
+ {
+ nextChunk -= buffered_chunks;
}
- my_usleep(1000);
- }
- if(pc->queueState!=PLAYER_QUEUE_PLAY) {
- quit = 1;
- break;
- }
- else {
- cb->next = -1;
- if(waitOnDecode(pc,dc,cb)<0) return;
- nextChunk = -1;
- doCrossFade = 0;
- crossFadeChunks = 0;
- pc->queueState = PLAYER_QUEUE_EMPTY;
- kill(getppid(),SIGUSR1);
- }
- pc->beginTime = cb->times[cb->begin];
+ cb->begin = nextChunk;
+ }
}
- else if(*decode_pid<=0 ||
- (dc->state==DECODE_STATE_STOP && !dc->start))
+ while(pc->queueState==PLAYER_QUEUE_DECODE ||
+ pc->queueLockState==PLAYER_QUEUE_LOCKED)
{
+ processDecodeInput();
+ if(quit) {
+ quitDecode(pc,dc);
+ return;
+ }
+ my_usleep(1000);
+ }
+ if(pc->queueState!=PLAYER_QUEUE_PLAY) {
quit = 1;
break;
}
else {
- if(playAudio(silence, CHUNK_SIZE) < 0) {
- quit = 1;
- }
+ cb->next = -1;
+ if(waitOnDecode(pc,dc,cb,&decodeWaitedOn)<0) {
+ return;
+ }
+ nextChunk = -1;
+ doCrossFade = 0;
+ crossFadeChunks = 0;
+ pc->queueState = PLAYER_QUEUE_EMPTY;
+ kill(getppid(),SIGUSR1);
}
+ pc->beginTime = cb->times[cb->begin];
+ }
+ else if(*decode_pid<=0 ||
+ (dc->state==DECODE_STATE_STOP && !dc->start))
+ {
+ quit = 1;
+ break;
}
+ else {
+ if(playAudio(silence, CHUNK_SIZE) < 0) quit = 1;
+ }
+ }
- pc->totalPlayTime+= pc->elapsedTime-pc->beginTime; \
- quitDecode(pc,dc);
+ pc->totalPlayTime+= pc->elapsedTime-pc->beginTime; \
+ quitDecode(pc,dc);
+}
+
+/* decode w/ buffering
+ * this will fork another process
+ * child process does decoding
+ * parent process does playing audio
+ */
+void decode() {
+ OutputBuffer * cb;
+ PlayerControl * pc;
+ DecoderControl * dc;
+
+ cb = &(getPlayerData()->buffer);
- /* END OF PARENT */
+ cb->begin = 0;
+ cb->end = 0;
+ cb->wrap = 0;
+ pc = &(getPlayerData()->playerControl);
+ dc = &(getPlayerData()->decoderControl);
+ dc->error = 0;
+ dc->start = 1;
+ cb->next = -1;
+
+ if(decode_pid==NULL || *decode_pid<=0) {
+ if(decoderInit(pc,cb,dc)<0) return;
}
- return;
+ decodeParent(pc, dc, cb);
}
-/* vim:set shiftwidth=4 tabstop=8 expandtab: */
+/* vim:set shiftwidth=8 tabstop=8 expandtab: */
diff --git a/src/decode.h b/src/decode.h
index c21407b48..8b36fe7ca 100644
--- a/src/decode.h
+++ b/src/decode.h
@@ -31,7 +31,8 @@
#define DECODE_TYPE_URL 1
#define DECODE_STATE_STOP 0
-#define DECODE_STATE_DECODE 1
+#define DECODE_STATE_START 1
+#define DECODE_STATE_DECODE 2
#define DECODE_ERROR_NOERROR 0
#define DECODE_ERROR_UNKTYPE 10
diff --git a/src/flac_decode.c b/src/flac_decode.c
index 6c718f654..7a966bbb8 100644
--- a/src/flac_decode.c
+++ b/src/flac_decode.c
@@ -135,7 +135,6 @@ int flac_decode(OutputBuffer * cb, DecoderControl *dc) {
}
dc->state = DECODE_STATE_DECODE;
- dc->start = 0;
while(1) {
FLAC__seekable_stream_decoder_process_single(flacDec);
diff --git a/src/mp3_decode.c b/src/mp3_decode.c
index 319f324d5..b1b072e23 100644
--- a/src/mp3_decode.c
+++ b/src/mp3_decode.c
@@ -560,7 +560,6 @@ int mp3_decode(OutputBuffer * cb, DecoderControl * dc, InputStream * inStream) {
getOutputAudioFormat(&(dc->audioFormat), &(cb->audioFormat));
dc->totalTime = data.totalTime;
- dc->start = 0;
dc->state = DECODE_STATE_DECODE;
while(mp3Read(&data,cb,dc)!=DECODE_BREAK);
diff --git a/src/mp4_decode.c b/src/mp4_decode.c
index dccc7a846..010e0524f 100644
--- a/src/mp4_decode.c
+++ b/src/mp4_decode.c
@@ -249,7 +249,7 @@ int mp4_decode(OutputBuffer * cb, DecoderControl * dc) {
break;
}
- if(dc->start) {
+ if(dc->state != DECODE_STATE_DECODE) {
channels = frameInfo.channels;
#ifdef HAVE_FAACDECFRAMEINFO_SAMPLERATE
scale = frameInfo.samplerate;
@@ -259,7 +259,6 @@ int mp4_decode(OutputBuffer * cb, DecoderControl * dc) {
getOutputAudioFormat(&(dc->audioFormat),
&(cb->audioFormat));
dc->state = DECODE_STATE_DECODE;
- dc->start = 0;
}
if(channels*(dur+offset) > frameInfo.samples) {
@@ -297,7 +296,7 @@ int mp4_decode(OutputBuffer * cb, DecoderControl * dc) {
closeInputStream(&inStream);
free(mp4cb);
- if(dc->start) return -1;
+ if(dc->state != DECODE_STATE_DECODE) return -1;
if(!dc->stop && !dc->seek && chunkLen>0) {
cb->chunkSize[cb->end] = chunkLen;
diff --git a/src/ogg_decode.c b/src/ogg_decode.c
index d24d6158b..672785af2 100644
--- a/src/ogg_decode.c
+++ b/src/ogg_decode.c
@@ -175,7 +175,6 @@ int ogg_decode(OutputBuffer * cb, DecoderControl * dc)
dc->totalTime = ov_time_total(&vf,-1);
dc->state = DECODE_STATE_DECODE;
- dc->start = 0;
{
int current_section;
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-09 23:24:50 +0000