Mercurial > audlegacy
diff libaudacious/beepctrl.c @ 0:cb178e5ad177 trunk
[svn] Import audacious source.
author | nenolod |
---|---|
date | Mon, 24 Oct 2005 03:06:47 -0700 |
parents | |
children | 0a73d1faeb4e |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/libaudacious/beepctrl.c Mon Oct 24 03:06:47 2005 -0700 @@ -0,0 +1,934 @@ +/* XMMS - Cross-platform multimedia player + * Copyright (C) 1998-2003 Peter Alm, Mikael Alm, Olle Hallnas, + * Thomas Nilsson and 4Front Technologies + * Copyright (C) 1999-2003 Haavard Kvaalen + * + * 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + */ + +#ifdef HAVE_CONFIG_H +# include "config.h" +#endif + +#include <glib.h> +#include <sys/types.h> +#include <sys/stat.h> +#include <sys/socket.h> +#include <sys/un.h> +#include <errno.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include "beepctrl.h" +#include "audacious/controlsocket.h" + + +#ifdef HAVE_UNISTD_H +#include <unistd.h> +#endif + +static gint +read_all(gint fd, gpointer buf, size_t count) +{ + size_t left = count; + GTimer *timer; + gulong usec; + gint r; + + timer = g_timer_new(); + + do { + if ((r = read(fd, buf, left)) < 0) { + count = -1; + break; + } + left -= r; + buf = (gchar *) buf + r; + g_timer_elapsed(timer, &usec); + } + while (left > 0 && usec <= CTRLSOCKET_IO_TIMEOUT_USEC); + + g_timer_destroy(timer); + return count - left; +} + +static gint +write_all(gint fd, gconstpointer buf, size_t count) +{ + size_t left = count; + GTimer *timer; + gulong usec; + gint written; + + timer = g_timer_new(); + + do { + if ((written = write(fd, buf, left)) < 0) { + count = -1; + break; + } + left -= written; + buf = (gchar *) buf + written; + g_timer_elapsed(timer, &usec); + } + while (left > 0 && usec <= CTRLSOCKET_IO_TIMEOUT_USEC); + + g_timer_destroy(timer); + return count - left; +} + +static gpointer +remote_read_packet(gint fd, ServerPktHeader * pkt_hdr) +{ + gpointer data = NULL; + + if (read_all(fd, pkt_hdr, sizeof(ServerPktHeader)) == + sizeof(ServerPktHeader)) { + if (pkt_hdr->data_length) { + size_t data_length = pkt_hdr->data_length; + data = g_malloc0(data_length); + if (read_all(fd, data, data_length) < data_length) { + g_free(data); + data = NULL; + } + } + } + return data; +} + +static void +remote_read_ack(gint fd) +{ + gpointer data; + ServerPktHeader pkt_hdr; + + data = remote_read_packet(fd, &pkt_hdr); + if (data) + g_free(data); + +} + +static void +remote_send_packet(gint fd, guint32 command, gpointer data, + guint32 data_length) +{ + ClientPktHeader pkt_hdr; + + pkt_hdr.version = XMMS_PROTOCOL_VERSION; + pkt_hdr.command = command; + pkt_hdr.data_length = data_length; + if (write_all(fd, &pkt_hdr, sizeof(ClientPktHeader)) < sizeof(pkt_hdr)) + return; + if (data_length && data) + write_all(fd, data, data_length); +} + +static void +remote_send_guint32(gint session, guint32 cmd, guint32 val) +{ + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + remote_send_packet(fd, cmd, &val, sizeof(guint32)); + remote_read_ack(fd); + close(fd); +} + +static void +remote_send_boolean(gint session, guint32 cmd, gboolean val) +{ + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + remote_send_packet(fd, cmd, &val, sizeof(gboolean)); + remote_read_ack(fd); + close(fd); +} + +static void +remote_send_gfloat(gint session, guint32 cmd, gfloat value) +{ + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + remote_send_packet(fd, cmd, &value, sizeof(gfloat)); + remote_read_ack(fd); + close(fd); +} + +static void +remote_send_string(gint session, guint32 cmd, gchar * string) +{ + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + remote_send_packet(fd, cmd, string, string ? strlen(string) + 1 : 0); + remote_read_ack(fd); + close(fd); +} + +static gboolean +remote_cmd(gint session, guint32 cmd) +{ + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return FALSE; + remote_send_packet(fd, cmd, NULL, 0); + remote_read_ack(fd); + close(fd); + + return TRUE; +} + +static gboolean +remote_get_gboolean(gint session, gint cmd) +{ + ServerPktHeader pkt_hdr; + gboolean ret = FALSE; + gpointer data; + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return ret; + remote_send_packet(fd, cmd, NULL, 0); + data = remote_read_packet(fd, &pkt_hdr); + if (data) { + ret = *((gboolean *) data); + g_free(data); + } + remote_read_ack(fd); + close(fd); + + return ret; +} + +static guint32 +remote_get_gint(gint session, gint cmd) +{ + ServerPktHeader pkt_hdr; + gpointer data; + gint fd, ret = 0; + + if ((fd = xmms_connect_to_session(session)) == -1) + return ret; + remote_send_packet(fd, cmd, NULL, 0); + data = remote_read_packet(fd, &pkt_hdr); + if (data) { + ret = *((gint *) data); + g_free(data); + } + remote_read_ack(fd); + close(fd); + return ret; +} + +static gfloat +remote_get_gfloat(gint session, gint cmd) +{ + ServerPktHeader pkt_hdr; + gpointer data; + gint fd; + gfloat ret = 0.0; + + if ((fd = xmms_connect_to_session(session)) == -1) + return ret; + remote_send_packet(fd, cmd, NULL, 0); + data = remote_read_packet(fd, &pkt_hdr); + if (data) { + ret = *((gfloat *) data); + g_free(data); + } + remote_read_ack(fd); + close(fd); + return ret; +} + +gchar * +remote_get_string(gint session, gint cmd) +{ + ServerPktHeader pkt_hdr; + gpointer data; + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return NULL; + remote_send_packet(fd, cmd, NULL, 0); + data = remote_read_packet(fd, &pkt_hdr); + remote_read_ack(fd); + close(fd); + return data; +} + +gchar * +remote_get_string_pos(gint session, gint cmd, guint32 pos) +{ + ServerPktHeader pkt_hdr; + gpointer data; + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return NULL; + remote_send_packet(fd, cmd, &pos, sizeof(guint32)); + data = remote_read_packet(fd, &pkt_hdr); + remote_read_ack(fd); + close(fd); + return data; +} + +gint +xmms_connect_to_session(gint session) +{ + gint fd; + uid_t stored_uid, euid; + struct sockaddr_un saddr; + + if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) != -1) { + saddr.sun_family = AF_UNIX; + stored_uid = getuid(); + euid = geteuid(); + setuid(euid); + g_snprintf(saddr.sun_path, 108, "%s/%s_%s.%d", g_get_tmp_dir(), + CTRLSOCKET_NAME, g_get_user_name(), session); + setreuid(stored_uid, euid); + if (connect(fd, (struct sockaddr *) &saddr, sizeof(saddr)) != -1) + return fd; + } + close(fd); + return -1; +} + +void +xmms_remote_playlist(gint session, gchar ** list, gint num, gboolean enqueue) +{ + gint fd, i; + gchar *data, *ptr; + gint data_length; + guint32 len; + + g_return_if_fail(list != NULL); + g_return_if_fail(num > 0); + + if (!enqueue) + xmms_remote_playlist_clear(session); + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + + for (i = 0, data_length = 0; i < num; i++) + data_length += (((strlen(list[i]) + 1) + 3) / 4) * 4 + 4; + if (data_length) { + data_length += 4; + data = g_malloc(data_length); + for (i = 0, ptr = data; i < num; i++) { + len = strlen(list[i]) + 1; + *((guint32 *) ptr) = len; + ptr += 4; + memcpy(ptr, list[i], len); + ptr += ((len + 3) / 4) * 4; + } + *((guint32 *) ptr) = 0; + remote_send_packet(fd, CMD_PLAYLIST_ADD, data, data_length); + remote_read_ack(fd); + close(fd); + g_free(data); + } + + if (!enqueue) + xmms_remote_play(session); +} + +gint +xmms_remote_get_version(gint session) +{ + return remote_get_gint(session, CMD_GET_VERSION); +} + +void +xmms_remote_play_files(gint session, GList * list) +{ + g_return_if_fail(list != NULL); + + xmms_remote_playlist_clear(session); + xmms_remote_add_files(session, list); + xmms_remote_play(session); +} + +void +xmms_remote_playlist_add(gint session, GList * list) +{ + gchar **str_list; + GList *node; + gint i, num; + + g_return_if_fail(list != NULL); + + num = g_list_length(list); + str_list = g_malloc0(num * sizeof(gchar *)); + for (i = 0, node = list; i < num && node; i++, node = g_list_next(node)) + str_list[i] = node->data; + + xmms_remote_playlist(session, str_list, num, TRUE); + g_free(str_list); +} + +void +xmms_remote_playlist_delete(gint session, gint pos) +{ + remote_send_guint32(session, CMD_PLAYLIST_DELETE, pos); +} + +void +xmms_remote_play(gint session) +{ + remote_cmd(session, CMD_PLAY); +} + +void +xmms_remote_pause(gint session) +{ + remote_cmd(session, CMD_PAUSE); +} + +void +xmms_remote_stop(gint session) +{ + remote_cmd(session, CMD_STOP); +} + +void +xmms_remote_play_pause(gint session) +{ + remote_cmd(session, CMD_PLAY_PAUSE); +} + +gboolean +xmms_remote_is_playing(gint session) +{ + return remote_get_gboolean(session, CMD_IS_PLAYING); +} + +gboolean +xmms_remote_is_paused(gint session) +{ + return remote_get_gboolean(session, CMD_IS_PAUSED); +} + +gint +xmms_remote_get_playlist_pos(gint session) +{ + return remote_get_gint(session, CMD_GET_PLAYLIST_POS); +} + +void +xmms_remote_set_playlist_pos(gint session, gint pos) +{ + remote_send_guint32(session, CMD_SET_PLAYLIST_POS, pos); +} + +gint +xmms_remote_get_playlist_length(gint session) +{ + return remote_get_gint(session, CMD_GET_PLAYLIST_LENGTH); +} + +void +xmms_remote_playlist_clear(gint session) +{ + remote_cmd(session, CMD_PLAYLIST_CLEAR); +} + +gint +xmms_remote_get_output_time(gint session) +{ + return remote_get_gint(session, CMD_GET_OUTPUT_TIME); +} + +void +xmms_remote_jump_to_time(gint session, gint pos) +{ + remote_send_guint32(session, CMD_JUMP_TO_TIME, pos); +} + +void +xmms_remote_get_volume(gint session, gint * vl, gint * vr) +{ + ServerPktHeader pkt_hdr; + gint fd; + gpointer data; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + + remote_send_packet(fd, CMD_GET_VOLUME, NULL, 0); + data = remote_read_packet(fd, &pkt_hdr); + if (data) { + *vl = ((guint32 *) data)[0]; + *vr = ((guint32 *) data)[1]; + g_free(data); + } + remote_read_ack(fd); + close(fd); +} + +gint +xmms_remote_get_main_volume(gint session) +{ + gint vl, vr; + + xmms_remote_get_volume(session, &vl, &vr); + + return (vl > vr) ? vl : vr; +} + +gint +xmms_remote_get_balance(gint session) +{ + return remote_get_gint(session, CMD_GET_BALANCE); +} + +void +xmms_remote_set_volume(gint session, gint vl, gint vr) +{ + gint fd; + guint32 v[2]; + + if (vl < 0) + vl = 0; + if (vl > 100) + vl = 100; + if (vr < 0) + vr = 0; + if (vr > 100) + vr = 100; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + v[0] = vl; + v[1] = vr; + remote_send_packet(fd, CMD_SET_VOLUME, v, 2 * sizeof(guint32)); + remote_read_ack(fd); + close(fd); +} + +void +xmms_remote_set_main_volume(gint session, gint v) +{ + gint b, vl, vr; + + b = xmms_remote_get_balance(session); + + if (b < 0) { + vl = v; + vr = (v * (100 - abs(b))) / 100; + } + else if (b > 0) { + vl = (v * (100 - b)) / 100; + vr = v; + } + else + vl = vr = v; + xmms_remote_set_volume(session, vl, vr); +} + +void +xmms_remote_set_balance(gint session, gint b) +{ + gint v, vl, vr; + + if (b < -100) + b = -100; + if (b > 100) + b = 100; + + v = xmms_remote_get_main_volume(session); + + if (b < 0) { + vl = v; + vr = (v * (100 - abs(b))) / 100; + } + else if (b > 0) { + vl = (v * (100 - b)) / 100; + vr = v; + } + else + vl = vr = v; + xmms_remote_set_volume(session, vl, vr); +} + +gchar * +xmms_remote_get_skin(gint session) +{ + return remote_get_string(session, CMD_GET_SKIN); +} + +void +xmms_remote_set_skin(gint session, gchar * skinfile) +{ + remote_send_string(session, CMD_SET_SKIN, skinfile); +} + +gchar * +xmms_remote_get_playlist_file(gint session, gint pos) +{ + return remote_get_string_pos(session, CMD_GET_PLAYLIST_FILE, pos); +} + +gchar * +xmms_remote_get_playlist_title(gint session, gint pos) +{ + return remote_get_string_pos(session, CMD_GET_PLAYLIST_TITLE, pos); +} + +gint +xmms_remote_get_playlist_time(gint session, gint pos) +{ + ServerPktHeader pkt_hdr; + gpointer data; + gint fd, ret = 0; + guint32 p = pos; + + if ((fd = xmms_connect_to_session(session)) == -1) + return ret; + remote_send_packet(fd, CMD_GET_PLAYLIST_TIME, &p, sizeof(guint32)); + data = remote_read_packet(fd, &pkt_hdr); + if (data) { + ret = *((gint *) data); + g_free(data); + } + remote_read_ack(fd); + close(fd); + return ret; +} + +void +xmms_remote_get_info(gint session, gint * rate, gint * freq, gint * nch) +{ + ServerPktHeader pkt_hdr; + gint fd; + gpointer data; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + remote_send_packet(fd, CMD_GET_INFO, NULL, 0); + data = remote_read_packet(fd, &pkt_hdr); + if (data) { + *rate = ((guint32 *) data)[0]; + *freq = ((guint32 *) data)[1]; + *nch = ((guint32 *) data)[2]; + g_free(data); + } + remote_read_ack(fd); + close(fd); +} + +void +xmms_remote_get_eq_data(gint session) +{ + /* Obsolete */ +} + +void +xmms_remote_set_eq_data(gint session) +{ + /* Obsolete */ +} + +void +xmms_remote_pl_win_toggle(gint session, gboolean show) +{ + remote_send_boolean(session, CMD_PL_WIN_TOGGLE, show); +} + +void +xmms_remote_eq_win_toggle(gint session, gboolean show) +{ + remote_send_boolean(session, CMD_EQ_WIN_TOGGLE, show); +} + +void +xmms_remote_main_win_toggle(gint session, gboolean show) +{ + remote_send_boolean(session, CMD_MAIN_WIN_TOGGLE, show); +} + +gboolean +xmms_remote_is_main_win(gint session) +{ + return remote_get_gboolean(session, CMD_IS_MAIN_WIN); +} + +gboolean +xmms_remote_is_pl_win(gint session) +{ + return remote_get_gboolean(session, CMD_IS_PL_WIN); +} + +gboolean +xmms_remote_is_eq_win(gint session) +{ + return remote_get_gboolean(session, CMD_IS_EQ_WIN); +} + +void +xmms_remote_show_prefs_box(gint session) +{ + remote_cmd(session, CMD_SHOW_PREFS_BOX); +} + +void +xmms_remote_toggle_aot(gint session, gboolean ontop) +{ + remote_send_boolean(session, CMD_TOGGLE_AOT, ontop); +} + +void +xmms_remote_show_about_box(gint session) +{ + remote_cmd(session, CMD_SHOW_ABOUT_BOX); +} + +void +xmms_remote_eject(gint session) +{ + remote_cmd(session, CMD_EJECT); +} + +void +xmms_remote_playlist_prev(gint session) +{ + remote_cmd(session, CMD_PLAYLIST_PREV); +} + +void +xmms_remote_playlist_next(gint session) +{ + remote_cmd(session, CMD_PLAYLIST_NEXT); +} + +void +xmms_remote_playlist_add_url_string(gint session, gchar * string) +{ + g_return_if_fail(string != NULL); + remote_send_string(session, CMD_PLAYLIST_ADD_URL_STRING, string); +} + +void +xmms_remote_playlist_ins_url_string(gint session, gchar * string, gint pos) +{ + gint fd, size; + gchar *packet; + + g_return_if_fail(string != NULL); + + size = strlen(string) + 1 + sizeof(gint); + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + + packet = g_malloc0(size); + *((gint *) packet) = pos; + strcpy(packet + sizeof(gint), string); + remote_send_packet(fd, CMD_PLAYLIST_INS_URL_STRING, packet, size); + remote_read_ack(fd); + close(fd); + g_free(packet); +} + +gboolean +xmms_remote_is_running(gint session) +{ + return remote_cmd(session, CMD_PING); +} + +void +xmms_remote_toggle_repeat(gint session) +{ + remote_cmd(session, CMD_TOGGLE_REPEAT); +} + +void +xmms_remote_toggle_shuffle(gint session) +{ + remote_cmd(session, CMD_TOGGLE_SHUFFLE); +} + +void +xmms_remote_toggle_advance(int session) +{ + remote_cmd(session, CMD_TOGGLE_ADVANCE); +} + +gboolean +xmms_remote_is_repeat(gint session) +{ + return remote_get_gboolean(session, CMD_IS_REPEAT); +} + +gboolean +xmms_remote_is_shuffle(gint session) +{ + return remote_get_gboolean(session, CMD_IS_SHUFFLE); +} + +gboolean +xmms_remote_is_advance(gint session) +{ + return remote_get_gboolean(session, CMD_IS_ADVANCE); +} + +void +xmms_remote_playqueue_add(gint session, gint pos) +{ + remote_send_guint32(session, CMD_PLAYQUEUE_ADD, pos); +} + +void +xmms_remote_playqueue_remove(gint session, gint pos) +{ + remote_send_guint32(session, CMD_PLAYQUEUE_REMOVE, pos); +} + +gint +xmms_remote_get_playqueue_length(gint session) +{ + return remote_get_gint(session, CMD_GET_PLAYQUEUE_LENGTH); +} + +void +xmms_remote_get_eq(gint session, gfloat * preamp, gfloat ** bands) +{ + ServerPktHeader pkt_hdr; + gint fd; + gpointer data; + + if (preamp) + *preamp = 0.0; + + if (bands) + *bands = NULL; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + remote_send_packet(fd, CMD_GET_EQ, NULL, 0); + data = remote_read_packet(fd, &pkt_hdr); + if (data) { + if (pkt_hdr.data_length >= 11 * sizeof(gfloat)) { + if (preamp) + *preamp = *((gfloat *) data); + if (bands) + *bands = + (gfloat *) g_memdup((gfloat *) data + 1, + 10 * sizeof(gfloat)); + } + g_free(data); + } + remote_read_ack(fd); + close(fd); +} + +gfloat +xmms_remote_get_eq_preamp(gint session) +{ + return remote_get_gfloat(session, CMD_GET_EQ_PREAMP); +} + +gfloat +xmms_remote_get_eq_band(gint session, gint band) +{ + ServerPktHeader pkt_hdr; + gint fd; + gpointer data; + gfloat val = 0.0; + + if ((fd = xmms_connect_to_session(session)) == -1) + return val; + remote_send_packet(fd, CMD_GET_EQ_BAND, &band, sizeof(band)); + data = remote_read_packet(fd, &pkt_hdr); + if (data) { + val = *((gfloat *) data); + g_free(data); + } + remote_read_ack(fd); + close(fd); + return val; +} + +void +xmms_remote_set_eq(gint session, gfloat preamp, gfloat * bands) +{ + gint fd, i; + gfloat data[11]; + + g_return_if_fail(bands != NULL); + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + data[0] = preamp; + for (i = 0; i < 10; i++) + data[i + 1] = bands[i]; + remote_send_packet(fd, CMD_SET_EQ, data, sizeof(data)); + remote_read_ack(fd); + close(fd); +} + +void +xmms_remote_set_eq_preamp(gint session, gfloat preamp) +{ + remote_send_gfloat(session, CMD_SET_EQ_PREAMP, preamp); +} + +void +xmms_remote_set_eq_band(gint session, gint band, gfloat value) +{ + gint fd; + gchar data[sizeof(gint) + sizeof(gfloat)]; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + *((gint *) data) = band; + *((gfloat *) (data + sizeof(gint))) = value; + remote_send_packet(fd, CMD_SET_EQ_BAND, data, sizeof(data)); + remote_read_ack(fd); + close(fd); +} + +void +xmms_remote_quit(gint session) +{ + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + remote_send_packet(fd, CMD_QUIT, NULL, 0); + remote_read_ack(fd); + close(fd); +} + +void +xmms_remote_activate(gint session) +{ + gint fd; + + if ((fd = xmms_connect_to_session(session)) == -1) + return; + remote_send_packet(fd, CMD_ACTIVATE, NULL, 0); + remote_read_ack(fd); + close(fd); +}