- PARA_NOTICE_LOG("connection from %s\n", inet_ntoa(dc->addr.sin_addr));
- dc->fd = ret;
- list_add(&dc->node, &clients);
-}
-
-static int dccp_open(void)
-{
- struct sockaddr_in servaddr;
- int ret;
-
- ret = dccp_get_socket();
- if (ret < 0)
- return ret;
- listen_fd = ret;
-
- bzero(&servaddr, 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);
- 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);
- list_del(&dc->node);
- free(dc);
-}
-
-static int dccp_write(int fd, const char *buf, size_t len)
-{
- size_t send, written = 0;
- int ret;
-again:
- send = PARA_MIN(1024, len - written);
- ret = write(fd, buf + written, send);
+ 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;
+ }
+ ret = mark_fd_nonblocking(fd);