Add missing files for para_afh.

[paraslash.git] / dccp_recv.c

diff --git a/dccp_recv.c b/dccp_recv.c
index 64506737195de991134df0e692e897375c832e85..07f616657a7db4ca0dfe5b9d318f542c215a18c6 100644 (file)
--- 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 = -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));
        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);
        return 1;
 err:
        close(fd);