2 #define OPENSSL_SYS_VMS
3 #pragma message disable DOLLARID
6 #include <openssl/OPENSSLCONF.H>
8 #if !defined(_POSIX_C_SOURCE) && defined(OPENSSL_SYS_VMS)
10 * On VMS, you need to define this to get the declaration of fileno(). The
11 * value 2 is to make sure no function defined in POSIX-2 is left undefined.
13 # define _POSIX_C_SOURCE 2
18 #undef _POSIX_C_SOURCE
20 #include <sys/types.h>
21 #include <sys/socket.h>
22 #include <netinet/in.h>
32 typedef struct _iosb { /* Copied from IOSBDEF.H for Alpha */
33 #pragma __nomember_alignment
36 unsigned short int iosb$w_status; /* Final I/O status */
38 __struct { /* 16-bit byte count variant */
39 unsigned short int iosb$w_bcnt; /* 16-bit byte count */
41 unsigned int iosb$l_dev_depend; /* 32-bit device dependent info */
42 unsigned int iosb$l_pid; /* 32-bit pid */
45 __struct { /* 32-bit byte count variant */
46 unsigned int iosb$l_bcnt; /* 32-bit byte count (unaligned) */
47 unsigned short int iosb$w_dev_depend_high; /* 16-bit device dependent info */
53 unsigned int iosb$l_getxxi_status; /* Final GETxxI status */
54 unsigned int iosb$l_reg_status; /* Final $Registry status */
56 unsigned int iosb$l_reserved; /* Reserved field */
62 #define iosb$w_status iosb$r_io_get.iosb$r_io_64.iosb$w_status
63 #define iosb$w_bcnt iosb$r_io_get.iosb$r_io_64.iosb$r_devdepend.iosb$r_bcnt_16.iosb$w_bcnt
64 #define iosb$r_l iosb$r_io_get.iosb$r_io_64.iosb$r_devdepend.iosb$r_bcnt_16.iosb$r_l
65 #define iosb$l_dev_depend iosb$r_l.iosb$l_dev_depend
66 #define iosb$l_pid iosb$r_l.iosb$l_pid
67 #define iosb$l_bcnt iosb$r_io_get.iosb$r_io_64.iosb$r_devdepend.iosb$r_bcnt_32.iosb$l_bcnt
68 #define iosb$w_dev_depend_high iosb$r_io_get.iosb$r_io_64.iosb$r_devdepend.iosb$r_bcnt_32.iosb$w_dev_depend_high
69 #define iosb$l_getxxi_status iosb$r_io_get.iosb$r_get_64.iosb$r_l_status.iosb$l_getxxi_status
70 #define iosb$l_reg_status iosb$r_io_get.iosb$r_get_64.iosb$r_l_status.iosb$l_reg_status
71 #endif /* #if !defined(__VAXC) */
73 #endif /* End of IOSBDEF */
82 #include "vms_term_sock.h"
85 static struct _iosb TerminalDeviceIosb;
87 IOSB TerminalDeviceIosb;
90 static char TerminalDeviceBuff[255 + 2];
91 static int TerminalSocketPair[2] = {0, 0};
92 static unsigned short TerminalDeviceChan = 0;
94 static int CreateSocketPair (int, int, int, int *);
95 static void SocketPairTimeoutAst (int);
96 static int TerminalDeviceAst (int);
97 static void LogMessage (char *, ...);
100 ** Socket Pair Timeout Value (must be 0-59 seconds)
102 #define SOCKET_PAIR_TIMEOUT_VALUE 20
105 ** Socket Pair Timeout Block which is passed to timeout AST
107 typedef struct _SocketPairTimeoutBlock {
108 unsigned short SockChan1;
109 unsigned short SockChan2;
112 #ifdef TERM_SOCK_TEST
114 /*----------------------------------------------------------------------------*/
116 /*----------------------------------------------------------------------------*/
117 int main (int argc, char *argv[], char *envp[])
124 LogMessage ("Enter 'q' or 'Q' to quit ...");
125 while (strcasecmp (TermBuff, "Q"))
128 ** Create the terminal socket
130 status = TerminalSocket (TERM_SOCK_CREATE, &TermSock);
131 if (status != TERM_SOCK_SUCCESS)
135 ** Process the terminal input
137 LogMessage ("Waiting on terminal I/O ...\n");
138 len = recv (TermSock, TermBuff, sizeof (TermBuff), 0) ;
139 TermBuff[len] = '\0';
140 LogMessage ("Received terminal I/O [%s]", TermBuff);
143 ** Delete the terminal socket
145 status = TerminalSocket (TERM_SOCK_DELETE, &TermSock);
146 if (status != TERM_SOCK_SUCCESS)
155 /*----------------------------------------------------------------------------*/
157 /*----------------------------------------------------------------------------*/
158 int TerminalSocket (int FunctionCode, int *ReturnSocket)
161 $DESCRIPTOR (TerminalDeviceDesc, "SYS$COMMAND");
164 ** Process the requested function code
166 switch (FunctionCode)
168 case TERM_SOCK_CREATE:
170 ** Create a socket pair
172 status = CreateSocketPair (AF_INET, SOCK_STREAM, 0, TerminalSocketPair);
175 LogMessage ("TerminalSocket: CreateSocketPair () - %08X", status);
176 if (TerminalSocketPair[0])
177 close (TerminalSocketPair[0]);
178 if (TerminalSocketPair[1])
179 close (TerminalSocketPair[1]);
180 return (TERM_SOCK_FAILURE);
184 ** Assign a channel to the terminal device
186 status = sys$assign (&TerminalDeviceDesc,
191 LogMessage ("TerminalSocket: SYS$ASSIGN () - %08X", status);
192 close (TerminalSocketPair[0]);
193 close (TerminalSocketPair[1]);
194 return (TERM_SOCK_FAILURE);
198 ** Queue an async IO to the terminal device
200 status = sys$qio (EFN$C_ENF,
207 sizeof (TerminalDeviceBuff) - 2,
211 LogMessage ("TerminalSocket: SYS$QIO () - %08X", status);
212 close (TerminalSocketPair[0]);
213 close (TerminalSocketPair[1]);
214 return (TERM_SOCK_FAILURE);
218 ** Return the input side of the socket pair
220 *ReturnSocket = TerminalSocketPair[1];
223 case TERM_SOCK_DELETE:
225 ** Cancel any pending IO on the terminal channel
227 status = sys$cancel (TerminalDeviceChan);
230 LogMessage ("TerminalSocket: SYS$CANCEL () - %08X", status);
231 close (TerminalSocketPair[0]);
232 close (TerminalSocketPair[1]);
233 return (TERM_SOCK_FAILURE);
237 ** Deassign the terminal channel
239 status = sys$dassgn (TerminalDeviceChan);
242 LogMessage ("TerminalSocket: SYS$DASSGN () - %08X", status);
243 close (TerminalSocketPair[0]);
244 close (TerminalSocketPair[1]);
245 return (TERM_SOCK_FAILURE);
249 ** Close the terminal socket pair
251 close (TerminalSocketPair[0]);
252 close (TerminalSocketPair[1]);
255 ** Return the initialized socket
262 ** Invalid function code
264 LogMessage ("TerminalSocket: Invalid Function Code - %d", FunctionCode);
265 return (TERM_SOCK_FAILURE);
272 return (TERM_SOCK_SUCCESS);
276 /*----------------------------------------------------------------------------*/
278 /*----------------------------------------------------------------------------*/
279 static int CreateSocketPair (
285 struct dsc$descriptor AscTimeDesc = {0, DSC$K_DTYPE_T, DSC$K_CLASS_S, NULL};
286 static const char* LocalHostAddr = {"127.0.0.1"};
287 unsigned short TcpAcceptChan = 0,
289 unsigned long BinTimeBuff[2];
290 struct sockaddr_in sin;
291 char AscTimeBuff[32];
305 $DESCRIPTOR (TcpDeviceDesc, "TCPIP$DEVICE");
310 SockDesc1 = socket (SocketFamily, SocketType, 0);
313 LogMessage ("CreateSocketPair: socket () - %d", errno);
318 ** Initialize the socket information
321 memset ((char *) &sin, 0, slen);
322 sin.sin_family = SocketFamily;
323 sin.sin_addr.s_addr = inet_addr (LocalHostAddr);
327 ** Bind the socket to the local IP
329 status = bind (SockDesc1, (struct sockaddr *) &sin, slen);
332 LogMessage ("CreateSocketPair: bind () - %d", errno);
338 ** Get the socket name so we can save the port number
340 status = getsockname (SockDesc1, (struct sockaddr *) &sin, &slen);
343 LogMessage ("CreateSocketPair: getsockname () - %d", errno);
348 LocalHostPort = sin.sin_port;
351 ** Setup a listen for the socket
353 listen (SockDesc1, 5);
356 ** Get the binary (64-bit) time of the specified timeout value
358 sprintf (AscTimeBuff, "0 0:0:%02d.00", SOCKET_PAIR_TIMEOUT_VALUE);
359 AscTimeDesc.dsc$w_length = strlen (AscTimeBuff);
360 AscTimeDesc.dsc$a_pointer = AscTimeBuff;
361 status = sys$bintim (&AscTimeDesc, BinTimeBuff);
364 LogMessage ("CreateSocketPair: SYS$BINTIM () - %08X", status);
370 ** Assign another channel to the TCP/IP device for the accept.
371 ** This is the channel that ends up being connected to.
373 status = sys$assign (&TcpDeviceDesc, &TcpDeviceChan, 0, 0, 0);
376 LogMessage ("CreateSocketPair: SYS$ASSIGN () - %08X", status);
382 ** Get the channel of the first socket for the accept
384 TcpAcceptChan = decc$get_sdc (SockDesc1);
387 ** Perform the accept using $QIO so we can do this asynchronously
389 status = sys$qio (EFN$C_ENF,
391 IO$_ACCESS | IO$M_ACCEPT,
398 LogMessage ("CreateSocketPair: SYS$QIO () - %08X", status);
400 sys$dassgn (TcpDeviceChan);
405 ** Create the second socket to do the connect
407 SockDesc2 = socket (SocketFamily, SocketType, 0);
410 LogMessage ("CreateSocketPair: socket () - %d", errno);
411 sys$cancel (TcpAcceptChan);
413 sys$dassgn (TcpDeviceChan);
418 ** Setup the Socket Pair Timeout Block
420 sptb.SockChan1 = TcpAcceptChan;
421 sptb.SockChan2 = decc$get_sdc (SockDesc2);
424 ** Before we block on the connect, set a timer that can cancel I/O on our two
425 ** sockets if it never connects.
427 status = sys$setimr (EFN$C_ENF,
429 SocketPairTimeoutAst,
434 LogMessage ("CreateSocketPair: SYS$SETIMR () - %08X", status);
435 sys$cancel (TcpAcceptChan);
438 sys$dassgn (TcpDeviceChan);
443 ** Now issue the connect
445 memset ((char *) &sin, 0, sizeof (sin)) ;
446 sin.sin_family = SocketFamily;
447 sin.sin_addr.s_addr = inet_addr (LocalHostAddr) ;
448 sin.sin_port = LocalHostPort ;
450 status = connect (SockDesc2, (struct sockaddr *) &sin, sizeof (sin));
453 LogMessage ("CreateSocketPair: connect () - %d", errno);
454 sys$cantim (&sptb, 0);
455 sys$cancel (TcpAcceptChan);
458 sys$dassgn (TcpDeviceChan);
463 ** Wait for the asynch $QIO to finish. Note that if the I/O was aborted
464 ** (SS$_ABORT), then we probably canceled it from the AST routine - so log a
467 status = sys$synch (EFN$C_ENF, &iosb);
468 if (! (iosb.iosb$w_status & 1))
470 if (iosb.iosb$w_status == SS$_ABORT)
471 LogMessage ("CreateSocketPair: SYS$QIO(iosb) timeout");
474 LogMessage ("CreateSocketPair: SYS$QIO(iosb) - %d", iosb.iosb$w_status);
475 sys$cantim (&sptb, 0);
479 sys$dassgn (TcpDeviceChan);
484 ** Here we're successfully connected, so cancel the timer, convert the I/O
485 ** channel to a socket fd, close the listener socket and return the connected
488 sys$cantim (&sptb, 0);
491 SocketPair[0] = SockDesc2 ;
492 SocketPair[1] = socket_fd (TcpDeviceChan);
498 /*----------------------------------------------------------------------------*/
500 /*----------------------------------------------------------------------------*/
501 static void SocketPairTimeoutAst (int astparm)
503 SPTB *sptb = (SPTB *) astparm;
505 sys$cancel (sptb->SockChan2); /* Cancel the connect() */
506 sys$cancel (sptb->SockChan1); /* Cancel the accept() */
512 /*----------------------------------------------------------------------------*/
514 /*----------------------------------------------------------------------------*/
515 static int TerminalDeviceAst (int astparm)
520 ** Terminate the terminal buffer
522 TerminalDeviceBuff[TerminalDeviceIosb.iosb$w_bcnt] = '\0';
523 strcat (TerminalDeviceBuff, "\n");
526 ** Send the data read from the terminal device throught the socket pair
528 send (TerminalSocketPair[0], TerminalDeviceBuff, TerminalDeviceIosb.iosb$w_bcnt + 1, 0);
531 ** Queue another async IO to the terminal device
533 status = sys$qio (EFN$C_ENF,
540 sizeof (TerminalDeviceBuff) - 1,
550 /*----------------------------------------------------------------------------*/
552 /*----------------------------------------------------------------------------*/
553 static void LogMessage (char *msg, ...)
555 char *Month[] = {"Jan", "Feb", "Mar", "Apr", "May", "Jun",
556 "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"};
557 static unsigned int pid = 0;
564 ** Get the process pid
570 ** Convert the current time into local time
572 CurTime = time (NULL);
573 LocTime = localtime (&CurTime);
576 ** Format the message buffer
578 sprintf (MsgBuff, "%02d-%s-%04d %02d:%02d:%02d [%08X] %s\n",
579 LocTime->tm_mday, Month[LocTime->tm_mon], (LocTime->tm_year + 1900),
580 LocTime->tm_hour, LocTime->tm_min, LocTime->tm_sec, pid, msg);
583 ** Get any variable arguments and add them to the print of the message buffer
585 va_start (args, msg);
586 vfprintf (stderr, MsgBuff, args);
590 ** Flush standard error output
592 fsync (fileno (stderr));