0

我没有成功使用 gst1 Java 绑定设置简单的 decodebin GST 管道。我在 decodebin 中收到“内部数据流错误”错误。我使用 gst1-java-core 做错了吗？

还想知道是否使用 EOS 侦听器来确定管道是否异步结束是使用管道的正确方法？

    public static void main(String[] args) throws InterruptedException
    {
        Gst.init();

        System.out.println("Version: " + Gst.getVersionString());
        System.out.println("Source: " + args[0]);
        System.out.println("Target: " + args[1]);

        final Pipeline pipeline   = new Pipeline("MyPipeline");

        Element        fileSource = ElementFactory.make("filesrc", "MyFile");
        fileSource.set("location", args[0]);

        Element decode   = ElementFactory.make("decodebin", "decode");

        Element fileSink = ElementFactory.make("filesink", "MyTargetFile");
        fileSink.set("location", args[1]);

        pipeline.addMany(fileSource, decode, fileSink);
        Element.linkMany(fileSource, decode, fileSink);

        final CountDownLatch latch = new CountDownLatch(1);

        // end of stream listener
        EOS eos = new EOS()
        {
            public void endOfStream(GstObject source)
            {
                System.out.println(String.format("EOS for (%s)", source));
                latch.countDown();
            }
        };

        // state change listener
        STATE_CHANGED state = new STATE_CHANGED()
        {
            public void stateChanged(GstObject source, State old, State current, State pending)
            {
                System.out.println(String.format("State changed for (%s) from (%s) to (%s)", source, old, current));
            }
        };

        // error listener
        ERROR error = new ERROR()
        {
            public void errorMessage(GstObject source, int code, String message)
            {
                System.err.println(String.format("Error (%d) for (%s): %s", code, source, message));
                latch.countDown();
            }
        };

        pipeline.getBus().connect(error);
        pipeline.getBus().connect(state);
        pipeline.getBus().connect(eos);
        StateChangeReturn stateReturn = pipeline.play();

        System.out.println("State return: " + stateReturn);

        synchronized (latch)
        {
            latch.await();
        }

        pipeline.setState(State.NULL);
        pipeline.close();

        Gst.deinit();
    }

Version: GStreamer 1.18.4
Source: /tmp/Imagine_Demo.mp4
Target: /tmp/out.yuv
State return: ASYNC
State changed for (BaseSink: [MyTargetFile]) from (NULL) to (READY)
State changed for (Element: [typefind]) from (NULL) to (READY)
State changed for (DecodeBin: [decode]) from (NULL) to (READY)
State changed for (BaseSrc: [MyFile]) from (NULL) to (READY)
State changed for (Pipeline: [MyPipeline]) from (NULL) to (READY)
State changed for (Element: [typefind]) from (READY) to (PAUSED)
State changed for (BaseSrc: [MyFile]) from (READY) to (PAUSED)
State changed for (Element: [qtdemux0]) from (NULL) to (READY)
State changed for (Element: [qtdemux0]) from (READY) to (PAUSED)
State changed for (Element: [h264parse0]) from (NULL) to (READY)
State changed for (Element: [h264parse0]) from (READY) to (PAUSED)
State changed for (Element: [avdec_h264-0]) from (NULL) to (READY)
State changed for (Element: [avdec_h264-0]) from (READY) to (PAUSED)
State changed for (Element: [aacparse0]) from (NULL) to (READY)
State changed for (Element: [aacparse0]) from (READY) to (PAUSED)
State changed for (Element: [avdec_aac0]) from (NULL) to (READY)
State changed for (Element: [avdec_aac0]) from (READY) to (PAUSED)
State changed for (DecodeBin: [decode]) from (READY) to (PAUSED)
Error (1) for (Element: [qtdemux0]): Internal data stream error.
State changed for (BaseSink: [MyTargetFile]) from (PLAYING) to (PAUSED)
State changed for (BaseSink: [MyTargetFile]) from (READY) to (READY)
State changed for (BaseSink: [MyTargetFile]) from (READY) to (NULL)
State changed for (Element: [avdec_aac0]) from (PAUSED) to (READY)
State changed for (Element: [aacparse0]) from (PAUSED) to (READY)
State changed for (Element: [avdec_h264-0]) from (PAUSED) to (READY)
State changed for (BaseTransform: [capsfilter0]) from (PAUSED) to (READY)
State changed for (Element: [h264parse0]) from (PAUSED) to (READY)
State changed for (Element: [multiqueue0]) from (PAUSED) to (READY)
State changed for (Element: [qtdemux0]) from (PAUSED) to (READY)
State changed for (Element: [typefind]) from (PAUSED) to (READY)
State changed for (Element: [avdec_aac0]) from (READY) to (NULL)
State changed for (Element: [aacparse0]) from (READY) to (NULL)
State changed for (Element: [avdec_h264-0]) from (READY) to (NULL)
State changed for (BaseTransform: [capsfilter0]) from (READY) to (NULL)
State changed for (Element: [h264parse0]) from (READY) to (NULL)
State changed for (Element: [multiqueue0]) from (READY) to (NULL)
State changed for (Element: [qtdemux0]) from (READY) to (NULL)
State changed for (DecodeBin: [decode]) from (PAUSED) to (READY)
State changed for (Element: [typefind]) from (READY) to (NULL)
State changed for (DecodeBin: [decode]) from (READY) to (NULL)
State changed for (BaseSrc: [MyFile]) from (PAUSED) to (READY)
State changed for (BaseSrc: [MyFile]) from (READY) to (NULL)
DtsGetHWFeatures: Create File Failed
DtsGetHWFeatures: Create File Failed
Running DIL (3.22.0) Version
DtsDeviceOpen: Opening HW in mode 0
DtsDeviceOpen: Create File Failed

但是，当我在控制台中的同一台计算机上运行管道时，它可以正常工作：

$ gst-launch-1.0 filesrc location=/tmp/Imagine_Demo.mp4 ! decodebin ! filesink location=/tmp/out.yuv
Setting pipeline to PAUSED ...
Pipeline is PREROLLING ...
DtsGetHWFeatures: Create File Failed
DtsGetHWFeatures: Create File Failed
Running DIL (3.22.0) Version
DtsDeviceOpen: Opening HW in mode 0
DtsDeviceOpen: Create File Failed
Redistribute latency...
Redistribute latency...
Pipeline is PREROLLED ...
Setting pipeline to PLAYING ...
New clock: GstSystemClock
Got EOS from element "pipeline0".
Execution ended after 0:00:04.713531469
Setting pipeline to NULL ...
Freeing pipeline ...
4

0 回答 0