2009-09-24 21:39:46 +02:00
|
|
|
/*
|
2011-01-29 10:13:54 +01:00
|
|
|
* Copyright (C) 2003-2011 The Music Player Daemon Project
|
2009-09-24 21:39:46 +02:00
|
|
|
* 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.
|
|
|
|
*/
|
|
|
|
|
2009-11-11 14:13:24 +01:00
|
|
|
#include "config.h" /* must be first for large file support */
|
2009-09-24 21:39:46 +02:00
|
|
|
#include "update_internal.h"
|
2012-02-12 17:00:00 +01:00
|
|
|
#include "update_io.h"
|
2012-02-12 17:06:34 +01:00
|
|
|
#include "update_db.h"
|
2009-09-24 21:39:46 +02:00
|
|
|
#include "database.h"
|
2012-01-31 22:12:14 +01:00
|
|
|
#include "db_lock.h"
|
2009-10-16 18:11:43 +02:00
|
|
|
#include "exclude.h"
|
2009-09-24 21:39:46 +02:00
|
|
|
#include "directory.h"
|
|
|
|
#include "song.h"
|
2012-02-12 17:50:30 +01:00
|
|
|
#include "playlist_vector.h"
|
2009-09-24 21:39:46 +02:00
|
|
|
#include "uri.h"
|
|
|
|
#include "mapper.h"
|
|
|
|
#include "path.h"
|
|
|
|
#include "decoder_list.h"
|
|
|
|
#include "decoder_plugin.h"
|
2010-07-21 08:58:15 +02:00
|
|
|
#include "playlist_list.h"
|
2012-06-03 09:00:11 +02:00
|
|
|
#include "glib_compat.h"
|
2009-09-24 21:39:46 +02:00
|
|
|
#include "conf.h"
|
2012-02-11 19:12:02 +01:00
|
|
|
#include "tag.h"
|
|
|
|
#include "tag_handler.h"
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2009-11-11 14:13:24 +01:00
|
|
|
#ifdef ENABLE_ARCHIVE
|
|
|
|
#include "archive_list.h"
|
2009-12-15 17:36:21 +01:00
|
|
|
#include "archive_plugin.h"
|
2009-11-11 14:13:24 +01:00
|
|
|
#endif
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
#include <glib.h>
|
|
|
|
|
|
|
|
#include <assert.h>
|
|
|
|
#include <sys/types.h>
|
|
|
|
#include <sys/stat.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
#include <dirent.h>
|
|
|
|
#include <string.h>
|
|
|
|
#include <stdlib.h>
|
|
|
|
#include <errno.h>
|
|
|
|
|
2009-09-24 21:55:40 +02:00
|
|
|
static bool walk_discard;
|
2009-09-24 21:39:46 +02:00
|
|
|
static bool modified;
|
|
|
|
|
|
|
|
#ifndef WIN32
|
|
|
|
|
|
|
|
enum {
|
|
|
|
DEFAULT_FOLLOW_INSIDE_SYMLINKS = true,
|
|
|
|
DEFAULT_FOLLOW_OUTSIDE_SYMLINKS = true,
|
|
|
|
};
|
|
|
|
|
|
|
|
static bool follow_inside_symlinks;
|
|
|
|
static bool follow_outside_symlinks;
|
|
|
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
void
|
|
|
|
update_walk_global_init(void)
|
|
|
|
{
|
|
|
|
#ifndef WIN32
|
|
|
|
follow_inside_symlinks =
|
|
|
|
config_get_bool(CONF_FOLLOW_INSIDE_SYMLINKS,
|
|
|
|
DEFAULT_FOLLOW_INSIDE_SYMLINKS);
|
|
|
|
|
|
|
|
follow_outside_symlinks =
|
|
|
|
config_get_bool(CONF_FOLLOW_OUTSIDE_SYMLINKS,
|
|
|
|
DEFAULT_FOLLOW_OUTSIDE_SYMLINKS);
|
|
|
|
#endif
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
update_walk_global_finish(void)
|
|
|
|
{
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
directory_set_stat(struct directory *dir, const struct stat *st)
|
|
|
|
{
|
|
|
|
dir->inode = st->st_ino;
|
|
|
|
dir->device = st->st_dev;
|
2011-11-27 20:15:25 +01:00
|
|
|
dir->have_stat = true;
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
|
2009-10-16 18:11:43 +02:00
|
|
|
static void
|
|
|
|
remove_excluded_from_directory(struct directory *directory,
|
|
|
|
GSList *exclude_list)
|
|
|
|
{
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
|
|
|
|
2012-01-24 18:20:58 +01:00
|
|
|
struct directory *child, *n;
|
|
|
|
directory_for_each_child_safe(child, n, directory) {
|
2009-10-16 18:11:43 +02:00
|
|
|
char *name_fs = utf8_to_fs_charset(directory_get_name(child));
|
|
|
|
|
|
|
|
if (exclude_list_check(exclude_list, name_fs)) {
|
|
|
|
delete_directory(child);
|
|
|
|
modified = true;
|
|
|
|
}
|
|
|
|
|
|
|
|
g_free(name_fs);
|
|
|
|
}
|
|
|
|
|
2012-01-24 21:33:09 +01:00
|
|
|
struct song *song, *ns;
|
|
|
|
directory_for_each_song_safe(song, ns, directory) {
|
|
|
|
assert(song->parent == directory);
|
2009-10-16 18:11:43 +02:00
|
|
|
|
2012-01-24 21:33:09 +01:00
|
|
|
char *name_fs = utf8_to_fs_charset(song->uri);
|
|
|
|
if (exclude_list_check(exclude_list, name_fs)) {
|
|
|
|
delete_song(directory, song);
|
|
|
|
modified = true;
|
|
|
|
}
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2012-01-24 21:33:09 +01:00
|
|
|
g_free(name_fs);
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
2012-01-31 22:12:14 +01:00
|
|
|
|
|
|
|
db_unlock();
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2012-06-13 20:48:30 +02:00
|
|
|
purge_deleted_from_directory(struct directory *directory)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
2012-01-24 18:20:58 +01:00
|
|
|
struct directory *child, *n;
|
|
|
|
directory_for_each_child_safe(child, n, directory) {
|
|
|
|
if (directory_exists(child))
|
2009-09-24 21:39:46 +02:00
|
|
|
continue;
|
|
|
|
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-01-24 18:20:58 +01:00
|
|
|
delete_directory(child);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
modified = true;
|
|
|
|
}
|
|
|
|
|
2012-01-24 21:33:09 +01:00
|
|
|
struct song *song, *ns;
|
|
|
|
directory_for_each_song_safe(song, ns, directory) {
|
|
|
|
char *path;
|
|
|
|
struct stat st;
|
|
|
|
if ((path = map_song_fs(song)) == NULL ||
|
|
|
|
stat(path, &st) < 0 || !S_ISREG(st.st_mode)) {
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-01-24 21:33:09 +01:00
|
|
|
delete_song(directory, song);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
|
|
|
|
2012-01-24 21:33:09 +01:00
|
|
|
modified = true;
|
|
|
|
}
|
|
|
|
|
|
|
|
g_free(path);
|
|
|
|
}
|
2010-07-21 08:58:15 +02:00
|
|
|
|
2012-02-12 17:50:30 +01:00
|
|
|
struct playlist_metadata *pm, *np;
|
|
|
|
directory_for_each_playlist_safe(pm, np, directory) {
|
2012-02-13 19:25:03 +01:00
|
|
|
if (!directory_child_is_regular(directory, pm->name)) {
|
|
|
|
db_lock();
|
2010-07-21 08:58:15 +02:00
|
|
|
playlist_vector_remove(&directory->playlists, pm->name);
|
2012-02-13 19:25:03 +01:00
|
|
|
db_unlock();
|
|
|
|
}
|
2010-07-21 08:58:15 +02:00
|
|
|
}
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
|
2010-05-19 07:48:52 +02:00
|
|
|
#ifndef G_OS_WIN32
|
2009-09-24 21:39:46 +02:00
|
|
|
static int
|
2012-06-13 20:48:30 +02:00
|
|
|
update_directory_stat(struct directory *directory)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
|
|
|
struct stat st;
|
2012-06-13 20:48:30 +02:00
|
|
|
if (stat_directory(directory, &st) < 0)
|
2009-09-24 21:39:46 +02:00
|
|
|
return -1;
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
directory_set_stat(directory, &st);
|
2009-09-24 21:39:46 +02:00
|
|
|
return 0;
|
|
|
|
}
|
2010-05-19 07:48:52 +02:00
|
|
|
#endif
|
2009-09-24 21:39:46 +02:00
|
|
|
|
|
|
|
static int
|
2012-06-13 20:48:30 +02:00
|
|
|
find_inode_ancestor(struct directory *parent, ino_t inode, dev_t device)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
2010-05-19 07:48:52 +02:00
|
|
|
#ifndef G_OS_WIN32
|
2009-09-24 21:39:46 +02:00
|
|
|
while (parent) {
|
2012-06-13 20:48:30 +02:00
|
|
|
if (!parent->have_stat && update_directory_stat(parent) < 0)
|
2009-09-24 21:39:46 +02:00
|
|
|
return -1;
|
2012-06-13 20:48:30 +02:00
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
if (parent->inode == inode && parent->device == device) {
|
|
|
|
g_debug("recursive directory found");
|
|
|
|
return 1;
|
|
|
|
}
|
2012-06-13 20:48:30 +02:00
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
parent = parent->parent;
|
|
|
|
}
|
2010-05-19 07:48:52 +02:00
|
|
|
#else
|
|
|
|
(void)parent;
|
|
|
|
(void)inode;
|
|
|
|
(void)device;
|
|
|
|
#endif
|
2009-09-24 21:39:46 +02:00
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
#ifdef ENABLE_ARCHIVE
|
|
|
|
static void
|
|
|
|
update_archive_tree(struct directory *directory, char *name)
|
|
|
|
{
|
2012-06-13 20:48:30 +02:00
|
|
|
char *tmp = strchr(name, '/');
|
2009-09-24 21:39:46 +02:00
|
|
|
if (tmp) {
|
|
|
|
*tmp = 0;
|
|
|
|
//add dir is not there already
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-06-13 20:48:30 +02:00
|
|
|
struct directory *subdir =
|
|
|
|
directory_make_child(directory, name);
|
2012-02-02 17:59:46 +01:00
|
|
|
subdir->device = DEVICE_INARCHIVE;
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
2009-09-24 21:39:46 +02:00
|
|
|
//create directories first
|
|
|
|
update_archive_tree(subdir, tmp+1);
|
|
|
|
} else {
|
|
|
|
if (strlen(name) == 0) {
|
|
|
|
g_warning("archive returned directory only");
|
|
|
|
return;
|
|
|
|
}
|
2012-06-13 20:48:30 +02:00
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
//add file
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-01-24 21:38:31 +01:00
|
|
|
struct song *song = directory_get_song(directory, name);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
2009-09-24 21:39:46 +02:00
|
|
|
if (song == NULL) {
|
|
|
|
song = song_file_load(name, directory);
|
|
|
|
if (song != NULL) {
|
2012-06-13 21:23:34 +02:00
|
|
|
db_lock();
|
2012-01-24 21:38:31 +01:00
|
|
|
directory_add_song(directory, song);
|
2012-06-13 21:23:34 +02:00
|
|
|
db_unlock();
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
modified = true;
|
|
|
|
g_message("added %s/%s",
|
|
|
|
directory_get_path(directory), name);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Updates the file listing from an archive file.
|
|
|
|
*
|
|
|
|
* @param parent the parent directory the archive file resides in
|
|
|
|
* @param name the UTF-8 encoded base name of the archive file
|
|
|
|
* @param st stat() information on the archive file
|
|
|
|
* @param plugin the archive plugin which fits this archive type
|
|
|
|
*/
|
|
|
|
static void
|
|
|
|
update_archive_file(struct directory *parent, const char *name,
|
|
|
|
const struct stat *st,
|
|
|
|
const struct archive_plugin *plugin)
|
|
|
|
{
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-06-13 20:48:30 +02:00
|
|
|
struct directory *directory = directory_get_child(parent, name);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
2012-06-13 20:48:30 +02:00
|
|
|
|
2009-09-24 21:55:40 +02:00
|
|
|
if (directory != NULL && directory->mtime == st->st_mtime &&
|
|
|
|
!walk_discard)
|
2009-09-24 21:39:46 +02:00
|
|
|
/* MPD has already scanned the archive, and it hasn't
|
|
|
|
changed since - don't consider updating it */
|
|
|
|
return;
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
char *path_fs = map_directory_child_fs(parent, name);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
|
|
|
/* open archive */
|
2012-06-13 20:48:30 +02:00
|
|
|
GError *error = NULL;
|
|
|
|
struct archive_file *file = archive_file_open(plugin, path_fs, &error);
|
2009-09-24 21:39:46 +02:00
|
|
|
if (file == NULL) {
|
|
|
|
g_free(path_fs);
|
2009-12-16 16:40:22 +01:00
|
|
|
g_warning("%s", error->message);
|
|
|
|
g_error_free(error);
|
2009-09-24 21:39:46 +02:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
g_debug("archive %s opened", path_fs);
|
|
|
|
g_free(path_fs);
|
|
|
|
|
|
|
|
if (directory == NULL) {
|
|
|
|
g_debug("creating archive directory: %s", name);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-01-24 19:07:11 +01:00
|
|
|
directory = directory_new_child(parent, name);
|
2009-09-24 21:39:46 +02:00
|
|
|
/* mark this directory as archive (we use device for
|
|
|
|
this) */
|
|
|
|
directory->device = DEVICE_INARCHIVE;
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
directory->mtime = st->st_mtime;
|
|
|
|
|
2009-12-16 16:28:26 +01:00
|
|
|
archive_file_scan_reset(file);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
char *filepath;
|
2009-12-16 16:28:26 +01:00
|
|
|
while ((filepath = archive_file_scan_next(file)) != NULL) {
|
2009-09-24 21:39:46 +02:00
|
|
|
/* split name into directory and file */
|
|
|
|
g_debug("adding archive file: %s", filepath);
|
|
|
|
update_archive_tree(directory, filepath);
|
|
|
|
}
|
|
|
|
|
2009-12-16 16:28:26 +01:00
|
|
|
archive_file_close(file);
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
#endif
|
|
|
|
|
2012-06-13 21:04:43 +02:00
|
|
|
/**
|
|
|
|
* 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;
|
|
|
|
}
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
static bool
|
2012-06-13 20:48:30 +02:00
|
|
|
update_container_file(struct directory *directory,
|
|
|
|
const char *name,
|
|
|
|
const struct stat *st,
|
|
|
|
const struct decoder_plugin *plugin)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-06-13 21:04:43 +02:00
|
|
|
struct directory *contdir =
|
|
|
|
make_directory_if_modified(directory, name, st);
|
|
|
|
if (contdir == NULL) {
|
|
|
|
/* not modified */
|
|
|
|
db_unlock();
|
|
|
|
return true;
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
contdir->device = DEVICE_CONTAINER;
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2012-06-13 21:04:43 +02:00
|
|
|
char *const pathname = map_directory_child_fs(directory, name);
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
char *vtrack;
|
|
|
|
unsigned int tnum = 0;
|
|
|
|
while ((vtrack = plugin->container_scan(pathname, ++tnum)) != NULL) {
|
|
|
|
struct song *song = song_file_new(vtrack, contdir);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
|
|
|
// shouldn't be necessary but it's there..
|
|
|
|
song->mtime = st->st_mtime;
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
char *child_path_fs = map_directory_child_fs(contdir, vtrack);
|
2009-10-18 19:02:43 +02:00
|
|
|
|
2012-02-11 19:12:02 +01:00
|
|
|
song->tag = tag_new();
|
|
|
|
decoder_plugin_scan_file(plugin, child_path_fs,
|
|
|
|
&add_tag_handler, song->tag);
|
2009-10-18 19:02:43 +02:00
|
|
|
g_free(child_path_fs);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2012-06-13 21:23:34 +02:00
|
|
|
db_lock();
|
2012-01-24 21:38:31 +01:00
|
|
|
directory_add_song(contdir, song);
|
2012-06-13 21:23:34 +02:00
|
|
|
db_unlock();
|
2009-09-24 21:39:46 +02:00
|
|
|
|
|
|
|
modified = true;
|
2009-11-07 16:03:25 +01:00
|
|
|
|
|
|
|
g_message("added %s/%s",
|
|
|
|
directory_get_path(directory), vtrack);
|
|
|
|
g_free(vtrack);
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
g_free(pathname);
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
if (tnum == 1) {
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2009-09-24 21:39:46 +02:00
|
|
|
delete_directory(contdir);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
2009-09-24 21:39:46 +02:00
|
|
|
return false;
|
2012-06-13 20:48:30 +02:00
|
|
|
} else
|
2009-09-24 21:39:46 +02:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2012-02-12 16:50:24 +01:00
|
|
|
static void
|
|
|
|
update_song_file(struct directory *directory,
|
|
|
|
const char *name, const struct stat *st,
|
|
|
|
const struct decoder_plugin *plugin)
|
|
|
|
{
|
|
|
|
db_lock();
|
|
|
|
struct song *song = directory_get_song(directory, name);
|
|
|
|
db_unlock();
|
|
|
|
|
|
|
|
if (!directory_child_access(directory, name, R_OK)) {
|
|
|
|
g_warning("no read permissions on %s/%s",
|
|
|
|
directory_get_path(directory), name);
|
|
|
|
if (song != NULL) {
|
|
|
|
db_lock();
|
|
|
|
delete_song(directory, song);
|
|
|
|
db_unlock();
|
|
|
|
}
|
|
|
|
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!(song != NULL && st->st_mtime == song->mtime &&
|
|
|
|
!walk_discard) &&
|
|
|
|
plugin->container_scan != NULL &&
|
|
|
|
update_container_file(directory, name, st, plugin)) {
|
|
|
|
if (song != NULL) {
|
|
|
|
db_lock();
|
|
|
|
delete_song(directory, song);
|
|
|
|
db_unlock();
|
|
|
|
}
|
|
|
|
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (song == NULL) {
|
|
|
|
g_debug("reading %s/%s",
|
|
|
|
directory_get_path(directory), name);
|
|
|
|
song = song_file_load(name, directory);
|
|
|
|
if (song == NULL) {
|
|
|
|
g_debug("ignoring unrecognized file %s/%s",
|
|
|
|
directory_get_path(directory), name);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2012-06-13 21:23:34 +02:00
|
|
|
db_lock();
|
2012-02-12 16:50:24 +01:00
|
|
|
directory_add_song(directory, song);
|
2012-06-13 21:23:34 +02:00
|
|
|
db_unlock();
|
|
|
|
|
2012-02-12 16:50:24 +01:00
|
|
|
modified = true;
|
|
|
|
g_message("added %s/%s",
|
|
|
|
directory_get_path(directory), name);
|
|
|
|
} else if (st->st_mtime != song->mtime || walk_discard) {
|
|
|
|
g_message("updating %s/%s",
|
|
|
|
directory_get_path(directory), name);
|
|
|
|
if (!song_file_update(song)) {
|
|
|
|
g_debug("deleting unrecognized file %s/%s",
|
|
|
|
directory_get_path(directory), name);
|
|
|
|
db_lock();
|
|
|
|
delete_song(directory, song);
|
|
|
|
db_unlock();
|
|
|
|
}
|
|
|
|
|
|
|
|
modified = true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
static void
|
|
|
|
update_regular_file(struct directory *directory,
|
|
|
|
const char *name, const struct stat *st)
|
|
|
|
{
|
|
|
|
const char *suffix = uri_get_suffix(name);
|
2012-06-13 20:48:30 +02:00
|
|
|
const struct decoder_plugin *plugin;
|
2009-09-24 21:39:46 +02:00
|
|
|
#ifdef ENABLE_ARCHIVE
|
|
|
|
const struct archive_plugin *archive;
|
|
|
|
#endif
|
|
|
|
if (suffix == NULL)
|
|
|
|
return;
|
|
|
|
|
|
|
|
if ((plugin = decoder_plugin_from_suffix(suffix, false)) != NULL)
|
|
|
|
{
|
2012-02-12 16:50:24 +01:00
|
|
|
update_song_file(directory, name, st, plugin);
|
2009-09-24 21:39:46 +02:00
|
|
|
#ifdef ENABLE_ARCHIVE
|
|
|
|
} else if ((archive = archive_plugin_from_suffix(suffix))) {
|
|
|
|
update_archive_file(directory, name, st, archive);
|
|
|
|
#endif
|
2010-07-21 08:58:15 +02:00
|
|
|
|
|
|
|
} else if (playlist_suffix_supported(suffix)) {
|
2012-02-13 19:25:03 +01:00
|
|
|
db_lock();
|
2010-09-07 20:19:53 +02:00
|
|
|
if (playlist_vector_update_or_add(&directory->playlists, name,
|
|
|
|
st->st_mtime))
|
|
|
|
modified = true;
|
2012-02-13 19:25:03 +01:00
|
|
|
db_unlock();
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static bool
|
2012-06-13 20:48:30 +02:00
|
|
|
update_directory(struct directory *directory, const struct stat *st);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
|
|
|
static void
|
2012-06-13 20:48:30 +02:00
|
|
|
update_directory_child(struct directory *directory,
|
|
|
|
const char *name, const struct stat *st)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
|
|
|
assert(strchr(name, '/') == NULL);
|
|
|
|
|
|
|
|
if (S_ISREG(st->st_mode)) {
|
|
|
|
update_regular_file(directory, name, st);
|
|
|
|
} else if (S_ISDIR(st->st_mode)) {
|
2012-06-13 20:48:30 +02:00
|
|
|
if (find_inode_ancestor(directory, st->st_ino, st->st_dev))
|
2009-09-24 21:39:46 +02:00
|
|
|
return;
|
|
|
|
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-06-13 20:48:30 +02:00
|
|
|
struct directory *subdir =
|
|
|
|
directory_make_child(directory, name);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
assert(directory == subdir->parent);
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
if (!update_directory(subdir, st)) {
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2009-09-24 21:39:46 +02:00
|
|
|
delete_directory(subdir);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
|
|
|
}
|
2009-09-24 21:39:46 +02:00
|
|
|
} else {
|
|
|
|
g_debug("update: %s is not a directory, archive or music", name);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* we don't look at "." / ".." nor files with newlines in their name */
|
2012-06-13 21:22:41 +02:00
|
|
|
G_GNUC_PURE
|
2009-09-24 21:39:46 +02:00
|
|
|
static bool skip_path(const char *path)
|
|
|
|
{
|
|
|
|
return (path[0] == '.' && path[1] == 0) ||
|
|
|
|
(path[0] == '.' && path[1] == '.' && path[2] == 0) ||
|
|
|
|
strchr(path, '\n') != NULL;
|
|
|
|
}
|
|
|
|
|
2012-06-13 21:22:41 +02:00
|
|
|
G_GNUC_PURE
|
2009-09-24 21:39:46 +02:00
|
|
|
static bool
|
|
|
|
skip_symlink(const struct directory *directory, const char *utf8_name)
|
|
|
|
{
|
|
|
|
#ifndef WIN32
|
2012-06-13 20:48:30 +02:00
|
|
|
char *path_fs = map_directory_child_fs(directory, utf8_name);
|
2009-09-24 21:39:46 +02:00
|
|
|
if (path_fs == NULL)
|
|
|
|
return true;
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
char buffer[MPD_PATH_MAX];
|
|
|
|
ssize_t ret = readlink(path_fs, buffer, sizeof(buffer));
|
2009-09-24 21:39:46 +02:00
|
|
|
g_free(path_fs);
|
|
|
|
if (ret < 0)
|
|
|
|
/* don't skip if this is not a symlink */
|
|
|
|
return errno != EINVAL;
|
|
|
|
|
|
|
|
if (!follow_inside_symlinks && !follow_outside_symlinks) {
|
|
|
|
/* ignore all symlinks */
|
|
|
|
return true;
|
|
|
|
} else if (follow_inside_symlinks && follow_outside_symlinks) {
|
|
|
|
/* consider all symlinks */
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
2011-07-20 07:05:10 +02:00
|
|
|
if (g_path_is_absolute(buffer)) {
|
|
|
|
/* if the symlink points to an absolute path, see if
|
|
|
|
that path is inside the music directory */
|
|
|
|
const char *relative = map_to_relative_path(buffer);
|
|
|
|
return relative > buffer
|
|
|
|
? !follow_inside_symlinks
|
|
|
|
: !follow_outside_symlinks;
|
|
|
|
}
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
const char *p = buffer;
|
2009-09-24 21:39:46 +02:00
|
|
|
while (*p == '.') {
|
2009-10-20 21:01:55 +02:00
|
|
|
if (p[1] == '.' && G_IS_DIR_SEPARATOR(p[2])) {
|
2009-09-24 21:39:46 +02:00
|
|
|
/* "../" moves to parent directory */
|
|
|
|
directory = directory->parent;
|
|
|
|
if (directory == NULL) {
|
|
|
|
/* we have moved outside the music
|
|
|
|
directory - skip this symlink
|
|
|
|
if such symlinks are not allowed */
|
|
|
|
return !follow_outside_symlinks;
|
|
|
|
}
|
|
|
|
p += 3;
|
2009-10-20 21:01:55 +02:00
|
|
|
} else if (G_IS_DIR_SEPARATOR(p[1]))
|
2009-09-24 21:39:46 +02:00
|
|
|
/* eliminate "./" */
|
|
|
|
p += 2;
|
|
|
|
else
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* we are still in the music directory, so this symlink points
|
|
|
|
to a song which is already in the database - skip according
|
|
|
|
to the follow_inside_symlinks param*/
|
|
|
|
return !follow_inside_symlinks;
|
|
|
|
#else
|
|
|
|
/* no symlink checking on WIN32 */
|
|
|
|
|
|
|
|
(void)directory;
|
|
|
|
(void)utf8_name;
|
|
|
|
|
|
|
|
return false;
|
|
|
|
#endif
|
|
|
|
}
|
|
|
|
|
|
|
|
static bool
|
2012-06-13 20:48:30 +02:00
|
|
|
update_directory(struct directory *directory, const struct stat *st)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
|
|
|
assert(S_ISDIR(st->st_mode));
|
|
|
|
|
|
|
|
directory_set_stat(directory, st);
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
char *path_fs = map_directory_fs(directory);
|
2009-09-24 21:39:46 +02:00
|
|
|
if (path_fs == NULL)
|
|
|
|
return false;
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
DIR *dir = opendir(path_fs);
|
2009-09-24 21:39:46 +02:00
|
|
|
if (!dir) {
|
|
|
|
g_warning("Failed to open directory %s: %s",
|
|
|
|
path_fs, g_strerror(errno));
|
|
|
|
g_free(path_fs);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
char *exclude_path_fs = g_build_filename(path_fs, ".mpdignore", NULL);
|
|
|
|
GSList *exclude_list = exclude_list_load(exclude_path_fs);
|
2009-10-16 18:11:43 +02:00
|
|
|
g_free(exclude_path_fs);
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
g_free(path_fs);
|
|
|
|
|
2009-10-16 18:11:43 +02:00
|
|
|
if (exclude_list != NULL)
|
|
|
|
remove_excluded_from_directory(directory, exclude_list);
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
purge_deleted_from_directory(directory);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
struct dirent *ent;
|
2009-09-24 21:39:46 +02:00
|
|
|
while ((ent = readdir(dir))) {
|
|
|
|
char *utf8;
|
|
|
|
struct stat st2;
|
|
|
|
|
2009-10-16 18:11:43 +02:00
|
|
|
if (skip_path(ent->d_name) ||
|
|
|
|
exclude_list_check(exclude_list, ent->d_name))
|
2009-09-24 21:39:46 +02:00
|
|
|
continue;
|
|
|
|
|
|
|
|
utf8 = fs_charset_to_utf8(ent->d_name);
|
2009-10-31 18:23:56 +01:00
|
|
|
if (utf8 == NULL)
|
|
|
|
continue;
|
|
|
|
|
|
|
|
if (skip_symlink(directory, utf8)) {
|
2012-02-12 17:06:34 +01:00
|
|
|
modified |= delete_name_in(directory, utf8);
|
2009-09-24 21:39:46 +02:00
|
|
|
g_free(utf8);
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (stat_directory_child(directory, utf8, &st2) == 0)
|
2012-06-13 20:48:30 +02:00
|
|
|
update_directory_child(directory, utf8, &st2);
|
2009-09-24 21:39:46 +02:00
|
|
|
else
|
2012-02-12 17:06:34 +01:00
|
|
|
modified |= delete_name_in(directory, utf8);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
|
|
|
g_free(utf8);
|
|
|
|
}
|
|
|
|
|
2009-10-16 18:11:43 +02:00
|
|
|
exclude_list_free(exclude_list);
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
closedir(dir);
|
|
|
|
|
|
|
|
directory->mtime = st->st_mtime;
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
static struct directory *
|
2012-01-24 19:07:11 +01:00
|
|
|
directory_make_child_checked(struct directory *parent, const char *name_utf8)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-06-13 20:48:30 +02:00
|
|
|
struct directory *directory = directory_get_child(parent, name_utf8);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
2012-06-13 20:48:30 +02:00
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
if (directory != NULL)
|
|
|
|
return directory;
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
struct stat st;
|
2012-01-24 19:07:11 +01:00
|
|
|
if (stat_directory_child(parent, name_utf8, &st) < 0 ||
|
2012-06-13 20:48:30 +02:00
|
|
|
find_inode_ancestor(parent, st.st_ino, st.st_dev))
|
2009-09-24 21:39:46 +02:00
|
|
|
return NULL;
|
|
|
|
|
2012-04-05 00:45:39 +02:00
|
|
|
if (skip_symlink(parent, name_utf8))
|
2012-04-04 08:56:45 +02:00
|
|
|
return NULL;
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
/* if we're adding directory paths, make sure to delete filenames
|
|
|
|
with potentially the same name */
|
2012-01-31 22:12:14 +01:00
|
|
|
db_lock();
|
2012-01-24 21:38:31 +01:00
|
|
|
struct song *conflicting = directory_get_song(parent, name_utf8);
|
2009-09-24 21:39:46 +02:00
|
|
|
if (conflicting)
|
|
|
|
delete_song(parent, conflicting);
|
|
|
|
|
2012-01-24 19:07:11 +01:00
|
|
|
directory = directory_new_child(parent, name_utf8);
|
2012-01-31 22:12:14 +01:00
|
|
|
db_unlock();
|
|
|
|
|
2009-09-24 21:39:46 +02:00
|
|
|
directory_set_stat(directory, &st);
|
|
|
|
return directory;
|
|
|
|
}
|
|
|
|
|
|
|
|
static struct directory *
|
2012-06-13 20:48:30 +02:00
|
|
|
directory_make_uri_parent_checked(const char *uri)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
|
|
|
struct directory *directory = db_get_root();
|
2012-06-13 20:48:30 +02:00
|
|
|
char *duplicated = g_strdup(uri);
|
2012-01-24 19:07:11 +01:00
|
|
|
char *name_utf8 = duplicated, *slash;
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2012-01-24 19:07:11 +01:00
|
|
|
while ((slash = strchr(name_utf8, '/')) != NULL) {
|
2009-09-24 21:39:46 +02:00
|
|
|
*slash = 0;
|
|
|
|
|
2012-01-24 19:07:11 +01:00
|
|
|
if (*name_utf8 == 0)
|
|
|
|
continue;
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
directory = directory_make_child_checked(directory, name_utf8);
|
2012-01-24 19:07:11 +01:00
|
|
|
if (directory == NULL)
|
2009-09-24 21:39:46 +02:00
|
|
|
break;
|
|
|
|
|
2012-01-24 19:07:11 +01:00
|
|
|
name_utf8 = slash + 1;
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
g_free(duplicated);
|
|
|
|
return directory;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2012-06-13 20:48:30 +02:00
|
|
|
update_uri(const char *uri)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
2012-06-13 20:48:30 +02:00
|
|
|
struct directory *parent = directory_make_uri_parent_checked(uri);
|
2009-09-24 21:39:46 +02:00
|
|
|
if (parent == NULL)
|
|
|
|
return;
|
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
char *name = g_path_get_basename(uri);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
2012-06-13 20:48:30 +02:00
|
|
|
struct stat st;
|
2012-04-04 08:56:45 +02:00
|
|
|
if (!skip_symlink(parent, name) &&
|
|
|
|
stat_directory_child(parent, name, &st) == 0)
|
2012-06-13 20:48:30 +02:00
|
|
|
update_directory_child(parent, name, &st);
|
2009-09-24 21:39:46 +02:00
|
|
|
else
|
2012-02-12 17:06:34 +01:00
|
|
|
modified |= delete_name_in(parent, name);
|
2009-09-24 21:39:46 +02:00
|
|
|
|
|
|
|
g_free(name);
|
|
|
|
}
|
|
|
|
|
|
|
|
bool
|
2009-09-24 21:55:40 +02:00
|
|
|
update_walk(const char *path, bool discard)
|
2009-09-24 21:39:46 +02:00
|
|
|
{
|
2009-09-24 21:55:40 +02:00
|
|
|
walk_discard = discard;
|
2009-09-24 21:39:46 +02:00
|
|
|
modified = false;
|
|
|
|
|
|
|
|
if (path != NULL && !isRootDirectory(path)) {
|
2012-06-13 20:48:30 +02:00
|
|
|
update_uri(path);
|
2009-09-24 21:39:46 +02:00
|
|
|
} else {
|
|
|
|
struct directory *directory = db_get_root();
|
|
|
|
struct stat st;
|
|
|
|
|
|
|
|
if (stat_directory(directory, &st) == 0)
|
2012-06-13 20:48:30 +02:00
|
|
|
update_directory(directory, &st);
|
2009-09-24 21:39:46 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
return modified;
|
|
|
|
}
|