git.chise.org Git - chise/xemacs-chise.git.1/blob - lib-src/gnuserv.c

   1 /* -*-C-*-
   2  Server code for handling requests from clients and forwarding them
   3  on to the GNU Emacs process.
   4
   5  This file is part of GNU Emacs.
   6
   7  Copying is permitted under those conditions described by the GNU
   8  General Public License.
   9
  10  Copyright (C) 1989 Free Software Foundation, Inc.
  11
  12  Author: Andy Norman (ange@hplb.hpl.hp.com), based on 'etc/server.c'
  13          from the 18.52 GNU Emacs distribution.
  14
  15  Please mail bugs and suggestions to the author at the above address.
  16 */
  17
  18 /* HISTORY
  19  * 11-Nov-1990          bristor@simba
  20  *    Added EOT stuff.
  21  */
  22
  23 /*
  24  * This file incorporates new features added by Bob Weiner <weiner@mot.com>,
  25  * Darrell Kindred <dkindred@cmu.edu> and Arup Mukherjee <arup@cmu.edu>.
  26  * Please see the note at the end of the README file for details.
  27  *
  28  * (If gnuserv came bundled with your emacs, the README file is probably
  29  * ../etc/gnuserv.README relative to the directory containing this file)
  30  */
  31
  32 #if 0
  33 static char rcsid [] = "!Header: gnuserv.c,v 2.1 95/02/16 11:58:27 arup alpha !";
  34 #endif
  35
  36 #include "gnuserv.h"
  37
  38 #ifdef USE_LITOUT
  39 #ifdef linux
  40 #include <bsd/sgtty.h>
  41 #else
  42 #include <sgtty.h>
  43 #endif
  44 #endif
  45
  46 #ifdef AIX
  47 #include <sys/select.h>
  48 #endif
  49
  50 #include <stdlib.h>
  51 #include <stdio.h>
  52 #include <sys/types.h>
  53 #include <sys/stat.h>
  54
  55 #ifdef HAVE_UNISTD_H
  56 #include <unistd.h>
  57 #endif /* HAVE_UNISTD_H */
  58
  59 #ifdef HAVE_STRING_H
  60 #include <string.h>
  61 #endif /* HAVE_STRING_H */
  62
  63 #if !defined(SYSV_IPC) && !defined(UNIX_DOMAIN_SOCKETS) && \
  64     !defined(INTERNET_DOMAIN_SOCKETS)
  65 main ()
  66 {
  67   fprintf (stderr,"Sorry, the Emacs server is only supported on systems that have\n");
  68   fprintf (stderr,"Unix Domain sockets, Internet Domain sockets or System V IPC\n");
  69   exit (1);
  70 } /* main */
  71 #else /* SYSV_IPC || UNIX_DOMAIN_SOCKETS || INTERNET_DOMAIN_SOCKETS */
  72
  73 #ifdef SYSV_IPC
  74
  75 int ipc_qid = 0;                /* ipc message queue id */
  76 int ipc_wpid = 0;               /* watchdog task pid */
  77
  78
  79 /*
  80   ipc_exit -- clean up the queue id and queue, then kill the watchdog task
  81               if it exists. exit with the given status.
  82 */
  83 void
  84 ipc_exit (int stat)
  85 {
  86   msgctl (ipc_qid,IPC_RMID,0);
  87
  88   if  (ipc_wpid != 0)
  89     kill (ipc_wpid, SIGKILL);
  90
  91   exit (stat);
  92 } /* ipc_exit */
  93
  94
  95 /*
  96   ipc_handle_signal -- catch the signal given and clean up.
  97 */
  98 void
  99 ipc_handle_signal(int sig)
 100 {
 101   ipc_exit (0);
 102 } /* ipc_handle_signal */
 103
 104
 105 /*
 106   ipc_spawn_watchdog -- spawn a watchdog task to clean up the message queue should the
 107                         server process die.
 108 */
 109 void
 110 ipc_spawn_watchdog (void)
 111 {
 112   if ((ipc_wpid = fork ()) == 0)
 113     { /* child process */
 114       int ppid = getppid ();    /* parent's process id */
 115
 116       setpgrp();                /* gnu kills process group on exit */
 117
 118       while (1)
 119         {
 120           if (kill (ppid, 0) < 0) /* ppid is no longer valid, parent
 121                                      may have died */
 122             {
 123               ipc_exit (0);
 124             } /* if */
 125
 126           sleep(10);            /* have another go later */
 127         } /* while */
 128     } /* if */
 129
 130 } /* ipc_spawn_watchdog */
 131
 132
 133 /*
 134   ipc_init -- initialize server, setting the global msqid that can be listened on.
 135 */
 136 void
 137 ipc_init (struct msgbuf **msgpp)
 138 {
 139   key_t key;                    /* messge key */
 140   char buf[GSERV_BUFSZ];        /* pathname for key */
 141
 142   sprintf (buf,"%s/gsrv%d",tmpdir,(int)geteuid ());
 143   creat (buf,0600);
 144   key = ftok (buf,1);
 145
 146   if ((ipc_qid = msgget (key,0600|IPC_CREAT)) == -1)
 147     {
 148       perror (progname);
 149       fprintf (stderr, "%s: unable to create msg queue\n", progname);
 150       ipc_exit (1);
 151     } /* if */
 152
 153   ipc_spawn_watchdog ();
 154
 155   signal (SIGTERM,ipc_handle_signal);
 156   signal (SIGINT,ipc_handle_signal);
 157
 158   if ((*msgpp = (struct msgbuf *)
 159        malloc (sizeof **msgpp + GSERV_BUFSZ)) == NULL)
 160     {
 161       fprintf (stderr,
 162                "%s: unable to allocate space for message buffer\n", progname);
 163       ipc_exit(1);
 164     } /* if */
 165 } /* ipc_init */
 166
 167
 168 /*
 169   handle_ipc_request -- accept a request from a client, pass the request on
 170                         to the GNU Emacs process, then wait for its reply and
 171                         pass that on to the client.
 172 */
 173 void
 174 handle_ipc_request (struct msgbuf *msgp)
 175 {
 176   struct msqid_ds msg_st;       /* message status */
 177   char buf[GSERV_BUFSZ];
 178   int len;                      /* length of message / read */
 179   int s, result_len;            /* tag fields on the response from emacs */
 180   int offset = 0;
 181   int total = 1;                /* # bytes that will actually be sent off */
 182
 183   if ((len = msgrcv (ipc_qid, msgp, GSERV_BUFSZ - 1, 1, 0)) < 0)
 184     {
 185       perror (progname);
 186       fprintf (stderr, "%s: unable to receive\n", progname);
 187       ipc_exit (1);
 188     } /* if */
 189
 190   msgctl (ipc_qid, IPC_STAT, &msg_st);
 191   strncpy (buf, msgp->mtext, len);
 192   buf[len] = '\0';              /* terminate */
 193
 194   printf ("%d %s", ipc_qid, buf);
 195   fflush (stdout);
 196
 197   /* now for the response from gnu */
 198   msgp->mtext[0] = '\0';
 199
 200 #if 0
 201   if ((len = read(0,buf,GSERV_BUFSZ-1)) < 0)
 202     {
 203       perror (progname);
 204       fprintf (stderr, "%s: unable to read\n", progname);
 205       ipc_exit (1);
 206   } /* if */
 207
 208   sscanf (buf, "%d:%[^\n]\n", &junk, msgp->mtext);
 209 #else
 210
 211   /* read in "n/m:" (n=client fd, m=message length) */
 212
 213   while (offset < (GSERV_BUFSZ-1) &&
 214          ((len = read (0, buf + offset, 1)) > 0) &&
 215          buf[offset] != ':')
 216     {
 217       offset += len;
 218     }
 219
 220   if (len < 0)
 221     {
 222       perror (progname);
 223       fprintf (stderr, "%s: unable to read\n", progname);
 224       exit(1);
 225     }
 226
 227   /* parse the response from emacs, getting client fd & result length */
 228   buf[offset] = '\0';
 229   sscanf (buf, "%d/%d", &s, &result_len);
 230
 231   while (result_len > 0)
 232     {
 233       if ((len = read(0, buf, min2 (result_len, GSERV_BUFSZ - 1))) < 0)
 234         {
 235           perror (progname);
 236           fprintf (stderr, "%s: unable to read\n", progname);
 237           exit (1);
 238         }
 239
 240       /* Send this string off, but only if we have enough space */
 241
 242       if (GSERV_BUFSZ > total)
 243         {
 244           if (total + len <= GSERV_BUFSZ)
 245             buf[len] = 0;
 246           else
 247             buf[GSERV_BUFSZ - total] = 0;
 248
 249           send_string(s,buf);
 250           total += strlen(buf);
 251         }
 252
 253       result_len -= len;
 254     }
 255
 256   /* eat the newline */
 257   while ((len = read (0,buf,1)) == 0)
 258     ;
 259   if (len < 0)
 260     {
 261       perror(progname);
 262       fprintf (stderr,"%s: unable to read\n", progname);
 263       exit (1);
 264     }
 265   if (buf[0] != '\n')
 266     {
 267       fprintf (stderr,"%s: garbage after result [%c]\n", progname, buf[0]);
 268       exit (1);
 269     }
 270 #endif
 271
 272   /* Send a response back to the client. */
 273
 274   msgp->mtype = msg_st.msg_lspid;
 275   if (msgsnd (ipc_qid,msgp,strlen(msgp->mtext)+1,0) < 0)
 276     perror ("msgsend(gnuserv)");
 277
 278 } /* handle_ipc_request */
 279 #endif /* SYSV_IPC */
 280
 281
 282 #if defined(INTERNET_DOMAIN_SOCKETS) || defined(UNIX_DOMAIN_SOCKETS)
 283 /*
 284   echo_request -- read request from a given socket descriptor, and send the information
 285                   to stdout (the gnu process).
 286 */
 287 static void
 288 echo_request (int s)
 289 {
 290   char buf[GSERV_BUFSZ];
 291   int len;
 292
 293   printf("%d ",s);
 294
 295   /* read until we get a newline or no characters */
 296   while ((len = recv(s,buf,GSERV_BUFSZ-1,0)) > 0) {
 297     buf[len] = '\0';
 298     printf("%s",buf);
 299
 300     if (buf[len-1] == EOT_CHR) {
 301       fflush(stdout);
 302       break;                    /* end of message */
 303     }
 304
 305   } /* while */
 306
 307   if (len < 0) {
 308     perror(progname);
 309     fprintf(stderr,"%s: unable to recv\n",progname);
 310     exit(1);
 311   } /* if */
 312
 313 } /* echo_request */
 314
 315
 316 /*
 317   handle_response -- accept a response from stdin (the gnu process) and pass the
 318                      information on to the relevant client.
 319 */
 320 static void
 321 handle_response (void)
 322 {
 323   char buf[GSERV_BUFSZ+1];
 324   int offset=0;
 325   int s;
 326   int len;
 327   int result_len;
 328
 329   /* read in "n/m:" (n=client fd, m=message length) */
 330   while (offset < GSERV_BUFSZ &&
 331          ((len = read(0,buf+offset,1)) > 0) &&
 332          buf[offset] != ':') {
 333     offset += len;
 334   }
 335
 336   if (len < 0) {
 337     perror(progname);
 338     fprintf(stderr,"%s: unable to read\n",progname);
 339     exit(1);
 340   }
 341
 342   /* parse the response from emacs, getting client fd & result length */
 343   buf[offset] = '\0';
 344   sscanf(buf,"%d/%d", &s, &result_len);
 345
 346   while (result_len > 0) {
 347     if ((len = read(0,buf,min2(result_len,GSERV_BUFSZ))) < 0) {
 348       perror(progname);
 349       fprintf(stderr,"%s: unable to read\n",progname);
 350       exit(1);
 351     }
 352     buf[len] = '\0';
 353     send_string(s,buf);
 354     result_len -= len;
 355   }
 356
 357   /* eat the newline */
 358   while ((len = read(0,buf,1)) == 0)
 359     ;
 360   if (len < 0)
 361     {
 362       perror(progname);
 363       fprintf(stderr,"%s: unable to read\n",progname);
 364       exit(1);
 365     }
 366   if (buf[0] != '\n')
 367     {
 368       fprintf(stderr,"%s: garbage after result\n",progname);
 369       exit(1);
 370     }
 371   /* send the newline */
 372   buf[1] = '\0';
 373   send_string(s,buf);
 374   close(s);
 375
 376 } /* handle_response */
 377 #endif /* INTERNET_DOMAIN_SOCKETS || UNIX_DOMAIN_SOCKETS */
 378
 379
 380 #ifdef INTERNET_DOMAIN_SOCKETS
 381 struct entry {
 382   u_long host_addr;
 383   struct entry *next;
 384 };
 385
 386 struct entry *permitted_hosts[TABLE_SIZE];
 387
 388 #ifdef AUTH_MAGIC_COOKIE
 389 # include <X11/X.h>
 390 # include <X11/Xauth.h>
 391
 392 static Xauth *server_xauth = NULL;
 393 #endif
 394
 395 static int
 396 timed_read (int fd, char *buf, int max, int timeout, int one_line)
 397 {
 398   fd_set rmask;
 399   struct timeval tv; /* = {timeout, 0}; */
 400   char c = 0;
 401   int nbytes = 0;
 402   int r;
 403
 404   tv.tv_sec = timeout;
 405   tv.tv_usec = 0;
 406
 407   FD_ZERO(&rmask);
 408   FD_SET(fd, &rmask);
 409
 410   do
 411     {
 412       r = select(fd + 1, &rmask, NULL, NULL, &tv);
 413
 414       if (r > 0)
 415         {
 416           if (read (fd, &c, 1) == 1 )
 417             {
 418               *buf++ = c;
 419               ++nbytes;
 420             }
 421           else
 422             {
 423               printf ("read error on socket\004\n");
 424               return -1;
 425             }
 426         }
 427       else if (r == 0)
 428         {
 429           printf ("read timed out\004\n");
 430           return -1;
 431         }
 432       else
 433         {
 434           printf ("error in select\004\n");
 435           return -1;
 436         }
 437     } while ((nbytes < max) &&  !(one_line && (c == '\n')));
 438
 439   --buf;
 440   if (one_line && *buf == '\n')
 441     {
 442       *buf = 0;
 443     }
 444
 445   return nbytes;
 446 }
 447
 448
 449
 450 /*
 451   permitted -- return whether a given host is allowed to connect to the server.
 452 */
 453 static int
 454 permitted (u_long host_addr, int fd)
 455 {
 456   int key;
 457   struct entry *entry;
 458
 459   char auth_protocol[128];
 460   char buf[1024];
 461   int  auth_data_len;
 462
 463   if (fd > 0)
 464     {
 465       /* we are checking permission on a real connection */
 466
 467       /* Read auth protocol name */
 468
 469       if (timed_read(fd, auth_protocol, AUTH_NAMESZ, AUTH_TIMEOUT, 1) <= 0)
 470         return FALSE;
 471
 472       if (strcmp (auth_protocol, DEFAUTH_NAME) &&
 473           strcmp (auth_protocol, MCOOKIE_NAME))
 474         {
 475           printf ("authentication protocol (%s) from client is invalid...\n",
 476                   auth_protocol);
 477           printf ("... Was the client an old version of gnuclient/gnudoit?\004\n");
 478
 479           return FALSE;
 480         }
 481
 482       if (!strcmp(auth_protocol, MCOOKIE_NAME))
 483         {
 484
 485           /*
 486            * doing magic cookie auth
 487            */
 488
 489           if (timed_read(fd, buf, 10, AUTH_TIMEOUT, 1) <= 0)
 490             return FALSE;
 491
 492           auth_data_len = atoi(buf);
 493
 494           if (timed_read(fd, buf, auth_data_len, AUTH_TIMEOUT, 0) != auth_data_len)
 495             return FALSE;
 496
 497 #ifdef AUTH_MAGIC_COOKIE
 498           if (server_xauth && server_xauth->data &&
 499               !memcmp(buf, server_xauth->data, auth_data_len))
 500             {
 501               return TRUE;
 502             }
 503 #else
 504           printf ("client tried Xauth, but server is not compiled with Xauth\n");
 505 #endif
 506
 507       /*
 508        * auth failed, but allow this to fall through to the GNU_SECURE
 509        * protocol....
 510        */
 511
 512           printf ("Xauth authentication failed, trying GNU_SECURE auth...\004\n");
 513
 514         }
 515
 516       /* Other auth protocols go here, and should execute only if the
 517        * auth_protocol name matches.
 518        */
 519
 520     }
 521
 522
 523   /* Now, try the old GNU_SECURE stuff... */
 524
 525   /* First find the hash key */
 526   key = HASH(host_addr) % TABLE_SIZE;
 527
 528   /* Now check the chain for that hash key */
 529   for(entry=permitted_hosts[key]; entry != NULL; entry=entry->next)
 530     if (host_addr == entry->host_addr)
 531       return(TRUE);
 532
 533   return(FALSE);
 534
 535 } /* permitted */
 536
 537
 538 /*
 539   add_host -- add the given host to the list of permitted hosts, provided it isn't
 540               already there.
 541 */
 542 static void
 543 add_host (u_long host_addr)
 544 {
 545   int key;
 546   struct entry *new_entry;
 547
 548   if (!permitted(host_addr, -1))
 549     {
 550       if ((new_entry = (struct entry *) malloc(sizeof(struct entry))) == NULL) {
 551         fprintf(stderr,"%s: unable to malloc space for permitted host entry\n",
 552                 progname);
 553         exit(1);
 554       } /* if */
 555
 556       new_entry->host_addr = host_addr;
 557       key = HASH(host_addr) % TABLE_SIZE;
 558       new_entry->next = permitted_hosts[key];
 559       permitted_hosts[key] = new_entry;
 560     } /* if */
 561
 562 } /* add_host */
 563
 564
 565 /*
 566   setup_table -- initialise the table of hosts allowed to contact the server,
 567                  by reading from the file specified by the GNU_SECURE
 568                  environment variable
 569                  Put in the local machine, and, if a security file is specifed,
 570                  add each host that is named in the file.
 571                  Return the number of hosts added.
 572 */
 573 static int
 574 setup_table (void)
 575 {
 576   FILE *host_file;
 577   char *file_name;
 578   char hostname[HOSTNAMSZ];
 579   u_int host_addr;
 580   int i, hosts=0;
 581
 582   /* Make sure every entry is null */
 583   for (i=0; i<TABLE_SIZE; i++)
 584     permitted_hosts[i] = NULL;
 585
 586   gethostname(hostname,HOSTNAMSZ);
 587
 588   if ((host_addr = internet_addr(hostname)) == -1)
 589     {
 590       fprintf(stderr,"%s: unable to find %s in /etc/hosts or from YP",
 591               progname,hostname);
 592       exit(1);
 593     } /* if */
 594
 595 #ifdef AUTH_MAGIC_COOKIE
 596
 597   server_xauth = XauGetAuthByAddr (FamilyInternet,
 598                                    sizeof(host_addr), (char *)&host_addr,
 599                                    strlen(MCOOKIE_SCREEN), MCOOKIE_SCREEN,
 600                                    strlen(MCOOKIE_X_NAME), MCOOKIE_X_NAME);
 601   hosts++;
 602
 603 #endif /* AUTH_MAGIC_COOKIE */
 604
 605
 606 #if 0 /* Don't even want to allow access from the local host by default */
 607   add_host(host_addr);                                  /* add local host */
 608 #endif
 609
 610   if (((file_name = getenv("GNU_SECURE")) != NULL &&    /* security file  */
 611        (host_file = fopen(file_name,"r")) != NULL))     /* opened ok */
 612     {
 613       while ((fscanf(host_file,"%s",hostname) != EOF))  /* find a host */
 614         if ((host_addr = internet_addr(hostname)) != -1)/* get its addr */
 615           {
 616             add_host(host_addr);                                /* add the addr */
 617             hosts++;
 618           }
 619       fclose(host_file);
 620     } /* if */
 621
 622   return hosts;
 623 } /* setup_table */
 624
 625
 626 /*
 627   internet_init -- initialize server, returning an internet socket that can
 628                     be listened on.
 629 */
 630 static int
 631 internet_init (void)
 632 {
 633   int ls;                       /* socket descriptor */
 634   struct servent *sp;           /* pointer to service information */
 635   struct sockaddr_in server;    /* for local socket address */
 636   char *ptr;                    /* ptr to return from getenv */
 637
 638   if (setup_table() == 0)
 639     return -1;
 640
 641   /* clear out address structure */
 642   memset((char *)&server,0,sizeof(struct sockaddr_in));
 643
 644   /* Set up address structure for the listen socket. */
 645   server.sin_family = AF_INET;
 646   server.sin_addr.s_addr = INADDR_ANY;
 647
 648   /* Find the information for the gnu server
 649    * in order to get the needed port number.
 650    */
 651   if ((ptr=getenv("GNU_PORT")) != NULL)
 652     server.sin_port = htons(atoi(ptr));
 653   else if ((sp = getservbyname ("gnuserv", "tcp")) == NULL)
 654     server.sin_port = htons(DEFAULT_PORT+getuid());
 655   else
 656     server.sin_port = sp->s_port;
 657
 658   /* Create the listen socket. */
 659   if ((ls = socket (AF_INET,SOCK_STREAM, 0)) == -1)
 660     {
 661       perror(progname);
 662       fprintf(stderr,"%s: unable to create socket\n",progname);
 663       exit(1);
 664     } /* if */
 665
 666   /* Bind the listen address to the socket. */
 667   if (bind(ls,(struct sockaddr *) &server,sizeof(struct sockaddr_in)) == -1)
 668     {
 669       perror(progname);
 670       fprintf(stderr,"%s: unable to bind socket\n",progname);
 671       exit(1);
 672     } /* if */
 673
 674   /* Initiate the listen on the socket so remote users
 675    * can connect.
 676    */
 677   if (listen(ls,20) == -1)
 678     {
 679       perror(progname);
 680       fprintf(stderr,"%s: unable to listen\n",progname);
 681       exit(1);
 682     } /* if */
 683
 684   return(ls);
 685
 686 } /* internet_init */
 687
 688
 689 /*
 690   handle_internet_request -- accept a request from a client and send the information
 691                              to stdout (the gnu process).
 692 */
 693 static void
 694 handle_internet_request (int ls)
 695 {
 696   int s;
 697   size_t addrlen = sizeof(struct sockaddr_in);
 698   struct sockaddr_in peer;      /* for peer socket address */
 699
 700   memset((char *)&peer,0,sizeof(struct sockaddr_in));
 701
 702   if ((s = accept(ls,(struct sockaddr *)&peer, (void *) &addrlen)) == -1)
 703     {
 704       perror(progname);
 705       fprintf(stderr,"%s: unable to accept\n",progname);
 706       exit(1);
 707     } /* if */
 708
 709   /* Check that access is allowed - if not return crud to the client */
 710   if (!permitted(peer.sin_addr.s_addr, s))
 711     {
 712       send_string(s,"gnudoit: Connection refused\ngnudoit: unable to connect to remote");
 713       close(s);
 714
 715       printf("Refused connection from %s\004\n", inet_ntoa(peer.sin_addr));
 716       return;
 717     } /* if */
 718
 719   echo_request(s);
 720
 721 } /* handle_internet_request */
 722 #endif /* INTERNET_DOMAIN_SOCKETS */
 723
 724
 725 #ifdef UNIX_DOMAIN_SOCKETS
 726 /*
 727   unix_init -- initialize server, returning an unix-domain socket that can
 728                be listened on.
 729 */
 730 static int
 731 unix_init (void)
 732 {
 733   int ls;                       /* socket descriptor */
 734   struct sockaddr_un server;    /* unix socket address */
 735   int bindlen;
 736
 737   if ((ls = socket(AF_UNIX,SOCK_STREAM, 0)) < 0)
 738     {
 739       perror(progname);
 740       fprintf(stderr,"%s: unable to create socket\n",progname);
 741       exit(1);
 742     } /* if */
 743
 744   /* Set up address structure for the listen socket. */
 745 #ifdef HIDE_UNIX_SOCKET
 746   sprintf(server.sun_path,"%s/gsrvdir%d",tmpdir,(int)geteuid());
 747   if (mkdir(server.sun_path, 0700) < 0)
 748     {
 749       /* assume it already exists, and try to set perms */
 750       if (chmod(server.sun_path, 0700) < 0)
 751         {
 752           perror(progname);
 753           fprintf(stderr,"%s: can't set permissions on %s\n",
 754                   progname, server.sun_path);
 755           exit(1);
 756         }
 757     }
 758   strcat(server.sun_path,"/gsrv");
 759   unlink(server.sun_path);      /* remove old file if it exists */
 760 #else /* HIDE_UNIX_SOCKET */
 761   sprintf(server.sun_path,"%s/gsrv%d",tmpdir,(int)geteuid());
 762   unlink(server.sun_path);      /* remove old file if it exists */
 763 #endif /* HIDE_UNIX_SOCKET */
 764
 765   server.sun_family = AF_UNIX;
 766 #ifdef HAVE_SOCKADDR_SUN_LEN
 767   /* See W. R. Stevens "Advanced Programming in the Unix Environment"
 768      p. 502 */
 769   bindlen = (sizeof (server.sun_len) + sizeof (server.sun_family)
 770              + strlen (server.sun_path) + 1);
 771   server.sun_len = bindlen;
 772 #else
 773   bindlen = strlen (server.sun_path) + sizeof (server.sun_family);
 774 #endif
 775
 776   if (bind(ls,(struct sockaddr *)&server,bindlen) < 0)
 777     {
 778       perror(progname);
 779       fprintf(stderr,"%s: unable to bind socket\n",progname);
 780       exit(1);
 781     } /* if */
 782
 783   chmod(server.sun_path,0700);  /* only this user can send commands */
 784
 785   if (listen(ls,20) < 0) {
 786     perror(progname);
 787     fprintf(stderr,"%s: unable to listen\n",progname);
 788     exit(1);
 789   } /* if */
 790
 791   /* #### there are also better ways of dealing with this when
 792      sigvec() is present. */
 793 #if  defined (HAVE_SIGPROCMASK)
 794   {
 795   sigset_t _mask;
 796   sigemptyset (&_mask);
 797   sigaddset (&_mask, SIGPIPE);
 798   sigprocmask (SIG_BLOCK, &_mask, NULL);
 799   }
 800 #else
 801   signal(SIGPIPE,SIG_IGN);      /* in case user kills client */
 802 #endif
 803
 804   return(ls);
 805
 806 } /* unix_init */
 807
 808
 809 /*
 810   handle_unix_request -- accept a request from a client and send the information
 811                          to stdout (the gnu process).
 812 */
 813 static void
 814 handle_unix_request (int ls)
 815 {
 816   int s;
 817   size_t len = sizeof(struct sockaddr_un);
 818   struct sockaddr_un server;    /* for unix socket address */
 819
 820   server.sun_family = AF_UNIX;
 821
 822   if ((s = accept(ls,(struct sockaddr *)&server, (void *)&len)) < 0)
 823     {
 824       perror(progname);
 825       fprintf(stderr,"%s: unable to accept\n",progname);
 826     } /* if */
 827
 828   echo_request(s);
 829
 830 } /* handle_unix_request */
 831 #endif /* UNIX_DOMAIN_SOCKETS */
 832
 833
 834 int
 835 main(argc,argv)
 836      int argc;
 837      char *argv[];
 838 {
 839   int chan;                     /* temporary channel number */
 840 #ifdef SYSV_IPC
 841   struct msgbuf *msgp;          /* message buffer */
 842 #else
 843   int ils = -1;                 /* internet domain listen socket */
 844   int uls = -1;                 /* unix domain listen socket */
 845 #endif /* SYSV_IPC */
 846
 847   progname = argv[0];
 848
 849   for(chan=3; chan < _NFILE; close(chan++)) /* close unwanted channels */
 850     ;
 851
 852 #ifdef USE_TMPDIR
 853   tmpdir = getenv("TMPDIR");
 854 #endif
 855   if (!tmpdir)
 856     tmpdir = "/tmp";
 857 #ifdef USE_LITOUT
 858   {
 859     /* this is to allow ^D to pass to emacs */
 860     int d = LLITOUT;
 861     (void) ioctl(fileno(stdout), TIOCLBIS, &d);
 862   }
 863 #endif
 864
 865 #ifdef SYSV_IPC
 866   ipc_init(&msgp);              /* get a msqid to listen on, and a message buffer */
 867 #endif /* SYSV_IPC */
 868
 869 #ifdef INTERNET_DOMAIN_SOCKETS
 870   ils = internet_init();        /* get a internet domain socket to listen on */
 871 #endif /* INTERNET_DOMAIN_SOCKETS */
 872
 873 #ifdef UNIX_DOMAIN_SOCKETS
 874   uls = unix_init();            /* get a unix domain socket to listen on */
 875 #endif /* UNIX_DOMAIN_SOCKETS */
 876
 877   while (1) {
 878 #ifdef SYSV_IPC
 879     handle_ipc_request(msgp);
 880 #else /* NOT SYSV_IPC */
 881     fd_set rmask;
 882     FD_ZERO(&rmask);
 883     FD_SET(fileno(stdin), &rmask);
 884     if (uls >= 0)
 885       FD_SET(uls, &rmask);
 886     if (ils >= 0)
 887       FD_SET(ils, &rmask);
 888
 889     if (select(max2(fileno(stdin),max2(uls,ils)) + 1, &rmask,
 890                (fd_set *)NULL, (fd_set *)NULL, (struct timeval *)NULL) < 0)
 891       {
 892         perror(progname);
 893         fprintf(stderr,"%s: unable to select\n",progname);
 894         exit(1);
 895       } /* if */
 896
 897 #ifdef UNIX_DOMAIN_SOCKETS
 898     if (uls > 0 && FD_ISSET(uls, &rmask))
 899       handle_unix_request(uls);
 900 #endif
 901
 902 #ifdef INTERNET_DOMAIN_SOCKETS
 903     if (ils > 0 && FD_ISSET(ils, &rmask))
 904       handle_internet_request(ils);
 905 #endif /* INTERNET_DOMAIN_SOCKETS */
 906
 907     if (FD_ISSET(fileno(stdin), &rmask))      /* from stdin (gnu process) */
 908       handle_response();
 909 #endif /* NOT SYSV_IPC */
 910   } /* while */
 911
 912   return 0;
 913 } /* main */
 914
 915 #endif /* SYSV_IPC || UNIX_DOMAIN_SOCKETS || INTERNET_DOMAIN_SOCKETS */