X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_recv.c;h=07f616657a7db4ca0dfe5b9d318f542c215a18c6;hp=64506737195de991134df0e692e897375c832e85;hb=80e46ec589d14be2fa4b0704f613a04ecb1b64c4;hpb=f03f1a8115c0b4dcb0a705d8a686ccf511648f60;ds=sidebyside

diff --git a/dccp_recv.c b/dccp_recv.c
index 64506737..07f61665 100644
--- a/dccp_recv.c
+++ b/dccp_recv.c
@@ -73,12 +73,12 @@ static int dccp_recv_open(struct receiver_node *rn)
 		ret = -ERRNO_TO_PARA_ERROR(errno);
 		goto err;
 	}
-
+	ret = mark_fd_nonblocking(fd);
+	if (ret < 0)
+		goto err;
 	rn->buf = para_calloc(DCCP_BUFSIZE);
 	rn->private_data = pdd = para_calloc(sizeof(struct private_dccp_recv_data));
-
-	pdd->fd = ret;
-	mark_fd_nonblocking(pdd->fd);
+	pdd->fd = fd;
 	return 1;
 err:
 	close(fd);