2 * uhttpd - Tiny single-threaded httpd
4 * Copyright (C) 2010-2012 Jo-Philipp Wich <xm@subsignal.org>
5 * Copyright (C) 2012 Felix Fietkau <nbd@openwrt.org>
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
20 #include <sys/types.h>
21 #include <sys/socket.h>
22 #include <netinet/tcp.h>
28 struct list_head list;
32 struct sockaddr_in6 addr;
37 static LIST_HEAD(listeners);
40 static void uh_block_listener(struct listener *l)
42 uloop_fd_delete(&l->fd);
47 void uh_unblock_listeners(void)
51 if (!n_blocked && conf.max_requests &&
52 n_clients >= conf.max_requests)
55 list_for_each_entry(l, &listeners, list) {
61 uloop_fd_add(&l->fd, ULOOP_READ);
65 static void listener_cb(struct uloop_fd *fd, unsigned int events)
67 struct listener *l = container_of(fd, struct listener, fd);
69 uh_accept_client(fd->fd);
71 if (conf.max_requests && n_clients >= conf.max_requests)
75 void uh_setup_listeners(void)
79 list_for_each_entry(l, &listeners, list) {
80 l->fd.cb = listener_cb;
81 uloop_fd_add(&l->fd, ULOOP_READ);
85 int uh_socket_bind(const char *host, const char *port, bool tls)
91 struct listener *l = NULL;
92 struct addrinfo *addrs = NULL, *p = NULL;
93 static struct addrinfo hints = {
94 .ai_family = AF_UNSPEC,
95 .ai_socktype = SOCK_STREAM,
96 .ai_flags = AI_PASSIVE,
99 if ((status = getaddrinfo(host, port, &hints, &addrs)) != 0) {
100 fprintf(stderr, "getaddrinfo(): %s\n", gai_strerror(status));
104 /* try to bind a new socket to each found address */
105 for (p = addrs; p; p = p->ai_next) {
107 sock = socket(p->ai_family, p->ai_socktype, p->ai_protocol);
113 /* "address already in use" */
114 if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes))) {
115 perror("setsockopt()");
120 if (conf.tcp_keepalive > 0) {
123 int tcp_ka_idl, tcp_ka_int, tcp_ka_cnt;
127 tcp_ka_int = conf.tcp_keepalive;
128 ret = setsockopt(sock, SOL_TCP, TCP_KEEPIDLE, &tcp_ka_idl, sizeof(tcp_ka_idl)) ||
129 setsockopt(sock, SOL_TCP, TCP_KEEPINTVL, &tcp_ka_int, sizeof(tcp_ka_int)) ||
130 setsockopt(sock, SOL_TCP, TCP_KEEPCNT, &tcp_ka_cnt, sizeof(tcp_ka_cnt));
133 if (ret || setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, &yes, sizeof(yes)))
134 fprintf(stderr, "Notice: Unable to enable TCP keep-alive: %s\n",
138 /* required to get parallel v4 + v6 working */
139 if (p->ai_family == AF_INET6 &&
140 setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY, &yes, sizeof(yes)) < 0) {
141 perror("setsockopt()");
146 if (bind(sock, p->ai_addr, p->ai_addrlen) < 0) {
152 if (listen(sock, UH_LIMIT_CLIENTS) < 0) {
159 l = calloc(1, sizeof(*l));
165 list_add_tail(&l->list, &listeners);