-
Notifications
You must be signed in to change notification settings - Fork 1
/
socket.c
174 lines (161 loc) · 4.75 KB
/
socket.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
/* Copyright Massachusetts Institute of Technology 1988 */
/*
* THIS IS AN OS DEPENDENT FILE! It should work on 4.2BSD derived
* systems. VMS and System V should plan to have their own version.
*
* This code was cribbed from lib/X/XConnDis.c.
* Compile using
* % cc -c socket.c -DUNIXCONN
*/
# ifdef __alpha
# pragma pointer_size (save)
# pragma pointer_size (long)
# endif
#include <stdio.h>
#include <X11/Xos.h>
#include <X11/Xproto.h>
#include <errno.h>
#include <netinet/in.h>
#include <sys/ioctl.h>
#include <netdb.h>
#include <sys/socket.h>
#ifndef hpux
#include <netinet/tcp.h>
#endif
extern int errno; /* Certain (broken) OS's don't have this */
/* decl in errno.h */
#ifdef UNIXCONN
#include <sys/un.h>
# ifndef X_UNIX_PATH
# ifdef hpux
# define X_UNIX_PATH "/usr/spool/sockets/X11/"
# define OLD_UNIX_PATH "/tmp/.X11-unix/X"
# else /* hpux */
# define X_UNIX_PATH "/tmp/.X11-unix/X"
# endif /* hpux */
# endif /* X_UNIX_PATH */
# ifdef __APPLE__
/* need to include this starting with a recent Xcode on macsup, 10/29/21 */
# include <arpa/inet.h>
# endif
#endif /* UNIXCONN */
# ifdef m_alpha
# pragma pointer_size (restore)
# endif
#if 0
void bcopy();
#endif /* hpux */
/*
* Attempts to connect to server, given host and display. Returns file
* descriptor (network socket) or 0 if connection fails.
*/
int connect_to_server (host, display)
char *host;
int display;
{
struct sockaddr_in inaddr; /* INET socket address. */
struct sockaddr *addr; /* address to connect to */
struct hostent *host_ptr;
int addrlen; /* length of address */
#ifdef UNIXCONN
struct sockaddr_un unaddr; /* UNIX socket address. */
#endif
extern char *getenv();
extern struct hostent *gethostbyname();
int fd; /* Network socket */
{
#ifdef UNIXCONN
if ((!host) || (host[0] == '\0') || (strcmp("unix", host) == 0)) {
/* Connect locally using Unix domain. */
unaddr.sun_family = AF_UNIX;
(void) strcpy(unaddr.sun_path, X_UNIX_PATH);
(void) sprintf(&unaddr.sun_path[strlen(unaddr.sun_path)], "%d", display);
addr = (struct sockaddr *) &unaddr;
addrlen = strlen(unaddr.sun_path) + 2;
/*
* Open the network connection.
*/
if ((fd = socket((int) addr->sa_family, SOCK_STREAM, 0)) < 0) {
#ifdef hpux /* this is disgusting */ /* cribbed from X11R4 xlib source */
if (errno == ENOENT) { /* No such file or directory */
(void) sprintf(unaddr.sun_path, "%s%d", OLD_UNIX_PATH, display);
addrlen = strlen(unaddr.sun_path) + 2;
if ((fd = socket ((int) addr->sa_family, SOCK_STREAM, 0)) < 0)
return(-1); /* errno set by most recent system call. */
} else
#endif /* hpux */
perror("Unix domain socket failed");
return(-1); /* errno set by system call. */
}
} else
#endif /* UNIXCONN */
{
/* Get the statistics on the specified host. */
if ((inaddr.sin_addr.s_addr = inet_addr(host)) == -1)
{
if ((host_ptr = gethostbyname(host)) == NULL)
{
/* No such host! */
fprintf(stderr, "Unknown host: %s\n", host);
errno = EINVAL;
return(-1);
}
/* Check the address type for an internet host. */
if (host_ptr->h_addrtype != AF_INET)
{
/* Not an Internet host! */
perror("Host lookup failed");
errno = EPROTOTYPE;
return(-1);
}
/* Set up the socket data. */
inaddr.sin_family = host_ptr->h_addrtype;
(void) memcpy((char *)&inaddr.sin_addr,
(char *)host_ptr->h_addr,
sizeof(inaddr.sin_addr));
#if 0
(void) bcopy((char *)host_ptr->h_addr,
(char *)&inaddr.sin_addr,
sizeof(inaddr.sin_addr));
#endif /* 0 */
}
else
{
inaddr.sin_family = AF_INET;
}
addr = (struct sockaddr *) &inaddr;
addrlen = sizeof (struct sockaddr_in);
inaddr.sin_port = display + X_TCP_PORT;
inaddr.sin_port = htons(inaddr.sin_port);
/*
* Open the network connection.
*/
if ((fd = socket((int) addr->sa_family, SOCK_STREAM, 0)) < 0){
perror("Internet domain socket failed");
return(-1); /* errno set by system call. */}
/* make sure to turn off TCP coalescence */
#ifdef TCP_NODELAY
{
int mi = 1;
setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &mi, sizeof (int));
}
#endif
}
/*
* Changed 9/89 to retry connection if system call was interrupted. This
* is necessary for multiprocessing implementations that use timers,
* since the timer results in a SIGALRM. -- jdi
*/
while (connect(fd, addr, addrlen) == -1) {
if (errno != EINTR) {
perror("Connection of socket failed");
(void) close (fd);
return(-1); /* errno set by system call. */
}
}
}
/*
* Return the id if the connection succeeded.
*/
return(fd);
}