mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-06-03 05:59:44 +00:00
8df1c8a278
Original commit message from CVS: Added DivX ;-) support by using the wine .dll loader. you must unzip binaries.zip from http://divx.euro.ru/binaries.zip into the win32 directory **of the source tree**. Extended and bugfixed thr riff parser to support DivX ;-) Extended the avi parser to support DivX ;-) and MPEG Layer 3. Fixed a bug in mpg123. Sound still is seriously wrong with layer 3. Fixed MPEG2 playback in gstplay. Time indication in gstplay is temporarly broken.
323 lines
10 KiB
C
323 lines
10 KiB
C
/*
|
|
* Initial main.c file generated by Glade. Edit as required.
|
|
* Glade will not overwrite this file.
|
|
*/
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
# include <config.h>
|
|
#endif
|
|
|
|
//#define DEBUG_ENABLED
|
|
|
|
#include <gst/gstclock.h>
|
|
|
|
#include "gstplay.h"
|
|
|
|
#include "interface.h"
|
|
#include "support.h"
|
|
|
|
#include "codecs.h"
|
|
|
|
#define MUTEX_STATUS() (g_mutex_trylock(gdk_threads_mutex)? g_mutex_unlock(gdk_threads_mutex), "was not locked" : "was locked")
|
|
|
|
|
|
#define BUFFER 4
|
|
|
|
extern gboolean _gst_plugin_spew;
|
|
gboolean idle_func(gpointer data);
|
|
GstElement *show, *video_render_queue;
|
|
GstElement *audio_play, *audio_render_queue;
|
|
GstElement *src;
|
|
GstPipeline *pipeline;
|
|
GstElement *parse = NULL;
|
|
GstPlayState state;
|
|
gboolean picture_shown = FALSE;
|
|
guchar statusline[200];
|
|
guchar *statustext = "stopped";
|
|
|
|
static void frame_displayed(GstSrc *asrc)
|
|
{
|
|
int size, time, frame_time = 0, src_pos;
|
|
guint mux_rate;
|
|
static int prev_time = -1;
|
|
|
|
if (!parse) return;
|
|
return;
|
|
DEBUG("gstplay: frame displayed %s\n", MUTEX_STATUS());
|
|
|
|
mux_rate = gst_util_get_int_arg(GTK_OBJECT(parse),"mux_rate");
|
|
size = gst_util_get_int_arg(GTK_OBJECT(src),"size");
|
|
time = (size*8)/mux_rate;
|
|
frame_time = gst_util_get_int_arg(GTK_OBJECT(show),"frame_time");
|
|
src_pos = gst_util_get_int_arg(GTK_OBJECT(src),"offset");
|
|
frame_time = (src_pos*8)/mux_rate;
|
|
|
|
if (frame_time >= prev_time) {
|
|
|
|
g_snprintf(statusline, 200, "%02d:%02d / %02d:%02d\n",
|
|
frame_time/60, frame_time%60,
|
|
time/60, time%60);
|
|
|
|
//printf("%d %d %g\n", frame_time, size, frame_time*100.0/size);
|
|
|
|
update_status_area();
|
|
if (state == GSTPLAY_PLAYING)
|
|
update_slider(src_pos*100.0/size);
|
|
}
|
|
picture_shown = TRUE;
|
|
|
|
prev_time = frame_time;
|
|
DEBUG("gstplay: frame displayed end %s\n", MUTEX_STATUS());
|
|
}
|
|
|
|
gboolean idle_func(gpointer data) {
|
|
DEBUG("idle start %s\n",MUTEX_STATUS());
|
|
gst_src_push(GST_SRC(data));
|
|
DEBUG("idle stop %s\n",MUTEX_STATUS());
|
|
return TRUE;
|
|
}
|
|
|
|
static void eof(GstSrc *src) {
|
|
change_state(GSTPLAY_PAUSE);
|
|
picture_shown = TRUE;
|
|
}
|
|
|
|
void show_next_picture() {
|
|
picture_shown = FALSE;
|
|
DEBUG("gstplay: next picture %s\n", MUTEX_STATUS());
|
|
while (!picture_shown) {
|
|
gdk_threads_leave();
|
|
gst_src_push(GST_SRC(src));
|
|
gdk_threads_enter();
|
|
}
|
|
DEBUG("gstplay: next found %s\n", MUTEX_STATUS());
|
|
}
|
|
|
|
void mute_audio(gboolean mute) {
|
|
gtk_object_set(GTK_OBJECT(audio_play),"mute",mute,NULL);
|
|
}
|
|
|
|
gint delete_event(GtkWidget *widget, GdkEvent *event, gpointer data)
|
|
{
|
|
gdk_threads_leave();
|
|
g_print("setting to ~PLAYING state\n");
|
|
gst_element_set_state(GST_ELEMENT(pipeline),~GST_STATE_PLAYING);
|
|
g_print("setting to ~RUNNING state\n");
|
|
gst_element_set_state(GST_ELEMENT(pipeline),~GST_STATE_RUNNING);
|
|
gdk_threads_enter();
|
|
return FALSE;
|
|
}
|
|
|
|
void destroy(GtkWidget *widget, gpointer data)
|
|
{
|
|
|
|
gtk_main_quit();
|
|
}
|
|
|
|
void gstplay_parse_state_changed(GstElement *element, gint state, gpointer data)
|
|
{
|
|
printf("gstplay: element \"%s\" state changed %d\n", gst_element_get_name(element), state);
|
|
|
|
if (state == GST_STATE_COMPLETE) {
|
|
g_print("gstplay: setting to PLAYING state\n");
|
|
gst_element_set_state(GST_ELEMENT(pipeline),GST_STATE_PLAYING);
|
|
gst_clock_reset(gst_clock_get_system());
|
|
g_print("gstplay: PLAYING\n");
|
|
}
|
|
}
|
|
|
|
void change_state(GstPlayState new_state) {
|
|
|
|
if (new_state == state) return;
|
|
switch (new_state) {
|
|
case GSTPLAY_PLAYING:
|
|
mute_audio(FALSE);
|
|
statustext = "playing";
|
|
update_status_area();
|
|
gtk_idle_add(idle_func,src);
|
|
state = GSTPLAY_PLAYING;
|
|
update_buttons(0);
|
|
break;
|
|
case GSTPLAY_PAUSE:
|
|
statustext = "paused";
|
|
update_status_area();
|
|
if (state != GSTPLAY_STOPPED) gtk_idle_remove_by_data(src);
|
|
mute_audio(TRUE);
|
|
state = GSTPLAY_PAUSE;
|
|
update_buttons(1);
|
|
break;
|
|
case GSTPLAY_STOPPED:
|
|
if (state != GSTPLAY_PAUSE) gtk_idle_remove_by_data(src);
|
|
statustext = "stopped";
|
|
update_status_area();
|
|
mute_audio(TRUE);
|
|
state = GSTPLAY_STOPPED;
|
|
gtk_object_set(GTK_OBJECT(src),"offset",0,NULL);
|
|
update_buttons(2);
|
|
update_slider(0.0);
|
|
show_next_picture();
|
|
break;
|
|
}
|
|
}
|
|
|
|
static void have_type(GstSink *sink) {
|
|
gint type;
|
|
GstType *gsttype;
|
|
|
|
type = gst_util_get_int_arg(GTK_OBJECT(sink),"type");
|
|
gsttype = gst_type_find_by_id(type);
|
|
|
|
g_print("have type %d:%s\n", type, gsttype->mime);
|
|
|
|
gst_bin_remove(GST_BIN(pipeline), GST_ELEMENT(sink));
|
|
|
|
gst_pad_disconnect(gst_element_get_pad(src,"src"),
|
|
gst_element_get_pad(GST_ELEMENT(sink),"sink"));
|
|
|
|
if (strstr(gsttype->mime, "mpeg1-system")) {
|
|
parse = gst_elementfactory_make("mpeg1parse","mpeg1_system_parse");
|
|
gtk_signal_connect(GTK_OBJECT(parse),"new_pad",
|
|
GTK_SIGNAL_FUNC(mpeg1_new_pad_created),pipeline);
|
|
}
|
|
else if (strstr(gsttype->mime, "mpeg2-system")) {
|
|
parse = gst_elementfactory_make("mpeg2parse","mpeg2_system_parse");
|
|
gtk_signal_connect(GTK_OBJECT(parse),"new_pad",
|
|
GTK_SIGNAL_FUNC(mpeg2_new_pad_created),pipeline);
|
|
}
|
|
else if (strstr(gsttype->mime, "avi")) {
|
|
parse = gst_elementfactory_make("parseavi","parse");
|
|
gtk_signal_connect(GTK_OBJECT(parse),"new_pad",
|
|
GTK_SIGNAL_FUNC(avi_new_pad_created),pipeline);
|
|
}
|
|
else if (strstr(gsttype->mime, "mpeg1")) {
|
|
mpeg1_setup_video_thread(gst_element_get_pad(src,"src"), video_render_queue, GST_ELEMENT(pipeline));
|
|
gst_element_set_state(GST_ELEMENT(pipeline),GST_STATE_PLAYING);
|
|
gst_clock_reset(gst_clock_get_system());
|
|
}
|
|
else {
|
|
g_print("unknown media type\n");
|
|
exit(0);
|
|
}
|
|
|
|
if (parse) {
|
|
gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(parse));
|
|
gst_pad_connect(gst_element_get_pad(src,"src"),
|
|
gst_element_get_pad(parse,"sink"));
|
|
gtk_signal_connect(GTK_OBJECT(parse),"state_change",
|
|
GTK_SIGNAL_FUNC(gstplay_parse_state_changed),pipeline);
|
|
}
|
|
|
|
gtk_object_set(GTK_OBJECT(src),"offset",0,NULL);
|
|
}
|
|
|
|
int
|
|
main (int argc, char *argv[])
|
|
{
|
|
GtkWidget *window1;
|
|
GstElement *typefind;
|
|
GstElement *video_render_thread;
|
|
GstElement *audio_render_thread;
|
|
|
|
bindtextdomain (PACKAGE, PACKAGE_LOCALE_DIR);
|
|
textdomain (PACKAGE);
|
|
|
|
g_thread_init(NULL);
|
|
gtk_init(&argc,&argv);
|
|
gnome_init ("gstreamer", VERSION, argc, argv);
|
|
gst_init(&argc,&argv);
|
|
gst_plugin_load("mpeg1parse");
|
|
gst_plugin_load("mpeg2parse");
|
|
gst_plugin_load("mp1videoparse");
|
|
gst_plugin_load("mp3parse");
|
|
gst_plugin_load("parsewav");
|
|
gst_plugin_load("parseavi");
|
|
gst_plugin_load("videosink");
|
|
|
|
g_snprintf(statusline, 200, "seeking");
|
|
|
|
pipeline = gst_pipeline_new("main_pipeline");
|
|
g_return_val_if_fail(pipeline != NULL, -1);
|
|
|
|
video_render_thread = gst_thread_new("video_render_thread");
|
|
g_return_val_if_fail(video_render_thread != NULL, -1);
|
|
show = gst_elementfactory_make("videosink","show");
|
|
g_return_val_if_fail(show != NULL, -1);
|
|
gtk_object_set(GTK_OBJECT(show),"xv_enabled",FALSE,NULL);
|
|
window1 = create_window1 (gst_util_get_widget_arg(GTK_OBJECT(show),"widget"));
|
|
gtk_widget_show (window1);
|
|
gtk_signal_connect(GTK_OBJECT(window1),"delete_event",
|
|
GTK_SIGNAL_FUNC(delete_event),NULL);
|
|
gtk_signal_connect(GTK_OBJECT(window1),"destroy",
|
|
GTK_SIGNAL_FUNC(destroy),pipeline);
|
|
|
|
gtk_signal_connect(GTK_OBJECT(show),"frame_displayed",
|
|
GTK_SIGNAL_FUNC(frame_displayed),NULL);
|
|
gst_bin_add(GST_BIN(video_render_thread),GST_ELEMENT(show));
|
|
gst_element_add_ghost_pad(GST_ELEMENT(video_render_thread),
|
|
gst_element_get_pad(show,"sink"));
|
|
|
|
video_render_queue = gst_elementfactory_make("queue","video_render_queue");
|
|
gtk_object_set(GTK_OBJECT(video_render_queue),"max_level",BUFFER,NULL);
|
|
gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(video_render_queue));
|
|
gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(video_render_thread));
|
|
gst_pad_connect(gst_element_get_pad(video_render_queue,"src"),
|
|
gst_element_get_pad(video_render_thread,"sink"));
|
|
gtk_object_set(GTK_OBJECT(video_render_thread),"create_thread",TRUE,NULL);
|
|
|
|
|
|
audio_render_thread = gst_thread_new("audio_render_thread");
|
|
g_return_val_if_fail(audio_render_thread != NULL, -1);
|
|
audio_play = gst_elementfactory_make("audiosink","play_audio");
|
|
gst_bin_add(GST_BIN(audio_render_thread),GST_ELEMENT(audio_play));
|
|
gst_element_add_ghost_pad(GST_ELEMENT(audio_render_thread),
|
|
gst_element_get_pad(audio_play,"sink"));
|
|
|
|
audio_render_queue = gst_elementfactory_make("queue","audio_render_queue");
|
|
gtk_object_set(GTK_OBJECT(audio_render_queue),"max_level",BUFFER,NULL);
|
|
gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(audio_render_queue));
|
|
gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(audio_render_thread));
|
|
gst_pad_connect(gst_element_get_pad(audio_render_queue,"src"),
|
|
gst_element_get_pad(audio_render_thread,"sink"));
|
|
gtk_object_set(GTK_OBJECT(audio_render_thread),"create_thread",TRUE,NULL);
|
|
|
|
|
|
src = gst_elementfactory_make("disksrc","disk_src");
|
|
g_return_val_if_fail(src != NULL, -1);
|
|
g_print("should be using file '%s'\n",argv[1]);
|
|
gtk_object_set(GTK_OBJECT(src),"location",argv[1],NULL);
|
|
|
|
gtk_window_set_title (GTK_WINDOW (window1), g_strdup_printf("GStreamer Media player - %s", argv[1]));
|
|
|
|
typefind = gst_elementfactory_make("typefind","typefind");
|
|
g_return_val_if_fail(typefind != NULL, -1);
|
|
|
|
gtk_signal_connect(GTK_OBJECT(typefind),"have_type",
|
|
GTK_SIGNAL_FUNC(have_type),NULL);
|
|
|
|
|
|
gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(src));
|
|
gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(typefind));
|
|
|
|
|
|
gtk_signal_connect(GTK_OBJECT(src),"eos",
|
|
GTK_SIGNAL_FUNC(eof),NULL);
|
|
|
|
gst_pad_connect(gst_element_get_pad(src,"src"),
|
|
gst_element_get_pad(typefind,"sink"));
|
|
|
|
g_print("setting to PREROLL state\n");
|
|
gst_element_set_state(GST_ELEMENT(pipeline),GST_STATE_PREROLL);
|
|
g_print("setting to RUNNING state\n");
|
|
gst_element_set_state(GST_ELEMENT(pipeline),GST_STATE_RUNNING);
|
|
|
|
state = GSTPLAY_STOPPED;
|
|
|
|
change_state(GSTPLAY_PLAYING);
|
|
|
|
gdk_threads_enter();
|
|
gtk_main();
|
|
gdk_threads_leave();
|
|
return 0;
|
|
}
|
|
|