1 files changed, 238 insertions, 0 deletions
diff --git a/src/jogl/classes/jogamp/opengl/omx/OMXGLMediaPlayer.java b/src/jogl/classes/jogamp/opengl/omx/OMXGLMediaPlayer.java
new file mode 100644
index 000000000..8f5f9c3ab
--- /dev/null
+++ b/src/jogl/classes/jogamp/opengl/omx/OMXGLMediaPlayer.java
@@ -0,0 +1,238 @@
+
+package jogamp.opengl.omx;
+
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+
+import javax.media.opengl.GL;
+import javax.media.opengl.GLContext;
+import javax.media.opengl.GLException;
+
+import com.jogamp.opengl.av.GLMediaEventListener;
+import com.jogamp.opengl.util.texture.Texture;
+
+import jogamp.opengl.av.EGLMediaPlayerImpl;
+import jogamp.opengl.egl.EGL;
+
+public class OMXGLMediaPlayer extends EGLMediaPlayerImpl {
+    protected long moviePtr = 0;
+    
+    /**
+     * Old stream values, before the last attributesUpdated)
+     */
+    protected int o_width = 0;
+    protected int o_height = 0;
+    protected int o_fps = 0;
+    protected long o_bps = 0;
+    protected long o_totalFrames = 0;
+        
+    public OMXGLMediaPlayer() {
+        super(TextureType.KHRImage, true);
+        initOMX();
+    }
+
+    protected void initOMX() {
+        moviePtr = _createInstance();
+        if(0==moviePtr) {
+            throw new GLException("Couldn't create OMXInstance");
+        }        
+    }
+    
+    @Override
+    protected TextureFrame createTexImage(GLContext ctx, int idx, int[] tex) {
+        final EGLTextureFrame eglTex = (EGLTextureFrame) super.createTexImage(ctx, idx, tex);
+        _setStreamEGLImageTexture2D(moviePtr, idx, tex[idx], eglTex.getImage(), eglTex.getSync());
+        return eglTex;
+    }
+    
+    @Override
+    protected void destroyTexImage(GLContext ctx, TextureFrame imgTex) {
+        super.destroyTexImage(ctx, imgTex);
+    }
+    
+    @Override
+    protected void destroyImpl(GL gl) {
+        _detachVideoRenderer(moviePtr);
+        if (moviePtr != 0) {
+            _destroyInstance(moviePtr);
+            moviePtr = 0;
+        }
+    }
+    
+    @Override
+    protected void setStreamImpl() throws IOException {
+        if(0==moviePtr) {
+            throw new GLException("OMX native instance null");
+        }
+        String path=null;
+        if (url.getProtocol() == null || "file".equals(url.getProtocol())) {
+            // CV only accepts absolute paths
+            try {
+                File file = new File(url.getPath());
+                if (!file.exists()) {
+                    throw new FileNotFoundException(file.toString());
+                }
+                path = file.getCanonicalPath();
+                System.out.println("setURL: path "+path);
+            } catch (Exception e) {
+                e.printStackTrace();
+                throw new IOException(e);
+            }
+        }
+        path = replaceAll(path, "\\", "/").trim();
+        if(null==path) {
+            throw new IOException("Couldn't parse stream URL: "+url);
+        }
+        System.out.println("setURL: clean path "+path);
+    
+        System.out.println("setURL: p1 "+this);
+        _setStream(moviePtr, textureCount, path);
+        System.out.println("setURL: p2 "+this);
+    }
+    
+        
+    @Override
+    public synchronized int getCurrentPosition() {
+        if(0==moviePtr) {
+            throw new GLException("OMX native instance null");
+        }
+        return _getCurrentPosition(moviePtr);
+    }
+
+    @Override
+    public synchronized boolean isValid() {
+        return (moviePtr != 0);
+    }
+
+    @Override
+    public synchronized void setPlaySpeed(float rate) {
+        if(0==moviePtr) {
+            throw new GLException("OMX native instance null");
+        }
+        _setPlaySpeed(moviePtr, rate);
+        playSpeed = rate;
+    }
+
+    /** @return time position after issuing the command */
+    @Override
+    public synchronized void start() {
+        if(0==moviePtr) {
+            throw new GLException("OMX native instance null");
+        }
+        _play(moviePtr);
+    }
+
+    /** @return time position after issuing the command */
+    @Override
+    public synchronized void pause() {
+        if(0==moviePtr) {
+            throw new GLException("OMX native instance null");
+        }
+        _pause(moviePtr);
+    }
+
+    /** @return time position after issuing the command */
+    @Override
+    public synchronized void stop() {
+        if(0==moviePtr) {
+            throw new GLException("OMX native instance null");
+        }
+        _stop(moviePtr);
+    }
+
+    /** @return time position after issuing the command */
+    @Override
+    public synchronized int seek(int msec) {
+        if(0==moviePtr) {
+            throw new GLException("OMX native instance null");
+        }
+        return _seek(moviePtr, msec);
+    }
+
+    @Override
+    public synchronized Texture getNextTextureID() {
+        if(0==moviePtr) {
+            throw new GLException("OMX native instance null");
+        }
+        texture=null;
+        TextureFrame eglImgTex = texFrameMap.get(new Integer(_getNextTextureID(moviePtr)));
+        if(null!=eglImgTex) {
+            texture = eglImgTex.getTexture();
+        }
+        return texture;
+    }
+
+    protected void attributesUpdated() {
+        int event_mask = 0;
+        if( o_width != width || o_height != height ) {
+            event_mask |= GLMediaEventListener.EVENT_CHANGE_SIZE;
+        }   
+        if( o_fps != fps ) {
+            event_mask |= GLMediaEventListener.EVENT_CHANGE_FPS;
+        }
+        if( o_bps != bps ) {
+            event_mask |= GLMediaEventListener.EVENT_CHANGE_BPS;
+        }
+        if( o_totalFrames != totalFrames ) {
+            event_mask |= GLMediaEventListener.EVENT_CHANGE_LENGTH;
+        }
+        if(0==event_mask) {
+            return;
+        }
+        super.attributesUpdated(event_mask);    
+    }
+
+    /**
+     * Java callback method issued by the native OMX backend
+     */
+    private void saveAttributes() {
+        o_width = width;
+        o_height = height;
+        o_fps = fps;
+        o_bps = bps;
+        o_totalFrames = totalFrames;
+    }
+
+    private String replaceAll(String orig, String search, String repl) {
+        String dest=null;
+        // In case replaceAll / java.util.regex.* is not supported (-> CVM)
+        int i=0,j;
+        dest = new String();
+        while((j=orig.indexOf(search, i))>=0) {
+            dest=dest.concat(orig.substring(i, j));
+            dest=dest.concat(repl);
+            i=j+1;
+        }
+        return dest.concat(orig.substring(i, orig.length()));
+    }
+
+    private void errorCheckEGL(String s) {
+        int e;
+        if( (e=EGL.eglGetError()) != EGL.EGL_SUCCESS ) {
+            System.out.println("EGL Error: ("+s+"): 0x"+Integer.toHexString(e));
+        }
+    }
+
+    //
+    // OMXEventListener Support
+    //
+
+    native long _createInstance();    
+    native void _destroyInstance(long moviePtr);
+    
+    native void _detachVideoRenderer(long moviePtr); // stop before
+    native void _attachVideoRenderer(long moviePtr); // detach before
+    native void _setStream(long moviePtr, int textureNum, String path);
+    native void _activateStream(long moviePtr);
+    
+    native void _setStreamEGLImageTexture2D(long moviePtr, int i, int tex, long image, long sync);
+    native int _seek(long moviePtr, int position);
+    native void _setPlaySpeed(long moviePtr, float rate);
+    native void _play(long moviePtr);
+    native void _pause(long moviePtr);
+    native void _stop(long moviePtr);
+    native int  _getNextTextureID(long moviePtr);
+    native int _getCurrentPosition(long moviePtr);
+}
+