X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=ortp_send.c;h=9c166aee289f5b06ed4c2e39e6c0ad100d73c8a8;hp=597068a82184ce93262ac6befd60566464207b2c;hb=f45846b1a228c806424e6bf937ba09e648e87441;hpb=c8862b9e246b4ef6ff1fe103946e18cf2537ecde diff --git a/ortp_send.c b/ortp_send.c index 597068a8..9c166aee 100644 --- a/ortp_send.c +++ b/ortp_send.c @@ -17,8 +17,8 @@ #include "afs.h" #include "server.h" #include "vss.h" -#include "send.h" #include "list.h" +#include "send.h" #include "ortp.h" /** Convert in_addr to ascii. */ @@ -46,6 +46,7 @@ struct ortp_target { static struct list_head targets; static struct sender *self; +static int sender_status; static void ortp_delete_target(struct ortp_target *ot, const char *msg) { @@ -167,7 +168,7 @@ static void ortp_send(long unsigned current_chunk, long unsigned chunks_sent, char *sendbuf, *header_buf = NULL; struct timeval *chunk_tv; - if (self->status != SENDER_ON) + if (sender_status != SENDER_ON) return; // PARA_NOTICE_LOG("sending %lu\n", current_chunk); @@ -189,7 +190,7 @@ static void ortp_send(long unsigned current_chunk, long unsigned chunks_sent, } if (list_empty(&targets)) return; - header_buf = vss_get_header(&header_len); + vss_get_header(&header_buf, &header_len); if (!need_extra_header(current_chunk)) header_len = 0; sendbuf_len = ORTP_AUDIO_HEADER_LEN + header_len + len; @@ -213,14 +214,14 @@ static void ortp_send(long unsigned current_chunk, long unsigned chunks_sent, static int ortp_com_on(__a_unused struct sender_command_data *scd) { - self->status = SENDER_ON; + sender_status = SENDER_ON; return 1; } static int ortp_com_off(__a_unused struct sender_command_data *scd) { ortp_shutdown_targets(); - self->status = SENDER_OFF; + sender_status = SENDER_OFF; return 1; } @@ -267,10 +268,11 @@ static char *ortp_info(void) tgts = tmp; } ret = make_message( - "ortp status: %s\n" - "ortp default port: udp %d\n" - "ortp targets: %s\n", - (self->status == SENDER_ON)? "on" : "off", + "ortp sender:\n" + "\tstatus: %s\n" + "\tport: udp %d\n" + "\ttargets: %s\n", + (sender_status == SENDER_ON)? "on" : "off", conf.ortp_default_port_arg, tgts? tgts : "(none)" ); @@ -308,12 +310,6 @@ success: } } -static void ortp_pre_select(__a_unused int *max_fileno, __a_unused fd_set *rfds, - __a_unused fd_set *wfds) -{ - return; -} - static char *ortp_help(void) { return make_message( @@ -337,7 +333,7 @@ void ortp_send_init(struct sender *s) s->info = ortp_info; s->help = ortp_help; s->send = ortp_send; - s->pre_select = ortp_pre_select; + s->pre_select = NULL; s->post_select = NULL; s->shutdown_clients = ortp_shutdown_targets; s->client_cmds[SENDER_ON] = ortp_com_on; @@ -347,9 +343,9 @@ void ortp_send_init(struct sender *s) s->client_cmds[SENDER_ADD] = ortp_com_add; s->client_cmds[SENDER_DELETE] = ortp_com_delete; self = s; - s->status = SENDER_OFF; + sender_status = SENDER_OFF; ortp_init_target_list(); if (!conf.ortp_no_autostart_given) - s->status = SENDER_ON; - PARA_DEBUG_LOG("%s", "ortp sender init complete\n"); + sender_status = SENDER_ON; + PARA_DEBUG_LOG("ortp sender init complete\n"); }