2009-07-28 17:17:23 +02:00
|
|
|
/*
|
2013-01-03 03:07:16 +01:00
|
|
|
* Copyright (C) 2003-2013 The Music Player Daemon Project
|
2009-07-28 17:17:23 +02:00
|
|
|
* 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.
|
|
|
|
*/
|
|
|
|
|
2009-11-12 09:12:38 +01:00
|
|
|
#include "config.h"
|
2013-01-03 10:33:04 +01:00
|
|
|
#include "ClientInternal.hxx"
|
2013-01-09 08:08:36 +01:00
|
|
|
#include "ClientList.hxx"
|
2013-01-07 10:59:56 +01:00
|
|
|
#include "Partition.hxx"
|
2011-09-19 21:04:19 +02:00
|
|
|
#include "fd_util.h"
|
2013-01-15 01:00:59 +01:00
|
|
|
#include "util/fifo_buffer.h"
|
2013-01-15 01:01:25 +01:00
|
|
|
extern "C" {
|
2011-09-20 07:56:59 +02:00
|
|
|
#include "resolver.h"
|
2013-01-03 03:07:16 +01:00
|
|
|
}
|
2013-01-03 03:06:45 +01:00
|
|
|
#include "Permission.hxx"
|
2011-09-19 20:40:33 +02:00
|
|
|
#include "glib_socket.h"
|
2009-07-28 17:17:23 +02:00
|
|
|
|
|
|
|
#include <assert.h>
|
2010-05-09 01:48:01 +02:00
|
|
|
#include <sys/types.h>
|
|
|
|
#ifdef WIN32
|
|
|
|
#include <winsock2.h>
|
|
|
|
#else
|
|
|
|
#include <sys/socket.h>
|
|
|
|
#endif
|
2009-07-28 17:17:23 +02:00
|
|
|
#include <unistd.h>
|
|
|
|
|
2010-01-20 21:04:07 +01:00
|
|
|
#ifdef HAVE_LIBWRAP
|
|
|
|
#include <tcpd.h>
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
2009-07-28 17:17:23 +02:00
|
|
|
#define LOG_LEVEL_SECURE G_LOG_LEVEL_INFO
|
|
|
|
|
|
|
|
static const char GREETING[] = "OK MPD " PROTOCOL_VERSION "\n";
|
|
|
|
|
2013-01-07 10:59:56 +01:00
|
|
|
Client::Client(Partition &_partition,
|
2013-01-03 23:32:05 +01:00
|
|
|
int fd, int _uid, int _num)
|
2013-01-07 10:59:56 +01:00
|
|
|
:partition(_partition),
|
|
|
|
playlist(partition.playlist), player_control(&partition.pc),
|
2013-01-03 23:32:05 +01:00
|
|
|
input(fifo_buffer_new(4096)),
|
|
|
|
permission(getDefaultPermissions()),
|
|
|
|
uid(_uid),
|
|
|
|
last_activity(g_timer_new()),
|
|
|
|
deferred_send(g_queue_new()), deferred_bytes(0),
|
|
|
|
num(_num),
|
2013-01-03 23:43:42 +01:00
|
|
|
send_buf_used(0),
|
2013-01-04 23:02:35 +01:00
|
|
|
idle_waiting(false), idle_flags(0),
|
|
|
|
num_subscriptions(0)
|
2013-01-03 23:32:05 +01:00
|
|
|
{
|
|
|
|
assert(fd >= 0);
|
|
|
|
|
|
|
|
channel = g_io_channel_new_socket(fd);
|
|
|
|
/* GLib is responsible for closing the file descriptor */
|
|
|
|
g_io_channel_set_close_on_unref(channel, true);
|
|
|
|
/* NULL encoding means the stream is binary safe; the MPD
|
|
|
|
protocol is UTF-8 only, but we are doing this call anyway
|
|
|
|
to prevent GLib from messing around with the stream */
|
|
|
|
g_io_channel_set_encoding(channel, NULL, NULL);
|
|
|
|
/* we prefer to do buffering */
|
|
|
|
g_io_channel_set_buffered(channel, false);
|
|
|
|
|
|
|
|
source_id = g_io_add_watch(channel,
|
|
|
|
GIOCondition(G_IO_IN|G_IO_ERR|G_IO_HUP),
|
|
|
|
client_in_event, this);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
deferred_buffer_free(gpointer data, G_GNUC_UNUSED gpointer user_data)
|
|
|
|
{
|
|
|
|
struct deferred_buffer *buffer = (struct deferred_buffer *)data;
|
|
|
|
g_free(buffer);
|
|
|
|
}
|
|
|
|
|
|
|
|
Client::~Client()
|
|
|
|
{
|
|
|
|
g_timer_destroy(last_activity);
|
|
|
|
|
|
|
|
g_queue_foreach(deferred_send, deferred_buffer_free, NULL);
|
|
|
|
g_queue_free(deferred_send);
|
|
|
|
|
|
|
|
fifo_buffer_free(input);
|
|
|
|
}
|
|
|
|
|
2009-11-03 21:08:48 +01:00
|
|
|
void
|
2013-01-07 10:59:56 +01:00
|
|
|
client_new(Partition &partition,
|
2009-11-03 21:08:48 +01:00
|
|
|
int fd, const struct sockaddr *sa, size_t sa_length, int uid)
|
2009-07-28 17:17:23 +02:00
|
|
|
{
|
|
|
|
static unsigned int next_client_num;
|
|
|
|
char *remote;
|
|
|
|
|
|
|
|
assert(fd >= 0);
|
|
|
|
|
2010-01-20 21:04:07 +01:00
|
|
|
#ifdef HAVE_LIBWRAP
|
|
|
|
if (sa->sa_family != AF_UNIX) {
|
|
|
|
char *hostaddr = sockaddr_to_string(sa, sa_length, NULL);
|
|
|
|
const char *progname = g_get_prgname();
|
|
|
|
|
|
|
|
struct request_info req;
|
|
|
|
request_init(&req, RQ_FILE, fd, RQ_DAEMON, progname, 0);
|
|
|
|
|
|
|
|
fromhost(&req);
|
|
|
|
|
|
|
|
if (!hosts_access(&req)) {
|
|
|
|
/* tcp wrappers says no */
|
|
|
|
g_log(G_LOG_DOMAIN, LOG_LEVEL_SECURE,
|
|
|
|
"libwrap refused connection (libwrap=%s) from %s",
|
|
|
|
progname, hostaddr);
|
|
|
|
|
|
|
|
g_free(hostaddr);
|
2011-09-19 21:04:19 +02:00
|
|
|
close_socket(fd);
|
2010-01-20 21:04:07 +01:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
g_free(hostaddr);
|
|
|
|
}
|
|
|
|
#endif /* HAVE_WRAP */
|
|
|
|
|
2009-07-28 17:17:23 +02:00
|
|
|
if (client_list_is_full()) {
|
|
|
|
g_warning("Max Connections Reached!");
|
2011-09-19 21:04:19 +02:00
|
|
|
close_socket(fd);
|
2009-07-28 17:17:23 +02:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2013-01-07 10:59:56 +01:00
|
|
|
Client *client = new Client(partition, fd, uid,
|
2013-01-03 23:32:05 +01:00
|
|
|
next_client_num++);
|
2009-07-28 17:17:23 +02:00
|
|
|
|
2010-05-09 01:48:01 +02:00
|
|
|
(void)send(fd, GREETING, sizeof(GREETING) - 1, 0);
|
2009-07-28 17:17:23 +02:00
|
|
|
|
|
|
|
client_list_add(client);
|
|
|
|
|
|
|
|
remote = sockaddr_to_string(sa, sa_length, NULL);
|
|
|
|
g_log(G_LOG_DOMAIN, LOG_LEVEL_SECURE,
|
|
|
|
"[%u] opened from %s", client->num, remote);
|
|
|
|
g_free(remote);
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
2013-01-15 10:11:08 +01:00
|
|
|
Client::Close()
|
2009-07-28 17:17:23 +02:00
|
|
|
{
|
2013-01-15 10:11:08 +01:00
|
|
|
client_list_remove(this);
|
2009-07-28 17:17:23 +02:00
|
|
|
|
2013-01-15 10:11:08 +01:00
|
|
|
SetExpired();
|
2009-07-28 17:17:23 +02:00
|
|
|
|
2013-01-15 10:11:08 +01:00
|
|
|
g_log(G_LOG_DOMAIN, LOG_LEVEL_SECURE, "[%u] closed", num);
|
|
|
|
delete this;
|
2009-07-28 17:17:23 +02:00
|
|
|
}
|