diff options
-rw-r--r-- | gtk/src/Makefile.am | 2 | ||||
-rw-r--r-- | gtk/src/callbacks.c | 1175 | ||||
-rw-r--r-- | gtk/src/callbacks.h | 2 | ||||
-rw-r--r-- | gtk/src/queuehandler.c | 1120 | ||||
-rw-r--r-- | gtk/src/queuehandler.h | 32 |
5 files changed, 1192 insertions, 1139 deletions
diff --git a/gtk/src/Makefile.am b/gtk/src/Makefile.am index 0886e666c..088a3b5d2 100644 --- a/gtk/src/Makefile.am +++ b/gtk/src/Makefile.am @@ -86,6 +86,8 @@ nodist_EXTRA_ghb_SOURCES = dummy.cpp ghb_SOURCES = \ callbacks.c \ callbacks.h \ + queuehandler.c \ + queuehandler.h \ main.c \ settings.c \ settings.h \ diff --git a/gtk/src/callbacks.c b/gtk/src/callbacks.c index e1ca99f85..e0e0b9b0a 100644 --- a/gtk/src/callbacks.c +++ b/gtk/src/callbacks.c @@ -25,7 +25,9 @@ #include <glib/gstdio.h> #include <gio/gio.h> +#include "hb.h" #include "callbacks.h" +#include "queuehandler.h" #include "resources.h" #include "settings.h" #include "presets.h" @@ -34,15 +36,12 @@ #include "hb-backend.h" #include "ghb-dvd.h" #include "ghbcellrenderertext.h" -#include "hb.h" static void update_chapter_list(signal_user_data_t *ud); static void clear_audio_list(signal_user_data_t *ud); static GList* dvd_device_list(); -static gboolean cancel_encode(); static void audio_list_refresh_selected(signal_user_data_t *ud); static GValue* get_selected_asettings(signal_user_data_t *ud); -static gint find_last_finished(GValue *queue); // This is a dependency map used for greying widgets // that are dependent on the state of another widget. @@ -268,7 +267,7 @@ on_quit1_activate(GtkMenuItem *quit, signal_user_data_t *ud) g_debug("on_quit1_activate ()"); if (state & GHB_STATE_WORKING) { - if (cancel_encode("Closing HandBrake will terminate encoding.\n")) + if (ghb_cancel_encode("Closing HandBrake will terminate encoding.\n")) { ghb_hb_cleanup(FALSE); gtk_main_quit(); @@ -814,7 +813,7 @@ window_delete_event_cb(GtkWidget *widget, GdkEvent *event, signal_user_data_t *u g_debug("window_delete_event_cb ()"); if (state & GHB_STATE_WORKING) { - if (cancel_encode("Closing HandBrake will terminate encoding.\n")) + if (ghb_cancel_encode("Closing HandBrake will terminate encoding.\n")) { ghb_hb_cleanup(FALSE); gtk_main_quit(); @@ -1246,8 +1245,6 @@ audio_codec_changed_cb(GtkWidget *widget, signal_user_data_t *ud) } } -static void audio_list_refresh_selected(signal_user_data_t *ud); - void audio_track_changed_cb(GtkWidget *widget, signal_user_data_t *ud) { @@ -1959,75 +1956,6 @@ audio_remove_clicked_cb(GtkWidget *widget, signal_user_data_t *ud) } } -static void -audio_list_refresh(signal_user_data_t *ud) -{ - GtkTreeView *treeview; - GtkTreeIter iter; - GtkListStore *store; - gboolean done; - gint row = 0; - GValue *audio_list; - - g_debug("audio_list_refresh ()"); - treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "audio_list")); - store = GTK_LIST_STORE(gtk_tree_view_get_model(treeview)); - if (gtk_tree_model_get_iter_first(GTK_TREE_MODEL(store), &iter)) - { - do - { - const gchar *track, *codec, *br, *sr, *mix; - gchar *drc, *s_track, *s_codec, *s_br, *s_sr, *s_mix; - gdouble s_drc; - GValue *asettings; - - audio_list = ghb_settings_get_value(ud->settings, "audio_list"); - if (row >= ghb_array_len(audio_list)) - return; - asettings = ghb_array_get_nth(audio_list, row); - - track = ghb_settings_combo_option(asettings, "audio_track"); - codec = ghb_settings_combo_option(asettings, "audio_codec"); - br = ghb_settings_combo_option(asettings, "audio_bitrate"); - sr = ghb_settings_combo_option(asettings, "audio_rate"); - mix = ghb_settings_combo_option(asettings, "audio_mix"); - drc = ghb_settings_get_string(asettings, "audio_drc"); - - s_track = ghb_settings_get_string(asettings, "audio_track"); - s_codec = ghb_settings_get_string(asettings, "audio_codec"); - s_br = ghb_settings_get_string(asettings, "audio_bitrate"); - s_sr = ghb_settings_get_string(asettings, "audio_rate"); - s_mix = ghb_settings_get_string(asettings, "audio_mix"); - s_drc = ghb_settings_get_double(asettings, "audio_drc"); - - gtk_list_store_set(GTK_LIST_STORE(store), &iter, - // These are displayed in list - 0, track, - 1, codec, - 2, br, - 3, sr, - 4, mix, - // These are used to set combo values when an item is selected - 5, drc, - 6, s_track, - 7, s_codec, - 8, s_br, - 9, s_sr, - 10, s_mix, - 11, s_drc, - -1); - g_free(drc); - g_free(s_track); - g_free(s_codec); - g_free(s_br); - g_free(s_sr); - g_free(s_mix); - done = !gtk_tree_model_iter_next(GTK_TREE_MODEL(store), &iter); - row++; - } while (!done); - } -} - void ghb_presets_list_update(signal_user_data_t *ud) { @@ -2350,346 +2278,6 @@ presets_list_selection_changed_cb(GtkTreeSelection *selection, signal_user_data_ } } -void -queue_list_selection_changed_cb(GtkTreeSelection *selection, signal_user_data_t *ud) -{ - GtkTreeModel *store; - GtkTreeIter iter, piter; - - g_debug("queue_list_selection_changed_cb ()"); - // A queue entry is made up of a parent and multiple - // children that are visible when expanded. When and entry - // is selected, I want the parent to be selected. - // This is purely cosmetic. - if (gtk_tree_selection_get_selected(selection, &store, &iter)) - { - if (gtk_tree_model_iter_parent (store, &piter, &iter)) - { - GtkTreePath *path; - GtkTreeView *treeview; - - gtk_tree_selection_select_iter (selection, &piter); - path = gtk_tree_model_get_path (store, &piter); - treeview = gtk_tree_selection_get_tree_view (selection); - // Make the parent visible in scroll window if it is not. - gtk_tree_view_scroll_to_cell (treeview, path, NULL, FALSE, 0, 0); - gtk_tree_path_free(path); - } - } -} - -static void -add_to_queue_list(signal_user_data_t *ud, GValue *settings, GtkTreeIter *piter) -{ - GtkTreeView *treeview; - GtkTreeIter iter; - GtkTreeStore *store; - gchar *info; - gint status; - GtkTreeIter citer; - gchar *dest, *preset, *vol_name, *basename; - const gchar *vcodec, *container; - gchar *fps, *vcodec_abbr; - gint title, start_chapter, end_chapter, width, height, vqvalue; - gint source_width, source_height; - gboolean pass2, anamorphic, round_dim, keep_aspect, vqtype, turbo; - gboolean tweaks; - - g_debug("update_queue_list ()"); - if (settings == NULL) return; - treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "queue_list")); - store = GTK_TREE_STORE(gtk_tree_view_get_model(treeview)); - - tweaks = ghb_settings_get_boolean(settings, "allow_tweaks"); - title = ghb_settings_combo_int(settings, "title"); - start_chapter = ghb_settings_get_int(settings, "start_chapter"); - end_chapter = ghb_settings_get_int(settings, "end_chapter"); - pass2 = ghb_settings_get_boolean(settings, "two_pass"); - vol_name = ghb_settings_get_string(settings, "volume_label"); - dest = ghb_settings_get_string(settings, "destination"); - basename = g_path_get_basename(dest); - info = g_strdup_printf - ( - "<big><b>%s</b></big> " - "<small>(Title %d, Chapters %d through %d, %d Video %s)" - " --> %s</small>", - vol_name, title+1, start_chapter, end_chapter, - pass2 ? 2:1, pass2 ? "Passes":"Pass", basename - ); - - if (piter) - iter = *piter; - else - gtk_tree_store_append(store, &iter, NULL); - - gtk_tree_store_set(store, &iter, 1, info, 2, "hb-queue-delete", -1); - g_free(info); - status = ghb_settings_get_int(settings, "job_status"); - switch (status) - { - case GHB_QUEUE_PENDING: - gtk_tree_store_set(store, &iter, 0, "hb-queue-job", -1); - break; - case GHB_QUEUE_CANCELED: - gtk_tree_store_set(store, &iter, 0, "hb-canceled", -1); - break; - case GHB_QUEUE_RUNNING: - gtk_tree_store_set(store, &iter, 0, "hb-working0", -1); - break; - case GHB_QUEUE_DONE: - gtk_tree_store_set(store, &iter, 0, "hb-complete", -1); - break; - default: - gtk_tree_store_set(store, &iter, 0, "hb-queue-job", -1); - break; - } - - GString *str = g_string_new(""); - gboolean markers; - gboolean preset_modified; - gint mux; - - container = ghb_settings_combo_option(settings, "container"); - mux = ghb_settings_combo_int(settings, "container"); - preset_modified = ghb_settings_get_boolean(settings, "preset_modified"); - preset = ghb_settings_get_string(settings, "preset"); - markers = ghb_settings_get_boolean(settings, "chapter_markers"); - - if (preset_modified) - g_string_append_printf(str, - "<b>Customized Preset Based On:</b> <small>%s</small>\n", - preset); - else - g_string_append_printf(str, - "<b>Preset:</b> <small>%s</small>\n", - preset); - - if (markers) - { - g_string_append_printf(str, - "<b>Format:</b> <small>%s Container, Chapter Markers</small>\n", - container); - } - else - { - g_string_append_printf(str, - "<b>Format:</b> <small>%s Container</small>\n", container); - } - if (mux == HB_MUX_MP4) - { - gboolean ipod, http, large; - - ipod = ghb_settings_get_boolean(settings, "ipod_file"); - http = ghb_settings_get_boolean(settings, "http_optimize_mp4"); - large = ghb_settings_get_boolean(settings, "large_mp4"); - if (http || ipod || large) - { - g_string_append_printf(str, "<b>MP4 Options:</b><small>"); - if (ipod) - g_string_append_printf(str, " - iPod 5G Support"); - if (http) - g_string_append_printf(str, " - Web Optimized"); - if (large) - g_string_append_printf(str, " - Large File Size (>4GB)"); - g_string_append_printf(str, "</small>\n"); - } - } - g_string_append_printf(str, - "<b>Destination:</b> <small>%s</small>\n", dest); - - width = ghb_settings_get_int(settings, "scale_width"); - height = ghb_settings_get_int(settings, "scale_height"); - anamorphic = ghb_settings_get_boolean(settings, "anamorphic"); - round_dim = ghb_settings_get_boolean(settings, "round_dimensions"); - keep_aspect = ghb_settings_get_boolean(settings, "keep_aspect"); - - gchar *aspect_desc; - if (anamorphic) - { - if (round_dim) - { - aspect_desc = "(Anamorphic)"; - } - else - { - aspect_desc = "(Strict Anamorphic)"; - } - } - else - { - if (keep_aspect) - { - aspect_desc = "(Aspect Preserved)"; - } - else - { - aspect_desc = "(Aspect Lost)"; - } - } - vqtype = ghb_settings_get_boolean(settings, "vquality_type_constant"); - vqvalue = 0; - - gchar *vq_desc = "Error"; - gchar *vq_units = ""; - if (!vqtype) - { - vqtype = ghb_settings_get_boolean(settings, "vquality_type_target"); - if (!vqtype) - { - // Has to be bitrate - vqvalue = ghb_settings_get_int(settings, "video_bitrate"); - vq_desc = "Bitrate:"; - vq_units = "kbps"; - } - else - { - // Target file size - vqvalue = ghb_settings_get_int(settings, "video_target"); - vq_desc = "Target Size:"; - vq_units = "MB"; - } - } - else - { - // Constant quality - vqvalue = ghb_settings_get_int(settings, "video_quality"); - vq_desc = "Constant Quality:"; - } - fps = ghb_settings_get_string(settings, "framerate"); - if (strcmp("source", fps) == 0) - { - g_free(fps); - if (ghb_settings_get_boolean(settings, "detelecine")) - fps = g_strdup("Same As Source (vfr detelecine)"); - else - fps = g_strdup("Same As Source (variable)"); - } - else - { - gchar *tmp; - tmp = g_strdup_printf("%s (constant frame rate)", fps); - g_free(fps); - fps = tmp; - } - vcodec = ghb_settings_combo_option(settings, "video_codec"); - vcodec_abbr = ghb_settings_get_string(settings, "video_codec"); - source_width = ghb_settings_get_int(settings, "source_width"); - source_height = ghb_settings_get_int(settings, "source_height"); - g_string_append_printf(str, - "<b>Picture:</b> Source: <small>%d x %d, Output %d x %d %s</small>\n", - source_width, source_height, width, height, aspect_desc); - - gboolean decomb; - gboolean filters = FALSE; - - decomb = ghb_settings_get_boolean(settings, "decomb"); - g_string_append_printf(str, "<b>Filters:</b><small>"); - if (ghb_settings_get_boolean(settings, "detelecine")) - { - g_string_append_printf(str, " - Detelecine"); - filters = TRUE; - } - if (decomb) - { - g_string_append_printf(str, " - Decomb"); - filters = TRUE; - } - else - { - gint deint = ghb_settings_combo_int(settings, - tweaks ? "tweak_deinterlace":"deinterlace"); - if (deint) - { - const gchar *opt = ghb_settings_combo_option(settings, - tweaks ? "tweak_deinterlace":"deinterlace"); - g_string_append_printf(str, " - Deinterlace: %s", opt); - filters = TRUE; - } - } - gint denoise = ghb_settings_combo_int(settings, - tweaks ? "tweak_denoise":"denoise"); - if (denoise) - { - const gchar *opt = ghb_settings_combo_option(settings, - tweaks ? "tweak_denoise":"denoise"); - g_string_append_printf(str, " - Denoise: %s", opt); - filters = TRUE; - } - gint deblock = ghb_settings_get_int(settings, "deblock"); - if (deblock >= 5) - { - g_string_append_printf(str, " - Deblock (%d)", deblock); - filters = TRUE; - } - if (ghb_settings_get_boolean(settings, "grayscale")) - { - g_string_append_printf(str, " - Grayscale"); - filters = TRUE; - } - if (!filters) - g_string_append_printf(str, " None"); - g_string_append_printf(str, "</small>\n"); - - g_string_append_printf(str, - "<b>Video:</b> <small>%s, Framerate: %s, %s %d%s</small>\n", - vcodec, fps, vq_desc, vqvalue, vq_units); - - turbo = ghb_settings_get_boolean(settings, "turbo"); - if (turbo) - { - g_string_append_printf(str, "<b>Turbo:</b> <small>On</small>\n"); - } - if (strcmp(vcodec_abbr, "x264") == 0) - { - gchar *x264opts = ghb_build_x264opts_string(settings); - g_string_append_printf(str, - "<b>x264 Options:</b> <small>%s</small>\n", x264opts); - g_free(x264opts); - } - // Add the audios - gint count, ii; - const GValue *audio_list; - - audio_list = ghb_settings_get_value(settings, "audio_list"); - count = ghb_array_len(audio_list); - for (ii = 0; ii < count; ii++) - { - gchar *bitrate, *samplerate, *track; - const gchar *acodec, *mix; - GValue *asettings; - - asettings = ghb_array_get_nth(audio_list, ii); - - acodec = ghb_settings_combo_option(asettings, "audio_codec"); - bitrate = ghb_settings_get_string(asettings, "audio_bitrate"); - samplerate = ghb_settings_get_string(asettings, "audio_rate"); - if (strcmp("source", samplerate) == 0) - { - g_free(samplerate); - samplerate = g_strdup("Same As Source"); - } - track = ghb_settings_get_string(asettings, "audio_track_long"); - mix = ghb_settings_combo_option(asettings, "audio_mix"); - g_string_append_printf(str, - "<b>Audio:</b><small> %s, Encoder: %s, Mixdown: %s, SampleRate: %s, Bitrate: %s</small>", - track, acodec, mix, samplerate, bitrate); - if (ii < count-1) - g_string_append_printf(str, "\n"); - g_free(track); - g_free(bitrate); - g_free(samplerate); - } - info = g_string_free(str, FALSE); - gtk_tree_store_append(store, &citer, &iter); - gtk_tree_store_set(store, &citer, 1, info, -1); - g_free(info); - g_free(fps); - g_free(vcodec_abbr); - g_free(vol_name); - g_free(dest); - g_free(preset); -} - gboolean ghb_message_dialog(GtkMessageType type, const gchar *message, const gchar *no, const gchar *yes) { @@ -2712,211 +2300,8 @@ ghb_message_dialog(GtkMessageType type, const gchar *message, const gchar *no, c return TRUE; } -static gint64 -estimate_file_size(signal_user_data_t *ud) -{ - ghb_title_info_t tinfo; - gint duration; - gint bitrate; - gint64 size; - gint titleindex; - - titleindex = ghb_settings_combo_int(ud->settings, "title"); - if (titleindex < 0) return 0; - - if (!ghb_get_title_info(&tinfo, titleindex)) return 0; - duration = ((tinfo.hours*60)+tinfo.minutes)*60+tinfo.seconds; - bitrate = ghb_guess_bitrate(ud->settings); - size = (gint64)duration * (gint64)bitrate/8; - return size; -} - -#define DISK_FREE_THRESH (1024L*1024L*1024L*3) - -static gboolean -validate_settings(signal_user_data_t *ud) -{ - // Check to see if the dest file exists or is - // already in the queue - gchar *message, *dest; - gint count, ii; - gint titleindex; - - titleindex = ghb_settings_combo_int(ud->settings, "title"); - if (titleindex < 0) return FALSE; - dest = ghb_settings_get_string(ud->settings, "destination"); - count = ghb_array_len(ud->queue); - for (ii = 0; ii < count; ii++) - { - GValue *js; - gchar *filename; - - js = ghb_array_get_nth(ud->queue, ii); - filename = ghb_settings_get_string(js, "destination"); - if (strcmp(dest, filename) == 0) - { - message = g_strdup_printf( - "Destination: %s\n\n" - "Another queued job has specified the same destination.\n" - "Do you want to overwrite?", - dest); - if (!ghb_message_dialog(GTK_MESSAGE_QUESTION, message, "Cancel", "Overwrite")) - { - g_free(filename); - g_free(dest); - g_free(message); - return FALSE; - } - g_free(message); - break; - } - g_free(filename); - } - gchar *destdir = g_path_get_dirname(dest); - if (!g_file_test(destdir, G_FILE_TEST_IS_DIR)) - { - message = g_strdup_printf( - "Destination: %s\n\n" - "This is not a valid directory.", - destdir); - ghb_message_dialog(GTK_MESSAGE_ERROR, message, "Cancel", NULL); - g_free(dest); - g_free(message); - g_free(destdir); - return FALSE; - } - if (g_access(destdir, R_OK|W_OK) != 0) - { - message = g_strdup_printf( - "Destination: %s\n\n" - "Can not read or write the directory.", - destdir); - ghb_message_dialog(GTK_MESSAGE_ERROR, message, "Cancel", NULL); - g_free(dest); - g_free(message); - g_free(destdir); - return FALSE; - } - GFile *gfile; - GFileInfo *info; - guint64 size; - gchar *resolved = ghb_resolve_symlink(destdir); - - gfile = g_file_new_for_path(resolved); - info = g_file_query_filesystem_info(gfile, - G_FILE_ATTRIBUTE_FILESYSTEM_FREE, NULL, NULL); - if (info != NULL) - { - if (g_file_info_has_attribute(info, G_FILE_ATTRIBUTE_FILESYSTEM_FREE)) - { - size = g_file_info_get_attribute_uint64(info, - G_FILE_ATTRIBUTE_FILESYSTEM_FREE); - - gint64 fsize = estimate_file_size(ud); - if (size < fsize) - { - message = g_strdup_printf( - "Destination filesystem is almost full: %uM free\n\n" - "Encode may be incomplete if you proceed.\n", - (guint)(size / (1024L*1024L))); - if (!ghb_message_dialog(GTK_MESSAGE_QUESTION, message, "Cancel", "Proceed")) - { - g_free(dest); - g_free(message); - return FALSE; - } - g_free(message); - } - } - g_object_unref(info); - } - g_object_unref(gfile); - g_free(resolved); - g_free(destdir); - if (g_file_test(dest, G_FILE_TEST_EXISTS)) - { - message = g_strdup_printf( - "Destination: %s\n\n" - "File already exhists.\n" - "Do you want to overwrite?", - dest); - if (!ghb_message_dialog(GTK_MESSAGE_QUESTION, message, "Cancel", "Overwrite")) - { - g_free(dest); - g_free(message); - return FALSE; - } - g_free(message); - g_unlink(dest); - } - g_free(dest); - // Validate video quality is in a reasonable range - if (!ghb_validate_vquality(ud->settings)) - { - return FALSE; - } - // Validate audio settings - if (!ghb_validate_audio(ud)) - { - return FALSE; - } - // Validate video settings - if (!ghb_validate_video(ud)) - { - return FALSE; - } - // Validate container settings - if (!ghb_validate_container(ud)) - { - return FALSE; - } - // Validate filter settings - if (!ghb_validate_filters(ud)) - { - return FALSE; - } - audio_list_refresh(ud); - return TRUE; -} - -static gboolean -queue_add(signal_user_data_t *ud) -{ - // Add settings to the queue - GValue *settings; - gint titleindex; - gint titlenum; - - g_debug("queue_add ()"); - if (!validate_settings(ud)) - { - return FALSE; - } - if (ud->queue == NULL) - ud->queue = ghb_array_value_new(32); - // Make a copy of current settings to be used for the new job - settings = ghb_value_dup(ud->settings); - ghb_settings_set_int(settings, "job_status", GHB_QUEUE_PENDING); - ghb_settings_set_int(settings, "job_unique_id", 0); - titleindex = ghb_settings_combo_int(settings, "title"); - titlenum = ghb_get_title_number(titleindex); - ghb_settings_set_int(settings, "titlenum", titlenum); - ghb_array_append(ud->queue, settings); - add_to_queue_list(ud, settings, NULL); - ghb_save_queue(ud->queue); - - return TRUE; -} - -void -queue_add_clicked_cb(GtkWidget *widget, signal_user_data_t *ud) -{ - g_debug("queue_add_clicked_cb ()"); - queue_add(ud); -} - -static gboolean -cancel_encode(const gchar *extra_msg) +gboolean +ghb_cancel_encode(const gchar *extra_msg) { GtkWidget *dialog; GtkResponseType response; @@ -2937,324 +2322,6 @@ cancel_encode(const gchar *extra_msg) return TRUE; } -void -queue_remove_clicked_cb(GtkWidget *widget, gchar *path, signal_user_data_t *ud) -{ - GtkTreeView *treeview; - GtkTreePath *treepath; - GtkTreeModel *store; - GtkTreeIter iter; - gint row; - gint *indices; - gint unique_id; - GValue *settings; - gint status; - - g_debug("queue_remove_clicked_cb ()"); - treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "queue_list")); - store = gtk_tree_view_get_model(treeview); - treepath = gtk_tree_path_new_from_string (path); - if (gtk_tree_path_get_depth(treepath) > 1) return; - if (gtk_tree_model_get_iter(store, &iter, treepath)) - { - // Find the entry in the queue - indices = gtk_tree_path_get_indices (treepath); - row = indices[0]; - // Can only free the treepath After getting what I need from - // indices since this points into treepath somewhere. - gtk_tree_path_free (treepath); - if (row < 0) return; - if (row >= ghb_array_len(ud->queue)) - return; - settings = ghb_array_get_nth(ud->queue, row); - status = ghb_settings_get_int(settings, "job_status"); - if (status == GHB_QUEUE_RUNNING) - { - // Ask if wants to stop encode. - if (!cancel_encode(NULL)) - { - return; - } - unique_id = ghb_settings_get_int(settings, "job_unique_id"); - ghb_remove_job(unique_id); - } - // Remove the selected item - gtk_tree_store_remove(GTK_TREE_STORE(store), &iter); - // Remove the corresponding item from the queue list - GValue *old = ghb_array_get_nth(ud->queue, row); - ghb_value_free(old); - ghb_array_remove(ud->queue, row); - ghb_save_queue(ud->queue); - } - else - { - gtk_tree_path_free (treepath); - } -} - -// This little bit is needed to prevent the default drag motion -// handler from expanding rows if you hover over them while -// dragging. -// Also controls where valid drop locations are -gboolean -queue_drag_motion_cb( - GtkTreeView *tv, - GdkDragContext *ctx, - gint x, - gint y, - guint time, - signal_user_data_t *ud) -{ - GtkTreePath *path = NULL; - GtkTreeViewDropPosition pos; - gint *indices, row, status, finished; - GValue *js; - GtkTreeIter iter; - GtkTreeView *srctv; - GtkTreeModel *model; - GtkTreeSelection *select; - - // This bit checks to see if the source is allowed to be - // moved. Only pending and canceled items may be moved. - srctv = GTK_TREE_VIEW(gtk_drag_get_source_widget(ctx)); - select = gtk_tree_view_get_selection (srctv); - gtk_tree_selection_get_selected (select, &model, &iter); - path = gtk_tree_model_get_path (model, &iter); - indices = gtk_tree_path_get_indices(path); - row = indices[0]; - gtk_tree_path_free(path); - js = ghb_array_get_nth(ud->queue, row); - status = ghb_settings_get_int(js, "job_status"); - if (status != GHB_QUEUE_PENDING && status != GHB_QUEUE_CANCELED) - { - gdk_drag_status(ctx, 0, time); - return TRUE; - } - - // The reset checks that the destination is a valid position - // in the list. Can not move above any finished or running items - gtk_tree_view_get_dest_row_at_pos (tv, x, y, &path, &pos); - if (path == NULL) - { - gdk_drag_status(ctx, GDK_ACTION_MOVE, time); - return TRUE; - } - // Don't allow *drop into* - if (pos == GTK_TREE_VIEW_DROP_INTO_OR_BEFORE) - pos = GTK_TREE_VIEW_DROP_BEFORE; - if (pos == GTK_TREE_VIEW_DROP_INTO_OR_AFTER) - pos = GTK_TREE_VIEW_DROP_AFTER; - // Don't allow droping int child items - if (gtk_tree_path_get_depth(path) > 1) - { - gtk_tree_path_up(path); - pos = GTK_TREE_VIEW_DROP_AFTER; - } - indices = gtk_tree_path_get_indices(path); - row = indices[0]; - js = ghb_array_get_nth(ud->queue, row); - - finished = find_last_finished(ud->queue); - if (row < finished) - { - gtk_tree_path_free(path); - gdk_drag_status(ctx, 0, time); - return TRUE; - } - if (pos != GTK_TREE_VIEW_DROP_AFTER && - row == finished) - { - gtk_tree_path_free(path); - gdk_drag_status(ctx, 0, time); - return TRUE; - } - gtk_tree_view_set_drag_dest_row(tv, path, pos); - gtk_tree_path_free(path); - gdk_drag_status(ctx, GDK_ACTION_MOVE, time); - return TRUE; -} - -void -queue_drag_cb( - GtkTreeView *dstwidget, - GdkDragContext *dc, - gint x, gint y, - GtkSelectionData *selection_data, - guint info, guint t, - signal_user_data_t *ud) -{ - GtkTreePath *path = NULL; - //GtkTreeModel *model; - GtkTreeViewDropPosition pos; - GtkTreeIter dstiter, srciter; - gint *indices, row; - GValue *js; - - GtkTreeModel *dstmodel = gtk_tree_view_get_model(dstwidget); - - g_debug("queue_drag_cb ()"); - // This doesn't work here for some reason... - // gtk_tree_view_get_drag_dest_row(dstwidget, &path, &pos); - gtk_tree_view_get_dest_row_at_pos (dstwidget, x, y, &path, &pos); - // This little hack is needed because attempting to drop after - // the last item gives us no path or pos. - if (path == NULL) - { - gint n_children; - - n_children = gtk_tree_model_iter_n_children(dstmodel, NULL); - if (n_children) - { - pos = GTK_TREE_VIEW_DROP_AFTER; - path = gtk_tree_path_new_from_indices(n_children-1, -1); - } - else - { - pos = GTK_TREE_VIEW_DROP_BEFORE; - path = gtk_tree_path_new_from_indices(0, -1); - } - } - if (path) - { - if (gtk_tree_path_get_depth(path) > 1) - gtk_tree_path_up(path); - if (gtk_tree_model_get_iter (dstmodel, &dstiter, path)) - { - GtkTreeIter iter; - GtkTreeView *srcwidget; - GtkTreeModel *srcmodel; - GtkTreeSelection *select; - GtkTreePath *srcpath = NULL; - GtkTreePath *dstpath = NULL; - - srcwidget = GTK_TREE_VIEW(gtk_drag_get_source_widget(dc)); - //srcmodel = gtk_tree_view_get_model(srcwidget); - select = gtk_tree_view_get_selection (srcwidget); - gtk_tree_selection_get_selected (select, &srcmodel, &srciter); - - srcpath = gtk_tree_model_get_path (srcmodel, &srciter); - indices = gtk_tree_path_get_indices(srcpath); - row = indices[0]; - gtk_tree_path_free(srcpath); - js = ghb_array_get_nth(ud->queue, row); - - switch (pos) - { - case GTK_TREE_VIEW_DROP_BEFORE: - case GTK_TREE_VIEW_DROP_INTO_OR_BEFORE: - gtk_tree_store_insert_before (GTK_TREE_STORE (dstmodel), - &iter, NULL, &dstiter); - break; - - case GTK_TREE_VIEW_DROP_AFTER: - case GTK_TREE_VIEW_DROP_INTO_OR_AFTER: - gtk_tree_store_insert_after (GTK_TREE_STORE (dstmodel), - &iter, NULL, &dstiter); - break; - - default: - break; - } - // Reset job to pending - ghb_settings_set_int(js, "job_status", GHB_QUEUE_PENDING); - add_to_queue_list(ud, js, &iter); - - dstpath = gtk_tree_model_get_path (dstmodel, &iter); - indices = gtk_tree_path_get_indices(dstpath); - row = indices[0]; - gtk_tree_path_free(dstpath); - ghb_array_insert(ud->queue, row, js); - - srcpath = gtk_tree_model_get_path (srcmodel, &srciter); - indices = gtk_tree_path_get_indices(srcpath); - row = indices[0]; - gtk_tree_path_free(srcpath); - ghb_array_remove(ud->queue, row); - gtk_tree_store_remove (GTK_TREE_STORE (srcmodel), &srciter); - ghb_save_queue(ud->queue); - } - gtk_tree_path_free(path); - } -} - - -static gint -find_last_finished(GValue *queue) -{ - GValue *js; - gint ii, count; - gint status; - - g_debug("find_last_finished"); - count = ghb_array_len(queue); - for (ii = 0; ii < count; ii++) - { - js = ghb_array_get_nth(queue, ii); - status = ghb_settings_get_int(js, "job_status"); - if (status != GHB_QUEUE_DONE && status != GHB_QUEUE_RUNNING) - { - return ii-1; - } - } - return -1; -} - -static gint -find_queue_job(GValue *queue, gint unique_id, GValue **job) -{ - GValue *js; - gint ii, count; - gint job_unique_id; - - *job = NULL; - g_debug("find_queue_job"); - count = ghb_array_len(queue); - for (ii = 0; ii < count; ii++) - { - js = ghb_array_get_nth(queue, ii); - job_unique_id = ghb_settings_get_int(js, "job_unique_id"); - if (job_unique_id == unique_id) - { - *job = js; - return ii; - } - } - return -1; -} - -static void -queue_buttons_grey(signal_user_data_t *ud, gboolean working) -{ - GtkWidget *widget; - GtkAction *action; - gint queue_count; - gint titleindex; - gboolean title_ok; - - queue_count = ghb_array_len(ud->queue); - titleindex = ghb_settings_combo_int(ud->settings, "title"); - title_ok = (titleindex >= 0); - - widget = GHB_WIDGET (ud->builder, "queue_start1"); - gtk_widget_set_sensitive (widget, !working && (title_ok || queue_count)); - widget = GHB_WIDGET (ud->builder, "queue_start2"); - gtk_widget_set_sensitive (widget, !working && (title_ok || queue_count)); - action = GHB_ACTION (ud->builder, "queue_start_menu"); - gtk_action_set_sensitive (action, !working && (title_ok || queue_count)); - widget = GHB_WIDGET (ud->builder, "queue_pause1"); - gtk_widget_set_sensitive (widget, working); - widget = GHB_WIDGET (ud->builder, "queue_pause2"); - gtk_widget_set_sensitive (widget, working); - action = GHB_ACTION (ud->builder, "queue_pause_menu"); - gtk_action_set_sensitive (action, working); - widget = GHB_WIDGET (ud->builder, "queue_stop"); - gtk_widget_set_sensitive (widget, working); - action = GHB_ACTION (ud->builder, "queue_stop_menu"); - gtk_action_set_sensitive (action, working); -} - -void queue_start_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud); - static void submit_job(GValue *settings) { @@ -3281,8 +2348,8 @@ queue_scan(GValue *js) g_free(path); } -static GValue* -start_next_job(signal_user_data_t *ud, gboolean find_first) +GValue* +ghb_start_next_job(signal_user_data_t *ud, gboolean find_first) { static gint current = 0; gint count, ii, jj; @@ -3346,6 +2413,29 @@ start_next_job(signal_user_data_t *ud, gboolean find_first) return NULL; } +static gint +find_queue_job(GValue *queue, gint unique_id, GValue **job) +{ + GValue *js; + gint ii, count; + gint job_unique_id; + + *job = NULL; + g_debug("find_queue_job"); + count = ghb_array_len(queue); + for (ii = 0; ii < count; ii++) + { + js = ghb_array_get_nth(queue, ii); + job_unique_id = ghb_settings_get_int(js, "job_unique_id"); + if (job_unique_id == unique_id) + { + *job = js; + return ii; + } + } + return -1; +} + gchar* working_status_string(signal_user_data_t *ud, ghb_status_t *status) { @@ -3449,7 +2539,7 @@ ghb_backend_events(signal_user_data_t *ud) gtk_progress_bar_set_text (progress, "No Source"); } ghb_clear_state(GHB_STATE_SCANDONE); - queue_buttons_grey(ud, work_started); + ghb_queue_buttons_grey(ud, work_started); } else if (status.queue_state & GHB_STATE_SCANNING) { @@ -3481,7 +2571,7 @@ ghb_backend_events(signal_user_data_t *ud) gint qstatus; work_started = FALSE; - queue_buttons_grey(ud, FALSE); + ghb_queue_buttons_grey(ud, FALSE); index = find_queue_job(ud->queue, status.unique_id, &js); treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "queue_list")); store = GTK_TREE_STORE(gtk_tree_view_get_model(treeview)); @@ -3534,7 +2624,7 @@ ghb_backend_events(signal_user_data_t *ud) gtk_progress_bar_set_fraction (progress, 1.0); ghb_clear_queue_state(GHB_STATE_WORKDONE); if (!ud->cancel_encode) - ud->current_job = start_next_job(ud, FALSE); + ud->current_job = ghb_start_next_job(ud, FALSE); else ud->current_job = NULL; if (js) @@ -3553,7 +2643,7 @@ ghb_backend_events(signal_user_data_t *ud) if (!work_started) { work_started = TRUE; - queue_buttons_grey(ud, TRUE); + ghb_queue_buttons_grey(ud, TRUE); } } if (status.queue_state & GHB_STATE_WORKING) @@ -3563,7 +2653,7 @@ ghb_backend_events(signal_user_data_t *ud) if (!work_started) { work_started = TRUE; - queue_buttons_grey(ud, TRUE); + ghb_queue_buttons_grey(ud, TRUE); } index = find_queue_job(ud->queue, status.unique_id, &js); if (status.unique_id != 0 && index >= 0) @@ -3961,21 +3051,6 @@ chapter_list_selection_changed_cb(GtkTreeSelection *selection, signal_user_data_ } void -queue_list_size_allocate_cb(GtkWidget *widget, GtkAllocation *allocation, GtkCellRenderer *cell) -{ - GtkTreeViewColumn *column; - gint width; - - column = gtk_tree_view_get_column (GTK_TREE_VIEW(widget), 0); - width = gtk_tree_view_column_get_width(column); - g_debug("col width %d alloc width %d", width, allocation->width); - // Set new wrap-width. Shave a little off to accomidate the icons - // that share this column. - if (width >= 564) // Don't allow below a certain size - g_object_set(cell, "wrap-width", width-70, NULL); -} - -void preview_button_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud) { gint titleindex; @@ -4012,55 +3087,6 @@ preview_button_size_allocate_cb(GtkWidget *widget, GtkAllocation *allocation, si } void -queue_start_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud) -{ - GValue *js; - gboolean running = FALSE; - gint count, ii; - gint status; - gint state; - - count = ghb_array_len(ud->queue); - for (ii = 0; ii < count; ii++) - { - js = ghb_array_get_nth(ud->queue, ii); - status = ghb_settings_get_int(js, "job_status"); - if ((status == GHB_QUEUE_RUNNING) || - (status == GHB_QUEUE_PENDING)) - { - running = TRUE; - break; - } - } - if (!running) - { - // The queue has no running or pending jobs. - // Add current settings to the queue, then run. - if (!queue_add(ud)) - return; - } - state = ghb_get_queue_state(); - if (state == GHB_STATE_IDLE) - { - // Add the first pending queue item and start - ud->current_job = start_next_job(ud, TRUE); - } -} - -void -queue_stop_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud) -{ - ud->cancel_encode = TRUE; - cancel_encode(NULL); -} - -void -queue_pause_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud) -{ - ghb_pause_queue(); -} - -void presets_default_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud) { ghb_set_preset_default(ud->settings); @@ -4480,135 +3506,6 @@ easter_egg_cb( return FALSE; } -gboolean -ghb_reload_queue(signal_user_data_t *ud) -{ - GValue *queue; - gint unfinished = 0; - gint count, ii; - gint status; - GValue *settings; - gchar *message; - - g_debug("ghb_reload_queue"); - queue = ghb_load_queue(); - // Look for unfinished entries - count = ghb_array_len(queue); - for (ii = 0; ii < count; ii++) - { - settings = ghb_array_get_nth(queue, ii); - status = ghb_settings_get_int(settings, "job_status"); - if (status != GHB_QUEUE_DONE && status != GHB_QUEUE_CANCELED) - { - unfinished++; - } - } - if (unfinished) - { - message = g_strdup_printf( - "You have %d unfinished job%s in a saved queue.\n\n" - "Would you like to reload %s?", - unfinished, - (unfinished > 1) ? "s" : "", - (unfinished > 1) ? "them" : "it"); - if (ghb_message_dialog(GTK_MESSAGE_QUESTION, message, "No", "Yes")) - { - GtkWidget *widget = GHB_WIDGET (ud->builder, "queue_window"); - gtk_widget_show (widget); - - ud->queue = queue; - // First get rid of any old items we don't want - for (ii = count-1; ii >= 0; ii--) - { - settings = ghb_array_get_nth(queue, ii); - status = ghb_settings_get_int(settings, "job_status"); - if (status == GHB_QUEUE_DONE || status == GHB_QUEUE_CANCELED) - { - GValue *old = ghb_array_get_nth(queue, ii); - ghb_value_free(old); - ghb_array_remove(queue, ii); - } - } - count = ghb_array_len(queue); - for (ii = 0; ii < count; ii++) - { - settings = ghb_array_get_nth(queue, ii); - ghb_settings_set_int(settings, "job_unique_id", 0); - ghb_settings_set_int(settings, "job_status", GHB_QUEUE_PENDING); - add_to_queue_list(ud, settings, NULL); - } - queue_buttons_grey(ud, FALSE); - } - else - { - ghb_value_free(queue); - ghb_remove_queue_file(); - } - g_free(message); - } - return FALSE; -} - -gboolean queue_key_press_cb( - GtkWidget *widget, - GdkEventKey *event, - signal_user_data_t *ud) -{ - GtkTreeView *treeview; - GtkTreeSelection *selection; - GtkTreeModel *store; - GtkTreeIter iter; - gint row; - gint *indices; - gint unique_id; - GValue *settings; - gint status; - - g_debug("queue_key_press_cb ()"); - if (event->keyval != GDK_Delete) - return FALSE; - treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "queue_list")); - store = gtk_tree_view_get_model(treeview); - - selection = gtk_tree_view_get_selection (treeview); - if (gtk_tree_selection_get_selected(selection, &store, &iter)) - { - GtkTreePath *treepath; - - treepath = gtk_tree_model_get_path (store, &iter); - // Find the entry in the queue - indices = gtk_tree_path_get_indices (treepath); - row = indices[0]; - // Can only free the treepath After getting what I need from - // indices since this points into treepath somewhere. - gtk_tree_path_free (treepath); - if (row < 0) return FALSE; - if (row >= ghb_array_len(ud->queue)) - return FALSE; - settings = ghb_array_get_nth(ud->queue, row); - status = ghb_settings_get_int(settings, "job_status"); - if (status == GHB_QUEUE_RUNNING) - { - // Ask if wants to stop encode. - if (!cancel_encode(NULL)) - { - return TRUE; - } - unique_id = ghb_settings_get_int(settings, "job_unique_id"); - ghb_remove_job(unique_id); - } - // Remove the selected item - gtk_tree_store_remove(GTK_TREE_STORE(store), &iter); - // Remove the corresponding item from the queue list - GValue *old = ghb_array_get_nth(ud->queue, row); - ghb_value_free(old); - ghb_array_remove(ud->queue, row); - ghb_save_queue(ud->queue); - return TRUE; - } - return FALSE; -} - gchar* format_deblock_cb(GtkScale *scale, gdouble val, signal_user_data_t *ud) { diff --git a/gtk/src/callbacks.h b/gtk/src/callbacks.h index 6bb8d3aea..3e073cf33 100644 --- a/gtk/src/callbacks.h +++ b/gtk/src/callbacks.h @@ -43,6 +43,8 @@ gboolean ghb_message_dialog( const gchar *no, const gchar *yes); void ghb_init_dep_map(); gboolean ghb_reload_queue(signal_user_data_t *ud); +gboolean ghb_cancel_encode(const gchar *extra_msg); +GValue* ghb_start_next_job(signal_user_data_t *ud, gboolean find_first); #endif // _CALLBACKS_H_ diff --git a/gtk/src/queuehandler.c b/gtk/src/queuehandler.c new file mode 100644 index 000000000..e92ecf3c3 --- /dev/null +++ b/gtk/src/queuehandler.c @@ -0,0 +1,1120 @@ +/* -*- Mode: C; indent-tabs-mode: t; c-basic-offset: 4; tab-width: 4 -*- */ +/* + * callbacks.c + * Copyright (C) John Stebbins 2008 <stebbins@stebbins> + * + * callbacks.c is free software. + * + * You may redistribute it and/or modify it under the terms of the + * GNU General Public License, as published by the Free Software + * Foundation; either version 2 of the License, or (at your option) + * any later version. + */ + +#include <gtk/gtk.h> +#include <gdk/gdkkeysyms.h> +#include <glib/gstdio.h> +#include <gio/gio.h> +#include "hb.h" +#include "settings.h" +#include "hb-backend.h" +#include "values.h" +#include "callbacks.h" +#include "presets.h" +#include "ghb-dvd.h" + +void +queue_list_selection_changed_cb(GtkTreeSelection *selection, signal_user_data_t *ud) +{ + GtkTreeModel *store; + GtkTreeIter iter, piter; + + g_debug("queue_list_selection_changed_cb ()"); + // A queue entry is made up of a parent and multiple + // children that are visible when expanded. When and entry + // is selected, I want the parent to be selected. + // This is purely cosmetic. + if (gtk_tree_selection_get_selected(selection, &store, &iter)) + { + if (gtk_tree_model_iter_parent (store, &piter, &iter)) + { + GtkTreePath *path; + GtkTreeView *treeview; + + gtk_tree_selection_select_iter (selection, &piter); + path = gtk_tree_model_get_path (store, &piter); + treeview = gtk_tree_selection_get_tree_view (selection); + // Make the parent visible in scroll window if it is not. + gtk_tree_view_scroll_to_cell (treeview, path, NULL, FALSE, 0, 0); + gtk_tree_path_free(path); + } + } +} + +static void +add_to_queue_list(signal_user_data_t *ud, GValue *settings, GtkTreeIter *piter) +{ + GtkTreeView *treeview; + GtkTreeIter iter; + GtkTreeStore *store; + gchar *info; + gint status; + GtkTreeIter citer; + gchar *dest, *preset, *vol_name, *basename; + const gchar *vcodec, *container; + gchar *fps, *vcodec_abbr; + gint title, start_chapter, end_chapter, width, height, vqvalue; + gint source_width, source_height; + gboolean pass2, anamorphic, round_dim, keep_aspect, vqtype, turbo; + gboolean tweaks; + + g_debug("update_queue_list ()"); + if (settings == NULL) return; + treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "queue_list")); + store = GTK_TREE_STORE(gtk_tree_view_get_model(treeview)); + + tweaks = ghb_settings_get_boolean(settings, "allow_tweaks"); + title = ghb_settings_combo_int(settings, "title"); + start_chapter = ghb_settings_get_int(settings, "start_chapter"); + end_chapter = ghb_settings_get_int(settings, "end_chapter"); + pass2 = ghb_settings_get_boolean(settings, "two_pass"); + vol_name = ghb_settings_get_string(settings, "volume_label"); + dest = ghb_settings_get_string(settings, "destination"); + basename = g_path_get_basename(dest); + info = g_strdup_printf + ( + "<big><b>%s</b></big> " + "<small>(Title %d, Chapters %d through %d, %d Video %s)" + " --> %s</small>", + vol_name, title+1, start_chapter, end_chapter, + pass2 ? 2:1, pass2 ? "Passes":"Pass", basename + ); + + if (piter) + iter = *piter; + else + gtk_tree_store_append(store, &iter, NULL); + + gtk_tree_store_set(store, &iter, 1, info, 2, "hb-queue-delete", -1); + g_free(info); + status = ghb_settings_get_int(settings, "job_status"); + switch (status) + { + case GHB_QUEUE_PENDING: + gtk_tree_store_set(store, &iter, 0, "hb-queue-job", -1); + break; + case GHB_QUEUE_CANCELED: + gtk_tree_store_set(store, &iter, 0, "hb-canceled", -1); + break; + case GHB_QUEUE_RUNNING: + gtk_tree_store_set(store, &iter, 0, "hb-working0", -1); + break; + case GHB_QUEUE_DONE: + gtk_tree_store_set(store, &iter, 0, "hb-complete", -1); + break; + default: + gtk_tree_store_set(store, &iter, 0, "hb-queue-job", -1); + break; + } + + GString *str = g_string_new(""); + gboolean markers; + gboolean preset_modified; + gint mux; + + container = ghb_settings_combo_option(settings, "container"); + mux = ghb_settings_combo_int(settings, "container"); + preset_modified = ghb_settings_get_boolean(settings, "preset_modified"); + preset = ghb_settings_get_string(settings, "preset"); + markers = ghb_settings_get_boolean(settings, "chapter_markers"); + + if (preset_modified) + g_string_append_printf(str, + "<b>Customized Preset Based On:</b> <small>%s</small>\n", + preset); + else + g_string_append_printf(str, + "<b>Preset:</b> <small>%s</small>\n", + preset); + + if (markers) + { + g_string_append_printf(str, + "<b>Format:</b> <small>%s Container, Chapter Markers</small>\n", + container); + } + else + { + g_string_append_printf(str, + "<b>Format:</b> <small>%s Container</small>\n", container); + } + if (mux == HB_MUX_MP4) + { + gboolean ipod, http, large; + + ipod = ghb_settings_get_boolean(settings, "ipod_file"); + http = ghb_settings_get_boolean(settings, "http_optimize_mp4"); + large = ghb_settings_get_boolean(settings, "large_mp4"); + if (http || ipod || large) + { + g_string_append_printf(str, "<b>MP4 Options:</b><small>"); + if (ipod) + g_string_append_printf(str, " - iPod 5G Support"); + if (http) + g_string_append_printf(str, " - Web Optimized"); + if (large) + g_string_append_printf(str, " - Large File Size (>4GB)"); + g_string_append_printf(str, "</small>\n"); + } + } + g_string_append_printf(str, + "<b>Destination:</b> <small>%s</small>\n", dest); + + width = ghb_settings_get_int(settings, "scale_width"); + height = ghb_settings_get_int(settings, "scale_height"); + anamorphic = ghb_settings_get_boolean(settings, "anamorphic"); + round_dim = ghb_settings_get_boolean(settings, "round_dimensions"); + keep_aspect = ghb_settings_get_boolean(settings, "keep_aspect"); + + gchar *aspect_desc; + if (anamorphic) + { + if (round_dim) + { + aspect_desc = "(Anamorphic)"; + } + else + { + aspect_desc = "(Strict Anamorphic)"; + } + } + else + { + if (keep_aspect) + { + aspect_desc = "(Aspect Preserved)"; + } + else + { + aspect_desc = "(Aspect Lost)"; + } + } + vqtype = ghb_settings_get_boolean(settings, "vquality_type_constant"); + vqvalue = 0; + + gchar *vq_desc = "Error"; + gchar *vq_units = ""; + if (!vqtype) + { + vqtype = ghb_settings_get_boolean(settings, "vquality_type_target"); + if (!vqtype) + { + // Has to be bitrate + vqvalue = ghb_settings_get_int(settings, "video_bitrate"); + vq_desc = "Bitrate:"; + vq_units = "kbps"; + } + else + { + // Target file size + vqvalue = ghb_settings_get_int(settings, "video_target"); + vq_desc = "Target Size:"; + vq_units = "MB"; + } + } + else + { + // Constant quality + vqvalue = ghb_settings_get_int(settings, "video_quality"); + vq_desc = "Constant Quality:"; + } + fps = ghb_settings_get_string(settings, "framerate"); + if (strcmp("source", fps) == 0) + { + g_free(fps); + if (ghb_settings_get_boolean(settings, "detelecine")) + fps = g_strdup("Same As Source (vfr detelecine)"); + else + fps = g_strdup("Same As Source (variable)"); + } + else + { + gchar *tmp; + tmp = g_strdup_printf("%s (constant frame rate)", fps); + g_free(fps); + fps = tmp; + } + vcodec = ghb_settings_combo_option(settings, "video_codec"); + vcodec_abbr = ghb_settings_get_string(settings, "video_codec"); + source_width = ghb_settings_get_int(settings, "source_width"); + source_height = ghb_settings_get_int(settings, "source_height"); + g_string_append_printf(str, + "<b>Picture:</b> Source: <small>%d x %d, Output %d x %d %s</small>\n", + source_width, source_height, width, height, aspect_desc); + + gboolean decomb; + gboolean filters = FALSE; + + decomb = ghb_settings_get_boolean(settings, "decomb"); + g_string_append_printf(str, "<b>Filters:</b><small>"); + if (ghb_settings_get_boolean(settings, "detelecine")) + { + g_string_append_printf(str, " - Detelecine"); + filters = TRUE; + } + if (decomb) + { + g_string_append_printf(str, " - Decomb"); + filters = TRUE; + } + else + { + gint deint = ghb_settings_combo_int(settings, + tweaks ? "tweak_deinterlace":"deinterlace"); + if (deint) + { + const gchar *opt = ghb_settings_combo_option(settings, + tweaks ? "tweak_deinterlace":"deinterlace"); + g_string_append_printf(str, " - Deinterlace: %s", opt); + filters = TRUE; + } + } + gint denoise = ghb_settings_combo_int(settings, + tweaks ? "tweak_denoise":"denoise"); + if (denoise) + { + const gchar *opt = ghb_settings_combo_option(settings, + tweaks ? "tweak_denoise":"denoise"); + g_string_append_printf(str, " - Denoise: %s", opt); + filters = TRUE; + } + gint deblock = ghb_settings_get_int(settings, "deblock"); + if (deblock >= 5) + { + g_string_append_printf(str, " - Deblock (%d)", deblock); + filters = TRUE; + } + if (ghb_settings_get_boolean(settings, "grayscale")) + { + g_string_append_printf(str, " - Grayscale"); + filters = TRUE; + } + if (!filters) + g_string_append_printf(str, " None"); + g_string_append_printf(str, "</small>\n"); + + g_string_append_printf(str, + "<b>Video:</b> <small>%s, Framerate: %s, %s %d%s</small>\n", + vcodec, fps, vq_desc, vqvalue, vq_units); + + turbo = ghb_settings_get_boolean(settings, "turbo"); + if (turbo) + { + g_string_append_printf(str, "<b>Turbo:</b> <small>On</small>\n"); + } + if (strcmp(vcodec_abbr, "x264") == 0) + { + gchar *x264opts = ghb_build_x264opts_string(settings); + g_string_append_printf(str, + "<b>x264 Options:</b> <small>%s</small>\n", x264opts); + g_free(x264opts); + } + // Add the audios + gint count, ii; + const GValue *audio_list; + + audio_list = ghb_settings_get_value(settings, "audio_list"); + count = ghb_array_len(audio_list); + for (ii = 0; ii < count; ii++) + { + gchar *bitrate, *samplerate, *track; + const gchar *acodec, *mix; + GValue *asettings; + + asettings = ghb_array_get_nth(audio_list, ii); + + acodec = ghb_settings_combo_option(asettings, "audio_codec"); + bitrate = ghb_settings_get_string(asettings, "audio_bitrate"); + samplerate = ghb_settings_get_string(asettings, "audio_rate"); + if (strcmp("source", samplerate) == 0) + { + g_free(samplerate); + samplerate = g_strdup("Same As Source"); + } + track = ghb_settings_get_string(asettings, "audio_track_long"); + mix = ghb_settings_combo_option(asettings, "audio_mix"); + g_string_append_printf(str, + "<b>Audio:</b><small> %s, Encoder: %s, Mixdown: %s, SampleRate: %s, Bitrate: %s</small>", + track, acodec, mix, samplerate, bitrate); + if (ii < count-1) + g_string_append_printf(str, "\n"); + g_free(track); + g_free(bitrate); + g_free(samplerate); + } + info = g_string_free(str, FALSE); + gtk_tree_store_append(store, &citer, &iter); + gtk_tree_store_set(store, &citer, 1, info, -1); + g_free(info); + g_free(fps); + g_free(vcodec_abbr); + g_free(vol_name); + g_free(dest); + g_free(preset); +} + +static gint64 +estimate_file_size(signal_user_data_t *ud) +{ + ghb_title_info_t tinfo; + gint duration; + gint bitrate; + gint64 size; + gint titleindex; + + titleindex = ghb_settings_combo_int(ud->settings, "title"); + if (titleindex < 0) return 0; + + if (!ghb_get_title_info(&tinfo, titleindex)) return 0; + duration = ((tinfo.hours*60)+tinfo.minutes)*60+tinfo.seconds; + bitrate = ghb_guess_bitrate(ud->settings); + size = (gint64)duration * (gint64)bitrate/8; + return size; +} + +void +audio_list_refresh(signal_user_data_t *ud) +{ + GtkTreeView *treeview; + GtkTreeIter iter; + GtkListStore *store; + gboolean done; + gint row = 0; + GValue *audio_list; + + g_debug("ghb_audio_list_refresh ()"); + treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "audio_list")); + store = GTK_LIST_STORE(gtk_tree_view_get_model(treeview)); + if (gtk_tree_model_get_iter_first(GTK_TREE_MODEL(store), &iter)) + { + do + { + const gchar *track, *codec, *br, *sr, *mix; + gchar *drc, *s_track, *s_codec, *s_br, *s_sr, *s_mix; + gdouble s_drc; + GValue *asettings; + + audio_list = ghb_settings_get_value(ud->settings, "audio_list"); + if (row >= ghb_array_len(audio_list)) + return; + asettings = ghb_array_get_nth(audio_list, row); + + track = ghb_settings_combo_option(asettings, "audio_track"); + codec = ghb_settings_combo_option(asettings, "audio_codec"); + br = ghb_settings_combo_option(asettings, "audio_bitrate"); + sr = ghb_settings_combo_option(asettings, "audio_rate"); + mix = ghb_settings_combo_option(asettings, "audio_mix"); + drc = ghb_settings_get_string(asettings, "audio_drc"); + + s_track = ghb_settings_get_string(asettings, "audio_track"); + s_codec = ghb_settings_get_string(asettings, "audio_codec"); + s_br = ghb_settings_get_string(asettings, "audio_bitrate"); + s_sr = ghb_settings_get_string(asettings, "audio_rate"); + s_mix = ghb_settings_get_string(asettings, "audio_mix"); + s_drc = ghb_settings_get_double(asettings, "audio_drc"); + + gtk_list_store_set(GTK_LIST_STORE(store), &iter, + // These are displayed in list + 0, track, + 1, codec, + 2, br, + 3, sr, + 4, mix, + // These are used to set combo values when an item is selected + 5, drc, + 6, s_track, + 7, s_codec, + 8, s_br, + 9, s_sr, + 10, s_mix, + 11, s_drc, + -1); + g_free(drc); + g_free(s_track); + g_free(s_codec); + g_free(s_br); + g_free(s_sr); + g_free(s_mix); + done = !gtk_tree_model_iter_next(GTK_TREE_MODEL(store), &iter); + row++; + } while (!done); + } +} + +static gboolean +validate_settings(signal_user_data_t *ud) +{ + // Check to see if the dest file exists or is + // already in the queue + gchar *message, *dest; + gint count, ii; + gint titleindex; + + titleindex = ghb_settings_combo_int(ud->settings, "title"); + if (titleindex < 0) return FALSE; + dest = ghb_settings_get_string(ud->settings, "destination"); + count = ghb_array_len(ud->queue); + for (ii = 0; ii < count; ii++) + { + GValue *js; + gchar *filename; + + js = ghb_array_get_nth(ud->queue, ii); + filename = ghb_settings_get_string(js, "destination"); + if (strcmp(dest, filename) == 0) + { + message = g_strdup_printf( + "Destination: %s\n\n" + "Another queued job has specified the same destination.\n" + "Do you want to overwrite?", + dest); + if (!ghb_message_dialog(GTK_MESSAGE_QUESTION, message, "Cancel", "Overwrite")) + { + g_free(filename); + g_free(dest); + g_free(message); + return FALSE; + } + g_free(message); + break; + } + g_free(filename); + } + gchar *destdir = g_path_get_dirname(dest); + if (!g_file_test(destdir, G_FILE_TEST_IS_DIR)) + { + message = g_strdup_printf( + "Destination: %s\n\n" + "This is not a valid directory.", + destdir); + ghb_message_dialog(GTK_MESSAGE_ERROR, message, "Cancel", NULL); + g_free(dest); + g_free(message); + g_free(destdir); + return FALSE; + } + if (g_access(destdir, R_OK|W_OK) != 0) + { + message = g_strdup_printf( + "Destination: %s\n\n" + "Can not read or write the directory.", + destdir); + ghb_message_dialog(GTK_MESSAGE_ERROR, message, "Cancel", NULL); + g_free(dest); + g_free(message); + g_free(destdir); + return FALSE; + } + GFile *gfile; + GFileInfo *info; + guint64 size; + gchar *resolved = ghb_resolve_symlink(destdir); + + gfile = g_file_new_for_path(resolved); + info = g_file_query_filesystem_info(gfile, + G_FILE_ATTRIBUTE_FILESYSTEM_FREE, NULL, NULL); + if (info != NULL) + { + if (g_file_info_has_attribute(info, G_FILE_ATTRIBUTE_FILESYSTEM_FREE)) + { + size = g_file_info_get_attribute_uint64(info, + G_FILE_ATTRIBUTE_FILESYSTEM_FREE); + + gint64 fsize = estimate_file_size(ud); + if (size < fsize) + { + message = g_strdup_printf( + "Destination filesystem is almost full: %uM free\n\n" + "Encode may be incomplete if you proceed.\n", + (guint)(size / (1024L*1024L))); + if (!ghb_message_dialog(GTK_MESSAGE_QUESTION, message, "Cancel", "Proceed")) + { + g_free(dest); + g_free(message); + return FALSE; + } + g_free(message); + } + } + g_object_unref(info); + } + g_object_unref(gfile); + g_free(resolved); + g_free(destdir); + if (g_file_test(dest, G_FILE_TEST_EXISTS)) + { + message = g_strdup_printf( + "Destination: %s\n\n" + "File already exhists.\n" + "Do you want to overwrite?", + dest); + if (!ghb_message_dialog(GTK_MESSAGE_QUESTION, message, "Cancel", "Overwrite")) + { + g_free(dest); + g_free(message); + return FALSE; + } + g_free(message); + g_unlink(dest); + } + g_free(dest); + // Validate video quality is in a reasonable range + if (!ghb_validate_vquality(ud->settings)) + { + return FALSE; + } + // Validate audio settings + if (!ghb_validate_audio(ud)) + { + return FALSE; + } + // Validate video settings + if (!ghb_validate_video(ud)) + { + return FALSE; + } + // Validate container settings + if (!ghb_validate_container(ud)) + { + return FALSE; + } + // Validate filter settings + if (!ghb_validate_filters(ud)) + { + return FALSE; + } + audio_list_refresh(ud); + return TRUE; +} + +static gboolean +queue_add(signal_user_data_t *ud) +{ + // Add settings to the queue + GValue *settings; + gint titleindex; + gint titlenum; + + g_debug("queue_add ()"); + if (!validate_settings(ud)) + { + return FALSE; + } + if (ud->queue == NULL) + ud->queue = ghb_array_value_new(32); + // Make a copy of current settings to be used for the new job + settings = ghb_value_dup(ud->settings); + ghb_settings_set_int(settings, "job_status", GHB_QUEUE_PENDING); + ghb_settings_set_int(settings, "job_unique_id", 0); + titleindex = ghb_settings_combo_int(settings, "title"); + titlenum = ghb_get_title_number(titleindex); + ghb_settings_set_int(settings, "titlenum", titlenum); + ghb_array_append(ud->queue, settings); + add_to_queue_list(ud, settings, NULL); + ghb_save_queue(ud->queue); + + return TRUE; +} + +void +queue_add_clicked_cb(GtkWidget *widget, signal_user_data_t *ud) +{ + g_debug("queue_add_clicked_cb ()"); + queue_add(ud); +} + +void +queue_remove_clicked_cb(GtkWidget *widget, gchar *path, signal_user_data_t *ud) +{ + GtkTreeView *treeview; + GtkTreePath *treepath; + GtkTreeModel *store; + GtkTreeIter iter; + gint row; + gint *indices; + gint unique_id; + GValue *settings; + gint status; + + g_debug("queue_remove_clicked_cb ()"); + treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "queue_list")); + store = gtk_tree_view_get_model(treeview); + treepath = gtk_tree_path_new_from_string (path); + if (gtk_tree_path_get_depth(treepath) > 1) return; + if (gtk_tree_model_get_iter(store, &iter, treepath)) + { + // Find the entry in the queue + indices = gtk_tree_path_get_indices (treepath); + row = indices[0]; + // Can only free the treepath After getting what I need from + // indices since this points into treepath somewhere. + gtk_tree_path_free (treepath); + if (row < 0) return; + if (row >= ghb_array_len(ud->queue)) + return; + settings = ghb_array_get_nth(ud->queue, row); + status = ghb_settings_get_int(settings, "job_status"); + if (status == GHB_QUEUE_RUNNING) + { + // Ask if wants to stop encode. + if (!ghb_cancel_encode(NULL)) + { + return; + } + unique_id = ghb_settings_get_int(settings, "job_unique_id"); + ghb_remove_job(unique_id); + } + // Remove the selected item + gtk_tree_store_remove(GTK_TREE_STORE(store), &iter); + // Remove the corresponding item from the queue list + GValue *old = ghb_array_get_nth(ud->queue, row); + ghb_value_free(old); + ghb_array_remove(ud->queue, row); + ghb_save_queue(ud->queue); + } + else + { + gtk_tree_path_free (treepath); + } +} + +static gint +find_last_finished(GValue *queue) +{ + GValue *js; + gint ii, count; + gint status; + + g_debug("find_last_finished"); + count = ghb_array_len(queue); + for (ii = 0; ii < count; ii++) + { + js = ghb_array_get_nth(queue, ii); + status = ghb_settings_get_int(js, "job_status"); + if (status != GHB_QUEUE_DONE && status != GHB_QUEUE_RUNNING) + { + return ii-1; + } + } + return -1; +} + +// This little bit is needed to prevent the default drag motion +// handler from expanding rows if you hover over them while +// dragging. +// Also controls where valid drop locations are +gboolean +queue_drag_motion_cb( + GtkTreeView *tv, + GdkDragContext *ctx, + gint x, + gint y, + guint time, + signal_user_data_t *ud) +{ + GtkTreePath *path = NULL; + GtkTreeViewDropPosition pos; + gint *indices, row, status, finished; + GValue *js; + GtkTreeIter iter; + GtkTreeView *srctv; + GtkTreeModel *model; + GtkTreeSelection *select; + + // This bit checks to see if the source is allowed to be + // moved. Only pending and canceled items may be moved. + srctv = GTK_TREE_VIEW(gtk_drag_get_source_widget(ctx)); + select = gtk_tree_view_get_selection (srctv); + gtk_tree_selection_get_selected (select, &model, &iter); + path = gtk_tree_model_get_path (model, &iter); + indices = gtk_tree_path_get_indices(path); + row = indices[0]; + gtk_tree_path_free(path); + js = ghb_array_get_nth(ud->queue, row); + status = ghb_settings_get_int(js, "job_status"); + if (status != GHB_QUEUE_PENDING && status != GHB_QUEUE_CANCELED) + { + gdk_drag_status(ctx, 0, time); + return TRUE; + } + + // The reset checks that the destination is a valid position + // in the list. Can not move above any finished or running items + gtk_tree_view_get_dest_row_at_pos (tv, x, y, &path, &pos); + if (path == NULL) + { + gdk_drag_status(ctx, GDK_ACTION_MOVE, time); + return TRUE; + } + // Don't allow *drop into* + if (pos == GTK_TREE_VIEW_DROP_INTO_OR_BEFORE) + pos = GTK_TREE_VIEW_DROP_BEFORE; + if (pos == GTK_TREE_VIEW_DROP_INTO_OR_AFTER) + pos = GTK_TREE_VIEW_DROP_AFTER; + // Don't allow droping int child items + if (gtk_tree_path_get_depth(path) > 1) + { + gtk_tree_path_up(path); + pos = GTK_TREE_VIEW_DROP_AFTER; + } + indices = gtk_tree_path_get_indices(path); + row = indices[0]; + js = ghb_array_get_nth(ud->queue, row); + + finished = find_last_finished(ud->queue); + if (row < finished) + { + gtk_tree_path_free(path); + gdk_drag_status(ctx, 0, time); + return TRUE; + } + if (pos != GTK_TREE_VIEW_DROP_AFTER && + row == finished) + { + gtk_tree_path_free(path); + gdk_drag_status(ctx, 0, time); + return TRUE; + } + gtk_tree_view_set_drag_dest_row(tv, path, pos); + gtk_tree_path_free(path); + gdk_drag_status(ctx, GDK_ACTION_MOVE, time); + return TRUE; +} + +void +queue_drag_cb( + GtkTreeView *dstwidget, + GdkDragContext *dc, + gint x, gint y, + GtkSelectionData *selection_data, + guint info, guint t, + signal_user_data_t *ud) +{ + GtkTreePath *path = NULL; + //GtkTreeModel *model; + GtkTreeViewDropPosition pos; + GtkTreeIter dstiter, srciter; + gint *indices, row; + GValue *js; + + GtkTreeModel *dstmodel = gtk_tree_view_get_model(dstwidget); + + g_debug("queue_drag_cb ()"); + // This doesn't work here for some reason... + // gtk_tree_view_get_drag_dest_row(dstwidget, &path, &pos); + gtk_tree_view_get_dest_row_at_pos (dstwidget, x, y, &path, &pos); + // This little hack is needed because attempting to drop after + // the last item gives us no path or pos. + if (path == NULL) + { + gint n_children; + + n_children = gtk_tree_model_iter_n_children(dstmodel, NULL); + if (n_children) + { + pos = GTK_TREE_VIEW_DROP_AFTER; + path = gtk_tree_path_new_from_indices(n_children-1, -1); + } + else + { + pos = GTK_TREE_VIEW_DROP_BEFORE; + path = gtk_tree_path_new_from_indices(0, -1); + } + } + if (path) + { + if (gtk_tree_path_get_depth(path) > 1) + gtk_tree_path_up(path); + if (gtk_tree_model_get_iter (dstmodel, &dstiter, path)) + { + GtkTreeIter iter; + GtkTreeView *srcwidget; + GtkTreeModel *srcmodel; + GtkTreeSelection *select; + GtkTreePath *srcpath = NULL; + GtkTreePath *dstpath = NULL; + + srcwidget = GTK_TREE_VIEW(gtk_drag_get_source_widget(dc)); + //srcmodel = gtk_tree_view_get_model(srcwidget); + select = gtk_tree_view_get_selection (srcwidget); + gtk_tree_selection_get_selected (select, &srcmodel, &srciter); + + srcpath = gtk_tree_model_get_path (srcmodel, &srciter); + indices = gtk_tree_path_get_indices(srcpath); + row = indices[0]; + gtk_tree_path_free(srcpath); + js = ghb_array_get_nth(ud->queue, row); + + switch (pos) + { + case GTK_TREE_VIEW_DROP_BEFORE: + case GTK_TREE_VIEW_DROP_INTO_OR_BEFORE: + gtk_tree_store_insert_before (GTK_TREE_STORE (dstmodel), + &iter, NULL, &dstiter); + break; + + case GTK_TREE_VIEW_DROP_AFTER: + case GTK_TREE_VIEW_DROP_INTO_OR_AFTER: + gtk_tree_store_insert_after (GTK_TREE_STORE (dstmodel), + &iter, NULL, &dstiter); + break; + + default: + break; + } + // Reset job to pending + ghb_settings_set_int(js, "job_status", GHB_QUEUE_PENDING); + add_to_queue_list(ud, js, &iter); + + dstpath = gtk_tree_model_get_path (dstmodel, &iter); + indices = gtk_tree_path_get_indices(dstpath); + row = indices[0]; + gtk_tree_path_free(dstpath); + ghb_array_insert(ud->queue, row, js); + + srcpath = gtk_tree_model_get_path (srcmodel, &srciter); + indices = gtk_tree_path_get_indices(srcpath); + row = indices[0]; + gtk_tree_path_free(srcpath); + ghb_array_remove(ud->queue, row); + gtk_tree_store_remove (GTK_TREE_STORE (srcmodel), &srciter); + ghb_save_queue(ud->queue); + } + gtk_tree_path_free(path); + } +} + +void +ghb_queue_buttons_grey(signal_user_data_t *ud, gboolean working) +{ + GtkWidget *widget; + GtkAction *action; + gint queue_count; + gint titleindex; + gboolean title_ok; + + queue_count = ghb_array_len(ud->queue); + titleindex = ghb_settings_combo_int(ud->settings, "title"); + title_ok = (titleindex >= 0); + + widget = GHB_WIDGET (ud->builder, "queue_start1"); + gtk_widget_set_sensitive (widget, !working && (title_ok || queue_count)); + widget = GHB_WIDGET (ud->builder, "queue_start2"); + gtk_widget_set_sensitive (widget, !working && (title_ok || queue_count)); + action = GHB_ACTION (ud->builder, "queue_start_menu"); + gtk_action_set_sensitive (action, !working && (title_ok || queue_count)); + widget = GHB_WIDGET (ud->builder, "queue_pause1"); + gtk_widget_set_sensitive (widget, working); + widget = GHB_WIDGET (ud->builder, "queue_pause2"); + gtk_widget_set_sensitive (widget, working); + action = GHB_ACTION (ud->builder, "queue_pause_menu"); + gtk_action_set_sensitive (action, working); + widget = GHB_WIDGET (ud->builder, "queue_stop"); + gtk_widget_set_sensitive (widget, working); + action = GHB_ACTION (ud->builder, "queue_stop_menu"); + gtk_action_set_sensitive (action, working); +} + +void +queue_list_size_allocate_cb(GtkWidget *widget, GtkAllocation *allocation, GtkCellRenderer *cell) +{ + GtkTreeViewColumn *column; + gint width; + + column = gtk_tree_view_get_column (GTK_TREE_VIEW(widget), 0); + width = gtk_tree_view_column_get_width(column); + g_debug("col width %d alloc width %d", width, allocation->width); + // Set new wrap-width. Shave a little off to accomidate the icons + // that share this column. + if (width >= 564) // Don't allow below a certain size + g_object_set(cell, "wrap-width", width-70, NULL); +} + +void +queue_start_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud) +{ + GValue *js; + gboolean running = FALSE; + gint count, ii; + gint status; + gint state; + + count = ghb_array_len(ud->queue); + for (ii = 0; ii < count; ii++) + { + js = ghb_array_get_nth(ud->queue, ii); + status = ghb_settings_get_int(js, "job_status"); + if ((status == GHB_QUEUE_RUNNING) || + (status == GHB_QUEUE_PENDING)) + { + running = TRUE; + break; + } + } + if (!running) + { + // The queue has no running or pending jobs. + // Add current settings to the queue, then run. + if (!queue_add(ud)) + return; + } + state = ghb_get_queue_state(); + if (state == GHB_STATE_IDLE) + { + // Add the first pending queue item and start + ud->current_job = ghb_start_next_job(ud, TRUE); + } +} + +void +queue_stop_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud) +{ + ud->cancel_encode = TRUE; + ghb_cancel_encode(NULL); +} + +void +queue_pause_clicked_cb(GtkWidget *xwidget, signal_user_data_t *ud) +{ + ghb_pause_queue(); +} + +gboolean +ghb_reload_queue(signal_user_data_t *ud) +{ + GValue *queue; + gint unfinished = 0; + gint count, ii; + gint status; + GValue *settings; + gchar *message; + + g_debug("ghb_reload_queue"); + queue = ghb_load_queue(); + // Look for unfinished entries + count = ghb_array_len(queue); + for (ii = 0; ii < count; ii++) + { + settings = ghb_array_get_nth(queue, ii); + status = ghb_settings_get_int(settings, "job_status"); + if (status != GHB_QUEUE_DONE && status != GHB_QUEUE_CANCELED) + { + unfinished++; + } + } + if (unfinished) + { + message = g_strdup_printf( + "You have %d unfinished job%s in a saved queue.\n\n" + "Would you like to reload %s?", + unfinished, + (unfinished > 1) ? "s" : "", + (unfinished > 1) ? "them" : "it"); + if (ghb_message_dialog(GTK_MESSAGE_QUESTION, message, "No", "Yes")) + { + GtkWidget *widget = GHB_WIDGET (ud->builder, "queue_window"); + gtk_widget_show (widget); + + ud->queue = queue; + // First get rid of any old items we don't want + for (ii = count-1; ii >= 0; ii--) + { + settings = ghb_array_get_nth(queue, ii); + status = ghb_settings_get_int(settings, "job_status"); + if (status == GHB_QUEUE_DONE || status == GHB_QUEUE_CANCELED) + { + GValue *old = ghb_array_get_nth(queue, ii); + ghb_value_free(old); + ghb_array_remove(queue, ii); + } + } + count = ghb_array_len(queue); + for (ii = 0; ii < count; ii++) + { + settings = ghb_array_get_nth(queue, ii); + ghb_settings_set_int(settings, "job_unique_id", 0); + ghb_settings_set_int(settings, "job_status", GHB_QUEUE_PENDING); + add_to_queue_list(ud, settings, NULL); + } + ghb_queue_buttons_grey(ud, FALSE); + } + else + { + ghb_value_free(queue); + ghb_remove_queue_file(); + } + g_free(message); + } + return FALSE; +} + +gboolean queue_key_press_cb( + GtkWidget *widget, + GdkEventKey *event, + signal_user_data_t *ud) +{ + GtkTreeView *treeview; + GtkTreeSelection *selection; + GtkTreeModel *store; + GtkTreeIter iter; + gint row; + gint *indices; + gint unique_id; + GValue *settings; + gint status; + + g_debug("queue_key_press_cb ()"); + if (event->keyval != GDK_Delete) + return FALSE; + treeview = GTK_TREE_VIEW(GHB_WIDGET(ud->builder, "queue_list")); + store = gtk_tree_view_get_model(treeview); + + selection = gtk_tree_view_get_selection (treeview); + if (gtk_tree_selection_get_selected(selection, &store, &iter)) + { + GtkTreePath *treepath; + + treepath = gtk_tree_model_get_path (store, &iter); + // Find the entry in the queue + indices = gtk_tree_path_get_indices (treepath); + row = indices[0]; + // Can only free the treepath After getting what I need from + // indices since this points into treepath somewhere. + gtk_tree_path_free (treepath); + if (row < 0) return FALSE; + if (row >= ghb_array_len(ud->queue)) + return FALSE; + settings = ghb_array_get_nth(ud->queue, row); + status = ghb_settings_get_int(settings, "job_status"); + if (status == GHB_QUEUE_RUNNING) + { + // Ask if wants to stop encode. + if (!ghb_cancel_encode(NULL)) + { + return TRUE; + } + unique_id = ghb_settings_get_int(settings, "job_unique_id"); + ghb_remove_job(unique_id); + } + // Remove the selected item + gtk_tree_store_remove(GTK_TREE_STORE(store), &iter); + // Remove the corresponding item from the queue list + GValue *old = ghb_array_get_nth(ud->queue, row); + ghb_value_free(old); + ghb_array_remove(ud->queue, row); + ghb_save_queue(ud->queue); + return TRUE; + } + return FALSE; +} + diff --git a/gtk/src/queuehandler.h b/gtk/src/queuehandler.h new file mode 100644 index 000000000..53661c620 --- /dev/null +++ b/gtk/src/queuehandler.h @@ -0,0 +1,32 @@ +/* -*- Mode: C; indent-tabs-mode: t; c-basic-offset: 4; tab-width: 4 -*- */ +/* + * queuehandler.h + * Copyright (C) John Stebbins 2008 <stebbins@stebbins> + * + * queuehandler.h is free software. + * + * You may redistribute it and/or modify it under the terms of the + * GNU General Public License, as published by the Free Software + * Foundation; either version 2 of the License, or (at your option) + * any later version. + * + * callbacks.h is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. + * See the GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with callbacks.h. If not, write to: + * The Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor + * Boston, MA 02110-1301, USA. + */ + +#if !defined(_QUEUEHANDLER_H_) +#define _QUEUEHANDLER_H_ + +#include <gtk/gtk.h> + +void ghb_queue_buttons_grey(signal_user_data_t *ud, gboolean working); + +#endif // _QUEUEHANDLER_H_ |