X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=ortp_send.c;h=19b54d3932897be20067c6b06b608653fafbf911;hp=94c979fcd7b8bcdf37ebc913e28ea1940a993cb6;hb=c430e588047c5db3eb0d043c4dd1378680ec2bcf;hpb=4c9c14ef6dec05d198a2e3c26dfce15ff25ea8ba diff --git a/ortp_send.c b/ortp_send.c index 94c979fc..19b54d39 100644 --- a/ortp_send.c +++ b/ortp_send.c @@ -18,13 +18,13 @@ /** \file ortp_send.c para_server's ortp sender */ +#include #include "server.cmdline.h" #include "server.h" #include "afs.h" #include "send.h" #include "list.h" -#include #include "ortp.h" #include "string.h" @@ -54,7 +54,6 @@ struct ortp_target { RtpSession *session; }; -static int numtargets; static struct list_head targets; static struct sender *self; @@ -66,7 +65,6 @@ static void ortp_delete_target(struct ortp_target *ot, const char *msg) rtp_session_destroy(ot->session); ot->session = NULL; } - numtargets--; list_del(&ot->node); free(ot); } @@ -103,7 +101,11 @@ static void ortp_init_session(struct ortp_target *ot) if (!ot->session) return; s = ot->session; -// rtp_session_set_jitter_compensation(ot->session, 100); + if (conf.ortp_jitter_compensation_arg) { + rtp_session_enable_adaptive_jitter_compensation(ot->session, TRUE); + rtp_session_set_jitter_compensation(ot->session, + conf.ortp_jitter_compensation_arg); + } /* always successful */ rtp_session_set_send_payload_type(s, PAYLOAD_AUDIO_CONTINUOUS); ret = rtp_session_set_remote_addr(s, TARGET_ADDR(ot), ot->port); @@ -159,8 +161,10 @@ static void ortp_send(struct audio_format *af, long unsigned current_chunk, continue; } if (!ot->chunk_ts) - ot->chunk_ts = rtp_session_time_to_ts(ot->session, tv2ms(&af->chunk_tv)); -// PARA_DEBUG_LOG("len: %d, af: %p, ts: %d\n", len, af, ot->chunk_ts); + ot->chunk_ts = rtp_session_time_to_ts(ot->session, + tv2ms(&af->chunk_tv)); +// PARA_DEBUG_LOG("len: %d, ts: %lu, ts: %d\n", +// len, ot->chunk_ts * chunks_sent, ot->chunk_ts); ot->streaming = 1; } if (list_empty(&targets)) @@ -311,7 +315,6 @@ static char *ortp_help(void) void ortp_send_init(struct sender *s) { ortp_init(); - ortp_set_debug_file("oRTP", NULL); INIT_LIST_HEAD(&targets); s->info = ortp_info; s->help = ortp_help;