talksik
86 lines
2.7 KiB
C
86 lines
2.7 KiB
C
#include <gst/gst.h>
|
|
#include <string.h>
|
|
|
|
typedef struct _RecordCamera {
|
|
GstElement *Rpipeline;
|
|
GstElement *Raudiosource;
|
|
GstElement *Rvideosource;
|
|
GstElement *Raudioenc;
|
|
GstElement *Rvideoenc;
|
|
GstElement *Rmux;
|
|
GstElement *Rqueue;
|
|
GstElement *Rsink;
|
|
GstBus *Rbus;
|
|
GMainLoop *Rloop;
|
|
GstState Rstate;
|
|
gint64 Rcurrent;
|
|
} RecordCamera;
|
|
|
|
static gboolean refresh_handler(RecordCamera *Rdata) {
|
|
if(!Rdata->Rstate == GST_STATE_PLAYING)
|
|
return TRUE;
|
|
|
|
if(!gst_element_query_position(Rdata->Rvideosource, GST_FORMAT_TIME, &Rdata->Rcurrent)) {
|
|
g_printerr("Error: could not query current position.\n");
|
|
}
|
|
|
|
g_print("Duration: %" GST_TIME_FORMAT "\r", GST_TIME_ARGS(Rdata->Rcurrent));
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
int main(int argc, char *argv[]) {
|
|
RecordCamera Rdata;
|
|
GstStateChangeReturn ret;
|
|
|
|
gst_init(&argc, &argv);
|
|
memset(&Rdata, 0, sizeof(Rdata));
|
|
Rdata.Rstate = GST_STATE_NULL;
|
|
|
|
Rdata.Raudiosource = gst_element_factory_make("audiotestsrc", "audio-source");
|
|
Rdata.Rvideosource = gst_element_factory_make("videotestsrc", "video-source");
|
|
Rdata.Raudioenc = gst_element_factory_make("voaacenc", "audio-enc");
|
|
Rdata.Rvideoenc = gst_element_factory_make("jpegenc", "video-enc");
|
|
Rdata.Rqueue = gst_element_factory_make("queue", "audio-queue");
|
|
Rdata.Rmux = gst_element_factory_make("avimux", "record-mux");
|
|
Rdata.Rsink = gst_element_factory_make("filesink", "record-sink");
|
|
Rdata.Rpipeline = gst_pipeline_new("record-pipeline");
|
|
|
|
if(!Rdata.Rpipeline || !Rdata.Raudiosource || !Rdata.Rvideosource || !Rdata.Rqueue ||
|
|
!Rdata.Raudioenc || !Rdata.Rvideoenc || !Rdata.Rmux || !Rdata.Rsink) {
|
|
g_printerr("Error: One or more element could't be created.\n");
|
|
return -1;
|
|
}
|
|
|
|
gst_bin_add_many(GST_BIN(Rdata.Rpipeline), Rdata.Rvideosource, Rdata.Raudiosource,
|
|
Rdata.Rqueue, Rdata.Raudioenc, Rdata.Rvideoenc, Rdata.Rmux, Rdata.Rsink, NULL);
|
|
if(!gst_element_link_many(Rdata.Raudiosource, Rdata.Raudioenc, Rdata.Rqueue, Rdata.Rmux, NULL)) {
|
|
g_printerr("Error(audio): Element could't be lined.\n");
|
|
return -1;
|
|
}
|
|
if(!gst_element_link_many(Rdata.Rvideosource, Rdata.Rvideoenc, Rdata.Rmux, Rdata.Rsink, NULL)) {
|
|
g_printerr("Error(video): Element could't be lined.\n");
|
|
return -1;
|
|
}
|
|
|
|
g_object_set(Rdata.Rsink, "location", "test.mp4", NULL);
|
|
// g_object_set(Rdata.Raudiosource, "device", "hw:1,0", NULL);
|
|
// g_object_set(Rdata.Rvideosource, "device", "/dev/video0", NULL);
|
|
|
|
ret = gst_element_set_state(Rdata.Rpipeline, GST_STATE_PLAYING);
|
|
|
|
Rdata.Rloop = g_main_loop_new(NULL, FALSE);
|
|
|
|
g_print("Recording...\n");
|
|
g_print("\n");
|
|
|
|
g_timeout_add(1, (GSourceFunc)refresh_handler, &Rdata);
|
|
g_main_loop_run(Rdata.Rloop);
|
|
|
|
g_main_loop_unref(Rdata.Rloop);
|
|
gst_element_set_state(Rdata.Rpipeline, GST_STATE_NULL);
|
|
gst_object_unref(Rdata.Rpipeline);
|
|
|
|
return 0;
|
|
}
|