Ошибка утечки памяти GStreamer

Question

У меня есть объект для создания видео с помощью GStreamer. Каждый раз, когда я хочу создать новое видео, создайте один новый объект и добавьте фреймы. После завершения видео я удаляю объект, но внутренняя память GStreamer выглядит как не выпущенная.

После того, как было создано несколько видеороликов, выделена вся RAM, а linux убивает процесс.

Почему это происходит? Как я могу решить эту проблему? Есть ли другой способ сделать это?

GVideo.h:

#ifndef GVIDEO_H 
#define GVIDEO_H 

#include <gst/gst.h> 

#include <string> 

class GVideo 
{ 
public: 
    GVideo(); 
    ~GVideo(); 

    void startVideo(std::string filename); 
    void endVideo(); 

    void addFrame(GstSample* element); 

    bool isRecording(){return _isRecording;} 
    bool isDataNeed(){return _dataNeed;} 
private: 
    void setDataNeed(bool dataNeed){_dataNeed = dataNeed;} 

protected: 
    bool _isRecording; 
    bool _dataNeed; 
    int _frameRate; 
    int _duration; 
    GstClockTime _timestamp; 

    GstElement *_pipeline; 
    GstElement *_source; 
}; 

#endif //GVIDEO_H 

GVideo.cpp

#include "GVideo.h" 

#include <gst/app/gstappsrc.h> 

#include <iostream> 

static gboolean bus_video_call(GstBus* bus, GstMessage* msg, void* user_data) 
{ 
    //std::cout << "BUS_CALL" << std::endl; 

    GVideo* video = (GVideo*)user_data; 

    switch (GST_MESSAGE_TYPE(msg)) 
    { 
     case GST_MESSAGE_EOS: 
      { 
       std::cout << "VIDEO GST_MESSAGE_EOS" << std::endl; 

       video->endVideo(); 

       break; 
      } 
     case GST_MESSAGE_ERROR: 
      { 
       std::cout << "GST_MESSAGE_ERROR" << std::endl; 

       GError *err; 
       gst_message_parse_error(msg, &err, NULL); 
       g_error("%s", err->message); 
       g_error_free(err); 

       video->endVideo(); 

       break; 
      } 
     default: 
      break; 
    } 

    return true; 
} 

GVideo::GVideo() 
    : _dataNeed(false), _isRecording(false) 
{ 
    _pipeline  = NULL; 
    _source  = NULL; 
} 

GVideo::~GVideo() 
{ 
    std::cout << "Deleting GstVideo." << std::endl; 

    if(_pipeline != NULL) 
     endVideo(); 
} 

void GVideo::startVideo(std::string filename) 
{ 
    _isRecording = true; 

    _frameRate = 2; 
    _duration = 5; 
    _timestamp = 0; 
    _dataNeed = true; 
    _pipeline  = gst_pipeline_new ("video_pipeline"); 
    _source  = gst_element_factory_make ("appsrc"  , "video_source"); 
    GstElement* _videorate = gst_element_factory_make ("videorate" , "video_vidrate"); 
    GstElement* _capsfilter = gst_element_factory_make ("capsfilter" , "video_capsfilter"); 
    GstElement* _videoconvert = gst_element_factory_make ("videoconvert", "video_conv"); 
    GstElement* _encoder  = gst_element_factory_make ("x264enc"  , "video_enc"); 
    GstElement* _muxer  = gst_element_factory_make ("mp4mux"  , "video_mux"); 
    GstElement* _filesink  = gst_element_factory_make ("filesink" , "video_filesink"); 

// g_object_set (G_OBJECT (_source), "num-buffers", _duration*_frameRate, NULL); 
    g_object_set (G_OBJECT (_source), "caps", 
        gst_caps_new_simple ("video/x-raw", 
             "format", G_TYPE_STRING, "I420", 
             "width", G_TYPE_INT, 352, 
             "height", G_TYPE_INT, 288, 
             "framerate", GST_TYPE_FRACTION, _frameRate, 1, 
             NULL), NULL); 

    /* setup appsrc */ 
    g_object_set (G_OBJECT (_source), 
    //    "do-timestamp", TRUE, 
        "stream-type", GST_APP_STREAM_TYPE_STREAM, 
        "format", GST_FORMAT_TIME, NULL); 

    g_object_set (G_OBJECT (_capsfilter), "caps", 
        gst_caps_new_simple ("video/x-raw", 
//          "format", G_TYPE_STRING, "I420", 
             "framerate", GST_TYPE_FRACTION, 30, 1, 
             NULL), NULL); 

    gst_bin_add_many (GST_BIN (_pipeline), _source, _videorate, _capsfilter, _videoconvert, _encoder, _muxer, _filesink, NULL); 
    gst_element_link_many (_source, _videorate, _capsfilter, _videoconvert, _encoder, _muxer, _filesink, NULL); 

    g_object_set (G_OBJECT (_filesink), "location", filename.c_str(), NULL); 

    GstBus* bus = gst_pipeline_get_bus(GST_PIPELINE(_pipeline)); 
    gst_bus_add_watch(bus, bus_video_call, this); 
    gst_object_unref(bus); 

    gst_element_set_state (_pipeline, GST_STATE_PLAYING); 
} 

void GVideo::addFrame(GstSample* element) 
{ 
    GstBuffer* buf = gst_sample_get_buffer((GstSample*)element); 

    GST_BUFFER_PTS (buf) = _timestamp; 
    GST_BUFFER_DURATION (buf) = gst_util_uint64_scale_int (1, GST_SECOND, _frameRate); 
    _timestamp += GST_BUFFER_DURATION (buf); 

    gst_app_src_push_sample(GST_APP_SRC(_source), element); 

    if(_timestamp >= _duration*GST_SECOND) 
    { 
     _dataNeed = false; 
     gst_app_src_end_of_stream(GST_APP_SRC(_source)); 
    } 
} 

void GVideo::endVideo() 
{ 
    std::cout << "gst_element_set_state." << std::endl; 
    gst_element_set_state (_pipeline, GST_STATE_NULL); 
    std::cout << "gst_object_unref." << std::endl; 
    gst_object_unref(_pipeline); 
    std::cout << "_pipeline= NULL." << std::endl; 
    _pipeline = NULL; 
    std::cout << "setDataNeed." << std::endl; 
    _isRecording = false; 
} 

Answer 1

Я предположил бы, что все, что звонит ADDFRAME(), возможно, потребуется UNREF образца.

https://gstreamer.freedesktop.org/data/doc/gstreamer/head/gst-plugins-base-libs/html/gst-plugins-base-libs-appsrc.html#gst-app-src-push-sample

В Документах там не указано «передачи: нет» на параметр sample, который я считаю, означает, что абонент должен UNREF. По какой-то причине более старый метод gst_app_src_push_buffer имеет передачу «полный». Не знаю почему.

https://gstreamer.freedesktop.org/data/doc/gstreamer/head/gst-plugins-base-libs/html/gst-plugins-base-libs-appsrc.html#gst-app-src-push-buffer