audlegacy: src/audacious/input.c comparison

comparison src/audacious/input.c @ 4029:76da6fe8cb39

- Branch merge

author	Ralf Ertzinger <ralf@skytale.net>
date	Wed, 28 Nov 2007 16:55:02 +0100
parents	bb709f82068b 67f01143e613
children	9e24c8746d99 1198b6911ca4

comparison

equal deleted inserted replaced

-:bb709f82068b
+:76da6fe8cb39
 FALSE,
 NULL
 };
 static GList *vis_list = NULL;
+static int volume_l = -1, volume_r = -1;
 InputPlayback *
 get_current_input_playback(void)
 {
 return ip_data.current_input_playback;
 } else {
 return 0; //error
 }
 }
+/* do actual probing. this function is called from input_check_file() */
+static ProbeResult *
+input_do_check_file(InputPlugin *ip, VFSFile *fd, gchar *filename_proxy, gboolean loading)
+{
+ProbeResult *pr = NULL;
+gint result = 0;
+g_return_val_if_fail(fd != NULL, NULL);
+vfs_rewind(fd);
+/* some input plugins provide probe_for_tuple() only. */
+if ( (ip->probe_for_tuple && !ip->is_our_file_from_vfs && !ip->is_our_file) ||
+(ip->probe_for_tuple && ip->have_subtune == TRUE) ||
+(ip->probe_for_tuple && (cfg.use_pl_metadata && (!loading || (loading && cfg.get_info_on_load)))) ) {
+Tuple *tuple = ip->probe_for_tuple(filename_proxy, fd);
+if (tuple != NULL) {
+pr = g_new0(ProbeResult, 1);
+pr->ip = ip;
+pr->tuple = tuple;
+tuple_associate_int(pr->tuple, FIELD_MTIME, NULL, input_get_mtime(filename_proxy));
+return pr;
+}
+}
+else if (ip->is_our_file_from_vfs != NULL) {
+result = ip->is_our_file_from_vfs(filename_proxy, fd);
+if (result > 0) {
+pr = g_new0(ProbeResult, 1);
+pr->ip = ip;
+return pr;
+}
+}
+else if (ip->is_our_file != NULL) {
+result = ip->is_our_file(filename_proxy);
+if (result > 0) {
+pr = g_new0(ProbeResult, 1);
+pr->ip = ip;
+return pr;
+}
+}
+return NULL;
+}
 /*
 * input_check_file()
 *
 * Inputs:
 *       filename to check recursively against input plugins
 * --nenolod, Jul  9 2007
 *
 * Adapted to return ProbeResult structure.
 *
 * --nenolod, Jul 20 2007
+*
+* Make use of ext_hash to avoid full scan in input list.
+*
+* --yaz, Nov 16 2007
 */
+/* if loading is TRUE, tuple probing can be skipped as regards configuration. */
 ProbeResult *
