oysteikt/mpd
0
0
Fork 0
Code Issues Pull Requests Releases Activity

update_walk: move code to update_archive.c

Browse Source
This commit is contained in:
Max Kellermann 2012-06-13 21:28:26 +02:00
parent ddf7f5c131
commit c9e63e9fdb
5 changed files with 250 additions and 135 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Makefile.am
View File

@ -269,6 +269,7 @@ src_mpd_SOURCES = \
src/update_io.c src/update_io.h \
src/update_db.c src/update_db.h \
src/update_walk.c src/update_walk.h \
src/update_internal.h \
src/update_remove.c \
src/client.c \
src/client_event.c \
@ -431,6 +432,9 @@ if ENABLE_ARCHIVE
noinst_LIBRARIES += libarchive.a
src_mpd_SOURCES += \
src/update_archive.c src/update_archive.h
libarchive_a_SOURCES = \
src/archive_api.c \
src/archive_list.c \

157
src/update_archive.c Normal file
View File

@ -0,0 +1,157 @@
/*
* 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_archive.h"
#include "update_internal.h"
#include "db_lock.h"
#include "directory.h"
#include "song.h"
#include "mapper.h"
#include "glib_compat.h"
#include "archive_list.h"
#include "archive_plugin.h"
#include <glib.h>
#include <string.h>
static void
update_archive_tree(struct directory *directory, char *name)
{
char *tmp = strchr(name, '/');
if (tmp) {
*tmp = 0;
//add dir is not there already
db_lock();
struct directory *subdir =
directory_make_child(directory, name);
subdir->device = DEVICE_INARCHIVE;
db_unlock();
//create directories first
update_archive_tree(subdir, tmp+1);
} else {
if (strlen(name) == 0) {
g_warning("archive returned directory only");
return;
}
//add file
db_lock();
struct song *song = directory_get_song(directory, name);
db_unlock();
if (song == NULL) {
song = song_file_load(name, directory);
if (song != NULL) {
db_lock();
directory_add_song(directory, song);
db_unlock();
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_file2(struct directory *parent, const char *name,
const struct stat *st,
const struct archive_plugin *plugin)
{
db_lock();
struct directory *directory = directory_get_child(parent, name);
db_unlock();
if (directory != NULL && directory->mtime == st->st_mtime &&
!walk_discard)
/* MPD has already scanned the archive, and it hasn't
changed since - don't consider updating it */
return;
char *path_fs = map_directory_child_fs(parent, name);
/* open archive */
GError *error = NULL;
struct archive_file *file = archive_file_open(plugin, path_fs, &error);
if (file == NULL) {
g_free(path_fs);
g_warning("%s", error->message);
g_error_free(error);
return;
}
g_debug("archive %s opened", path_fs);
g_free(path_fs);
if (directory == NULL) {
g_debug("creating archive directory: %s", name);
db_lock();
directory = directory_new_child(parent, name);
/* mark this directory as archive (we use device for
this) */
directory->device = DEVICE_INARCHIVE;
db_unlock();
}
directory->mtime = st->st_mtime;
archive_file_scan_reset(file);
char *filepath;
while ((filepath = archive_file_scan_next(file)) != NULL) {
/* split name into directory and file */
g_debug("adding archive file: %s", filepath);
update_archive_tree(directory, filepath);
}
archive_file_close(file);
}
bool
update_archive_file(struct directory *directory,
const char *name, const char *suffix,
const struct stat *st)
{
#ifdef ENABLE_ARCHIVE
const struct archive_plugin *plugin =
archive_plugin_from_suffix(suffix);
if (plugin == NULL)
return false;
update_archive_file2(directory, name, st, plugin);
return true;
#else
(void)directory;
(void)name;
(void)suffix;
(void)st;
return false;
#endif
}

53
src/update_archive.h Normal file
View File

@ -0,0 +1,53 @@
/*
* 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.
*/
#ifndef MPD_UPDATE_ARCHIVE_H
#define MPD_UPDATE_ARCHIVE_H
#include "check.h"
#include <stdbool.h>
#include <sys/stat.h>
struct directory;
struct archive_plugin;
#ifdef ENABLE_ARCHIVE
bool
update_archive_file(struct directory *directory,
const char *name, const char *suffix,
const struct stat *st);
#else
#include <glib.h>
static inline bool
update_archive_file(G_GNUC_UNUSED struct directory *directory,
G_GNUC_UNUSED const char *name,
G_GNUC_UNUSED const char *suffix,
G_GNUC_UNUSED const struct stat *st)
{
return false;
}
#endif
#endif

