- PARA_NOTICE_LOG("connection from %s\n", inet_ntoa(dc->addr.sin_addr));
- dc->fd = ret;
- para_list_add(&dc->node, &clients);
- add_close_on_fork_list(dc->fd);
- mark_fd_nonblock(dc->fd);
-}
-
-static int dccp_open(void)
-{
- struct sockaddr_in servaddr;
- int ret;
-
- ret = dccp_get_socket();
- if (ret < 0)
- return ret;
- listen_fd = ret;
-
- memset(&servaddr, 0, sizeof(servaddr));
- servaddr.sin_family = AF_INET;
- servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
- servaddr.sin_port = htons(conf.dccp_port_arg);
- ret = bind(listen_fd, (struct sockaddr *)&servaddr, sizeof(servaddr));
- if (ret < 0)
- return -E_DCCP_BIND;
- ret = dccp_set_socket(listen_fd);
- if (ret < 0)
- return ret;
- ret = listen(listen_fd, 0);
- 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;
-}
-
-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);
-}
-
-static int dccp_write(int fd, const char *buf, size_t len)
-{
- size_t written = 0;
- int ret = 0;
-
- while (written < len) {
- ret = write(fd, buf + written, PARA_MIN(1024, len - written));
- /*
- * Error handling: CCID3 has a sending wait queue which fills up and is
- * emptied asynchronously. The EAGAIN case means that there is currently
- * no space in the wait queue, but this can change at any moment and is
- * thus not an error condition. Keep polling until an entry becomes free.
- */
- if (ret < 0 && errno == EAGAIN)
- continue;
- if (ret < 0)
- return -E_DCCP_WRITE;
- written += ret;
+ fd = ret;
+ /*
+ * 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(fd, SHUT_RD) < 0) {
+ ret = -ERRNO_TO_PARA_ERROR(errno);
+ goto err;