X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=audiod.c;h=0479e1e132c6b6e8d9fceb110f97bd98ed6d8381;hp=767afa8dec4b4e607b82e244b10c71d71d049e1f;hb=dd462c7e1b61864d6da01a877ced78dab72e2244;hpb=337d7784b0f8bc30b1fa9af56ace503acd97d40d

diff --git a/audiod.c b/audiod.c
index 767afa8d..0479e1e1 100644
--- a/audiod.c
+++ b/audiod.c
@@ -5,19 +5,21 @@
  */
 
 /** \file audiod.c the paraslash's audio daemon */
+#include <regex.h>
 #include <sys/types.h>
 #include <dirent.h>
 #include <signal.h>
+#include <openssl/rc4.h>
 
 #include "para.h"
 #include "error.h"
+#include "crypt.h"
 #include "audiod.cmdline.h"
 #include "list.h"
 #include "sched.h"
 #include "ggo.h"
 #include "recv.h"
 #include "filter.h"
-#include "grab_client.cmdline.h"
 #include "grab_client.h"
 #include "client.cmdline.h"
 #include "client.h"
@@ -160,7 +162,7 @@ struct command_task {
  * \return The audio format number on success, -E_UNSUPPORTED_AUDIO_FORMAT if
  * \a name is not a supported audio format.
  */
-int get_audio_format_num(char *name)
+int get_audio_format_num(const char *name)
 {
 	int i;
 
@@ -384,8 +386,8 @@ static void open_filters(int slot_num)
 	s->fc->inbufp = &s->receiver_node->buf;
 	s->fc->in_loaded = &s->receiver_node->loaded;
 	s->fc->input_error = &s->receiver_node->task.error;
-	s->fc->task.pre_select = filter_pre_select;
-	s->fc->task.post_select = NULL;
+	s->fc->task.pre_select = NULL;
+	s->fc->task.post_select = filter_post_select;
 	s->fc->task.error = 0;
 	s->fc->num_filters = nf;
 
@@ -443,7 +445,7 @@ static void open_writers(int slot_num)
 		stat_task->server_stream_start : *now;
 	s->offset_seconds = stat_task->offset_seconds;
 	s->seconds_total = stat_task->length_seconds;
-	activate_inactive_grab_clients(slot_num, s->format, s->fc);
+	activate_inactive_grab_clients(s->format, s->fc);
 }
 
 static int open_receiver(int format)
@@ -900,8 +902,15 @@ static void command_post_select(struct sched *s, struct task *t)
 {
 	int ret;
 	struct command_task *ct = container_of(t, struct command_task, task);
+	static struct timeval last_status_dump;
+	struct timeval tmp;
+
+	tv_add(&last_status_dump, &(struct timeval){0, 500 * 1000}, &tmp);
+	if (tv_diff(&tmp, now, NULL) < 0) {
+		audiod_status_dump();
+		last_status_dump = *now;
+	}
 
-	audiod_status_dump();
 	if (!FD_ISSET(ct->fd, &s->rfds))
 		return;
 	ret = handle_connect(ct->fd);
@@ -1225,7 +1234,7 @@ int main(int argc, char *argv[])
 	register_task(&cmd_task->task);
 	register_task(&stat_task->task);
 	s.default_timeout.tv_sec = 0;
-	s.default_timeout.tv_usec = 99 * 1000;
+	s.default_timeout.tv_usec = 999 * 1000;
 	ret = schedule(&s);
 
 	PARA_EMERG_LOG("%s\n", para_strerror(-ret));