May 14, 2025 · May 2, 2025 · May 2, 2025 · May 3, 2025 · May 5, 2025 · May 5, 2025
diff --git a/modules/videoio/misc/java/gen_dict.json b/modules/videoio/misc/java/gen_dict.json
            "jn_type": "IStreamReader",
            "jni_name": "n_%(n)s",
            "jni_type": "jclass",
            "jni_var": "auto n_%(n)s = makePtr<JavaStreamReader>(source)",
            "jni_var": "auto n_%(n)s = makePtr<JavaStreamReader>(env,source)",
            "j_import": "org.opencv.videoio.IStreamReader"
        }
    }
diff --git a/modules/videoio/misc/java/src/cpp/videoio_converters.hpp b/modules/videoio/misc/java/src/cpp/videoio_converters.hpp
 #pragma once

 class JavaStreamReader : public cv::IStreamReader
 {
 public:
    JavaStreamReader(jclass _jobject) : jobject(_jobject) {}
    JavaStreamReader(JNIEnv* _env,jclass _jobject) : env(_env), jobject(_jobject) {}

    long long read(char* buffer, long long size) CV_OVERRIDE
    {
        printf("native read\n");
        return 0;
        jmethodID m_read = env->GetMethodID(env->GetObjectClass(jobject), "read", "([BJ)J");
        if (!m_read)
            return 0;
        jbyteArray jBuffer = env->NewByteArray(size);
        if (!jBuffer)
            return 0;
        jlong res = env->CallIntMethod(jobject, m_read, jBuffer, size);
        env->GetByteArrayRegion(jBuffer, 0, size, reinterpret_cast<jbyte*>(buffer));
        return res;
    }

    long long seek(long long offset, int way) CV_OVERRIDE
    {
        printf("native seek\n");
        return 0;
        jmethodID m_seek = env->GetMethodID(env->GetObjectClass(jobject), "seek", "(JJ)J");
        if (!m_seek)
            return 0;
        jlong res = env->CallIntMethod(jobject, m_seek, offset, way);
        return res;
    }

 private:
    JNIEnv* env;
    jclass jobject;
 };
diff --git a/modules/videoio/misc/java/src/java/videoio+IStreamReader.java b/modules/videoio/misc/java/src/java/videoio+IStreamReader.java
 package org.opencv.videoio;

 public interface IStreamReader {
    public int seek(int offset, int origin);
    public long read(byte[] buffer, long size);
    public long seek(long offset, long origin);
 }
diff --git a/modules/videoio/misc/java/test/VideoCaptureTest.java b/modules/videoio/misc/java/test/VideoCaptureTest.java
 package org.opencv.test.videoio;

 import java.util.List;
 import java.io.File;
 import java.io.RandomAccessFile;
 import java.io.IOException;
 import java.io.FileNotFoundException;

 import org.opencv.core.Mat;
 import org.opencv.core.Size;
 import org.opencv.core.MatOfInt;
 import org.opencv.videoio.Videoio;
 import org.opencv.videoio.VideoCapture;
 import org.opencv.videoio.IStreamReader;

 import org.opencv.test.OpenCVTestCase;

 public class VideoCaptureTest extends OpenCVTestCase {
    private final static String ENV_OPENCV_TEST_DATA_PATH = "OPENCV_TEST_DATA_PATH";

    private VideoCapture capture;
    private boolean isOpened;
    private boolean isSucceed;
    private File testDataPath;

    @Override
    protected void setUp() throws Exception {
        super.setUp();

        capture = null;
        // isTestCaseEnabled = false;
        isSucceed = false;
        isOpened = false;

        String envTestDataPath = System.getenv(ENV_OPENCV_TEST_DATA_PATH);

        if(envTestDataPath == null) throw new Exception(ENV_OPENCV_TEST_DATA_PATH + " has to be defined!");

        testDataPath = new File(envTestDataPath);
    }

    // public void testGrab() {
    //     assertNotNull(capture);
    // }

    public void testConstructorStream() {
    public void testConstructorStream() throws FileNotFoundException {
        RandomAccessFile f = new RandomAccessFile(new File(testDataPath, "cv/video/768x576.avi"), "r");

        IStreamReader stream = new IStreamReader() {
            // @Override
            // public int read(String buffer, int size) {
            //     return 0;
            // }
            @Override
            public long read(byte[] buffer, long size) {
                try
                {
                    return f.read(buffer);
                }
                catch (IOException e)
                {
                    System.out.println(e.getMessage());
                    return 0;
                }
            }

            @Override
            public int seek(int offset, int origin) {
                System.out.println("java seek");
                return 0;
            public long seek(long offset, long origin) {
                try
                {
                    if (origin == 0)
                    {
                        f.seek(offset);
                        return offset;
                    }
                    else
                        throw new IOException("seek");
                }
                catch (IOException e)
                {
                    System.out.println(e.getMessage());
                    return 0;
                }
            }
        };
        capture = new VideoCapture(stream, Videoio.CAP_ANY, null);
        capture = new VideoCapture(stream, Videoio.CAP_FFMPEG, new MatOfInt());
        assertNotNull(capture);
        assertTrue(capture.isOpened());

        Mat frame = new Mat();
        assertTrue(capture.read(frame));
        assertEquals(frame.rows(), 576);
        assertEquals(frame.cols(), 768);
    }
 }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -5,7 +5,7 @@
		"jn_type": "IStreamReader",
		"jni_name": "n_%(n)s",
		"jni_type": "jclass",
		"jni_var": "auto n_%(n)s = makePtr<JavaStreamReader>(source)",
		"jni_var": "auto n_%(n)s = makePtr<JavaStreamReader>(env,source)",
		"j_import": "org.opencv.videoio.IStreamReader"
		}
		}
