Merge pull request #52 from lafoletc/AllocationQuery

Add AllocationQuery

Author: neilcsmith-net

src/org/freedesktop/gstreamer/BufferPool.java

@@ -0,0 +1,55 @@
+/*
+ * Copyright (c) 2016 Christophe Lafolet
+ *
+ * This file is part of gstreamer-java.
+ *
+ * This code is free software: you can redistribute it and/or modify it under
+ * the terms of the GNU Lesser General Public License version 3 only, as
+ * published by the Free Software Foundation.
+ *
+ * This code 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 Lesser General Public License
+ * version 3 for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * version 3 along with this work.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.freedesktop.gstreamer;
+
+import org.freedesktop.gstreamer.lowlevel.GstBufferPoolAPI;
+
+import com.sun.jna.Pointer;
+
+public class BufferPool extends GstObject {
+
+    public static final String GTYPE_NAME = "GstBufferPool";
+
+    /**
+     * This constructor is for internal use only.
+     * @param init initialization data.
+     */
+    public BufferPool(final Initializer init) {
+        super(init);
+    }
+
+    /**
+     * Creates a new instance of BufferPool
+     */
+    public BufferPool() {
+        this(initializer(GstBufferPoolAPI.GSTBUFFERPOOL_API.ptr_gst_buffer_pool_new()));
+    }
+
+    public void setParams(Caps caps, int size, int min_buffers, int max_buffers) {
+    	Structure config = GstBufferPoolAPI.GSTBUFFERPOOL_API.gst_buffer_pool_get_config(this);
+    	GstBufferPoolAPI.GSTBUFFERPOOL_API.gst_buffer_pool_config_set_params(config, caps, size, min_buffers, max_buffers);
+    }
+
+    public Caps getCaps() {
+    	Structure config = GstBufferPoolAPI.GSTBUFFERPOOL_API.gst_buffer_pool_get_config(this);
+    	Pointer[] ptr = new Pointer[1];
+    	GstBufferPoolAPI.GSTBUFFERPOOL_API.gst_buffer_pool_config_get_params(config, ptr, null, null, null);
+    	return new Caps(new Initializer(ptr[0], false, true));
+    }
+
+}

src/org/freedesktop/gstreamer/Gst.java

@@ -448,11 +448,13 @@ private static synchronized void loadAllClasses() {
 		GDate.class,
 		GValue.class,
 		GValueArray.class,
+        TagList.class,
 		TimedValue.class,
 		ValueArray.class,
 		ValueList.class,
 		// ----------- Base -------------
 		Buffer.class,
+		BufferPool.class,
 		Bus.class,
 		Caps.class,
 		Clock.class,
@@ -480,8 +482,6 @@ private static synchronized void loadAllClasses() {
 		DecodeBin.class,
 		Pipeline.class,
 		PlayBin.class,
-		URIDecodeBin.class,
-        //
-        TagList.class
+		URIDecodeBin.class
 	};
 }

src/org/freedesktop/gstreamer/elements/BaseSink.java

@@ -28,7 +28,11 @@
 import org.freedesktop.gstreamer.MiniObject;
 import org.freedesktop.gstreamer.Pad;
 import org.freedesktop.gstreamer.lowlevel.BaseSinkAPI;
+import org.freedesktop.gstreamer.lowlevel.BaseSinkAPI.GstBaseSinkClass;
+import org.freedesktop.gstreamer.lowlevel.BaseSinkAPI.GstBaseSinkStruct;
+import org.freedesktop.gstreamer.lowlevel.BaseSinkAPI.ProposeAllocation;
 import org.freedesktop.gstreamer.lowlevel.GstAPI;
+import org.freedesktop.gstreamer.query.AllocationQuery;
 
 import com.sun.jna.Pointer;
 
@@ -202,5 +206,33 @@ public void connect(final PREROLL_HANDOFF listener) {
      */
     public void disconnect(PREROLL_HANDOFF listener) {
         disconnect(PREROLL_HANDOFF.class, listener);
-    }    
+    }
+    
+    /**
+     * Signal emitted when this {@link BaseSink} received a {@link ProposeAllocation} query.
+     *
+     * @see #setProposeAllocationHandler(ProposeAllocationHandler)
+     */
+    public static interface ProposeAllocationHandler {
+    	public boolean proposeAllocation(BaseSink sink, AllocationQuery query);    	
+    }
+    
+    /**
+     * Set a handler for the {@link ProposeAllocation} query on this sink
+     *
+     * @param handler The handler to be called when a {@link ProposeAllocation} is received.
+     */
+    public void setProposeAllocationHandler(final ProposeAllocationHandler handler) {
+        GstBaseSinkStruct struct = new GstBaseSinkStruct(handle());
+        struct.readField("element");
+        GstBaseSinkClass basesinkClass = new GstBaseSinkClass(struct.element.object.object.g_type_instance.g_class.getPointer());
+        basesinkClass.propose_allocation = new ProposeAllocation() {
+			@Override
+			public boolean callback(BaseSink sink, AllocationQuery query) {
+				return handler.proposeAllocation(sink, query);
+			}
+        };
+        basesinkClass.writeField("propose_allocation");
+    }
+
 }