Exception in thread "main" java.lang.Error: Invalid memory access

[AmitAkuka]

Hi,
I've been running lately into this issue (on version 1.22.2 and latest version 1.22.3).
The full exception output:
Exception in thread "main" java.lang.Error: Invalid memory access
at com.sun.jna.Native.invokePointer(Native Method)
at com.sun.jna.Function.invokePointer(Function.java:497)
at com.sun.jna.Function.invoke(Function.java:441)
at com.sun.jna.Function.invoke(Function.java:361)
at com.sun.jna.Library$Handler.invoke(Library.java:270)
at jdk.proxy1/jdk.proxy1.$Proxy3.gst_parse_launch(Unknown Source)
at org.freedesktop.gstreamer.Gst.parseLaunch(Gst.java:225)
at org.freedesktop.gstreamer.Gst.parseLaunch(Gst.java:256)
at com.cisco.jtapi.collabEdgeIvr.collabEdgeIvr.main(collabEdgeIvr.java:253)

Line 253: pipeline = (Pipeline) Gst.parseLaunch(pipeGreetingsDesc);
Looks like something is happening to the Gst object pointer which turns out to be a null for some reason.

[neilcsmith-net]

Can you replicate with the BasicPipeline example at https://github.com/gstreamer-java/gst1-java-examples/tree/master/BasicPipeline ?

What's the relation with com.cisco.jtapi.collabEdgeIvr?

Unfortunately we don't have CI testing on 1.22 at the moment. It could be that updates are required in the bindings. If this is for a commercial project, please contact me as covered in the readme.

[AmitAkuka]

Can you replicate with the BasicPipeline example at https://github.com/gstreamer-java/gst1-java-examples/tree/master/BasicPipeline ?

What's the relation with com.cisco.jtapi.collabEdgeIvr?

Unfortunately we don't have CI testing on 1.22 at the moment. It could be that updates are required in the bindings. If this is for a commercial project, please contact me as covered in the readme.

Hi Neil,
Further to our conversation, here is the code I'm using after I removed the additional dependencies that might be an issue.
Thank you for the support.

`package com.cisco.jtapi.collabEdgeIvr;

import java.time.format.DateTimeFormatter;
import java.time.LocalDateTime;
import java.time.DayOfWeek;
import java.time.LocalTime;

import org.freedesktop.gstreamer.Gst;
import org.freedesktop.gstreamer.GstObject;
import org.freedesktop.gstreamer.Pipeline;
import org.freedesktop.gstreamer.State;
import org.freedesktop.gstreamer.Bus;
import org.freedesktop.gstreamer.Element;

import java.util.List;

public class test {
public static Pipeline pipeline;
public static Bus bus;

static String greetingsPath;
static String closedPath;
static String pipeGreetingsDesc;
static String pipeClosedDesc;
static String destHost = "192.168.1.50";
static Integer destPort = 16895;
static Boolean isDoneResetParams;

private static DateTimeFormatter dtf = DateTimeFormatter.ofPattern("HH:mm:ss.SS");

private static void log(String msg) {
    System.out.println(dtf.format(LocalDateTime.now()) + " " + msg);
}

public static void main(String[] args) throws

InterruptedException {

    // Initialize the gstreamer-java framework Gst object
    Utils.configurePaths();
    Gst.init();

    while (true) {
        System.out.println("Running");
        isDoneResetParams = false;

        pipeGreetingsDesc = String.format(
                "filesrc location=" + greetingsPath
                        + " ! wavparse ! mulawenc ! rtppcmupay max-ptime=30000000 ! udpsink host=%s port=%s",
                destHost, destPort);

        pipeClosedDesc = String.format(
                "filesrc location=" + closedPath
                        + " ! wavparse ! mulawenc ! rtppcmupay max-ptime=30000000 ! udpsink host=%s port=%s",
                destHost, destPort);

        pipeline = (Pipeline) Gst.parseLaunch(pipeGreetingsDesc);
        bus = (Bus) pipeline.getBus();

        System.out.println(pipeline);
        System.out.println(bus);

        bus.connect(new Bus.EOS() {
            public void endOfStream(GstObject source) {
                Gst.quit();
            }
        });

        pipeline.play();
        System.out.println("PLAYING GREETING");

        Gst.main();
        System.out.println("GREETING ENDED");

        Boolean isOpen = false;
        if (!isOpen) {
            System.out.println("Closed");

            // Cleaning resources.
            List<Element> elements = pipeline.getElements();
            for (Element element : elements) {
                element.dispose();
            }
            pipeline.setState(State.NULL);
            bus.clearSyncHandler();
            Gst.invokeLater(() -> {
                pipeline.dispose();
            });

            pipeline = (Pipeline) Gst.parseLaunch(pipeClosedDesc);
            bus = (Bus) pipeline.getBus();

            System.out.println(pipeline);
            System.out.println(bus);

            bus.connect(new Bus.EOS() {
                public void endOfStream(GstObject source) {
                    Gst.quit();
                }
            });

            pipeline.play();
            System.out.println("PLAYING CLOSING");

            Gst.main();
            System.out.println("CLOSING ENDED");

            while (!isDoneResetParams) {
                log("waiting for isDoneResetParams: " + isDoneResetParams);
                Thread.sleep(1000);
            }
        }
    }
}

public static void resetParams() {
    try {
        System.out.println("Restarting params");

        try {
            if (pipeline.getState().toString().equals("PLAYING")) {
                System.out.print("pipeline is playing, disposing...");
                Gst.quit();
                List<Element> elements = pipeline.getElements();
                for (Element element : elements) {
                    element.dispose();
                }

                pipeline.setState(State.NULL);
                bus.clearSyncHandler();
                Gst.invokeLater(() -> {
                    pipeline.dispose();
                });
            }
        } catch (Exception e) {
            System.out.print("Failed to clean pipeline " + e);
        }

        System.out.println("Done cleaning");

        isDoneResetParams = true;
    } catch (Exception e) {
        System.out.println(e);
    }
}

}
`

