[ashd.git] / src / callfcgi.c

/*
    ashd - A Sane HTTP Daemon
    Copyright (C) 2008  Fredrik Tolf <fredrik@dolda2000.com>

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/

/*
 * XXX: This program is mostly copied from callscgi. It may be
 * reasonable to unify some of their shared code in a source file.
 */

/*
 * XXX: All the various ways to start a child process makes this
 * program quite ugly at the moment. It is unclear whether it is
 * meaningfully possible to unify them better than they currently are.
 */

#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <fcntl.h>
#include <ctype.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <netinet/in.h>
#include <netdb.h>
#include <signal.h>
#include <errno.h>

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include <utils.h>
#include <req.h>
#include <resp.h>
#include <log.h>
#include <mt.h>
#include <mtio.h>

#define FCGI_BEGIN_REQUEST 1
#define FCGI_ABORT_REQUEST 2
#define FCGI_END_REQUEST 3
#define FCGI_PARAMS 4
#define FCGI_STDIN 5
#define FCGI_STDOUT 6
#define FCGI_STDERR 7

static char **progspec;
static char *sockid, *unspec, *inspec;
static int nolisten;
static struct sockaddr *curaddr;
static size_t caddrlen;
static int cafamily, isanon;
static pid_t child;

static struct addrinfo *resolv(int flags)
{
    int ret;
    struct addrinfo *ai, h;
    char *name, *srv, *p;
    
    if((p = strchr(inspec, ':')) != NULL) {
	name = smalloc(p - inspec + 1);
	memcpy(name, inspec, p - inspec);
	name[p - inspec] = 0;
	srv = p + 1;
    } else {
	name = sstrdup("localhost");
	srv = inspec;
    }
    memset(&h, 0, sizeof(h));
    h.ai_family = AF_UNSPEC;
    h.ai_socktype = SOCK_STREAM;
    h.ai_flags = flags;
    ret = getaddrinfo(name, srv, &h, &ai);
    free(name);
    if(ret != 0) {
	flog(LOG_ERR, "could not resolve TCP specification `%s': %s", inspec, gai_strerror(ret));
	exit(1);
    }
    return(ai);
}

static char *mksockid(char *sockid)
{
    char *home;
    
    home = getenv("HOME");
    if(home && !access(sprintf3("%s/.ashd/sockets/", home), X_OK))
	return(sprintf3("%s/.ashd/sockets/fcgi-p-%s", home, sockid));
    return(sprintf3("/tmp/fcgi-%i-%s", getuid(), sockid));
}

static char *mkanonid(void)
{
    char *home;
    char *tmpl;
    int fd;
    
    home = getenv("HOME");
    if(home && !access(sprintf3("%s/.ashd/sockets/", home), X_OK))
	tmpl = sprintf2("%s/.ashd/sockets/fcgi-a-XXXXXX", home);
    else
	tmpl = sprintf2("/tmp/fcgi-a-%i-XXXXXX", getuid());
    if((fd = mkstemp(tmpl)) < 0) {
	flog(LOG_ERR, "could not create anonymous socket `%s': %s", tmpl, strerror(errno));
	exit(1);
    }
    close(fd);
    unlink(tmpl);
    return(tmpl);
}

