diff options
Diffstat (limited to 'src/player.c')
| -rw-r--r-- | src/player.c | 397 |
1 files changed, 397 insertions, 0 deletions
diff --git a/src/player.c b/src/player.c new file mode 100644 index 000000000..cf09f388b --- /dev/null +++ b/src/player.c @@ -0,0 +1,397 @@ +/* the Music Player Daemon (MPD) + * (c)2003-2004 by Warren Dukes (shank@mercury.chem.pitt.edu) + * This project's homepage is: http://www.musicpd.org + * + * This program 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. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#include "player.h" +#include "decode.h" +#include "command.h" +#include "interface.h" +#include "playlist.h" +#include "ls.h" +#include "listen.h" +#include "path.h" +#include "log.h" +#include "utils.h" +#include "tables.h" +#include "directory.h" +#include "volume.h" +#include "playerData.h" +#include "permission.h" + +#include <stdio.h> +#include <sys/types.h> +#include <sys/stat.h> +#include <unistd.h> +#include <sys/time.h> +#include <sys/wait.h> +#include <stdlib.h> +#include <signal.h> +#include <string.h> +#include <errno.h> +#include <fcntl.h> + +int player_pid = 0; +int player_termSent = 0; + +void resetPlayer() { + player_pid = 0; + player_termSent = 0; + getPlayerData()->playerControl.stop = 0; + getPlayerData()->playerControl.play = 0; + getPlayerData()->playerControl.pause = 0; + getPlayerData()->playerControl.lockQueue = 0; + getPlayerData()->playerControl.unlockQueue = 0; + getPlayerData()->playerControl.state = PLAYER_STATE_STOP; + getPlayerData()->playerControl.queueState = PLAYER_QUEUE_UNLOCKED; + getPlayerData()->playerControl.seek = 0; +} + +void player_sigHandler(int signal) { + if(signal==SIGCHLD) { + int status; + if(player_pid==wait3(&status,WNOHANG,NULL)) { + if(WIFSIGNALED(status) && WTERMSIG(status)!=SIGTERM) { + ERROR("player process died from a " + "non-TERM signal: %i\n", + WTERMSIG(status)); + } + resetPlayer(); + } + } +} + +int playerInit() { + player_pid = fork(); + + if(player_pid==0) { + PlayerControl * pc = &(getPlayerData()->playerControl); + struct sigaction sa; + sa.sa_flags = 0; + sigemptyset(&sa.sa_mask); + + sa.sa_handler = SIG_IGN; + sigaction(SIGPIPE,&sa,NULL); + sa.sa_handler = decodeSigHandler; + sigaction(SIGCHLD,&sa,NULL); + sigaction(SIGTERM,&sa,NULL); + + close(listenSocket); + finishPlaylist(); + freeAllInterfaces(); + closeMp3Directory(); + closeTables(); + finishPaths(); + finishPermissions(); + finishCommands(); + finishVolume(); + + while(1) { + if(pc->play) decode(); + else if(pc->stop) pc->stop = 0; + else if(pc->pause) pc->pause = 0; + else if(pc->closeAudio) { + finishAudio(); + pc->closeAudio = 0; + kill(getppid(),SIGUSR1); + } + else if(pc->lockQueue) { + pc->queueLockState = PLAYER_QUEUE_LOCKED; + pc->lockQueue = 0; + } + else if(pc->unlockQueue) { + pc->queueLockState = PLAYER_QUEUE_UNLOCKED; + pc->unlockQueue = 0; + } + else usleep(1000); + } + + exit(0); + } + else if(player_pid<0) { + ERROR("player Problems fork()'ing\n"); + player_pid = 0; + + return -1; + } + + return 0; +} + +int playerPlay(FILE * fp, char * utf8file) { + PlayerControl * pc = &(getPlayerData()->playerControl); + if(fp==NULL) fp = stderr; + + if(playerStop(fp)<0) return -1; + + { + struct stat st; + if(stat(rmp2amp(utf8ToFsCharset(utf8file)),&st)<0) { + strcpy(pc->erroredFile,pc->file); + pc->error = PLAYER_ERROR_FILENOTFOUND; + return 0; + } + } + + if(0); +#ifdef HAVE_MAD + else if(isMp3(utf8file)) pc->decodeType = DECODE_TYPE_MP3; +#endif +#ifdef HAVE_OGG + else if(isOgg(utf8file)) pc->decodeType = DECODE_TYPE_OGG; +#endif +#ifdef HAVE_FLAC + else if(isFlac(utf8file)) pc->decodeType = DECODE_TYPE_FLAC; +#endif +#ifdef HAVE_AUDIOFILE + else if(isWave(utf8file)) pc->decodeType = DECODE_TYPE_AUDIOFILE; +#endif + else { + strcpy(pc->erroredFile,pc->file); + pc->error = PLAYER_ERROR_UNKTYPE; + return 0; + } + + strcpy(pc->file,rmp2amp(utf8ToFsCharset(utf8file))); + + pc->play = 1; + if(player_pid==0 && playerInit()<0) { + pc->play = 0; + return -1; + } + + while(player_pid>0 && pc->play) usleep(10); + + return 0; +} + +int playerStop(FILE * fp) { + PlayerControl * pc = &(getPlayerData()->playerControl); + + if(player_pid>0 && pc->state!=PLAYER_STATE_STOP) { + pc->stop = 1; + while(player_pid>0 && pc->stop) usleep(10); + } + + pc->queueState = PLAYER_QUEUE_BLANK; + playerQueueUnlock(); + + return 0; +} + +void playerKill() { + int pid; + PlayerControl * pc = &(getPlayerData()->playerControl); + + playerStop(stderr); + playerCloseAudio(stderr); + if(player_pid>0 && pc->closeAudio) sleep(1); + + pid = player_pid; + if(pid>0) kill(pid,SIGTERM); +} + +int playerPause(FILE * fp) { + PlayerControl * pc = &(getPlayerData()->playerControl); + + if(player_pid>0 && pc->state!=PLAYER_STATE_STOP) { + pc->pause = 1; + while(player_pid>0 && pc->pause) usleep(10); + } + + return 0; +} + +int getPlayerElapsedTime() { + return (int)(getPlayerData()->playerControl.elapsedTime+0.5); +} + +unsigned long getPlayerBitRate() { + return getPlayerData()->playerControl.bitRate; +} + +int getPlayerTotalTime() { + return (int)(getPlayerData()->playerControl.totalTime+0.5); +} + +int getPlayerState() { + return getPlayerData()->playerControl.state; +} + +void clearPlayerError() { + getPlayerData()->playerControl.error = 0; +} + +int getPlayerError() { + return getPlayerData()->playerControl.error; +} + +char * getPlayerErrorStr() { + static char error[2*MAXPATHLEN]; + PlayerControl * pc = &(getPlayerData()->playerControl); + + switch(pc->error) { + case PLAYER_ERROR_FILENOTFOUND: + sprintf(error,"file \"%s\" does not exist or is inaccesible", + pc->erroredFile); + return error; + case PLAYER_ERROR_FILE: + sprintf(error,"problems decoding \"%s\"",pc->erroredFile); + return error; + case PLAYER_ERROR_AUDIO: + sprintf(error,"problems opening audio device"); + return error; + case PLAYER_ERROR_SYSTEM: + sprintf(error,"system error occured"); + return error; + case PLAYER_ERROR_UNKTYPE: + sprintf(error,"file type of \"%s\" is unknown",pc->erroredFile); + return error; + default: + return NULL; + } +} + +void playerCloseAudio() { + PlayerControl * pc = &(getPlayerData()->playerControl); + + if(player_pid>0) { + if(playerStop(stderr)<0) return; + pc->closeAudio = 1; + } +} + +int queueSong(char * utf8file) { + PlayerControl * pc = &(getPlayerData()->playerControl); + + if(pc->queueState==PLAYER_QUEUE_BLANK) { + strcpy(pc->file,rmp2amp(utf8ToFsCharset(utf8file))); + + if(0); +#ifdef HAVE_MAD + else if(isMp3(utf8file)) pc->decodeType = DECODE_TYPE_MP3; +#endif +#ifdef HAVE_OGG + else if(isOgg(utf8file)) pc->decodeType = DECODE_TYPE_OGG; +#endif +#ifdef HAVE_FLAC + else if(isFlac(utf8file)) pc->decodeType = DECODE_TYPE_FLAC; +#endif +#ifdef HAVE_AUDIOFILE + else if(isWave(utf8file)) { + pc->decodeType = DECODE_TYPE_AUDIOFILE; + } +#endif + else return -1; + pc->queueState = PLAYER_QUEUE_FULL; + return 0; + } + + return -1; +} + +int getPlayerQueueState() { + PlayerControl * pc = &(getPlayerData()->playerControl); + + return pc->queueState; +} + +void setQueueState(int queueState) { + PlayerControl * pc = &(getPlayerData()->playerControl); + + pc->queueState = queueState; +} + +void playerQueueLock() { + PlayerControl * pc = &(getPlayerData()->playerControl); + + if(player_pid>0 && pc->queueLockState==PLAYER_QUEUE_UNLOCKED) + { + pc->lockQueue = 1; + while(player_pid>0 && pc->lockQueue) usleep(10); + } +} + +void playerQueueUnlock() { + PlayerControl * pc = &(getPlayerData()->playerControl); + + if(player_pid>0 && pc->queueLockState==PLAYER_QUEUE_LOCKED) + { + pc->unlockQueue = 1; + while(player_pid>0 && pc->unlockQueue) usleep(10); + } +} + +int playerSeek(FILE * fp, char * file, float time) { + PlayerControl * pc = &(getPlayerData()->playerControl); + + if(pc->state==PLAYER_STATE_STOP) { + myfprintf(fp,"%s player not currently playing\n", + COMMAND_RESPOND_ERROR); + return -1; + } + + if(strcmp(pc->file,rmp2amp(file))!=0) strcpy(pc->file,rmp2amp(file)); + /*if(playerStop(fp)<0) return -1; + if(playerPlay(stderr,file)<0) return -1;*/ + /*}*/ + + if(pc->error==PLAYER_ERROR_NOERROR) { + pc->seekWhere = time; + pc->seek = 1; + while(player_pid>0 && pc->seek) usleep(10); + } + + return 0; +} + +float getPlayerCrossFade() { + PlayerControl * pc = &(getPlayerData()->playerControl); + + return pc->crossFade; +} + +void setPlayerCrossFade(float crossFadeInSeconds) { + if(crossFadeInSeconds<0) crossFadeInSeconds = 0; + + PlayerControl * pc = &(getPlayerData()->playerControl); + + pc->crossFade = crossFadeInSeconds; +} + +void setPlayerSoftwareVolume(int volume) { + volume = (volume>100) ? 100 : (volume<0 ? 0 : volume); + + PlayerControl * pc = &(getPlayerData()->playerControl); + + pc->softwareVolume = volume; +} + +int getPlayerSoftwareVolume() { + PlayerControl * pc = &(getPlayerData()->playerControl); + + return pc->softwareVolume; +} + +double getPlayerTotalPlayTime() { + PlayerControl * pc = &(getPlayerData()->playerControl); + + if(pc->state==PLAYER_STATE_STOP) { + return pc->totalPlayTime; + } + + return pc->totalPlayTime+pc->elapsedTime-pc->beginTime; +} |