X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_send.c;h=855780e6cd6a691be9dbaf1200e2c40f8fda3872;hp=74976cf202a27c430be96448011a966865fbf249;hb=db34194eaab9819772bd55ea1ab08c719ed8f1c8;hpb=a651debd8179d2a43d711b6f7f429a28bd2893c1 diff --git a/dccp_send.c b/dccp_send.c index 74976cf2..855780e6 100644 --- a/dccp_send.c +++ b/dccp_send.c @@ -50,17 +50,17 @@ struct dccp_client { int header_sent; }; -static void dccp_pre_select(__unused struct audio_format *af, int *max_fileno, fd_set *rfds, - __unused fd_set *wfds) +static void dccp_pre_select(__a_unused struct audio_format_handler *af, + int *max_fileno, fd_set *rfds, __a_unused fd_set *wfds) { if (listen_fd < 0) return; FD_SET(listen_fd, rfds); - *max_fileno = MAX(*max_fileno, listen_fd); + *max_fileno = PARA_MAX(*max_fileno, listen_fd); } -static void dccp_post_select(__unused struct audio_format *af, fd_set *rfds, - __unused fd_set *wfds) +static void dccp_post_select(__a_unused struct audio_format_handler *af, + fd_set *rfds, __a_unused fd_set *wfds) { struct dccp_client *dc; int ret; @@ -119,7 +119,7 @@ static int dccp_write(int fd, const char *buf, size_t len) size_t send, written = 0; int ret; again: - send = MIN(1024, len - written); + send = PARA_MIN(1024, len - written); ret = write(fd, buf + written, send); if (ret < 0) goto err_out; @@ -133,9 +133,9 @@ err_out: return -E_DCCP_WRITE; } -static void dccp_send(__unused struct audio_format *af, +static void dccp_send(__a_unused struct audio_format_handler *af, long unsigned current_chunk, - __unused long unsigned chunks_sent, const char *buf, size_t len) + __a_unused long unsigned chunks_sent, const char *buf, size_t len) { struct dccp_client *dc, *tmp; int ret, header_len; @@ -234,8 +234,9 @@ void dccp_send_init(struct sender *s) s->client_cmds[SENDER_DELETE] = NULL; self = s; ret = dccp_open(); - if (ret < 0) + if (ret < 0) { PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret)); - else + s->status = SENDER_OFF; + } else s->status = SENDER_ON; }