30
src/update_internal.h Normal file
View File

@ -0,0 +1,30 @@
/*
* Copyright (C) 2003-2011 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.
*/
#ifndef MPD_UPDATE_INTERNAL_H
#define MPD_UPDATE_INTERNAL_H
#include "check.h"
#include <stdbool.h>
extern bool walk_discard;
extern bool modified;
#endif

141
src/update_walk.c
View File

@ -1,5 +1,5 @@
/*
* Copyright (C) 2003-2011 The Music Player Daemon Project
* 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
@ -19,8 +19,10 @@
#include "config.h" /* must be first for large file support */
#include "update_walk.h"
#include "update_internal.h"
#include "update_io.h"
#include "update_db.h"
#include "update_archive.h"
#include "database.h"
#include "db_lock.h"
#include "exclude.h"
@ -38,11 +40,6 @@
#include "tag.h"
#include "tag_handler.h"
#ifdef ENABLE_ARCHIVE
#include "archive_list.h"
#include "archive_plugin.h"
#endif
#include <glib.h>
#include <assert.h>
@ -57,8 +54,8 @@
#undef G_LOG_DOMAIN
#define G_LOG_DOMAIN "update"
static bool walk_discard;
static bool modified;
bool walk_discard;
bool modified;
#ifndef WIN32
@ -211,109 +208,6 @@ find_inode_ancestor(struct directory *parent, ino_t inode, dev_t device)
return 0;
}
#ifdef ENABLE_ARCHIVE
static void
update_archive_tree(struct directory *directory, char *name)
{
char *tmp = strchr(name, '/');
if (tmp) {
*tmp = 0;
//add dir is not there already
db_lock();
struct directory *subdir =
directory_make_child(directory, name);
subdir->device = DEVICE_INARCHIVE;
db_unlock();
//create directories first
update_archive_tree(subdir, tmp+1);
} else {
if (strlen(name) == 0) {
g_warning("archive returned directory only");
return;
}
//add file
db_lock();
struct song *song = directory_get_song(directory, name);
db_unlock();
if (song == NULL) {
song = song_file_load(name, directory);
if (song != NULL) {
db_lock();
directory_add_song(directory, song);
db_unlock();
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)
{
db_lock();
struct directory *directory = directory_get_child(parent, name);
db_unlock();
if (directory != NULL && directory->mtime == st->st_mtime &&
!walk_discard)
/* MPD has already scanned the archive, and it hasn't
changed since - don't consider updating it */
return;
char *path_fs = map_directory_child_fs(parent, name);
/* open archive */
GError *error = NULL;
struct archive_file *file = archive_file_open(plugin, path_fs, &error);
if (file == NULL) {
g_free(path_fs);
g_warning("%s", error->message);
g_error_free(error);
return;
}
g_debug("archive %s opened", path_fs);
g_free(path_fs);
if (directory == NULL) {
g_debug("creating archive directory: %s", name);
db_lock();
directory = directory_new_child(parent, name);
/* mark this directory as archive (we use device for
this) */
directory->device = DEVICE_INARCHIVE;
db_unlock();
}
directory->mtime = st->st_mtime;
archive_file_scan_reset(file);
char *filepath;
while ((filepath = archive_file_scan_next(file)) != NULL) {
/* split name into directory and file */
g_debug("adding archive file: %s", filepath);
update_archive_tree(directory, filepath);
}
archive_file_close(file);
}
#endif
/**
* Create the specified directory object if it does not exist already
* or if the #stat object indicates that it has been modified since
@ -482,29 +376,6 @@ update_song_file2(struct directory *directory,
return true;
}
static bool
update_archive_file2(struct directory *directory,
const char *name, const char *suffix,
const struct stat *st)
{
#ifdef ENABLE_ARCHIVE
const struct archive_plugin *plugin =
archive_plugin_from_suffix(suffix);
if (plugin == NULL)
return false;
update_archive_file(directory, name, st, plugin);
return true;
#else
(void)directory;
(void)name;
(void)suffix;
(void)st;
return false;
#endif
}
static bool
update_playlist_file2(struct directory *directory,
const char *name, const char *suffix,
@ -530,7 +401,7 @@ update_regular_file(struct directory *directory,
return false;
return update_song_file2(directory, name, suffix, st) ||
update_archive_file2(directory, name, suffix, st) ||
update_archive_file(directory, name, suffix, st) ||
update_playlist_file2(directory, name, suffix, st);
}