oxmc/libgtop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Changed indentation using

Browse Source 
'indent -br -ce -sc -pcs -cs -bs -i8 -bad -bap -fca '
This commit is contained in:
Martin Baulig
1998-07-12 14:24:49 +00:00
parent b177c3930d
commit 61071132bf
1 changed files with 285 additions and 267 deletions
Download Patch File Download Diff File Expand all files Collapse all files

536
sysdeps/common/gnuslib.c
View File

@@ -1,22 +1,22 @@
/* -*-C-*- /* -*-C-*-
Common library code for the GNU Emacs server and client. * Common library code for the GNU Emacs server and client.
*
This file is part of GNU Emacs. * This file is part of GNU Emacs.
*
Copying is permitted under those conditions described by the GNU * Copying is permitted under those conditions described by the GNU
General Public License. * General Public License.
*
Copyright (C) 1989 Free Software Foundation, Inc. * Copyright (C) 1989 Free Software Foundation, Inc.
*
Author: Andy Norman (ange@hplb.hpl.hp.com), based on * Author: Andy Norman (ange@hplb.hpl.hp.com), based on
'etc/server.c' and 'etc/emacsclient.c' from the 18.52 GNU * 'etc/server.c' and 'etc/emacsclient.c' from the 18.52 GNU
Emacs distribution. * Emacs distribution.
*
Please mail bugs and suggestions to the author at the above address. * Please mail bugs and suggestions to the author at the above address.
*/ */
/* HISTORY /* HISTORY
* 11-Nov-1990 bristor@simba * 11-Nov-1990 bristor@simba
* Added EOT stuff. * Added EOT stuff.
*/ */
@@ -30,7 +30,8 @@
*/ */
#if 0 #if 0
static char rcsid [] = "!Header: gnuslib.c,v 2.4 95/02/16 11:57:37 arup alpha !"; static char rcsid[] = "!Header: gnuslib.c,v 2.4 95/02/16 11:57:37 arup alpha !";
#endif #endif
#include <glibtop/gnuserv.h> #include <glibtop/gnuserv.h>
@@ -39,25 +40,28 @@ static char rcsid [] = "!Header: gnuslib.c,v 2.4 95/02/16 11:57:37 arup alpha !"
#ifdef SYSV_IPC #ifdef SYSV_IPC
static int connect_to_ipc_server (void); static int connect_to_ipc_server (void);
#endif #endif
#ifdef UNIX_DOMAIN_SOCKETS #ifdef UNIX_DOMAIN_SOCKETS
static int connect_to_unix_server (void); static int connect_to_unix_server (void);
#endif #endif
#ifdef INTERNET_DOMAIN_SOCKETS #ifdef INTERNET_DOMAIN_SOCKETS
static int connect_to_internet_server (const char *serverhost, u_short port); static int connect_to_internet_server (const char *serverhost, u_short port);
#endif #endif
/* On some systems, e.g. DGUX, inet_addr returns a 'struct in_addr'. */ /* On some systems, e.g. DGUX, inet_addr returns a 'struct in_addr'. */
#ifdef HAVE_BROKEN_INET_ADDR #ifdef HAVE_BROKEN_INET_ADDR
# define IN_ADDR struct in_addr #define IN_ADDR struct in_addr
# define NUMERIC_ADDR_ERROR (numeric_addr.s_addr == -1) #define NUMERIC_ADDR_ERROR (numeric_addr.s_addr == -1)
#else #else
# if (LONGBITS > 32) #if (LONGBITS > 32)
# define IN_ADDR unsigned int #define IN_ADDR unsigned int
# else #else
# define IN_ADDR unsigned long #define IN_ADDR unsigned long
# endif #endif
# define NUMERIC_ADDR_ERROR (numeric_addr == (IN_ADDR) -1) #define NUMERIC_ADDR_ERROR (numeric_addr == (IN_ADDR) -1)
#endif #endif
#include <arpa/inet.h> #include <arpa/inet.h>
@@ -69,365 +73,379 @@ glibtop_make_connection (hostarg, portarg, s)
int *s; int *s;
{ {
#ifdef INTERNET_DOMAIN_SOCKETS #ifdef INTERNET_DOMAIN_SOCKETS
char *ptr; char *ptr;
if (hostarg == NULL)
hostarg = getenv ("LIBGTOP_HOST"); if (hostarg == NULL)
if (portarg == 0 && (ptr = getenv("LIBGTOP_PORT")) != NULL) hostarg = getenv ("LIBGTOP_HOST");
portarg = atoi (ptr); if (portarg == 0 && (ptr = getenv ("LIBGTOP_PORT")) != NULL)
portarg = atoi (ptr);
#endif #endif
if (hostarg != NULL) { if (hostarg != NULL) {
/* hostname was given explicitly, via cmd line arg or LIBGTOP_HOST, /* hostname was given explicitly, via cmd line arg or
* so obey it. */ * LIBGTOP_HOST, * so obey it. */
#ifdef UNIX_DOMAIN_SOCKETS #ifdef UNIX_DOMAIN_SOCKETS
if (!strcmp (hostarg, "unix")) { if (!strcmp (hostarg, "unix")) {
*s = connect_to_unix_server (); *s = connect_to_unix_server ();
return (int) CONN_UNIX; return (int) CONN_UNIX;
} }
#endif /* UNIX_DOMAIN_SOCKETS */ #endif /* UNIX_DOMAIN_SOCKETS */
#ifdef INTERNET_DOMAIN_SOCKETS #ifdef INTERNET_DOMAIN_SOCKETS
*s = connect_to_internet_server (hostarg, portarg); *s = connect_to_internet_server (hostarg, portarg);
return (int) CONN_INTERNET; return (int) CONN_INTERNET;
#endif #endif
#ifdef SYSV_IPC #ifdef SYSV_IPC
return -1; /* hostarg should always be NULL for SYSV_IPC */ return -1; /* hostarg should always be NULL for SYSV_IPC
*/
#endif #endif
} else { } else {
/* no hostname given. Use unix-domain/sysv-ipc, or /* no hostname given. Use unix-domain/sysv-ipc, or *
* internet-domain connection to local host if they're not available. */ * internet-domain connection to local host if they're not
* available. */
#if defined(UNIX_DOMAIN_SOCKETS) #if defined(UNIX_DOMAIN_SOCKETS)
*s = connect_to_unix_server (); *s = connect_to_unix_server ();
return (int) CONN_UNIX; return (int) CONN_UNIX;
#elif defined(SYSV_IPC) #elif defined(SYSV_IPC)
*s = connect_to_ipc_server (); *s = connect_to_ipc_server ();
return (int) CONN_IPC; return (int) CONN_IPC;
#elif defined(INTERNET_DOMAIN_SOCKETS) #elif defined(INTERNET_DOMAIN_SOCKETS)
{ {
char localhost [HOSTNAMSZ]; char localhost[HOSTNAMSZ];
gethostname (localhost, HOSTNAMSZ); /* use this host by default */
*s = connect_to_internet_server (localhost, portarg); gethostname (localhost, HOSTNAMSZ); /* use this
return (int) CONN_INTERNET; * host by
} * default */
*s = connect_to_internet_server (localhost, portarg);
return (int) CONN_INTERNET;
}
#endif /* IPC type */ #endif /* IPC type */
} }
} }
#ifdef SYSV_IPC #ifdef SYSV_IPC
/* /*
connect_to_ipc_server -- establish connection with server process via SYSV IPC * connect_to_ipc_server -- establish connection with server process via SYSV IPC
Returns msqid for server if successful. * Returns msqid for server if successful.
*/ */
static int static int
connect_to_ipc_server (void) connect_to_ipc_server (void)
{ {
int s; /* connected msqid */ int s; /* connected msqid */
key_t key; /* message key */ key_t key; /* message key */
char buf [GSERV_BUFSZ+1]; /* buffer for filename */ char buf[GSERV_BUFSZ + 1]; /* buffer for filename */
sprintf (buf, "/tmp/lgtd%d", (int)geteuid()); sprintf (buf, "/tmp/lgtd%d", (int) geteuid ());
creat (buf, 0600); creat (buf, 0600);
if ((key = ftok (buf, 1)) == -1) if ((key = ftok (buf, 1)) == -1)
glibtop_error_io ("unable to get ipc key from %s", buf); glibtop_error_io ("unable to get ipc key from %s", buf);
if ((s = msgget (key, 0600)) == -1) if ((s = msgget (key, 0600)) == -1)
glibtop_error_io ("unable to access msg queue"); glibtop_error_io ("unable to access msg queue");
return(s); return (s);
} /* connect_to_ipc_server */ } /* connect_to_ipc_server */
/* /*
disconnect_from_ipc_server -- inform the server that sending has finished, * disconnect_from_ipc_server -- inform the server that sending has finished,
and wait for its reply. * and wait for its reply.
*/ */
void disconnect_from_ipc_server(s,msgp,echo) void
disconnect_from_ipc_server (s, msgp, echo)
int s; int s;
struct msgbuf *msgp; struct msgbuf *msgp;
int echo; int echo;
{ {
int len; /* length of received message */ int len; /* length of received message */
send_string(s,EOT_STR); /* EOT terminates this message */ send_string (s, EOT_STR); /* EOT terminates this message */
msgp->mtype = 1; msgp->mtype = 1;
if(msgsnd(s,msgp,strlen(msgp->mtext)+1,0) < 0) { if (msgsnd (s, msgp, strlen (msgp->mtext) + 1, 0) < 0) {
perror(progname); perror (progname);
fprintf(stderr,"%s: unable to send message to server\n",progname); fprintf (stderr, "%s: unable to send message to server\n", progname);
exit(1); exit (1);
}; /* if */ }; /* if */
if((len = msgrcv(s,msgp,GSERV_BUFSZ,getpid(),0)) < 0) { if ((len = msgrcv (s, msgp, GSERV_BUFSZ, getpid (), 0)) < 0) {
perror(progname); perror (progname);
fprintf(stderr,"%s: unable to receive message from server\n",progname); fprintf (stderr, "%s: unable to receive message from server\n", progname);
exit(1); exit (1);
}; /* if */ }; /* if */
if (echo) { if (echo) {
msgp->mtext[len] = '\0'; /* string terminate message */ msgp->mtext[len] = '\0'; /* string terminate message */
fputs(msgp->mtext, stdout); fputs (msgp->mtext, stdout);
if (msgp->mtext[len-1] != '\n') putchar ('\n'); if (msgp->mtext[len - 1] != '\n')
}; /* if */ putchar ('\n');
}; /* if */
} /* disconnect_from_ipc_server */ } /* disconnect_from_ipc_server */
#endif /* SYSV_IPC */ #endif /* SYSV_IPC */
#if defined(INTERNET_DOMAIN_SOCKETS) || defined(UNIX_DOMAIN_SOCKETS) #if defined(INTERNET_DOMAIN_SOCKETS) || defined(UNIX_DOMAIN_SOCKETS)
/* /*
send_string -- send string to socket. * send_string -- send string to socket.
*/ */
#if 0 #if 0
static void static void
send_string(s,msg) send_string (s, msg)
int s; int s;
const char *msg; const char *msg;
{ {
#if 0 #if 0
if (send(s,msg,strlen(msg),0) < 0) { if (send (s, msg, strlen (msg), 0) < 0) {
perror(progname); perror (progname);
fprintf(stderr,"%s: unable to send\n",progname); fprintf (stderr, "%s: unable to send\n", progname);
exit(1); exit (1);
}; /* if */ }; /* if */
#else #else
int len, left=strlen(msg); int len, left = strlen (msg);
while (left > 0) {
if ((len=write(s,msg,min2(left,GSERV_BUFSZ))) < 0) { while (left > 0) {
/* XEmacs addition: robertl@arnet.com */ if ((len = write (s, msg, min2 (left, GSERV_BUFSZ))) < 0) {
if (errno == EPIPE) { /* XEmacs addition: robertl@arnet.com */
return ; if (errno == EPIPE) {
} return;
perror(progname); }
fprintf(stderr,"%s: unable to send\n",progname); perror (progname);
exit(1); fprintf (stderr, "%s: unable to send\n", progname);
}; /* if */ exit (1);
left -= len; }; /* if */
msg += len; left -= len;
}; /* while */ msg += len;
}; /* while */
#endif #endif
} /* send_string */ } /* send_string */
/* /*
read_line -- read a \n terminated line from a socket * read_line -- read a \n terminated line from a socket
*/ */
static int static int
read_line(int s, char *dest) read_line (int s, char *dest)
{ {
int length; int length;
int offset=0; int offset = 0;
char buffer[GSERV_BUFSZ+1]; char buffer[GSERV_BUFSZ + 1];
while ((length=read(s,buffer+offset,1)>0) && buffer[offset]!='\n' while ((length = read (s, buffer + offset, 1) > 0) && buffer[offset] != '\n'
&& buffer[offset] != EOT_CHR) { && buffer[offset] != EOT_CHR) {
offset += length; offset += length;
if (offset >= GSERV_BUFSZ) if (offset >= GSERV_BUFSZ)
break; break;
} }
buffer[offset] = '\0'; buffer[offset] = '\0';
strcpy(dest,buffer); strcpy (dest, buffer);
return 1; return 1;
} /* read_line */ } /* read_line */
#endif #endif
#endif /* INTERNET_DOMAIN_SOCKETS || UNIX_DOMAIN_SOCKETS */ #endif /* INTERNET_DOMAIN_SOCKETS || UNIX_DOMAIN_SOCKETS */
#ifdef UNIX_DOMAIN_SOCKETS #ifdef UNIX_DOMAIN_SOCKETS
/* /*
connect_to_unix_server -- establish connection with server process via a unix- * connect_to_unix_server -- establish connection with server process via a unix-
domain socket. Returns socket descriptor for server * domain socket. Returns socket descriptor for server
if successful. * if successful.
*/ */
static int static int
connect_to_unix_server (void) connect_to_unix_server (void)
{ {
int s; /* connected socket descriptor */ int s; /* connected socket descriptor */
struct sockaddr_un server; /* for unix connections */ struct sockaddr_un server; /* for unix connections */
if ((s = socket (AF_UNIX, SOCK_STREAM, 0)) < 0) if ((s = socket (AF_UNIX, SOCK_STREAM, 0)) < 0)
glibtop_error_io ("unable to create socket"); glibtop_error_io ("unable to create socket");
server.sun_family = AF_UNIX; server.sun_family = AF_UNIX;
#ifdef HIDE_UNIX_SOCKET #ifdef HIDE_UNIX_SOCKET
sprintf(server.sun_path, "/tmp/lgtddir%d/lgtd", (int)geteuid()); sprintf (server.sun_path, "/tmp/lgtddir%d/lgtd", (int) geteuid ());
#else /* HIDE_UNIX_SOCKET */ #else /* HIDE_UNIX_SOCKET */
sprintf(server.sun_path, "/tmp/lgtd%d", (int)geteuid()); sprintf (server.sun_path, "/tmp/lgtd%d", (int) geteuid ());
#endif /* HIDE_UNIX_SOCKET */ #endif /* HIDE_UNIX_SOCKET */
if (connect (s, (struct sockaddr *)&server, strlen(server.sun_path)+2) < 0) if (connect (s, (struct sockaddr *) &server, strlen (server.sun_path) + 2) < 0)
glibtop_error_io ("unable to connect to local"); glibtop_error_io ("unable to connect to local");
return(s); return (s);
} /* connect_to_unix_server */ } /* connect_to_unix_server */
#endif /* UNIX_DOMAIN_SOCKETS */ #endif /* UNIX_DOMAIN_SOCKETS */
#ifdef INTERNET_DOMAIN_SOCKETS #ifdef INTERNET_DOMAIN_SOCKETS
/* /*
internet_addr -- return the internet addr of the hostname or * internet_addr -- return the internet addr of the hostname or
internet address passed. Return -1 on error. * internet address passed. Return -1 on error.
*/ */
long glibtop_internet_addr (host) long
glibtop_internet_addr (host)
const char *host; const char *host;
{ {
struct hostent *hp; /* pointer to host info for remote host */ struct hostent *hp; /* pointer to host info for remote host */
IN_ADDR numeric_addr; /* host address */ IN_ADDR numeric_addr; /* host address */
numeric_addr = inet_addr (host); numeric_addr = inet_addr (host);
if (!NUMERIC_ADDR_ERROR) if (!NUMERIC_ADDR_ERROR)
return numeric_addr; return numeric_addr;
else if ((hp = gethostbyname (host)) != NULL) else if ((hp = gethostbyname (host)) != NULL)
return ((struct in_addr *)(hp->h_addr))->s_addr; return ((struct in_addr *) (hp->h_addr))->s_addr;
else { else {
glibtop_warn_io ("gethostbyname (%s)", host); glibtop_warn_io ("gethostbyname (%s)", host);
return -1; return -1;
} }
} /* glibtop_internet_addr */ } /* glibtop_internet_addr */
#ifdef AUTH_MAGIC_COOKIE #ifdef AUTH_MAGIC_COOKIE
# include <X11/X.h> #include <X11/X.h>
# include <X11/Xauth.h> #include <X11/Xauth.h>
static Xauth *server_xauth = NULL; static Xauth *server_xauth = NULL;
#endif #endif
/* /*
connect_to_internet_server -- establish connection with server process via * connect_to_internet_server -- establish connection with server process via
an internet domain socket. Returns socket * an internet domain socket. Returns socket
descriptor for server if successful. * descriptor for server if successful.
*/ */
static int static int
connect_to_internet_server (const char *serverhost, u_short port) connect_to_internet_server (const char *serverhost, u_short port)
{ {
int s; /* connected socket descriptor */ int s; /* connected socket descriptor */
struct servent *sp; /* pointer to service information */ struct servent *sp; /* pointer to service information */
struct sockaddr_in peeraddr_in; /* for peer socket address */ struct sockaddr_in peeraddr_in; /* for peer socket address */
char buf[512]; /* temporary buffer */ char buf[512]; /* temporary buffer */
/* clear out address structures */ /* clear out address structures */
memset((char *)&peeraddr_in, 0, sizeof(struct sockaddr_in)); memset ((char *) &peeraddr_in, 0, sizeof (struct sockaddr_in));
/* Set up the peer address to which we will connect. */ /* Set up the peer address to which we will connect. */
peeraddr_in.sin_family = AF_INET; peeraddr_in.sin_family = AF_INET;
/* look up the server host's internet address */ /* look up the server host's internet address */
if (((long) peeraddr_in.sin_addr.s_addr = glibtop_internet_addr (serverhost)) == -1) if (((long) peeraddr_in.sin_addr.s_addr = glibtop_internet_addr (serverhost)) == -1)
glibtop_error ("unable to find %s in /etc/hosts or from YP", serverhost); glibtop_error ("unable to find %s in /etc/hosts or from YP", serverhost);
if (port == 0) { if (port == 0) {
if ((sp = getservbyname ("gtopd","tcp")) == NULL) if ((sp = getservbyname ("gtopd", "tcp")) == NULL)
peeraddr_in.sin_port = htons (DEFAULT_PORT+getuid()); peeraddr_in.sin_port = htons (DEFAULT_PORT + getuid ());
else else
peeraddr_in.sin_port = sp->s_port; peeraddr_in.sin_port = sp->s_port;
} /* if */ }
else /* if */
peeraddr_in.sin_port = htons (port); else
peeraddr_in.sin_port = htons (port);
/* Create the socket. */ /* Create the socket. */
if ((s = socket (AF_INET, SOCK_STREAM, 0))== -1) if ((s = socket (AF_INET, SOCK_STREAM, 0)) == -1)
glibtop_error_io ("unable to create socket"); glibtop_error_io ("unable to create socket");
/* Try to connect to the remote server at the address /* Try to connect to the remote server at the address * which was
* which was just built into peeraddr. * just built into peeraddr. */
*/ if (connect (s, (struct sockaddr *) &peeraddr_in,
if (connect(s, (struct sockaddr *)&peeraddr_in, sizeof (struct sockaddr_in)) == -1)
sizeof(struct sockaddr_in)) == -1) glibtop_error_io ("unable to connect to remote");
glibtop_error_io ("unable to connect to remote");
#ifdef AUTH_MAGIC_COOKIE #ifdef AUTH_MAGIC_COOKIE
/* send credentials using MIT-MAGIC-COOKIE-1 protocol */ /* send credentials using MIT-MAGIC-COOKIE-1 protocol */
server_xauth = server_xauth =
XauGetAuthByAddr(FamilyInternet, XauGetAuthByAddr (FamilyInternet,
sizeof(peeraddr_in.sin_addr.s_addr), sizeof (peeraddr_in.sin_addr.s_addr),
(char *) &peeraddr_in.sin_addr.s_addr, (char *) &peeraddr_in.sin_addr.s_addr,
strlen(MCOOKIE_SCREEN), MCOOKIE_SCREEN, strlen (MCOOKIE_SCREEN), MCOOKIE_SCREEN,
strlen(MCOOKIE_X_NAME), MCOOKIE_X_NAME); strlen (MCOOKIE_X_NAME), MCOOKIE_X_NAME);
if (server_xauth && server_xauth->data) { if (server_xauth && server_xauth->data) {
sprintf(buf, "%s\n%d\n", MCOOKIE_NAME, server_xauth->data_length); sprintf (buf, "%s\n%d\n", MCOOKIE_NAME, server_xauth->data_length);
write (s, buf, strlen(buf)); write (s, buf, strlen (buf));
write (s, server_xauth->data, server_xauth->data_length); write (s, server_xauth->data, server_xauth->data_length);
return (s);
}
return (s);
}
#endif /* AUTH_MAGIC_COOKIE */ #endif /* AUTH_MAGIC_COOKIE */
sprintf (buf, "%s\n", DEFAUTH_NAME); sprintf (buf, "%s\n", DEFAUTH_NAME);
write (s, buf, strlen(buf)); write (s, buf, strlen (buf));
return(s); return (s);
} /* connect_to_internet_server */ } /* connect_to_internet_server */
#endif /* INTERNET_DOMAIN_SOCKETS */ #endif /* INTERNET_DOMAIN_SOCKETS */
#if defined(INTERNET_DOMAIN_SOCKETS) || defined(UNIX_DOMAIN_SOCKETS) #if defined(INTERNET_DOMAIN_SOCKETS) || defined(UNIX_DOMAIN_SOCKETS)
/* /*
disconnect_from_server -- inform the server that sending has finished, and wait for * disconnect_from_server -- inform the server that sending has finished, and wait for
its reply. * its reply.
*/ */
#if 0 #if 0
static void static void
disconnect_from_server(s,echo) disconnect_from_server (s, echo)
int s; int s;
int echo; int echo;
{ {
#if 0 #if 0
char buffer[REPLYSIZ+1]; char buffer[REPLYSIZ + 1];
#else
char buffer[GSERV_BUFSZ+1];
#endif
int add_newline = 1;
int length;
send_string(s,EOT_STR); /* make sure server gets string */ #else
char buffer[GSERV_BUFSZ + 1];
#endif
int add_newline = 1;
int length;
send_string (s, EOT_STR); /* make sure server gets string */
#if !defined (linux) && !defined (_SCO_DS) #if !defined (linux) && !defined (_SCO_DS)
/* /*
* shutdown is completely hozed under linux. If s is a unix domain socket, * shutdown is completely hozed under linux. If s is a unix domain socket,
* you'll get EOPNOTSUPP back from it. If s is an internet socket, you get * you'll get EOPNOTSUPP back from it. If s is an internet socket, you get
* a broken pipe when you try to read a bit later. The latter * a broken pipe when you try to read a bit later. The latter
* problem is fixed for linux versions >= 1.1.46, but the problem * problem is fixed for linux versions >= 1.1.46, but the problem
* with unix sockets persists. Sigh. * with unix sockets persists. Sigh.
*/ */
if (shutdown(s,1) == -1) { if (shutdown (s, 1) == -1) {
perror(progname); perror (progname);
fprintf(stderr, "%s: unable to shutdown socket\n",progname); fprintf (stderr, "%s: unable to shutdown socket\n", progname);
exit(1); exit (1);
}; /* if */ }; /* if */
#endif #endif
#if 0 #if 0
while((length = recv(s,buffer,REPLYSIZ,0)) > 0) { while ((length = recv (s, buffer, REPLYSIZ, 0)) > 0) {
buffer[length] = '\0'; buffer[length] = '\0';
if (echo) fputs(buffer,stdout); if (echo)
add_newline = (buffer[length-1] != '\n'); fputs (buffer, stdout);
}; /* while */ add_newline = (buffer[length - 1] != '\n');
}; /* while */
#else #else
while ((length = read(s,buffer,GSERV_BUFSZ)) > 0 || while ((length = read (s, buffer, GSERV_BUFSZ)) > 0 ||
(length == -1 && errno == EINTR)) { (length == -1 && errno == EINTR)) {
if (length) { if (length) {
buffer[length] = '\0'; buffer[length] = '\0';
if (echo) { if (echo) {
fputs(buffer,stdout); fputs (buffer, stdout);
add_newline = (buffer[length-1] != '\n'); add_newline = (buffer[length - 1] != '\n');
}; /* if */ }; /* if */
}; /* if */ }; /* if */
}; /* while */ }; /* while */
#endif #endif
if (echo && add_newline) putchar('\n'); if (echo && add_newline)
putchar ('\n');
if(length < 0) { if (length < 0) {
perror(progname); perror (progname);
fprintf(stderr,"%s: unable to read the reply from the server\n",progname); fprintf (stderr, "%s: unable to read the reply from the server\n", progname);
exit(1); exit (1);
}; /* if */ }; /* if */
} /* disconnect_from_server */ } /* disconnect_from_server */
#endif #endif
#endif /* INTERNET_DOMAIN_SOCKETS || UNIX_DOMAIN_SOCKETS */ #endif /* INTERNET_DOMAIN_SOCKETS || UNIX_DOMAIN_SOCKETS */