src/callfcgi.c

   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>
  40 #include <signal.h>
  41 #include <errno.h>
  42
  43 #ifdef HAVE_CONFIG_H
  44 #include <config.h>
  45 #endif
  46 #include <utils.h>
  47 #include <req.h>
  48 #include <resp.h>
  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));
 212         _exit(127);
 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));
 230             _exit(127);
 231         }
 232         dup2(fd, 0);
 233         close(fd);
 234         execvp(*progspec, progspec);
 235         flog(LOG_ERR, "callfcgi: %s: %s", *progspec, strerror(errno));
 236         _exit(127);
 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;
 445     char *url, *pi, *tmp, *qp, *h, *p;
 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);
 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))) {
 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);
 469     }
 470     bufaddenv(dst, "PATH_INFO", pi);
 471     bufaddenv(dst, "SCRIPT_NAME", url);
 472     bufaddenv(dst, "QUERY_STRING", "%s", qp?qp:"");
 473     free(pi);
 474     free(url);
 475     if((h = getheader(req, "Host")) != NULL)
 476         bufaddenv(dst, "SERVER_NAME", "%s", h);
 477     if((h = getheader(req, "X-Ash-Server-Address")) != NULL)
 478         bufaddenv(dst, "SERVER_ADDR", "%s", h);
 479     if((h = getheader(req, "X-Ash-Server-Port")) != NULL)
 480         bufaddenv(dst, "SERVER_PORT", "%s", h);
 481     if((h = getheader(req, "X-Ash-Remote-User")) != NULL)
 482         bufaddenv(dst, "REMOTE_USER", "%s", h);
 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);
 487     if((h = getheader(req, "X-Ash-Port")) != NULL)
 488         bufaddenv(dst, "REMOTE_PORT", "%s", h);
 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");
 495     if((h = getheader(req, "X-Ash-File")) != NULL) {
 496         h = absolutify(h);
 497         bufaddenv(dst, "SCRIPT_FILENAME", "%s", h);
 498         free(h);
 499     }
 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
 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);
 531             resp->msg = sstrdup(httpdefstatus(resp->code));
 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
 572 static int recvrec(FILE *in, int *type, int *rid, char **data, size_t *dlen)
 573 {
 574     unsigned char header[8];
 575     int tl;
 576
 577     if(fread(header, 1, 8, in) != 8)
 578         return(-1);
 579     if(header[0] != 1)
 580         return(-1);
 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)
 586         return(-1);
 587     *data = smalloc(max(tl, 1));
 588     if(fread(*data, 1, tl, in) != tl) {
 589         free(*data);
 590         return(-1);
 591     }
 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
 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 {
 760     shutdown(0, SHUT_RDWR);
 761     exit(0);
 762 }
 763
 764 static void usage(FILE *out)
 765 {
 766     fprintf(out, "usage: callfcgi [-h] [-N RETRIES] [-i ID] [-u UNIX-PATH] [-t [HOST:]TCP-PORT] [PROGRAM [ARGS...]]\n");
 767 }
 768
 769 int main(int argc, char **argv)
 770 {
 771     int c;
 772
 773     while((c = getopt(argc, argv, "+hN:i:u:t:")) >= 0) {
 774         switch(c) {
 775         case 'h':
 776             usage(stdout);
 777             exit(0);
 778         case 'N':
 779             nolisten = atoi(optarg);
 780             break;
 781         case 'i':
 782             sockid = optarg;
 783             break;
 784         case 'u':
 785             unspec = optarg;
 786             break;
 787         case 't':
 788             inspec = optarg;
 789             break;
 790         default:
 791             usage(stderr);
 792             exit(1);
 793         }
 794     }
 795     progspec = argv + optind;
 796     if(((sockid != NULL) + (unspec != NULL) + (inspec != NULL)) > 1) {
 797         flog(LOG_ERR, "callfcgi: at most one of -i, -u or -t may be given");
 798         exit(1);
 799     }
 800     signal(SIGCHLD, SIG_IGN);
 801     signal(SIGPIPE, sigign);
 802     signal(SIGINT, sigexit);
 803     signal(SIGTERM, sigexit);
 804     mustart(listenloop, 0);
 805     atexit(killcuraddr);
 806     ioloop();
 807     return(0);
 808 }