From 14d2d6865ebcfd8f4c1bdb1600f29fc2b1a4366d Mon Sep 17 00:00:00 2001 From: Sven Gothel Date: Sat, 31 Aug 2013 16:40:44 +0200 Subject: GLMediaPlayer: pause() -> pause(boolean flush): Allowing to flush buffers, next frame after play() will provide new frame. Added API doc. --- .../com/jogamp/opengl/util/av/GLMediaPlayer.java | 22 +++++++++++++--- .../jogamp/opengl/util/av/GLMediaPlayerImpl.java | 30 ++++++++++++---------- 2 files changed, 35 insertions(+), 17 deletions(-) (limited to 'src/jogl/classes') diff --git a/src/jogl/classes/com/jogamp/opengl/util/av/GLMediaPlayer.java b/src/jogl/classes/com/jogamp/opengl/util/av/GLMediaPlayer.java index 5072c410d..63fc693ca 100644 --- a/src/jogl/classes/com/jogamp/opengl/util/av/GLMediaPlayer.java +++ b/src/jogl/classes/com/jogamp/opengl/util/av/GLMediaPlayer.java @@ -85,7 +85,7 @@ import com.jogamp.opengl.util.TimeFrameI; * {@link #initStream(URI, int, int, int)} {@link State#Uninitialized Uninitialized} {@link State#Initialized Initialized}1, {@link State#Uninitialized Uninitialized} {@link GLMediaEventListener#EVENT_CHANGE_INIT EVENT_CHANGE_INIT} or ( {@link GLMediaEventListener#EVENT_CHANGE_ERR EVENT_CHANGE_ERR} + {@link GLMediaEventListener#EVENT_CHANGE_UNINIT EVENT_CHANGE_UNINIT} ) * {@link #initGL(GL)} {@link State#Initialized Initialized} {@link State#Paused Paused}, , {@link State#Uninitialized Uninitialized} {@link GLMediaEventListener#EVENT_CHANGE_PAUSE EVENT_CHANGE_PAUSE} or ( {@link GLMediaEventListener#EVENT_CHANGE_ERR EVENT_CHANGE_ERR} + {@link GLMediaEventListener#EVENT_CHANGE_UNINIT EVENT_CHANGE_UNINIT} ) * {@link #play()} {@link State#Paused Paused} {@link State#Playing Playing} {@link GLMediaEventListener#EVENT_CHANGE_PLAY EVENT_CHANGE_PLAY} - * {@link #pause()} {@link State#Playing Playing} {@link State#Paused Paused} {@link GLMediaEventListener#EVENT_CHANGE_PAUSE EVENT_CHANGE_PAUSE} + * {@link #pause(boolean)} {@link State#Playing Playing} {@link State#Paused Paused} {@link GLMediaEventListener#EVENT_CHANGE_PAUSE EVENT_CHANGE_PAUSE} * {@link #seek(int)} {@link State#Paused Paused}, {@link State#Playing Playing} {@link State#Paused Paused}, {@link State#Playing Playing} none * {@link #getNextTexture(GL)} {@link State#Paused Paused}, {@link State#Playing Playing} {@link State#Paused Paused}, {@link State#Playing Playing} none * {@link #getLastTexture()} {@link State#Paused Paused}, {@link State#Playing Playing} {@link State#Paused Paused}, {@link State#Playing Playing} none @@ -427,18 +427,34 @@ public interface GLMediaPlayer extends TextureSequence { public float getAudioVolume(); /** + * Starts or resumes the StreamWorker decoding thread. + *

* Lifecycle: {@link State#Paused} -> {@link State#Playing} + *

*/ public State play(); /** + * Pauses the StreamWorker decoding thread. + *

* Lifecycle: {@link State#Playing} -> {@link State#Paused} + *

+ *

+ * If a new frame is desired after the next {@link #play()} call, + * e.g. to make a snapshot of a camera input stream, + * flush shall be set to true. + *

+ * @param flush if true flushes the video and audio buffers, otherwise keep them intact. */ - public State pause(); + public State pause(boolean flush); /** + * Seeks to the new absolute position. The StreamWorker decoding thread + * is paused while doing so and the A/V buffers are flushed. + *

* Allowed in state {@link State#Playing} and {@link State#Paused}, otherwise ignored, - * see Lifecycle. + * see Lifecycle. + *

* * @param msec absolute desired time position in milliseconds * @return time current position in milliseconds, after seeking to the desired position diff --git a/src/jogl/classes/jogamp/opengl/util/av/GLMediaPlayerImpl.java b/src/jogl/classes/jogamp/opengl/util/av/GLMediaPlayerImpl.java index 205642eb0..40fa9c9d6 100644 --- a/src/jogl/classes/jogamp/opengl/util/av/GLMediaPlayerImpl.java +++ b/src/jogl/classes/jogamp/opengl/util/av/GLMediaPlayerImpl.java @@ -296,7 +296,7 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { switch( state ) { case Paused: if( playImpl() ) { - resetAudioVideoPTS(); + resetAVPTS(); if( null != audioSink ) { audioSink.play(); // cont. w/ new data } @@ -312,17 +312,19 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { protected abstract boolean playImpl(); @Override - public final State pause() { - return pauseImpl(0); + public final State pause(boolean flush) { + return pauseImpl(flush, 0); } - private final State pauseImpl(int event_mask) { + private final State pauseImpl(boolean flush, int event_mask) { synchronized( stateLock ) { final State preState = state; if( State.Playing == state ) { event_mask = addStateEventMask(event_mask, GLMediaPlayer.State.Paused); state = State.Paused; streamWorker.doPause(); - if( null != audioSink ) { + if( flush ) { + resetAVPTSAndFlush(); + } else if( null != audioSink ) { audioSink.pause(); } attributesUpdated( event_mask ); @@ -365,7 +367,7 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { state = State.Paused; streamWorker.doPause(); pts1 = seekImpl(msec); - resetAllAudioVideoSync(); + resetAVPTSAndFlush(); if( null != audioSink && State.Playing == _state ) { audioSink.play(); // cont. w/ new data } @@ -398,7 +400,7 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { rate = 1.0f; } if( setPlaySpeedImpl(rate) ) { - resetAudioVideoPTS(); + resetAVPTS(); playSpeed = rate; res = true; } @@ -738,7 +740,7 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { presentedFrameCount++; final int video_pts = nextFrame.getPTS(); if( video_pts == TimeFrameI.END_OF_STREAM_PTS ) { - pauseImpl(GLMediaEventListener.EVENT_CHANGE_EOS); + pauseImpl(true, GLMediaEventListener.EVENT_CHANGE_EOS); } else if( video_pts != TimeFrameI.INVALID_PTS ) { final int audio_pts = getAudioPTSImpl(); final int audio_scr = (int) ( ( currentTimeMillis - audio_scr_t0 ) * playSpeed ); @@ -855,7 +857,7 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { * {@inheritDoc} *

* Note: All {@link AudioSink} operations are performed from {@link GLMediaPlayerImpl}, - * i.e. {@link #play()}, {@link #pause()}, {@link #seek(int)}, {@link #setPlaySpeed(float)}, {@link #getAudioPTS()}. + * i.e. {@link #play()}, {@link #pause(boolean)}, {@link #seek(int)}, {@link #setPlaySpeed(float)}, {@link #getAudioPTS()}. *

*

* Implementations using an {@link AudioSink} shall write it's instance to {@link #audioSink} @@ -887,16 +889,16 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { } cachedFrame = null; } - private void resetAllAudioVideoSync() { + private void resetAVPTSAndFlush() { video_dpts_cum = 0; video_dpts_count = 0; - resetAudioVideoPTS(); + resetAVPTS(); flushAllVideoFrames(); if( null != audioSink ) { audioSink.flush(); } } - private void resetAudioVideoPTS() { + private void resetAVPTS() { presentedFrameCount = 0; displayedFrameCount = 0; decodedFrameCount = 0; @@ -1129,7 +1131,7 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { // state transition incl. notification shallPause = true; isActive = false; - pauseImpl(GLMediaEventListener.EVENT_CHANGE_EOS); + pauseImpl(true, GLMediaEventListener.EVENT_CHANGE_EOS); } } } @@ -1153,7 +1155,7 @@ public abstract class GLMediaPlayerImpl implements GLMediaPlayer { // state transition incl. notification shallPause = true; isActive = false; - pauseImpl(GLMediaEventListener.EVENT_CHANGE_ERR); + pauseImpl(true, GLMediaEventListener.EVENT_CHANGE_ERR); } } } -- cgit v1.2.3