Expand Down
Original file line number	Diff line number	Diff line change
		@@ -1,20 +1,33 @@
		#pragma once

		class JavaStreamReader : public cv::IStreamReader
		{
		public:
		JavaStreamReader(jclass _jobject) : jobject(_jobject) {}
		JavaStreamReader(JNIEnv* _env,jclass _jobject) : env(_env), jobject(_jobject) {}

		long long read(char* buffer, long long size) CV_OVERRIDE
		{
		printf("native read\n");
		return 0;
		jmethodID m_read = env->GetMethodID(env->GetObjectClass(jobject), "read", "([BJ)J");
		if (!m_read)
		return 0;
		jbyteArray jBuffer = env->NewByteArray(size);
		if (!jBuffer)
		return 0;
		jlong res = env->CallIntMethod(jobject, m_read, jBuffer, size);
		env->GetByteArrayRegion(jBuffer, 0, size, reinterpret_cast<jbyte*>(buffer));
		return res;
		}

		long long seek(long long offset, int way) CV_OVERRIDE
		{
		printf("native seek\n");
		return 0;
		jmethodID m_seek = env->GetMethodID(env->GetObjectClass(jobject), "seek", "(JJ)J");
		if (!m_seek)
		return 0;
		jlong res = env->CallIntMethod(jobject, m_seek, offset, way);
		return res;
		}

		private:
		JNIEnv* env;
		jclass jobject;
		};
Original file line number	Diff line number	Diff line change
		@@ -1,5 +1,6 @@
		package org.opencv.videoio;

		public interface IStreamReader {
		public int seek(int offset, int origin);
		public long read(byte[] buffer, long size);
dkurt marked this conversation as resolved. OutdatedShow resolvedHide resolved
		public long seek(long offset, long origin);
		}
Original file line number	Diff line number	Diff line change
		@@ -1,28 +1,41 @@
		package org.opencv.test.videoio;

		import java.util.List;
		import java.io.File;
		import java.io.RandomAccessFile;
		import java.io.IOException;
		import java.io.FileNotFoundException;

		import org.opencv.core.Mat;
		import org.opencv.core.Size;
		import org.opencv.core.MatOfInt;
		import org.opencv.videoio.Videoio;
		import org.opencv.videoio.VideoCapture;
		import org.opencv.videoio.IStreamReader;

		import org.opencv.test.OpenCVTestCase;

		public class VideoCaptureTest extends OpenCVTestCase {
		private final static String ENV_OPENCV_TEST_DATA_PATH = "OPENCV_TEST_DATA_PATH";

		private VideoCapture capture;
		private boolean isOpened;
		private boolean isSucceed;
		private File testDataPath;

		@Override
		protected void setUp() throws Exception {
		super.setUp();

		capture = null;
		// isTestCaseEnabled = false;
		isSucceed = false;
		isOpened = false;

		String envTestDataPath = System.getenv(ENV_OPENCV_TEST_DATA_PATH);

		if(envTestDataPath == null) throw new Exception(ENV_OPENCV_TEST_DATA_PATH + " has to be defined!");

		testDataPath = new File(envTestDataPath);
		}

		// public void testGrab() {
Expand DownExpand Up		@@ -62,21 +75,49 @@ protected void setUp() throws Exception {
		// assertNotNull(capture);
		// }

		public void testConstructorStream() {
		public void testConstructorStream() throws FileNotFoundException {
		RandomAccessFile f = new RandomAccessFile(new File(testDataPath, "cv/video/768x576.avi"), "r");

		IStreamReader stream = new IStreamReader() {
		// @Override
		// public int read(String buffer, int size) {
		// return 0;
		// }
		@Override
		public long read(byte[] buffer, long size) {
		try
		{
		return f.read(buffer);
		}
		catch (IOException e)
		{
		System.out.println(e.getMessage());
		return 0;
		}
		}

		@Override
		public int seek(int offset, int origin) {
		System.out.println("java seek");
		return 0;
		public long seek(long offset, long origin) {
		try
		{
		if (origin == 0)
		{
		f.seek(offset);
		return offset;
		}
		else
		throw new IOException("seek");
		}
		catch (IOException e)
		{
		System.out.println(e.getMessage());
		return 0;
		}
		}
		};
		capture = new VideoCapture(stream, Videoio.CAP_ANY, null);
		capture = new VideoCapture(stream, Videoio.CAP_FFMPEG, new MatOfInt());
		assertNotNull(capture);
		assertTrue(capture.isOpened());

		Mat frame = new Mat();
		assertTrue(capture.read(frame));
		assertEquals(frame.rows(), 576);
		assertEquals(frame.cols(), 768);
		}
		}