aboutsummaryrefslogtreecommitdiffstats
path: root/src/output/FifoOutputPlugin.cxx
diff options
context:
space:
mode:
authorMax Kellermann <max@duempel.org>2013-08-07 19:54:38 +0200
committerMax Kellermann <max@duempel.org>2013-08-07 19:59:09 +0200
commitb76a29a69ae5412c3c1d101eefa9562990e74407 (patch)
tree5c60aa1bb5e6a8d134707291d12fb4ebb77c06c8 /src/output/FifoOutputPlugin.cxx
parentabe090ec1f2255ce422f74e5b59bffc83aaff875 (diff)
downloadmpd-b76a29a69ae5412c3c1d101eefa9562990e74407.tar.gz
mpd-b76a29a69ae5412c3c1d101eefa9562990e74407.tar.xz
mpd-b76a29a69ae5412c3c1d101eefa9562990e74407.zip
ConfigPath: return a Path object
Migrate all callers to use Path directly, instead of doing the conversion in each caller.
Diffstat (limited to '')
-rw-r--r--src/output/FifoOutputPlugin.cxx56
1 files changed, 29 insertions, 27 deletions
diff --git a/src/output/FifoOutputPlugin.cxx b/src/output/FifoOutputPlugin.cxx
index 4d1b56e69..29dd50cb1 100644
--- a/src/output/FifoOutputPlugin.cxx
+++ b/src/output/FifoOutputPlugin.cxx
@@ -22,6 +22,8 @@
#include "OutputAPI.hxx"
#include "Timer.hxx"
#include "system/fd_util.h"
+#include "fs/Path.hxx"
+#include "fs/FileSystem.hxx"
#include "open.h"
#include <glib.h>
@@ -40,18 +42,16 @@
struct FifoOutput {
struct audio_output base;
- char *path;
+ Path path;
+ std::string path_utf8;
+
int input;
int output;
bool created;
Timer *timer;
FifoOutput()
- :path(nullptr), input(-1), output(-1), created(false) {}
-
- ~FifoOutput() {
- g_free(path);
- }
+ :path(Path::Null()), input(-1), output(-1), created(false) {}
bool Initialize(const config_param &param, GError **error_r) {
return ao_base_init(&base, &fifo_output_plugin, param,
@@ -82,11 +82,11 @@ fifo_output_quark(void)
inline void
FifoOutput::Delete()
{
- g_debug("Removing FIFO \"%s\"", path);
+ g_debug("Removing FIFO \"%s\"", path_utf8.c_str());
- if (unlink(path) < 0) {
+ if (!RemoveFile(path)) {
g_warning("Could not remove FIFO \"%s\": %s",
- path, g_strerror(errno));
+ path_utf8.c_str(), g_strerror(errno));
return;
}
@@ -96,8 +96,6 @@ FifoOutput::Delete()
void
FifoOutput::Close()
{
- struct stat st;
-
if (input >= 0) {
close(input);
input = -1;
@@ -108,17 +106,18 @@ FifoOutput::Close()
output = -1;
}
- if (created && (stat(path, &st) == 0))
+ struct stat st;
+ if (created && StatFile(path, st))
Delete();
}
inline bool
FifoOutput::Create(GError **error_r)
{
- if (mkfifo(path, 0666) < 0) {
+ if (!MakeFifo(path, 0666)) {
g_set_error(error_r, fifo_output_quark(), errno,
"Couldn't create FIFO \"%s\": %s",
- path, g_strerror(errno));
+ path_utf8.c_str(), g_strerror(errno));
return false;
}
@@ -130,7 +129,7 @@ inline bool
FifoOutput::Check(GError **error_r)
{
struct stat st;
- if (stat(path, &st) < 0) {
+ if (!StatFile(path, st)) {
if (errno == ENOENT) {
/* Path doesn't exist */
return Create(error_r);
@@ -138,14 +137,14 @@ FifoOutput::Check(GError **error_r)
g_set_error(error_r, fifo_output_quark(), errno,
"Failed to stat FIFO \"%s\": %s",
- path, g_strerror(errno));
+ path_utf8.c_str(), g_strerror(errno));
return false;
}
if (!S_ISFIFO(st.st_mode)) {
g_set_error(error_r, fifo_output_quark(), 0,
"\"%s\" already exists, but is not a FIFO",
- path);
+ path_utf8.c_str());
return false;
}
@@ -158,20 +157,20 @@ FifoOutput::Open(GError **error_r)
if (!Check(error_r))
return false;
- input = open_cloexec(path, O_RDONLY|O_NONBLOCK|O_BINARY, 0);
+ input = OpenFile(path, O_RDONLY|O_NONBLOCK|O_BINARY, 0);
if (input < 0) {
g_set_error(error_r, fifo_output_quark(), errno,
"Could not open FIFO \"%s\" for reading: %s",
- path, g_strerror(errno));
+ path_utf8.c_str(), g_strerror(errno));
Close();
return false;
}
- output = open_cloexec(path, O_WRONLY|O_NONBLOCK|O_BINARY, 0);
+ output = OpenFile(path, O_WRONLY|O_NONBLOCK|O_BINARY, 0);
if (output < 0) {
g_set_error(error_r, fifo_output_quark(), errno,
"Could not open FIFO \"%s\" for writing: %s",
- path, g_strerror(errno));
+ path_utf8.c_str(), g_strerror(errno));
Close();
return false;
}
@@ -189,8 +188,12 @@ static struct audio_output *
fifo_output_init(const config_param &param, GError **error_r)
{
GError *error = nullptr;
- char *path = param.DupBlockPath("path", &error);
- if (!path) {
+
+ FifoOutput *fd = new FifoOutput();
+
+ fd->path = param.GetBlockPath("path", &error);
+ if (fd->path.IsNull()) {
+ delete fd;
if (error != nullptr)
g_propagate_error(error_r, error);
else
@@ -199,8 +202,7 @@ fifo_output_init(const config_param &param, GError **error_r)
return nullptr;
}
- FifoOutput *fd = new FifoOutput();
- fd->path = path;
+ fd->path_utf8 = fd->path.ToUTF8();
if (!fd->Initialize(param, error_r)) {
delete fd;
@@ -259,7 +261,7 @@ fifo_output_cancel(struct audio_output *ao)
if (bytes < 0 && errno != EAGAIN) {
g_warning("Flush of FIFO \"%s\" failed: %s",
- fd->path, g_strerror(errno));
+ fd->path_utf8.c_str(), g_strerror(errno));
}
}
@@ -301,7 +303,7 @@ fifo_output_play(struct audio_output *ao, const void *chunk, size_t size,
g_set_error(error, fifo_output_quark(), errno,
"Failed to write to FIFO %s: %s",
- fd->path, g_strerror(errno));
+ fd->path_utf8.c_str(), g_strerror(errno));
return 0;
}
}