X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_send.c;h=273961fcf908fdfbc6faa2b953210930a48fae5e;hp=546056a04282b9b87c27b9a4cfb811fd005f761d;hb=6693375b52f2712ace6dc50b717de9cb371a7c2a;hpb=8b2c02c8d6255583982e767374d39375b3380c4d diff --git a/dccp_send.c b/dccp_send.c index 546056a0..273961fc 100644 --- a/dccp_send.c +++ b/dccp_send.c @@ -31,8 +31,10 @@ #include "dccp.h" #include "error.h" #include "string.h" +#include "fd.h" +#include "close_on_fork.h" #include "server.cmdline.h" -extern struct gengetopt_args_info conf; + /** the list of connected clients **/ static struct list_head clients; static int listen_fd = -1; @@ -74,7 +76,9 @@ static void dccp_post_select(fd_set *rfds, __a_unused fd_set *wfds) } PARA_NOTICE_LOG("connection from %s\n", inet_ntoa(dc->addr.sin_addr)); dc->fd = ret; - list_add(&dc->node, &clients); + para_list_add(&dc->node, &clients); + add_close_on_fork_list(dc->fd); + mark_fd_nonblock(dc->fd); } static int dccp_open(void) @@ -101,6 +105,8 @@ static int dccp_open(void) if (ret < 0) return -E_DCCP_LISTEN; PARA_DEBUG_LOG("listening on fd %d\n", listen_fd); + add_close_on_fork_list(listen_fd); + mark_fd_nonblock(listen_fd); return 1; } @@ -109,19 +115,27 @@ static void dccp_shutdown_client(struct dccp_client *dc) PARA_DEBUG_LOG("shutting down %s (fd %d)\n", inet_ntoa(dc->addr.sin_addr), dc->fd); close(dc->fd); + del_close_on_fork_list(dc->fd); list_del(&dc->node); free(dc); } +#define DCCP_RETRIES 100 + static int dccp_write(int fd, const char *buf, size_t len) { - size_t send, written = 0; - int ret; + size_t size, written = 0; + int ret, retries = 0; again: - send = PARA_MIN(1024, len - written); - ret = write(fd, buf + written, send); - if (ret < 0) - goto err_out; + size = PARA_MIN(1024, len - written); + ret = write(fd, buf + written, size); + if (ret < 0) { + if (errno != EAGAIN || !retries++ > DCCP_RETRIES) + goto err_out; + PARA_DEBUG_LOG("EAGAIN #%d@%zd/%zd\n", retries, written, len); + goto again; + } + retries = 0; written += ret; if (written >= len) return written; @@ -152,25 +166,25 @@ static void dccp_send(long unsigned current_chunk, continue; if (!dc->header_sent && current_chunk) { header_buf = afs_get_header(&header_len); - if (!header_buf || header_len <= 0) - continue; /* header not yet available */ - ret = dccp_write(dc->fd, header_buf, header_len); - if (ret != header_len) { - int err = errno; - PARA_ERROR_LOG("header write: %d/%d (%s)\n", - ret, header_len, ret < 0? - strerror(err) : ""); - dccp_shutdown_client(dc); - continue; - } - dc->header_sent = 1; - ret = write_ok(dc->fd); - if (ret < 0) { - dccp_shutdown_client(dc); - continue; + if (header_buf && header_len > 0) { + ret = dccp_write(dc->fd, header_buf, header_len); + if (ret != header_len) { + int err = errno; + PARA_ERROR_LOG("header write: %d/%d (%s)\n", + ret, header_len, ret < 0? + strerror(err) : ""); + dccp_shutdown_client(dc); + continue; + } + dc->header_sent = 1; + ret = write_ok(dc->fd); + if (ret < 0) { + dccp_shutdown_client(dc); + continue; + } + if (!ret) + continue; } - if (!ret) - continue; } // PARA_DEBUG_LOG("writing %d bytes to fd %d\n", len, dc->fd); ret = dccp_write(dc->fd, buf, len);