X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=audiod.c;h=0d8745d725bce902419afdd17c50a58cf51dd7fc;hp=df7c1e1b4969d84591b8e24993cfb55cfcd999c7;hb=b99f2c1074bb0786c389830fc5c4db93a61a1dcc;hpb=a9fff73b100933309af4e1b35d7ff5aa320f2c9b

diff --git a/audiod.c b/audiod.c
index df7c1e1b..0d8745d7 100644
--- a/audiod.c
+++ b/audiod.c
@@ -83,10 +83,6 @@ struct audio_format_info {
 struct slot_info {
 	/** number of the audio format in this slot */
 	int format;
-	/** time of the last successful read from the receiver */
-	struct timeval rtime;
-	/** time the last write to the write fd happend */
-	struct timeval wtime;
 	/** writer start time */
 	struct timeval wstime;
 	/** the receiver info associated with this slot */
@@ -710,8 +706,6 @@ static void open_receiver(int format)
 		clean_exit(EXIT_FAILURE, PARA_STRERROR(-slot_num));
 	s = &slot[slot_num];
 	s->format = format;
-	s->rtime = *now;
-	s->wtime = s->rtime;
 	s->receiver_node = para_calloc(sizeof(struct receiver_node));
 	rn = s->receiver_node;
 	rn->receiver = a->receiver;
@@ -862,25 +856,6 @@ static void handle_signal(int sig)
 	}
 }
 
-static void check_timeouts(void)
-{
-
-	int slot_num, timeout = conf.stream_timeout_arg;
-
-	FOR_EACH_SLOT(slot_num) {
-		struct slot_info *s = &slot[slot_num];
-		if (s->format < 0)
-			continue;
-		/* check read time */
-		if (s->receiver_node &&
-			now->tv_sec > s->rtime.tv_sec + timeout) {
-			PARA_INFO_LOG("%s stream (slot %d) not ready\n",
-				audio_formats[s->format], slot_num);
-			s->receiver_node->eof = 1;
-		}
-	}
-}
-
 static void try_to_close_slot(int slot_num)
 {
 	struct slot_info *s = &slot[slot_num];
@@ -911,7 +886,6 @@ static void audiod_pre_select(struct sched *s, __a_unused struct task *t)
 		kill_all_decoders();
 	else if (playing)
 		open_current_receiver();
-	check_timeouts();
 	FOR_EACH_SLOT(i) {
 		struct receiver_node *rn;
 
@@ -928,15 +902,8 @@ static void audiod_pre_select(struct sched *s, __a_unused struct task *t)
 
 static void audiod_post_select(struct sched *s, __a_unused struct task *t)
 {
-	int i;
-
+	/* only save away the current time for other users */
 	now = &s->now;
-	FOR_EACH_SLOT(i) {
-		struct receiver_node *rn = slot[i].receiver_node;
-
-		if (rn && rn->loaded)
-			slot[i].rtime = *now;
-	}
 }
 
 static void init_audiod_task(struct audiod_task *at)