X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=ortp_send.c;h=077e7cf5c6c9aa645d6c944b557288141d92a363;hp=597068a82184ce93262ac6befd60566464207b2c;hb=80e46ec589d14be2fa4b0704f613a04ecb1b64c4;hpb=c8862b9e246b4ef6ff1fe103946e18cf2537ecde diff --git a/ortp_send.c b/ortp_send.c index 597068a8..077e7cf5 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); @@ -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"); }