#include <dirent.h>
#include "para.h"
+#include "error.h"
#include "server.cmdline.h"
-#include "afs_common.h"
#include "afh.h"
+#include "string.h"
+#include "afs.h"
#include "server.h"
#include "vss.h"
#include "config.h"
#include "close_on_fork.h"
#include "send.h"
-#include "error.h"
#include "net.h"
#include "daemon.h"
-#include "string.h"
#include "ipc.h"
#include "fd.h"
#include "list.h"
#include "sched.h"
#include "signal.h"
#include "user_list.h"
-#include "afs.h"
/** define the array of error lists needed by para_server */
INIT_SERVER_ERRLISTS;
extern void http_send_init(struct sender *);
extern void ortp_send_init(struct sender *);
-/* TODO: This is better handled by autoconf */
-/** the list of supported audio file selectors */
-struct audio_file_selector selectors[] = {
- {
- .name = "random",
- .init = random_selector_init,
- .update_audio_file = NULL,
- },
- {
- .name = "playlist",
- .init = playlist_selector_init,
- .update_audio_file = NULL,
- .pre_select = NULL,
- .post_select = NULL,
- },
-#ifdef HAVE_MYSQL
- {
- .name = "mysql",
- .init = mysql_selector_init,
- .update_audio_file = NULL,
- .pre_select = NULL,
- .post_select = NULL,
- },
-#endif
- {
- .name = NULL,
- }
-};
-
/** the list of supported senders */
struct sender senders[] = {
{
goto err_out;
mmd_mutex = ret;
- mmd->selector_num = 0;
mmd->num_played = 0;
mmd->num_commands = 0;
mmd->events = 0;
mmd->num_connects = 0;
mmd->active_connections = 0;
- strcpy(mmd->filename, "(none)");
- mmd->audio_format = -1;
+ strcpy(mmd->afd.path, "(none)");
mmd->vss_status_flags = VSS_NEXT;
mmd->new_vss_status_flags = VSS_NEXT;
mmd->sender_cmd_data.cmd_num = -1;
char *cf;
if (conf.config_file_given)
- cf = conf.config_file_arg;
+ cf = para_strdup(conf.config_file_arg);
else
cf = make_message("%s/.paraslash/server.conf", home);
free(user_list_file);
}
}
-static void init_selector(void)
-{
- int i, ret;
-
- mmd->selector_change = -1; /* no change nec., set to new num by com_chs */
- if (!conf.selector_given)
- goto random;
- for (i = 0; selectors[i].name; i++) {
- if (strcmp(selectors[i].name, conf.selector_arg))
- continue;
- PARA_NOTICE_LOG("initializing %s audio file selector\n",
- selectors[i].name);
- ret = selectors[i].init(&selectors[i]);
- if (ret < 0) {
- PARA_WARNING_LOG("%s", PARA_STRERROR(-ret));
- break;
- }
- mmd->selector_num = i;
- return;
- }
- PARA_WARNING_LOG("%s", "falling back to the random selector\n");
-random:
- mmd->selector_num = 0;
- selectors[0].init(&selectors[0]); /* always successful */
-}
-
static unsigned init_network(void)
{
int fd, ret = init_tcp_socket(conf.port_arg);
}
uint32_t afs_socket_cookie;
-static int afs_socket;
+int afs_socket;
static pid_t afs_pid;
static void init_afs(void)
/* become daemon */
if (conf.daemon_given)
daemon_init();
- init_selector();
-// PARA_ERROR_LOG("num: %d\n", mmd->selector_num);
PARA_NOTICE_LOG("%s", "initializing virtual streaming system\n");
+ afh_init();
vss_init();
mmd->server_pid = getpid();
setup_signal_handling();
return sockfd;
}
-static void change_selector(void)
-{
- int ret, old = mmd->selector_num, new = mmd->selector_change;
-
- selectors[old].shutdown();
- ret = selectors[new].init(&selectors[new]);
- mmd->selector_change = -1; /* reset */
- if (ret >= 0) {
- mmd->selector_num = new;
- return;
- }
- /* init failed */
- PARA_ERROR_LOG("%s -- switching to the random selector\n", PARA_STRERROR(-ret));
- selectors[0].init(&selectors[0]);
- mmd->selector_num = 0;
-}
-
/*
* called when server gets SIGHUP or when client invokes hup command.
*/
close_log(logfile); /* gets reopened if necessary by parse_config */
logfile = NULL;
parse_config(1); /* reopens log */
- mmd->selector_change = mmd->selector_num; /* do not change selector.. */
- change_selector(); /* .. just reload */
init_user_list(user_list_file); /* reload user list */
if (afs_pid)
kill(afs_pid, SIGHUP);
prev_events = mmd->events;
mmd->vss_status_flags = mmd->new_vss_status_flags;
if (ret) {
- PARA_DEBUG_LOG("%d events, forcing status update, af = %d\n",
- mmd->events, mmd->audio_format);
+ PARA_DEBUG_LOG("%d events, forcing status update\n",
+ mmd->events);
killpg(0, SIGUSR1);
}
}
/* check socket and signal pipe in any case */
para_fd_set(sockfd, &rfds, &max_fileno);
para_fd_set(signal_pipe, &rfds, &max_fileno);
- timeout = vss_preselect();
+ timeout = vss_preselect(&rfds, &wfds, &max_fileno);
status_refresh();
for (i = 0; senders[i].name; i++) {
if (senders[i].status != SENDER_ON)
continue;
if (!senders[i].pre_select)
continue;
- senders[i].pre_select( &max_fileno, &rfds, &wfds);
- }
- if (selectors[mmd->selector_num].pre_select) {
- ret = selectors[mmd->selector_num].pre_select(&rfds, &wfds);
- max_fileno = PARA_MAX(max_fileno, ret);
+ senders[i].pre_select(&max_fileno, &rfds, &wfds);
}
mmd_unlock();
ret = para_select(max_fileno + 1, &rfds, &wfds, timeout);
mmd_lock();
- if (mmd->selector_change >= 0)
- change_selector();
- if (selectors[mmd->selector_num].post_select)
- selectors[mmd->selector_num].post_select(&rfds, &wfds);
+ vss_post_select(&rfds, &wfds);
if (ret < 0)
goto repeat;
for (i = 0; senders[i].name; i++) {
PARA_EMERG_LOG("terminating on signal %d\n", sig);
genocide:
kill(0, SIGTERM);
- selectors[mmd->selector_num].shutdown();
mutex_destroy(mmd_mutex);
shm_detach(mmd);
shm_destroy(mmd_shm_id);