mirror of https://github.com/lukechilds/node.git
Browse Source
This replaces all sources of openssl-1.0.2i.tar.gz into deps/openssl/openssl PR-URL: https://github.com/nodejs/node/pull/8714 Reviewed-By: Fedor Indutny <fedor@indutny.com>v6
Shigeki Ohtsu
8 years ago
321 changed files with 5881 additions and 39962 deletions
@ -1,38 +1,75 @@ |
|||
HOW TO CONTRIBUTE TO OpenSSL |
|||
---------------------------- |
|||
HOW TO CONTRIBUTE TO PATCHES OpenSSL |
|||
------------------------------------ |
|||
|
|||
Development is coordinated on the openssl-dev mailing list (see |
|||
http://www.openssl.org for information on subscribing). If you |
|||
would like to submit a patch, send it to rt@openssl.org with |
|||
the string "[PATCH]" in the subject. Please be sure to include a |
|||
textual explanation of what your patch does. |
|||
|
|||
You can also make GitHub pull requests. If you do this, please also send |
|||
mail to rt@openssl.org with a brief description and a link to the PR so |
|||
that we can more easily keep track of it. |
|||
(Please visit https://www.openssl.org/community/getting-started.html for |
|||
other ideas about how to contribute.) |
|||
|
|||
Development is coordinated on the openssl-dev mailing list (see the |
|||
above link or https://mta.openssl.org for information on subscribing). |
|||
If you are unsure as to whether a feature will be useful for the general |
|||
OpenSSL community please discuss it on the openssl-dev mailing list first. |
|||
Someone may be already working on the same thing or there may be a good |
|||
reason as to why that feature isn't implemented. |
|||
|
|||
Patches should be as up to date as possible, preferably relative to the |
|||
current Git or the last snapshot. They should follow our coding style |
|||
(see https://www.openssl.org/policies/codingstyle.html) and compile without |
|||
warnings using the --strict-warnings flag. OpenSSL compiles on many varied |
|||
platforms: try to ensure you only use portable features. |
|||
OpenSSL community you might want to discuss it on the openssl-dev mailing |
|||
list first. Someone may be already working on the same thing or there |
|||
may be a good reason as to why that feature isn't implemented. |
|||
|
|||
Our preferred format for patch files is "git format-patch" output. For example |
|||
to provide a patch file containing the last commit in your local git repository |
|||
use the following command: |
|||
The best way to submit a patch is to make a pull request on GitHub. |
|||
(It is not necessary to send mail to rt@openssl.org to open a ticket!) |
|||
If you think the patch could use feedback from the community, please |
|||
start a thread on openssl-dev. |
|||
|
|||
# git format-patch --stdout HEAD^ >mydiffs.patch |
|||
You can also submit patches by sending it as mail to rt@openssl.org. |
|||
Please include the word "PATCH" and an explanation of what the patch |
|||
does in the subject line. If you do this, our preferred format is "git |
|||
format-patch" output. For example to provide a patch file containing the |
|||
last commit in your local git repository use the following command: |
|||
|
|||
% git format-patch --stdout HEAD^ >mydiffs.patch |
|||
|
|||
Another method of creating an acceptable patch file without using git is as |
|||
follows: |
|||
|
|||
# cd openssl-work |
|||
# [your changes] |
|||
# ./Configure dist; make clean |
|||
# cd .. |
|||
# diff -ur openssl-orig openssl-work > mydiffs.patch |
|||
% cd openssl-work |
|||
...make your changes... |
|||
% ./Configure dist; make clean |
|||
% cd .. |
|||
% diff -ur openssl-orig openssl-work >mydiffs.patch |
|||
|
|||
Note that pull requests are generally easier for the team, and community, to |
|||
work with. Pull requests benefit from all of the standard GitHub features, |
|||
including code review tools, simpler integration, and CI build support. |
|||
|
|||
No matter how a patch is submitted, the following items will help make |
|||
the acceptance and review process faster: |
|||
|
|||
1. Anything other than trivial contributions will require a contributor |
|||
licensing agreement, giving us permission to use your code. See |
|||
https://www.openssl.org/policies/cla.html for details. |
|||
|
|||
2. All source files should start with the following text (with |
|||
appropriate comment characters at the start of each line and the |
|||
year(s) updated): |
|||
|
|||
Copyright 20xx-20yy The OpenSSL Project Authors. All Rights Reserved. |
|||
|
|||
Licensed under the OpenSSL license (the "License"). You may not use |
|||
this file except in compliance with the License. You can obtain a copy |
|||
in the file LICENSE in the source distribution or at |
|||
https://www.openssl.org/source/license.html |
|||
|
|||
3. Patches should be as current as possible. When using GitHub, please |
|||
expect to have to rebase and update often. Note that we do not accept merge |
|||
commits. You will be asked to remove them before a patch is considered |
|||
acceptable. |
|||
|
|||
4. Patches should follow our coding style (see |
|||
https://www.openssl.org/policies/codingstyle.html) and compile without |
|||
warnings. Where gcc or clang is availble you should use the |
|||
--strict-warnings Configure option. OpenSSL compiles on many varied |
|||
platforms: try to ensure you only use portable features. |
|||
|
|||
5. When at all possible, patches should include tests. These can either be |
|||
added to an existing test, or completely new. Please see test/README |
|||
for information on the test framework. |
|||
|
|||
6. New features or changed functionality must include documentation. Please |
|||
look at the "pod" files in doc/apps, doc/crypto and doc/ssl for examples of |
|||
our style. |
|||
|
|||
@ -0,0 +1,590 @@ |
|||
/*
|
|||
* Copyright 2016 VMS Software, Inc. All Rights Reserved. |
|||
* |
|||
* Licensed under the OpenSSL license (the "License"). You may not use |
|||
* this file except in compliance with the License. You can obtain a copy |
|||
* in the file LICENSE in the source distribution or at |
|||
* https://www.openssl.org/source/license.html
|
|||
*/ |
|||
|
|||
#ifdef __VMS |
|||
# define OPENSSL_SYS_VMS |
|||
# pragma message disable DOLLARID |
|||
|
|||
|
|||
# include <openssl/opensslconf.h> |
|||
|
|||
# if !defined(_POSIX_C_SOURCE) && defined(OPENSSL_SYS_VMS) |
|||
/*
|
|||
* On VMS, you need to define this to get the declaration of fileno(). The |
|||
* value 2 is to make sure no function defined in POSIX-2 is left undefined. |
|||
*/ |
|||
# define _POSIX_C_SOURCE 2 |
|||
# endif |
|||
|
|||
# include <stdio.h> |
|||
|
|||
# undef _POSIX_C_SOURCE |
|||
|
|||
# include <sys/types.h> |
|||
# include <sys/socket.h> |
|||
# include <netinet/in.h> |
|||
# include <inet.h> |
|||
# include <unistd.h> |
|||
# include <string.h> |
|||
# include <errno.h> |
|||
# include <starlet.h> |
|||
# include <iodef.h> |
|||
# ifdef __alpha |
|||
# include <iosbdef.h> |
|||
# else |
|||
typedef struct _iosb { /* Copied from IOSBDEF.H for Alpha */ |
|||
# pragma __nomember_alignment |
|||
__union { |
|||
__struct { |
|||
unsigned short int iosb$w_status; /* Final I/O status */ |
|||
__union { |
|||
__struct { /* 16-bit byte count variant */ |
|||
unsigned short int iosb$w_bcnt; /* 16-bit byte count */ |
|||
__union { |
|||
unsigned int iosb$l_dev_depend; /* 32-bit device dependent info */ |
|||
unsigned int iosb$l_pid; /* 32-bit pid */ |
|||
} iosb$r_l; |
|||
} iosb$r_bcnt_16; |
|||
__struct { /* 32-bit byte count variant */ |
|||
unsigned int iosb$l_bcnt; /* 32-bit byte count (unaligned) */ |
|||
unsigned short int iosb$w_dev_depend_high; /* 16-bit device dependent info */ |
|||
} iosb$r_bcnt_32; |
|||
} iosb$r_devdepend; |
|||
} iosb$r_io_64; |
|||
__struct { |
|||
__union { |
|||
unsigned int iosb$l_getxxi_status; /* Final GETxxI status */ |
|||
unsigned int iosb$l_reg_status; /* Final $Registry status */ |
|||
} iosb$r_l_status; |
|||
unsigned int iosb$l_reserved; /* Reserved field */ |
|||
} iosb$r_get_64; |
|||
} iosb$r_io_get; |
|||
} IOSB; |
|||
|
|||
# if !defined(__VAXC) |
|||
# define iosb$w_status iosb$r_io_get.iosb$r_io_64.iosb$w_status |
|||
# define iosb$w_bcnt iosb$r_io_get.iosb$r_io_64.iosb$r_devdepend.iosb$r_bcnt_16.iosb$w_bcnt |
|||
# define iosb$r_l iosb$r_io_get.iosb$r_io_64.iosb$r_devdepend.iosb$r_bcnt_16.iosb$r_l |
|||
# define iosb$l_dev_depend iosb$r_l.iosb$l_dev_depend |
|||
# define iosb$l_pid iosb$r_l.iosb$l_pid |
|||
# define iosb$l_bcnt iosb$r_io_get.iosb$r_io_64.iosb$r_devdepend.iosb$r_bcnt_32.iosb$l_bcnt |
|||
# 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 |
|||
# define iosb$l_getxxi_status iosb$r_io_get.iosb$r_get_64.iosb$r_l_status.iosb$l_getxxi_status |
|||
# define iosb$l_reg_status iosb$r_io_get.iosb$r_get_64.iosb$r_l_status.iosb$l_reg_status |
|||
# endif /* #if !defined(__VAXC) */ |
|||
|
|||
# endif /* End of IOSBDEF */ |
|||
|
|||
# include <efndef.h> |
|||
# include <stdlib.h> |
|||
# include <ssdef.h> |
|||
# include <time.h> |
|||
# include <stdarg.h> |
|||
# include <descrip.h> |
|||
|
|||
# include "vms_term_sock.h" |
|||
|
|||
# ifdef __alpha |
|||
static struct _iosb TerminalDeviceIosb; |
|||
# else |
|||
IOSB TerminalDeviceIosb; |
|||
# endif |
|||
|
|||
static char TerminalDeviceBuff[255 + 2]; |
|||
static int TerminalSocketPair[2] = {0, 0}; |
|||
static unsigned short TerminalDeviceChan = 0; |
|||
|
|||
static int CreateSocketPair (int, int, int, int *); |
|||
static void SocketPairTimeoutAst (int); |
|||
static int TerminalDeviceAst (int); |
|||
static void LogMessage (char *, ...); |
|||
|
|||
/*
|
|||
** Socket Pair Timeout Value (must be 0-59 seconds) |
|||
*/ |
|||
# define SOCKET_PAIR_TIMEOUT_VALUE 20 |
|||
|
|||
/*
|
|||
** Socket Pair Timeout Block which is passed to timeout AST |
|||
*/ |
|||
typedef struct _SocketPairTimeoutBlock { |
|||
unsigned short SockChan1; |
|||
unsigned short SockChan2; |
|||
} SPTB; |
|||
|
|||
# ifdef TERM_SOCK_TEST |
|||
|
|||
/*----------------------------------------------------------------------------*/ |
|||
/* */ |
|||
/*----------------------------------------------------------------------------*/ |
|||
int main (int argc, char *argv[], char *envp[]) |
|||
{ |
|||
char TermBuff[80]; |
|||
int TermSock, |
|||
status, |
|||
len; |
|||
|
|||
LogMessage ("Enter 'q' or 'Q' to quit ..."); |
|||
while (strcasecmp (TermBuff, "Q")) { |
|||
/*
|
|||
** Create the terminal socket |
|||
*/ |
|||
status = TerminalSocket (TERM_SOCK_CREATE, &TermSock); |
|||
if (status != TERM_SOCK_SUCCESS) |
|||
exit (1); |
|||
|
|||
/*
|
|||
** Process the terminal input |
|||
*/ |
|||
LogMessage ("Waiting on terminal I/O ...\n"); |
|||
len = recv (TermSock, TermBuff, sizeof (TermBuff), 0) ; |
|||
TermBuff[len] = '\0'; |
|||
LogMessage ("Received terminal I/O [%s]", TermBuff); |
|||
|
|||
/*
|
|||
** Delete the terminal socket |
|||
*/ |
|||
status = TerminalSocket (TERM_SOCK_DELETE, &TermSock); |
|||
if (status != TERM_SOCK_SUCCESS) |
|||
exit (1); |
|||
} |
|||
|
|||
return 1; |
|||
|
|||
} |
|||
# endif |
|||
|
|||
/*----------------------------------------------------------------------------*/ |
|||
/* */ |
|||
/*----------------------------------------------------------------------------*/ |
|||
int TerminalSocket (int FunctionCode, int *ReturnSocket) |
|||
{ |
|||
int status; |
|||
$DESCRIPTOR (TerminalDeviceDesc, "SYS$COMMAND"); |
|||
|
|||
/*
|
|||
** Process the requested function code |
|||
*/ |
|||
switch (FunctionCode) { |
|||
case TERM_SOCK_CREATE: |
|||
/*
|
|||
** Create a socket pair |
|||
*/ |
|||
status = CreateSocketPair (AF_INET, SOCK_STREAM, 0, TerminalSocketPair); |
|||
if (status == -1) { |
|||
LogMessage ("TerminalSocket: CreateSocketPair () - %08X", status); |
|||
if (TerminalSocketPair[0]) |
|||
close (TerminalSocketPair[0]); |
|||
if (TerminalSocketPair[1]) |
|||
close (TerminalSocketPair[1]); |
|||
return (TERM_SOCK_FAILURE); |
|||
} |
|||
|
|||
/*
|
|||
** Assign a channel to the terminal device |
|||
*/ |
|||
status = sys$assign (&TerminalDeviceDesc, |
|||
&TerminalDeviceChan, |
|||
0, 0, 0); |
|||
if (! (status & 1)) { |
|||
LogMessage ("TerminalSocket: SYS$ASSIGN () - %08X", status); |
|||
close (TerminalSocketPair[0]); |
|||
close (TerminalSocketPair[1]); |
|||
return (TERM_SOCK_FAILURE); |
|||
} |
|||
|
|||
/*
|
|||
** Queue an async IO to the terminal device |
|||
*/ |
|||
status = sys$qio (EFN$C_ENF, |
|||
TerminalDeviceChan, |
|||
IO$_READVBLK, |
|||
&TerminalDeviceIosb, |
|||
TerminalDeviceAst, |
|||
0, |
|||
TerminalDeviceBuff, |
|||
sizeof (TerminalDeviceBuff) - 2, |
|||
0, 0, 0, 0); |
|||
if (! (status & 1)) { |
|||
LogMessage ("TerminalSocket: SYS$QIO () - %08X", status); |
|||
close (TerminalSocketPair[0]); |
|||
close (TerminalSocketPair[1]); |
|||
return (TERM_SOCK_FAILURE); |
|||
} |
|||
|
|||
/*
|
|||
** Return the input side of the socket pair |
|||
*/ |
|||
*ReturnSocket = TerminalSocketPair[1]; |
|||
break; |
|||
|
|||
case TERM_SOCK_DELETE: |
|||
/*
|
|||
** Cancel any pending IO on the terminal channel |
|||
*/ |
|||
status = sys$cancel (TerminalDeviceChan); |
|||
if (! (status & 1)) { |
|||
LogMessage ("TerminalSocket: SYS$CANCEL () - %08X", status); |
|||
close (TerminalSocketPair[0]); |
|||
close (TerminalSocketPair[1]); |
|||
return (TERM_SOCK_FAILURE); |
|||
} |
|||
|
|||
/*
|
|||
** Deassign the terminal channel |
|||
*/ |
|||
status = sys$dassgn (TerminalDeviceChan); |
|||
if (! (status & 1)) { |
|||
LogMessage ("TerminalSocket: SYS$DASSGN () - %08X", status); |
|||
close (TerminalSocketPair[0]); |
|||
close (TerminalSocketPair[1]); |
|||
return (TERM_SOCK_FAILURE); |
|||
} |
|||
|
|||
/*
|
|||
** Close the terminal socket pair |
|||
*/ |
|||
close (TerminalSocketPair[0]); |
|||
close (TerminalSocketPair[1]); |
|||
|
|||
/*
|
|||
** Return the initialized socket |
|||
*/ |
|||
*ReturnSocket = 0; |
|||
break; |
|||
|
|||
default: |
|||
/*
|
|||
** Invalid function code |
|||
*/ |
|||
LogMessage ("TerminalSocket: Invalid Function Code - %d", FunctionCode); |
|||
return (TERM_SOCK_FAILURE); |
|||
break; |
|||
} |
|||
|
|||
/*
|
|||
** Return success |
|||
*/ |
|||
return (TERM_SOCK_SUCCESS); |
|||
|
|||
} |
|||
|
|||
/*----------------------------------------------------------------------------*/ |
|||
/* */ |
|||
/*----------------------------------------------------------------------------*/ |
|||
static int CreateSocketPair (int SocketFamily, |
|||
int SocketType, |
|||
int SocketProtocol, |
|||
int *SocketPair) |
|||
{ |
|||
struct dsc$descriptor AscTimeDesc = {0, DSC$K_DTYPE_T, DSC$K_CLASS_S, NULL}; |
|||
static const char* LocalHostAddr = {"127.0.0.1"}; |
|||
unsigned short TcpAcceptChan = 0, |
|||
TcpDeviceChan = 0; |
|||
unsigned long BinTimeBuff[2]; |
|||
struct sockaddr_in sin; |
|||
char AscTimeBuff[32]; |
|||
short LocalHostPort; |
|||
int status; |
|||
unsigned int slen; |
|||
|
|||
# ifdef __alpha |
|||
struct _iosb iosb; |
|||
# else |
|||
IOSB iosb; |
|||
# endif |
|||
|
|||
int SockDesc1 = 0, |
|||
SockDesc2 = 0; |
|||
SPTB sptb; |
|||
$DESCRIPTOR (TcpDeviceDesc, "TCPIP$DEVICE"); |
|||
|
|||
/*
|
|||
** Create a socket |
|||
*/ |
|||
SockDesc1 = socket (SocketFamily, SocketType, 0); |
|||
if (SockDesc1 < 0) { |
|||
LogMessage ("CreateSocketPair: socket () - %d", errno); |
|||
return (-1); |
|||
} |
|||
|
|||
/*
|
|||
** Initialize the socket information |
|||
*/ |
|||
slen = sizeof (sin); |
|||
memset ((char *) &sin, 0, slen); |
|||
sin.sin_family = SocketFamily; |
|||
sin.sin_addr.s_addr = inet_addr (LocalHostAddr); |
|||
sin.sin_port = 0; |
|||
|
|||
/*
|
|||
** Bind the socket to the local IP |
|||
*/ |
|||
status = bind (SockDesc1, (struct sockaddr *) &sin, slen); |
|||
if (status < 0) { |
|||
LogMessage ("CreateSocketPair: bind () - %d", errno); |
|||
close (SockDesc1); |
|||
return (-1); |
|||
} |
|||
|
|||
/*
|
|||
** Get the socket name so we can save the port number |
|||
*/ |
|||
status = getsockname (SockDesc1, (struct sockaddr *) &sin, &slen); |
|||
if (status < 0) { |
|||
LogMessage ("CreateSocketPair: getsockname () - %d", errno); |
|||
close (SockDesc1); |
|||
return (-1); |
|||
} else |
|||
LocalHostPort = sin.sin_port; |
|||
|
|||
/*
|
|||
** Setup a listen for the socket |
|||
*/ |
|||
listen (SockDesc1, 5); |
|||
|
|||
/*
|
|||
** Get the binary (64-bit) time of the specified timeout value |
|||
*/ |
|||
sprintf (AscTimeBuff, "0 0:0:%02d.00", SOCKET_PAIR_TIMEOUT_VALUE); |
|||
AscTimeDesc.dsc$w_length = strlen (AscTimeBuff); |
|||
AscTimeDesc.dsc$a_pointer = AscTimeBuff; |
|||
status = sys$bintim (&AscTimeDesc, BinTimeBuff); |
|||
if (! (status & 1)) { |
|||
LogMessage ("CreateSocketPair: SYS$BINTIM () - %08X", status); |
|||
close (SockDesc1); |
|||
return (-1); |
|||
} |
|||
|
|||
/*
|
|||
** Assign another channel to the TCP/IP device for the accept. |
|||
** This is the channel that ends up being connected to. |
|||
*/ |
|||
status = sys$assign (&TcpDeviceDesc, &TcpDeviceChan, 0, 0, 0); |
|||
if (! (status & 1)) { |
|||
LogMessage ("CreateSocketPair: SYS$ASSIGN () - %08X", status); |
|||
close (SockDesc1); |
|||
return (-1); |
|||
} |
|||
|
|||
/*
|
|||
** Get the channel of the first socket for the accept |
|||
*/ |
|||
TcpAcceptChan = decc$get_sdc (SockDesc1); |
|||
|
|||
/*
|
|||
** Perform the accept using $QIO so we can do this asynchronously |
|||
*/ |
|||
status = sys$qio (EFN$C_ENF, |
|||
TcpAcceptChan, |
|||
IO$_ACCESS | IO$M_ACCEPT, |
|||
&iosb, |
|||
0, 0, 0, 0, 0, |
|||
&TcpDeviceChan, |
|||
0, 0); |
|||
if (! (status & 1)) { |
|||
LogMessage ("CreateSocketPair: SYS$QIO () - %08X", status); |
|||
close (SockDesc1); |
|||
sys$dassgn (TcpDeviceChan); |
|||
return (-1); |
|||
} |
|||
|
|||
/*
|
|||
** Create the second socket to do the connect |
|||
*/ |
|||
SockDesc2 = socket (SocketFamily, SocketType, 0); |
|||
if (SockDesc2 < 0) { |
|||
LogMessage ("CreateSocketPair: socket () - %d", errno); |
|||
sys$cancel (TcpAcceptChan); |
|||
close (SockDesc1); |
|||
sys$dassgn (TcpDeviceChan); |
|||
return (-1) ; |
|||
} |
|||
|
|||
/*
|
|||
** Setup the Socket Pair Timeout Block |
|||
*/ |
|||
sptb.SockChan1 = TcpAcceptChan; |
|||
sptb.SockChan2 = decc$get_sdc (SockDesc2); |
|||
|
|||
/*
|
|||
** Before we block on the connect, set a timer that can cancel I/O on our |
|||
** two sockets if it never connects. |
|||
*/ |
|||
status = sys$setimr (EFN$C_ENF, |
|||
BinTimeBuff, |
|||
SocketPairTimeoutAst, |
|||
&sptb, |
|||
0); |
|||
if (! (status & 1)) { |
|||
LogMessage ("CreateSocketPair: SYS$SETIMR () - %08X", status); |
|||
sys$cancel (TcpAcceptChan); |
|||
close (SockDesc1); |
|||
close (SockDesc2); |
|||
sys$dassgn (TcpDeviceChan); |
|||
return (-1); |
|||
} |
|||
|
|||
/*
|
|||
** Now issue the connect |
|||
*/ |
|||
memset ((char *) &sin, 0, sizeof (sin)) ; |
|||
sin.sin_family = SocketFamily; |
|||
sin.sin_addr.s_addr = inet_addr (LocalHostAddr) ; |
|||
sin.sin_port = LocalHostPort ; |
|||
|
|||
status = connect (SockDesc2, (struct sockaddr *) &sin, sizeof (sin)); |
|||
if (status < 0 ) { |
|||
LogMessage ("CreateSocketPair: connect () - %d", errno); |
|||
sys$cantim (&sptb, 0); |
|||
sys$cancel (TcpAcceptChan); |
|||
close (SockDesc1); |
|||
close (SockDesc2); |
|||
sys$dassgn (TcpDeviceChan); |
|||
return (-1); |
|||
} |
|||
|
|||
/*
|
|||
** Wait for the asynch $QIO to finish. Note that if the I/O was aborted |
|||
** (SS$_ABORT), then we probably canceled it from the AST routine - so log |
|||
** a timeout. |
|||
*/ |
|||
status = sys$synch (EFN$C_ENF, &iosb); |
|||
if (! (iosb.iosb$w_status & 1)) { |
|||
if (iosb.iosb$w_status == SS$_ABORT) |
|||
LogMessage ("CreateSocketPair: SYS$QIO(iosb) timeout"); |
|||
else { |
|||
LogMessage ("CreateSocketPair: SYS$QIO(iosb) - %d", |
|||
iosb.iosb$w_status); |
|||
sys$cantim (&sptb, 0); |
|||
} |
|||
close (SockDesc1); |
|||
close (SockDesc2); |
|||
sys$dassgn (TcpDeviceChan); |
|||
return (-1); |
|||
} |
|||
|
|||
/*
|
|||
** Here we're successfully connected, so cancel the timer, convert the |
|||
** I/O channel to a socket fd, close the listener socket and return the |
|||
** connected pair. |
|||
*/ |
|||
sys$cantim (&sptb, 0); |
|||
|
|||
close (SockDesc1) ; |
|||
SocketPair[0] = SockDesc2 ; |
|||
SocketPair[1] = socket_fd (TcpDeviceChan); |
|||
|
|||
return (0) ; |
|||
|
|||
} |
|||
|
|||
/*----------------------------------------------------------------------------*/ |
|||
/* */ |
|||
/*----------------------------------------------------------------------------*/ |
|||
static void SocketPairTimeoutAst (int astparm) |
|||
{ |
|||
SPTB *sptb = (SPTB *) astparm; |
|||
|
|||
sys$cancel (sptb->SockChan2); /* Cancel the connect() */ |
|||
sys$cancel (sptb->SockChan1); /* Cancel the accept() */ |
|||
|
|||
return; |
|||
|
|||
} |
|||
|
|||
/*----------------------------------------------------------------------------*/ |
|||
/* */ |
|||
/*----------------------------------------------------------------------------*/ |
|||
static int TerminalDeviceAst (int astparm) |
|||
{ |
|||
int status; |
|||
|
|||
/*
|
|||
** Terminate the terminal buffer |
|||
*/ |
|||
TerminalDeviceBuff[TerminalDeviceIosb.iosb$w_bcnt] = '\0'; |
|||
strcat (TerminalDeviceBuff, "\n"); |
|||
|
|||
/*
|
|||
** Send the data read from the terminal device throught the socket pair |
|||
*/ |
|||
send (TerminalSocketPair[0], TerminalDeviceBuff, |
|||
TerminalDeviceIosb.iosb$w_bcnt + 1, 0); |
|||
|
|||
/*
|
|||
** Queue another async IO to the terminal device |
|||
*/ |
|||
status = sys$qio (EFN$C_ENF, |
|||
TerminalDeviceChan, |
|||
IO$_READVBLK, |
|||
&TerminalDeviceIosb, |
|||
TerminalDeviceAst, |
|||
0, |
|||
TerminalDeviceBuff, |
|||
sizeof (TerminalDeviceBuff) - 1, |
|||
0, 0, 0, 0); |
|||
|
|||
/*
|
|||
** Return status |
|||
*/ |
|||
return status; |
|||
|
|||
} |
|||
|
|||
/*----------------------------------------------------------------------------*/ |
|||
/* */ |
|||
/*----------------------------------------------------------------------------*/ |
|||
static void LogMessage (char *msg, ...) |
|||
{ |
|||
char *Month[] = {"Jan", "Feb", "Mar", "Apr", "May", "Jun", |
|||
"Jul", "Aug", "Sep", "Oct", "Nov", "Dec"}; |
|||
static unsigned int pid = 0; |
|||
va_list args; |
|||
time_t CurTime; |
|||
struct tm *LocTime; |
|||
char MsgBuff[256]; |
|||
|
|||
/*
|
|||
** Get the process pid |
|||
*/ |
|||
if (pid == 0) |
|||
pid = getpid (); |
|||
|
|||
/*
|
|||
** Convert the current time into local time |
|||
*/ |
|||
CurTime = time (NULL); |
|||
LocTime = localtime (&CurTime); |
|||
|
|||
/*
|
|||
** Format the message buffer |
|||
*/ |
|||
sprintf (MsgBuff, "%02d-%s-%04d %02d:%02d:%02d [%08X] %s\n", |
|||
LocTime->tm_mday, Month[LocTime->tm_mon], |
|||
(LocTime->tm_year + 1900), LocTime->tm_hour, LocTime->tm_min, |
|||
LocTime->tm_sec, pid, msg); |
|||
|
|||
/*
|
|||
** Get any variable arguments and add them to the print of the message |
|||
** buffer |
|||
*/ |
|||
va_start (args, msg); |
|||
vfprintf (stderr, MsgBuff, args); |
|||
va_end (args); |
|||
|
|||
/*
|
|||
** Flush standard error output |
|||
*/ |
|||
fsync (fileno (stderr)); |
|||
|
|||
return; |
|||
|
|||
} |
|||
#endif |
|||
@ -0,0 +1,30 @@ |
|||
/*
|
|||
* Copyright 2016 VMS Software, Inc. All Rights Reserved. |
|||
* |
|||
* Licensed under the OpenSSL license (the "License"). You may not use |
|||
* this file except in compliance with the License. You can obtain a copy |
|||
* in the file LICENSE in the source distribution or at |
|||
* https://www.openssl.org/source/license.html
|
|||
*/ |
|||
|
|||
#ifndef TERM_SOCK_H |
|||
# define TERM_SOCK_H |
|||
|
|||
/*
|
|||
** Terminal Socket Function Codes |
|||
*/ |
|||
# define TERM_SOCK_CREATE 1 |
|||
# define TERM_SOCK_DELETE 2 |
|||
|
|||
/*
|
|||
** Terminal Socket Status Codes |
|||
*/ |
|||
# define TERM_SOCK_FAILURE 0 |
|||
# define TERM_SOCK_SUCCESS 1 |
|||
|
|||
/*
|
|||
** Terminal Socket Prototype |
|||
*/ |
|||
int TerminalSocket (int FunctionCode, int *ReturnSocket); |
|||
|
|||
#endif |
|||
Some files were not shown because too many files changed in this diff
Loading…
Reference in new issue