X-Git-Url: http://research.m1stereo.tv/gitweb?a=blobdiff_plain;f=src%2Flibrary.c;h=665a108ec149d7644bb9b8169ac31606e3531703;hb=HEAD;hp=700d5bfe341f5d706fc4896fc4e87ef4a9b2ae7a;hpb=5a2f0a475dfa74cb43b5abeb69dce4fd386e2fdb;p=omnplay diff --git a/src/library.c b/src/library.c index 700d5bf..665a108 100644 --- a/src/library.c +++ b/src/library.c @@ -21,12 +21,17 @@ # include #endif +#ifndef _GNU_SOURCE +#define _GNU_SOURCE +#endif + #include #include #include #include #include #include +#include #include "omnplay.h" #include "ui.h" @@ -52,28 +57,79 @@ int omnplay_library_normalize_item(omnplay_instance_t* app, playlist_item_t* ite { int r = 0; playlist_item_t* lib; + playlist_item_t prev; pthread_mutex_lock(&app->library.lock); + prev = *item; + lib = omnplay_library_find(app, item->id); item->error = 0; if(lib) { - if(!item->title[0]) { strcpy(item->title, lib->title); - r = 1; + g_warning("%s: [%s] title=[%s]->[%s]", __FUNCTION__, item->id, prev.title, item->title); + r++; }; - if(!item->dur || item->in < lib->in || (item->in + item->dur) > (lib->in + lib->dur)) + if(item->in < lib->in || item->in >= (lib->in + lib->dur)) { - item->dur = lib->dur; + g_warning("%s: [%s] (item->in=[%d] < lib->in=[%d] || item->in=[%d] >= (lib->in=[%d] + lib->dur=[%d]))", + __FUNCTION__, item->id, + item->in, lib->in, item->in, lib->in, lib->dur); + item->in = lib->in; - r = 1; + + g_warning("%s: [%s] in=[%d]->[%d]", __FUNCTION__, item->id, prev.in, item->in); + + r++; }; + + if(!item->dur || (item->in + item->dur) > (lib->in + lib->dur)) + { + g_warning("%s: [%s] (!item->dur=[%d] || (item->in=[%d] + item->dur=[%d]) > (lib->in=[%d] + lib->dur=[%d])", + __FUNCTION__, item->id, + item->dur, item->in, item->dur, lib->in, lib->dur); + + item->dur = lib->in + lib->dur - item->in; + + g_warning("%s: [%s] dur=[%d]->[%d]", __FUNCTION__, item->id, prev.dur, item->dur); + + r++; + }; + } + else + { + r = 1; + item->error = PLAYLIST_ITEM_ERROR_LIB; + }; + + pthread_mutex_unlock(&app->library.lock); + + return r; +}; + +int omnplay_library_relink_item(omnplay_instance_t* app, playlist_item_t* item) +{ + int r = 0; + playlist_item_t* lib; + + pthread_mutex_lock(&app->library.lock); + + lib = omnplay_library_find(app, item->id); + + item->error = 0; + + if(lib) + { + r = 1; + strcpy(item->title, lib->title); + item->dur = lib->dur; + item->in = lib->in; } else { @@ -123,7 +179,7 @@ int omnplay_library_load_file(playlist_item_t* items, int *pcount, char* filenam /* open and process file */ if((f = fopen(filename, "rt"))) { - while( !feof(f) && c < (limit -1)) + while(!feof(f) && c < limit) { char *s, *sp_r, *sp_b; @@ -140,8 +196,12 @@ int omnplay_library_load_file(playlist_item_t* items, int *pcount, char* filenam { memset(&item, 0, sizeof(playlist_item_t)); + g_warning("%s: [%s]", __FUNCTION__, l); + for(i = 0, sp_b = l; (NULL != (sp_r = strtok(sp_b, "\t"))); i++, sp_b = NULL) { + g_warning("%s: [%d]=[%s]", __FUNCTION__, i, sp_r); + switch(i) { case 0: strncpy(item.id, sp_r, PATH_MAX); break; @@ -153,7 +213,10 @@ int omnplay_library_load_file(playlist_item_t* items, int *pcount, char* filenam /* insert item */ items[c++] = item; - }; + g_warning("%s: id=[%s], in=[%d], dur=[%d]", __FUNCTION__, item.id, item.in, item.dur); + } + else + g_warning("omnplay_library_load_file: ignored line [%s]\n", l); } fclose(f); @@ -166,6 +229,8 @@ int omnplay_library_load_file(playlist_item_t* items, int *pcount, char* filenam *pcount = c; + g_warning("omnplay_library_load_file: loaded [%d] items from [%s] file, limit [%d]\n", c, filename, limit); + return r; }; @@ -201,8 +266,8 @@ static void omnplay_library_save_file(playlist_item_t* item, int count, char* fi frames2tc(item[i].in, 25.0, tc_in), frames2tc(item[i].dur, 25.0, tc_dur), item[i].title); - fclose(f); + g_warning("omnplay_library_save_file: written [%d] lines to file [%s]\n", count, filename); }; }; @@ -219,23 +284,37 @@ void omnplay_library_save(omnplay_instance_t* app) static void omnplay_get_content_cb(omnplay_instance_t* app, playlist_item_t* item, void* data) { - fprintf(stderr, "requested: id=[%s]\n", item->id); + if(!(app->library.id_display_idx % app->library.id_display_rate)) + omnplay_set_status(app, item->id); + app->library.id_display_idx++; }; -void omnplay_library_refresh(omnplay_instance_t* app) +static void* omnplay_library_refresh_proc(void* data) { + omnplay_instance_t* app = (omnplay_instance_t*)data; int count, i; playlist_item_t* items; + gdk_threads_enter(); + gtk_widget_set_sensitive(app->window, FALSE); + gdk_flush(); + gdk_threads_leave(); + + omnplay_set_status(app, "Updating library..."); + items = (playlist_item_t*)malloc(sizeof(playlist_item_t) * MAX_LIBRARY_ITEMS); count = omnplay_get_content(app, items, MAX_LIBRARY_ITEMS, omnplay_get_content_cb, NULL); if(count > 0) { + omnplay_set_status(app, "Quering whois..."); + if(app->library.whois[0]) omnplay_whois_list(app, items, &count); + omnplay_set_status(app, "Setting library..."); + pthread_mutex_lock(&app->library.lock); for(i = 0; i < count; i++) @@ -247,12 +326,39 @@ void omnplay_library_refresh(omnplay_instance_t* app) pthread_mutex_unlock(&app->library.lock); + gdk_threads_enter(); omnplay_library_draw(app); + gdk_flush(); + gdk_threads_leave(); }; + omnplay_set_status(app, "Normalizing playlist..."); + free(items); + gdk_threads_enter(); omnplay_playlist_normalize(app); + gdk_flush(); + gdk_threads_leave(); + + omnplay_set_status(app, ""); + + gdk_threads_enter(); + gtk_widget_set_sensitive(app->window, TRUE); + gdk_flush(); + gdk_threads_leave(); + + + return NULL; +}; + +void omnplay_library_refresh(omnplay_instance_t* app) +{ + if(app->library.refresh_thread) + g_thread_join(app->library.refresh_thread); + + app->library.refresh_thread = g_thread_create( + omnplay_library_refresh_proc, app, TRUE, NULL); }; void omnplay_library_draw(omnplay_instance_t* app) @@ -352,3 +458,44 @@ playlist_item_t* omnplay_library_get_selected(omnplay_instance_t* app, int *coun return items; }; + +void omnplay_library_search(omnplay_instance_t* app, int next) +{ + int idx = 0, i; + int* idxs; + const char *search; + GtkTreePath* path; + + pthread_mutex_lock(&app->library.lock); + + idxs = get_selected_idx_library(app); + if(idxs) idx = idxs[1]; + free(idxs); + + if(!next) idx = 0; + else idx++; + + search = gtk_entry_get_text(GTK_ENTRY(app->library.search)); + + if(search[0]) + { + for(i = idx; i < app->library.count; i++) + if( strcasestr(app->library.item[i].id, search) || + strcasestr(app->library.item[i].title, search)) + break; + + if(i < app->library.count) + { + g_warning("found at pos=%d\n", i); + + /* select */ + path = gtk_tree_path_new_from_indices(i, -1); + gtk_tree_selection_select_path(gtk_tree_view_get_selection( + GTK_TREE_VIEW(app->library_grid)), path); + gtk_tree_view_set_cursor(GTK_TREE_VIEW(app->library_grid), path, NULL, FALSE); + gtk_tree_path_free(path); + }; + }; + + pthread_mutex_unlock(&app->library.lock); +};