stream - Gstreamer - appsrc push model -


i'm developing c application (under linux) receives raw h.264 stream , should visualize stream using gstreamer apis. newbie gstreamer maybe doing huge stupid mistakes or ignoring well-known stuff, sorry that.

i got raw h264 video (i knew exact same format need) , developed application plays it. correctly works appsrc in pull mode (when need data called, new data file , perform push-buffer).

now i'm trying exact same thing in push mode, because don't have video, stream. have method inside code called every time new data (in form of uint8_t buffer) arrives, , video source.

i googled problem , had @ documentation, found no simple code snippets use case, if seems simple one. understood have init pipeline , appsrc , push-buffer when have new data.

well, developed 2 methods: init_stream() pipeline/appsrc initialization , populate_app(void *inbuf, size_t len) send data when available. compiles , correctly runs, no video:

struct _app {     gstappsrc *appsrc;     gstpipeline *pipeline;     gstelement *h264parse;     gstelement *mfw_vpudecoder;     gstelement *mfw_v4lsin;     gmainloop *loop; };  typedef struct _app app; app s_app; app *app = &s_app;   static gboolean bus_message (gstbus * bus, gstmessage * message, app * app) {     gst_debug ("got message %s", gst_message_type_get_name (gst_message_type (message)));      switch (gst_message_type (message)) {         case gst_message_error:             g_error ("received error");             g_main_loop_quit (app->loop);             break;         case gst_message_eos:             g_main_loop_quit (app->loop);             break;         default:             break;     }     return true; }  int init_stream() {     gstbus *bus;      gst_init (null, null);     fprintf(stderr, "gst_init done\n");      /* create mainloop messages */     app->loop = g_main_loop_new (null, true);     fprintf(stderr, "app loop initialized\n");       app->pipeline = gst_parse_launch("appsrc name=mysource ! h264parse ! mfw_vpudecoder ! mfw_v4lsin", null);      app->appsrc = gst_bin_get_by_name (gst_bin(app->pipeline), "mysource");     gst_app_src_set_stream_type(app->appsrc, gst_app_stream_type_stream);      gst_app_src_set_emit_signals(app->appsrc, true);     fprintf(stderr, "pipeline , appsrc initialized\n");      /* create bus pipeline */     bus = gst_pipeline_get_bus(app->pipeline);     fprintf(stderr, "bus created\n");      /* add watch messages */     gst_bus_add_watch (bus, (gstbusfunc) bus_message, app);     gst_object_unref(bus);     fprintf(stderr, "bus_add_watch done\n");      gstcaps* video_caps = gst_caps_new_simple ("video/x-h264",                                          "width", g_type_int, 800,                                          "height", g_type_int, 480,                                          "framerate", gst_type_fraction, 25,                                          1, null);      gst_app_src_set_caps(gst_app_src(app->appsrc), video_caps);      /* go playing , wait in mainloop. */     gst_element_set_state ((gstelement*) app->pipeline, gst_state_playing);     fprintf(stderr, "gst_element_set_state play\n");      /* mainloop stopped when receive error or eos */     g_main_loop_run (app->loop);     fprintf(stderr, "g_main_loop_run called\n");      gst_element_set_state ((gstelement*) app->pipeline, gst_state_null);      fprintf(stderr, "gst_element_set_state gst_state_null\n");      /* free file */     // g_mapped_file_unref (app->file);      gst_object_unref (bus);     g_main_loop_unref (app->loop);      return 0; }  void populateapp(void  *inbuf ,  size_t len) {      guint8 *_buffer = (guint8*) inbuf;     gstflowreturn ret;     gstbuffer *buffer = gst_buffer_new();      gstcaps* video_caps = gst_caps_new_simple ("video/x-h264",                                                "width", g_type_int, 800,                                                "height", g_type_int, 480,                                                "framerate", gst_type_fraction, 25,                                                1, null);  gst_buffer_set_caps(buffer, video_caps);      gst_buffer_data (buffer) = _buffer;     gst_buffer_size (buffer) = len;      // g_signal_emit_by_name (app->appsrc, "push-buffer", buffer, &ret);     ret = gst_app_src_push_buffer(gst_app_src(app->appsrc), buffer);     gst_buffer_unref (buffer); }

as said, total newbie @ gstreamer there's lot of cut-and-paste code internet, imho should work. see issues?

it's not clear how calling populateapp, need call repeatedly have data push pipeline. can done in separate thread 1 blocked g_main_loop_run, or can restructure program avoid using gmainloop.


Comments

Post a Comment

Popular posts from this blog

curl - PHP fsockopen help required -

i trying work on cloudflare api , have found in documentation. unfortunately have no idea how can use in fsockopen or through curl. here example of post request. need know how can make request below data post using curl or fsockopen curl https://www.cloudflare.com/api_json.html -d 'a=cache_lvl' \ -d 'tkn=8afbe6dea02407989af4dd4c97bb6e25' \ -d 'email=sample@example.com' \ -d 'z=example.com' \ -d 'v=agg' here link cloudflare https://www.cloudflare.com/docs/client-api.html#s4.2 try one: $ch = curl_init("https://www.cloudflare.com/api_json.html"); curl_setopt($ch, curlopt_returntransfer,1); curl_setopt($ch, curlopt_followlocation, 1); curl_setopt($ch, curlopt_ssl_verifypeer,false); // handling of -d curl parameter here. $param = array( 'a' => 'cache_lvl', 'tkn' => '8afbe6dea02407989af4dd4c97bb6e25', 'email' => 'sample@example.com', 'z' =...
Read more

HTTP/1.0 407 Proxy Authentication Required PHP -

i working in restricted network/limited access internet. since have use proxy make web service call. here php code calling web service , response . $client = new soapclient("http: //www.xyz.com/abc/wsdls/login.wsdl", array("trace" => 1, "exceptions" => 1, 'proxy_host' => $proxy_host, 'proxy_port' => $proxy_port, 'proxy_login' => $proxy_login, 'proxy_password' => $proxy_password)); response is fatal error: uncaught soapfault exception: [wsdl] soap-error: parsing wsdl: couldn't load ' http://www.xyz.com/abc/wsdls/login.wsdl ' : failed load external entity if copy url error message , paste in browser(with same proxy settings) works. 2nd scenario is, if pass values instead of variables giving me diffarant response $client = new soapclient("http: //www.xyz.com/abc/wsdls/login.wsdl", array("trace" => 1, "exceptions" => 1, 'proxy_host' ...
Read more

c# - Resource not found error -

i have problem accessing method on homecontroller. show code of method : [httpget] public actionresult decriptidentifiantetredirige(string login_crypter, string mdp_crypter) { string loginacrypter = _globalmanager.protegemotdepasse(login_crypter); string mdpacrypter = _globalmanager.protegemotdepasse(mdp_crypter); user userapp = new models.user(login_crypter, mdp_crypter); if (userapp.authentificationvalidee(userapp.userlogin, userapp.password)) { session["name"] = userapp.userlogin; return redirecttoaction("accueil", "home"); } else { return redirecttoaction("validerauthentification", "home"); } } then in routeconfig.cs wrote route : routes.maproute( name: "authentificationapresdecryptage", url: "{controller}/{action}/{login_crypter}/{mdp_crypter}", defaults: new...
Read more