[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]
[0393]
[0394]
[0395]
[0396]
[0397]
[0398]
[0399]
[0400]
[0401]
[0402]
[0403]
[0404]
[0405]
[0406]
[0407]
[0408]
[0409]
[0410]
[0411]
[0412]
[0413]
[0414]
[0415]
[0416]
[0417]
[0418]
[0419]
[0420]
[0421]
[0422]
[0423]
[0424]
[0425]
[0426]
[0427]
[0428]
[0429]
[0430]
[0431]
[0432]
[0433]
[0434]
[0435]
[0436]
[0437]
[0438]
[0439]
[0440]
[0441]
[0442]
[0443]
[0444]
[0445]
[0446]
[0447]
[0448]
[0449]
[0450]
[0451]
[0452]
[0453]
[0454]
[0455]
[0456]
[0457]
[0458]
[0459]
[0460]
[0461]
[0462]
[0463]
[0464]
[0465]
[0466]
[0467]
[0468]
[0469]
[0470]
[0471]
[0472]
[0473]
[0474]
[0475]
[0476]
[0477]
[0478]
[0479]
[0480]
[0481]
[0482]
[0483]
[0484]
[0485]
[0486]
[0487]
[0488]
[0489]
[0490]
[0491]
[0492]
[0493]
[0494]
[0495]
[0496]
[0497]
[0498]
[0499]
[0500]
[0501]
[0502]
[0503]
[0504]
[0505]
[0506]
[0507]
[0508]
[0509]
[0510]
[0511]
[0512]
[0513]
[0514]
[0515]
[0516]
[0517]
[0518]
[0519]
[0520]
[0521]
[0522]
[0523]
[0524]
[0525]
[0526]
[0527]
[0528]
[0529]
[0530]
[0531]
[0532]
[0533]
[0534]
[0535]
[0536]
[0537]
[0538]
[0539]
[0540]
[0541]
[0542]
[0543]
[0544]
[0545]
[0546]
[0547]
[0548]
[0549]
[0550]
[0551]
[0552]
[0553]
[0554]
[0555]
[0556]
[0557]
[0558]
[0559]
[0560]
[0561]
[0562]
[0563]
[0564]
[0565]
[0566]
[0567]
[0568]
[0569]
[0570]
[0571]
[0572]
[0573]
[0574]
[0575]
[0576]
[0577]
[0578]
[0579]
[0580]
[0581]
[0582]
[0583]
[0584]
[0585]
[0586]
[0587]
[0588]
[0589]
[0590]
[0591]
[0592]
[0593]
[0594]
[0595]
[0596]
[0597]
[0598]
[0599]
[0600]
[0601]
[0602]
[0603]
[0604]
[0605]
[0606]
[0607]
[0608]
[0609]
[0610]
[0611]
[0612]
[0613]
[0614]
[0615]
[0616]
[0617]
[0618]
[0619]
[0620]
[0621]
[0622]
[0623]
[0624]
[0625]
[0626]
[0627]
[0628]
[0629]
[0630]
[0631]
[0632]
[0633]
[0634]
[0635]
[0636]
[0637]
[0638]
[0639]
[0640]
[0641]
[0642]
[0643]
[0644]
[0645]
[0646]
[0647]
[0648]
[0649]
[0650]
[0651]
[0652]
[0653]
[0654]
[0655]
[0656]
[0657]
[0658]
[0659]
[0660]
[0661]
[0662]
[0663]
[0664]
[0665]
[0666]
[0667]
[0668]
[0669]
[0670]
[0671]
[0672]
[0673]
[0674]
[0675]
[0676]
[0677]
[0678]
[0679]
[0680]
[0681]
[0682]
[0683]
[0684]
[0685]
[0686]
[0687]
[0688]
[0689]
[0690]
[0691]
[0692]
[0693]
[0694]
[0695]
[0696]
[0697]
[0698]
[0699]
[0700]
[0701]
[0702]
[0703]
[0704]
[0705]
[0706]
[0707]
[0708]
[0709]
[0710]
[0711]
[0712]
[0713]
[0714]
[0715]
[0716]
[0717]
[0718]
[0719]
[0720]
[0721]
[0722]
[0723]
[0724]
[0725]
[0726]
[0727]
[0728]
[0729]
[0730]
[0731]
[0732]
[0733]
[0734]
[0735]
[0736]
[0737]
[0738]
[0739]
[0740]
[0741]
[0742]
[0743]
[0744]
[0745]
[0746]
[0747]
[0748]
[0749]
[0750]
[0751]
[0752]
[0753]
[0754]
[0755]
[0756]
[0757]
[0758]
[0759]
[0760]
[0761]
[0762]
[0763]
[0764]
[0765]
[0766]
[0767]
[0768]
[0769]
[0770]
[0771]
[0772]
[0773]
[0774]
[0775]
[0776]
[0777]
[0778]
[0779]
[0780]
[0781]
[0782]
[0783]
[0784]
[0785]
[0786]
[0787]
[0788]
[0789]
[0790]
[0791]
[0792]
[0793]
[0794]
[0795]
[0796]
[0797]
[0798]
[0799]
[0800]
[0801]
[0802]
[0803]
[0804]
[0805]
[0806]
[0807]
[0808]
[0809]
[0810]
[0811]
[0812]
[0813]
[0814]
[0815]
[0816]
[0817]
[0818]
[0819]
[0820]
[0821]
[0822]
[0823]
[0824]
[0825]
[0826]
[0827]
[0828]
[0829]
[0830]
[0831]
[0832]
[0833]
[0834]
[0835]
[0836]
[0837]
[0838]
[0839]
[0840]
[0841]
[0842]
[0843]
[0844]
[0845]
[0846]
[0847]
[0848]
[0849]
[0850]
[0851]
[0852]
[0853]
[0854]
[0855]
[0856]
[0857]
[0858]
[0859]
[0860]
[0861]
[0862]
[0863]
[0864]
[0865]
[0866]
[0867]
[0868]
[0869]
[0870]
[0871]
[0872]
[0873]
[0874]
[0875]
[0876]
[0877]
[0878]
[0879]
[0880]
[0881]
[0882]
[0883]
[0884]
[0885]
[0886]
[0887]
[0888]
[0889]
[0890]
[0891]
[0892]
[0893]
[0894]
[0895]
[0896]
[0897]
[0898]
[0899]
[0900]
[0901]
[0902]
[0903]
[0904]
[0905]
[0906]
[0907]
[0908]
[0909]
[0910]
[0911]
[0912]
[0913]
[0914]
[0915]
[0916]
[0917]
[0918]
[0919]
[0920]
[0921]
[0922]
[0923]
[0924]
[0925]
[0926]
[0927]
[0928]
[0929]
[0930]
[0931]
[0932]
[0933]
[0934]
[0935]
[0936]
[0937]
[0938]
[0939]
[0940]
[0941]
[0942]
[0943]
[0944]
[0945]
[0946]
[0947]
[0948]
[0949]
[0950]
[0951]
[0952]
[0953]
[0954]
[0955]
[0956]
[0957]
[0958]
[0959]
[0960]
[0961]
[0962]
[0963]
[0964]
[0965]
[0966]
[0967]
[0968]
[0969]
[0970]
[0971]
[0972]
[0973]
[0974]
[0975]
[0976]
[0977]
[0978]
[0979]
[0980]
[0981]
[0982]
[0983]
[0984]
[0985]
[0986]
[0987]
[0988]
[0989]
[0990]
[0991]
[0992]
[0993]
[0994]
[0995]
[0996]
[0997]
[0998]
[0999]
[1000]
[1001]
[1002]
[1003]
[1004]
[1005]
[1006]
[1007]
[1008]
[1009]
[1010]
[1011]
[1012]
[1013]
[1014]
[1015]
[1016]
[1017]
[1018]
[1019]
[1020]
[1021]
[1022]
[1023]
[1024]
[1025]
[1026]
[1027]
[1028]
[1029]
[1030]
[1031]
[1032]
[1033]
[1034]
[1035]
[1036]
[1037]
[1038]
[1039]
[1040]
[1041]
[1042]
[1043]
[1044]
[1045]
[1046]
[1047]
[1048]
[1049]
[1050]
[1051]
[1052]
[1053]
[1054]
[1055]
[1056]
[1057]
[1058]
[1059]
[1060]
[1061]
[1062]
[1063]
[1064]
[1065]
[1066]
[1067]
[1068]
[1069]
[1070]
[1071]
[1072]
[1073]
[1074]
[1075]
[1076]
[1077]
[1078]
[1079]
[1080]
[1081]
[1082]
[1083]
[1084]
[1085]
[1086]
[1087]
[1088]
[1089]
[1090]
[1091]
[1092]
[1093]
[1094]
[1095]
[1096]
[1097]
[1098]
[1099]
[1100]
[1101]
[1102]
[1103]
[1104]
[1105]
[1106]
[1107]
[1108]
[1109]
[1110]
[1111]
[1112]
[1113]
[1114]
[1115]
[1116]
[1117]
[1118]
[1119]
[1120]
[1121]
[1122]
[1123]
[1124]
[1125]
[1126]
[1127]
[1128]
[1129]
[1130]
[1131]
[1132]
[1133]
[1134]
[1135]
[1136]
[1137]
[1138]
[1139]
[1140]
[1141]
[1142]
[1143]
[1144]
[1145]
[1146]
[1147]
[1148]
[1149]
[1150]
[1151]
[1152]
/*****************************************************************************/
/*
HTTP2net.c
HTTP/2 network reads and writes. Reads are multiplexed onto the connection by
the client and similarly multiplexed off at the server end. The frames read
are then handed off to the appropriate processing function by frame type.
Writes are serialised onto the connection using a FIFO queue. Well, four
(prioritised) queues to be precise. Request (network) reads and writes have
wrapper functions that interface the single HTTP/2 multiplexed connection to an
emulation of the dedicated, per-request network connection.
All request data being written to the network is required to be prepended with
a 9 byte frame header. Without copying a lot of data between buffers this is
implemented using two, independent writes; the header then the data. In an
effort to reduce the overall number of such network writes (especially when
transported by SSL), *all* WASD memory allocations have inbuilt space for an
HTTP/2 frame header immediately preceding the returned memory pointer. This
space has some (not very distant) magic (VM_MAGIC_HTTP2) to indicate it is
present. So, when this is detected the HTTP/2 frame header fields can be
written to the space immediately preceding the data buffer, saving on the
separate, small (and relatively costly) frame header write, reducing *all*
request data written from two to a single write without adding significant
complication to memory or data buffer management. Hopefully not too clever for
its own good! Of course it is also possible that a write originates from
non-allocated memory (e.g. string constant) and does not contain this header
and so requires a separate header write.
VERSION HISTORY
---------------
31-JAN-2020 MGD fiddle with the code (perhaps optimisations, even bugfixes)
15-FEB-2019 MGD bugfix; Http2NetQueueWrite() PEEK_8 at w2ptr->type
01-JUL-2018 MGD bugfix; Http2NetIoWrite() blocking write data must be
asynchronously persistent so employ internal buffer(s)
06-JAN-2018 MGD refactor write code paths (simplify and greater efficiency)
11-FEB-2017 MGD bugfix; Http2NetQueueWrite() and Http2NetWriteDataAst()
blocking writes are not placed on the request's
write list as they are transparent to the request
bugfix; Http2NetQueueWrite() deliver via NetIoWriteStatus()
using SS$_NORMAL (HTTP/2 I/O) not the request ->VmsStatus
06-AUG-2016 MGD last stream ident now noted by Http2RequestBegin()
16-AUG-2015 MGD initial
*/
/*****************************************************************************/
#ifdef WASD_VMS_V7
# undef __VMS_VER
# define __VMS_VER 70000000
# undef __CRTL_VER
# define __CRTL_VER 70000000
#else
# ifdef WASD_VMS_V7
# undef _VMS__V6__SOURCE
# define _VMS__V6__SOURCE
# undef __VMS_VER
# define __VMS_VER 70000000
# undef __CRTL_VER
# define __CRTL_VER 70000000
# endif
#endif
#include <stdio.h>
#include <ctype.h>
#include "wasd.h"
#define WASD_MODULE "HTTP2NET"
/********************/
/* external storage */
/********************/
extern uint Http2ClientPrefaceLength,
Http2FlowControlCurrent,
Http2MaxFrameSize;
extern char ErrorSanityCheck[],
Http2ClientPreface[];
extern LIST_HEAD Http2List;
extern WATCH_STRUCT Watch;
/*****************************************************************************/
/*
Initial read of the data described below.
*/
int Http2NetClientRead (HTTP2_STRUCT *h2ptr)
{
int status;
/*********/
/* begin */
/*********/
if (WATCHMOD (h2ptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_MOD_HTTP2,
"Http2NetClientRead() !&X", h2ptr->NetIoPtr);
h2ptr->ReadBufferCount = 0;
status = NetIoRead (h2ptr->NetIoPtr, Http2NetClientReadAst, h2ptr,
h2ptr->ReadBufferPtr, h2ptr->ReadBufferSize);
return (status);
}
/*****************************************************************************/
/*
AST of read from client with sufficient data to parse (at least) the frame
header (9 octets) so the length of the frame can be determined. Multiple reads
may be performed to build up a complete frame in the read buffer (potentially
more than one frame). Only a complete frame is parsed and processed. This
function always expects the frame to be located at the beinning of the read
buffer.
*/
void Http2NetClientReadAst (HTTP2_STRUCT *h2ptr)
{
int count, length, retval, status;
uint flags, ident, type;
uchar *bptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (h2ptr, WATCH_MOD_HTTP2))
{
WatchThis (WATCHITM(h2ptr), WATCH_MOD_HTTP2,
"Http2NetClientReadAst() !&F !&X !&S !UL",
Http2NetClientReadAst,
h2ptr->NetIoPtr, h2ptr->NetIoPtr->ReadStatus,
h2ptr->NetIoPtr->ReadCount);
WatchDataDump (h2ptr->ReadBufferPtr, h2ptr->NetIoPtr->ReadCount);
}
/* if the connection has a set VMS status */
if (h2ptr->NetIoPtr->VmsStatus)
h2ptr->NetIoPtr->ReadStatus = h2ptr->NetIoPtr->WriteStatus =
h2ptr->NetIoPtr->VmsStatus;
/* if the connection presented a read error */
if (VMSnok (h2ptr->NetIoPtr->ReadStatus))
{
Http2CloseConnection (h2ptr);
return;
}
h2ptr->BytesRawRx64 += h2ptr->NetIoPtr->ReadCount;
h2ptr->BytesRawTallyRx64 += h2ptr->NetIoPtr->ReadCount;
h2ptr->ReadBufferCount += h2ptr->NetIoPtr->ReadCount;
bptr = h2ptr->ReadBufferPtr;
count = h2ptr->ReadBufferCount;
while (count >= HTTP2_FRAME_HEADER_SIZE)
{
if (h2ptr->ExpectingH2cPreface)
{
/* RFC 7540 3.2 Starting HTTP/2 for "http" URIs */
if (count >= Http2ClientPrefaceLength &&
MATCH8 (bptr, Http2ClientPreface) &&
MATCH0 (bptr, Http2ClientPreface, Http2ClientPrefaceLength))
{
if (WATCHING (h2ptr, WATCH_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_HTTP2,
"HTTP/2 connection preface (h2c)");
h2ptr->ExpectingH2cPreface = false;
count -= Http2ClientPrefaceLength;
bptr += Http2ClientPrefaceLength;
continue;
}
Http2Error (h2ptr, 0, HTTP2_ERROR_PROTOCOL);
return;
}
HTTP2_PEEK_24 (bptr, length);
if (WATCHPNT(h2ptr) && (WATCH_CATEGORY(WATCH_HTTP2) ||
WATCH_MODULE(WATCH_MOD_HTTP2)))
{
if (count >= length)
Http2WatchFrame (h2ptr, bptr, NULL, count, false);
else
{
HTTP2_PEEK_8 (bptr+3, type);
HTTP2_PEEK_8 (bptr+4, flags);
HTTP2_PEEK_32 (bptr+5, ident);
WatchThis (WATCHITM(h2ptr), WATCH_HTTP2,
"FRAME !SL count:!UL length:!UL type:!UL flags:0x!2ZL ident:!UL",
count-length, count, length, type, flags, ident);
}
}
if (length > h2ptr->ServerMaxFrameSize)
{
if (WATCHING (h2ptr, WATCH_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_HTTP2,
"HTTP/2 frame size !UL exceeds !UL bytes",
length, h2ptr->ServerMaxFrameSize);
Http2Error (h2ptr, 0, HTTP2_ERROR_SIZE);
return;
}
/* if not a complete frame */
if (length + HTTP2_FRAME_HEADER_SIZE > count) break;
HTTP2_GET_24 (bptr, length);
HTTP2_GET_8 (bptr, type);
HTTP2_GET_8 (bptr, flags);
HTTP2_GET_32 (bptr, ident);
count -= HTTP2_FRAME_HEADER_SIZE;
h2ptr->FrameCountRx++;
h2ptr->FrameTallyRx++;
if (ident)
{
h2ptr->FrameRequestCountRx++;
h2ptr->FrameRequestTallyRx++;
}
if (ident)
{
if (ident & 0x1 == 0)
{
/* client initiated streams must have odd numbered idents */
if (WATCHING (h2ptr, WATCH_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_HTTP2,
"STREAM error !UL", ident);
Http2Error (h2ptr, 0, HTTP2_ERROR_PROTOCOL);
return;
}
if (h2ptr->GoAwayIdent)
{
/* ignore frames with idents after server signals goaway */
count -= length;
bptr += length;
continue;
}
}
/* mitigate CVE-2019-9518 */
if (!length && !(flags & HTTP2_FLAG_DATA_END_STR))
{
switch (type)
{
case HTTP2_FRAME_DATA :
case HTTP2_FRAME_HEADERS :
case HTTP2_FRAME_CONTINUATION :
case HTTP2_FRAME_PUSH_PROMISE :
if (h2ptr->EmptyFrameLimitCount++ > HTTP2_EMPTY_FRAME_LIMIT_COUNT)
{
if (WATCHING (h2ptr, WATCH_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_HTTP2,
"LIMIT empty frames to !UL/S (DoS?)",
HTTP2_EMPTY_FRAME_LIMIT_COUNT);
Http2Error (h2ptr, 0, HTTP2_ERROR_CALM);
return;
}
}
}
switch (type)
{
case HTTP2_FRAME_DATA :
retval = Http2RequestData (h2ptr, flags, ident, bptr, length);
if (retval >= 0) break;
retval = Http2Error (h2ptr, ident, -(retval));
if (retval >= 0) break;
return;
case HTTP2_FRAME_HEADERS :
case HTTP2_FRAME_CONTINUATION :
retval = HpackHeadersFrame (&h2ptr->HpackClientTable,
flags, ident, bptr, length);
if (retval >= 0) break;
retval = Http2Error (h2ptr, ident, -(retval));
if (retval >= 0) break;
return;
case HTTP2_FRAME_PRIORITY :
retval = Http2Priority (h2ptr, flags, bptr, length);
if (retval >= 0) break;
retval = Http2Error (h2ptr, 0, -(retval));
if (retval >= 0) break;
return;
case HTTP2_FRAME_RST_STREAM :
retval = Http2ResetStream (h2ptr, ident, 0, bptr, length);
if (retval >= 0) break;
retval = Http2Error (h2ptr, ident, -(retval));
if (retval >= 0) break;
return;
case HTTP2_FRAME_SETTINGS :
retval = Http2Settings (h2ptr, flags, bptr, length);
if (retval >= 0) break;
retval = Http2Error (h2ptr, 0, -(retval));
if (retval >= 0) break;
return;
case HTTP2_FRAME_PUSH_PROMISE :
/* client cannot server-push (RFC7540 8.2) */
retval = Http2Error (h2ptr, 0, -(HTTP2_ERROR_PROTOCOL));
if (retval >= 0) break;
return;
case HTTP2_FRAME_PING :
retval = Http2Ping (h2ptr, flags, bptr, length);
if (retval >= 0) break;
retval = Http2Error (h2ptr, 0, -(retval));
if (retval >= 0) break;
return;
case HTTP2_FRAME_GOAWAY :
retval = Http2GoAway (h2ptr, 0, bptr, length);
if (retval >= 0) break;
retval = Http2Error (h2ptr, 0, -(retval));
if (retval >= 0) break;
return;
case HTTP2_FRAME_WINDOW_UPDATE :
retval = Http2WindowUpdate (h2ptr, ident, 0, bptr, length);
if (retval >= 0) break;
retval = Http2Error (h2ptr, ident, -(retval));
if (retval >= 0) break;
return;
default :
Http2Error (h2ptr, 0, -(HTTP2_ERROR_PROTOCOL));
return;
}
count -= length;
bptr += length;
}
if (count)
{
/* shuffle remaining data to front of buffer */
memcpy (h2ptr->ReadBufferPtr, bptr, count);
}
h2ptr->ReadBufferCount = count;
bptr = h2ptr->ReadBufferPtr + count;
length = h2ptr->ReadBufferSize - count;
/* get the next, or rest of, frame */
NetIoRead (h2ptr->NetIoPtr, Http2NetClientReadAst, h2ptr, bptr, length);
}
/*****************************************************************************/
/*
Return true if this HTTP/2 stream has outstanding network I/O.
*/
BOOL Http2NetIoInProgress (NETIO_STRUCT *ioptr)
{
/*********/
/* begin */
/*********/
ioptr = ((HTTP2_STREAM_STRUCT*)ioptr->Http2StreamPtr)->Http2Ptr->NetIoPtr;
if (ioptr->SesolaPtr) return (SesolaNetIoInProgress (ioptr->SesolaPtr));
return (ioptr->WriteAstFunction || ioptr->ReadAstFunction);
}
/*****************************************************************************/
/*
This function wraps the HTTP/1.1 network I/O response reads. Named
Http2NetIo..() for consistency with NetIo..() and SesolaNetIo..(). It is
called from NetIoRead(). It calls the Http2RequestData() function to handle
the asynchronous HTTP/2 DATA frames from the client (request body) and the
reads by the request body processing code.
*/
int Http2NetIoRead (NETIO_STRUCT *ioptr)
{
HTTP2_STRUCT *h2ptr;
HTTP2_STREAM_STRUCT *s2ptr;
REQUEST_STRUCT *rqptr;
/*********/
/* begin */
/*********/
s2ptr = ioptr->Http2StreamPtr;
h2ptr = s2ptr->Http2Ptr;
rqptr = s2ptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(rqptr), WATCH_MOD_HTTP2,
"Http2NetRead() !&A !&X !UL",
ioptr->ReadAstFunction, ioptr->ReadPtr, ioptr->ReadSize);
/* no such creature as a blocking HTTP/2 read! */
if (!ioptr->ReadAstFunction)
{
ErrorNoticed (rqptr, SS$_BUGCHECK, ErrorSanityCheck, FI_LI);
return (SS$_BUGCHECK);
}
return (Http2RequestData (h2ptr, 0, s2ptr->Ident, NULL, 0));
}
/*****************************************************************************/
/*
Wraps the HTTP/1.1 network I/O response writes in HTTP/2 DATA frames. Named
Http2NetIo..() for consistency with NetIo..() and SesolaNetIO..(). It is
called from NetIoWrite(). The function must be able to queue multiple
(sub-)writes should a request write exceed the maximum client accepted frame
size. Optimally the write buffers will always be sized at or below the maximum
frame size.
All HTTP/2 I/O are by nature asynchronous and so a blocking write (one with a
NULL |AstFunction| parameter) is made asynchronous. Data persistance must be
guaranteed during the write and so is *always* copied to HTTP/2 internal
buffers and *never* used in-situ, as the calling code may well (*will*)
continue on processing and likely (*will*) modify the data buffer it considers
was *already* written. An example of where blocking writes are used is the
WATCH facility.
If |DataPtr| is NULL then an empty frame with the end data flag set is sent.
If the stream associated with the request has been closed then allow the write
to be queued but the status will be delivered as cancelled, not performing the
network I/O but allowing any AST to be delivered.
*/
int Http2NetIoWrite
(
NETIO_STRUCT *ioptr,
VOID_AST AstFunction,
void *AstParam,
void *DataPtr,
uint DataLength
)
{
BOOL magic;
int queue, status;
HTTP2_STRUCT *h2ptr;
HTTP2_HEADER_STRUCT *hsptr;
HTTP2_STREAM_STRUCT *s2ptr;
HTTP2_WRITE_STRUCT *w2ptr;
REQUEST_STRUCT *rqptr;
VM_STRUCT *vmptr;
/*********/
/* begin */
/*********/
s2ptr = ioptr->Http2StreamPtr;
h2ptr = s2ptr->Http2Ptr;
rqptr = s2ptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(rqptr), WATCH_MOD_HTTP2,
"Http2NetIoWrite() !&A !&X !UL",
AstFunction, DataPtr, DataLength);
if (!AstFunction)
{
/* blocking write */
if (ioptr->VmsStatus)
{
ioptr->WriteIOsb.Count = 0;
ioptr->WriteIOsb.Status = ioptr->VmsStatus;
return (ioptr->WriteIOsb.Status);
}
if (rqptr->Http2Stream.State == HTTP2_STATE_CLOSED ||
rqptr->Http2Stream.State == HTTP2_STATE_CLOSED_LOC)
{
ioptr->WriteIOsb.Count = 0;
ioptr->WriteIOsb.Status = SS$_VCCLOSED;
return (ioptr->WriteIOsb.Status);
}
ioptr->WriteIOsb.Count = DataLength;
ioptr->WriteIOsb.Status = SS$_NORMAL;
}
if (rqptr->rqPathSet.Http2WriteQueue)
queue = rqptr->rqPathSet.Http2WriteQueue;
else
queue = HTTP2_WRITE_QUEUE_NORMAL;
if (!DataPtr)
{
DataPtr = "";
DataLength = 0;
}
/* check for the appropriate incantation */
vmptr = (VM_STRUCT*)((uchar*)DataPtr - sizeof(VM_STRUCT));
magic = false;
switch (vmptr->magic)
{
case VM_MAGIC_CACHE :
case VM_MAGIC_DECC :
case VM_MAGIC_EXPAT :
case VM_MAGIC_GENERAL :
case VM_MAGIC_HTTP2 :
case VM_MAGIC_OPENSSL :
case VM_MAGIC_PERMCACHE :
case VM_MAGIC_REQUEST : magic = true;
}
for (;;)
{
/******************/
/* write frame(s) */
/******************/
/* loop for where a write potentially exceeds the max frame size */
#if WATCH_MOD
if (WATCHING (rqptr, WATCH_HTTP2))
WatchThis (WATCHITM(rqptr), WATCH_HTTP2, "MAGIC !&B !UL/!UL",
magic, DataLength, h2ptr->ClientMaxFrameSize);
#endif
if (magic)
{
/* can use the in-built header of WASD allocated memory */
w2ptr = Http2GetWriteStruct (h2ptr, 0, FI_LI);
w2ptr->HeaderPtr = hsptr = vmptr->h2header;
w2ptr->DataPtr = DataPtr;
if (DataLength <= h2ptr->ClientMaxFrameSize)
{
w2ptr->DataLength = DataLength;
/* final or only write delivers any AST */
w2ptr->AstFunction = AstFunction;
w2ptr->AstParam = AstParam;
}
else
w2ptr->DataLength = h2ptr->ClientMaxFrameSize;
}
else
{
/* buffer partial or "blocking" or non-allocated (magic) write */
if (DataLength <= h2ptr->ClientMaxFrameSize)
w2ptr = Http2GetWriteStruct (h2ptr, DataLength, FI_LI);
else
w2ptr = Http2GetWriteStruct (h2ptr, h2ptr->ClientMaxFrameSize, FI_LI);
w2ptr->HeaderPtr = hsptr = w2ptr->header;
w2ptr->DataPtr = w2ptr->payload;
if (DataLength <= h2ptr->ClientMaxFrameSize)
{
w2ptr->DataLength = DataLength;
/* final or only write delivers any AST */
w2ptr->AstFunction = AstFunction;
w2ptr->AstParam = AstParam;
}
else
w2ptr->DataLength = h2ptr->ClientMaxFrameSize;
memcpy (w2ptr->DataPtr, DataPtr, w2ptr->DataLength);
}
w2ptr->Http2Ptr = h2ptr;
w2ptr->RequestPtr = rqptr;
w2ptr->WriteQueue = queue;
HTTP2_PLACE_24 (hsptr->length, w2ptr->DataLength)
HTTP2_PLACE_8 (hsptr->type, HTTP2_FRAME_DATA);
HTTP2_PLACE_8 (hsptr->flags, 0);
HTTP2_PLACE_32 (hsptr->ident, rqptr->Http2Stream.Ident);
Http2NetQueueWrite (h2ptr, w2ptr);
/* on the only or final write then that's it */
if (DataLength <= h2ptr->ClientMaxFrameSize) return (SS$_NORMAL);
/* if intermediate write then continue to the next */
(uchar*)DataPtr += w2ptr->DataLength;
DataLength -= w2ptr->DataLength;
/* any magic cannot be used with subsequent writes */
magic = false;
}
}
/*****************************************************************************/
/*
HTTP/2 network writes are serialised using FIFO lists. In this current
implementation of WASD HTTP/2 there is limited prioritisation of streams.
There are four queues/lists. Connection management writes are to queue zero
(index 0) and have the highest priority, then the high priority (index 1),
normal priority (index 2), and then the lowest (index 3). The HIGH, NORMAL
(default) and LOW can be set via path mappings. All writes from a queue are
FIFO and asynchronous (empty AST function notwithstanding). Request data
writes are subject to RFC 7540 flow control.
*/
void Http2NetQueueWrite
(
HTTP2_STRUCT *h2ptr,
HTTP2_WRITE_STRUCT *w2ptr
)
{
int cnt, idx, type;
REQUEST_STRUCT *rqptr;
HTTP2_STREAM_STRUCT *s2ptr;
HTTP2_WRITE_STRUCT *w22ptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (h2ptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_MOD_HTTP2,
"Http2NetQueueWrite() h2ptr:!&X w2ptr:!&X write-in-prog:!&B",
h2ptr, w2ptr, NETIO_WRITE_IN_PROGRESS(h2ptr->NetIoPtr));
if (w2ptr)
{
/*************/
/* new write */
/*************/
/* must always have an AST address to indicate NETIO is in use */
if (!w2ptr->AstFunction)
w2ptr->AstFunction = w2ptr->AstParam = Http2Net_WRITE_NO_AST;
/* add to the HTTP/2 connection's write list */
ListAddTail (&h2ptr->QueuedWriteList[w2ptr->WriteQueue], w2ptr,
LIST_ENTRY_TYPE_WRITE2);
if (w2ptr->RequestPtr) w2ptr->RequestPtr->Http2Stream.QueuedWriteCount++;
cnt = 0;
for (idx = HTTP2_WRITE_QUEUE_MAX; idx <= HTTP2_WRITE_QUEUE_LOW; idx++)
cnt += LIST_GET_COUNT (&h2ptr->QueuedWriteList[idx]);
if (cnt > h2ptr->QueuedWritePeak) h2ptr->QueuedWritePeak = cnt;
}
/* if there's a write already in progress */
if (NETIO_WRITE_IN_PROGRESS(h2ptr->NetIoPtr)) return;
/***************/
/* check queue */
/***************/
/* look through the queues from highest to lowest priority */
for (idx = HTTP2_WRITE_QUEUE_MAX; idx <= HTTP2_WRITE_QUEUE_LOW; idx++)
{
/* if nothing in this queue then look at the next */
if (!LIST_GET_COUNT (&h2ptr->QueuedWriteList[idx])) continue;
for (w2ptr = LIST_GET_HEAD (&h2ptr->QueuedWriteList[idx]);
w2ptr != NULL;
w2ptr = LIST_GET_NEXT(w2ptr))
{
/* double check in case of some unexpected timing issue! */
if (w2ptr->WriteInProgress) return;
/* if not a DATA frame and therefore not subject to flow control */
HTTP2_PEEK_8 (w2ptr->type, type);
if (type != HTTP2_FRAME_DATA) break;
/* if not associated with a request */
if (!(rqptr = w2ptr->RequestPtr)) break;
/* if SS$_VCCLOSED or other specific status just do it */
if (h2ptr->NetIoPtr->VmsStatus) break;
/****************/
/* flow control */
/****************/
s2ptr = &rqptr->Http2Stream;
if (WATCHMOD (rqptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(rqptr), WATCH_MOD_HTTP2,
"FLOW length:!UL h2size:!UL s2size:!UL",
w2ptr->DataLength, h2ptr->WriteWindowSize,
s2ptr->WriteWindowSize);
if ((int)s2ptr->WriteWindowSize - (int)w2ptr->DataLength < 0 ||
(int)h2ptr->WriteWindowSize - (int)w2ptr->DataLength < 0)
{
if (!s2ptr->FlowControl)
{
Http2FlowControlCurrent++;
h2ptr->FlowControlCurrent++;
h2ptr->FlowControlTally++;
s2ptr->FlowControl = true;
if (WATCHING (rqptr, WATCH_HTTP2))
WatchThis (WATCHITM(rqptr), WATCH_HTTP2,
"FLOW control ON (!UL/!UL/!UL)",
w2ptr->DataLength, s2ptr->WriteWindowSize,
h2ptr->WriteWindowSize);
}
/* continue to look for a write that can be performed */
continue;
}
h2ptr->FlowFrameTally++;
if (s2ptr->FlowControl)
{
if (Http2FlowControlCurrent) Http2FlowControlCurrent--;
if (h2ptr->FlowControlCurrent) h2ptr->FlowControlCurrent--;
s2ptr->FlowControl = false;
if (WATCHING (rqptr, WATCH_HTTP2))
WatchThis (WATCHITM(rqptr), WATCH_HTTP2,
"FLOW control OFF (!UL/!UL/!UL)",
w2ptr->DataLength, s2ptr->WriteWindowSize,
h2ptr->WriteWindowSize);
}
/* adjust the flow control window in use */
s2ptr->WriteWindowSize -= w2ptr->DataLength;
h2ptr->WriteWindowSize -= w2ptr->DataLength;
/* break from the entry loop */
break;
}
/* break from the queue loop to perform the write */
if (w2ptr) break;
}
/* if nothing in any queue */
if (idx > HTTP2_WRITE_QUEUE_LOW)
{
if (!h2ptr->NetIoPtr->Channel)
Http2CloseConnection (h2ptr);
else
if (h2ptr->NetIoPtr->VmsStatus)
Http2CloseConnection (h2ptr);
else
if (h2ptr->GoAwayLastStreamIdent)
Http2CloseConnection (h2ptr);
return;
}
/*********/
/* write */
/*********/
w2ptr->WriteInProgress = true;
if (WATCHMOD (h2ptr, WATCH_MOD_HTTP2))
{
WatchThis (WATCHITM(h2ptr), WATCH_MOD_HTTP2, "!&X queue:!UL",
w2ptr, w2ptr->WriteQueue);
Http2WatchFrame (h2ptr, w2ptr->HeaderPtr,
w2ptr->DataPtr, w2ptr->DataLength,
w2ptr->HeaderPtr != w2ptr->header);
}
else
if (WATCHING (h2ptr, WATCH_HTTP2))
Http2WatchFrame (h2ptr, w2ptr->HeaderPtr, w2ptr->DataPtr, 0,
w2ptr->HeaderPtr != w2ptr->header);
/* if something is amiss with the HTTP/2 connection */
if (h2ptr->NetIoPtr->VmsStatus)
{
NetIoWriteStatus (h2ptr->NetIoPtr, Http2NetWriteDataAst,
w2ptr, h2ptr->NetIoPtr->VmsStatus, 0);
return;
}
if (rqptr = w2ptr->RequestPtr)
{
/* half-closed remote can still be sent frames (RFC7540 5.1) */
if (rqptr->NetIoPtr->VmsStatus ||
rqptr->Http2Stream.State == HTTP2_STATE_CLOSED ||
rqptr->Http2Stream.State == HTTP2_STATE_CLOSED_LOC)
{
/* ss$_normal means no issue with the underlying HTTP/2 write */
NetIoWriteStatus (h2ptr->NetIoPtr, Http2NetWriteDataAst,
w2ptr, SS$_NORMAL, 0);
return;
}
h2ptr->FrameRequestCountTx++;
h2ptr->FrameRequestTallyTx++;
}
h2ptr->FrameCountTx++;
h2ptr->FrameTallyTx++;
if ((uchar*)w2ptr->HeaderPtr + HTTP2_FRAME_HEADER_SIZE == w2ptr->DataPtr)
/* header immediately precedes the data - write single datagram */
NetIoWrite (h2ptr->NetIoPtr, Http2NetWriteDataAst, w2ptr,
w2ptr->HeaderPtr, HTTP2_FRAME_HEADER_SIZE +
w2ptr->DataLength);
else
/* write header then data independently (two datagrams) */
NetIoWrite (h2ptr->NetIoPtr, Http2NetWriteHeaderAst, w2ptr,
w2ptr->HeaderPtr, HTTP2_FRAME_HEADER_SIZE);
}
/*****************************************************************************/
/*
Cancel (all) write(s) associated with the request.
Done here rather than in Http2Request.C because it deals with queues.
Return the count of canceled writes (with WASD should always be 0 or 1).
*/
int Http2NetCancelWrite (REQUEST_STRUCT *rqptr)
{
int cnt, idx;
HTTP2_STRUCT *h2ptr;
NETIO_STRUCT *ioptr;
HTTP2_WRITE_STRUCT *next2, *w2ptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(rqptr), WATCH_MOD_HTTP2, "Http2NetCancelWrite()");
h2ptr = rqptr->Http2Stream.Http2Ptr;
ioptr = h2ptr->NetIoPtr;
cnt = 0;
/* look through the queues */
for (idx = HTTP2_WRITE_QUEUE_MAX; idx <= HTTP2_WRITE_QUEUE_LOW; idx++)
{
/* if nothing in this queue then look at the next */
if (!LIST_GET_COUNT (&h2ptr->QueuedWriteList[idx])) continue;
for (w2ptr = LIST_GET_HEAD (&h2ptr->QueuedWriteList[idx]);
w2ptr != NULL;
w2ptr = next2)
{
next2 = LIST_GET_NEXT(w2ptr);
if (rqptr != w2ptr->RequestPtr) continue;
if (w2ptr->WriteInProgress) continue;
cnt++;
/* remove from the HTTP/2 connection's write list */
ListRemove (&h2ptr->QueuedWriteList[idx], w2ptr);
if (rqptr->Http2Stream.QueuedWriteCount)
rqptr->Http2Stream.QueuedWriteCount--;
/* if NOT special cases without "real" AST delivery */
if (w2ptr->AstFunction != Http2Net_WRITE_NO_AST &&
w2ptr->AstFunction != Http2Net_REQUEST_END_AST)
{
/* deliver an AST so adjust the underlying NETIO */
ioptr = rqptr->NetIoPtr;
ioptr->WriteIOsb.Count = 0;
ioptr->WriteIOsb.Status = SS$_CANCEL;
SysDclAst (NetIoWriteAst, ioptr);
}
Http2FreeWriteStruct (h2ptr, w2ptr, FI_LI);
}
}
return (cnt);
}
/*****************************************************************************/
/*
Post-process the HTTP/2 (9 octet) header write. If OK then write the payload.
*/
void Http2NetWriteHeaderAst (HTTP2_WRITE_STRUCT *w2ptr)
{
HTTP2_STRUCT *h2ptr;
NETIO_STRUCT *io2ptr;
/*********/
/* begin */
/*********/
h2ptr = w2ptr->Http2Ptr;
io2ptr = h2ptr->NetIoPtr;
if (WATCHMOD (h2ptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_MOD_HTTP2,
"Http2NetWriteHeaderAst() !&F !&X !&S !UL",
Http2NetWriteHeaderAst,
w2ptr, io2ptr->WriteStatus, io2ptr->WriteCount);
/* if explicitly set (error) status */
if (io2ptr->VmsStatus) io2ptr->WriteStatus = io2ptr->VmsStatus;
if (VMSnok (io2ptr->WriteStatus))
{
/* the connection has failed (or at least the last write) */
SysDclAst (Http2NetWriteDataAst, w2ptr);
return;
}
h2ptr->BytesRawTx64 += io2ptr->WriteCount;
h2ptr->BytesRawTallyTx64 += io2ptr->WriteCount;
NetIoWrite (h2ptr->NetIoPtr, Http2NetWriteDataAst, w2ptr,
w2ptr->DataPtr, w2ptr->DataLength);
}
/*****************************************************************************/
/*
Post-process the payload write (or combined header and payload write).
Delivers (any) AST. Then queue the next write.
*/
void Http2NetWriteDataAst (HTTP2_WRITE_STRUCT *w2ptr)
{
uint WriteLength;
void *AstParam;
HTTP2_STRUCT *h2ptr;
NETIO_STRUCT *ioptr, *io2ptr;
REQUEST_STRUCT *rqptr;
VOID_AST AstFunction;
/*********/
/* begin */
/*********/
h2ptr = w2ptr->Http2Ptr;
io2ptr = h2ptr->NetIoPtr;
if (WATCHMOD (h2ptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_MOD_HTTP2,
"Http2NetWriteDataAst() !&F h2ptr:!&X w2ptr:!&X !&S !UL", Http2NetWriteDataAst,
h2ptr, w2ptr, io2ptr->WriteStatus, io2ptr->WriteCount);
/* if explicitly set (error) status */
if (io2ptr->VmsStatus) io2ptr->WriteStatus = io2ptr->VmsStatus;
h2ptr->BytesRawTx64 += io2ptr->WriteCount;
h2ptr->BytesRawTallyTx64 += io2ptr->WriteCount;
/* remove from the HTTP/2 connection's write list */
ListRemove (&h2ptr->QueuedWriteList[w2ptr->WriteQueue], w2ptr);
w2ptr->WriteInProgress = false;
if (rqptr = w2ptr->RequestPtr)
{
/********************/
/* request response */
/********************/
if (WATCHMOD (h2ptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_MOD_HTTP2,
"rqptr:!&X ast:!&A", rqptr, w2ptr->AstFunction);
if (rqptr->Http2Stream.QueuedWriteCount)
rqptr->Http2Stream.QueuedWriteCount--;
if (w2ptr->AstFunction == Http2Net_REQUEST_END_AST)
{
/* special case that should not be processed by NetIoWriteAst() */
SysDclAst (Http2RequestEnd2, rqptr);
}
else
if (w2ptr->AstFunction != Http2Net_WRITE_NO_AST)
{
/* deliver an AST so adjust the underlying NETIO */
ioptr = rqptr->NetIoPtr;
if (ioptr->VmsStatus)
{
/* use explicit request I/O status */
ioptr->WriteIOsb.Count = 0;
ioptr->WriteIOsb.Status = ioptr->VmsStatus;
}
else
{
/* use actual network I/O status */
ioptr->WriteIOsb.Count = io2ptr->WriteCount;
ioptr->WriteIOsb.Status = io2ptr->WriteStatus;
}
/* post-process the request I/O */
ioptr->WriteCount = ioptr->WriteLength = 0;
SysDclAst (NetIoWriteAst, ioptr);
}
}
else
{
/**************************/
/* HTTP/2 control message */
/**************************/
if (WATCHMOD (h2ptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(h2ptr), WATCH_MOD_HTTP2, "AstFunction !&A 0x!8XL",
w2ptr->AstFunction, w2ptr->AstParam);
AstParam = w2ptr->AstParam;
AstFunction = w2ptr->AstFunction;
if (AstFunction != Http2Net_WRITE_NO_AST) AstFunction (AstParam);
}
Http2FreeWriteStruct (h2ptr, w2ptr, FI_LI);
/********/
/* next */
/********/
Http2NetQueueWrite (h2ptr, NULL);
}
/****************************************************************************/
/*
The presence of an AST function is used to indicate a NETIO in progress. For
I/O environments that cannot block (viz. HTTP/2) this as an AST target can be
detected during post processing and not actually called. Could have used a
magic number of some sort but this seemed cleaner.
*/
void Http2Net_WRITE_NO_AST (void *param)
{
if (WATCH_MODULE (WATCH_MOD_HTTP2))
WatchThis (WATCHALL, WATCH_MOD_HTTP2,
"Http2Net_WRITE_NO_AST() !&F", Http2Net_WRITE_NO_AST);
ErrorNoticed (NULL, SS$_BUGCHECK, "Http2Net_WRITE_NO_AST()", FI_LI);
}
/*****************************************************************************/
/*
Write an end-of-stream frame (at end of output) to the client.
This is the final element of the request's HTTP/2 data stream.
*/
void Http2NetWriteEnd (REQUEST_STRUCT *rqptr)
{
int queue;
HTTP2_STRUCT *h2ptr;
HTTP2_WRITE_STRUCT *w2ptr, *w22ptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_HTTP2))
WatchThis (WATCHITM(rqptr), WATCH_MOD_HTTP2, "Http2NetWriteEnd()");
h2ptr = rqptr->Http2Stream.Http2Ptr;
if (rqptr->rqPathSet.Http2WriteQueue)
queue = rqptr->rqPathSet.Http2WriteQueue;
else
queue = HTTP2_WRITE_QUEUE_NORMAL;
w2ptr = Http2GetWriteStruct (h2ptr, 0, FI_LI);
HTTP2_PLACE_24 (w2ptr->length, 0);
HTTP2_PLACE_8 (w2ptr->type, HTTP2_FRAME_DATA);
HTTP2_PLACE_8 (w2ptr->flags, HTTP2_FLAG_DATA_END_STR);
HTTP2_PLACE_32 (w2ptr->ident, rqptr->Http2Stream.Ident);
w2ptr->Http2Ptr = h2ptr;
w2ptr->HeaderPtr = w2ptr->header;
w2ptr->DataPtr = w2ptr->payload;
w2ptr->WriteQueue = queue;
/* this is a request datagram */
w2ptr->RequestPtr = rqptr;
/* detected by Htt2NetWriteDataAst() and specially processed */
w2ptr->AstFunction = w2ptr->AstParam = Http2Net_REQUEST_END_AST;
Http2NetQueueWrite (h2ptr, w2ptr);
}
/*****************************************************************************/
/*
Detected by Htt2NetWriteDataAst() and specially processed. Could have used a
magic number of some sort but this seemed cleaner.
*/
void Http2Net_REQUEST_END_AST (void *param)
{
/*********/
/* begin */
/*********/
if (WATCH_MODULE (WATCH_MOD_HTTP2))
WatchThis (WATCHALL, WATCH_MOD_HTTP2,
"Http2Net_REQUEST_END_AST() !&F",
Http2Net_REQUEST_END_AST);
ErrorNoticed (NULL, SS$_BUGCHECK, "Http2Net_REQUEST_END_AST()", FI_LI);
}
/*****************************************************************************/
/*
Disconnect network connections. Provides comparable HTTP/2 functionality to
NetControl(). Note that this is not an elegant "goaway". The network channel
is just cancelled running down any I/O.
*/
int Http2NetControl (int ConnectNumber)
{
int PurgeCount;
HTTP2_STRUCT *h2ptr, *next2;
/*********/
/* begin */
/*********/
if (WATCH_MODULE(WATCH_MOD_HTTP2))
WatchThis (WATCHALL, WATCH_MOD_HTTP2, "Http2NetControl()");
PurgeCount = 0;
for (h2ptr = LIST_GET_HEAD(&Http2List); h2ptr != NULL; h2ptr = next2)
{
/* get (any) next in list in case the current connection is closed */
next2 = LIST_GET_NEXT(h2ptr);
if (ConnectNumber <= -2)
{
/* purge all (including only HTTP2) */
Http2GoAway (h2ptr, HTTP2_ERROR_NONE, NULL, 0);
Http2CloseConnection (h2ptr);
PurgeCount++;
}
else
if (ConnectNumber == h2ptr->ConnectNumber)
{
/* purge matching */
Http2GoAway (h2ptr, HTTP2_ERROR_NONE, NULL, 0);
Http2CloseConnection (h2ptr);
PurgeCount++;
}
else
if (LIST_IS_EMPTY (&h2ptr->StreamList))
{
/* purge idle */
Http2GoAway (h2ptr, HTTP2_ERROR_NONE, NULL, 0);
Http2CloseConnection (h2ptr);
PurgeCount++;
}
}
if (WATCH_MODULE(WATCH_MOD_HTTP2))
WatchThis (WATCHALL, WATCH_MOD_HTTP2, "purged: !UL", PurgeCount);
return (PurgeCount);
}
/*****************************************************************************/