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 */