XEmacs 21.2.20 "Yoko".
[chise/xemacs-chise.git.1] / 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 = 0;
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 -- initialize 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 (int argc, char *argv[])
836 {
837   int chan;                     /* temporary channel number */
838 #ifdef SYSV_IPC
839   struct msgbuf *msgp;          /* message buffer */
840 #else
841   int ils = -1;                 /* internet domain listen socket */
842   int uls = -1;                 /* unix domain listen socket */
843 #endif /* SYSV_IPC */
844
845   progname = argv[0];
846
847   for(chan=3; chan < _NFILE; close(chan++)) /* close unwanted channels */
848     ;
849
850 #ifdef USE_TMPDIR
851   tmpdir = getenv("TMPDIR");
852 #endif
853   if (!tmpdir)
854     tmpdir = "/tmp";
855 #ifdef USE_LITOUT
856   {
857     /* this is to allow ^D to pass to emacs */
858     int d = LLITOUT;
859     (void) ioctl(fileno(stdout), TIOCLBIS, &d);
860   }
861 #endif
862
863 #ifdef SYSV_IPC
864   ipc_init(&msgp);              /* get a msqid to listen on, and a message buffer */
865 #endif /* SYSV_IPC */
866
867 #ifdef INTERNET_DOMAIN_SOCKETS
868   ils = internet_init();        /* get an internet domain socket to listen on */
869 #endif /* INTERNET_DOMAIN_SOCKETS */
870
871 #ifdef UNIX_DOMAIN_SOCKETS
872   uls = unix_init();            /* get a unix domain socket to listen on */
873 #endif /* UNIX_DOMAIN_SOCKETS */
874
875   while (1) {
876 #ifdef SYSV_IPC
877     handle_ipc_request(msgp);
878 #else /* NOT SYSV_IPC */
879     fd_set rmask;
880     FD_ZERO(&rmask);
881     FD_SET(fileno(stdin), &rmask);
882     if (uls >= 0)
883       FD_SET(uls, &rmask);
884     if (ils >= 0)
885       FD_SET(ils, &rmask);
886     
887     if (select(max2(fileno(stdin),max2(uls,ils)) + 1, &rmask, 
888                (fd_set *)NULL, (fd_set *)NULL, (struct timeval *)NULL) < 0)
889       {
890         perror(progname);
891         fprintf(stderr,"%s: unable to select\n",progname);
892         exit(1);
893       } /* if */
894
895 #ifdef UNIX_DOMAIN_SOCKETS
896     if (uls > 0 && FD_ISSET(uls, &rmask))
897       handle_unix_request(uls);
898 #endif
899
900 #ifdef INTERNET_DOMAIN_SOCKETS
901     if (ils > 0 && FD_ISSET(ils, &rmask))
902       handle_internet_request(ils);
903 #endif /* INTERNET_DOMAIN_SOCKETS */
904
905     if (FD_ISSET(fileno(stdin), &rmask))      /* from stdin (gnu process) */
906       handle_response();
907 #endif /* NOT SYSV_IPC */
908   } /* while */
909
910   return 0;
911 } /* main */
912
913 #endif /* SYSV_IPC || UNIX_DOMAIN_SOCKETS || INTERNET_DOMAIN_SOCKETS */