X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;ds=sidebyside;f=http_send.c;h=69e75ccb80eddd0badfdf49aadaadcf6e75e8417;hb=8d7bdabd22ed7750086ca660754d8d881dae3832;hp=6b67a6aae09e0dca5b61fda5277d13b7a4603299;hpb=37c39c45fe642f3be30658a95a35583affa2c9fa;p=paraslash.git diff --git a/http_send.c b/http_send.c index 6b67a6aa..69e75ccb 100644 --- a/http_send.c +++ b/http_send.c @@ -258,6 +258,9 @@ static void http_post_select(fd_set *rfds, fd_set *wfds) err_msg = "permission denied"; goto err_out; } + err_msg = "failed to mark fd non-blocking"; + if (mark_fd_nonblocking(hc->fd) < 0) + goto err_out; hc->status = HTTP_CONNECTED; hc->cq = cq_new(MAX_BACKLOG); numclients++; @@ -265,7 +268,6 @@ static void http_post_select(fd_set *rfds, fd_set *wfds) hc->name, hc->fd); para_list_add(&hc->node, &clients); add_close_on_fork_list(hc->fd); - mark_fd_nonblocking(hc->fd); return; err_out: PARA_WARNING_LOG("ignoring connect request from %s (%s)\n", @@ -314,10 +316,8 @@ static int http_open(void) int ret; listen_fd = para_listen(AF_UNSPEC, IPPROTO_TCP, conf.http_port_arg); - if (listen_fd < 0) { - http_shutdown_clients(); + if (listen_fd < 0) return listen_fd; - } ret = mark_fd_nonblocking(listen_fd); if (ret < 0) { PARA_EMERG_LOG("%s\n", para_strerror(-ret));