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

test/run_input, ...: RAII-style global initialization

This commit is contained in:
Max Kellermann 2017-01-03 12:22:14 +01:00
parent 4397fe3a13
commit d2046de193
3 changed files with 75 additions and 73 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
test/dump_text_file.cxx
View File

@ -36,6 +36,27 @@
#include <stdio.h>
#include <stdlib.h>
class GlobalInit {
const ScopeIOThread io_thread;
public:
GlobalInit() {
config_global_init();
#ifdef ENABLE_ARCHIVE
archive_plugin_init_all();
#endif
input_stream_global_init();
}
~GlobalInit() {
input_stream_global_finish();
#ifdef ENABLE_ARCHIVE
archive_plugin_deinit_all();
#endif
config_global_finish();
}
};
static void
dump_text_file(TextInputStream &is)
{
@ -60,8 +81,6 @@ dump_input_stream(InputStreamPtr &&is)
int main(int argc, char **argv)
try {
int ret;
if (argc != 2) {
fprintf(stderr, "Usage: run_input URI\n");
return EXIT_FAILURE;
@ -69,37 +88,15 @@ try {
/* initialize MPD */
config_global_init();
const ScopeIOThread io_thread;
#ifdef ENABLE_ARCHIVE
archive_plugin_init_all();
#endif
input_stream_global_init();
const GlobalInit init;
/* open the stream and dump it */
{
Mutex mutex;
Cond cond;
Mutex mutex;
Cond cond;
auto is = InputStream::OpenReady(argv[1], mutex, cond);
ret = dump_input_stream(std::move(is));
}
/* deinitialize everything */
input_stream_global_finish();
#ifdef ENABLE_ARCHIVE
archive_plugin_deinit_all();
#endif
config_global_finish();
return ret;
auto is = InputStream::OpenReady(argv[1], mutex, cond);
return dump_input_stream(std::move(is));
} catch (const std::exception &e) {
LogError(e);
return EXIT_FAILURE;

54
test/run_input.cxx
View File

@ -38,6 +38,27 @@
#include <unistd.h>
#include <stdlib.h>
class GlobalInit {
const ScopeIOThread io_thread;
public:
GlobalInit() {
config_global_init();
#ifdef ENABLE_ARCHIVE
archive_plugin_init_all();
#endif
input_stream_global_init();
}
~GlobalInit() {
input_stream_global_finish();
#ifdef ENABLE_ARCHIVE
archive_plugin_deinit_all();
#endif
config_global_finish();
}
};
static void
tag_save(FILE *file, const Tag &tag)
{
@ -91,37 +112,14 @@ try {
/* initialize MPD */
config_global_init();
const ScopeIOThread io_thread;
#ifdef ENABLE_ARCHIVE
archive_plugin_init_all();
#endif
input_stream_global_init();
const GlobalInit init;
/* open the stream and dump it */
int ret;
{
Mutex mutex;
Cond cond;
auto is = InputStream::OpenReady(argv[1], mutex, cond);
ret = dump_input_stream(is.get());
}
/* deinitialize everything */
input_stream_global_finish();
#ifdef ENABLE_ARCHIVE
archive_plugin_deinit_all();
#endif
config_global_finish();
return ret;
Mutex mutex;
Cond cond;
auto is = InputStream::OpenReady(argv[1], mutex, cond);
return dump_input_stream(is.get());
} catch (const std::exception &e) {
LogError(e);
return EXIT_FAILURE;

39
test/visit_archive.cxx
View File

@ -35,8 +35,29 @@
#include <stdlib.h>
#include <stdio.h>
class GlobalInit {
const ScopeIOThread io_thread;
public:
GlobalInit() {
config_global_init();
#ifdef ENABLE_ARCHIVE
archive_plugin_init_all();
#endif
input_stream_global_init();
}
~GlobalInit() {
input_stream_global_finish();
#ifdef ENABLE_ARCHIVE
archive_plugin_deinit_all();
#endif
config_global_finish();
}
};
class MyArchiveVisitor final : public ArchiveVisitor {
public:
public:
virtual void VisitArchiveEntry(const char *path_utf8) override {
printf("%s\n", path_utf8);
}
@ -55,13 +76,7 @@ try {
/* initialize MPD */
config_global_init();
const ScopeIOThread io_thread;
archive_plugin_init_all();
input_stream_global_init();
const GlobalInit init;
/* open the archive and dump it */
@ -79,14 +94,6 @@ try {
file->Visit(visitor);
file->Close();
/* deinitialize everything */
input_stream_global_finish();
archive_plugin_deinit_all();
config_global_finish();
return result;
} catch (const std::exception &e) {
LogError(e);