/*
* uhttpd - Tiny single-threaded httpd - Utility functions
*
- * Copyright (C) 2010 Jo-Philipp Wich <xm@subsignal.org>
+ * Copyright (C) 2010-2012 Jo-Philipp Wich <xm@subsignal.org>
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
struct sockaddr_in *v4 = (struct sockaddr_in *)sa;
struct sockaddr_in6 *v6 = (struct sockaddr_in6 *)sa;
- if( v4->sin_family == AF_INET )
+ if (v4->sin_family == AF_INET)
return inet_ntop(AF_INET, &(v4->sin_addr), str, sizeof(str));
else
return inet_ntop(AF_INET6, &(v6->sin6_addr), str, sizeof(str));
struct sockaddr_in *v4 = (struct sockaddr_in *)sa;
unsigned long a = htonl(v4->sin_addr.s_addr);
- if( v4->sin_family == AF_INET )
+ if (v4->sin_family == AF_INET)
{
return ((a >= 0x0A000000) && (a <= 0x0AFFFFFF)) ||
((a >= 0xAC100000) && (a <= 0xAC1FFFFF)) ||
int match = 0;
int i, j;
- for( i = 0; i < hslen; i++ )
+ for (i = 0; i < hslen; i++)
{
- if( haystack[i] == needle[0] )
+ if (haystack[i] == needle[0])
{
match = ((ndlen == 1) || ((i + ndlen) <= hslen));
- for( j = 1; (j < ndlen) && ((i + j) < hslen); j++ )
+ for (j = 1; (j < ndlen) && ((i + j) < hslen); j++)
{
- if( haystack[i+j] != needle[j] )
+ if (haystack[i+j] != needle[j])
{
match = 0;
break;
}
}
- if( match )
+ if (match)
return &haystack[i];
}
}
return NULL;
}
-/* interruptable select() */
-int select_intr(int n, fd_set *r, fd_set *w, fd_set *e, struct timeval *t)
+bool uh_socket_wait(int fd, int sec, bool write)
{
int rv;
- sigset_t ssn, sso;
+ struct timeval timeout;
- /* unblock SIGCHLD */
- sigemptyset(&ssn);
- sigaddset(&ssn, SIGCHLD);
- sigaddset(&ssn, SIGPIPE);
- sigprocmask(SIG_UNBLOCK, &ssn, &sso);
+ fd_set fds;
- rv = select(n, r, w, e, t);
+ FD_ZERO(&fds);
+ FD_SET(fd, &fds);
- /* restore signal mask */
- sigprocmask(SIG_SETMASK, &sso, NULL);
+ timeout.tv_sec = sec;
+ timeout.tv_usec = 0;
- return rv;
-}
+ while (((rv = select(fd+1, write ? NULL : &fds, write ? &fds : NULL,
+ NULL, &timeout)) < 0) && (errno == EINTR))
+ {
+ D("IO: Socket(%d) select interrupted: %s\n",
+ fd, strerror(errno));
+ continue;
+ }
-int uh_tcp_send_lowlevel(struct client *cl, const char *buf, int len)
-{
- fd_set writer;
- struct timeval timeout;
+ if (rv <= 0)
+ {
+ D("IO: Socket(%d) appears dead (rv=%d)\n", fd, rv);
+ return false;
+ }
- FD_ZERO(&writer);
- FD_SET(cl->socket, &writer);
+ return true;
+}
- timeout.tv_sec = cl->server->conf->network_timeout;
- timeout.tv_usec = 0;
+static int __uh_raw_send(struct client *cl, const char *buf, int len, int sec,
+ int (*wfn) (struct client *, const char *, int))
+{
+ ssize_t rv;
+ int fd = cl->fd.fd;
- if (select(cl->socket + 1, NULL, &writer, NULL, &timeout) > 0)
- return send(cl->socket, buf, len, 0);
+ while (true)
+ {
+ if ((rv = wfn(cl, buf, len)) < 0)
+ {
+ if (errno == EINTR)
+ {
+ D("IO: Socket(%d) interrupted\n", cl->fd.fd);
+ continue;
+ }
+ else if ((sec > 0) && (errno == EAGAIN || errno == EWOULDBLOCK))
+ {
+ if (!uh_socket_wait(fd, sec, true))
+ return -1;
+ }
+ else
+ {
+ D("IO: Socket(%d) write error: %s\n", fd, strerror(errno));
+ return -1;
+ }
+ }
+ /*
+ * It is not entirely clear whether rv = 0 on nonblocking sockets
+ * is an error. In real world fuzzing tests, not handling it as close
+ * led to tight infinite loops in this send procedure, so treat it as
+ * closed and break out.
+ */
+ else if (rv == 0)
+ {
+ D("IO: Socket(%d) closed\n", fd);
+ return 0;
+ }
+ else if (rv < len)
+ {
+ D("IO: Socket(%d) short write %d/%d bytes\n", fd, rv, len);
+ len -= rv;
+ buf += rv;
+ continue;
+ }
+ else
+ {
+ D("IO: Socket(%d) sent %d/%d bytes\n", fd, rv, len);
+ return rv;
+ }
+ }
+}
+
+int uh_tcp_send_lowlevel(struct client *cl, const char *buf, int len)
+{
+ return write(cl->fd.fd, buf, len);
+}
- return -1;
+int uh_raw_send(int fd, const char *buf, int len, int sec)
+{
+ struct client_light cl = { .fd = { .fd = fd } };
+ return __uh_raw_send((struct client *)&cl, buf, len, sec,
+ uh_tcp_send_lowlevel);
}
int uh_tcp_send(struct client *cl, const char *buf, int len)
{
+ int seconds = cl->server->conf->network_timeout;
#ifdef HAVE_TLS
if (cl->tls)
- return cl->server->conf->tls_send(cl, (void *)buf, len);
- else
+ return __uh_raw_send(cl, buf, len, seconds,
+ cl->server->conf->tls_send);
#endif
- return uh_tcp_send_lowlevel(cl, buf, len);
+ return __uh_raw_send(cl, buf, len, seconds, uh_tcp_send_lowlevel);
}
-int uh_tcp_peek(struct client *cl, char *buf, int len)
+static int __uh_raw_recv(struct client *cl, char *buf, int len, int sec,
+ int (*rfn) (struct client *, char *, int))
{
- /* sanity check, prevent overflowing peek buffer */
- if (len > sizeof(cl->peekbuf))
- return -1;
-
- int sz = uh_tcp_recv(cl, buf, len);
+ ssize_t rv;
+ int fd = cl->fd.fd;
- /* store received data in peek buffer */
- if( sz > 0 )
+ while (true)
{
- cl->peeklen = sz;
- memcpy(cl->peekbuf, buf, sz);
+ if ((rv = rfn(cl, buf, len)) < 0)
+ {
+ if (errno == EINTR)
+ {
+ continue;
+ }
+ else if ((sec > 0) && (errno == EAGAIN || errno == EWOULDBLOCK))
+ {
+ if (!uh_socket_wait(fd, sec, false))
+ return -1;
+ }
+ else
+ {
+ D("IO: Socket(%d) read error: %s\n", fd, strerror(errno));
+ return -1;
+ }
+ }
+ else if (rv == 0)
+ {
+ D("IO: Socket(%d) closed\n", fd);
+ return 0;
+ }
+ else
+ {
+ D("IO: Socket(%d) read %d bytes\n", fd, rv);
+ return rv;
+ }
}
-
- return sz;
}
int uh_tcp_recv_lowlevel(struct client *cl, char *buf, int len)
{
- fd_set reader;
- struct timeval timeout;
-
- FD_ZERO(&reader);
- FD_SET(cl->socket, &reader);
-
- timeout.tv_sec = cl->server->conf->network_timeout;
- timeout.tv_usec = 0;
-
- if (select(cl->socket + 1, &reader, NULL, NULL, &timeout) > 0)
- return recv(cl->socket, buf, len, 0);
+ return read(cl->fd.fd, buf, len);
+}
- return -1;
+int uh_raw_recv(int fd, char *buf, int len, int sec)
+{
+ struct client_light cl = { .fd = { .fd = fd } };
+ return __uh_raw_recv((struct client *)&cl, buf, len, sec,
+ uh_tcp_recv_lowlevel);
}
int uh_tcp_recv(struct client *cl, char *buf, int len)
{
- int sz = 0;
- int rsz = 0;
-
- /* first serve data from peek buffer */
- if (cl->peeklen > 0)
- {
- sz = min(cl->peeklen, len);
- len -= sz; cl->peeklen -= sz;
- memcpy(buf, cl->peekbuf, sz);
- memmove(cl->peekbuf, &cl->peekbuf[sz], cl->peeklen);
- }
-
- /* caller wants more */
- if (len > 0)
- {
+ int seconds = cl->server->conf->network_timeout;
#ifdef HAVE_TLS
- if (cl->tls)
- rsz = cl->server->conf->tls_recv(cl, (void *)&buf[sz], len);
- else
+ if (cl->tls)
+ return __uh_raw_recv(cl, buf, len, seconds,
+ cl->server->conf->tls_recv);
#endif
- rsz = uh_tcp_recv_lowlevel(cl, (void *)&buf[sz], len);
-
- if (rsz < 0)
- return rsz;
-
- sz += rsz;
- }
-
- return sz;
+ return __uh_raw_recv(cl, buf, len, seconds, uh_tcp_recv_lowlevel);
}
-int uh_http_sendhf(struct client *cl, int code, const char *summary, const char *fmt, ...)
+int uh_http_sendhf(struct client *cl, int code, const char *summary,
+ const char *fmt, ...)
{
va_list ap;
char chunk[8];
int clen;
- if( len == -1 )
+ if (len == -1)
len = strlen(data);
- if( len > 0 )
+ if (len > 0)
{
clen = snprintf(chunk, sizeof(chunk), "%X\r\n", len);
ensure_ret(uh_tcp_send(cl, chunk, clen));
return 0;
}
-int uh_http_sendf(
- struct client *cl, struct http_request *req, const char *fmt, ...
-) {
+int uh_http_sendf(struct client *cl, struct http_request *req,
+ const char *fmt, ...)
+{
va_list ap;
char buffer[UH_LIMIT_MSGHEAD];
int len;
len = vsnprintf(buffer, sizeof(buffer), fmt, ap);
va_end(ap);
- if( (req != NULL) && (req->version > 1.0) )
+ if ((req != NULL) && (req->version > 1.0))
ensure_ret(uh_http_sendc(cl, buffer, len));
- else if( len > 0 )
+ else if (len > 0)
ensure_ret(uh_tcp_send(cl, buffer, len));
return 0;
}
-int uh_http_send(
- struct client *cl, struct http_request *req, const char *buf, int len
-) {
- if( len < 0 )
+int uh_http_send(struct client *cl, struct http_request *req,
+ const char *buf, int len)
+{
+ if (len < 0)
len = strlen(buf);
- if( (req != NULL) && (req->version > 1.0) )
+ if ((req != NULL) && (req->version > 1.0))
ensure_ret(uh_http_sendc(cl, buf, len));
- else if( len > 0 )
+ else if (len > 0)
ensure_ret(uh_tcp_send(cl, buf, len));
return 0;
}
+/* blen is the size of buf; slen is the length of src. The input-string need
+** not be, and the output string will not be, null-terminated. Returns the
+** length of the decoded string, -1 on buffer overflow, -2 on malformed string. */
int uh_urldecode(char *buf, int blen, const char *src, int slen)
{
int i;
(((x) <= 'F') ? ((x) - 'A' + 10) : \
((x) - 'a' + 10)))
- for( i = 0; (i <= slen) && (i <= blen); i++ )
+ for (i = 0; (i < slen) && (len < blen); i++)
{
- if( src[i] == '%' )
+ if (src[i] == '%')
{
- if( ((i+2) <= slen) && isxdigit(src[i+1]) && isxdigit(src[i+2]) )
+ if (((i+2) < slen) && isxdigit(src[i+1]) && isxdigit(src[i+2]))
{
buf[len++] = (char)(16 * hex(src[i+1]) + hex(src[i+2]));
i += 2;
}
else
{
- buf[len++] = '%';
+ /* Encoding error: it's hard to think of a
+ ** scenario in which returning an incorrect
+ ** 'decoding' of the malformed string is
+ ** preferable to signaling an error condition. */
+ #if 0 /* WORSE_IS_BETTER */
+ buf[len++] = '%';
+ #else
+ return -2;
+ #endif
}
}
else
}
}
- return len;
+ return (i == slen) ? len : -1;
}
+/* blen is the size of buf; slen is the length of src. The input-string need
+** not be, and the output string will not be, null-terminated. Returns the
+** length of the encoded string, or -1 on error (buffer overflow) */
int uh_urlencode(char *buf, int blen, const char *src, int slen)
{
int i;
int len = 0;
const char hex[] = "0123456789abcdef";
- for( i = 0; (i <= slen) && (i <= blen); i++ )
+ for (i = 0; (i < slen) && (len < blen); i++)
{
if( isalnum(src[i]) || (src[i] == '-') || (src[i] == '_') ||
(src[i] == '.') || (src[i] == '~') )
{
buf[len++] = src[i];
}
- else if( (len+3) <= blen )
+ else if ((len+3) <= blen)
{
buf[len++] = '%';
buf[len++] = hex[(src[i] >> 4) & 15];
- buf[len++] = hex[(src[i] & 15) & 15];
+ buf[len++] = hex[ src[i] & 15];
}
else
{
+ len = -1;
break;
}
}
- return len;
+ return (i == slen) ? len : -1;
}
int uh_b64decode(char *buf, int blen, const unsigned char *src, int slen)
unsigned int cout = 0;
- for( i = 0; (i <= slen) && (src[i] != 0); i++ )
+ for (i = 0; (i <= slen) && (src[i] != 0); i++)
{
cin = src[i];
- if( (cin >= '0') && (cin <= '9') )
+ if ((cin >= '0') && (cin <= '9'))
cin = cin - '0' + 52;
- else if( (cin >= 'A') && (cin <= 'Z') )
+ else if ((cin >= 'A') && (cin <= 'Z'))
cin = cin - 'A';
- else if( (cin >= 'a') && (cin <= 'z') )
+ else if ((cin >= 'a') && (cin <= 'z'))
cin = cin - 'a' + 26;
- else if( cin == '+' )
+ else if (cin == '+')
cin = 62;
- else if( cin == '/' )
+ else if (cin == '/')
cin = 63;
- else if( cin == '=' )
+ else if (cin == '=')
cin = 0;
else
continue;
cout = (cout << 6) | cin;
- if( (i % 4) == 3 )
+ if ((i % 4) == 3)
{
- if( (len + 3) < blen )
+ if ((len + 3) < blen)
{
buf[len++] = (char)(cout >> 16);
buf[len++] = (char)(cout >> 8);
/* relative -> absolute */
- if( *path != '/' )
+ if (*path != '/')
{
getcwd(path_copy, PATH_MAX);
strncat(path_copy, "/", PATH_MAX - strlen(path_copy));
}
/* normalize */
- while( (*path_cpy != '\0') && (path_cpy < (path_copy + PATH_MAX - 2)) )
+ while ((*path_cpy != '\0') && (path_cpy < (path_copy + PATH_MAX - 2)))
{
- if( *path_cpy == '/' )
+ if (*path_cpy == '/')
{
/* skip repeating / */
- if( path_cpy[1] == '/' )
+ if (path_cpy[1] == '/')
{
path_cpy++;
continue;
}
/* /./ or /../ */
- else if( path_cpy[1] == '.' )
+ else if (path_cpy[1] == '.')
{
/* skip /./ */
- if( (path_cpy[2] == '/') || (path_cpy[2] == '\0') )
+ if ((path_cpy[2] == '/') || (path_cpy[2] == '\0'))
{
path_cpy += 2;
continue;
}
/* collapse /x/../ */
- else if( (path_cpy[2] == '.') &&
- ((path_cpy[3] == '/') || (path_cpy[3] == '\0'))
- ) {
- while( (path_res > path_resolved) && (*--path_res != '/') )
+ else if ((path_cpy[2] == '.') &&
+ ((path_cpy[3] == '/') || (path_cpy[3] == '\0')))
+ {
+ while ((path_res > path_resolved) && (*--path_res != '/'))
;
path_cpy += 3;
}
/* remove trailing slash if not root / */
- if( (path_res > (path_resolved+1)) && (path_res[-1] == '/') )
+ if ((path_res > (path_resolved+1)) && (path_res[-1] == '/'))
path_res--;
- else if( path_res == path_resolved )
+ else if (path_res == path_resolved)
*path_res++ = '/';
*path_res = '\0';
/* test access */
- if( !stat(path_resolved, &s) && (s.st_mode & S_IROTH) )
+ if (!stat(path_resolved, &s) && (s.st_mode & S_IROTH))
return path_resolved;
return NULL;
}
+/* Returns NULL on error.
+** NB: improperly encoded URL should give client 400 [Bad Syntax]; returning
+** NULL here causes 404 [Not Found], but that's not too unreasonable. */
struct path_info * uh_path_lookup(struct client *cl, const char *url)
{
static char path_phys[PATH_MAX];
struct stat s;
/* back out early if url is undefined */
- if ( url == NULL )
+ if (url == NULL)
return NULL;
memset(path_phys, 0, sizeof(path_phys));
/* copy docroot */
memcpy(buffer, docroot,
- min(strlen(docroot), sizeof(buffer) - 1));
+ min(strlen(docroot), sizeof(buffer) - 1));
/* separate query string from url */
- if( (pathptr = strchr(url, '?')) != NULL )
+ if ((pathptr = strchr(url, '?')) != NULL)
{
p.query = pathptr[1] ? pathptr + 1 : NULL;
/* urldecode component w/o query */
- if( pathptr > url )
- uh_urldecode(
- &buffer[strlen(docroot)],
- sizeof(buffer) - strlen(docroot) - 1,
- url, (int)(pathptr - url) - 1
- );
+ if (pathptr > url)
+ {
+ if (uh_urldecode(&buffer[strlen(docroot)],
+ sizeof(buffer) - strlen(docroot) - 1,
+ url, pathptr - url ) < 0)
+ {
+ return NULL; /* bad URL */
+ }
+ }
}
/* no query string, decode all of url */
else
{
- uh_urldecode(
- &buffer[strlen(docroot)],
- sizeof(buffer) - strlen(docroot) - 1,
- url, strlen(url)
- );
+ if (uh_urldecode(&buffer[strlen(docroot)],
+ sizeof(buffer) - strlen(docroot) - 1,
+ url, strlen(url) ) < 0)
+ {
+ return NULL; /* bad URL */
+ }
}
/* create canon path */
- for( i = strlen(buffer), slash = (buffer[max(0, i-1)] == '/'); i >= 0; i-- )
+ for (i = strlen(buffer), slash = (buffer[max(0, i-1)] == '/'); i >= 0; i--)
{
- if( (buffer[i] == 0) || (buffer[i] == '/') )
+ if ((buffer[i] == 0) || (buffer[i] == '/'))
{
memset(path_info, 0, sizeof(path_info));
memcpy(path_info, buffer, min(i + 1, sizeof(path_info) - 1));
- if( no_sym ? realpath(path_info, path_phys)
- : canonpath(path_info, path_phys)
- ) {
+ if (no_sym ? realpath(path_info, path_phys)
+ : canonpath(path_info, path_phys))
+ {
memset(path_info, 0, sizeof(path_info));
memcpy(path_info, &buffer[i],
- min(strlen(buffer) - i, sizeof(path_info) - 1));
+ min(strlen(buffer) - i, sizeof(path_info) - 1));
break;
}
}
/* check whether found path is within docroot */
- if( strncmp(path_phys, docroot, strlen(docroot)) ||
- ((path_phys[strlen(docroot)] != 0) &&
- (path_phys[strlen(docroot)] != '/'))
- ) {
+ if (strncmp(path_phys, docroot, strlen(docroot)) ||
+ ((path_phys[strlen(docroot)] != 0) &&
+ (path_phys[strlen(docroot)] != '/')))
+ {
return NULL;
}
/* test current path */
- if( ! stat(path_phys, &p.stat) )
+ if (!stat(path_phys, &p.stat))
{
/* is a regular file */
- if( p.stat.st_mode & S_IFREG )
+ if (p.stat.st_mode & S_IFREG)
{
p.root = docroot;
p.phys = path_phys;
}
/* is a directory */
- else if( (p.stat.st_mode & S_IFDIR) && !strlen(path_info) )
+ else if ((p.stat.st_mode & S_IFDIR) && !strlen(path_info))
{
/* ensure trailing slash */
- if( path_phys[strlen(path_phys)-1] != '/' )
+ if (path_phys[strlen(path_phys)-1] != '/')
path_phys[strlen(path_phys)] = '/';
/* try to locate index file */
/* if requested url resolves to a directory and a trailing slash
is missing in the request url, redirect the client to the same
url with trailing slash appended */
- if( !slash )
+ if (!slash)
{
uh_http_sendf(cl, NULL,
"HTTP/1.1 302 Found\r\n"
p.redirected = 1;
}
- else if( cl->server->conf->index_file )
+ else if (cl->server->conf->index_file)
{
strncat(buffer, cl->server->conf->index_file, sizeof(buffer));
- if( !stat(buffer, &s) && (s.st_mode & S_IFREG) )
+ if (!stat(buffer, &s) && (s.st_mode & S_IFREG))
{
memcpy(path_phys, buffer, sizeof(path_phys));
memcpy(&p.stat, &s, sizeof(p.stat));
}
else
{
- for( i = 0; i < array_size(uh_index_files); i++ )
+ for (i = 0; i < array_size(uh_index_files); i++)
{
strncat(buffer, uh_index_files[i], sizeof(buffer));
- if( !stat(buffer, &s) && (s.st_mode & S_IFREG) )
+ if (!stat(buffer, &s) && (s.st_mode & S_IFREG))
{
memcpy(path_phys, buffer, sizeof(path_phys));
memcpy(&p.stat, &s, sizeof(p.stat));
memset(new, 0, sizeof(struct auth_realm));
memcpy(new->path, path,
- min(strlen(path), sizeof(new->path) - 1));
+ min(strlen(path), sizeof(new->path) - 1));
memcpy(new->user, user,
- min(strlen(user), sizeof(new->user) - 1));
+ min(strlen(user), sizeof(new->user) - 1));
/* given password refers to a passwd entry */
- if( (strlen(pass) > 3) && !strncmp(pass, "$p$", 3) )
+ if ((strlen(pass) > 3) && !strncmp(pass, "$p$", 3))
{
#ifdef HAVE_SHADOW
/* try to resolve shadow entry */
- if( ((spwd = getspnam(&pass[3])) != NULL) && spwd->sp_pwdp )
+ if (((spwd = getspnam(&pass[3])) != NULL) && spwd->sp_pwdp)
{
memcpy(new->pass, spwd->sp_pwdp,
- min(strlen(spwd->sp_pwdp), sizeof(new->pass) - 1));
+ min(strlen(spwd->sp_pwdp), sizeof(new->pass) - 1));
}
else
#endif
/* try to resolve passwd entry */
- if( ((pwd = getpwnam(&pass[3])) != NULL) && pwd->pw_passwd &&
- (pwd->pw_passwd[0] != '!') && (pwd->pw_passwd[0] != 0)
- ) {
+ if (((pwd = getpwnam(&pass[3])) != NULL) && pwd->pw_passwd &&
+ (pwd->pw_passwd[0] != '!') && (pwd->pw_passwd[0] != 0))
+ {
memcpy(new->pass, pwd->pw_passwd,
- min(strlen(pwd->pw_passwd), sizeof(new->pass) - 1));
+ min(strlen(pwd->pw_passwd), sizeof(new->pass) - 1));
}
}
min(strlen(pass), sizeof(new->pass) - 1));
}
- if( new->pass[0] )
+ if (new->pass[0])
{
new->next = uh_realms;
uh_realms = new;
return NULL;
}
-int uh_auth_check(
- struct client *cl, struct http_request *req, struct path_info *pi
-) {
+int uh_auth_check(struct client *cl, struct http_request *req,
+ struct path_info *pi)
+{
int i, plen, rlen, protected;
char buffer[UH_LIMIT_MSGHEAD];
char *user = NULL;
protected = 0;
/* check whether at least one realm covers the requested url */
- for( realm = uh_realms; realm; realm = realm->next )
+ for (realm = uh_realms; realm; realm = realm->next)
{
rlen = strlen(realm->path);
- if( (plen >= rlen) && !strncasecmp(pi->name, realm->path, rlen) )
+ if ((plen >= rlen) && !strncasecmp(pi->name, realm->path, rlen))
{
req->realm = realm;
protected = 1;
}
/* requested resource is covered by a realm */
- if( protected )
+ if (protected)
{
/* try to get client auth info */
foreach_header(i, req->headers)
{
- if( !strcasecmp(req->headers[i], "Authorization") &&
+ if (!strcasecmp(req->headers[i], "Authorization") &&
(strlen(req->headers[i+1]) > 6) &&
- !strncasecmp(req->headers[i+1], "Basic ", 6)
- ) {
+ !strncasecmp(req->headers[i+1], "Basic ", 6))
+ {
memset(buffer, 0, sizeof(buffer));
uh_b64decode(buffer, sizeof(buffer) - 1,
(unsigned char *) &req->headers[i+1][6],
strlen(req->headers[i+1]) - 6);
- if( (pass = strchr(buffer, ':')) != NULL )
+ if ((pass = strchr(buffer, ':')) != NULL)
{
user = buffer;
*pass++ = 0;
}
/* have client auth */
- if( user && pass )
+ if (user && pass)
{
/* find matching realm */
- for( realm = uh_realms; realm; realm = realm->next )
+ for (realm = uh_realms; realm; realm = realm->next)
{
rlen = strlen(realm->path);
- if( (plen >= rlen) &&
- !strncasecmp(pi->name, realm->path, rlen) &&
- !strcmp(user, realm->user)
- ) {
+ if ((plen >= rlen) &&
+ !strncasecmp(pi->name, realm->path, rlen) &&
+ !strcmp(user, realm->user))
+ {
req->realm = realm;
break;
}
}
/* found a realm matching the username */
- if( realm )
+ if (realm)
{
- /* is a crypt passwd */
- if( realm->pass[0] == '$' )
- pass = crypt(pass, realm->pass);
-
/* check user pass */
- if( !strcmp(pass, realm->pass) )
+ if (!strcmp(pass, realm->pass) ||
+ !strcmp(crypt(pass, realm->pass), realm->pass))
return 1;
}
}
struct listener *new = NULL;
socklen_t sl;
- if( (new = (struct listener *)malloc(sizeof(struct listener))) != NULL )
+ if ((new = (struct listener *)malloc(sizeof(struct listener))) != NULL)
{
memset(new, 0, sizeof(struct listener));
- new->socket = sock;
- new->conf = conf;
+ new->fd.fd = sock;
+ new->conf = conf;
+
/* get local endpoint addr */
sl = sizeof(struct sockaddr_in6);
{
struct listener *cur = NULL;
- for( cur = uh_listeners; cur; cur = cur->next )
- if( cur->socket == sock )
+ for (cur = uh_listeners; cur; cur = cur->next)
+ if (cur->fd.fd == sock)
return cur;
return NULL;
struct client *new = NULL;
socklen_t sl;
- if( (new = (struct client *)malloc(sizeof(struct client))) != NULL )
+ if ((new = (struct client *)malloc(sizeof(struct client))) != NULL)
{
memset(new, 0, sizeof(struct client));
- new->socket = sock;
+ new->fd.fd = sock;
new->server = serv;
/* get remote endpoint addr */
new->next = uh_clients;
uh_clients = new;
+
+ serv->n_clients++;
}
return new;
{
struct client *cur = NULL;
- for( cur = uh_clients; cur; cur = cur->next )
- if( cur->socket == sock )
+ for (cur = uh_clients; cur; cur = cur->next)
+ if (cur->fd.fd == sock)
return cur;
return NULL;
}
-void uh_client_remove(int sock)
+void uh_client_shutdown(struct client *cl)
+{
+#ifdef HAVE_TLS
+ /* free client tls context */
+ if (cl->server && cl->server->conf->tls)
+ cl->server->conf->tls_close(cl);
+#endif
+
+ /* remove from global client list */
+ uh_client_remove(cl);
+}
+
+void uh_client_remove(struct client *cl)
{
struct client *cur = NULL;
struct client *prv = NULL;
- for( cur = uh_clients; cur; prv = cur, cur = cur->next )
+ for (cur = uh_clients; cur; prv = cur, cur = cur->next)
{
- if( cur->socket == sock )
+ if ((cur == cl) || (!cl && cur->dead))
{
- if( prv )
+ if (prv)
prv->next = cur->next;
else
uh_clients = cur->next;
+ if (cur->timeout.pending)
+ uloop_timeout_cancel(&cur->timeout);
+
+ if (cur->proc.pid)
+ uloop_process_delete(&cur->proc);
+
+ if (cur->pipe.fd)
+ uloop_fd_delete(&cur->pipe);
+
+ uloop_fd_delete(&cur->fd);
+ close(cur->fd.fd);
+
+ D("IO: Socket(%d) closing\n", cur->fd.fd);
+ cur->server->n_clients--;
+
free(cur);
break;
}
{
struct interpreter *new = NULL;
- if( (new = (struct interpreter *)
- malloc(sizeof(struct interpreter))) != NULL )
+ if ((new = (struct interpreter *)malloc(sizeof(struct interpreter))) != NULL)
{
memset(new, 0, sizeof(struct interpreter));
struct interpreter *cur = NULL;
const char *e;
- for( cur = uh_interpreters; cur; cur = cur->next )
+ for (cur = uh_interpreters; cur; cur = cur->next)
{
e = &path[max(strlen(path) - strlen(cur->extn), 0)];
- if( !strcmp(e, cur->extn) )
+ if (!strcmp(e, cur->extn))
return cur;
}
projects / openwrt.git / blobdiff