X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_send.c;h=27623237a731e0089d0563cd41f1ccb8525c2b74;hp=f61427169e83d5366c1d1509666405573944e504;hb=d2e164526bed7f523043b7e4ec5bd282d5bc6f19;hpb=5f25c580aed568f05dd8ec285c2990ad1906b83d diff --git a/dccp_send.c b/dccp_send.c index f6142716..27623237 100644 --- a/dccp_send.c +++ b/dccp_send.c @@ -11,14 +11,20 @@ * (C) 2005 Ian McDonald */ +#include +#include + +#include "para.h" +#include "error.h" +#include "string.h" +#include "afh.h" +#include "afs.h" #include "server.h" #include "net.h" #include "list.h" #include "vss.h" #include "send.h" #include "dccp.h" -#include "error.h" -#include "string.h" #include "fd.h" #include "close_on_fork.h" #include "chunk_queue.h" @@ -72,7 +78,7 @@ static void dccp_post_select(fd_set *rfds, __a_unused fd_set *wfds) dc->fd = ret; para_list_add(&dc->node, &clients); add_close_on_fork_list(dc->fd); - mark_fd_nonblock(dc->fd); + mark_fd_nonblocking(dc->fd); dc->cq = cq_new(DCCP_MAX_PENDING_BYTES); } @@ -103,7 +109,7 @@ static int dccp_open(void) } PARA_DEBUG_LOG("listening on fd %d\n", listen_fd); add_close_on_fork_list(listen_fd); - mark_fd_nonblock(listen_fd); + mark_fd_nonblocking(listen_fd); return 1; } @@ -182,7 +188,7 @@ static void dccp_send(long unsigned current_chunk, struct dccp_client *dc, *tmp; int ret; char *header_buf; - unsigned header_len; + size_t header_len; if (listen_fd < 0 || !len) return;