X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=dccp_send.c;h=0410c8bca99838a199fe30d92280d7fe333ef15f;hb=d4171bf0379c24a15df0281c5328c53087e446f4;hp=f3b9120b3dfd75ef913a1d4b1f6a2b968e887ba1;hpb=73f02f72cb49baebff3e0f6946750a5bc0693321;p=paraslash.git diff --git a/dccp_send.c b/dccp_send.c index f3b9120b..0410c8bc 100644 --- a/dccp_send.c +++ b/dccp_send.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2006-2007 Andre Noll + * Copyright (C) 2006-2008 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -65,11 +65,11 @@ static void dccp_post_select(fd_set *rfds, __a_unused fd_set *wfds) struct dccp_client *dc; int ret; - if (!FD_ISSET(listen_fd, rfds)) + if (listen_fd < 0 || !FD_ISSET(listen_fd, rfds)) return; ret = para_accept(listen_fd, NULL, 0); if (ret < 0) { - PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret)); + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); return; } /* @@ -200,7 +200,7 @@ static void dccp_send(long unsigned current_chunk, // PARA_DEBUG_LOG("writing %d bytes to fd %d\n", len, dc->fd); ret = dccp_write(dc->fd, buf, len); if (ret < 0) { - PARA_NOTICE_LOG("%s\n", PARA_STRERROR(-ret)); + PARA_NOTICE_LOG("%s\n", para_strerror(-ret)); dccp_shutdown_client(dc); continue; } @@ -262,9 +262,6 @@ void dccp_send_init(struct sender *s) s->client_cmds[SENDER_DELETE] = NULL; self = s; ret = dccp_open(); - if (ret < 0) { - PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret)); - s->status = SENDER_OFF; - } else - s->status = SENDER_ON; + if (ret < 0) + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); }