mirrors/NewPipe
1
0
Fork 0
mirror of https://github.com/TeamNewPipe/NewPipe synced 2024-12-24 09:00:31 +00:00
Code Issues Releases Wiki Activity

Make shure thread quits before service

Browse Source
This commit is contained in:
Coffeemakr 2016-12-27 16:17:59 +01:00
parent f22b5157f5
commit ac0dff7aa1
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
app/src/main/java/org/schabi/newpipe/player/BackgroundPlayer.java
View File

@ -161,18 +161,20 @@ public class BackgroundPlayer extends Service /*implements MediaPlayer.OnPrepare
} }
} }
private PlaybackState getPlaybackState() { private synchronized PlaybackState getPlaybackState() {
try { try {
return new PlaybackState(mediaPlayer.getDuration(), mediaPlayer.getCurrentPosition(), isPlaying()); return new PlaybackState(mediaPlayer.getDuration(), mediaPlayer.getCurrentPosition(), isPlaying());
} catch (IllegalStateException e) { } catch (IllegalStateException e) {
// This isn't that nice way to handle this. // This isn't that nice way to handle this.
// maybe there is a better way // maybe there is a better way
Log.w(TAG, this + ": Got illegal state exception while creating playback state", e);
return PlaybackState.UNPREPARED; return PlaybackState.UNPREPARED;
} }
} }
private void broadcastState() { private void broadcastState() {
PlaybackState state = getPlaybackState(); PlaybackState state = getPlaybackState();
if(state == null) return;
Intent intent = new Intent(ACTION_PLAYBACK_STATE); Intent intent = new Intent(ACTION_PLAYBACK_STATE);
intent.putExtra(EXTRA_PLAYBACK_STATE, state); intent.putExtra(EXTRA_PLAYBACK_STATE, state);
sendBroadcast(intent); sendBroadcast(intent);
@ -284,9 +286,6 @@ public class BackgroundPlayer extends Service /*implements MediaPlayer.OnPrepare
break; break;
case ACTION_PLAYBACK_STATE: { case ACTION_PLAYBACK_STATE: {
PlaybackState playbackState = intent.getParcelableExtra(EXTRA_PLAYBACK_STATE); PlaybackState playbackState = intent.getParcelableExtra(EXTRA_PLAYBACK_STATE);
Log.d(TAG, "playback state recieved: " + playbackState);
Log.d(TAG, "is unprepared: " + playbackState.equals(PlaybackState.UNPREPARED));
Log.d(TAG, "playing: " + playbackState.getPlayedTime());
if(!playbackState.equals(PlaybackState.UNPREPARED)) { if(!playbackState.equals(PlaybackState.UNPREPARED)) {
noteBuilder.setProgress(playbackState.getDuration(), playbackState.getPlayedTime(), false); noteBuilder.setProgress(playbackState.getDuration(), playbackState.getPlayedTime(), false);
noteBuilder.setIsPlaying(playbackState.isPlaying()); noteBuilder.setIsPlaying(playbackState.isPlaying());
@ -301,6 +300,8 @@ public class BackgroundPlayer extends Service /*implements MediaPlayer.OnPrepare
}; };
private void afterPlayCleanup() { private void afterPlayCleanup() {
// Notify thread to stop
setDonePlaying();
//remove progress bar //remove progress bar
//noteBuilder.setProgress(0, 0, false); //noteBuilder.setProgress(0, 0, false);
@ -314,7 +315,12 @@ public class BackgroundPlayer extends Service /*implements MediaPlayer.OnPrepare
wifiLock.release(); wifiLock.release();
//remove foreground status of service; make BackgroundPlayer killable //remove foreground status of service; make BackgroundPlayer killable
stopForeground(true); stopForeground(true);
try {
// Wait for thread to stop
PlayerThread.this.join();
} catch (InterruptedException e) {
Log.e(TAG, "unable to join player thread", e);
}
stopSelf(); stopSelf();
} }
@ -326,9 +332,7 @@ public class BackgroundPlayer extends Service /*implements MediaPlayer.OnPrepare
@Override @Override
public void onCompletion(MediaPlayer mp) { public void onCompletion(MediaPlayer mp) {
setDonePlaying();
afterPlayCleanup(); afterPlayCleanup();
} }
} }