Main: move code to db/Configured.cxx
This commit is contained in:
parent
ff62b6742b
commit
de160bb2d1
@ -209,6 +209,7 @@ src_mpd_SOURCES += \
|
|||||||
src/db/Directory.cxx src/db/Directory.hxx \
|
src/db/Directory.cxx src/db/Directory.hxx \
|
||||||
src/db/DirectorySave.cxx src/db/DirectorySave.hxx \
|
src/db/DirectorySave.cxx src/db/DirectorySave.hxx \
|
||||||
src/db/DatabaseGlue.cxx src/db/DatabaseGlue.hxx \
|
src/db/DatabaseGlue.cxx src/db/DatabaseGlue.hxx \
|
||||||
|
src/db/Configured.cxx src/db/Configured.hxx \
|
||||||
src/db/DatabaseSong.cxx src/db/DatabaseSong.hxx \
|
src/db/DatabaseSong.cxx src/db/DatabaseSong.hxx \
|
||||||
src/db/DatabasePrint.cxx src/db/DatabasePrint.hxx \
|
src/db/DatabasePrint.cxx src/db/DatabasePrint.hxx \
|
||||||
src/db/DatabaseQueue.cxx src/db/DatabaseQueue.hxx \
|
src/db/DatabaseQueue.cxx src/db/DatabaseQueue.hxx \
|
||||||
|
50
src/Main.cxx
50
src/Main.cxx
@ -67,7 +67,7 @@
|
|||||||
|
|
||||||
#ifdef ENABLE_DATABASE
|
#ifdef ENABLE_DATABASE
|
||||||
#include "db/update/Service.hxx"
|
#include "db/update/Service.hxx"
|
||||||
#include "db/DatabaseGlue.hxx"
|
#include "db/Configured.hxx"
|
||||||
#include "db/plugins/SimpleDatabasePlugin.hxx"
|
#include "db/plugins/SimpleDatabasePlugin.hxx"
|
||||||
#include "storage/Configured.hxx"
|
#include "storage/Configured.hxx"
|
||||||
#include "storage/CompositeStorage.hxx"
|
#include "storage/CompositeStorage.hxx"
|
||||||
@ -168,46 +168,18 @@ InitStorage(Error &error)
|
|||||||
static bool
|
static bool
|
||||||
glue_db_init_and_load(void)
|
glue_db_init_and_load(void)
|
||||||
{
|
{
|
||||||
const struct config_param *param = config_get_param(CONF_DATABASE);
|
|
||||||
const struct config_param *path = config_get_param(CONF_DB_FILE);
|
|
||||||
|
|
||||||
if (param != nullptr && path != nullptr)
|
|
||||||
LogWarning(main_domain,
|
|
||||||
"Found both 'database' and 'db_file' setting - ignoring the latter");
|
|
||||||
|
|
||||||
if (instance->storage == nullptr) {
|
|
||||||
if (param != nullptr)
|
|
||||||
LogDefault(main_domain,
|
|
||||||
"Found database setting without "
|
|
||||||
"music_directory - disabling database");
|
|
||||||
if (path != nullptr)
|
|
||||||
LogDefault(main_domain,
|
|
||||||
"Found db_file setting without "
|
|
||||||
"music_directory - disabling database");
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
struct config_param *allocated = nullptr;
|
|
||||||
|
|
||||||
if (param == nullptr && path != nullptr) {
|
|
||||||
allocated = new config_param("database", path->line);
|
|
||||||
allocated->AddBlockParam("path", path->value.c_str(),
|
|
||||||
path->line);
|
|
||||||
param = allocated;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (param == nullptr)
|
|
||||||
return true;
|
|
||||||
|
|
||||||
bool is_simple;
|
bool is_simple;
|
||||||
Error error;
|
Error error;
|
||||||
instance->database = DatabaseGlobalInit(*instance->event_loop,
|
instance->database =
|
||||||
*instance, *param,
|
CreateConfiguredDatabase(*instance->event_loop, *instance,
|
||||||
is_simple, error);
|
instance->storage != nullptr,
|
||||||
if (instance->database == nullptr)
|
is_simple, error);
|
||||||
FatalError(error);
|
if (instance->database == nullptr) {
|
||||||
|
if (error.IsDefined())
|
||||||
delete allocated;
|
FatalError(error);
|
||||||
|
else
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
if (!instance->database->Open(error))
|
if (!instance->database->Open(error))
|
||||||
FatalError(error);
|
FatalError(error);
|
||||||
|
67
src/db/Configured.cxx
Normal file
67
src/db/Configured.cxx
Normal file
@ -0,0 +1,67 @@
|
|||||||
|
/*
|
||||||
|
* Copyright (C) 2003-2014 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"
|
||||||
|
#include "Configured.hxx"
|
||||||
|
#include "DatabaseGlue.hxx"
|
||||||
|
#include "config/ConfigGlobal.hxx"
|
||||||
|
#include "config/ConfigData.hxx"
|
||||||
|
#include "config/ConfigError.hxx"
|
||||||
|
#include "Log.hxx"
|
||||||
|
|
||||||
|
Database *
|
||||||
|
CreateConfiguredDatabase(EventLoop &loop, DatabaseListener &listener,
|
||||||
|
bool have_storage, bool &is_simple_r, Error &error)
|
||||||
|
{
|
||||||
|
const struct config_param *param = config_get_param(CONF_DATABASE);
|
||||||
|
const struct config_param *path = config_get_param(CONF_DB_FILE);
|
||||||
|
|
||||||
|
if (param != nullptr && path != nullptr)
|
||||||
|
LogWarning(config_domain,
|
||||||
|
"Found both 'database' and 'db_file' setting - ignoring the latter");
|
||||||
|
|
||||||
|
if (!have_storage) {
|
||||||
|
if (param != nullptr)
|
||||||
|
LogDefault(config_domain,
|
||||||
|
"Found database setting without "
|
||||||
|
"music_directory - disabling database");
|
||||||
|
if (path != nullptr)
|
||||||
|
LogDefault(config_domain,
|
||||||
|
"Found db_file setting without "
|
||||||
|
"music_directory - disabling database");
|
||||||
|
return nullptr;
|
||||||
|
}
|
||||||
|
|
||||||
|
struct config_param *allocated = nullptr;
|
||||||
|
|
||||||
|
if (param == nullptr && path != nullptr) {
|
||||||
|
allocated = new config_param("database", path->line);
|
||||||
|
allocated->AddBlockParam("path", path->value.c_str(),
|
||||||
|
path->line);
|
||||||
|
param = allocated;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (param == nullptr)
|
||||||
|
return nullptr;
|
||||||
|
|
||||||
|
Database *db = DatabaseGlobalInit(loop, listener, *param,
|
||||||
|
is_simple_r, error);
|
||||||
|
delete allocated;
|
||||||
|
return db;
|
||||||
|
}
|
39
src/db/Configured.hxx
Normal file
39
src/db/Configured.hxx
Normal file
@ -0,0 +1,39 @@
|
|||||||
|
/*
|
||||||
|
* Copyright (C) 2003-2014 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_DB_CONFIG_HXX
|
||||||
|
#define MPD_DB_CONFIG_HXX
|
||||||
|
|
||||||
|
#include "check.h"
|
||||||
|
|
||||||
|
class EventLoop;
|
||||||
|
class DatabaseListener;
|
||||||
|
class Database;
|
||||||
|
class Error;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Read database configuration settings and create a #Database
|
||||||
|
* instance from it, but do not open it. Returns nullptr on error or
|
||||||
|
* if no database is configured (no #Error set in that case).
|
||||||
|
*/
|
||||||
|
Database *
|
||||||
|
CreateConfiguredDatabase(EventLoop &loop, DatabaseListener &listener,
|
||||||
|
bool have_storage, bool &is_simple_r, Error &error);
|
||||||
|
|
||||||
|
#endif
|
Loading…
Reference in New Issue
Block a user