Commit 6b83d082 authored by Max Kellermann's avatar Max Kellermann

output/fifo: convert to C++

parent dc415b76
...@@ -829,7 +829,7 @@ endif ...@@ -829,7 +829,7 @@ endif
if HAVE_FIFO if HAVE_FIFO
liboutput_plugins_a_SOURCES += \ liboutput_plugins_a_SOURCES += \
src/output/fifo_output_plugin.c src/output/fifo_output_plugin.h src/output/FifoOutputPlugin.cxx src/output/FifoOutputPlugin.hxx
endif endif
if ENABLE_PIPE_OUTPUT if ENABLE_PIPE_OUTPUT
......
...@@ -23,7 +23,7 @@ ...@@ -23,7 +23,7 @@
#include "output/AlsaOutputPlugin.hxx" #include "output/AlsaOutputPlugin.hxx"
#include "output/ao_output_plugin.h" #include "output/ao_output_plugin.h"
#include "output/ffado_output_plugin.h" #include "output/ffado_output_plugin.h"
#include "output/fifo_output_plugin.h" #include "output/FifoOutputPlugin.hxx"
#include "output/HttpdOutputPlugin.hxx" #include "output/HttpdOutputPlugin.hxx"
#include "output/jack_output_plugin.h" #include "output/jack_output_plugin.h"
#include "output/mvp_output_plugin.h" #include "output/mvp_output_plugin.h"
......
/* /*
* Copyright (C) 2003-2011 The Music Player Daemon Project * Copyright (C) 2003-2013 The Music Player Daemon Project
* http://www.musicpd.org * http://www.musicpd.org
* *
* This program is free software; you can redistribute it and/or modify * This program is free software; you can redistribute it and/or modify
...@@ -18,7 +18,7 @@ ...@@ -18,7 +18,7 @@
*/ */
#include "config.h" #include "config.h"
#include "fifo_output_plugin.h" #include "FifoOutputPlugin.hxx"
#include "output_api.h" #include "output_api.h"
#include "timer.h" #include "timer.h"
#include "fd_util.h" #include "fd_util.h"
...@@ -37,7 +37,7 @@ ...@@ -37,7 +37,7 @@
#define FIFO_BUFFER_SIZE 65536 /* pipe capacity on Linux >= 2.6.11 */ #define FIFO_BUFFER_SIZE 65536 /* pipe capacity on Linux >= 2.6.11 */
struct fifo_data { struct FifoOutput {
struct audio_output base; struct audio_output base;
char *path; char *path;
...@@ -45,6 +45,29 @@ struct fifo_data { ...@@ -45,6 +45,29 @@ struct fifo_data {
int output; int output;
bool created; bool created;
struct timer *timer; struct timer *timer;
FifoOutput()
:path(nullptr), input(-1), output(-1), created(false) {}
~FifoOutput() {
g_free(path);
}
bool Initialize(const config_param *param, GError **error_r) {
return ao_base_init(&base, &fifo_output_plugin, param,
error_r);
}
void Deinitialize() {
ao_base_finish(&base);
}
bool Create(GError **error_r);
bool Check(GError **error_r);
void Delete();
bool Open(GError **error_r);
void Close();
}; };
/** /**
...@@ -56,156 +79,138 @@ fifo_output_quark(void) ...@@ -56,156 +79,138 @@ fifo_output_quark(void)
return g_quark_from_static_string("fifo_output"); return g_quark_from_static_string("fifo_output");
} }
static struct fifo_data *fifo_data_new(void) inline void
{ FifoOutput::Delete()
struct fifo_data *ret;
ret = g_new(struct fifo_data, 1);
ret->path = NULL;
ret->input = -1;
ret->output = -1;
ret->created = false;
return ret;
}
static void fifo_data_free(struct fifo_data *fd)
{ {
g_free(fd->path); g_debug("Removing FIFO \"%s\"", path);
g_free(fd);
}
static void fifo_delete(struct fifo_data *fd)
{
g_debug("Removing FIFO \"%s\"", fd->path);
if (unlink(fd->path) < 0) { if (unlink(path) < 0) {
g_warning("Could not remove FIFO \"%s\": %s", g_warning("Could not remove FIFO \"%s\": %s",
fd->path, g_strerror(errno)); path, g_strerror(errno));
return; return;
} }
fd->created = false; created = false;
} }
static void void
fifo_close(struct fifo_data *fd) FifoOutput::Close()
{ {
struct stat st; struct stat st;
if (fd->input >= 0) { if (input >= 0) {
close(fd->input); close(input);
fd->input = -1; input = -1;
} }
if (fd->output >= 0) { if (output >= 0) {
close(fd->output); close(output);
fd->output = -1; output = -1;
} }
if (fd->created && (stat(fd->path, &st) == 0)) if (created && (stat(path, &st) == 0))
fifo_delete(fd); Delete();
} }
static bool inline bool
fifo_make(struct fifo_data *fd, GError **error) FifoOutput::Create(GError **error_r)
{ {
if (mkfifo(fd->path, 0666) < 0) { if (mkfifo(path, 0666) < 0) {
g_set_error(error, fifo_output_quark(), errno, g_set_error(error_r, fifo_output_quark(), errno,
"Couldn't create FIFO \"%s\": %s", "Couldn't create FIFO \"%s\": %s",
fd->path, g_strerror(errno)); path, g_strerror(errno));
return false; return false;
} }
fd->created = true; created = true;
return true; return true;
} }
static bool inline bool
fifo_check(struct fifo_data *fd, GError **error) FifoOutput::Check(GError **error_r)
{ {
struct stat st; struct stat st;
if (stat(path, &st) < 0) {
if (stat(fd->path, &st) < 0) {
if (errno == ENOENT) { if (errno == ENOENT) {
/* Path doesn't exist */ /* Path doesn't exist */
return fifo_make(fd, error); return Create(error_r);
} }
g_set_error(error, fifo_output_quark(), errno, g_set_error(error_r, fifo_output_quark(), errno,
"Failed to stat FIFO \"%s\": %s", "Failed to stat FIFO \"%s\": %s",
fd->path, g_strerror(errno)); path, g_strerror(errno));
return false; return false;
} }
if (!S_ISFIFO(st.st_mode)) { if (!S_ISFIFO(st.st_mode)) {
g_set_error(error, fifo_output_quark(), 0, g_set_error(error_r, fifo_output_quark(), 0,
"\"%s\" already exists, but is not a FIFO", "\"%s\" already exists, but is not a FIFO",
fd->path); path);
return false; return false;
} }
return true; return true;
} }
static bool inline bool
fifo_open(struct fifo_data *fd, GError **error) FifoOutput::Open(GError **error_r)
{ {
if (!fifo_check(fd, error)) if (!Check(error_r))
return false; return false;
fd->input = open_cloexec(fd->path, O_RDONLY|O_NONBLOCK|O_BINARY, 0); input = open_cloexec(path, O_RDONLY|O_NONBLOCK|O_BINARY, 0);
if (fd->input < 0) { if (input < 0) {
g_set_error(error, fifo_output_quark(), errno, g_set_error(error_r, fifo_output_quark(), errno,
"Could not open FIFO \"%s\" for reading: %s", "Could not open FIFO \"%s\" for reading: %s",
fd->path, g_strerror(errno)); path, g_strerror(errno));
fifo_close(fd); Close();
return false; return false;
} }
fd->output = open_cloexec(fd->path, O_WRONLY|O_NONBLOCK|O_BINARY, 0); output = open_cloexec(path, O_WRONLY|O_NONBLOCK|O_BINARY, 0);
if (fd->output < 0) { if (output < 0) {
g_set_error(error, fifo_output_quark(), errno, g_set_error(error_r, fifo_output_quark(), errno,
"Could not open FIFO \"%s\" for writing: %s", "Could not open FIFO \"%s\" for writing: %s",
fd->path, g_strerror(errno)); path, g_strerror(errno));
fifo_close(fd); Close();
return false; return false;
} }
return true; return true;
} }
static struct audio_output * static bool
fifo_output_init(const struct config_param *param, fifo_open(FifoOutput *fd, GError **error_r)
GError **error_r)
{ {
struct fifo_data *fd; return fd->Open(error_r);
}
GError *error = NULL; static struct audio_output *
fifo_output_init(const config_param *param, GError **error_r)
{
GError *error = nullptr;
char *path = config_dup_block_path(param, "path", &error); char *path = config_dup_block_path(param, "path", &error);
if (!path) { if (!path) {
if (error != NULL) if (error != nullptr)
g_propagate_error(error_r, error); g_propagate_error(error_r, error);
else else
g_set_error(error_r, fifo_output_quark(), 0, g_set_error(error_r, fifo_output_quark(), 0,
"No \"path\" parameter specified"); "No \"path\" parameter specified");
return NULL; return nullptr;
} }
fd = fifo_data_new(); FifoOutput *fd = new FifoOutput();
fd->path = path; fd->path = path;
if (!ao_base_init(&fd->base, &fifo_output_plugin, param, error_r)) { if (!fd->Initialize(param, error_r)) {
fifo_data_free(fd); delete fd;
return NULL; return nullptr;
} }
if (!fifo_open(fd, error_r)) { if (!fifo_open(fd, error_r)) {
ao_base_finish(&fd->base); fd->Deinitialize();
fifo_data_free(fd); delete fd;
return NULL; return nullptr;
} }
return &fd->base; return &fd->base;
...@@ -214,18 +219,18 @@ fifo_output_init(const struct config_param *param, ...@@ -214,18 +219,18 @@ fifo_output_init(const struct config_param *param,
static void static void
fifo_output_finish(struct audio_output *ao) fifo_output_finish(struct audio_output *ao)
{ {
struct fifo_data *fd = (struct fifo_data *)ao; FifoOutput *fd = (FifoOutput *)ao;
fifo_close(fd); fd->Close();
ao_base_finish(&fd->base); fd->Deinitialize();
fifo_data_free(fd); delete fd;
} }
static bool static bool
fifo_output_open(struct audio_output *ao, struct audio_format *audio_format, fifo_output_open(struct audio_output *ao, struct audio_format *audio_format,
G_GNUC_UNUSED GError **error) G_GNUC_UNUSED GError **error)
{ {
struct fifo_data *fd = (struct fifo_data *)ao; FifoOutput *fd = (FifoOutput *)ao;
fd->timer = timer_new(audio_format); fd->timer = timer_new(audio_format);
...@@ -235,7 +240,7 @@ fifo_output_open(struct audio_output *ao, struct audio_format *audio_format, ...@@ -235,7 +240,7 @@ fifo_output_open(struct audio_output *ao, struct audio_format *audio_format,
static void static void
fifo_output_close(struct audio_output *ao) fifo_output_close(struct audio_output *ao)
{ {
struct fifo_data *fd = (struct fifo_data *)ao; FifoOutput *fd = (FifoOutput *)ao;
timer_free(fd->timer); timer_free(fd->timer);
} }
...@@ -243,7 +248,7 @@ fifo_output_close(struct audio_output *ao) ...@@ -243,7 +248,7 @@ fifo_output_close(struct audio_output *ao)
static void static void
fifo_output_cancel(struct audio_output *ao) fifo_output_cancel(struct audio_output *ao)
{ {
struct fifo_data *fd = (struct fifo_data *)ao; FifoOutput *fd = (FifoOutput *)ao;
char buf[FIFO_BUFFER_SIZE]; char buf[FIFO_BUFFER_SIZE];
int bytes = 1; int bytes = 1;
...@@ -261,7 +266,7 @@ fifo_output_cancel(struct audio_output *ao) ...@@ -261,7 +266,7 @@ fifo_output_cancel(struct audio_output *ao)
static unsigned static unsigned
fifo_output_delay(struct audio_output *ao) fifo_output_delay(struct audio_output *ao)
{ {
struct fifo_data *fd = (struct fifo_data *)ao; FifoOutput *fd = (FifoOutput *)ao;
return fd->timer->started return fd->timer->started
? timer_delay(fd->timer) ? timer_delay(fd->timer)
...@@ -272,7 +277,7 @@ static size_t ...@@ -272,7 +277,7 @@ static size_t
fifo_output_play(struct audio_output *ao, const void *chunk, size_t size, fifo_output_play(struct audio_output *ao, const void *chunk, size_t size,
GError **error) GError **error)
{ {
struct fifo_data *fd = (struct fifo_data *)ao; FifoOutput *fd = (FifoOutput *)ao;
ssize_t bytes; ssize_t bytes;
if (!fd->timer->started) if (!fd->timer->started)
...@@ -303,12 +308,19 @@ fifo_output_play(struct audio_output *ao, const void *chunk, size_t size, ...@@ -303,12 +308,19 @@ fifo_output_play(struct audio_output *ao, const void *chunk, size_t size,
} }
const struct audio_output_plugin fifo_output_plugin = { const struct audio_output_plugin fifo_output_plugin = {
.name = "fifo", "fifo",
.init = fifo_output_init, nullptr,
.finish = fifo_output_finish, fifo_output_init,
.open = fifo_output_open, fifo_output_finish,
.close = fifo_output_close, nullptr,
.delay = fifo_output_delay, nullptr,
.play = fifo_output_play, fifo_output_open,
.cancel = fifo_output_cancel, fifo_output_close,
fifo_output_delay,
nullptr,
fifo_output_play,
nullptr,
fifo_output_cancel,
nullptr,
nullptr,
}; };
/* /*
* Copyright (C) 2003-2011 The Music Player Daemon Project * Copyright (C) 2003-2013 The Music Player Daemon Project
* http://www.musicpd.org * http://www.musicpd.org
* *
* This program is free software; you can redistribute it and/or modify * This program is free software; you can redistribute it and/or modify
...@@ -17,8 +17,8 @@ ...@@ -17,8 +17,8 @@
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/ */
#ifndef MPD_FIFO_OUTPUT_PLUGIN_H #ifndef MPD_FIFO_OUTPUT_PLUGIN_HXX
#define MPD_FIFO_OUTPUT_PLUGIN_H #define MPD_FIFO_OUTPUT_PLUGIN_HXX
extern const struct audio_output_plugin fifo_output_plugin; extern const struct audio_output_plugin fifo_output_plugin;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment