X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_send.c;h=c9a03b94738848b94911cf7d7becea1227bd42b6;hp=02e60f44c680a0406826a3439543b1b389bbb456;hb=25f41ad9243f73f2027c69c8dac9be39cdb506bb;hpb=c568930c77d134f09c7a0aa59cb0622ae35fb7cb diff --git a/dccp_send.c b/dccp_send.c index 02e60f44..c9a03b94 100644 --- a/dccp_send.c +++ b/dccp_send.c @@ -82,13 +82,17 @@ static void dccp_post_select(fd_set *rfds, __a_unused fd_set *wfds) PARA_ERROR_LOG("shutdown(SHUT_RD): %s\n", strerror(errno)); goto err; } + ret = mark_fd_nonblocking(fd); + if (ret < 0) { + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); + goto err; + } dc = para_calloc(sizeof(struct dccp_client)); - dc->fd = ret; + dc->fd = fd; dc->name = make_message("%s", remote_name(dc->fd)); PARA_NOTICE_LOG("connection from %s\n", dc->name); para_list_add(&dc->node, &clients); add_close_on_fork_list(dc->fd); - mark_fd_nonblocking(dc->fd); dc->cq = cq_new(DCCP_MAX_PENDING_BYTES); return; err: