X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=ortp_send.c;h=46b3ece763aaed16f8de964a40d5c5c91d10eaf2;hp=9363d74e79f4b85e990a5c667655dd68dc6eb77a;hb=ccf42979a31a56e991b5c6d7d4043381f7487d6e;hpb=45ae2fe1c2fa855e4f63ea168a63d0bd39e416a4 diff --git a/ortp_send.c b/ortp_send.c index 9363d74e..46b3ece7 100644 --- a/ortp_send.c +++ b/ortp_send.c @@ -116,23 +116,25 @@ static void ortp_init_session(struct ortp_target *ot) /* called by afs */ static void ortp_shutdown_targets(void) { - char buf[2]; + char buf[ORTP_AUDIO_HEADER_LEN]; struct ortp_target *ot, *tmp; - buf[0] = ORTP_EOF; + WRITE_PACKET_TYPE(buf, ORTP_EOF); list_for_each_entry_safe(ot, tmp, &targets, node) { if (!ot->session || !ot->streaming) continue; - PARA_INFO_LOG("sending eof to ortp target %s:%d, ts = %d\n", TARGET_ADDR(ot), ot->port, - ot->last_ts); - rtp_session_send_with_ts(ot->session, buf, 1, ot->last_ts); + PARA_INFO_LOG("sending eof to ortp target %s:%d, ts = %d\n", + TARGET_ADDR(ot), ot->port, ot->last_ts); + rtp_session_send_with_ts(ot->session, buf, + ORTP_AUDIO_HEADER_LEN, ot->last_ts); ot->streaming = 0; ot->chunk_ts = 0; rtp_session_reset(ot->session); } } -static int need_extra_header(struct audio_format *af, long unsigned chunks_sent) +static int need_extra_header(struct audio_format_handler *af, + long unsigned chunks_sent) { /* FIXME: No need to compute this on every run */ int mod = conf.ortp_header_interval_arg / (tv2ms(&af->chunk_tv) + 1); @@ -141,7 +143,7 @@ static int need_extra_header(struct audio_format *af, long unsigned chunks_sent) return 1; } -static void ortp_send(struct audio_format *af, long unsigned current_chunk, +static void ortp_send(struct audio_format_handler *af, long unsigned current_chunk, long unsigned chunks_sent, const char *buf, size_t len) { struct ortp_target *ot, *tmp; @@ -288,7 +290,7 @@ success: } } -static void ortp_pre_select(__a_unused struct audio_format *af, +static void ortp_pre_select(__a_unused struct audio_format_handler *af, __a_unused int *max_fileno, __a_unused fd_set *rfds, __a_unused fd_set *wfds) {