X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_send.c;h=7ec6e686bd5659b79b54ec49247d587e05110851;hp=5d8e6593fe0bffd5b628fe92eeffac8d9638c90a;hb=c73d23911d78ed10179c12ef8f79a3fcf3bbcdaf;hpb=8d7f47e8cec74e4d209cfa1f6c4c0cec3b0e5019 diff --git a/dccp_send.c b/dccp_send.c index 5d8e6593..7ec6e686 100644 --- a/dccp_send.c +++ b/dccp_send.c @@ -69,7 +69,16 @@ static void dccp_post_select(fd_set *rfds, __a_unused fd_set *wfds) return; ret = para_accept(listen_fd, NULL, 0); if (ret < 0) { - PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret)); + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); + return; + } + /* + * Bypass unused CCID paths: the sender does not receive application data + * from the client; by shutting down this unused communication path we can + * reduce processing costs a bit. See analogous comment in dccp_recv.c. + */ + if (shutdown(ret, SHUT_RD) < 0) { + PARA_ERROR_LOG("shutdown(SHUT_RD): %s\n", strerror(errno)); return; } dc = para_calloc(sizeof(struct dccp_client)); @@ -191,7 +200,7 @@ static void dccp_send(long unsigned current_chunk, // PARA_DEBUG_LOG("writing %d bytes to fd %d\n", len, dc->fd); ret = dccp_write(dc->fd, buf, len); if (ret < 0) { - PARA_NOTICE_LOG("%s\n", PARA_STRERROR(-ret)); + PARA_NOTICE_LOG("%s\n", para_strerror(-ret)); dccp_shutdown_client(dc); continue; } @@ -254,7 +263,7 @@ void dccp_send_init(struct sender *s) self = s; ret = dccp_open(); if (ret < 0) { - PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret)); + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); s->status = SENDER_OFF; } else s->status = SENDER_ON;