-#ifndef BIT_FIELD_LIMITS
- memcpy(&server.sin_addr.s_addr,ip,4);
-#else
- memcpy(&server.sin_addr,ip,4);
-#endif
- s=socket(AF_INET,SOCK_STREAM,SOCKET_PROTOCOL);
-
- if (s == INVALID_SOCKET) goto err;
- if (bind(s,(struct sockaddr *)&server,sizeof(server)) == -1)
- {
-#ifndef WINDOWS
- perror("bind");
-#endif
- goto err;
- }
- /* Make it 128 for linux */
- if (listen(s,128) == -1) goto err;
- i=0;
- *sock=s;
- ret=1;
-err:
- if ((ret == 0) && (s != -1))
- {
- SHUTDOWN(s);
- }
- return(ret);
- }
-
-int init_server(sock,port)
-int *sock;
-int port;
- {
- return(init_server_long(sock, port, NULL));
- }
-
-int do_accept(acc_sock, sock, host)
-int acc_sock;
-int *sock;
-char **host;
- {
- int ret,i;
- struct hostent *h1,*h2;
- static struct sockaddr_in from;
- int len;
-/* struct linger ling; */
-
- if (!sock_init()) return(0);
-
-#ifndef WINDOWS
-redoit:
-#endif
-
- memset((char *)&from,0,sizeof(from));
- len=sizeof(from);
- ret=accept(acc_sock,(struct sockaddr *)&from,&len);
- if (ret == INVALID_SOCKET)
- {
-#ifdef WINDOWS
- i=WSAGetLastError();
- BIO_printf(bio_err,"accept error %d\n",i);
-#else
- if (errno == EINTR)
- {
- /*check_timeout(); */
- goto redoit;
- }
- fprintf(stderr,"errno=%d ",errno);
- perror("accept");
-#endif
- return(0);
- }
+# ifndef BIT_FIELD_LIMITS
+ memcpy(&server.sin_addr.s_addr, ip, 4);
+# else
+ memcpy(&server.sin_addr, ip, 4);
+# endif
+
+ if (type == SOCK_STREAM)
+ s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
+ else /* type == SOCK_DGRAM */
+ s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
+
+ if (s == INVALID_SOCKET)
+ goto err;
+# if defined SOL_SOCKET && defined SO_REUSEADDR
+ {
+ int j = 1;
+ setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (void *)&j, sizeof j);
+ }
+# endif
+ if (bind(s, (struct sockaddr *)&server, sizeof(server)) == -1) {
+# ifndef OPENSSL_SYS_WINDOWS
+ perror("bind");
+# endif
+ goto err;
+ }
+ /* Make it 128 for linux */
+ if (type == SOCK_STREAM && listen(s, 128) == -1)
+ goto err;
+ *sock = s;
+ ret = 1;
+ err:
+ if ((ret == 0) && (s != -1)) {
+ SHUTDOWN(s);
+ }
+ return (ret);
+}
+
+static int init_server(int *sock, int port, int type)
+{
+ return (init_server_long(sock, port, NULL, type));
+}
+
+# ifndef NO_SYS_UN_H
+static int init_server_unix(int *sock, const char *path)
+{
+ int ret = 0;
+ struct sockaddr_un server;
+ int s = -1;
+
+ if (strlen(path) > (UNIX_PATH_MAX + 1))
+ return (0);
+ if (!ssl_sock_init())
+ return (0);
+
+ s = socket(AF_UNIX, SOCK_STREAM, 0);
+ if (s == INVALID_SOCKET)
+ goto err;
+
+ memset(&server, 0, sizeof(server));
+ server.sun_family = AF_UNIX;
+ strcpy(server.sun_path, path);
+
+ if (bind(s, (struct sockaddr *)&server, sizeof(server)) == -1) {
+# ifndef OPENSSL_SYS_WINDOWS
+ perror("bind");
+# endif
+ goto err;
+ }
+ /* Make it 128 for linux */
+ if (listen(s, 128) == -1) {
+# ifndef OPENSSL_SYS_WINDOWS
+ perror("listen");
+# endif
+ unlink(path);
+ goto err;
+ }
+ *sock = s;
+ ret = 1;
+ err:
+ if ((ret == 0) && (s != -1)) {
+ SHUTDOWN(s);
+ }
+ return (ret);
+}
+# endif
+
+static int do_accept(int acc_sock, int *sock, char **host)
+{
+ int ret;
+ struct hostent *h1, *h2;
+ static struct sockaddr_in from;
+ int len;
+/* struct linger ling; */
+
+ if (!ssl_sock_init())
+ return (0);
+
+# ifndef OPENSSL_SYS_WINDOWS
+ redoit:
+# endif
+
+ memset(&from, 0, sizeof(from));
+ len = sizeof(from);
+ /*
+ * Note: under VMS with SOCKETSHR the fourth parameter is currently of
+ * type (int *) whereas under other systems it is (void *) if you don't
+ * have a cast it will choke the compiler: if you do have a cast then you
+ * can either go for (int *) or (void *).
+ */
+ ret = accept(acc_sock, (struct sockaddr *)&from, (void *)&len);
+ if (ret == INVALID_SOCKET) {
+# if defined(OPENSSL_SYS_WINDOWS) || (defined(OPENSSL_SYS_NETWARE) && !defined(NETWARE_BSDSOCK))
+ int i;
+ i = WSAGetLastError();
+ BIO_printf(bio_err, "accept error %d\n", i);
+# else
+ if (errno == EINTR) {
+ /*
+ * check_timeout();
+ */
+ goto redoit;
+ }
+ fprintf(stderr, "errno=%d ", errno);
+ perror("accept");
+# endif
+ return (0);
+ }
+
+ if (host == NULL)
+ goto end;
+# ifndef BIT_FIELD_LIMITS
+ /* I should use WSAAsyncGetHostByName() under windows */
+ h1 = gethostbyaddr((char *)&from.sin_addr.s_addr,
+ sizeof(from.sin_addr.s_addr), AF_INET);
+# else
+ h1 = gethostbyaddr((char *)&from.sin_addr,
+ sizeof(struct in_addr), AF_INET);
+# endif
+ if (h1 == NULL) {
+ BIO_printf(bio_err, "bad gethostbyaddr\n");
+ *host = NULL;
+ /* return(0); */
+ } else {
+ *host = app_malloc(strlen(h1->h_name) + 1, "copy hostname");
+ BUF_strlcpy(*host, h1->h_name, strlen(h1->h_name) + 1);
+
+ h2 = gethostbyname(*host);
+ if (h2 == NULL) {
+ BIO_printf(bio_err, "gethostbyname failure\n");
+ closesocket(ret);
+ return (0);
+ }
+ if (h2->h_addrtype != AF_INET) {
+ BIO_printf(bio_err, "gethostbyname addr is not AF_INET\n");
+ closesocket(ret);
+ return (0);
+ }
+ }
+ end:
+ *sock = ret;
+ return (1);
+}
+
+# ifndef NO_SYS_UN_H
+static int do_accept_unix(int acc_sock, int *sock)
+{
+ int ret;
+
+ if (!ssl_sock_init())
+ return (0);
+
+ redoit:
+ ret = accept(acc_sock, NULL, NULL);
+ if (ret == INVALID_SOCKET) {
+ if (errno == EINTR) {
+ /*
+ * check_timeout();
+ */
+ goto redoit;
+ }
+ fprintf(stderr, "errno=%d ", errno);
+ perror("accept");
+ return (0);
+ }
+
+ *sock = ret;
+ return (1);
+}
+# endif
+
+int extract_host_port(char *str, char **host_ptr, unsigned char *ip,
+ unsigned short *port_ptr)
+{
+ char *h, *p;
+
+ h = str;
+ p = strchr(str, ':');
+ if (p == NULL) {
+ BIO_printf(bio_err, "no port defined\n");
+ return (0);
+ }
+ *(p++) = '\0';
+
+ if ((ip != NULL) && !host_ip(str, ip))
+ goto err;
+ if (host_ptr != NULL)
+ *host_ptr = h;
+
+ if (!extract_port(p, port_ptr))
+ goto err;
+ return (1);
+ err:
+ return (0);
+}
+
+static int host_ip(const char *str, unsigned char ip[4])
+{
+ unsigned int in[4];
+ int i;
+
+ if (sscanf(str, "%u.%u.%u.%u", &(in[0]), &(in[1]), &(in[2]), &(in[3])) ==
+ 4) {
+ for (i = 0; i < 4; i++)
+ if (in[i] > 255) {
+ BIO_printf(bio_err, "invalid IP address\n");
+ goto err;
+ }
+ ip[0] = in[0];
+ ip[1] = in[1];
+ ip[2] = in[2];
+ ip[3] = in[3];
+ } else { /* do a gethostbyname */
+ struct hostent *he;
+
+ if (!ssl_sock_init())
+ return (0);
+
+ he = gethostbyname(str);
+ if (he == NULL) {
+ BIO_printf(bio_err, "gethostbyname failure\n");
+ goto err;
+ }
+ if (he->h_addrtype != AF_INET) {
+ BIO_printf(bio_err, "gethostbyname addr is not AF_INET\n");
+ return (0);
+ }
+ ip[0] = he->h_addr_list[0][0];
+ ip[1] = he->h_addr_list[0][1];
+ ip[2] = he->h_addr_list[0][2];
+ ip[3] = he->h_addr_list[0][3];
+ }
+ return (1);
+ err:
+ return (0);
+}
+
+int extract_port(const char *str, unsigned short *port_ptr)
+{
+ int i;
+ struct servent *s;
+
+ i = atoi(str);
+ if (i != 0)
+ *port_ptr = (unsigned short)i;
+ else {
+ s = getservbyname(str, "tcp");
+ if (s == NULL) {
+ BIO_printf(bio_err, "getservbyname failure for %s\n", str);
+ return (0);
+ }
+ *port_ptr = ntohs((unsigned short)s->s_port);
+ }
+ return (1);
+}