aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/directory.c121
1 files changed, 49 insertions, 72 deletions
diff --git a/src/directory.c b/src/directory.c
index 230dea5dc..08b3fb0e2 100644
--- a/src/directory.c
+++ b/src/directory.c
@@ -48,9 +48,11 @@
#define DIRECTORY_UPDATE_EXIT_UPDATE 1
#define DIRECTORY_UPDATE_EXIT_ERROR 2
-#define DIRECTORY_RETURN_NOUPDATE 0
-#define DIRECTORY_RETURN_UPDATE 1
-#define DIRECTORY_RETURN_ERROR -1
+enum update_return {
+ UPDATE_RETURN_ERROR = -1,
+ UPDATE_RETURN_NOUPDATE = 0,
+ UPDATE_RETURN_UPDATED = 1
+};
static Directory *mp3rootDirectory;
@@ -73,16 +75,16 @@ static void freeDirectoryList(DirectoryList * list);
static void freeDirectory(Directory * directory);
-static int exploreDirectory(Directory * directory);
+static enum update_return exploreDirectory(Directory * directory);
-static int updateDirectory(Directory * directory);
+static enum update_return updateDirectory(Directory * directory);
static void deleteEmptyDirectoriesInDirectory(Directory * directory);
static void removeSongFromDirectory(Directory * directory,
const char *shortname);
-static int addSubDirectoryToDirectory(Directory * directory,
+static enum update_return addSubDirectoryToDirectory(Directory * directory,
const char *shortname,
const char *name, struct stat *st);
@@ -94,7 +96,7 @@ static Directory *getDirectory(const char *name);
static Song *getSongDetails(const char *file, const char **shortnameRet,
Directory ** directoryRet);
-static int updatePath(const char *utf8path);
+static enum update_return updatePath(const char *utf8path);
static void sortDirectory(Directory * directory);
@@ -175,7 +177,7 @@ int updateInit(int fd, List * pathList)
directory_updatePid = fork();
if (directory_updatePid == 0) {
/* child */
- int dbUpdated = 0;
+ enum update_return dbUpdated = UPDATE_RETURN_NOUPDATE;
unblockSignals();
@@ -198,7 +200,7 @@ int updateInit(int fd, List * pathList)
while (node) {
switch (updatePath(node->key)) {
case 1:
- dbUpdated = 1;
+ dbUpdated = UPDATE_RETURN_UPDATED;
break;
case 0:
break;
@@ -208,12 +210,11 @@ int updateInit(int fd, List * pathList)
node = node->nextNode;
}
} else {
- if ((dbUpdated = updateDirectory(mp3rootDirectory)) < 0) {
+ if ((dbUpdated = updateDirectory(mp3rootDirectory)) < 0)
exit(DIRECTORY_UPDATE_EXIT_ERROR);
- }
}
- if (!dbUpdated)
+ if (dbUpdated == UPDATE_RETURN_NOUPDATE)
exit(DIRECTORY_UPDATE_EXIT_NOUPDATE);
/* ignore signals since we don't want them to corrupt the db */
@@ -320,12 +321,7 @@ static void deleteEmptyDirectoriesInDirectory(Directory * directory)
}
}
-/* return values:
- -1 -> error
- 0 -> no error, but nothing updated
- 1 -> no error, and stuff updated
- */
-static int updateInDirectory(Directory * directory,
+static enum update_return updateInDirectory(Directory * directory,
const char *shortname, const char *name)
{
Song *song;
@@ -333,17 +329,17 @@ static int updateInDirectory(Directory * directory,
struct stat st;
if (myStat(name, &st))
- return -1;
+ return UPDATE_RETURN_ERROR;
if (S_ISREG(st.st_mode) && hasMusicSuffix(name, 0)) {
if (!(song = songvec_find(&directory->songs, shortname))) {
addToDirectory(directory, shortname, name);
- return DIRECTORY_RETURN_UPDATE;
+ return UPDATE_RETURN_UPDATED;
} else if (st.st_mtime != song->mtime) {
LOG("updating %s\n", name);
if (updateSongInfo(song) < 0)
removeSongFromDirectory(directory, shortname);
- return 1;
+ return UPDATE_RETURN_UPDATED;
}
} else if (S_ISDIR(st.st_mode)) {
if (findInList
@@ -356,7 +352,7 @@ static int updateInDirectory(Directory * directory,
}
}
- return 0;
+ return UPDATE_RETURN_NOUPDATE;
}
/* we don't look at hidden files nor files with newlines in them */
@@ -365,18 +361,14 @@ static int skip_path(const char *path)
return (path[0] == '.' || strchr(path, '\n')) ? 1 : 0;
}
-/* return values:
- -1 -> error
- 0 -> no error, but nothing removed
- 1 -> no error, and stuff removed
- */
-static int removeDeletedFromDirectory(char *path_max_tmp, Directory * directory)
+static enum update_return
+removeDeletedFromDirectory(char *path_max_tmp, Directory * directory)
{
const char *dirname = (directory && directory->path) ?
directory->path : NULL;
ListNode *node, *tmpNode;
DirectoryList *subdirs = directory->subDirectories;
- int ret = 0;
+ enum update_return ret = UPDATE_RETURN_NOUPDATE;
int i;
struct songvec *sv = &directory->songs;
@@ -393,7 +385,7 @@ static int removeDeletedFromDirectory(char *path_max_tmp, Directory * directory)
if (!isDir(path_max_tmp)) {
LOG("removing directory: %s\n", path_max_tmp);
deleteFromList(subdirs, node->key);
- ret = 1;
+ ret = UPDATE_RETURN_UPDATED;
}
}
node = tmpNode;
@@ -411,7 +403,7 @@ static int removeDeletedFromDirectory(char *path_max_tmp, Directory * directory)
if (!isFile(path_max_tmp, NULL)) {
removeSongFromDirectory(directory, song->url);
- ret = 1;
+ ret = UPDATE_RETURN_UPDATED;
}
}
@@ -483,12 +475,7 @@ static Directory *addParentPathToDB(const char *utf8path, const char **shortname
return (Directory *) parentDirectory;
}
-/* return values:
- -1 -> error
- 0 -> no error, but nothing updated
- 1 -> no error, and stuff updated
- */
-static int updatePath(const char *utf8path)
+static enum update_return updatePath(const char *utf8path)
{
Directory *directory;
Directory *parentDirectory;
@@ -496,11 +483,11 @@ static int updatePath(const char *utf8path)
const char *shortname;
char *path = sanitizePathDup(utf8path);
time_t mtime;
- int ret = 0;
+ enum update_return ret = UPDATE_RETURN_NOUPDATE;
char path_max_tmp[MPD_PATH_MAX];
if (NULL == path)
- return -1;
+ return UPDATE_RETURN_ERROR;
/* if path is in the DB try to update it, or else delete it */
if ((directory = getDirectoryDetails(path, &shortname))) {
@@ -515,21 +502,21 @@ static int updatePath(const char *utf8path)
/* we don't want to delete the root directory */
else if (directory == mp3rootDirectory) {
free(path);
- return 0;
+ return UPDATE_RETURN_NOUPDATE;
}
/* if updateDirectory fails, means we should delete it */
else {
LOG("removing directory: %s\n", path);
deleteFromList(parentDirectory->subDirectories,
shortname);
- ret = 1;
+ ret = UPDATE_RETURN_UPDATED;
/* don't return, path maybe a song now */
}
} else if ((song = getSongDetails(path, &shortname, &parentDirectory))) {
if (!parentDirectory->stat
&& statDirectory(parentDirectory) < 0) {
free(path);
- return 0;
+ return UPDATE_RETURN_NOUPDATE;
}
/* if this song update is successfull, we are done */
else if (0 == inodeFoundInParent(parentDirectory->parent,
@@ -539,19 +526,19 @@ static int updatePath(const char *utf8path)
isMusic(get_song_url(path_max_tmp, song), &mtime, 0)) {
free(path);
if (song->mtime == mtime)
- return 0;
+ return UPDATE_RETURN_NOUPDATE;
else if (updateSongInfo(song) == 0)
- return 1;
+ return UPDATE_RETURN_UPDATED;
else {
removeSongFromDirectory(parentDirectory,
shortname);
- return 1;
+ return UPDATE_RETURN_UPDATED;
}
}
/* if updateDirectory fails, means we should delete it */
else {
removeSongFromDirectory(parentDirectory, shortname);
- ret = 1;
+ ret = UPDATE_RETURN_UPDATED;
/* don't return, path maybe a directory now */
}
}
@@ -569,7 +556,7 @@ static int updatePath(const char *utf8path)
parentDirectory->device)
&& addToDirectory(parentDirectory, shortname, path)
> 0) {
- ret = 1;
+ ret = UPDATE_RETURN_UPDATED;
}
}
@@ -586,32 +573,27 @@ static const char *opendir_path(char *path_max_tmp, const char *dirname)
return musicDir;
}
-/* return values:
- -1 -> error
- 0 -> no error, but nothing updated
- 1 -> no error, and stuff updated
- */
-static int updateDirectory(Directory * directory)
+static enum update_return updateDirectory(Directory * directory)
{
DIR *dir;
const char *dirname = getDirectoryPath(directory);
struct dirent *ent;
char path_max_tmp[MPD_PATH_MAX];
- int ret = 0;
+ enum update_return ret = UPDATE_RETURN_NOUPDATE;
if (!directory->stat && statDirectory(directory) < 0)
- return -1;
+ return UPDATE_RETURN_ERROR;
else if (inodeFoundInParent(directory->parent,
directory->inode,
directory->device))
- return -1;
+ return UPDATE_RETURN_ERROR;
dir = opendir(opendir_path(path_max_tmp, dirname));
if (!dir)
- return -1;
+ return UPDATE_RETURN_ERROR;
if (removeDeletedFromDirectory(path_max_tmp, directory) > 0)
- ret = 1;
+ ret = UPDATE_RETURN_UPDATED;
while ((ent = readdir(dir))) {
char *utf8;
@@ -626,7 +608,7 @@ static int updateDirectory(Directory * directory)
utf8 = pfx_dir(path_max_tmp, utf8, strlen(utf8),
dirname, strlen(dirname));
if (updateInDirectory(directory, utf8, path_max_tmp) > 0)
- ret = 1;
+ ret = UPDATE_RETURN_UPDATED;
}
closedir(dir);
@@ -634,24 +616,19 @@ static int updateDirectory(Directory * directory)
return ret;
}
-/* return values:
- -1 -> error
- 0 -> no error, but nothing found
- 1 -> no error, and stuff found
- */
-static int exploreDirectory(Directory * directory)
+static enum update_return exploreDirectory(Directory * directory)
{
DIR *dir;
const char *dirname = getDirectoryPath(directory);
struct dirent *ent;
char path_max_tmp[MPD_PATH_MAX];
- int ret = 0;
+ enum update_return ret = UPDATE_RETURN_NOUPDATE;
DEBUG("explore: attempting to opendir: %s\n", dirname);
dir = opendir(opendir_path(path_max_tmp, dirname));
if (!dir)
- return -1;
+ return UPDATE_RETURN_ERROR;
DEBUG("explore: %s\n", dirname);
@@ -670,7 +647,7 @@ static int exploreDirectory(Directory * directory)
utf8 = pfx_dir(path_max_tmp, utf8, strlen(utf8),
dirname, strlen(dirname));
if (addToDirectory(directory, utf8, path_max_tmp) > 0)
- ret = 1;
+ ret = UPDATE_RETURN_UPDATED;
}
closedir(dir);
@@ -705,26 +682,26 @@ static int inodeFoundInParent(Directory * parent, ino_t inode, dev_t device)
return 0;
}
-static int addSubDirectoryToDirectory(Directory * directory,
+static enum update_return addSubDirectoryToDirectory(Directory * directory,
const char *shortname,
const char *name, struct stat *st)
{
Directory *subDirectory;
if (inodeFoundInParent(directory, st->st_ino, st->st_dev))
- return 0;
+ return UPDATE_RETURN_NOUPDATE;
subDirectory = newDirectory(name, directory);
directory_set_stat(subDirectory, st);
if (exploreDirectory(subDirectory) < 1) {
freeDirectory(subDirectory);
- return 0;
+ return UPDATE_RETURN_NOUPDATE;
}
insertInList(directory->subDirectories, shortname, subDirectory);
- return 1;
+ return UPDATE_RETURN_UPDATED;
}
static int addToDirectory(Directory * directory,