First Commit of my working state

[simh.git] / sim_sock.c

/* sim_sock.c: OS-dependent socket routines\r
\r
   Copyright (c) 2001-2005, Robert M Supnik\r
\r
   Permission is hereby granted, free of charge, to any person obtaining a\r
   copy of this software and associated documentation files (the "Software"),\r
   to deal in the Software without restriction, including without limitation\r
   the rights to use, copy, modify, merge, publish, distribute, sublicense,\r
   and/or sell copies of the Software, and to permit persons to whom the\r
   Software is furnished to do so, subject to the following conditions:\r
\r
   The above copyright notice and this permission notice shall be included in\r
   all copies or substantial portions of the Software.\r
\r
   THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR\r
   IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,\r
   FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL\r
   ROBERT M SUPNIK BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER\r
   IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN\r
   CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.\r
\r
   Except as contained in this notice, the name of Robert M Supnik shall not be\r
   used in advertising or otherwise to promote the sale, use or other dealings\r
   in this Software without prior written authorization from Robert M Supnik.\r
\r
   19-Nov-05    RMS     Added conditional for OpenBSD (from Federico G. Schwindt)\r
   16-Aug-05    RMS     Fixed spurious SIGPIPE signal error in Unix\r
   14-Apr-05    RMS     Added WSAEINPROGRESS test (from Tim Riker)\r
   09-Jan-04    RMS     Fixed typing problem in Alpha Unix (found by Tim Chapman)\r
   17-Apr-03    RMS     Fixed non-implemented version of sim_close_sock\r
                        (found by Mark Pizzolato)\r
   17-Dec-02    RMS     Added sim_connect_socket, sim_create_socket\r
   08-Oct-02    RMS     Revised for .NET compatibility\r
   22-Aug-02    RMS     Changed calling sequence for sim_accept_conn\r
   22-May-02    RMS     Added OS2 EMX support from Holger Veit\r
   06-Feb-02    RMS     Added VMS support from Robert Alan Byer\r
   16-Sep-01    RMS     Added Macintosh support from Peter Schorn\r
   02-Sep-01    RMS     Fixed UNIX bugs found by Mirian Lennox and Tom Markson\r
*/\r
\r
#include "sim_defs.h"\r
#include "sim_sock.h"\r
#include <signal.h>\r
\r
/* OS dependent routines\r
\r
   sim_master_sock      create master socket\r
   sim_accept_conn      accept connection\r
   sim_read_sock        read from socket\r
   sim_write_sock       write from socket\r
   sim_close_sock       close socket\r
   sim_setnonblock      set socket non-blocking\r
   sim_msg_sock         send message to socket\r
*/\r
\r
int32 sim_sock_cnt = 0;\r
\r
/* First, all the non-implemented versions */\r
\r
#if defined (__OS2__) && !defined (__EMX__)\r
\r
SOCKET sim_master_sock (int32 port)\r
{\r
return INVALID_SOCKET;\r
}\r
\r
SOCKET sim_connect_sock (int32 ip, int32 port)\r
{\r
return INVALID_SOCKET;\r
}\r
\r
SOCKET sim_accept_conn (SOCKET master, uint32 *ipaddr)\r
{\r
return INVALID_SOCKET;\r
}\r
\r
int32 sim_read_sock (SOCKET sock, char *buf, int32 nbytes)\r
{\r
return -1;\r
}\r
\r
int32 sim_write_sock (SOCKET sock, char *msg, int32 nbytes)\r
{\r
return 0;\r
}\r
\r
void sim_close_sock (SOCKET sock, t_bool master)\r
{\r
return;\r
}\r
\r
SOCKET sim_setnonblock (SOCKET sock)\r
{\r
return SOCKET_ERROR;\r
}\r
\r
#else                                                   /* endif unimpl */\r
\r
/* UNIX, Win32, Macintosh, VMS, OS2 (Berkeley socket) routines */\r
\r
SOCKET sim_err_sock (SOCKET s, char *emsg, int32 flg)\r
{\r
int32 err = WSAGetLastError ();\r
\r
printf ("Sockets: %s error %d\n", emsg, err);\r
sim_close_sock (s, flg);\r
return INVALID_SOCKET;\r
}\r
\r
SOCKET sim_create_sock (void)\r
{\r
SOCKET newsock;\r
int32 err;\r
\r
#if defined (_WIN32)\r
WORD wVersionRequested; \r
WSADATA wsaData; \r
wVersionRequested = MAKEWORD (1, 1); \r
\r
if (sim_sock_cnt == 0) {\r
    err = WSAStartup (wVersionRequested, &wsaData);     /* start Winsock */ \r
    if (err != 0) {\r
        printf ("Winsock: startup error %d\n", err);\r
        return INVALID_SOCKET;\r
        }\r
    }\r
sim_sock_cnt = sim_sock_cnt + 1;\r
#endif                                                  /* endif Win32 */\r
#if defined (SIGPIPE)\r
signal (SIGPIPE, SIG_IGN);                              /* no pipe signals */\r
#endif\r
\r
newsock = socket (AF_INET, SOCK_STREAM, 0);             /* create socket */\r
if (newsock == INVALID_SOCKET) {                        /* socket error? */\r
    err = WSAGetLastError ();\r
    printf ("Sockets: socket error %d\n", err);\r
    return INVALID_SOCKET;\r
    }\r
return newsock;\r
}\r
\r
SOCKET sim_master_sock (int32 port)\r
{\r
SOCKET newsock;\r
struct sockaddr_in name;\r
int32 sta;\r
\r
newsock = sim_create_sock ();                           /* create socket */\r
if (newsock == INVALID_SOCKET) return newsock;          /* socket error? */\r
\r
name.sin_family = AF_INET;                              /* name socket */\r
name.sin_port = htons ((unsigned short) port);          /* insert port */\r
name.sin_addr.s_addr = htonl (INADDR_ANY);              /* insert addr */\r
\r
sta = bind (newsock, (struct sockaddr *) &name, sizeof (name));\r
if (sta == SOCKET_ERROR)                                /* bind error? */\r
    return sim_err_sock (newsock, "bind", 1);\r
sta = sim_setnonblock (newsock);                        /* set nonblocking */\r
if (sta == SOCKET_ERROR)                                /* fcntl error? */\r
    return sim_err_sock (newsock, "fcntl", 1);\r
sta = listen (newsock, 1);                              /* listen on socket */\r
if (sta == SOCKET_ERROR)                                /* listen error? */\r
    return sim_err_sock (newsock, "listen", 1);\r
return newsock;                                         /* got it! */\r
}\r
\r
SOCKET sim_connect_sock (int32 ip, int32 port)\r
{\r
SOCKET newsock;\r
struct sockaddr_in name;\r
int32 sta;\r
\r
newsock = sim_create_sock ();                           /* create socket */\r
if (newsock == INVALID_SOCKET) return newsock;          /* socket error? */\r
\r
name.sin_family = AF_INET;                              /* name socket */\r
name.sin_port = htons ((unsigned short) port);          /* insert port */\r
name.sin_addr.s_addr = htonl (ip);                      /* insert addr */\r
\r
sta = sim_setnonblock (newsock);                        /* set nonblocking */\r
if (sta == SOCKET_ERROR)                                /* fcntl error? */\r
    return sim_err_sock (newsock, "fcntl", 1);\r
sta = connect (newsock, (struct sockaddr *) &name, sizeof (name));\r
if ((sta == SOCKET_ERROR) && \r
    (WSAGetLastError () != WSAEWOULDBLOCK) &&\r
    (WSAGetLastError () != WSAEINPROGRESS))\r
    return sim_err_sock (newsock, "connect", 1);\r
\r
return newsock;                                         /* got it! */\r
}\r
\r
SOCKET sim_accept_conn (SOCKET master, uint32 *ipaddr)\r
{\r
int32 sta, err;\r
#if defined (macintosh) || defined (__linux) || \\r
    defined (__APPLE__) || defined (__OpenBSD__)\r
socklen_t size;\r
#elif defined (_WIN32) || defined (__EMX__) ||\\r
     (defined (__ALPHA) && defined (__unix__))\r
int size;\r
#else \r
size_t size; \r
#endif\r
SOCKET newsock;\r
struct sockaddr_in clientname;\r
\r
if (master == 0) return INVALID_SOCKET;                 /* not attached? */\r
size = sizeof (clientname);\r
newsock = accept (master, (struct sockaddr *) &clientname, &size);\r
if (newsock == INVALID_SOCKET) {                        /* error? */\r
    err = WSAGetLastError ();\r
    if (err != WSAEWOULDBLOCK)\r
        printf ("Sockets: accept error %d\n", err);\r
    return INVALID_SOCKET;\r
    }\r
if (ipaddr != NULL) *ipaddr = ntohl (clientname.sin_addr.s_addr);\r
\r
sta = sim_setnonblock (newsock);                        /* set nonblocking */\r
if (sta == SOCKET_ERROR)                                /* fcntl error? */\r
    return sim_err_sock (newsock, "fcntl", 0);\r
return newsock;\r
}\r
\r
int32 sim_check_conn (SOCKET sock, t_bool rd)\r
{\r
fd_set rw_set, er_set;\r
fd_set *rw_p = &rw_set;\r
fd_set *er_p = &er_set;\r
struct timeval tz;\r
\r
timerclear (&tz);\r
FD_ZERO (rw_p);\r
FD_ZERO (er_p);\r
FD_SET (sock, rw_p);\r
FD_SET (sock, er_p);\r
if (rd) select ((int) sock + 1, rw_p, NULL, er_p, &tz);\r
else select ((int) sock + 1, NULL, rw_p, er_p, &tz);\r
if (FD_ISSET (sock, rw_p)) return 1;\r
if (FD_ISSET (sock, er_p)) return -1;\r
return 0;\r
}\r
\r
int32 sim_read_sock (SOCKET sock, char *buf, int32 nbytes)\r
{\r
int32 rbytes, err;\r
\r
rbytes = recv (sock, buf, nbytes, 0);\r
if (rbytes == 0) return -1;                             /* disconnect */\r
if (rbytes == SOCKET_ERROR) {\r
    err = WSAGetLastError ();\r
    if (err == WSAEWOULDBLOCK) return 0;                /* no data */\r
    printf ("Sockets: read error %d\n", err);\r
    return -1;\r
    }\r
return rbytes;\r
}\r
\r
int32 sim_write_sock (SOCKET sock, char *msg, int32 nbytes)\r
{\r
return send (sock, msg, nbytes, 0);\r
}\r
\r
void sim_close_sock (SOCKET sock, t_bool master)\r
{\r
#if defined (_WIN32)\r
closesocket (sock);\r
if (master) {\r
    sim_sock_cnt = sim_sock_cnt - 1;\r
    if (sim_sock_cnt <= 0) {\r
        WSACleanup ();\r
        sim_sock_cnt = 0;\r
        }\r
    }\r
#else\r
close (sock);\r
#endif\r
return;\r
}\r
\r
#if defined (_WIN32)                                    /* Windows */\r
SOCKET sim_setnonblock (SOCKET sock)\r
{\r
unsigned long non_block = 1;\r
\r
return ioctlsocket (sock, FIONBIO, &non_block);         /* set nonblocking */\r
}\r
\r
#elif defined (VMS)                                     /* VMS */\r
SOCKET sim_setnonblock (SOCKET sock)\r
{\r
int non_block = 1;\r
\r
return ioctl (sock, FIONBIO, &non_block);               /* set nonblocking */\r
}\r
\r
#else                                                   /* Mac, Unix, OS/2 */\r
int32 sim_setnonblock (SOCKET sock)\r
{\r
int32 fl, sta;\r
\r
fl = fcntl (sock, F_GETFL,0);                           /* get flags */\r
if (fl == -1) return SOCKET_ERROR;\r
sta = fcntl (sock, F_SETFL, fl | O_NONBLOCK);           /* set nonblock */\r
if (sta == -1) return SOCKET_ERROR;\r
#if !defined (macintosh) && !defined (__EMX__)          /* Unix only */\r
sta = fcntl (sock, F_SETOWN, getpid());                 /* set ownership */\r
if (sta == -1) return SOCKET_ERROR;\r
#endif\r
return 0;\r
}\r
\r
#endif                                                  /* endif !Win32 && !VMS */\r
\r
#endif                                                  /* end else !implemented */\r