static void startlisten(void)
{
    int i, fd;
    struct addrinfo *ai, *cai;
    char *unpath;
    struct sockaddr_un unm;
    char *aname;
    
    isanon = 0;
    if(inspec != NULL) {
	fd = -1;
	for(cai = ai = resolv(AI_PASSIVE); cai != NULL; cai = cai->ai_next) {
	    if((fd = socket(cai->ai_family, cai->ai_socktype, cai->ai_protocol)) < 0)
		continue;
	    if(bind(fd, cai->ai_addr, cai->ai_addrlen)) {
		close(fd);
		fd = -1;
		continue;
	    }
	    if(listen(fd, 128)) {
		close(fd);
		fd = -1;
		continue;
	    }
	    break;
	}
	freeaddrinfo(ai);
	if(fd < 0) {
	    flog(LOG_ERR, "could not bind to specified TCP address: %s", strerror(errno));
	    exit(1);
	}
    } else if((unspec != NULL) || (sockid != NULL)) {
	if((fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
	    flog(LOG_ERR, "could not create Unix socket: %s", strerror(errno));
	    exit(1);
	}
	if(unspec != NULL)
	    unpath = unspec;
	else
	    unpath = mksockid(sockid);
	unlink(unpath);
	unm.sun_family = AF_UNIX;
	strcpy(unm.sun_path, unpath);
	if(bind(fd, (struct sockaddr *)&unm, sizeof(unm))) {
	    flog(LOG_ERR, "could not bind Unix socket to `%s': %s", unspec, strerror(errno));
	    exit(1);
	}
	if(listen(fd, 128)) {
	    flog(LOG_ERR, "listen: %s", strerror(errno));
	    exit(1);
	}
    } else {
	if((fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
	    flog(LOG_ERR, "could not create Unix socket: %s", strerror(errno));
	    exit(1);
	}
	memset(&unm, 0, sizeof(unm));
	aname = mkanonid();
	unm.sun_family = AF_UNIX;
	strcpy(unm.sun_path, aname);
	free(aname);
	if(bind(fd, (struct sockaddr *)&unm, sizeof(unm))) {
	    flog(LOG_ERR, "could not bind Unix socket to `%s': %s", unspec, strerror(errno));
	    exit(1);
	}
	if(listen(fd, 128)) {
	    flog(LOG_ERR, "listen: %s", strerror(errno));
	    exit(1);
	}
	
	curaddr = smalloc(caddrlen = sizeof(unm));
	memcpy(curaddr, &unm, sizeof(unm));
	cafamily = AF_UNIX;
	isanon = 1;
    }
    if((child = fork()) < 0) {
	flog(LOG_ERR, "could not fork: %s", strerror(errno));
	exit(1);
    }
    if(child == 0) {
	dup2(fd, 0);
	for(i = 3; i < FD_SETSIZE; i++)
	    close(i);
	execvp(*progspec, progspec);
	flog(LOG_ERR, "callfcgi: %s: %s", *progspec, strerror(errno));
	_exit(127);
    }
    close(fd);
}

static void startnolisten(void)
{
    int i, fd;
    
    if((child = fork()) < 0) {
	flog(LOG_ERR, "could not fork: %s", strerror(errno));
	exit(1);
    }
    if(child == 0) {
	for(i = 3; i < FD_SETSIZE; i++)
	    close(i);
	if((fd = open("/dev/null", O_RDONLY)) < 0) {
	    flog(LOG_ERR, "/dev/null: %s", strerror(errno));
	    _exit(127);
	}
	dup2(fd, 0);
	close(fd);
	execvp(*progspec, progspec);
	flog(LOG_ERR, "callfcgi: %s: %s", *progspec, strerror(errno));
	_exit(127);
    }
}

static int sconnect(void)
{
    int fd;
    int err;
    socklen_t errlen;

    fd = socket(cafamily, SOCK_STREAM, 0);
    fcntl(fd, F_SETFL, fcntl(fd, F_GETFL) | O_NONBLOCK);
    while(1) {
	if(connect(fd, curaddr, caddrlen)) {
	    if(errno == EINPROGRESS) {
		block(fd, EV_WRITE, 30);
		errlen = sizeof(err);
		if(getsockopt(fd, SOL_SOCKET, SO_ERROR, &err, &errlen) || ((errno = err) != 0)) {
		    close(fd);
		    return(-1);
		}
		return(fd);
	    }
	    close(fd);
	    return(-1);
	}
	return(fd);
    }
}

static int econnect(void)
{
    int fd;
    struct addrinfo *ai, *cai;
    int tries;
    char *unpath;
    struct sockaddr_un unm;
    
    tries = 0;
retry:
    if(inspec != NULL) {
	fd = -1;
	for(cai = ai = resolv(0); cai != NULL; cai = cai->ai_next) {
	    if((fd = socket(cai->ai_family, cai->ai_socktype, cai->ai_protocol)) < 0)
		continue;
	    if(connect(fd, cai->ai_addr, cai->ai_addrlen)) {
		close(fd);
		fd = -1;
		continue;
	    }
	    break;
	}
	if(fd < 0) {
	    if(tries++ < nolisten) {
		sleep(1);
		goto retry;
	    }
	    flog(LOG_ERR, "could not connect to specified TCP address: %s", strerror(errno));
	    exit(1);
	}
	curaddr = smalloc(caddrlen = cai->ai_addrlen);
	memcpy(curaddr, cai->ai_addr, caddrlen);
	cafamily = cai->ai_family;
	isanon = 0;
	freeaddrinfo(ai);
	return(fd);
    } else if((unspec != NULL) || (sockid != NULL)) {
	if((fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
	    flog(LOG_ERR, "could not create Unix socket: %s", strerror(errno));
	    exit(1);
	}
	if(unspec != NULL)
	    unpath = unspec;
	else
	    unpath = mksockid(sockid);
	unlink(unpath);
	unm.sun_family = AF_UNIX;
	strcpy(unm.sun_path, unpath);
	if(connect(fd, (struct sockaddr *)&unm, sizeof(unm))) {
	    close(fd);
	    if(tries++ < nolisten) {
		sleep(1);
		goto retry;
	    }
	    flog(LOG_ERR, "could not connect to Unix socket `%s': %s", unspec, strerror(errno));
	    exit(1);
	}
	curaddr = smalloc(caddrlen = sizeof(unm));
	memcpy(curaddr, &unm, sizeof(unm));
	cafamily = AF_UNIX;
	isanon = 0;
	return(fd);
    } else {
	flog(LOG_ERR, "callfcgi: cannot use an anonymous socket without a program to start");
	exit(1);
    }
}

static int startconn(void)
{
    if(*progspec) {
	if(nolisten == 0)
	    startlisten();
	else
	    startnolisten();
    }
    if(curaddr != NULL)
	return(sconnect());
    return(econnect());
}

static void killcuraddr(void)
{
    if(curaddr == NULL)
	return;
    if(isanon) {
	unlink(((struct sockaddr_un *)curaddr)->sun_path);
	if(child > 0)
	    kill(child, SIGTERM);
    }
    free(curaddr);
    curaddr = NULL;
}

static int reconn(void)
{
    int fd;
    
    if(curaddr != NULL) {
	if((fd = sconnect()) >= 0)
	    return(fd);
	killcuraddr();
    }
    return(startconn());
}

static off_t passdata(FILE *in, FILE *out)
{
    size_t read;
    off_t total;
    char buf[8192];
    
    total = 0;
    while(!feof(in)) {
	read = fread(buf, 1, sizeof(buf), in);
	if(ferror(in))
	    return(-1);
	if(fwrite(buf, 1, read, out) != read)
	    return(-1);
	total += read;
    }
    return(total);
}

static void bufcatkv(struct charbuf *dst, char *key, char *val)
{
    size_t kl, vl;
    
    if((kl = strlen(key)) < 128) {
	bufadd(*dst, kl);
    } else {
	bufadd(*dst, ((kl & 0x7f000000) >> 24) | 0x80);
	bufadd(*dst, (kl & 0x00ff0000) >> 16);
	bufadd(*dst, (kl & 0x0000ff00) >> 8);
	bufadd(*dst, kl & 0x000000ff);
    }
    if((vl = strlen(val)) < 128) {
	bufadd(*dst, vl);
    } else {
	bufadd(*dst, ((vl & 0x7f000000) >> 24) | 0x80);
	bufadd(*dst, (vl & 0x00ff0000) >> 16);
	bufadd(*dst, (vl & 0x0000ff00) >> 8);
	bufadd(*dst, vl & 0x000000ff);
    }
    bufcat(*dst, key, kl);
    bufcat(*dst, val, vl);
}

static void bufaddenv(struct charbuf *dst, char *name, char *fmt, ...)
{
    va_list args;
    char *val = NULL;
    
    va_start(args, fmt);
    val = vsprintf2(fmt, args);
    va_end(args);
    bufcatkv(dst, name, val);
    free(val);
}

static char *absolutify(char *file)
{
    static int inited = 0;
    static char cwd[1024];
    
    if(*file != '/') {
	if(!inited) {
	    getcwd(cwd, sizeof(cwd));
	    inited = 1;
	}
	return(sprintf2("%s/%s", cwd, file));
    }
    return(sstrdup(file));
}

/* Mostly copied from callcgi. */
static void mkcgienv(struct hthead *req, struct charbuf *dst)
{
    int i;
    char *url, *pi, *tmp, *qp, *h, *p;
    
    bufaddenv(dst, "SERVER_SOFTWARE", "ashd/%s", VERSION);
    bufaddenv(dst, "GATEWAY_INTERFACE", "CGI/1.1");
    bufaddenv(dst, "SERVER_PROTOCOL", "%s", req->ver);
    bufaddenv(dst, "REQUEST_METHOD", "%s", req->method);
    bufaddenv(dst, "REQUEST_URI", "%s", req->url);
    url = sstrdup(req->url);
    if((qp = strchr(url, '?')) != NULL)
	*(qp++) = 0;
    /* XXX: This is an ugly hack (I think), but though I can think of
     * several alternatives, none seem to be better. */
    if(*req->rest && (strlen(url) >= strlen(req->rest)) &&
       !strcmp(req->rest, url + strlen(url) - strlen(req->rest))) {
	url[strlen(url) - strlen(req->rest)] = 0;
    }
    if((pi = unquoteurl(req->rest)) == NULL)
	pi = sstrdup(req->rest);
    if(!strcmp(url, "/")) {
	/* This seems to be normal CGI behavior, but see callcgi.c for
	 * details. */
	url[0] = 0;
	pi = sprintf2("/%s", tmp = pi);
	free(tmp);
    }
    bufaddenv(dst, "PATH_INFO", pi);
    bufaddenv(dst, "SCRIPT_NAME", url);
    bufaddenv(dst, "QUERY_STRING", "%s", qp?qp:"");
    free(pi);
    free(url);
    if((h = getheader(req, "Host")) != NULL)
	bufaddenv(dst, "SERVER_NAME", "%s", h);
    if((h = getheader(req, "X-Ash-Server-Address")) != NULL)
	bufaddenv(dst, "SERVER_ADDR", "%s", h);
    if((h = getheader(req, "X-Ash-Server-Port")) != NULL)
	bufaddenv(dst, "SERVER_PORT", "%s", h);
    if((h = getheader(req, "X-Ash-Remote-User")) != NULL)
	bufaddenv(dst, "REMOTE_USER", "%s", h);
    if(((h = getheader(req, "X-Ash-Protocol")) != NULL) && !strcmp(h, "https"))
	bufaddenv(dst, "HTTPS", "on");
    if((h = getheader(req, "X-Ash-Address")) != NULL)
	bufaddenv(dst, "REMOTE_ADDR", "%s", h);
    if((h = getheader(req, "X-Ash-Port")) != NULL)
	bufaddenv(dst, "REMOTE_PORT", "%s", h);
    if((h = getheader(req, "Content-Type")) != NULL)
	bufaddenv(dst, "CONTENT_TYPE", "%s", h);
    if((h = getheader(req, "Content-Length")) != NULL)
	bufaddenv(dst, "CONTENT_LENGTH", "%s", h);
    else
	bufaddenv(dst, "CONTENT_LENGTH", "0");
    if((h = getheader(req, "X-Ash-File")) != NULL) {
	h = absolutify(h);
	bufaddenv(dst, "SCRIPT_FILENAME", "%s", h);
	free(h);
    }
    for(i = 0; i < req->noheaders; i++) {
	h = sprintf2("HTTP_%s", req->headers[i][0]);
	for(p = h; *p; p++) {
	    if(isalnum(*p))
		*p = toupper(*p);
	    else
		*p = '_';
	}
	bufcatkv(dst, h, req->headers[i][1]);
	free(h);
    }
}

static struct hthead *parseresp(FILE *in)
{
    struct hthead *resp;
    char *st, *p;
    
    omalloc(resp);
    resp->ver = sstrdup("HTTP/1.1");
    if(parseheaders(resp, in)) {
	freehthead(resp);
	return(NULL);
    }
    if((st = getheader(resp, "Status")) != NULL) {
	if((p = strchr(st, ' ')) != NULL) {
	    *(p++) = 0;
	    resp->code = atoi(st);
	    resp->msg = sstrdup(p);
	} else {
	    resp->code = atoi(st);
	    resp->msg = sstrdup(httpdefstatus(resp->code));
	}
	headrmheader(resp, "Status");
    } else if(getheader(resp, "Location")) {
	resp->code = 303;
	resp->msg = sstrdup("See Other");
    } else {
	resp->code = 200;
	resp->msg = sstrdup("OK");
    }
    return(resp);
}

#define fputc2(b, f) if(fputc((b), (f)) == EOF) return(-1);

static int sendrec(FILE *out, int type, int rid, char *data, size_t dlen)
{
    off_t off;
    size_t cl;
    int p;
    
    off = 0;
    do {
	cl = min(dlen - off, 65535);
	p = (8 - (cl % 8)) % 8;
	fputc2(1, out);
	fputc2(type, out);
	fputc2((rid & 0xff00) >> 8, out);
	fputc2(rid & 0x00ff, out);
	fputc2((cl & 0xff00) >> 8, out);
	fputc2(cl & 0x00ff, out);
	fputc2(p, out);
	fputc2(0, out);
	if(fwrite(data + off, 1, cl, out) != cl)
	    return(-1);
	for(; p > 0; p--)
	    fputc2(0, out);
    } while((off += cl) < dlen);
    return(0);
}

static int recvrec(FILE *in, int *type, int *rid, char **data, size_t *dlen)
{
    unsigned char header[8];
    int tl;
    
    if(fread(header, 1, 8, in) != 8)
	return(-1);
    if(header[0] != 1)
	return(-1);
    *type = header[1];
    *rid  = (header[2] << 8) | header[3];
    *dlen = (header[4] << 8) | header[5];
    tl = *dlen + header[6];
    if(header[7] != 0)
	return(-1);
    *data = smalloc(max(tl, 1));
    if(fread(*data, 1, tl, in) != tl) {
	free(*data);
	return(-1);
    }
    return(0);
}

static int begreq(FILE *out, int rid)
{
    char rec[] = {0, 1, 0, 0, 0, 0, 0, 0};
    
    return(sendrec(out, FCGI_BEGIN_REQUEST, rid, rec, 8));
}

static void outplex(struct muth *muth, va_list args)
{
    vavar(FILE *, sk);
    struct {
	struct ch {
	    FILE *s;
	    int id;
	} *b;
	size_t s, d;
    } outs;
    int i;
    struct ch ch;
    int type, rid;
    char *data;
    size_t dlen;
    
    bufinit(outs);
    while((ch.s = va_arg(args, FILE *)) != NULL) {
	ch.id = va_arg(args, int);
	bufadd(outs, ch);
    }
    data = NULL;
    while(1) {
	if(recvrec(sk, &type, &rid, &data, &dlen))
	    goto out;
	if(rid != 1)
	    goto out;
	for(i = 0; i < outs.d; i++) {
	    if(outs.b[i].id == type) {
		if(outs.b[i].s != NULL) {
		    if(dlen == 0) {
			fclose(outs.b[i].s);
			outs.b[i].s = NULL;
		    } else {
			if(fwrite(data, 1, dlen, outs.b[i].s) != dlen)
			    goto out;
		    }
		}
		break;
	    }
	}
	free(data);
	data = NULL;
    }

out:
    if(data != NULL)
	free(data);
    for(i = 0; i < outs.d; i++) {
	if(outs.b[i].s != NULL)
	    fclose(outs.b[i].s);
    }
    buffree(outs);
    fclose(sk);
}

static void errhandler(struct muth *muth, va_list args)
{
    vavar(FILE *, in);
    char buf[1024];
    char *p;
    
    bufinit(buf);
    while(fgets(buf, sizeof(buf), in) != NULL) {
	p = buf + strlen(buf) - 1;
	while((p >= buf) && (*p == '\n'))
	    *(p--) = 0;
	if(buf[0])
	    flog(LOG_INFO, "child said: %s", buf);
    }
    fclose(in);
}

static void serve(struct muth *muth, va_list args)
{
    vavar(struct hthead *, req);
    vavar(int, fd);
    vavar(int, sfd);
    FILE *is, *os, *outi, *outo, *erri, *erro;
    struct charbuf head;
    struct hthead *resp;
    size_t read;
    char buf[8192];
    
    sfd = reconn();
    is = mtstdopen(fd, 1, 60, "r+");
    os = mtstdopen(sfd, 1, 600, "r+");
    
    outi = NULL;
    mtiopipe(&outi, &outo); mtiopipe(&erri, &erro);
    mustart(outplex, mtstdopen(dup(sfd), 1, 600, "r+"), outo, FCGI_STDOUT, erro, FCGI_STDERR, NULL);
    mustart(errhandler, erri);
    
    if(begreq(os, 1))
	goto out;
    bufinit(head);
    mkcgienv(req, &head);
    if(sendrec(os, FCGI_PARAMS, 1, head.b, head.d))
	goto out;
    if(sendrec(os, FCGI_PARAMS, 1, NULL, 0))
	goto out;
    buffree(head);
    if(fflush(os))
	goto out;
    
    while(!feof(is)) {
	read = fread(buf, 1, sizeof(buf), is);
	if(ferror(is))
	    goto out;
	if(sendrec(os, FCGI_STDIN, 1, buf, read))
	    goto out;
    }
    if(sendrec(os, FCGI_STDIN, 1, NULL, 0))
	goto out;
    if(fflush(os))
	goto out;
    
    if((resp = parseresp(outi)) == NULL)
	goto out;
    writeresp(is, resp);
    freehthead(resp);
    fputc('\n', is);
    if(passdata(outi, is) < 0)
	goto out;
    
out:
    freehthead(req);
    buffree(head);
    shutdown(sfd, SHUT_RDWR);
    if(outi != NULL)
	fclose(outi);
    fclose(is);
    fclose(os);
}

static void listenloop(struct muth *muth, va_list args)
{
    vavar(int, lfd);
    int fd;
    struct hthead *req;
    
    while(1) {
	block(0, EV_READ, 0);
	if((fd = recvreq(lfd, &req)) < 0) {
	    if(errno != 0)
		flog(LOG_ERR, "recvreq: %s", strerror(errno));
	    break;
	}
	mustart(serve, req, fd);
    }
}

static void sigign(int sig)
{
}

static void sigexit(int sig)
{
    shutdown(0, SHUT_RDWR);
}

static void usage(FILE *out)
{
    fprintf(out, "usage: callfcgi [-h] [-N RETRIES] [-i ID] [-u UNIX-PATH] [-t [HOST:]TCP-PORT] [PROGRAM [ARGS...]]\n");
}

int main(int argc, char **argv)
{
    int c;
    
    while((c = getopt(argc, argv, "+hN:i:u:t:")) >= 0) {
	switch(c) {
	case 'h':
	    usage(stdout);
	    exit(0);
	case 'N':
	    nolisten = atoi(optarg);
	    break;
	case 'i':
	    sockid = optarg;
	    break;
	case 'u':
	    unspec = optarg;
	    break;
	case 't':
	    inspec = optarg;
	    break;
	default:
	    usage(stderr);
	    exit(1);
	}
    }
    progspec = argv + optind;
    if(((sockid != NULL) + (unspec != NULL) + (inspec != NULL)) > 1) {
	flog(LOG_ERR, "callfcgi: at most one of -i, -u or -t may be given");
	exit(1);
    }
    signal(SIGCHLD, SIG_IGN);
    signal(SIGPIPE, sigign);
    signal(SIGINT, sigexit);
    signal(SIGTERM, sigexit);
    mustart(listenloop, 0);
    ioloop();
    killcuraddr();
    return(0);
}
Commit	Line	Data
5c2040da FT	1	/*
	2	ashd - A Sane HTTP Daemon
	3	Copyright (C) 2008 Fredrik Tolf <fredrik@dolda2000.com>
	4
	5	This program is free software: you can redistribute it and/or modify
	6	it under the terms of the GNU General Public License as published by
	7	the Free Software Foundation, either version 3 of the License, or
	8	(at your option) any later version.
	9
	10	This program is distributed in the hope that it will be useful,
	11	but WITHOUT ANY WARRANTY; without even the implied warranty of
	12	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	13	GNU General Public License for more details.
	14
	15	You should have received a copy of the GNU General Public License
	16	along with this program. If not, see <http://www.gnu.org/licenses/>.
	17	*/
	18
	19	/*
	20	* XXX: This program is mostly copied from callscgi. It may be
	21	* reasonable to unify some of their shared code in a source file.
	22	*/
	23
	24	/*
	25	* XXX: All the various ways to start a child process makes this
	26	* program quite ugly at the moment. It is unclear whether it is
	27	* meaningfully possible to unify them better than they currently are.
	28	*/
	29
	30	#include <stdlib.h>
	31	#include <stdio.h>
	32	#include <unistd.h>
	33	#include <string.h>
	34	#include <fcntl.h>
	35	#include <ctype.h>
	36	#include <sys/socket.h>
	37	#include <sys/un.h>
	38	#include <netinet/in.h>
	39	#include <netdb.h>
cc5adcf9	40	#include <signal.h>
5c2040da FT	41	#include <errno.h>
	42
	43	#ifdef HAVE_CONFIG_H
	44	#include <config.h>
	45	#endif
	46	#include <utils.h>
	47	#include <req.h>
62e76c42	48	#include <resp.h>
5c2040da FT	49	#include <log.h>
	50	#include <mt.h>
	51	#include <mtio.h>
	52
	53	#define FCGI_BEGIN_REQUEST 1
	54	#define FCGI_ABORT_REQUEST 2
	55	#define FCGI_END_REQUEST 3
	56	#define FCGI_PARAMS 4
	57	#define FCGI_STDIN 5
	58	#define FCGI_STDOUT 6
	59	#define FCGI_STDERR 7
	60
	61	static char **progspec;
	62	static char sockid, unspec, *inspec;
	63	static int nolisten;
	64	static struct sockaddr *curaddr;
	65	static size_t caddrlen;
	66	static int cafamily, isanon;
	67	static pid_t child;
	68
	69	static struct addrinfo *resolv(int flags)
	70	{
	71	int ret;
	72	struct addrinfo *ai, h;
	73	char name, srv, *p;
	74
	75	if((p = strchr(inspec, ':')) != NULL) {
	76	name = smalloc(p - inspec + 1);
	77	memcpy(name, inspec, p - inspec);
	78	name[p - inspec] = 0;
	79	srv = p + 1;
	80	} else {
	81	name = sstrdup("localhost");
	82	srv = inspec;
	83	}
	84	memset(&h, 0, sizeof(h));
	85	h.ai_family = AF_UNSPEC;
	86	h.ai_socktype = SOCK_STREAM;
	87	h.ai_flags = flags;
	88	ret = getaddrinfo(name, srv, &h, &ai);
	89	free(name);
	90	if(ret != 0) {
	91	flog(LOG_ERR, "could not resolve TCP specification `%s': %s", inspec, gai_strerror(ret));
	92	exit(1);
	93	}
	94	return(ai);
	95	}
	96
	97	static char mksockid(char sockid)
	98	{
	99	char *home;
	100
	101	home = getenv("HOME");
	102	if(home && !access(sprintf3("%s/.ashd/sockets/", home), X_OK))
	103	return(sprintf3("%s/.ashd/sockets/fcgi-p-%s", home, sockid));
	104	return(sprintf3("/tmp/fcgi-%i-%s", getuid(), sockid));
	105	}
	106
	107	static char *mkanonid(void)
	108	{
	109	char *home;
	110	char *tmpl;
	111	int fd;
	112
113	home = getenv("HOME");
114	if(home && !access(sprintf3("%s/.ashd/sockets/", home), X_OK))
115	tmpl = sprintf2("%s/.ashd/sockets/fcgi-a-XXXXXX", home);
116	else
117	tmpl = sprintf2("/tmp/fcgi-a-%i-XXXXXX", getuid());
118	if((fd = mkstemp(tmpl)) < 0) {
119	flog(LOG_ERR, "could not create anonymous socket `%s': %s", tmpl, strerror(errno));
120	exit(1);
121	}
122	close(fd);
123	unlink(tmpl);
124	return(tmpl);
125	}
126
127	static void startlisten(void)
128	{
129	int i, fd;
130	struct addrinfo ai, cai;
131	char *unpath;
132	struct sockaddr_un unm;
133	char *aname;
134
135	isanon = 0;
136	if(inspec != NULL) {
137	fd = -1;
138	for(cai = ai = resolv(AI_PASSIVE); cai != NULL; cai = cai->ai_next) {
139	if((fd = socket(cai->ai_family, cai->ai_socktype, cai->ai_protocol)) < 0)
140	continue;
141	if(bind(fd, cai->ai_addr, cai->ai_addrlen)) {
142	close(fd);
143	fd = -1;
144	continue;
145	}
146	if(listen(fd, 128)) {
147	close(fd);
148	fd = -1;
149	continue;
150	}
151	break;
152	}
153	freeaddrinfo(ai);
154	if(fd < 0) {
155	flog(LOG_ERR, "could not bind to specified TCP address: %s", strerror(errno));
156	exit(1);
157	}
158	} else if((unspec != NULL) \|\| (sockid != NULL)) {
159	if((fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
160	flog(LOG_ERR, "could not create Unix socket: %s", strerror(errno));
161	exit(1);
162	}
163	if(unspec != NULL)
164	unpath = unspec;
165	else
166	unpath = mksockid(sockid);
167	unlink(unpath);
168	unm.sun_family = AF_UNIX;
169	strcpy(unm.sun_path, unpath);
170	if(bind(fd, (struct sockaddr *)&unm, sizeof(unm))) {
171	flog(LOG_ERR, "could not bind Unix socket to `%s': %s", unspec, strerror(errno));
172	exit(1);
173	}
174	if(listen(fd, 128)) {
175	flog(LOG_ERR, "listen: %s", strerror(errno));
176	exit(1);
177	}
178	} else {
179	if((fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
180	flog(LOG_ERR, "could not create Unix socket: %s", strerror(errno));
181	exit(1);
182	}
183	memset(&unm, 0, sizeof(unm));
184	aname = mkanonid();
185	unm.sun_family = AF_UNIX;
186	strcpy(unm.sun_path, aname);
187	free(aname);
188	if(bind(fd, (struct sockaddr *)&unm, sizeof(unm))) {
189	flog(LOG_ERR, "could not bind Unix socket to `%s': %s", unspec, strerror(errno));
190	exit(1);
191	}
192	if(listen(fd, 128)) {
193	flog(LOG_ERR, "listen: %s", strerror(errno));
194	exit(1);
195	}
196
197	curaddr = smalloc(caddrlen = sizeof(unm));
198	memcpy(curaddr, &unm, sizeof(unm));
199	cafamily = AF_UNIX;
200	isanon = 1;
201	}
202	if((child = fork()) < 0) {
203	flog(LOG_ERR, "could not fork: %s", strerror(errno));
204	exit(1);
205	}
206	if(child == 0) {
207	dup2(fd, 0);
208	for(i = 3; i < FD_SETSIZE; i++)
209	close(i);
210	execvp(*progspec, progspec);
211	flog(LOG_ERR, "callfcgi: %s: %s", *progspec, strerror(errno));
107aa2ef	212	_exit(127);
5c2040da FT	213	}
	214	close(fd);
	215	}
	216
	217	static void startnolisten(void)
	218	{
	219	int i, fd;
	220
	221	if((child = fork()) < 0) {
	222	flog(LOG_ERR, "could not fork: %s", strerror(errno));
	223	exit(1);
	224	}
	225	if(child == 0) {
	226	for(i = 3; i < FD_SETSIZE; i++)
	227	close(i);
	228	if((fd = open("/dev/null", O_RDONLY)) < 0) {
	229	flog(LOG_ERR, "/dev/null: %s", strerror(errno));
107aa2ef	230	_exit(127);
5c2040da FT	231	}
	232	dup2(fd, 0);
	233	close(fd);
	234	execvp(*progspec, progspec);
	235	flog(LOG_ERR, "callfcgi: %s: %s", *progspec, strerror(errno));
107aa2ef	236	_exit(127);
5c2040da FT	237	}
	238	}
	239
	240	static int sconnect(void)
	241	{
	242	int fd;
	243	int err;
	244	socklen_t errlen;
	245
	246	fd = socket(cafamily, SOCK_STREAM, 0);
	247	fcntl(fd, F_SETFL, fcntl(fd, F_GETFL) \| O_NONBLOCK);
	248	while(1) {
	249	if(connect(fd, curaddr, caddrlen)) {
	250	if(errno == EINPROGRESS) {
	251	block(fd, EV_WRITE, 30);
	252	errlen = sizeof(err);
	253	if(getsockopt(fd, SOL_SOCKET, SO_ERROR, &err, &errlen) \|\| ((errno = err) != 0)) {
	254	close(fd);
	255	return(-1);
	256	}
	257	return(fd);
	258	}
	259	close(fd);
	260	return(-1);
	261	}
	262	return(fd);
	263	}
	264	}
	265
	266	static int econnect(void)
	267	{
	268	int fd;
	269	struct addrinfo ai, cai;
	270	int tries;
	271	char *unpath;
	272	struct sockaddr_un unm;
	273
	274	tries = 0;
	275	retry:
	276	if(inspec != NULL) {
	277	fd = -1;
	278	for(cai = ai = resolv(0); cai != NULL; cai = cai->ai_next) {
	279	if((fd = socket(cai->ai_family, cai->ai_socktype, cai->ai_protocol)) < 0)
	280	continue;
	281	if(connect(fd, cai->ai_addr, cai->ai_addrlen)) {
	282	close(fd);
	283	fd = -1;
	284	continue;
	285	}
	286	break;
	287	}
	288	if(fd < 0) {
	289	if(tries++ < nolisten) {
	290	sleep(1);
	291	goto retry;
	292	}
	293	flog(LOG_ERR, "could not connect to specified TCP address: %s", strerror(errno));
	294	exit(1);
	295	}
	296	curaddr = smalloc(caddrlen = cai->ai_addrlen);
	297	memcpy(curaddr, cai->ai_addr, caddrlen);
	298	cafamily = cai->ai_family;
	299	isanon = 0;
	300	freeaddrinfo(ai);
301	return(fd);
302	} else if((unspec != NULL) \|\| (sockid != NULL)) {
303	if((fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
304	flog(LOG_ERR, "could not create Unix socket: %s", strerror(errno));
305	exit(1);
306	}
307	if(unspec != NULL)
308	unpath = unspec;
309	else
310	unpath = mksockid(sockid);
311	unlink(unpath);
312	unm.sun_family = AF_UNIX;
313	strcpy(unm.sun_path, unpath);
314	if(connect(fd, (struct sockaddr *)&unm, sizeof(unm))) {
315	close(fd);
316	if(tries++ < nolisten) {
317	sleep(1);
318	goto retry;
319	}
320	flog(LOG_ERR, "could not connect to Unix socket `%s': %s", unspec, strerror(errno));
321	exit(1);
322	}
323	curaddr = smalloc(caddrlen = sizeof(unm));
324	memcpy(curaddr, &unm, sizeof(unm));
325	cafamily = AF_UNIX;
326	isanon = 0;
327	return(fd);
328	} else {
329	flog(LOG_ERR, "callfcgi: cannot use an anonymous socket without a program to start");
330	exit(1);
331	}
332	}
333
334	static int startconn(void)
335	{
336	if(*progspec) {
337	if(nolisten == 0)
338	startlisten();
339	else
340	startnolisten();
341	}
342	if(curaddr != NULL)
343	return(sconnect());
344	return(econnect());
345	}
346
347	static void killcuraddr(void)
348	{
349	if(curaddr == NULL)
350	return;
351	if(isanon) {
352	unlink(((struct sockaddr_un *)curaddr)->sun_path);
353	if(child > 0)
354	kill(child, SIGTERM);
355	}
356	free(curaddr);
357	curaddr = NULL;
358	}
359
360	static int reconn(void)
361	{
362	int fd;
363
364	if(curaddr != NULL) {
365	if((fd = sconnect()) >= 0)
366	return(fd);
367	killcuraddr();
368	}
369	return(startconn());
370	}
371
372	static off_t passdata(FILE in, FILE out)
373	{
374	size_t read;
375	off_t total;
376	char buf[8192];
377
378	total = 0;
379	while(!feof(in)) {
380	read = fread(buf, 1, sizeof(buf), in);
381	if(ferror(in))
382	return(-1);
383	if(fwrite(buf, 1, read, out) != read)
384	return(-1);
385	total += read;
386	}
387	return(total);
388	}
389
390	static void bufcatkv(struct charbuf dst, char key, char *val)
391	{
392	size_t kl, vl;
393
394	if((kl = strlen(key)) < 128) {
395	bufadd(*dst, kl);
396	} else {
397	bufadd(*dst, ((kl & 0x7f000000) >> 24) \| 0x80);
398	bufadd(*dst, (kl & 0x00ff0000) >> 16);
399	bufadd(*dst, (kl & 0x0000ff00) >> 8);
400	bufadd(*dst, kl & 0x000000ff);
401	}
402	if((vl = strlen(val)) < 128) {
403	bufadd(*dst, vl);
404	} else {
405	bufadd(*dst, ((vl & 0x7f000000) >> 24) \| 0x80);
406	bufadd(*dst, (vl & 0x00ff0000) >> 16);
407	bufadd(*dst, (vl & 0x0000ff00) >> 8);
408	bufadd(*dst, vl & 0x000000ff);
409	}
410	bufcat(*dst, key, kl);
411	bufcat(*dst, val, vl);
412	}
413
414	static void bufaddenv(struct charbuf dst, char name, char *fmt, ...)
415	{
416	va_list args;
417	char *val = NULL;
418
419	va_start(args, fmt);
420	val = vsprintf2(fmt, args);
421	va_end(args);
422	bufcatkv(dst, name, val);
423	free(val);
424	}
425
426	static char absolutify(char file)
427	{
428	static int inited = 0;
429	static char cwd[1024];
430
431	if(*file != '/') {
432	if(!inited) {
433	getcwd(cwd, sizeof(cwd));
434	inited = 1;
435	}
436	return(sprintf2("%s/%s", cwd, file));
437	}
438	return(sstrdup(file));
439	}
440
441	/* Mostly copied from callcgi. */
442	static void mkcgienv(struct hthead req, struct charbuf dst)
443	{
444	int i;
53d666ca	445	char url, pi, tmp, qp, h, p;
5c2040da FT	446
	447	bufaddenv(dst, "SERVER_SOFTWARE", "ashd/%s", VERSION);
	448	bufaddenv(dst, "GATEWAY_INTERFACE", "CGI/1.1");
	449	bufaddenv(dst, "SERVER_PROTOCOL", "%s", req->ver);
	450	bufaddenv(dst, "REQUEST_METHOD", "%s", req->method);
	451	bufaddenv(dst, "REQUEST_URI", "%s", req->url);
5c2040da FT	452	url = sstrdup(req->url);
	453	if((qp = strchr(url, '?')) != NULL)
	454	*(qp++) = 0;
	455	/* XXX: This is an ugly hack (I think), but though I can think of
	456	* several alternatives, none seem to be better. */
	457	if(*req->rest && (strlen(url) >= strlen(req->rest)) &&
	458	!strcmp(req->rest, url + strlen(url) - strlen(req->rest))) {
53d666ca FT	459	url[strlen(url) - strlen(req->rest)] = 0;
	460	}
	461	if((pi = unquoteurl(req->rest)) == NULL)
	462	pi = sstrdup(req->rest);
	463	if(!strcmp(url, "/")) {
	464	/* This seems to be normal CGI behavior, but see callcgi.c for
	465	* details. */
	466	url[0] = 0;
	467	pi = sprintf2("/%s", tmp = pi);
	468	free(tmp);
5c2040da	469	}
53d666ca FT	470	bufaddenv(dst, "PATH_INFO", pi);
53d666ca FT	471	bufaddenv(dst, "SCRIPT_NAME", url);
5c2040da	472	bufaddenv(dst, "QUERY_STRING", "%s", qp?qp:"");
53d666ca	473	free(pi);
b77076c4	474	free(url);
5c2040da FT	475	if((h = getheader(req, "Host")) != NULL)
5c2040da FT	476	bufaddenv(dst, "SERVER_NAME", "%s", h);
1af656d2 FT	477	if((h = getheader(req, "X-Ash-Server-Address")) != NULL)
1af656d2 FT	478	bufaddenv(dst, "SERVER_ADDR", "%s", h);
5c2040da FT	479	if((h = getheader(req, "X-Ash-Server-Port")) != NULL)
5c2040da FT	480	bufaddenv(dst, "SERVER_PORT", "%s", h);
381f9919 FT	481	if((h = getheader(req, "X-Ash-Remote-User")) != NULL)
381f9919 FT	482	bufaddenv(dst, "REMOTE_USER", "%s", h);
5c2040da FT	483	if(((h = getheader(req, "X-Ash-Protocol")) != NULL) && !strcmp(h, "https"))
	484	bufaddenv(dst, "HTTPS", "on");
	485	if((h = getheader(req, "X-Ash-Address")) != NULL)
	486	bufaddenv(dst, "REMOTE_ADDR", "%s", h);
1af656d2 FT	487	if((h = getheader(req, "X-Ash-Port")) != NULL)
1af656d2 FT	488	bufaddenv(dst, "REMOTE_PORT", "%s", h);
5c2040da FT	489	if((h = getheader(req, "Content-Type")) != NULL)
	490	bufaddenv(dst, "CONTENT_TYPE", "%s", h);
	491	if((h = getheader(req, "Content-Length")) != NULL)
	492	bufaddenv(dst, "CONTENT_LENGTH", "%s", h);
	493	else
	494	bufaddenv(dst, "CONTENT_LENGTH", "0");
e25bf4f9 FT	495	if((h = getheader(req, "X-Ash-File")) != NULL) {
	496	h = absolutify(h);
	497	bufaddenv(dst, "SCRIPT_FILENAME", "%s", h);
	498	free(h);
	499	}
5c2040da FT	500	for(i = 0; i < req->noheaders; i++) {
	501	h = sprintf2("HTTP_%s", req->headers[i][0]);
	502	for(p = h; *p; p++) {
	503	if(isalnum(*p))
	504	p = toupper(p);
	505	else
	506	*p = '_';
	507	}
	508	bufcatkv(dst, h, req->headers[i][1]);
	509	free(h);
	510	}
	511	}
	512
5c2040da FT	513	static struct hthead parseresp(FILE in)
	514	{
	515	struct hthead *resp;
	516	char st, p;
	517
	518	omalloc(resp);
	519	resp->ver = sstrdup("HTTP/1.1");
	520	if(parseheaders(resp, in)) {
	521	freehthead(resp);
	522	return(NULL);
	523	}
	524	if((st = getheader(resp, "Status")) != NULL) {
	525	if((p = strchr(st, ' ')) != NULL) {
	526	*(p++) = 0;
	527	resp->code = atoi(st);
	528	resp->msg = sstrdup(p);
	529	} else {
	530	resp->code = atoi(st);
62e76c42	531	resp->msg = sstrdup(httpdefstatus(resp->code));
5c2040da FT	532	}
	533	headrmheader(resp, "Status");
	534	} else if(getheader(resp, "Location")) {
	535	resp->code = 303;
	536	resp->msg = sstrdup("See Other");
	537	} else {
	538	resp->code = 200;
	539	resp->msg = sstrdup("OK");
	540	}
	541	return(resp);
	542	}
	543
	544	#define fputc2(b, f) if(fputc((b), (f)) == EOF) return(-1);
	545
	546	static int sendrec(FILE out, int type, int rid, char data, size_t dlen)
	547	{
	548	off_t off;
	549	size_t cl;
	550	int p;
	551
	552	off = 0;
	553	do {
	554	cl = min(dlen - off, 65535);
	555	p = (8 - (cl % 8)) % 8;
	556	fputc2(1, out);
	557	fputc2(type, out);
	558	fputc2((rid & 0xff00) >> 8, out);
	559	fputc2(rid & 0x00ff, out);
	560	fputc2((cl & 0xff00) >> 8, out);
	561	fputc2(cl & 0x00ff, out);
	562	fputc2(p, out);
	563	fputc2(0, out);
	564	if(fwrite(data + off, 1, cl, out) != cl)
	565	return(-1);
	566	for(; p > 0; p--)
	567	fputc2(0, out);
	568	} while((off += cl) < dlen);
	569	return(0);
	570	}
	571
5c2040da FT	572	static int recvrec(FILE in, int type, int rid, char data, size_t dlen)
5c2040da FT	573	{
e6fbc5e5 FT	574	unsigned char header[8];
e6fbc5e5 FT	575	int tl;
5c2040da	576
e6fbc5e5 FT	577	if(fread(header, 1, 8, in) != 8)
	578	return(-1);
	579	if(header[0] != 1)
5c2040da	580	return(-1);
e6fbc5e5 FT	581	*type = header[1];
	582	*rid = (header[2] << 8) \| header[3];
	583	*dlen = (header[4] << 8) \| header[5];
	584	tl = *dlen + header[6];
	585	if(header[7] != 0)
5c2040da	586	return(-1);
e6fbc5e5 FT	587	*data = smalloc(max(tl, 1));
e6fbc5e5 FT	588	if(fread(*data, 1, tl, in) != tl) {
49b8b4d2	589	free(*data);
5c2040da FT	590	return(-1);
5c2040da FT	591	}
5c2040da FT	592	return(0);
	593	}
	594
	595	static int begreq(FILE *out, int rid)
	596	{
	597	char rec[] = {0, 1, 0, 0, 0, 0, 0, 0};
	598
	599	return(sendrec(out, FCGI_BEGIN_REQUEST, rid, rec, 8));
	600	}
	601
5c2040da FT	602	static void outplex(struct muth *muth, va_list args)
	603	{
	604	vavar(FILE *, sk);
	605	struct {
	606	struct ch {
	607	FILE *s;
	608	int id;
	609	} *b;
	610	size_t s, d;
	611	} outs;
	612	int i;
	613	struct ch ch;
	614	int type, rid;
	615	char *data;
	616	size_t dlen;
	617
	618	bufinit(outs);
	619	while((ch.s = va_arg(args, FILE *)) != NULL) {
	620	ch.id = va_arg(args, int);
	621	bufadd(outs, ch);
	622	}
	623	data = NULL;
	624	while(1) {
	625	if(recvrec(sk, &type, &rid, &data, &dlen))
	626	goto out;
	627	if(rid != 1)
	628	goto out;
	629	for(i = 0; i < outs.d; i++) {
	630	if(outs.b[i].id == type) {
	631	if(outs.b[i].s != NULL) {
	632	if(dlen == 0) {
	633	fclose(outs.b[i].s);
	634	outs.b[i].s = NULL;
	635	} else {
	636	if(fwrite(data, 1, dlen, outs.b[i].s) != dlen)
	637	goto out;
	638	}
	639	}
	640	break;
	641	}
	642	}
	643	free(data);
	644	data = NULL;
	645	}
	646
	647	out:
	648	if(data != NULL)
	649	free(data);
	650	for(i = 0; i < outs.d; i++) {
	651	if(outs.b[i].s != NULL)
	652	fclose(outs.b[i].s);
	653	}
	654	buffree(outs);
	655	fclose(sk);
	656	}
	657
	658	static void errhandler(struct muth *muth, va_list args)
	659	{
	660	vavar(FILE *, in);
	661	char buf[1024];
	662	char *p;
	663
	664	bufinit(buf);
	665	while(fgets(buf, sizeof(buf), in) != NULL) {
666	p = buf + strlen(buf) - 1;
667	while((p >= buf) && (*p == '\n'))
668	*(p--) = 0;
669	if(buf[0])
670	flog(LOG_INFO, "child said: %s", buf);
671	}
672	fclose(in);
673	}
674
675	static void serve(struct muth *muth, va_list args)
676	{
677	vavar(struct hthead *, req);
678	vavar(int, fd);
679	vavar(int, sfd);
680	FILE is, os, outi, outo, erri, erro;
681	struct charbuf head;
682	struct hthead *resp;
683	size_t read;
684	char buf[8192];
685
686	sfd = reconn();
687	is = mtstdopen(fd, 1, 60, "r+");
688	os = mtstdopen(sfd, 1, 600, "r+");
689
690	outi = NULL;
691	mtiopipe(&outi, &outo); mtiopipe(&erri, &erro);
692	mustart(outplex, mtstdopen(dup(sfd), 1, 600, "r+"), outo, FCGI_STDOUT, erro, FCGI_STDERR, NULL);
693	mustart(errhandler, erri);
694
695	if(begreq(os, 1))
696	goto out;
697	bufinit(head);
698	mkcgienv(req, &head);
699	if(sendrec(os, FCGI_PARAMS, 1, head.b, head.d))
700	goto out;
701	if(sendrec(os, FCGI_PARAMS, 1, NULL, 0))
702	goto out;
703	buffree(head);
704	if(fflush(os))
705	goto out;
706
707	while(!feof(is)) {
708	read = fread(buf, 1, sizeof(buf), is);
709	if(ferror(is))
710	goto out;
711	if(sendrec(os, FCGI_STDIN, 1, buf, read))
712	goto out;
713	}
714	if(sendrec(os, FCGI_STDIN, 1, NULL, 0))
715	goto out;
716	if(fflush(os))
717	goto out;
718
719	if((resp = parseresp(outi)) == NULL)
720	goto out;
721	writeresp(is, resp);
722	freehthead(resp);
723	fputc('\n', is);
724	if(passdata(outi, is) < 0)
725	goto out;
726
727	out:
728	freehthead(req);
729	buffree(head);
730	shutdown(sfd, SHUT_RDWR);
731	if(outi != NULL)
732	fclose(outi);
733	fclose(is);
734	fclose(os);
735	}
736
737	static void listenloop(struct muth *muth, va_list args)
738	{
739	vavar(int, lfd);
740	int fd;
741	struct hthead *req;
742
743	while(1) {
744	block(0, EV_READ, 0);
745	if((fd = recvreq(lfd, &req)) < 0) {
746	if(errno != 0)
747	flog(LOG_ERR, "recvreq: %s", strerror(errno));
748	break;
749	}
750	mustart(serve, req, fd);
751	}
752	}
753
754	static void sigign(int sig)
755	{
756	}
757
758	static void sigexit(int sig)
759	{
254eb937	760	shutdown(0, SHUT_RDWR);
5c2040da FT	761	}
	762
	763	static void usage(FILE *out)
	764	{
	765	fprintf(out, "usage: callfcgi [-h] [-N RETRIES] [-i ID] [-u UNIX-PATH] [-t [HOST:]TCP-PORT] [PROGRAM [ARGS...]]\n");
	766	}
	767
	768	int main(int argc, char **argv)
	769	{
	770	int c;
	771
	772	while((c = getopt(argc, argv, "+hN:i:u:t:")) >= 0) {
	773	switch(c) {
	774	case 'h':
	775	usage(stdout);
	776	exit(0);
	777	case 'N':
	778	nolisten = atoi(optarg);
	779	break;
	780	case 'i':
	781	sockid = optarg;
	782	break;
	783	case 'u':
	784	unspec = optarg;
	785	break;
	786	case 't':
	787	inspec = optarg;
	788	break;
	789	default:
	790	usage(stderr);
	791	exit(1);
	792	}
	793	}
	794	progspec = argv + optind;
	795	if(((sockid != NULL) + (unspec != NULL) + (inspec != NULL)) > 1) {
	796	flog(LOG_ERR, "callfcgi: at most one of -i, -u or -t may be given");
	797	exit(1);
	798	}
	799	signal(SIGCHLD, SIG_IGN);
	800	signal(SIGPIPE, sigign);
	801	signal(SIGINT, sigexit);
	802	signal(SIGTERM, sigexit);
	803	mustart(listenloop, 0);
5c2040da	804	ioloop();
d06b6013	805	killcuraddr();
5c2040da FT	806	return(0);
5c2040da FT	807	}