diff options
author | Max Kellermann <max@duempel.org> | 2012-06-13 22:07:15 +0200 |
---|---|---|
committer | Max Kellermann <max@duempel.org> | 2012-06-13 22:11:43 +0200 |
commit | 66ed427a571a9e224eed94790664b0612574bef9 (patch) | |
tree | aff2b05ed7f7915c49ebddd47b872965d03e766d /src/update_container.c | |
parent | c9e63e9fdbd9275243f8a71783a6eb792ba3ef6b (diff) | |
download | mpd-66ed427a571a9e224eed94790664b0612574bef9.tar.gz mpd-66ed427a571a9e224eed94790664b0612574bef9.tar.xz mpd-66ed427a571a9e224eed94790664b0612574bef9.zip |
update_walk: move code to update_container.c
Diffstat (limited to '')
-rw-r--r-- | src/update_container.c | 124 |
1 files changed, 124 insertions, 0 deletions
diff --git a/src/update_container.c b/src/update_container.c new file mode 100644 index 000000000..9fe4bb0a9 --- /dev/null +++ b/src/update_container.c @@ -0,0 +1,124 @@ +/* + * Copyright (C) 2003-2012 The Music Player Daemon Project + * http://www.musicpd.org + * + * This program is free software; you can 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. + * + * This program 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 this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + */ + +#include "config.h" /* must be first for large file support */ +#include "update_container.h" +#include "update_internal.h" +#include "update_db.h" +#include "db_lock.h" +#include "directory.h" +#include "song.h" +#include "mapper.h" +#include "glib_compat.h" +#include "decoder_plugin.h" +#include "tag.h" +#include "tag_handler.h" + +#include <glib.h> + +/** + * Create the specified directory object if it does not exist already + * or if the #stat object indicates that it has been modified since + * the last update. Returns NULL when it exists already and is + * unmodified. + * + * The caller must lock the database. + */ +static struct directory * +make_directory_if_modified(struct directory *parent, const char *name, + const struct stat *st) +{ + struct directory *directory = directory_get_child(parent, name); + + // directory exists already + if (directory != NULL) { + if (directory->mtime == st->st_mtime && !walk_discard) { + /* not modified */ + db_unlock(); + return NULL; + } + + delete_directory(directory); + modified = true; + } + + directory = directory_make_child(parent, name); + directory->mtime = st->st_mtime; + return directory; +} + +bool +update_container_file(struct directory *directory, + const char *name, + const struct stat *st, + const struct decoder_plugin *plugin) +{ + if (plugin->container_scan == NULL) + return false; + + db_lock(); + struct directory *contdir = + make_directory_if_modified(directory, name, st); + if (contdir == NULL) { + /* not modified */ + db_unlock(); + return true; + } + + contdir->device = DEVICE_CONTAINER; + db_unlock(); + + char *const pathname = map_directory_child_fs(directory, name); + + char *vtrack; + unsigned int tnum = 0; + while ((vtrack = plugin->container_scan(pathname, ++tnum)) != NULL) { + struct song *song = song_file_new(vtrack, contdir); + + // shouldn't be necessary but it's there.. + song->mtime = st->st_mtime; + + char *child_path_fs = map_directory_child_fs(contdir, vtrack); + + song->tag = tag_new(); + decoder_plugin_scan_file(plugin, child_path_fs, + &add_tag_handler, song->tag); + g_free(child_path_fs); + + db_lock(); + directory_add_song(contdir, song); + db_unlock(); + + modified = true; + + g_message("added %s/%s", + directory_get_path(directory), vtrack); + g_free(vtrack); + } + + g_free(pathname); + + if (tnum == 1) { + db_lock(); + delete_directory(contdir); + db_unlock(); + return false; + } else + return true; +} |