|
428
|
1 /* -*-C-*-
|
|
613
|
2 Common library code for the XEmacs server and client.
|
|
428
|
3
|
|
613
|
4 This file is part of XEmacs.
|
|
428
|
5
|
|
|
6 Copying is permitted under those conditions described by the GNU
|
|
|
7 General Public License.
|
|
|
8
|
|
|
9 Copyright (C) 1989 Free Software Foundation, Inc.
|
|
|
10
|
|
|
11 Author: Andy Norman (ange@hplb.hpl.hp.com), based on
|
|
|
12 'etc/server.c' and 'etc/emacsclient.c' from the 18.52 GNU
|
|
|
13 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: gnuslib.c,v 2.4 95/02/16 11:57:37 arup alpha !";
|
|
|
34 #endif
|
|
|
35
|
|
|
36 #include "gnuserv.h"
|
|
|
37 #include <errno.h>
|
|
|
38
|
|
|
39 #ifdef SYSV_IPC
|
|
|
40 static int connect_to_ipc_server (void);
|
|
|
41 #endif
|
|
|
42 #ifdef UNIX_DOMAIN_SOCKETS
|
|
|
43 static int connect_to_unix_server (void);
|
|
|
44 #endif
|
|
|
45 #ifdef INTERNET_DOMAIN_SOCKETS
|
|
458
|
46 static int connect_to_internet_server (char *serverhost, unsigned short port);
|
|
428
|
47 #endif
|
|
|
48
|
|
|
49 /* On some systems, e.g. DGUX, inet_addr returns a 'struct in_addr'. */
|
|
|
50 #ifdef HAVE_BROKEN_INET_ADDR
|
|
|
51 # define IN_ADDR struct in_addr
|
|
|
52 # define NUMERIC_ADDR_ERROR (numeric_addr.s_addr == -1)
|
|
|
53 #else
|
|
|
54 # if (LONGBITS > 32)
|
|
|
55 # define IN_ADDR unsigned int
|
|
|
56 # else
|
|
|
57 # define IN_ADDR unsigned long
|
|
|
58 # endif
|
|
|
59 # define NUMERIC_ADDR_ERROR (numeric_addr == (IN_ADDR) -1)
|
|
|
60 #endif
|
|
|
61
|
|
|
62 #include <stdlib.h>
|
|
|
63 #include <stdio.h>
|
|
|
64 #include <sys/types.h>
|
|
|
65 #include <sys/stat.h>
|
|
|
66 #ifdef HAVE_UNISTD_H
|
|
|
67 #include <unistd.h>
|
|
|
68 #endif /* HAVE_UNISTD_H */
|
|
|
69 #ifdef HAVE_STRING_H
|
|
|
70 #include <string.h>
|
|
|
71 #endif /* HAVE_STRING_H */
|
|
|
72
|
|
|
73 #include <arpa/inet.h>
|
|
|
74
|
|
|
75 char *tmpdir = NULL;
|
|
|
76
|
|
|
77 char *progname = NULL;
|
|
|
78
|
|
440
|
79 int
|
|
|
80 make_connection (char *hostarg, int portarg, int *s)
|
|
428
|
81 {
|
|
|
82 #ifdef INTERNET_DOMAIN_SOCKETS
|
|
|
83 char *ptr;
|
|
|
84 if (hostarg == NULL)
|
|
|
85 hostarg = getenv("GNU_HOST");
|
|
|
86 if (portarg == 0 && (ptr=getenv("GNU_PORT")) != NULL)
|
|
|
87 portarg = atoi(ptr);
|
|
|
88 #endif
|
|
|
89
|
|
|
90 if (hostarg != NULL) {
|
|
|
91 /* hostname was given explicitly, via cmd line arg or GNU_HOST,
|
|
|
92 * so obey it. */
|
|
|
93 #ifdef UNIX_DOMAIN_SOCKETS
|
|
|
94 if (!strcmp(hostarg, "unix")) {
|
|
|
95 *s = connect_to_unix_server();
|
|
|
96 return (int) CONN_UNIX;
|
|
|
97 }
|
|
|
98 #endif /* UNIX_DOMAIN_SOCKETS */
|
|
|
99 #ifdef INTERNET_DOMAIN_SOCKETS
|
|
|
100 *s = connect_to_internet_server(hostarg, portarg);
|
|
|
101 return (int) CONN_INTERNET;
|
|
|
102 #endif
|
|
|
103 #ifdef SYSV_IPC
|
|
|
104 return -1; /* hostarg should always be NULL for SYSV_IPC */
|
|
|
105 #endif
|
|
|
106 } else {
|
|
|
107 /* no hostname given. Use unix-domain/sysv-ipc, or
|
|
|
108 * internet-domain connection to local host if they're not available. */
|
|
|
109 #if defined(UNIX_DOMAIN_SOCKETS)
|
|
|
110 *s = connect_to_unix_server();
|
|
|
111 return (int) CONN_UNIX;
|
|
|
112 #elif defined(SYSV_IPC)
|
|
|
113 *s = connect_to_ipc_server();
|
|
|
114 return (int) CONN_IPC;
|
|
|
115 #elif defined(INTERNET_DOMAIN_SOCKETS)
|
|
|
116 {
|
|
|
117 char localhost[HOSTNAMSZ];
|
|
|
118 gethostname(localhost,HOSTNAMSZ); /* use this host by default */
|
|
|
119 *s = connect_to_internet_server(localhost, portarg);
|
|
|
120 return (int) CONN_INTERNET;
|
|
|
121 }
|
|
|
122 #endif /* IPC type */
|
|
|
123 }
|
|
|
124 }
|
|
|
125
|
|
|
126 #ifdef SYSV_IPC
|
|
|
127 /*
|
|
|
128 connect_to_ipc_server -- establish connection with server process via SYSV IPC
|
|
|
129 Returns msqid for server if successful.
|
|
|
130 */
|
|
440
|
131 static int
|
|
|
132 connect_to_ipc_server (void)
|
|
428
|
133 {
|
|
|
134 int s; /* connected msqid */
|
|
|
135 key_t key; /* message key */
|
|
|
136 char buf[GSERV_BUFSZ+1]; /* buffer for filename */
|
|
|
137
|
|
|
138 sprintf(buf,"%s/gsrv%d",tmpdir,(int)geteuid());
|
|
|
139 creat(buf,0600);
|
|
|
140 if ((key = ftok(buf,1)) == -1) {
|
|
|
141 perror(progname);
|
|
|
142 fprintf(stderr, "%s: unable to get ipc key from %s\n",
|
|
|
143 progname, buf);
|
|
|
144 exit(1);
|
|
|
145 }
|
|
|
146
|
|
|
147 if ((s = msgget(key,0600)) == -1) {
|
|
|
148 perror(progname);
|
|
|
149 fprintf(stderr,"%s: unable to access msg queue\n",progname);
|
|
|
150 exit(1);
|
|
|
151 }; /* if */
|
|
|
152
|
|
|
153 return(s);
|
|
|
154
|
|
|
155 } /* connect_to_ipc_server */
|
|
|
156
|
|
|
157
|
|
|
158 /*
|
|
|
159 disconnect_from_ipc_server -- inform the server that sending has finished,
|
|
|
160 and wait for its reply.
|
|
|
161 */
|
|
440
|
162 void
|
|
|
163 disconnect_from_ipc_server (int s, struct msgbuf *msgp, int echo)
|
|
428
|
164 {
|
|
|
165 int len; /* length of received message */
|
|
|
166
|
|
|
167 send_string(s,EOT_STR); /* EOT terminates this message */
|
|
|
168 msgp->mtype = 1;
|
|
|
169
|
|
|
170 if(msgsnd(s,msgp,strlen(msgp->mtext)+1,0) < 0) {
|
|
|
171 perror(progname);
|
|
|
172 fprintf(stderr,"%s: unable to send message to server\n",progname);
|
|
|
173 exit(1);
|
|
|
174 }; /* if */
|
|
|
175
|
|
|
176 if((len = msgrcv(s,msgp,GSERV_BUFSZ,getpid(),0)) < 0) {
|
|
|
177 perror(progname);
|
|
|
178 fprintf(stderr,"%s: unable to receive message from server\n",progname);
|
|
|
179 exit(1);
|
|
|
180 }; /* if */
|
|
|
181
|
|
|
182 if (echo) {
|
|
|
183 msgp->mtext[len] = '\0'; /* string terminate message */
|
|
|
184 fputs(msgp->mtext, stdout);
|
|
|
185 if (msgp->mtext[len-1] != '\n') putchar ('\n');
|
|
|
186 }; /* if */
|
|
|
187
|
|
|
188 } /* disconnect_from_ipc_server */
|
|
|
189 #endif /* SYSV_IPC */
|
|
|
190
|
|
|
191
|
|
|
192 #if defined(INTERNET_DOMAIN_SOCKETS) || defined(UNIX_DOMAIN_SOCKETS)
|
|
|
193 /*
|
|
|
194 send_string -- send string to socket.
|
|
|
195 */
|
|
440
|
196 void
|
|
442
|
197 send_string (int s, const char *msg)
|
|
428
|
198 {
|
|
|
199 #if 0
|
|
|
200 if (send(s,msg,strlen(msg),0) < 0) {
|
|
|
201 perror(progname);
|
|
|
202 fprintf(stderr,"%s: unable to send\n",progname);
|
|
|
203 exit(1);
|
|
|
204 }; /* if */
|
|
|
205 #else
|
|
|
206 int len, left=strlen(msg);
|
|
|
207 while (left > 0) {
|
|
|
208 if ((len=write(s,msg,min2(left,GSERV_BUFSZ))) < 0) {
|
|
|
209 /* XEmacs addition: robertl@arnet.com */
|
|
|
210 if (errno == EPIPE) {
|
|
|
211 return ;
|
|
|
212 }
|
|
|
213 perror(progname);
|
|
|
214 fprintf(stderr,"%s: unable to send\n",progname);
|
|
|
215 exit(1);
|
|
|
216 }; /* if */
|
|
|
217 left -= len;
|
|
|
218 msg += len;
|
|
|
219 }; /* while */
|
|
|
220 #endif
|
|
|
221 } /* send_string */
|
|
|
222
|
|
|
223 /*
|
|
|
224 read_line -- read a \n terminated line from a socket
|
|
|
225 */
|
|
440
|
226 int
|
|
|
227 read_line (int s, char *dest)
|
|
428
|
228 {
|
|
|
229 int length;
|
|
|
230 int offset=0;
|
|
|
231 char buffer[GSERV_BUFSZ+1];
|
|
|
232
|
|
|
233 while ((length=read(s,buffer+offset,1)>0) && buffer[offset]!='\n'
|
|
|
234 && buffer[offset] != EOT_CHR) {
|
|
|
235 offset += length;
|
|
|
236 if (offset >= GSERV_BUFSZ)
|
|
|
237 break;
|
|
|
238 }
|
|
|
239 buffer[offset] = '\0';
|
|
|
240 strcpy(dest,buffer);
|
|
|
241 return 1;
|
|
|
242 } /* read_line */
|
|
|
243 #endif /* INTERNET_DOMAIN_SOCKETS || UNIX_DOMAIN_SOCKETS */
|
|
|
244
|
|
|
245
|
|
|
246 #ifdef UNIX_DOMAIN_SOCKETS
|
|
|
247 /*
|
|
|
248 connect_to_unix_server -- establish connection with server process via a unix-
|
|
|
249 domain socket. Returns socket descriptor for server
|
|
|
250 if successful.
|
|
|
251 */
|
|
440
|
252 static int
|
|
|
253 connect_to_unix_server (void)
|
|
428
|
254 {
|
|
|
255 int s; /* connected socket descriptor */
|
|
|
256 struct sockaddr_un server; /* for unix connections */
|
|
|
257
|
|
|
258 if ((s = socket(AF_UNIX,SOCK_STREAM,0)) < 0) {
|
|
|
259 perror(progname);
|
|
|
260 fprintf(stderr,"%s: unable to create socket\n",progname);
|
|
|
261 exit(1);
|
|
|
262 }; /* if */
|
|
|
263
|
|
|
264 server.sun_family = AF_UNIX;
|
|
|
265 #ifdef HIDE_UNIX_SOCKET
|
|
|
266 sprintf(server.sun_path,"%s/gsrvdir%d/gsrv",tmpdir,(int)geteuid());
|
|
|
267 #else /* HIDE_UNIX_SOCKET */
|
|
|
268 sprintf(server.sun_path,"%s/gsrv%d",tmpdir,(int)geteuid());
|
|
|
269 #endif /* HIDE_UNIX_SOCKET */
|
|
|
270 if (connect(s,(struct sockaddr *)&server,strlen(server.sun_path)+2) < 0) {
|
|
|
271 perror(progname);
|
|
|
272 fprintf(stderr,"%s: unable to connect to local\n",progname);
|
|
|
273 exit(1);
|
|
|
274 }; /* if */
|
|
|
275
|
|
|
276 return(s);
|
|
|
277
|
|
|
278 } /* connect_to_unix_server */
|
|
|
279 #endif /* UNIX_DOMAIN_SOCKETS */
|
|
|
280
|
|
|
281
|
|
|
282 #ifdef INTERNET_DOMAIN_SOCKETS
|
|
|
283 /*
|
|
|
284 internet_addr -- return the internet addr of the hostname or
|
|
|
285 internet address passed. Return -1 on error.
|
|
|
286 */
|
|
440
|
287 int
|
|
|
288 internet_addr (char *host)
|
|
428
|
289 {
|
|
|
290 struct hostent *hp; /* pointer to host info for remote host */
|
|
|
291 IN_ADDR numeric_addr; /* host address */
|
|
|
292
|
|
|
293 numeric_addr = inet_addr(host);
|
|
|
294 if (!NUMERIC_ADDR_ERROR)
|
|
|
295 return numeric_addr;
|
|
|
296 else if ((hp = gethostbyname(host)) != NULL)
|
|
|
297 return ((struct in_addr *)(hp->h_addr))->s_addr;
|
|
|
298 else
|
|
|
299 return -1;
|
|
|
300
|
|
|
301 } /* internet_addr */
|
|
|
302
|
|
|
303 #ifdef AUTH_MAGIC_COOKIE
|
|
|
304 # include <X11/X.h>
|
|
|
305 # include <X11/Xauth.h>
|
|
|
306
|
|
|
307 static Xauth *server_xauth = NULL;
|
|
|
308 #endif
|
|
|
309
|
|
|
310 /*
|
|
|
311 connect_to_internet_server -- establish connection with server process via
|
|
|
312 an internet domain socket. Returns socket
|
|
|
313 descriptor for server if successful.
|
|
|
314 */
|
|
440
|
315 static int
|
|
458
|
316 connect_to_internet_server (char *serverhost, unsigned short port)
|
|
428
|
317 {
|
|
|
318 int s; /* connected socket descriptor */
|
|
|
319 struct servent *sp; /* pointer to service information */
|
|
|
320 struct sockaddr_in peeraddr_in; /* for peer socket address */
|
|
|
321 char buf[512]; /* temporary buffer */
|
|
|
322
|
|
|
323 /* clear out address structures */
|
|
|
324 memset((char *)&peeraddr_in,0,sizeof(struct sockaddr_in));
|
|
|
325
|
|
|
326 /* Set up the peer address to which we will connect. */
|
|
|
327 peeraddr_in.sin_family = AF_INET;
|
|
|
328
|
|
|
329 /* look up the server host's internet address */
|
|
647
|
330 if ((peeraddr_in.sin_addr.s_addr = internet_addr (serverhost)) ==
|
|
|
331 (unsigned int) -1)
|
|
|
332 {
|
|
|
333 fprintf (stderr, "%s: unable to find %s in /etc/hosts or from YP\n",
|
|
|
334 progname, serverhost);
|
|
|
335 exit(1);
|
|
|
336 }
|
|
428
|
337
|
|
|
338 if (port == 0) {
|
|
|
339 if ((sp = getservbyname ("gnuserv","tcp")) == NULL)
|
|
|
340 peeraddr_in.sin_port = htons(DEFAULT_PORT+getuid());
|
|
|
341 else
|
|
|
342 peeraddr_in.sin_port = sp->s_port;
|
|
|
343 } /* if */
|
|
|
344 else
|
|
|
345 peeraddr_in.sin_port = htons(port);
|
|
|
346
|
|
|
347 /* Create the socket. */
|
|
|
348 if ((s = socket (AF_INET,SOCK_STREAM, 0))== -1) {
|
|
|
349 perror(progname);
|
|
|
350 fprintf(stderr,"%s: unable to create socket\n",progname);
|
|
|
351 exit(1);
|
|
|
352 }; /* if */
|
|
|
353
|
|
|
354 /* Try to connect to the remote server at the address
|
|
|
355 * which was just built into peeraddr.
|
|
|
356 */
|
|
|
357 if (connect(s, (struct sockaddr *)&peeraddr_in,
|
|
|
358 sizeof(struct sockaddr_in)) == -1) {
|
|
|
359 perror(progname);
|
|
|
360 fprintf(stderr, "%s: unable to connect to remote\n",progname);
|
|
|
361 exit(1);
|
|
|
362 }; /* if */
|
|
|
363
|
|
|
364 #ifdef AUTH_MAGIC_COOKIE
|
|
|
365
|
|
|
366 /* send credentials using MIT-MAGIC-COOKIE-1 protocol */
|
|
|
367
|
|
|
368 server_xauth =
|
|
|
369 XauGetAuthByAddr(FamilyInternet,
|
|
|
370 sizeof(peeraddr_in.sin_addr.s_addr),
|
|
|
371 (char *) &peeraddr_in.sin_addr.s_addr,
|
|
|
372 strlen(MCOOKIE_SCREEN), MCOOKIE_SCREEN,
|
|
|
373 strlen(MCOOKIE_X_NAME), MCOOKIE_X_NAME);
|
|
|
374
|
|
|
375 if (server_xauth && server_xauth->data) {
|
|
|
376 sprintf(buf, "%s\n%d\n", MCOOKIE_NAME, server_xauth->data_length);
|
|
|
377 write (s, buf, strlen(buf));
|
|
|
378 write (s, server_xauth->data, server_xauth->data_length);
|
|
|
379
|
|
|
380 return (s);
|
|
|
381 }
|
|
|
382
|
|
|
383 #endif /* AUTH_MAGIC_COOKIE */
|
|
|
384
|
|
|
385 sprintf (buf, "%s\n", DEFAUTH_NAME);
|
|
|
386 write (s, buf, strlen(buf));
|
|
|
387
|
|
|
388 return(s);
|
|
|
389
|
|
|
390 } /* connect_to_internet_server */
|
|
|
391 #endif /* INTERNET_DOMAIN_SOCKETS */
|
|
|
392
|
|
|
393
|
|
|
394 #if defined(INTERNET_DOMAIN_SOCKETS) || defined(UNIX_DOMAIN_SOCKETS)
|
|
|
395 /*
|
|
|
396 disconnect_from_server -- inform the server that sending has finished, and wait for
|
|
|
397 its reply.
|
|
|
398 */
|
|
440
|
399 void
|
|
|
400 disconnect_from_server (int s, int echo)
|
|
428
|
401 {
|
|
|
402 #if 0
|
|
|
403 char buffer[REPLYSIZ+1];
|
|
|
404 #else
|
|
|
405 char buffer[GSERV_BUFSZ+1];
|
|
|
406 #endif
|
|
|
407 int add_newline = 1;
|
|
|
408 int length;
|
|
|
409
|
|
|
410 send_string(s,EOT_STR); /* make sure server gets string */
|
|
|
411
|
|
|
412 #if !defined (linux) && !defined (_SCO_DS)
|
|
|
413 /*
|
|
|
414 * shutdown is completely hozed under linux. If s is a unix domain socket,
|
|
|
415 * you'll get EOPNOTSUPP back from it. If s is an internet socket, you get
|
|
|
416 * a broken pipe when you try to read a bit later. The latter
|
|
|
417 * problem is fixed for linux versions >= 1.1.46, but the problem
|
|
|
418 * with unix sockets persists. Sigh.
|
|
|
419 */
|
|
|
420
|
|
|
421 if (shutdown(s,1) == -1) {
|
|
|
422 perror(progname);
|
|
|
423 fprintf(stderr, "%s: unable to shutdown socket\n",progname);
|
|
|
424 exit(1);
|
|
|
425 }; /* if */
|
|
|
426 #endif
|
|
|
427
|
|
|
428 #if 0
|
|
|
429 while((length = recv(s,buffer,REPLYSIZ,0)) > 0) {
|
|
|
430 buffer[length] = '\0';
|
|
|
431 if (echo) fputs(buffer,stdout);
|
|
|
432 add_newline = (buffer[length-1] != '\n');
|
|
|
433 }; /* while */
|
|
|
434 #else
|
|
|
435 while ((length = read(s,buffer,GSERV_BUFSZ)) > 0 ||
|
|
|
436 (length == -1 && errno == EINTR)) {
|
|
|
437 if (length) {
|
|
|
438 buffer[length] = '\0';
|
|
|
439 if (echo) {
|
|
|
440 fputs(buffer,stdout);
|
|
|
441 add_newline = (buffer[length-1] != '\n');
|
|
|
442 }; /* if */
|
|
|
443 }; /* if */
|
|
|
444 }; /* while */
|
|
|
445 #endif
|
|
|
446
|
|
|
447 if (echo && add_newline) putchar('\n');
|
|
|
448
|
|
|
449 if(length < 0) {
|
|
|
450 perror(progname);
|
|
|
451 fprintf(stderr,"%s: unable to read the reply from the server\n",progname);
|
|
|
452 exit(1);
|
|
|
453 }; /* if */
|
|
|
454
|
|
|
455 } /* disconnect_from_server */
|
|
|
456 #endif /* INTERNET_DOMAIN_SOCKETS || UNIX_DOMAIN_SOCKETS */
|