[neilcsmith-net]

Thanks for posting the code. There are multiple issues here which would need resolving in order to confirm if there's a bug or not, so I've converted this into a discussion post.

            Gst.invokeLater(() -> {
                pipeline.dispose();
            });

            pipeline = (Pipeline) Gst.parseLaunch(pipeClosedDesc);

This is a problem - by the time the invoke later code is executed you've probably changed the pipeline reference, so you'll be disposing the pipeline you've just launched. You could possibly rewrite this to use Pipeline p = pipeline; Gst.invokeLater(p::dispose); but ideally your code needs restructuring to handle each pipeline independently.

            // Cleaning resources.
            List<Element> elements = pipeline.getElements();
            for (Element element : elements) {
                element.dispose();
            }

Where has that code come from? This is never required! You should only dispose() elements you have a direct reference to, so the pipeline. Here you are creating Java references to GStreamer elements purely to dispose of them - inefficient and occasionally a source of issues.

bus.clearSyncHandler()

A no-op - will do nothing because you're not setting one in the first place.

Gst.main();
Gst.quit();

Generally not designed for the purpose you're using them here. Set up the logic to change file / pipeline, and just use a single Gst.main() at the end of main() to stop your program from exiting.

I'm not sure why you're using multiple pipelines here? Is this for testing purposes only? Because you could use a single pipeline, or even a PlayBin with custom audio sink, and change the source file location and restart after each EOS.

[neilcsmith-net]

This should be close to what you're trying to do -

    private static List<String> files = List.of(
            greetingsPath, closedPath
    );
    
    private static int index = 0;
    private static PlayBin playbin;
    private static String sinkDesc = "mulawenc ! rtppcmupay max-ptime=30000000 ! udpsink host=127.0.0.1 port=16895";
    
    public static void main(String[] args) {
        Gst.init();
        playbin = new PlayBin("playbin");
        playbin.getBus().connect((Bus.EOS) (e -> playNext()));
        Bin sink = Gst.parseBinFromDescription(sinkDesc, true);
        playbin.setAudioSink(sink);
        playNext();
        Gst.main();
    }
    
    private static void playNext() {
        playbin.stop();
        index = (index + 1) % files.size();
        playbin.setInputFile(new File(files.get(index)));
        playbin.play();
    }