output/*: move to output/plugins/

1 files changed, 0 insertions, 601 deletions

diff --git a/src/output/HttpdOutputPlugin.cxx b/src/output/HttpdOutputPlugin.cxx
deleted file mode 100644
index 322c9a61e..000000000
--- a/src/output/HttpdOutputPlugin.cxx
+++ /dev/null
@@ -1,601 +0,0 @@
-/*
- * 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 "HttpdOutputPlugin.hxx"
-#include "HttpdInternal.hxx"
-#include "HttpdClient.hxx"
-#include "OutputAPI.hxx"
-#include "encoder/EncoderPlugin.hxx"
-#include "encoder/EncoderList.hxx"
-#include "system/Resolver.hxx"
-#include "Page.hxx"
-#include "IcyMetaDataServer.hxx"
-#include "system/fd_util.h"
-#include "IOThread.hxx"
-#include "event/Call.hxx"
-#include "util/Error.hxx"
-#include "util/Domain.hxx"
-#include "Log.hxx"
-
-#include <assert.h>
-
-#include <sys/types.h>
-#include <unistd.h>
-#include <string.h>
-#include <errno.h>
-
-#ifdef HAVE_LIBWRAP
-#include <sys/socket.h> /* needed for AF_UNIX */
-#include <tcpd.h>
-#endif
-
-const Domain httpd_output_domain("httpd_output");
-
-inline
-HttpdOutput::HttpdOutput(EventLoop &_loop)
-	:ServerSocket(_loop), DeferredMonitor(_loop),
-	 encoder(nullptr), unflushed_input(0),
-	 metadata(nullptr)
-{
-}
-
-HttpdOutput::~HttpdOutput()
-{
-	if (metadata != nullptr)
-		metadata->Unref();
-
-	if (encoder != nullptr)
-		encoder_finish(encoder);
-
-}
-
-inline bool
-HttpdOutput::Bind(Error &error)
-{
-	open = false;
-
-	bool result = false;
-	BlockingCall(GetEventLoop(), [this, &error, &result](){
-			result = ServerSocket::Open(error);
-		});
-	return result;
-}
-
-inline void
-HttpdOutput::Unbind()
-{
-	assert(!open);
-
-	BlockingCall(GetEventLoop(), [this](){
-			ServerSocket::Close();
-		});
-}
-
-inline bool
-HttpdOutput::Configure(const config_param &param, Error &error)
-{
-	/* read configuration */
-	name = param.GetBlockValue("name", "Set name in config");
-	genre = param.GetBlockValue("genre", "Set genre in config");
-	website = param.GetBlockValue("website", "Set website in config");
-
-	unsigned port = param.GetBlockValue("port", 8000u);
-
-	const char *encoder_name =
-		param.GetBlockValue("encoder", "vorbis");
-	const auto encoder_plugin = encoder_plugin_get(encoder_name);
-	if (encoder_plugin == nullptr) {
-		error.Format(httpd_output_domain,
-			     "No such encoder: %s", encoder_name);
-		return false;
-	}
-
-	clients_max = param.GetBlockValue("max_clients", 0u);
-
-	/* set up bind_to_address */
-
-	const char *bind_to_address = param.GetBlockValue("bind_to_address");
-	bool success = bind_to_address != nullptr &&
-		strcmp(bind_to_address, "any") != 0
-		? AddHost(bind_to_address, port, error)
-		: AddPort(port, error);
-	if (!success)
-		return false;
-
-	/* initialize encoder */
-
-	encoder = encoder_init(*encoder_plugin, param, error);
-	if (encoder == nullptr)
-		return false;
-
-	/* determine content type */
-	content_type = encoder_get_mime_type(encoder);
-	if (content_type == nullptr)
-		content_type = "application/octet-stream";
-
-	return true;
-}
-
-inline bool
-HttpdOutput::Init(const config_param &param, Error &error)
-{
-	return ao_base_init(&base, &httpd_output_plugin, param, error);
-}
-
-static struct audio_output *
-httpd_output_init(const config_param &param, Error &error)
-{
-	HttpdOutput *httpd = new HttpdOutput(io_thread_get());
-
-	audio_output *result = httpd->InitAndConfigure(param, error);
-	if (result == nullptr)
-		delete httpd;
-
-	return result;
-}
-
-static void
-httpd_output_finish(struct audio_output *ao)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	httpd->Finish();
-	delete httpd;
-}
-
-/**
- * Creates a new #HttpdClient object and adds it into the
- * HttpdOutput.clients linked list.
- */
-inline void
-HttpdOutput::AddClient(int fd)
-{
-	clients.emplace_front(*this, fd, GetEventLoop(),
-			      encoder->plugin.tag == nullptr);
-	++clients_cnt;
-
-	/* pass metadata to client */
-	if (metadata != nullptr)
-		clients.front().PushMetaData(metadata);
-}
-
-void
-HttpdOutput::RunDeferred()
-{
-	/* this method runs in the IOThread; it broadcasts pages from
-	   our own queue to all clients */
-
-	const ScopeLock protect(mutex);
-
-	while (!pages.empty()) {
-		Page *page = pages.front();
-		pages.pop();
-
-		for (auto &client : clients)
-			client.PushPage(page);
-
-		page->Unref();
-	}
-
-	/* wake up the client that may be waiting for the queue to be
-	   flushed */
-	cond.broadcast();
-}
-
-void
-HttpdOutput::OnAccept(int fd, const sockaddr &address,
-		      size_t address_length, gcc_unused int uid)
-{
-	/* the listener socket has become readable - a client has
-	   connected */
-
-#ifdef HAVE_LIBWRAP
-	if (address.sa_family != AF_UNIX) {
-		const auto hostaddr = sockaddr_to_string(&address,
-							 address_length);
-		// TODO: shall we obtain the program name from argv[0]?
-		const char *progname = "mpd";
-
-		struct request_info req;
-		request_init(&req, RQ_FILE, fd, RQ_DAEMON, progname, 0);
-
-		fromhost(&req);
-
-		if (!hosts_access(&req)) {
-			/* tcp wrappers says no */
-			FormatWarning(httpd_output_domain,
-				      "libwrap refused connection (libwrap=%s) from %s",
-				      progname, hostaddr.c_str());
-			close_socket(fd);
-			return;
-		}
-	}
-#else
-	(void)address;
-	(void)address_length;
-#endif	/* HAVE_WRAP */
-
-	const ScopeLock protect(mutex);
-
-	if (fd >= 0) {
-		/* can we allow additional client */
-		if (open && (clients_max == 0 ||  clients_cnt < clients_max))
-			AddClient(fd);
-		else
-			close_socket(fd);
-	} else if (fd < 0 && errno != EINTR) {
-		LogErrno(httpd_output_domain, "accept() failed");
-	}
-}
-
-Page *
-HttpdOutput::ReadPage()
-{
-	if (unflushed_input >= 65536) {
-		/* we have fed a lot of input into the encoder, but it
-		   didn't give anything back yet - flush now to avoid
-		   buffer underruns */
-		encoder_flush(encoder, IgnoreError());
-		unflushed_input = 0;
-	}
-
-	size_t size = 0;
-	do {
-		size_t nbytes = encoder_read(encoder,
-					     buffer + size,
-					     sizeof(buffer) - size);
-		if (nbytes == 0)
-			break;
-
-		unflushed_input = 0;
-
-		size += nbytes;
-	} while (size < sizeof(buffer));
-
-	if (size == 0)
-		return nullptr;
-
-	return Page::Copy(buffer, size);
-}
-
-static bool
-httpd_output_enable(struct audio_output *ao, Error &error)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	return httpd->Bind(error);
-}
-
-static void
-httpd_output_disable(struct audio_output *ao)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	httpd->Unbind();
-}
-
-inline bool
-HttpdOutput::OpenEncoder(AudioFormat &audio_format, Error &error)
-{
-	if (!encoder_open(encoder, audio_format, error))
-		return false;
-
-	/* we have to remember the encoder header, i.e. the first
-	   bytes of encoder output after opening it, because it has to
-	   be sent to every new client */
-	header = ReadPage();
-
-	unflushed_input = 0;
-
-	return true;
-}
-
-inline bool
-HttpdOutput::Open(AudioFormat &audio_format, Error &error)
-{
-	assert(!open);
-	assert(clients.empty());
-
-	/* open the encoder */
-
-	if (!OpenEncoder(audio_format, error))
-		return false;
-
-	/* initialize other attributes */
-
-	clients_cnt = 0;
-	timer = new Timer(audio_format);
-
-	open = true;
-
-	return true;
-}
-
-static bool
-httpd_output_open(struct audio_output *ao, AudioFormat &audio_format,
-		  Error &error)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	const ScopeLock protect(httpd->mutex);
-	return httpd->Open(audio_format, error);
-}
-
-inline void
-HttpdOutput::Close()
-{
-	assert(open);
-
-	open = false;
-
-	delete timer;
-
-	BlockingCall(GetEventLoop(), [this](){
-			clients.clear();
-		});
-
-	if (header != nullptr)
-		header->Unref();
-
-	encoder_close(encoder);
-}
-
-static void
-httpd_output_close(struct audio_output *ao)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	const ScopeLock protect(httpd->mutex);
-	httpd->Close();
-}
-
-void
-HttpdOutput::RemoveClient(HttpdClient &client)
-{
-	assert(clients_cnt > 0);
-
-	for (auto prev = clients.before_begin(), i = std::next(prev);;
-	     prev = i, i = std::next(prev)) {
-		assert(i != clients.end());
-		if (&*i == &client) {
-			clients.erase_after(prev);
-			clients_cnt--;
-			break;
-		}
-	}
-}
-
-void
-HttpdOutput::SendHeader(HttpdClient &client) const
-{
-	if (header != nullptr)
-		client.PushPage(header);
-}
-
-inline unsigned
-HttpdOutput::Delay() const
-{
-	if (!LockHasClients() && base.pause) {
-		/* if there's no client and this output is paused,
-		   then httpd_output_pause() will not do anything, it
-		   will not fill the buffer and it will not update the
-		   timer; therefore, we reset the timer here */
-		timer->Reset();
-
-		/* some arbitrary delay that is long enough to avoid
-		   consuming too much CPU, and short enough to notice
-		   new clients quickly enough */
-		return 1000;
-	}
-
-	return timer->IsStarted()
-		? timer->GetDelay()
-		: 0;
-}
-
-static unsigned
-httpd_output_delay(struct audio_output *ao)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	return httpd->Delay();
-}
-
-void
-HttpdOutput::BroadcastPage(Page *page)
-{
-	assert(page != nullptr);
-
-	mutex.lock();
-	pages.push(page);
-	page->Ref();
-	mutex.unlock();
-
-	DeferredMonitor::Schedule();
-}
-
-void
-HttpdOutput::BroadcastFromEncoder()
-{
-	/* synchronize with the IOThread */
-	mutex.lock();
-	while (!pages.empty())
-		cond.wait(mutex);
-
-	Page *page;
-	while ((page = ReadPage()) != nullptr)
-		pages.push(page);
-
-	mutex.unlock();
-
-	DeferredMonitor::Schedule();
-}
-
-inline bool
-HttpdOutput::EncodeAndPlay(const void *chunk, size_t size, Error &error)
-{
-	if (!encoder_write(encoder, chunk, size, error))
-		return false;
-
-	unflushed_input += size;
-
-	BroadcastFromEncoder();
-	return true;
-}
-
-inline size_t
-HttpdOutput::Play(const void *chunk, size_t size, Error &error)
-{
-	if (LockHasClients()) {
-		if (!EncodeAndPlay(chunk, size, error))
-			return 0;
-	}
-
-	if (!timer->IsStarted())
-		timer->Start();
-	timer->Add(size);
-
-	return size;
-}
-
-static size_t
-httpd_output_play(struct audio_output *ao, const void *chunk, size_t size,
-		  Error &error)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	return httpd->Play(chunk, size, error);
-}
-
-static bool
-httpd_output_pause(struct audio_output *ao)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	if (httpd->LockHasClients()) {
-		static const char silence[1020] = { 0 };
-		return httpd_output_play(ao, silence, sizeof(silence),
-					 IgnoreError()) > 0;
-	} else {
-		return true;
-	}
-}
-
-inline void
-HttpdOutput::SendTag(const Tag *tag)
-{
-	assert(tag != nullptr);
-
-	if (encoder->plugin.tag != nullptr) {
-		/* embed encoder tags */
-
-		/* flush the current stream, and end it */
-
-		encoder_pre_tag(encoder, IgnoreError());
-		BroadcastFromEncoder();
-
-		/* send the tag to the encoder - which starts a new
-		   stream now */
-
-		encoder_tag(encoder, tag, IgnoreError());
-
-		/* the first page generated by the encoder will now be
-		   used as the new "header" page, which is sent to all
-		   new clients */
-
-		Page *page = ReadPage();
-		if (page != nullptr) {
-			if (header != nullptr)
-				header->Unref();
-			header = page;
-			BroadcastPage(page);
-		}
-	} else {
-		/* use Icy-Metadata */
-
-		if (metadata != nullptr)
-			metadata->Unref();
-
-		static constexpr TagType types[] = {
-			TAG_ALBUM, TAG_ARTIST, TAG_TITLE,
-			TAG_NUM_OF_ITEM_TYPES
-		};
-
-		metadata = icy_server_metadata_page(*tag, &types[0]);
-		if (metadata != nullptr) {
-			const ScopeLock protect(mutex);
-			for (auto &client : clients)
-				client.PushMetaData(metadata);
-		}
-	}
-}
-
-static void
-httpd_output_tag(struct audio_output *ao, const Tag *tag)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	httpd->SendTag(tag);
-}
-
-inline void
-HttpdOutput::CancelAllClients()
-{
-	const ScopeLock protect(mutex);
-
-	while (!pages.empty()) {
-		Page *page = pages.front();
-		pages.pop();
-		page->Unref();
-	}
-
-	for (auto &client : clients)
-		client.CancelQueue();
-
-	cond.broadcast();
-}
-
-static void
-httpd_output_cancel(struct audio_output *ao)
-{
-	HttpdOutput *httpd = HttpdOutput::Cast(ao);
-
-	BlockingCall(io_thread_get(), [httpd](){
-			httpd->CancelAllClients();
-		});
-}
-
-const struct audio_output_plugin httpd_output_plugin = {
-	"httpd",
-	nullptr,
-	httpd_output_init,
-	httpd_output_finish,
-	httpd_output_enable,
-	httpd_output_disable,
-	httpd_output_open,
-	httpd_output_close,
-	httpd_output_delay,
-	httpd_output_tag,
-	httpd_output_play,
-	nullptr,
-	httpd_output_cancel,
-	httpd_output_pause,
-	nullptr,
-};