-input_check_file(const gchar * filename, gboolean show_warning)
+input_check_file(const gchar *filename, gboolean loading)
 {
 VFSFile *fd;
 GList *node;
 InputPlugin *ip;
 gchar *filename_proxy;
 gint ret = 1;
 gchar *ext, *tmp, *tmp_uri;
-gboolean use_ext_filter;
+gboolean use_ext_filter = FALSE;
 gchar *mimetype;
 ProbeResult *pr = NULL;
+GList **list_hdr = NULL;
-filename_proxy = g_strdup(filename);
+extern GHashTable *ext_hash;
 /* Some URIs will end in ?<subsong> to determine the subsong requested. */
 tmp_uri = g_strdup(filename);
 tmp = strrchr(tmp_uri, '?');
-if (tmp != NULL && g_ascii_isdigit(*(tmp + 1)))
+if (tmp && g_ascii_isdigit(*(tmp + 1)))
 *tmp = '\0';
+filename_proxy = g_strdup(tmp_uri);
+g_free(tmp_uri);
 /* Check for plugins with custom URI:// strings */
 /* cue:// cdda:// tone:// tact:// */
-if ((ip = uri_get_plugin(filename)) != NULL && ip->enabled)
+if ((ip = uri_get_plugin(filename_proxy)) != NULL && ip->enabled) {
-{
-printf("Offering '%s' to %s, based on special URL scheme\n", filename, ip->description);
 if (ip->is_our_file != NULL)
 ret = ip->is_our_file(filename_proxy);
 else
 ret = 0;
-if (ret > 0)
+if (ret > 0) {
-{
 g_free(filename_proxy);
 pr = g_new0(ProbeResult, 1);
 pr->ip = ip;
 return pr;
 }
 g_free(filename_proxy);
 return NULL;
 }
-fd = vfs_buffered_file_new_from_uri(tmp_uri);
-g_free(tmp_uri);
+// open the file with vfs sub-system
+fd = vfs_buffered_file_new_from_uri(filename_proxy);
 if (!fd) {
 printf("Unable to read from %s, giving up.\n", filename_proxy);
 g_free(filename_proxy);
 return NULL;
 }
-ext = strrchr(filename_proxy, '.') + 1;
+// apply mimetype check. note that stdio does not support mimetype check.
-use_ext_filter =
-(fd != NULL && (!g_strncasecmp(filename, "/", 1) ||
-!g_strncasecmp(filename, "file://", 7))) ? TRUE : FALSE;
 mimetype = vfs_get_metadata(fd, "content-type");
-if ((ip = mime_get_plugin(mimetype)) != NULL && ip->enabled)
+if ((ip = mime_get_plugin(mimetype)) != NULL && ip->enabled) {
-{
+while(1) {
-printf("Offering '%s' to %s, based on mime-type\n", filename, ip->description);
+if (!ip || !ip->enabled)
-if (ip->probe_for_tuple != NULL)
+continue;
-{
-Tuple *tuple = ip->probe_for_tuple(filename_proxy, fd);
+pr = input_do_check_file(ip, fd, filename_proxy, loading);
-if (tuple != NULL)
+if(pr) {
-{
 g_free(filename_proxy);
 vfs_fclose(fd);
-pr = g_new0(ProbeResult, 1);
-pr->ip = ip;
-pr->tuple = tuple;
-tuple_associate_int(pr->tuple, FIELD_MTIME, NULL, input_get_mtime(filename_proxy));
 return pr;
 }
 }
-else if (fd && ip->is_our_file_from_vfs != NULL)
+}
-{
-ret = ip->is_our_file_from_vfs(filename_proxy, fd);
+// apply ext_hash check
-if (ret > 0)
+if(cfg.use_extension_probing) {
-{
+use_ext_filter =
-g_free(filename_proxy);
+(fd && (!g_strncasecmp(filename_proxy, "/", 1) ||
-vfs_fclose(fd);
+!g_strncasecmp(filename_proxy, "file://", 7))) ? TRUE : FALSE;
+}
-pr = g_new0(ProbeResult, 1);
-pr->ip = ip;
+if(use_ext_filter) {
+gchar *base, *lext;
-return pr;
+gchar *tmp2 = g_filename_from_uri(filename_proxy, NULL, NULL);
-}
+gchar *realfn = g_strdup(tmp2 ? tmp2 : filename_proxy);
+g_free(tmp2);
+base = g_path_get_basename(realfn);
+g_free(realfn);
+ext = strrchr(base, '.');
+if(ext) {
+lext = g_ascii_strdown(ext+1, -1);
+list_hdr = g_hash_table_lookup(ext_hash, lext);
+g_free(lext);
 }
-else if (ip->is_our_file != NULL)
+g_free(base);
-{
-ret = ip->is_our_file(filename_proxy);
+if(list_hdr) {
+for(node = *list_hdr; node != NULL; node = g_list_next(node)) {
-if (ret > 0)
+ip = INPUT_PLUGIN(node->data);
-{
-g_free(filename_proxy);
+if (!ip || !ip->enabled)
-vfs_fclose(fd);
+continue;
-pr = g_new0(ProbeResult, 1);
+pr = input_do_check_file(ip, fd, filename_proxy, loading);
-pr->ip = ip;
+if(pr) {
-return pr;
+g_free(filename_proxy);
+vfs_fclose(fd);
+return pr;
+}
 }
 }
-}
+return NULL; // no plugin found.
-for (node = get_input_list(); node != NULL; node = g_list_next(node))
+}
-{
+// do full scan when extension match isn't specified.
+for (node = get_input_list(); node != NULL; node = g_list_next(node)) {
 ip = INPUT_PLUGIN(node->data);
 if (!ip || !ip->enabled)
 continue;
-printf("Offering '%s' to %s\n", filename, ip->description);
+pr = input_do_check_file(ip, fd, filename_proxy, loading);
-vfs_rewind(fd);
+if(pr) {
+g_free(filename_proxy);
-if (cfg.use_extension_probing == TRUE && ip->vfs_extensions != NULL &&
+vfs_fclose(fd);
-ext != NULL && ext != (gpointer) 0x1 && use_ext_filter == TRUE)
+return pr;
-{
-gint i;
-gboolean is_our_ext = FALSE;
-for (i = 0; ip->vfs_extensions[i] != NULL; i++)
-{
-if (str_has_prefix_nocase(ext, ip->vfs_extensions[i]))
-{
-is_our_ext = TRUE;
-break;
-}
-}
-/* not a plugin that supports this extension */
-if (is_our_ext == FALSE)
-continue;
 }
+}
-if (fd && ip->probe_for_tuple != NULL)
-{
-Tuple *tuple = ip->probe_for_tuple(filename_proxy, fd);
+// all probing failed. return NULL
-if (tuple != NULL)
-{
-g_free(filename_proxy);
-vfs_fclose(fd);
-pr = g_new0(ProbeResult, 1);
-pr->ip = ip;
-pr->tuple = tuple;
-tuple_associate_int(pr->tuple, FIELD_MTIME, NULL, input_get_mtime(filename_proxy));
-return pr;
-}
-}
-else if (fd && ip->is_our_file_from_vfs != NULL)
-{
-ret = ip->is_our_file_from_vfs(filename_proxy, fd);
-if (ret > 0)
-{
-g_free(filename_proxy);
-vfs_fclose(fd);
-pr = g_new0(ProbeResult, 1);
-pr->ip = ip;
-return pr;
-}
-}
-else if (ip->is_our_file != NULL)
-{
-ret = ip->is_our_file(filename_proxy);
-if (ret > 0)
-{
-g_free(filename_proxy);
-vfs_fclose(fd);
-pr = g_new0(ProbeResult, 1);
-pr->ip = ip;
-return pr;
-}
-}
-if (ret <= -1)
-break;
-}
 g_free(filename_proxy);
 vfs_fclose(fd);
 return NULL;
 }
 void
 }
 void
 input_get_volume(gint * l, gint * r)
 {
-InputPlayback *playback;
+if (volume_l == -1 || volume_r == -1)
+	output_get_volume(&volume_l, &volume_r);
-*l = -1;
-*r = -1;
+*l = volume_l;
-if (playback_get_playing()) {
+*r = volume_r;
-if ((playback = get_current_input_playback()) != NULL &&
-playback->plugin->get_volume &&
-playback->plugin->get_volume(l, r))
-return;
-}
-output_get_volume(l, r);
 }
 void
 input_set_volume(gint l, gint r)
 {
 playback->plugin->set_volume &&
 playback->plugin->set_volume(l, r))
 return;
 output_set_volume(l, r);
+volume_l = l;
+volume_r = r;
 }
 void
 input_update_vis(gint time)
 {

Mercurial > audlegacy

comparison src/audacious/input.c @ 4029:76da6fe8cb39