[0001]
[0002]
[0003]
[0004]
[0005]
[0006]
[0007]
[0008]
[0009]
[0010]
[0011]
[0012]
[0013]
[0014]
[0015]
[0016]
[0017]
[0018]
[0019]
[0020]
[0021]
[0022]
[0023]
[0024]
[0025]
[0026]
[0027]
[0028]
[0029]
[0030]
[0031]
[0032]
[0033]
[0034]
[0035]
[0036]
[0037]
[0038]
[0039]
[0040]
[0041]
[0042]
[0043]
[0044]
[0045]
[0046]
[0047]
[0048]
[0049]
[0050]
[0051]
[0052]
[0053]
[0054]
[0055]
[0056]
[0057]
[0058]
[0059]
[0060]
[0061]
[0062]
[0063]
[0064]
[0065]
[0066]
[0067]
[0068]
[0069]
[0070]
[0071]
[0072]
[0073]
[0074]
[0075]
[0076]
[0077]
[0078]
[0079]
[0080]
[0081]
[0082]
[0083]
[0084]
[0085]
[0086]
[0087]
[0088]
[0089]
[0090]
[0091]
[0092]
[0093]
[0094]
[0095]
[0096]
[0097]
[0098]
[0099]
[0100]
[0101]
[0102]
[0103]
[0104]
[0105]
[0106]
[0107]
[0108]
[0109]
[0110]
[0111]
[0112]
[0113]
[0114]
[0115]
[0116]
[0117]
[0118]
[0119]
[0120]
[0121]
[0122]
[0123]
[0124]
[0125]
[0126]
[0127]
[0128]
[0129]
[0130]
[0131]
[0132]
[0133]
[0134]
[0135]
[0136]
[0137]
[0138]
[0139]
[0140]
[0141]
[0142]
[0143]
[0144]
[0145]
[0146]
[0147]
[0148]
[0149]
[0150]
[0151]
[0152]
[0153]
[0154]
[0155]
[0156]
[0157]
[0158]
[0159]
[0160]
[0161]
[0162]
[0163]
[0164]
[0165]
[0166]
[0167]
[0168]
[0169]
[0170]
[0171]
[0172]
[0173]
[0174]
[0175]
[0176]
[0177]
[0178]
[0179]
[0180]
[0181]
[0182]
[0183]
[0184]
[0185]
[0186]
[0187]
[0188]
[0189]
[0190]
[0191]
[0192]
[0193]
[0194]
[0195]
[0196]
[0197]
[0198]
[0199]
[0200]
[0201]
[0202]
[0203]
[0204]
[0205]
[0206]
[0207]
[0208]
[0209]
[0210]
[0211]
[0212]
[0213]
[0214]
[0215]
[0216]
[0217]
[0218]
[0219]
[0220]
[0221]
[0222]
[0223]
[0224]
[0225]
[0226]
[0227]
[0228]
[0229]
[0230]
[0231]
[0232]
[0233]
[0234]
[0235]
[0236]
[0237]
[0238]
[0239]
[0240]
[0241]
[0242]
[0243]
[0244]
[0245]
[0246]
[0247]
[0248]
[0249]
[0250]
[0251]
[0252]
[0253]
[0254]
[0255]
[0256]
[0257]
[0258]
[0259]
[0260]
[0261]
[0262]
[0263]
[0264]
[0265]
[0266]
[0267]
[0268]
[0269]
[0270]
[0271]
[0272]
[0273]
[0274]
[0275]
[0276]
[0277]
[0278]
[0279]
[0280]
[0281]
[0282]
[0283]
[0284]
[0285]
[0286]
[0287]
[0288]
[0289]
[0290]
[0291]
[0292]
[0293]
[0294]
[0295]
[0296]
[0297]
[0298]
[0299]
[0300]
[0301]
[0302]
[0303]
[0304]
[0305]
[0306]
[0307]
[0308]
[0309]
[0310]
[0311]
[0312]
[0313]
[0314]
[0315]
[0316]
[0317]
[0318]
[0319]
[0320]
[0321]
[0322]
[0323]
[0324]
[0325]
[0326]
[0327]
[0328]
[0329]
[0330]
[0331]
[0332]
[0333]
[0334]
[0335]
[0336]
[0337]
[0338]
[0339]
[0340]
[0341]
[0342]
[0343]
[0344]
[0345]
[0346]
[0347]
[0348]
[0349]
[0350]
[0351]
[0352]
[0353]
[0354]
[0355]
[0356]
[0357]
[0358]
[0359]
[0360]
[0361]
[0362]
[0363]
[0364]
[0365]
[0366]
[0367]
[0368]
[0369]
[0370]
[0371]
[0372]
[0373]
[0374]
[0375]
[0376]
[0377]
[0378]
[0379]
[0380]
[0381]
[0382]
[0383]
[0384]
[0385]
[0386]
[0387]
[0388]
[0389]
[0390]
[0391]
[0392]
/*****************************************************************************/
/*
ProxyStruct.h
08-AUG-1998 MGD initial
*/
/*****************************************************************************/
#ifndef PROXYSTRUCT_H_LOADED
#define PROXYSTRUCT_H_LOADED 1
#include <atrdef.h>
#include <fibdef.h>
#include "enamel.h"
#include "auth.h"
#include "config.h"
#include "net.h"
#include "odsstruct.h"
#include "proxytunnel.h"
#define PROXY_REWORK_COUNT 4
#pragma nomember_alignment
/* forward references */
typedef struct RequestStruct REQUEST_STRUCT;
typedef struct ServiceStruct SERVICE_STRUCT;
/********************/
/* proxy accounting */
/********************/
#pragma member_alignment __save
#pragma member_alignment
#define TUNNEL_COUNT_MAX 5
typedef struct ProxyAccountingStruct PROXY_ACCOUNTING_STRUCT;
struct ProxyAccountingStruct
{
BOOL ServingEnabled;
int ConnectIpv4Count,
ConnectIpv6Count,
ConnectPersistCount,
ConnectPersistFull,
ConnectPersistMax,
ConnectPersistPeak,
FtpCount,
FtpDeleCount,
FtpDosCount,
FtpListCount,
FtpLoginFailCount,
FtpRetrCount,
FtpStorCount,
FtpUnixCount,
FtpUnknownCount,
FtpVmsCount,
/* ipv4/ipv6 -> ipv4/ipv6 */
GatewayIpvCount[2][2],
/* http/https -> http/https/ftp */
GatewaySchemeCount[2][3],
MethodConnectCount,
MethodDeleteCount,
MethodExtensionCount,
MethodGetCount,
MethodHeadCount,
MethodOptionsCount,
MethodPostCount,
MethodPutCount,
MethodSshCount,
MethodTraceCount,
MethodWebDavCopyCount,
MethodWebDavLockCount,
MethodWebDavMkColCount,
MethodWebDavMoveCount,
MethodWebDavPropFindCount,
MethodWebDavPropPatchCount,
MethodWebDavUnLockCount,
PrevFileCount,
ReworkCount,
ReworkNoType,
ReworkReplaceCount,
ReworkReplaceSearch,
ReworkTooBig,
Socks5Count,
Socks5FailCount,
Socks5SuccessCount,
/* [service-in][proxy-out] */
TunnelCount[TUNNEL_COUNT_MAX][TUNNEL_COUNT_MAX],
TunnelCurrent,
Verify200Count,
Verify403Count,
Verify404Count,
VerifyCurrentCount,
VerifyFindRecordCount,
VerifyFullCount,
VerifySetRecordCount;
int64 /* count of TOTAL blocks received from the server */
BlocksRawRx64,
/* count of TOTAL blocks sent to the server */
BlocksRawTx64,
/* count of bytes in cache-serviced request header */
BytesRawRx64,
/* count of bytes in cache-serviced response */
BytesRawTx64;
ulong /* HTTP status status code counts from network */
NetStatusCodeCount [6];
};
#pragma member_alignment __restore
/**************************************/
/* proxy->server connection structure */
/**************************************/
typedef struct ProxyConnectStruct PROXY_CONNECT;
struct ProxyConnectStruct
{
LIST_ENTRY ListEntry;
int /* how many times the TCP/IP connection has been (re)used */
ConnectionCount,
/* server tick-second when the connection was placed on the list */
EntryTickSecond,
/* is this connection for a SSL client enabled service */
SSLclientEnabled;
ushort /* connect port at remote server */
ConnectPort;
IPADDRESS /* address of remote server */
ConnectIpAddress;
/* pointer to proxy network I/O structure */
NETIO_STRUCT *NetIoPtr;
};
/*****************************************/
/* reverse proxy verification structures */
/*****************************************/
#define PROXY_VERIFY_MAX_AUTH_LENGTH 96
typedef struct ProxyVerifyRecord PROXYVERIFY_RECORD;
struct ProxyVerifyRecord
{
int AuthorizationStringLength,
VerifyAttemptCount;
ulong SourceRealm;
char AuthorizationString [PROXY_VERIFY_MAX_AUTH_LENGTH+1],
HttpdPrcNam [15+1],
RealmName [AUTH_MAX_REALM_GROUP_LENGTH+1],
RemoteUser [AUTH_MAX_USERNAME_LENGTH+1];
};
typedef struct ProxyVerifyGblSecStruct PROXYVERIFY_GBLSEC;
struct ProxyVerifyGblSecStruct
{
ulong GblSecVersion,
GblSecLength;
int RecordCount;
int64 SinceTime64;
/* verify records are stored from this point onwards */
char RecordPool [];
};
/************************/
/* proxy task structure */
/************************/
#pragma member_alignment __save
#pragma member_alignment
/* include to get the GZIP_COMPRESS structure */
#define GZIP_COMPRESS_ONLY
#include "gzip.h"
#undef GZIP_COMPRESS_ONLY
typedef struct ProxyTaskStruct PROXY_TASK;
struct ProxyTaskStruct
{
BOOL WatchItem,
FtpDirList,
FtpHasVersion,
FtpListAlt,
FtpListHide,
FtpListRaw,
FtpStorDone,
FtpTypeDone,
ParseInUse,
PersistentRequest,
PersistentResponse,
ProxyAffinityInUse,
ProxySslHttpRequest,
RequestAuthorization,
ResponseCacheControlMaxAgeZero,
ResponseCacheControlMustReval,
ResponseCacheControlNoCache,
ResponseCacheControlNoStore,
ResponseCacheControlNoTransform,
ResponseCacheControlPrivate,
ResponseCacheControlProxyReval,
ResponseCacheControlPublic,
ResponseContentEncodingGzip,
ResponseContentEncodingUnknown,
ResponseChunkedEnd,
ResponseChunkedEol,
ResponseChunkedEot,
ResponseChunkedInit,
ResponseConnectionClose,
ResponseConnectionKeepAlive,
ResponseKeepAlive,
ResponseNegative,
ResponseNoCache,
ResponseReworkInit,
ResponseTransferEncodingChunked,
ResponseTransferEncodingUnsupported,
ResponseUpgradeWebSocket,
ResponseVaryUnsupported,
TunnelEstablished,
TunnelRequestGenerated;
int ChainIpPort,
ConnectPort,
Ftp230Length,
FtpCommandCount,
FtpCommandSize,
FtpFilePathLength,
FtpFileSystem,
FtpResponseClass,
FtpResponseCode,
FtpResponseCount,
FtpResponseLineCount,
FtpResponseRemaining,
FtpResponseSize,
FtpSpecific,
FtpState,
HttpMethod,
ConnectionCount,
ProxyLookupRetryCount,
ProxyTunnel,
QueuedBodyRead,
RebuiltHeaderLength,
RebuiltRequestLength,
RequestHostPortLength,
RequestHttpMethod,
RequestHttpVersion,
RequestPort,
RequestScheme,
ResponseBodyLength,
ResponseBufferCount,
ResponseBufferNetCount,
ResponseBufferRemaining,
ResponseBufferSize,
ResponseBytes,
ResponseCacheControlMaxAge,
ResponseCacheControlSMaxAge,
ResponseChunkedCount,
ResponseChunkedSize,
ResponseChunkedNewlineCount,
ResponseConsecutiveNewLineCount,
ResponseContentLength,
ResponseHeaderLength,
ResponseHttpVersion,
ResponseReworkMax,
ResponseStatusCode;
int64 ResponseExpiresTime64,
ResponseLastModifiedTime64;
ushort FtpDataIpPort;
char *ChainHostPortPtr,
*ConnectHostPortPtr,
*Ftp230Ptr,
*FtpCommandPtr,
*FtpContentTypePtr,
*FtpFileSystemPtr,
*FtpFilePathPtr,
*FtpNextResponsePtr,
*FtpResponsePtr,
*FtpResponseCurrentPtr,
*FtpWildPtr,
*RebuiltHeaderPtr,
*RebuiltRequestPtr,
*ResponseBufferPtr,
*ResponseBufferCurrentPtr,
*ResponseBufferNetPtr,
*ResponseContentTypePtr,
*RequestHttpCookiePtr,
*RequestHttpMethodNamePtr,
*ResponseHeaderPtr,
*RequestUriPtr,
*RequestUriQueryStringPtr;
char AffinityDomain [32],
ChainHostPort [TCPIP_HOSTNAME_MAX+1+8],
FtpCWD [256],
FtpSYST [128],
RequestHostName [TCPIP_HOSTNAME_MAX+1],
RequestHostPort [TCPIP_HOSTNAME_MAX+1+8],
RequestPortString [16],
RequestSchemeName [16],
ResponseChunkedString [32],
ResponseExpires [32],
ResponseHttpProtocol [16],
ResponseLastModified [48],
Socks5Reply [64],
UrlPassword [32],
UrlUserName [32];
int ReworkLen1 [PROXY_REWORK_COUNT],
ReworkLen2 [PROXY_REWORK_COUNT];
char *ReworkPtr1 [PROXY_REWORK_COUNT],
*ReworkPtr2 [PROXY_REWORK_COUNT];
IPADDRESS BindIpAddress,
ChainIpAddress,
ConnectIpAddress,
FtpDataBindIpAddress,
FtpDataIpAddress,
RequestHostIpAddress;
/* pointer to service struct */
SERVICE_STRUCT *ServicePtr;
/* pointer to associated request (if any) */
REQUEST_STRUCT *RequestPtr;
/* pointer to structure holding reverse-proxy verification data */
PROXYVERIFY_RECORD *VerifyRecordPtr;
ushort FtpDataChannel;
/* network read and write buffer */
char *FtpDataReadRawDataPtr,
*FtpDataWriteRawDataPtr,
*ProxyReadRawDataPtr,
*ProxyWriteRawDataPtr;
int FtpDataReadRawDataSize,
FtpDataWriteRawDataCount,
ProxyReadRawDataSize,
ProxyWriteRawDataCount;
/* pointer to proxy network I/O structure */
NETIO_STRUCT *NetIoPtr;
/* ZLIB (compressed) stream to/from remote server */
GZIP_COMPRESS GzipCompress;
/* AST function pointers */
PROXY_AST FtpAstFunction;
REQUEST_AST FtpDataReadRawAstFunction;
REQUEST_AST FtpDataWriteRawAstFunction;
/* I/O status blocks */
IO_SB FtpDataConnectIOsb,
FtpDataReadIOsb,
FtpDataWriteIOsb,
ProxyConnectIOsb;
SOCKADDRESS FtpDataSocketName,
FtpDataBindSocketName,
ProxySocketName,
ProxyBindSocketName;
TCPIP_HOST_LOOKUP HostLookup;
VMS_ITEM_LIST2 FtpDataBindSocketNameItem,
FtpDataSocketNameItem,
ProxyBindSocketNameItem,
ProxySocketNameItem;
};
#pragma member_alignment __restore
#endif /* PROXYSTRUCT_H_LOADED */
/*****************************************************************************/