[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]
[1153]
[1154]
[1155]
[1156]
[1157]
[1158]
[1159]
[1160]
[1161]
[1162]
[1163]
[1164]
[1165]
[1166]
[1167]
[1168]
[1169]
[1170]
[1171]
[1172]
[1173]
[1174]
[1175]
[1176]
[1177]
[1178]
[1179]
[1180]
[1181]
[1182]
[1183]
[1184]
[1185]
[1186]
[1187]
[1188]
[1189]
[1190]
[1191]
[1192]
[1193]
[1194]
[1195]
[1196]
[1197]
[1198]
[1199]
[1200]
[1201]
[1202]
[1203]
[1204]
[1205]
[1206]
[1207]
[1208]
[1209]
[1210]
[1211]
[1212]
[1213]
[1214]
[1215]
[1216]
[1217]
[1218]
[1219]
[1220]
[1221]
[1222]
[1223]
[1224]
[1225]
[1226]
[1227]
[1228]
[1229]
[1230]
[1231]
[1232]
[1233]
[1234]
[1235]
[1236]
[1237]
[1238]
[1239]
[1240]
[1241]
[1242]
[1243]
[1244]
[1245]
[1246]
[1247]
[1248]
[1249]
[1250]
[1251]
[1252]
[1253]
[1254]
[1255]
[1256]
[1257]
[1258]
[1259]
[1260]
[1261]
[1262]
[1263]
[1264]
[1265]
[1266]
[1267]
[1268]
[1269]
[1270]
[1271]
[1272]
[1273]
[1274]
[1275]
[1276]
[1277]
[1278]
[1279]
[1280]
[1281]
[1282]
[1283]
[1284]
[1285]
[1286]
[1287]
[1288]
[1289]
[1290]
[1291]
[1292]
[1293]
[1294]
[1295]
[1296]
[1297]
[1298]
[1299]
[1300]
[1301]
[1302]
[1303]
[1304]
[1305]
[1306]
[1307]
[1308]
[1309]
[1310]
[1311]
[1312]
[1313]
[1314]
[1315]
[1316]
[1317]
[1318]
[1319]
[1320]
[1321]
[1322]
[1323]
[1324]
[1325]
[1326]
[1327]
[1328]
[1329]
[1330]
[1331]
[1332]
[1333]
[1334]
[1335]
[1336]
[1337]
[1338]
[1339]
[1340]
[1341]
[1342]
[1343]
[1344]
[1345]
[1346]
[1347]
[1348]
[1349]
[1350]
[1351]
[1352]
[1353]
[1354]
[1355]
[1356]
[1357]
[1358]
[1359]
[1360]
[1361]
[1362]
[1363]
[1364]
[1365]
[1366]
[1367]
[1368]
[1369]
[1370]
[1371]
[1372]
[1373]
[1374]
[1375]
[1376]
[1377]
[1378]
[1379]
[1380]
[1381]
[1382]
[1383]
[1384]
[1385]
[1386]
[1387]
[1388]
[1389]
[1390]
[1391]
[1392]
[1393]
[1394]
[1395]
[1396]
[1397]
[1398]
[1399]
[1400]
[1401]
[1402]
[1403]
[1404]
[1405]
[1406]
[1407]
[1408]
[1409]
[1410]
[1411]
[1412]
[1413]
[1414]
[1415]
[1416]
[1417]
[1418]
[1419]
[1420]
[1421]
[1422]
[1423]
[1424]
[1425]
[1426]
[1427]
[1428]
[1429]
[1430]
[1431]
[1432]
[1433]
[1434]
[1435]
[1436]
[1437]
[1438]
[1439]
[1440]
[1441]
[1442]
[1443]
[1444]
[1445]
[1446]
[1447]
[1448]
[1449]
[1450]
[1451]
[1452]
[1453]
[1454]
[1455]
[1456]
[1457]
[1458]
[1459]
[1460]
[1461]
[1462]
[1463]
[1464]
[1465]
[1466]
[1467]
[1468]
[1469]
[1470]
[1471]
[1472]
[1473]
[1474]
[1475]
[1476]
[1477]
[1478]
[1479]
[1480]
[1481]
[1482]
[1483]
[1484]
[1485]
[1486]
[1487]
[1488]
[1489]
[1490]
[1491]
[1492]
[1493]
[1494]
[1495]
[1496]
[1497]
[1498]
[1499]
[1500]
[1501]
[1502]
[1503]
[1504]
[1505]
[1506]
[1507]
[1508]
[1509]
[1510]
[1511]
[1512]
[1513]
[1514]
[1515]
[1516]
[1517]
[1518]
[1519]
[1520]
[1521]
[1522]
[1523]
[1524]
[1525]
[1526]
[1527]
[1528]
[1529]
[1530]
[1531]
[1532]
[1533]
[1534]
[1535]
[1536]
[1537]
[1538]
[1539]
[1540]
[1541]
[1542]
[1543]
[1544]
[1545]
[1546]
[1547]
[1548]
[1549]
[1550]
[1551]
[1552]
[1553]
[1554]
[1555]
[1556]
[1557]
[1558]
[1559]
[1560]
[1561]
[1562]
[1563]
[1564]
[1565]
[1566]
[1567]
[1568]
[1569]
[1570]
[1571]
[1572]
[1573]
[1574]
[1575]
[1576]
[1577]
[1578]
[1579]
[1580]
[1581]
[1582]
[1583]
[1584]
[1585]
[1586]
[1587]
[1588]
[1589]
[1590]
[1591]
[1592]
[1593]
[1594]
[1595]
[1596]
[1597]
[1598]
[1599]
[1600]
[1601]
[1602]
[1603]
[1604]
[1605]
[1606]
[1607]
[1608]
[1609]
[1610]
[1611]
[1612]
[1613]
[1614]
[1615]
[1616]
[1617]
[1618]
[1619]
[1620]
[1621]
[1622]
[1623]
[1624]
[1625]
[1626]
[1627]
[1628]
[1629]
[1630]
[1631]
[1632]
[1633]
[1634]
[1635]
[1636]
[1637]
[1638]
[1639]
[1640]
[1641]
[1642]
[1643]
[1644]
[1645]
[1646]
[1647]
[1648]
[1649]
[1650]
[1651]
[1652]
[1653]
[1654]
[1655]
[1656]
[1657]
[1658]
[1659]
[1660]
[1661]
[1662]
[1663]
[1664]
[1665]
[1666]
[1667]
[1668]
[1669]
[1670]
[1671]
[1672]
[1673]
[1674]
[1675]
[1676]
[1677]
[1678]
[1679]
[1680]
[1681]
[1682]
[1683]
[1684]
[1685]
[1686]
[1687]
[1688]
[1689]
[1690]
[1691]
[1692]
[1693]
[1694]
[1695]
[1696]
[1697]
[1698]
[1699]
[1700]
[1701]
[1702]
[1703]
[1704]
[1705]
[1706]
[1707]
[1708]
[1709]
[1710]
[1711]
[1712]
[1713]
[1714]
[1715]
[1716]
[1717]
[1718]
[1719]
[1720]
[1721]
[1722]
[1723]
[1724]
[1725]
[1726]
[1727]
[1728]
[1729]
[1730]
[1731]
[1732]
[1733]
[1734]
[1735]
[1736]
[1737]
[1738]
[1739]
[1740]
[1741]
[1742]
[1743]
[1744]
[1745]
[1746]
[1747]
[1748]
[1749]
[1750]
[1751]
[1752]
[1753]
[1754]
[1755]
[1756]
[1757]
[1758]
[1759]
[1760]
[1761]
[1762]
[1763]
[1764]
[1765]
[1766]
[1767]
[1768]
[1769]
[1770]
[1771]
[1772]
[1773]
[1774]
[1775]
[1776]
[1777]
[1778]
[1779]
[1780]
[1781]
[1782]
[1783]
[1784]
[1785]
[1786]
[1787]
[1788]
[1789]
[1790]
[1791]
[1792]
[1793]
[1794]
[1795]
[1796]
[1797]
[1798]
[1799]
[1800]
[1801]
[1802]
[1803]
[1804]
[1805]
[1806]
[1807]
[1808]
[1809]
[1810]
[1811]
[1812]
[1813]
[1814]
[1815]
[1816]
[1817]
[1818]
[1819]
[1820]
[1821]
[1822]
[1823]
[1824]
[1825]
[1826]
[1827]
[1828]
[1829]
[1830]
[1831]
[1832]
[1833]
[1834]
[1835]
[1836]
[1837]
[1838]
[1839]
[1840]
[1841]
[1842]
[1843]
[1844]
[1845]
[1846]
[1847]
[1848]
[1849]
[1850]
[1851]
[1852]
[1853]
[1854]
[1855]
[1856]
[1857]
[1858]
[1859]
[1860]
[1861]
[1862]
[1863]
[1864]
[1865]
[1866]
[1867]
[1868]
[1869]
[1870]
[1871]
[1872]
[1873]
[1874]
[1875]
[1876]
[1877]
[1878]
[1879]
[1880]
[1881]
[1882]
[1883]
[1884]
[1885]
[1886]
[1887]
[1888]
[1889]
[1890]
[1891]
[1892]
[1893]
[1894]
[1895]
[1896]
[1897]
[1898]
[1899]
[1900]
[1901]
[1902]
[1903]
[1904]
[1905]
[1906]
[1907]
[1908]
[1909]
[1910]
[1911]
[1912]
[1913]
[1914]
[1915]
[1916]
[1917]
[1918]
[1919]
[1920]
[1921]
[1922]
[1923]
[1924]
[1925]
[1926]
[1927]
[1928]
[1929]
[1930]
[1931]
[1932]
[1933]
[1934]
[1935]
[1936]
[1937]
[1938]
[1939]
[1940]
[1941]
[1942]
[1943]
[1944]
[1945]
[1946]
[1947]
[1948]
[1949]
[1950]
[1951]
[1952]
[1953]
[1954]
[1955]
[1956]
[1957]
[1958]
[1959]
[1960]
[1961]
[1962]
[1963]
[1964]
[1965]
[1966]
[1967]
[1968]
[1969]
[1970]
[1971]
[1972]
[1973]
[1974]
[1975]
[1976]
[1977]
[1978]
[1979]
[1980]
[1981]
[1982]
[1983]
[1984]
[1985]
[1986]
[1987]
[1988]
[1989]
[1990]
[1991]
[1992]
[1993]
[1994]
[1995]
[1996]
[1997]
[1998]
[1999]
[2000]
[2001]
[2002]
[2003]
[2004]
[2005]
[2006]
[2007]
[2008]
[2009]
[2010]
[2011]
[2012]
[2013]
[2014]
[2015]
[2016]
[2017]
[2018]
[2019]
[2020]
[2021]
[2022]
[2023]
[2024]
[2025]
[2026]
[2027]
[2028]
[2029]
[2030]
[2031]
[2032]
[2033]
[2034]
[2035]
[2036]
[2037]
[2038]
[2039]
[2040]
[2041]
[2042]
[2043]
[2044]
[2045]
[2046]
[2047]
[2048]
[2049]
[2050]
[2051]
[2052]
[2053]
[2054]
[2055]
[2056]
[2057]
[2058]
[2059]
[2060]
[2061]
[2062]
[2063]
[2064]
[2065]
[2066]
[2067]
[2068]
[2069]
[2070]
[2071]
[2072]
[2073]
[2074]
[2075]
[2076]
[2077]
[2078]
[2079]
[2080]
[2081]
[2082]
[2083]
[2084]
[2085]
[2086]
[2087]
[2088]
[2089]
[2090]
[2091]
[2092]
[2093]
[2094]
[2095]
[2096]
[2097]
[2098]
[2099]
[2100]
[2101]
[2102]
[2103]
[2104]
[2105]
[2106]
[2107]
[2108]
[2109]
[2110]
[2111]
[2112]
[2113]
[2114]
[2115]
[2116]
[2117]
[2118]
[2119]
[2120]
[2121]
[2122]
[2123]
[2124]
[2125]
[2126]
[2127]
[2128]
[2129]
[2130]
[2131]
[2132]
[2133]
[2134]
[2135]
[2136]
[2137]
[2138]
[2139]
[2140]
[2141]
[2142]
[2143]
[2144]
[2145]
[2146]
[2147]
[2148]
[2149]
[2150]
[2151]
[2152]
[2153]
[2154]
[2155]
[2156]
[2157]
[2158]
[2159]
[2160]
[2161]
[2162]
[2163]
[2164]
[2165]
[2166]
[2167]
[2168]
[2169]
[2170]
[2171]
[2172]
[2173]
[2174]
[2175]
[2176]
[2177]
[2178]
[2179]
[2180]
[2181]
[2182]
[2183]
[2184]
[2185]
[2186]
[2187]
[2188]
[2189]
[2190]
[2191]
[2192]
[2193]
[2194]
[2195]
[2196]
[2197]
[2198]
[2199]
[2200]
[2201]
[2202]
[2203]
[2204]
[2205]
[2206]
[2207]
[2208]
[2209]
[2210]
[2211]
[2212]
[2213]
[2214]
[2215]
[2216]
[2217]
[2218]
[2219]
[2220]
[2221]
[2222]
[2223]
[2224]
[2225]
[2226]
[2227]
[2228]
[2229]
[2230]
[2231]
[2232]
[2233]
[2234]
[2235]
[2236]
[2237]
[2238]
[2239]
[2240]
[2241]
[2242]
[2243]
[2244]
[2245]
[2246]
[2247]
[2248]
[2249]
[2250]
[2251]
[2252]
[2253]
[2254]
[2255]
[2256]
[2257]
[2258]
[2259]
[2260]
[2261]
[2262]
[2263]
[2264]
[2265]
[2266]
[2267]
[2268]
[2269]
[2270]
[2271]
[2272]
[2273]
[2274]
[2275]
[2276]
[2277]
[2278]
[2279]
[2280]
[2281]
[2282]
[2283]
[2284]
[2285]
[2286]
[2287]
[2288]
[2289]
[2290]
[2291]
[2292]
[2293]
[2294]
[2295]
[2296]
[2297]
[2298]
[2299]
[2300]
[2301]
[2302]
[2303]
[2304]
[2305]
[2306]
[2307]
[2308]
[2309]
[2310]
[2311]
[2312]
[2313]
[2314]
[2315]
[2316]
[2317]
[2318]
[2319]
[2320]
[2321]
[2322]
[2323]
[2324]
[2325]
[2326]
[2327]
[2328]
[2329]
[2330]
[2331]
[2332]
[2333]
[2334]
[2335]
[2336]
[2337]
[2338]
[2339]
[2340]
[2341]
[2342]
[2343]
[2344]
[2345]
[2346]
[2347]
[2348]
[2349]
[2350]
[2351]
[2352]
[2353]
[2354]
[2355]
[2356]
[2357]
[2358]
[2359]
[2360]
[2361]
[2362]
[2363]
[2364]
[2365]
[2366]
[2367]
[2368]
[2369]
[2370]
[2371]
[2372]
[2373]
[2374]
[2375]
[2376]
[2377]
[2378]
[2379]
[2380]
[2381]
[2382]
[2383]
[2384]
[2385]
[2386]
[2387]
[2388]
[2389]
[2390]
[2391]
[2392]
[2393]
[2394]
[2395]
[2396]
[2397]
[2398]
[2399]
[2400]
[2401]
[2402]
[2403]
[2404]
[2405]
[2406]
[2407]
[2408]
[2409]
[2410]
[2411]
[2412]
[2413]
[2414]
[2415]
[2416]
[2417]
[2418]
[2419]
[2420]
[2421]
[2422]
[2423]
[2424]
[2425]
[2426]
[2427]
[2428]
[2429]
[2430]
[2431]
[2432]
[2433]
[2434]
[2435]
[2436]
[2437]
[2438]
[2439]
[2440]
[2441]
[2442]
[2443]
[2444]
[2445]
[2446]
[2447]
[2448]
[2449]
[2450]
[2451]
[2452]
[2453]
[2454]
[2455]
[2456]
[2457]
[2458]
[2459]
[2460]
[2461]
[2462]
[2463]
[2464]
[2465]
[2466]
[2467]
[2468]
[2469]
[2470]
[2471]
[2472]
[2473]
[2474]
[2475]
[2476]
[2477]
[2478]
[2479]
[2480]
[2481]
[2482]
[2483]
[2484]
[2485]
[2486]
[2487]
[2488]
[2489]
[2490]
[2491]
[2492]
[2493]
[2494]
[2495]
[2496]
[2497]
[2498]
[2499]
[2500]
[2501]
[2502]
[2503]
[2504]
[2505]
[2506]
[2507]
[2508]
[2509]
[2510]
[2511]
[2512]
[2513]
[2514]
[2515]
[2516]
[2517]
[2518]
[2519]
[2520]
[2521]
[2522]
[2523]
[2524]
[2525]
[2526]
[2527]
[2528]
[2529]
[2530]
[2531]
[2532]
[2533]
[2534]
[2535]
[2536]
[2537]
[2538]
[2539]
[2540]
[2541]
[2542]
[2543]
[2544]
[2545]
[2546]
[2547]
[2548]
[2549]
[2550]
[2551]
[2552]
[2553]
[2554]
[2555]
[2556]
[2557]
[2558]
[2559]
[2560]
[2561]
[2562]
[2563]
[2564]
[2565]
[2566]
[2567]
[2568]
[2569]
[2570]
[2571]
[2572]
[2573]
[2574]
[2575]
[2576]
[2577]
[2578]
[2579]
[2580]
[2581]
[2582]
[2583]
[2584]
[2585]
[2586]
[2587]
[2588]
[2589]
[2590]
[2591]
[2592]
[2593]
[2594]
[2595]
[2596]
[2597]
[2598]
[2599]
[2600]
[2601]
[2602]
[2603]
[2604]
[2605]
[2606]
[2607]
[2608]
[2609]
[2610]
[2611]
[2612]
[2613]
[2614]
[2615]
[2616]
[2617]
[2618]
[2619]
[2620]
[2621]
[2622]
[2623]
[2624]
[2625]
[2626]
[2627]
[2628]
[2629]
[2630]
[2631]
[2632]
[2633]
[2634]
[2635]
[2636]
[2637]
[2638]
[2639]
[2640]
[2641]
[2642]
[2643]
[2644]
[2645]
[2646]
[2647]
[2648]
[2649]
[2650]
[2651]
[2652]
[2653]
[2654]
[2655]
[2656]
[2657]
[2658]
[2659]
[2660]
[2661]
[2662]
[2663]
[2664]
[2665]
[2666]
[2667]
[2668]
[2669]
[2670]
[2671]
[2672]
[2673]
[2674]
[2675]
[2676]
[2677]
[2678]
[2679]
[2680]
[2681]
[2682]
[2683]
[2684]
[2685]
[2686]
[2687]
[2688]
[2689]
[2690]
[2691]
[2692]
[2693]
[2694]
[2695]
[2696]
[2697]
[2698]
[2699]
[2700]
[2701]
[2702]
[2703]
[2704]
[2705]
[2706]
[2707]
[2708]
[2709]
[2710]
[2711]
[2712]
[2713]
[2714]
[2715]
[2716]
[2717]
[2718]
[2719]
[2720]
[2721]
[2722]
[2723]
[2724]
[2725]
[2726]
[2727]
[2728]
[2729]
[2730]
[2731]
[2732]
[2733]
[2734]
[2735]
[2736]
[2737]
[2738]
[2739]
[2740]
[2741]
[2742]
[2743]
[2744]
[2745]
[2746]
[2747]
[2748]
[2749]
[2750]
[2751]
[2752]
[2753]
[2754]
[2755]
[2756]
[2757]
[2758]
[2759]
[2760]
[2761]
[2762]
[2763]
[2764]
[2765]
[2766]
[2767]
[2768]
[2769]
[2770]
[2771]
[2772]
[2773]
[2774]
[2775]
[2776]
[2777]
[2778]
[2779]
[2780]
[2781]
[2782]
[2783]
[2784]
[2785]
[2786]
[2787]
[2788]
[2789]
[2790]
[2791]
[2792]
[2793]
[2794]
[2795]
[2796]
[2797]
[2798]
[2799]
[2800]
[2801]
[2802]
[2803]
[2804]
[2805]
[2806]
[2807]
[2808]
[2809]
[2810]
[2811]
[2812]
[2813]
[2814]
[2815]
[2816]
[2817]
[2818]
[2819]
[2820]
[2821]
[2822]
[2823]
[2824]
[2825]
[2826]
[2827]
[2828]
[2829]
[2830]
[2831]
[2832]
[2833]
[2834]
[2835]
[2836]
[2837]
[2838]
[2839]
[2840]
[2841]
[2842]
[2843]
[2844]
[2845]
[2846]
[2847]
[2848]
[2849]
[2850]
[2851]
[2852]
[2853]
[2854]
[2855]
[2856]
[2857]
[2858]
[2859]
[2860]
[2861]
[2862]
[2863]
[2864]
[2865]
[2866]
[2867]
[2868]
[2869]
[2870]
[2871]
[2872]
[2873]
[2874]
[2875]
[2876]
[2877]
[2878]
[2879]
[2880]
[2881]
[2882]
[2883]
[2884]
[2885]
[2886]
[2887]
[2888]
[2889]
[2890]
[2891]
[2892]
[2893]
[2894]
[2895]
[2896]
[2897]
[2898]
[2899]
[2900]
[2901]
[2902]
[2903]
[2904]
[2905]
[2906]
[2907]
[2908]
[2909]
[2910]
[2911]
[2912]
[2913]
[2914]
[2915]
[2916]
[2917]
[2918]
[2919]
[2920]
[2921]
[2922]
[2923]
[2924]
[2925]
[2926]
[2927]
[2928]
[2929]
[2930]
[2931]
[2932]
[2933]
[2934]
[2935]
[2936]
[2937]
[2938]
[2939]
[2940]
[2941]
[2942]
[2943]
[2944]
[2945]
[2946]
[2947]
[2948]
[2949]
[2950]
[2951]
[2952]
[2953]
[2954]
[2955]
[2956]
[2957]
[2958]
[2959]
[2960]
[2961]
[2962]
[2963]
[2964]
[2965]
[2966]
[2967]
[2968]
[2969]
[2970]
[2971]
[2972]
[2973]
[2974]
[2975]
[2976]
[2977]
[2978]
[2979]
[2980]
[2981]
[2982]
[2983]
[2984]
[2985]
[2986]
[2987]
[2988]
[2989]
[2990]
[2991]
[2992]
[2993]
[2994]
[2995]
[2996]
[2997]
[2998]
[2999]
[3000]
[3001]
[3002]
[3003]
[3004]
[3005]
[3006]
[3007]
[3008]
[3009]
[3010]
[3011]
[3012]
[3013]
[3014]
[3015]
[3016]
[3017]
[3018]
[3019]
[3020]
[3021]
[3022]
[3023]
[3024]
[3025]
[3026]
[3027]
[3028]
[3029]
[3030]
[3031]
[3032]
[3033]
[3034]
[3035]
[3036]
[3037]
[3038]
[3039]
[3040]
[3041]
[3042]
[3043]
[3044]
[3045]
[3046]
[3047]
[3048]
[3049]
[3050]
[3051]
[3052]
[3053]
[3054]
[3055]
[3056]
[3057]
[3058]
[3059]
[3060]
[3061]
[3062]
[3063]
[3064]
[3065]
[3066]
[3067]
[3068]
[3069]
[3070]
[3071]
[3072]
[3073]
[3074]
[3075]
[3076]
[3077]
[3078]
[3079]
[3080]
[3081]
[3082]
[3083]
[3084]
[3085]
[3086]
[3087]
[3088]
[3089]
[3090]
[3091]
[3092]
[3093]
[3094]
[3095]
[3096]
[3097]
[3098]
[3099]
[3100]
[3101]
[3102]
[3103]
[3104]
[3105]
[3106]
[3107]
[3108]
[3109]
[3110]
[3111]
[3112]
[3113]
[3114]
[3115]
[3116]
[3117]
[3118]
[3119]
[3120]
[3121]
[3122]
[3123]
[3124]
[3125]
[3126]
[3127]
[3128]
[3129]
[3130]
[3131]
[3132]
[3133]
[3134]
[3135]
[3136]
[3137]
[3138]
[3139]
[3140]
[3141]
[3142]
[3143]
[3144]
[3145]
[3146]
[3147]
[3148]
[3149]
[3150]
[3151]
[3152]
[3153]
[3154]
[3155]
[3156]
[3157]
[3158]
[3159]
[3160]
[3161]
[3162]
[3163]
[3164]
[3165]
[3166]
[3167]
[3168]
[3169]
[3170]
[3171]
[3172]
[3173]
[3174]
[3175]
[3176]
[3177]
[3178]
[3179]
[3180]
[3181]
[3182]
/*****************************************************************************/
/*
Cache.c
This module implements both a file data and revision time cache, and a general
non-file (e.g. script) output cache. With file content caching the file
revision time is stored (along with the directory and file IDs for efficiency)
allowing the entry validity to expire and to be periodically revalidated
against the on-disk version. If the on-disk version has changed the cache is
purged and the content reloaded, otherwise the expiry period just recommences.
For non-file content the revalidation is not possible so when the validity of
the cache entry expires the entry is purged from the cache forcing it to be
reloaded through full request processing.
The cache has limits imposed on it. A maximum number of files that can be
cached at any one time, and a maximum amount of memory that can be allocated
in total by the cache. Each of these two operates to limit the other. In
addition the maximum size of a file that can be loaded into the cache can be
specified.
Fine control on cache behaviour is exercised using mapping rules.
See the MAPURL.C module for a list of those applicable.
FILE CONTENT
------------
File content cache data is loaded by the file module while concurrently
transfering that data to the request client, using buffer space supplied by
cache module, space that can then be retained for reuse as cache. Hence the
cache load adds no significant overhead to the actual reading and initial
transfer of the file. An entirely accurate estimate of the quantity of cache
memory required for file content can be derived from the file header. Cache
loads that exceed the configuration or rule mapping maxima do not proceed.
NON-FILE CONTENT
----------------
Non-file content is a little different from file content in that the size of
the cache memory required is generally not known when the cache load begins
(content-length is often not supplied with script output for example). When
this is not known the cache module just allocates an ambit quantity of memory,
determined by configuration or rule mapping indicated maxima. When the load
successfully completes the actual memory required is compared to that
originally allocated and reduced as necessary. If non-file output exceeds the
original ambit memory allocation (and hence configuration or rule maxima) the
data is just discarded at end-of-request.
Non-file content entries are sourced in two ways. First, from the CGI module.
This can discriminate and load either (or both) CGI-compliant responses and
Non-Parse-Header (NPH) responses. The former allows the server to generate the
response header, the latter contains the response header as the leading output
from the script. Cached CGI responses generate a new header with each
subsequent use, while cached NPH response reuse the original header. The
second source of cached response is direct from network-to-client output via
the NET module. Like scripts, network loaded content can contain only the body
of the response, or the full header and body (viz. NPH). Some care should be
excercised with the caching of responses using the NET source.
By default only GET requests, without query strings, generating responses with
a success HTTP status (200) will be cached. Other response status content will
be discarded. Requests containing query strings may be cached by using the
'cache=query' mapping rule. This sort of caching should be done carefully and
selectively. The multitude of differing query string usually accepted by such
resources would soon fill the cache with generally non-repeated data and thus
render the cache completely ineffective.
BYTE RANGES
-----------
See comments in FILE.C module.
TERMINOLOGY
-----------
"hit" refers to a request path being found in cache. If the data is still
valid the request can be supplied from cache.
"load"ing the cache refers to reading the contents of a file into cache
memory.
"valid" means that the file from which the cached data was originally read has
not had it's revision date changed (the implication being is the file contents
have not changed.
WHY IMPLEMENT CACHING?
----------------------
Caching, be definition, attempts to improve performance by keeping data in
storage that is faster to access than it's usual location. The performance
improvement can be assessed in three basic ways. Reduction in latency when
accessing the data, of processing involved, and in impact on the usual storage
location.
This cache is provided to address all three. Where networks are particularly
responsive a reduction in request latency can often be noticable. Where
servers are particularly busy or where disk systems particularly loaded a
reduction in the need to access the file system can significantly improve
performance. My suggestion is though, that for most VMS sites high levels of
hits are not a great concern, and for these caching can easily be left
disabled.
CACHE SUITABILITY CONSIDERATIONS
--------------------------------
A cache is not always of benefit! It's cost *may* outweigh it's return.
Any cache's efficiencies can only occur where subsets of data are consistently
being demanded. Although these subsets may change slowly over time a consistent
and rapidly changing aggregate of requests lose the benefit of more readily
accessable data to the overhead of cache management due to the constant and
continuous flushing and reloading of cache data. This server's cache is no
different, it will only improve performance if the site experiences some
consistency in the files requested. For sites that have only a small
percentage of files being repeatedly requested it is probably better that the
cache be disabled. The other major consideration is available system memory.
On a system where memory demand is high there is little value in having cache
memory sitting in page space, trading disk I/O and latency for paging I/O and
latency. On memory-challenged systems cache is probably best disabled.
With "loads not hit", the count represents the cumulative number of files
loaded but never subsequently hit. If this percentage is high it means most
files loaded are never hit, indicating the site's request profile is possibly
unsuitable for caching.
The item "hits" respresents the cumulative, total number of hits against the
cumulative, total number of loads. The percentage here can range from zero to
many thousands of percent :^) with less than 100% indicating poor cache
performance, from 200% upwards better and good performance. The items "1-9",
"10-99" and "100+" show the count and percentage of total hits that occured
when a given entry had experienced hits within that range (e.g. if an entry
has had 8 previous hits, the ninth increments the "1-9" item whereas the tenth
and eleventh increments the "10-99" item, etc.)
Other considerations also apply when assessing the benefit of having a cache.
For example, a high number and percentage of hits can be generated while the
percentage of "loads not hit" could be in the also be very high. The
explanation for this would be one or two frequently requested files being hit
while most others are loaded, never hit, and flushed as other files request
cache space. In situations such as this it is difficult to judge whether cache
processing is improving performance or just adding overhead.
Again, my suggestion is, that for most VMS sites, high levels of access are not
a great concern, and for these caching can easily be left disabled.
DESCRIPTION
-----------
An MD5 digest (16 byte hash) is used to uniquely identify cached files. The
hash is generated either from a mapped path or from the file name before
calling any of the cache search, load or completion functions. This MD5 hash
is then stored along with the file details and contents so that identical
paths/files can be matched during subsequent searches. The MD5 algorithm
"guarantees" a unique identifier for any resource name, and the 16 byte size
makes matching using just 4 longword comparisons very efficient.
If using a path it MUST be the mapped path, not the client-supplied, request
path. With conditional mapping, identical request paths may be mapped to
completely different virtual paths.
Space for a file's data is dynamically allocated and reallocated if necessary
as cache entries are reused. It is allocated in user-specifiable chunks. It
is expected this mechanism provides some efficiencies when reusing cache
entries.
A simple hash table is used to try and initially hit an entry. A collision
list allows rapid subsequent searching. The hash table is a fixed 4096 entries
with the hash value generated by directly using a fixed three bytes of the
MD5 hash for a range from 0..4095.
Cache entries are also maintained in a global linked list with the most recent
and most frequently hit entries towards the head of the list. The linked-list
organisation allows a simple implementation of a least-recently-used (LRU)
algorithm for selecting an entry when a new request demands an entry and space
for cache loading. The linked list is naturally ordered from most recently and
most frequently accessed at the head, to the least recently and least
frequently accessed at the tail. Hence an infrequently accessed entry is
selected from the tail end of the list, it's data invalidated and given to the
new request for cache load. Invalidated data cache entries are also
immediately placed at the tail of the list for reuse/reloading.
When a new entry is initially loaded it is placed at the top of the list. Hits
on other entries result in a check being made against the number of hits of
head entry in the list. If the entry being hit has a higher hit count it is
placed at the head of the list, pushing the previously head entry "down". If
not then it is again checked against the entry immediately before it in the
list. If higher then the two are swapped. This results in the most recently
loaded entries and the more frequently hit being nearest and migrating towards
the start of the search.
To help prevent the cache thrashing with floods of requests for not currently
loaded files, any entry that has a suitably high number of hits over the recent
past (suitably high ... how many is that, and recent past ... how long is
that?) are not reused until no hits have occured within that period. Hopefully
this prevents lots of unnecessary loads of one-offs at the expense of genuinely
frequently accessed files.
To prevent multiple loads of the same path/file, for instance if a subsequent
request demands the same file as a previous request is still currently loading,
any subsequent request will merely transfer the file, not concurrently load it
into the cache.
CACHE CONTENT VALIDATION
------------------------
The cache will automatically revalidate the data after a specified number of
seconds. With file content this is done by comparing the original file
revision time to the current revision time. If different the file contents
have changed and the cache contents declared invalid. If found invalid the
file transfer then continues outside of the cache with the new contents being
concurrently reloaded into the cache. With non-file content the entry is just
purged and the full request processing is used to reload the content. Cache
validation is also always performed if the request uses "Pragma: no-cache"
(i.e. as with the Netscape Navigator reload function). Hence there is no need
for any explicit flushing of the cache under normal operation. If a document
does not immediately reflect and changes made to it (i.e. validation time has
not been reached) validation (and consequent reload) can be "forced" with a
browser reload. There is a discretional "guard" period that can be set which
prevent forced reloading of cached data within the specified number of seconds
since last loaded or revalidated. This period can be used to prevent a cache
entry or entries from constantly being reloaded through pragma directives
(Mozilla for instance has a user-option cache setting which causes the request
header always to contain a 'no-cache' indication causing reload). The entire
cache may be purged of cached data either from the server administration menu
or using command line server control.
PERMANENT ENTRIES
-----------------
Permanent entries are indicated by a path mapping a SET rule. Permanent
entries are designed to allow certain classes of (mainly file) entry, those
that are relatively static and/or frequently being used by requests, that once
loaded remain in the cache, never validated, never able to be reclaimed or
otherwise removed from the cache during routine server activity. These
entries, along with the volatile ones, can of course be purged from the cache
either via the CLI /DO=CACHE=PURGE command or using Server Administration menu.
Permanent entries do not use any of the data memory ([CacheTotalKBytesMax]) set
aside for the volatile cache. They use memory from their own specific VM pool.
Unlike for volatile entries there is no upper limit (apart from system and
server process virtual memory) on the memory that can be allocated for
permanent entries (be careful!). Entry slots ([CacheEntriesMax]) are shared
between permanent and volatile entries (and can be a constraint on both).
GZIP COMPRESSED CONTENT
-----------------------
If ZLIB is being used by the server (see GZIP.C) the cache will generate a
buffer of GZIP compressed content from the cached binary content. This is then
is returned to clients that can accept GZIP encoding saving the processing
expense of generating the GZIP compression dynamically with each request. When
the cache load is complete the content-type, etc., is tested for suitability
for GZIP compression. It is performed as part of the cache post-processing
rather than just collecting the original request's GZIP compressed network
stream (for instance) for three basic reasons. First; the point at which the
deflate is finalized is different to when the cache load is finalized. Second;
not all initial cache load requests may accept GZIP encoding. This approach
ensures GZIP content is available for any subsequent access. Third; it's
slightly more expensive in terms or processing (the possible double GZIPing on
the initial cache load) but was fairly straight-forward and self-contained when
introducing to the code.
VERSION HISTORY
---------------
23-JAN-2020 MGD bugfix; CacheLoadEnd() free rqCache.ContentPtr on fail
(seemed to be induced only by HTTP/2 requests - hmmmm)
05-FEB-2019 MGD CacheLoadBegin() CacheLoadEnd() accept 203 as 200
01-JAN-2018 MGD refactor some code paths (sigh! *so* tightly coupled with
FILE.C and REQUEST.C modules)
14-JAN-2016 MGD CacheLoadResponse() in line with HTTP/2 changes
bugfix; CacheLoadResponse() initialise storage
04-MAR-2011 MGD CacheSearch() implement request cache control
01-MAR-2011 MGD CacheLoadResponse() checks response header for
"Cache-Control:" directives and adjusts accordingly
27-FEB-2011 MGD CacheLoadEnd() buffer all content-type data (per JPP)
(previous behaviour truncated at ';' or white-space)
05-OCT-2009 MGD use OutputFileBufferSize to maximise transfer
19-AUG-2009 MGD bugfix; CacheAcpInfoAst() byte-range limit negative offset
09-JUN-2007 MGD use STR_DSC
28-FEB-2007 MGD bugfix; CacheNext() don't adjust GZIP content for CGI header
04-JUL-2006 MGD use PercentOf32() for more accurate percentages
11-AUG-2005 MGD CacheEntryReclaimCount report item
26-MAR-2005 MGD provide caching and supply of GZIP deflated content
28-JUL-2004 MGD support use of entity tag in file responses
15-MAY-2004 MGD bugfix; content pointer needs to be NULLed
before first call to CacheNext()
24-APR-2004 MGD extend cache hit accounting to 100-999 and 1000 plus
09-JUL-2003 MGD rework for non-file caching requirements,
support byte-range requests on cached *files*
16-JUN-2003 MGD bugfix; FileSetCharset() moved from FILE.C module
24-MAY-2003 MGD permanent cache entries,
path specified maximum file size
11-MAR-2002 MGD bugfix; ensure only one request revalidates a cache entry at
a time (multiple could cause eventual channel exhaustion)
22-NOV-2001 MGD ensure there are reasonable cache minima
29-SEP-2001 MGD instance support
04-AUG-2001 MGD use MD5 hash to identify cache entries,
modify hash table as fixed 4096 entrie,
support module WATCHing
27-MAY-2000 MGD BUGFIX; CacheEntryNotValid() linked list :^{
bugfix; CacheLoadBegin() #else before memcpy()
09-APR-2000 MGD simplified cache search
04-MAR-2000 MGD use FaolToNet(), et.al.
28-DEC-1999 MGD support ODS-2 and ODS-5 using ODS module,
add a number of other WATCH points
26-SEP-1999 MGD minor changes in line with RequestExecute(),
CacheReport() now only optionally reports cached files,
scavenge failure should not result in a sanity check exit
20-JAN-1999 MGD report format refinenment
19-SEP-1998 MGD improve granularity of cache operation,
add check for existing entry to CacheLoadBegin()
14-MAY-1998 MGD request-specified content-type ("httpd=content&type=")
18-MAR-1998 MGD use file's VBN and first free byte to check size changes
(allows variable record files to be cached more efficiently)
24-FEB-1998 MGD if CacheAcpInfo() reports a problem
then let the file module handle/report it,
add file size check to entry validation (allow for extend)
10-JAN-1998 MGD added a (much overdue) hash collision list,
fixed problem with cache purge (it mostly didn't :^)
22-NOV-1997 MGD sigh, bugfix; need to proactively free memory at capacity
05-OCT-1997 MGD initial development for v4.5
*/
/*****************************************************************************/
#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
/* standard C header files */
#include <ctype.h>
#include <errno.h>
#include <stdio.h>
#include <string.h>
/* VMS related header files */
#include <atrdef.h>
#include <descrip.h>
#include <fibdef.h>
#include <iodef.h>
#include <libdef.h>
#include <ssdef.h>
#include <stsdef.h>
/* application header files */
#include "wasd.h"
#include "gzip.h"
#include "md5.h"
#define WASD_MODULE "CACHE"
/******************/
/* global storage */
/******************/
BOOL CacheEnabled,
CacheHashTableInitialised;
/* this is run-time storage */
int CacheChunkInBytes,
CacheCurrentlyLoading,
CacheCurrentlyLoadingInUse,
CacheEntriesMax,
CacheEntryCount,
CacheEntryKBytesMax,
CacheFrequentHits,
CacheFrequentSeconds,
CacheGuardSeconds,
CacheHashTableMask,
CacheMemoryInUse,
CachePermEntryCount,
CachePermMemoryInUse,
CacheTotalKBytesMax,
CacheValidateSeconds;
/* these counters may be zeroed when accounting is zeroed */
int CacheGzipDeflateCount,
CacheHashTableCollsnCount,
CacheHashTableCount,
CacheHashTableHitCount,
CacheHashTableMissCount,
CacheHashTableCollsnHitCount,
CacheHashTableCollsnMissCount,
CacheHitCount,
CacheHits0,
CacheHits10,
CacheHits100,
CacheHits1000,
CacheHits1000plus,
CacheListHitCount,
CacheLoadCount,
CacheNotHitCount,
CacheNoHitsCount,
CacheReclaimCount,
CacheSearchCount;
uint64 CacheGzipDeflateBytesIn64,
CacheGzipDeflateBytesOut64;
LIST_HEAD CacheList;
/* the hash table index is the first byte of the MD5 hash */
#define CACHE_HASH_TABLE_ENTRIES 4096 /* 12 bits, 16384 bytes, 32 page(lets) */
struct GenericCacheEntry *CacheHashTable [CACHE_HASH_TABLE_ENTRIES];
/********************/
/* external storage */
/********************/
extern BOOL CliCacheEnabled,
CliCacheDisabled,
GzipResponse;
extern int HttpdTickSecond,
OdsExtended,
OutputFileBufferSize;
extern int ToLowerCase[],
ToUpperCase[];
extern short HttpdTime7[];
extern char ErrorSanityCheck[],
HttpProtocol[],
SoftwareID[];
extern ACCOUNTING_STRUCT *AccountingPtr;
extern CONFIG_STRUCT Config;
extern MSG_STRUCT Msgs;
extern HTTPD_PROCESS HttpdProcess;
extern WATCH_STRUCT Watch;
/*****************************************************************************/
/*
Initialize cache run-time parameters at startup (even though caching might be
initially disabled). Also allocate the hash table when appropriate.
*/
void CacheInit (BOOL Startup)
{
int HashValue;
/*********/
/* begin */
/*********/
if (WATCH_MODULE(WATCH_MOD_CACHE))
WatchThis (WATCHALL, WATCH_MOD_CACHE, "CacheInit()");
if (Startup)
{
if (!CliCacheDisabled && (CliCacheEnabled || Config.cfCache.Enabled))
CacheEnabled = true;
else
CacheEnabled = false;
CacheChunkInBytes = CACHE_CHUNK_SIZE;
CacheEntriesMax = Config.cfCache.EntriesMax;
if (CacheEntriesMax < 256) CacheEntriesMax = 256;
CacheEntryKBytesMax = Config.cfCache.FileKBytesMax;
if (CacheEntryKBytesMax <= 0) CacheEntryKBytesMax = 65;
CacheFrequentHits = Config.cfCache.FrequentHits;
CacheFrequentSeconds = Config.cfCache.FrequentSeconds;
CacheGuardSeconds = Config.cfCache.GuardSeconds;
if (!CacheGuardSeconds) CacheGuardSeconds = 15;
CacheTotalKBytesMax = Config.cfCache.TotalKBytesMax;
if (CacheTotalKBytesMax < 1024) CacheTotalKBytesMax = 1024;
CacheValidateSeconds = Config.cfCache.ValidateSeconds;
if (!CacheValidateSeconds) CacheValidateSeconds = 300;
CacheEntryCount = CacheMemoryInUse =
CachePermEntryCount = CachePermMemoryInUse = 0;
CacheZeroCounters ();
}
if (CacheEntriesMax && CacheEnabled)
{
/* 100% overhead for ambit memory allocations, fragmentation, etc. */
VmCacheInit (CacheTotalKBytesMax * 2);
/* the permanent cache space will be created on the first perm entry */
/** VmPermCacheInit (CacheTotalKBytesMax); **/
for (HashValue = 0; HashValue < CACHE_HASH_TABLE_ENTRIES; HashValue++)
CacheHashTable[HashValue] = NULL;
CacheHashTableInitialised = true;
}
}
/*****************************************************************************/
/*
Just zero the cache-associated counters :^)
*/
void CacheZeroCounters ()
{
/*********/
/* begin */
/*********/
if (WATCH_MODULE(WATCH_MOD_CACHE))
WatchThis (WATCHALL, WATCH_MOD_CACHE, "CacheZeroCounter()");
CacheGzipDeflateCount =
CacheGzipDeflateBytesIn64 = CacheGzipDeflateBytesOut64 =
CacheHitCount = CacheHashTableHitCount =
CacheHashTableCollsnCount = CacheHashTableCollsnHitCount =
CacheHashTableCollsnMissCount = CacheHashTableCount =
CacheHashTableMissCount =
CacheNoHitsCount = CacheHits0 = CacheHits10 =
CacheHits100 = CacheHits1000 =
CacheHits1000plus = CacheLoadCount =
CacheReclaimCount = CacheSearchCount = 0;
}
/*****************************************************************************/
/*
Look through the cache list for a resource hash (MD5) that matches. If one is
found then call CacheBegin() and return success, otherwise return error status
to indicate the search was unsuccessful.
NOTE: as with CacheLoadBegin(), the path passed to this function MUST be the
mapped path, not the request path. With conditional mapping identical request
paths may be mapped to completely different virtual paths.
*/
int CacheSearch (REQUEST_STRUCT *rqptr)
{
int status,
EntryCount,
HashValue;
char *cptr, *sptr;
FILE_CENTRY *captr;
LIST_ENTRY *leptr;
MD5_HASH *md5ptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"CacheSearch() file:!&B", rqptr->FileTaskPtr);
if (!CacheEnabled) return (SS$_NOSUCHFILE);
if (!CacheHashTableInitialised) CacheInit (false);
/* if the request specified that cache not be used */
if (rqptr->rqHeader.CacheControlNoCache ||
rqptr->rqHeader.CacheControlNoStore ||
rqptr->rqHeader.PragmaNoCache)
{
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE request no-cache");
return (SS$_NOSUCHFILE);
}
/* if not interested in anything with a query string */
if (!rqptr->rqPathSet.CacheQuery &&
rqptr->rqHeader.QueryStringLength)
{
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE request query-string");
return (SS$_NOSUCHFILE);
}
/* any request containing a cookie that is not from a static file */
if (rqptr->rqHeader.CookiePtr &&
!rqptr->FileTaskPtr &&
!rqptr->rqPathSet.CacheCookie)
{
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE request cookie");
return (SS$_NOSUCHFILE);
}
/* if not a GET request */
if (rqptr->rqHeader.Method != HTTP_METHOD_GET) return (SS$_NOSUCHFILE);
/* if a SET mapping rule has specified the path should not be cached */
if (rqptr->rqPathSet.NoCache) return (SS$_NOSUCHFILE);
/* server has specifically set this request not to be cached */
if (rqptr->rqCache.DoNotCache) return (SS$_NOSUCHFILE);
/* must be using this for a cache load (e.g. during directory listing) */
if (rqptr->rqCache.EntryPtr) return (SS$_NOSUCHFILE);
if (rqptr->FileTaskPtr)
md5ptr = &rqptr->FileTaskPtr->Md5Hash;
else
md5ptr = &rqptr->Md5HashPath;
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE search !&?file\rpath\r !16&H",
rqptr->FileTaskPtr, md5ptr);
/* check the hash table */
CacheHashTableCount++;
/* 12 bit hash value, 0..4095 from a fixed 3 bytes of the MD5 hash */
HashValue = md5ptr->HashLong[0] & 0xfff;
if (!(captr = CacheHashTable[HashValue]))
{
/*************/
/* not found */
/*************/
if (rqptr->rqHeader.CacheControlOnlyIfCached)
{
rqptr->rqResponse.HttpStatus = 504;
ErrorVmsStatus (rqptr, SS$_TIMEOUT, FI_LI);
return (SS$_TIMEOUT);
}
/* nope, no pointer against that hash value */
CacheHashTableMissCount++;
return (SS$_NOSUCHFILE);
}
EntryCount = 0;
for ( /*set above*/ ; captr; captr = captr->HashCollisionNextPtr)
{
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"file:!&B valid:!&B revalidating:!&B !AZ !16&H !&?match\rno-match\r",
captr->FromFile,
captr->EntryValid, captr->EntryRevalidating,
captr->FileOds.ExpFileName,
&captr->Md5Hash,
MATCH16 (&captr->Md5Hash, md5ptr));
/* note the first collision entry */
if (++EntryCount == 2) CacheHashTableCollsnCount++;
if (!MATCH16 (&captr->Md5Hash, md5ptr)) continue;
/********/
/* hit! */
/********/
/* first entry is always the hash table, after that the collision list */
if (EntryCount == 1)
CacheHashTableHitCount++;
else
CacheHashTableCollsnHitCount++;
if (!captr->EntryValid ||
captr->DataLoading ||
captr->EntryRevalidating)
{
/**************/
/* not usable */
/**************/
rqptr->rqCache.NotUsable = true;
return (SS$_NOSUCHFILE);
}
/**********/
/* usable */
/**********/
if (rqptr->rqHeader.CacheControlMaxAge &&
HttpdTickSecond - captr->LoadSeconds >
rqptr->rqHeader.CacheControlMaxAge)
{
/***********/
/* too old */
/***********/
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE request max-age !UL",
rqptr->rqHeader.CacheControlMaxAge);
return (SS$_NOSUCHFILE);
}
if (!ResponseEntityMatch (rqptr, captr->EntityTag))
{
/********************/
/* failed condition */
/********************/
/* ResponseEntityMatch() should generate its own HTTP response */
return (SS$_ABORT);
}
/************/
/* letsdoit */
/************/
rqptr->rqCache.EntryPtr = captr;
status = CacheBegin (rqptr);
if (VMSnok (status)) rqptr->rqCache.EntryPtr = NULL;
return (status);
}
/***********/
/* not hit */
/***********/
CacheHashTableCollsnMissCount++;
return (SS$_NOSUCHFILE);
}
/*****************************************************************************/
/*
Use this cached entry as the contents for the client. If the entry needs to
be validated then generate an asynchronous ACP QIO to get the required file
details, other wise call the AST processing function directly.
NOTE: as with CacheLoadBegin(), the path passed to this function MUST be the
mapped path, not the request path. With conditional mapping identical request
paths may be mapped to completely different virtual paths.
*/
int CacheBegin (REQUEST_STRUCT *rqptr)
{
BOOL RevalidateEntry;
FILE_CENTRY *captr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "CacheBegin() !AZ",
rqptr->rqCache.EntryPtr->FileOds.ExpFileName);
captr = rqptr->rqCache.EntryPtr;
if (captr->EntryPermanent)
RevalidateEntry = false;
else
if (rqptr->NotFromCache &&
captr->GuardTickSecond < HttpdTickSecond)
RevalidateEntry = true;
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_DAY)
if (captr->ExpiresAfterTime != HttpdTime7[2])
RevalidateEntry = true;
else
RevalidateEntry = false;
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_HOUR)
if (captr->ExpiresAfterTime != HttpdTime7[3])
RevalidateEntry = true;
else
RevalidateEntry = false;
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_MINUTE)
if (captr->ExpiresAfterTime != HttpdTime7[4])
RevalidateEntry = true;
else
RevalidateEntry = false;
else
if (captr->ExpiresTickSecond < HttpdTickSecond)
RevalidateEntry = true;
else
RevalidateEntry = false;
if (!RevalidateEntry)
{
/* status of non-zero used to determine whether the ACPQIO was used */
captr->FileOds.FileQio.IOsb.Status = 0;
CacheAcpInfoAst (rqptr);
return (SS$_NORMAL);
}
if (captr->FromFile)
{
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE revalidate !AZ",
captr->FileOds.ExpFileName);
captr->EntryRevalidating = true;
captr->InUseCount++;
captr->ValidatedCount++;
OdsFileAcpInfo (&captr->FileOds, &CacheAcpInfoAst, rqptr);
return (SS$_NORMAL);
}
/* non-file entries that are invalid are purged and re-cached */
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE stale !AZ",
captr->FileOds.ExpFileName);
CacheRemoveEntry (captr, false);
/* move it to the end of the cache list ready for reuse */
ListMoveTail (&CacheList, captr);
return (SS$_NOSUCHFILE);
}
/*****************************************************************************/
/*
Called either explicitly or as an AST from an ACP QIO in CacheBegin(). Check if
modified, if not then just reply with a 302 header. If contents should be
transfered to the client then begin. If there is a problem at all then declare
the AST to continue processing the request and let it worry about it, otherwise
begin providing the file data from the cache entry.
*/
void CacheAcpInfoAst (REQUEST_STRUCT *rqptr)
{
BOOL RangeValid;
int idx, status,
ContentLength;
unsigned short Length;
char *cptr, *sptr, *zptr;
RANGE_BYTE *rbptr;
REQUEST_AST AstFunction;
FILE_CENTRY *captr, *tcaptr;
FILE_CONTENT *fcptr;
FILE_QIO *fqptr;
LIST_ENTRY *leptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"CacheAcpInfoAst() !&F !&S !%D !%D", &CacheAcpInfoAst,
rqptr->rqCache.EntryPtr->FileOds.FileQio.IOsb.Status,
&rqptr->rqCache.EntryPtr->RdtTime64,
&rqptr->rqCache.EntryPtr->FileOds.FileQio.RdtTime64);
captr = rqptr->rqCache.EntryPtr;
fqptr = &captr->FileOds.FileQio;
/* proactively remove the association between the entry and the request */
rqptr->rqCache.EntryPtr = NULL;
/* status of non-zero used to determine whether the ACPQIO was used */
if (fqptr->IOsb.Status)
{
/*********************/
/* revalidating file */
/*********************/
/* finished getting the revalidate data */
captr->EntryRevalidating = false;
captr->InUseCount--;
/* first deassign the channel allocated by OdsFileAcpInfo() */
sys$dassgn (fqptr->AcpChannel);
if (VMSnok (fqptr->IOsb.Status))
{
/***********************/
/* file access problem */
/***********************/
/* entry no longer valid */
CacheRemoveEntry (captr, false);
/* move it to the end of the cache list ready for reuse */
ListMoveTail (&CacheList, captr);
CacheEnd (rqptr);
return;
}
if (rqptr->rqResponse.HttpVersion == HTTP_VERSION_1_1)
if (captr->EntityTag[0])
strcpy (rqptr->rqResponse.EntityTag, captr->EntityTag);
fqptr->EndOfFileVbn = ((fqptr->RecAttr.fat$l_efblk & 0xffff) << 16) |
((fqptr->RecAttr.fat$l_efblk & 0xffff0000) >> 16);
fqptr->FirstFreeByte = fqptr->RecAttr.fat$w_ffbyte;
if (captr->RdtTime64 != fqptr->RdtTime64 ||
captr->EndOfFileVbn != fqptr->EndOfFileVbn ||
captr->FirstFreeByte != fqptr->FirstFreeByte)
{
/************************/
/* data no longer valid */
/************************/
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE stale !AZ !%D (!%D / !%D) (!UL,!UL / !UL,!UL)",
captr->FileOds.ExpFileName, &captr->CdtTime64,
&captr->RdtTime64, &fqptr->RdtTime64,
captr->EndOfFileVbn, captr->FirstFreeByte,
fqptr->EndOfFileVbn, fqptr->FirstFreeByte);
/* entry no longer valid */
CacheRemoveEntry (captr, false);
/* move it to the end of the cache list ready for reuse */
ListMoveTail (&CacheList, captr);
CacheEnd (rqptr);
return;
}
/********************/
/* data still valid */
/********************/
/* note the time the cached data was last validated */
captr->ValidateTime64 = rqptr->rqTime.BeginTime64;
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_DAY)
captr->ExpiresAfterTime = HttpdTime7[2];
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_HOUR)
captr->ExpiresAfterTime = HttpdTime7[3];
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_MINUTE)
captr->ExpiresAfterTime = HttpdTime7[4];
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_NONE)
captr->ExpiresTickSecond = 0xffffffff;
else
if (captr->ExpiresAfterPeriod)
captr->ExpiresTickSecond = HttpdTickSecond + captr->ExpiresAfterPeriod;
else
captr->ExpiresTickSecond = HttpdTickSecond + CacheValidateSeconds;
if (captr->GuardSeconds)
captr->GuardTickSecond = HttpdTickSecond + captr->GuardSeconds;
else
captr->GuardTickSecond = HttpdTickSecond + CacheGuardSeconds;
}
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE hit !&?permanent\rvolatile\r !AZ",
captr->EntryPermanent, captr->FileOds.ExpFileName);
/**************************************/
/* request to be fulfilled from cache */
/**************************************/
/* cancel any no-such-file callback, we've obviously got it! */
if (rqptr->FileTaskPtr) rqptr->FileTaskPtr->NoSuchFileFunction = NULL;
captr->HitTime64 = rqptr->rqTime.BeginTime64;
captr->FrequentTickSecond = HttpdTickSecond + CacheFrequentSeconds;
CacheHitCount++;
if (!captr->HitCount) CacheHits0--;
captr->HitCount++;
if (captr->HitCount < 10)
CacheHits10++;
else
if (captr->HitCount < 100)
CacheHits100++;
else
if (captr->HitCount < 1000)
CacheHits1000++;
else
CacheHits1000plus++;
rqptr->AccountingDone =
InstanceGblSecIncrLong (&AccountingPtr->CacheHitCount);
/* if this entry has more hits move it to the head of the cache list */
leptr = CacheList.HeadPtr;
tcaptr = (FILE_CENTRY*)leptr;
if (captr->HitCount > tcaptr->HitCount)
ListMoveHead (&CacheList, captr);
else
{
/* if this entry has more hits than the one "above" it swap them */
leptr = captr;
if (leptr->PrevPtr)
{
leptr = leptr->PrevPtr;
tcaptr = (FILE_CENTRY*)leptr;
if (captr->HitCount > tcaptr->HitCount)
{
ListRemove (&CacheList, captr);
ListAddBefore (&CacheList, leptr, captr, LIST_ENTRY_TYPE_CACHE);
}
}
}
if (captr->ContentHandlerFunction)
{
/***********************************/
/* this file has a content handler */
/***********************************/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "!&X",
captr->ContentHandlerFunction);
/* reassociated the cache entry with this request */
rqptr->rqCache.EntryPtr = captr;
/* allow one extra character for a(n implicit) terminating null */
rqptr->FileContentPtr = fcptr = (FILE_CONTENT*)
VmGetHeap (rqptr, sizeof(FILE_CONTENT) + captr->ContentLength+1);
fcptr->ContentSize = fcptr->ContentSizeMax = captr->ContentLength+1;
/* buffer space immediately follows the structured storage */
fcptr->ContentPtr = (char*)fcptr + sizeof(FILE_CONTENT);
memcpy (fcptr->ContentPtr,
captr->ContentPtr,
fcptr->ContentLength = captr->ContentLength);
/* populate the file contents structure with some file data */
zptr = (sptr = fcptr->FileName) + sizeof(fcptr->FileName);
for (cptr = captr->FileOds.ExpFileName;
*cptr && sptr < zptr;
*sptr++ = *cptr++);
if (sptr >= zptr)
{
ErrorGeneralOverflow (rqptr, FI_LI);
CacheEnd (rqptr);
return;
}
*sptr = '\0';
fcptr->FileNameLength = sptr - fcptr->FileName;
fcptr->CdtTime64 = captr->CdtTime64;
fcptr->RdtTime64 = captr->RdtTime64;
fcptr->UicGroup = captr->UicGroup;
fcptr->UicMember = captr->UicMember;
fcptr->Protection = captr->Protection;
fcptr->ContentHandlerFunction = captr->ContentHandlerFunction;
CacheEnd (rqptr);
return;
}
if (!rqptr->rqResponse.HeaderGenerated)
{
/**************************/
/* full response required */
/**************************/
if (captr->FromFile)
{
/********/
/* file */
/********/
if (rqptr->rqHeader.RangeBytePtr &&
rqptr->rqHeader.RangeBytePtr->Total)
{
/**************/
/* byte-range */
/**************/
RangeValid = true;
rbptr = rqptr->rqHeader.RangeBytePtr;
for (idx = 0; idx < rbptr->Total; idx++)
{
if (!rbptr->Last[idx])
{
/* last byte not specified, set at EOF */
rbptr->Last[idx] = captr->ContentLength - 1;
}
else
if (rbptr->Last[idx] < 0)
{
/* first byte a negative offset from end, last byte at EOF */
rbptr->First[idx] = captr->ContentLength + rbptr->Last[idx];
if (rbptr->First[idx] < 0) rbptr->First[idx] = 0;
rbptr->Last[idx] = captr->ContentLength - 1;
}
else
if (rbptr->Last[idx] >= captr->ContentLength)
{
/* if the last byte is ambit make it at the EOF */
rbptr->Last[idx] = captr->ContentLength - 1;
}
/* if the range still does not make sense then back out now */
if (rbptr->Last[idx] < rbptr->First[idx])
{
RangeValid = false;
rbptr->Length = 0;
}
else
rbptr->Length = rbptr->Last[idx] - rbptr->First[idx] + 1;
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"RANGE !UL !UL-!UL !UL byte!%s!&? INVALID\r\r",
idx+1, rbptr->First[idx], rbptr->Last[idx],
rbptr->Length, !rbptr->Length);
}
if (RangeValid) rbptr->Count = idx;
}
if (rqptr->rqPathSet.CharsetPtr)
{
cptr = captr->FileOds.ResFileName;
if (!*cptr) cptr = captr->FileOds.ExpFileName;
rqptr->rqPathSet.CharsetPtr = FileSetCharset (rqptr, cptr);
}
if (rqptr->rqResponse.HttpVersion == HTTP_VERSION_1_1)
if (captr->EntityTag[0])
strcpy (rqptr->rqResponse.EntityTag, captr->EntityTag);
/* in this case /status/ is used as a boolean */
status = FileResponseHeader (rqptr,
captr->ContentType,
captr->ContentLength,
&captr->RdtTime64);
if (!status)
{
captr->HitNotModifiedCount++;
CacheEnd (rqptr);
return;
}
}
else
{
/************/
/* non-file */
/************/
if (captr->ContentType[0])
{
/* if any retained CGI header fields add these to the header */
if (captr->CgiHeaderLength)
{
cptr = captr->ContentPtr;
ContentLength = captr->ContentLength -
captr->CgiHeaderLength - 1;
}
else
{
cptr = NULL;
ContentLength = captr->ContentLength;
}
ResponseHeader (rqptr, 200, captr->ContentType,
ContentLength, &captr->RdtTime64, cptr);
}
else
{
/* when no associated content-type it's an NPH script */
rqptr->rqResponse.HttpStatus = 200;
}
}
/* quit here if the HTTP method was HEAD */
if (rqptr->rqHeader.Method == HTTP_METHOD_HEAD)
{
CacheEnd (rqptr);
return;
}
}
/************/
/* transfer */
/************/
/* 'CacheInUse' keeps track of whether the entry is in use or not */
captr->InUseCount++;
/* initialize this for start-of-transfer detection in CacheNext() */
rqptr->rqCache.ContentPtr = NULL;
/* reassociated the cache entry with this request */
rqptr->rqCache.EntryPtr = captr;
/* network writes are checked for success, fudge the first one! */
rqptr->NetIoPtr->WriteStatus = SS$_NORMAL;
/* begin the transfer */
if (STR_DSC_LEN(&rqptr->NetWriteBufferDsc))
{
/* after ensuring the current contents are output */
NetWriteFullFlush (rqptr, &CacheNext);
}
else
CacheNext (rqptr);
}
/*****************************************************************************/
/*
Write the next (or first) block of data from the cache buffer to the client.
*/
void CacheNext (REQUEST_STRUCT *rqptr)
{
int status,
DataLength;
unsigned short Length;
unsigned char *DataPtr;
FILE_CENTRY *captr;
RANGE_BYTE *rbptr;
REQUEST_AST AstFunction;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "CacheNext() !&F !&S",
&CacheNext, rqptr->NetIoPtr->WriteStatus);
if (rqptr->RequestState >= REQUEST_STATE_ABORT)
{
CacheEnd (rqptr);
return;
}
if (VMSnok (rqptr->NetIoPtr->WriteStatus))
{
CacheEnd (rqptr);
return;
}
captr = rqptr->rqCache.EntryPtr;
if (!rqptr->rqCache.ContentPtr)
{
/* first read, initialize content pointer and length */
if (rqptr->rqHeader.RangeBytePtr &&
rqptr->rqHeader.RangeBytePtr->Count)
{
/* returning a byte range within the file (partial content) */
rbptr = rqptr->rqHeader.RangeBytePtr;
rbptr->Length = rbptr->Last[rbptr->Index] -
rbptr->First[rbptr->Index] + 1;
if (rbptr->Count > 1)
{
/* returning 'multipart/byteranges' range content */
char Buffer [256];
FaoToBuffer (Buffer, sizeof(Buffer), &Length,
"!AZ--!AZ\r\n\
Content-Type: !AZ\r\n\
Range: bytes !UL-!UL/!UL\r\n\
\r\n",
rbptr->Index ? "\r\n" : "",
rqptr->rqResponse.MultipartBoundaryPtr,
captr->ContentType,
rbptr->First[rbptr->Index],
rbptr->Last[rbptr->Index],
captr->ContentLength);
/* synchronous network write (just for the convenience of it!) */
NetWrite (rqptr, NULL, Buffer, Length);
}
rqptr->rqCache.ContentPtr = captr->ContentPtr +
rbptr->First[rbptr->Index];
rqptr->rqCache.ContentLength = rbptr->Length;
}
else
if (captr->GzipContentPtr &&
rqptr->rqResponse.ContentEncodeAsGzip &&
/* if the header has been sent this is something like a readme! */
!rqptr->rqResponse.HeaderSent)
{
/* GZIP content is available and we're going to provide one */
rqptr->rqCache.ContentPtr = captr->GzipContentPtr;
rqptr->rqCache.ContentLength = captr->GzipContentLength;
rqptr->rqResponse.ContentEncodeAsGzip = false;
rqptr->rqResponse.ContentIsEncodedGzip = true;
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE (gzip deflated) !UL->!UL bytes, !UL%",
captr->ContentLength, captr->GzipContentLength,
PercentOf32(captr->GzipContentLength,
captr->ContentLength));
}
else
{
/* use the unencoded content */
rqptr->rqCache.ContentPtr = captr->ContentPtr;
rqptr->rqCache.ContentLength = captr->ContentLength;
if (captr->CgiHeaderLength)
{
/* adjust body of response for any retained CGI header fields */
rqptr->rqCache.ContentPtr += captr->CgiHeaderLength + 1;
rqptr->rqCache.ContentLength -= captr->CgiHeaderLength + 1;
}
}
}
if (rqptr->rqCache.ContentLength > OutputFileBufferSize)
{
DataPtr = rqptr->rqCache.ContentPtr;
DataLength = OutputFileBufferSize;
rqptr->rqCache.ContentPtr += DataLength;
rqptr->rqCache.ContentLength -= DataLength;
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
{
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "CACHE !UL/!UL",
DataLength, rqptr->rqCache.ContentLength);
WatchDataDump (DataPtr, DataLength);
}
NetWrite (rqptr, &CacheNext, DataPtr, DataLength);
return;
}
else
{
DataPtr = rqptr->rqCache.ContentPtr;
DataLength = rqptr->rqCache.ContentLength;
rqptr->rqCache.ContentLength = 0;
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
{
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "CACHE !UL/!UL",
DataLength, rqptr->rqCache.ContentLength);
WatchDataDump (DataPtr, DataLength);
}
NetWrite (rqptr, &CacheEnd, DataPtr, DataLength);
return;
}
}
/*****************************************************************************/
/*
End of transfer to client using cached contents.
*/
void CacheEnd (REQUEST_STRUCT *rqptr)
{
char *cptr, *sptr, *zptr;
FILE_CENTRY *captr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "CacheEnd() !&F", &CacheEnd);
if (!(captr = rqptr->rqCache.EntryPtr))
{
/* entry is no longer valid */
if (rqptr->FileTaskPtr)
FileParse (rqptr);
else
RequestExecutePostCache1 (rqptr);
return;
}
if (rqptr->rqHeader.RangeBytePtr &&
rqptr->rqHeader.RangeBytePtr->Count)
{
/* transfering byte-range(s) */
rqptr->rqHeader.RangeBytePtr->Index++;
if (rqptr->rqHeader.RangeBytePtr->Index <
rqptr->rqHeader.RangeBytePtr->Count)
{
/* multiple byte ranges, restart with next range */
rqptr->rqCache.ContentPtr = NULL;
rqptr->rqCache.ContentLength = 0;
SysDclAst (&CacheNext, rqptr);
return;
}
if (rqptr->rqHeader.RangeBytePtr->Count > 1)
{
/* end of multiple byte ranges, provide final boundary */
char Buffer [64];
zptr = (sptr = Buffer) + sizeof(Buffer)-1;
for (cptr = "\r\n--"; *cptr && sptr < zptr; *sptr++ = *cptr++);
for (cptr = rqptr->rqResponse.MultipartBoundaryPtr;
*cptr && sptr < zptr;
*sptr++ = *cptr++);
for (cptr = "--\r\n"; *cptr && sptr < zptr; *sptr++ = *cptr++);
*sptr = '\0';
/* synchronous network write (for the convenience of it!) */
NetWrite (rqptr, NULL, Buffer, sptr-Buffer);
}
}
/* this cache entry is no longer associated with this request */
rqptr->rqCache.EntryPtr = NULL;
/* this cache entry is no longer in use (if now zero) */
if (captr->InUseCount) captr->InUseCount--;
if (captr->Purge && !captr->InUseCount)
{
if (captr->PurgeCompletely)
CacheRemoveEntry (captr, true);
else
{
CacheRemoveEntry (captr, false);
/* move it to the end of the cache list ready for reuse */
ListMoveTail (&CacheList, captr);
}
}
rqptr->BytesTxGzipPercent = PercentOf32 (captr->GzipContentLength,
captr->ContentLength);
if (rqptr->FileTaskPtr)
FileEnd (rqptr);
else
RequestEnd (rqptr);
}
/*****************************************************************************/
/*
Check that we're interested in caching this particular data and that the
requested size is allowed to be cached. Find/create a cache structure ready to
contain the data buffered. This also blocks other concurrent loads of the same
resource. It is entirely possible, given that the maximum number of cache
entries has been reached and all are currently in use (either for data transfer
or being loaded) - though this if fairly unlikely, that there will be no cache
entry available for this request to use and the load will fail. If available
allocate an appropriate chunk of either volatile or permanent cache memory and
use that to load the to-be-cached data.
*/
BOOL CacheLoadBegin
(
REQUEST_STRUCT *rqptr,
int SizeInBytes,
char *ContentTypePtr
)
{
int secs, MaxKBytes;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"CacheLoadBegin() !UL bytes !&Z !&Z http:!UL in-use:!&B",
SizeInBytes, ContentTypePtr, rqptr->rqHeader.QueryStringPtr,
rqptr->rqResponse.HttpStatus, rqptr->rqCache.ContentPtr);
rqptr->rqCache.LoadCheck = true;
/* could be disabled between search and load beginning */
if (!CacheEnabled) return (false);
/* only interested in HTTP success status */
if (rqptr->rqResponse.HttpStatus &&
rqptr->rqResponse.HttpStatus != 200 &&
rqptr->rqResponse.HttpStatus != 203) return (false);
/* if this cache structure is already in use (e.g. directory listing) */
if (rqptr->rqCache.EntryPtr) return (false);
/* if not interested in query strings */
if (!rqptr->rqPathSet.CacheQuery &&
rqptr->rqHeader.QueryStringLength) return (false);
/* if a SET mapping rule has specified the path should not be cached */
if (rqptr->rqPathSet.NoCache) return (false);
/* if not a GET request */
if (rqptr->rqHeader.Method != HTTP_METHOD_GET) return (false);
/* server has specifically set this request not to be cached */
if (rqptr->rqCache.DoNotCache) return (false);
MaxKBytes = 0;
if (rqptr->rqCgi.ScriptControlCacheMaxKBytes)
{
/* start off with any script specified value */
MaxKBytes = rqptr->rqCgi.ScriptControlCacheMaxKBytes;
if (rqptr->rqPathSet.CacheMaxKBytes)
{
/* any path setting should limit anything script supplied */
if (MaxKBytes > rqptr->rqPathSet.CacheMaxKBytes)
MaxKBytes = rqptr->rqPathSet.CacheMaxKBytes;
}
else
{
/* configuration setting should limit anything script supplied */
if (MaxKBytes > CacheEntryKBytesMax) MaxKBytes = CacheEntryKBytesMax;
}
}
else
if (rqptr->rqPathSet.CacheMaxKBytes)
{
/* path specified maximum overrides configuration maximum */
MaxKBytes = rqptr->rqPathSet.CacheMaxKBytes;
}
/* fall back to using the configuration setting */
if (!MaxKBytes) MaxKBytes = CacheEntryKBytesMax;
/* zero indicates exact size is unknown so start with an ambit maximum */
if (SizeInBytes <= 0) SizeInBytes = MaxKBytes << 10;
/* if it's larger than the maximum allowed */
if ((SizeInBytes >> 10) > MaxKBytes)
{
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE load fail, too large (!ULkB>!ULkB)",
SizeInBytes >> 10, MaxKBytes);
return (false);
}
if (!CacheLoadResponse (rqptr)) return (false);
/* if we can't get one then just forget it! */
if (!CacheAllocateEntry (rqptr)) return (false);
/* calculate the cache chunk */
if (SizeInBytes % CacheChunkInBytes) SizeInBytes += CacheChunkInBytes;
SizeInBytes = SizeInBytes / CacheChunkInBytes;
SizeInBytes *= CacheChunkInBytes;
if (rqptr->rqPathSet.CachePermanent)
rqptr->rqCache.ContentPtr = VmGetPermCache (SizeInBytes);
else
rqptr->rqCache.ContentPtr = VmGetCache (SizeInBytes);
rqptr->rqCache.CurrentPtr = rqptr->rqCache.ContentPtr;
rqptr->rqCache.ContentRemaining = SizeInBytes;
rqptr->rqCache.ContentBufferSize = SizeInBytes;
rqptr->rqCache.ContentLength = rqptr->rqCache.RecordBlockLength = 0;
rqptr->rqCache.ContentTypePtr = ContentTypePtr;
rqptr->rqCache.Loading = true;
rqptr->rqCache.LoadStatus = 0;
CacheCurrentlyLoadingInUse += SizeInBytes;
CacheCurrentlyLoading++;
return (true);
}
/*****************************************************************************/
/*
This function checks any cache-control in that and if it should not be cached
returns false. It also checks for an entity-tag header and stores it locally
to the request, and for the presence of a cookie (responses with cookies or
vary headers are never cached). The rqCache.Response.. storage conveys
information back to the cache load to determine some characterstics. Return
true to allow caching (the default), and false to prohibit caching. This
function is very much a collection of pragmatics.
*/
BOOL CacheLoadResponse (REQUEST_STRUCT *rqptr)
{
BOOL ok2cache,
CookieHit = false,
VaryCookie = false;
int len,
CacheFor = CACHE_EXPIRES_NONE,
VaryCount = 0;
char *cptr, *sptr, *zptr;
DICT_ENTRY_STRUCT *denptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "CacheLoadResponse()");
if (denptr = DictLookup (rqptr->rqDictPtr, DICT_TYPE_RESPONSE,
"cache-control", 13))
{
cptr = DICT_GET_VALUE(denptr);
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE cache-control: !AZ", cptr);
while (*cptr)
{
if (strsame (cptr, "max-age=", len=8))
CacheFor = rqptr->rqCache.ResponseCacheControl = atoi(cptr+8);
else
if (strsame (cptr, "must-revalidate", len=15))
CacheFor = 0;
else
if (strsame (cptr, "no-cache", len=8))
CacheFor = 0;
else
if (strsame (cptr, "no-store", len=8))
CacheFor = 0;
else
if (strsame (cptr, "private", len=7))
CacheFor = 0;
else
if (strsame (cptr, "proxy-revalidate", len=16))
CacheFor = 0;
else
if (strsame (cptr, "public", len=6))
CacheFor = CACHE_EXPIRES_NONE;
else
if (strsame (cptr, "s-maxage=", len=9))
CacheFor = rqptr->rqCache.ResponseCacheControl = atoi(cptr+9);
else
len = 0;
while (*cptr && !ISLWS(*cptr) && *cptr != ',') cptr++;
while (*cptr && (ISLWS(*cptr) || *cptr == ',')) cptr++;
}
}
if (denptr = DictLookup (rqptr->rqDictPtr, DICT_TYPE_RESPONSE, "etag", 4))
{
cptr = DICT_GET_VALUE(denptr);
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE etag: !AZ", cptr);
zptr = (sptr = rqptr->rqCache.ResponseEntityTag) +
sizeof(rqptr->rqCache.ResponseEntityTag)-1;
if (*cptr == '\"') cptr++;
while (*cptr && !ISLWS(*cptr) && *cptr != '\"' && sptr < zptr)
*sptr++ = *cptr++;
if (sptr >= zptr)
{
ErrorNoticed (rqptr, SS$_RESULTOVF, NULL, FI_LI);
sptr = rqptr->rqCache.ResponseEntityTag;
}
*sptr = '\0';
}
if (denptr = DictLookup (rqptr->rqDictPtr, DICT_TYPE_RESPONSE, "pragma", 6))
{
cptr = DICT_GET_VALUE(denptr);
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE pragma: !AZ", cptr);
while (*cptr && ISLWS(*cptr)) cptr++;
if (strsame (cptr, "no-cache", 8)) CacheFor = 0;
}
if (denptr = DictLookup (rqptr->rqDictPtr, DICT_TYPE_RESPONSE,
"set-cookie", 10))
{
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE set-cookie:");
CookieHit = true;
}
if (denptr = DictLookup (rqptr->rqDictPtr, DICT_TYPE_RESPONSE, "vary", 4))
{
cptr = DICT_GET_VALUE(denptr);
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE vary: !AZ", cptr);
while (*cptr && ISLWS(*cptr)); cptr++;
/* server generated response based on specific request characteristics */
VaryCount = 1;
VaryCookie = false;
while (*cptr)
{
if (*cptr == ',')
VaryCount++;
else
if (TOUP(*cptr) == 'C' && strsame (cptr, "Cookie", 6))
VaryCookie = true;
cptr++;
}
/* if the only variation is cookie and not one in this response */
if (VaryCount == 1 && VaryCookie && !CookieHit) VaryCount = 0;
}
/* return true if (all other things being equal) it's OK to cache */
ok2cache = !CookieHit && !VaryCount && CacheFor != 0;
if (WATCHING (rqptr, WATCH_RESPONSE))
{
if (!ok2cache)
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE no");
else
if (CacheFor != CACHE_EXPIRES_NONE)
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE for !UL", CacheFor);
}
return (ok2cache);
}
/*****************************************************************************/
/*
Check the success of the load. This is indicated using an end-of-file status.
If the load failed or finding a cache entry failed just discard the loaded data
and return the memory to the cache pool. If the content-type, etc., lends
itself to being GZIP encoded then go ahead and process the cached binary
content into a buffer of GZIP compressed content.
*/
void CacheLoadEnd (REQUEST_STRUCT *rqptr)
{
int status,
ReclaimEntryBytes,
ReclaimEntryCount,
SizeInBytes;
char *cptr, *sptr, *zptr;
FILE_CENTRY *captr, *lcaptr;
FILE_TASK *ftkptr;
LIST_ENTRY *leptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
if (rqptr->FileTaskPtr)
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"CacheLoadEnd() file:!&B !UL !&S",
rqptr->FileTaskPtr, rqptr->rqResponse.HttpStatus,
rqptr->rqCache.LoadStatus);
else
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"CacheLoadEnd() file:FALSE !UL !&S",
rqptr->rqResponse.HttpStatus, rqptr->rqCache.LoadStatus);
/* better check, caching could be enabled between ASTs since search */
if (!CacheHashTableInitialised) CacheInit (false);
if (!rqptr->rqCache.Loading)
ErrorExitVmsStatus (SS$_BUGCHECK, ErrorSanityCheck, FI_LI);
captr = rqptr->rqCache.EntryPtr;
/* entry is no longer associated with this request */
rqptr->rqCache.EntryPtr = NULL;
captr->InUseCount--;
if (captr->FromFile = rqptr->rqCache.LoadFromFile) cptr = "FILE";
if (captr->FromNet = rqptr->rqCache.LoadFromNet) cptr = "NET";
if (captr->FromScript = rqptr->rqCache.LoadFromCgi) cptr = "CGI";
rqptr->rqCache.Loading =
rqptr->rqCache.LoadFromCgi =
rqptr->rqCache.LoadFromFile =
rqptr->rqCache.LoadFromNet = false;
CacheCurrentlyLoading--;
CacheCurrentlyLoadingInUse -= rqptr->rqCache.ContentBufferSize;
/* not interested in anything but successful responses */
if ((rqptr->rqResponse.HttpStatus &&
rqptr->rqResponse.HttpStatus != 200 &&
rqptr->rqResponse.HttpStatus != 203) ||
/* an early HTTP success status but an error during processing */
rqptr->rqResponse.ErrorReportPtr)
rqptr->rqCache.LoadStatus = SS$_CANCEL;
/* end-of-file is used to indicate successful cache data load */
if (rqptr->rqCache.LoadStatus != RMS$_EOF &&
rqptr->rqCache.LoadStatus != SS$_ENDOFFILE)
{
/*********************/
/* load unsuccessful */
/*********************/
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE load from !AZ fail, data %!&M",
cptr, rqptr->rqCache.LoadStatus);
CacheRemoveEntry (captr, false);
/* move it to the end of the cache list ready for reuse */
ListMoveTail (&CacheList, captr);
if (rqptr->rqCache.ContentPtr)
{
if (rqptr->rqPathSet.CachePermanent)
VmFreePermCache (rqptr->rqCache.ContentPtr, FI_LI);
else
VmFreeCache (rqptr->rqCache.ContentPtr, FI_LI);
rqptr->rqCache.ContentPtr = NULL;
}
return;
}
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE load from !AZ complete, !UL bytes",
cptr, rqptr->rqCache.ContentLength);
/**********************/
/* check memory usage */
/**********************/
/* calculate the required cache chunk */
SizeInBytes = rqptr->rqCache.ContentLength;
if (SizeInBytes % CacheChunkInBytes) SizeInBytes += CacheChunkInBytes;
SizeInBytes = SizeInBytes / CacheChunkInBytes;
SizeInBytes *= CacheChunkInBytes;
if (!SizeInBytes) SizeInBytes = CacheChunkInBytes;
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "!UL < !UL !&B",
SizeInBytes, rqptr->rqCache.ContentBufferSize,
SizeInBytes < rqptr->rqCache.ContentBufferSize);
if (SizeInBytes < rqptr->rqCache.ContentBufferSize)
{
/* actually required cache chunk is smaller than original ambit chunk */
cptr = rqptr->rqCache.ContentPtr;
if (rqptr->rqPathSet.CachePermanent)
{
sptr = VmGetPermCache (SizeInBytes);
memcpy (sptr, cptr, rqptr->rqCache.ContentLength);
VmFreePermCache (cptr, FI_LI);
}
else
{
sptr = VmGetCache (SizeInBytes);
memcpy (sptr, cptr, rqptr->rqCache.ContentLength);
VmFreeCache (cptr, FI_LI);
}
rqptr->rqCache.ContentPtr = sptr;
rqptr->rqCache.ContentBufferSize = SizeInBytes;
}
/************************/
/* populate cache entry */
/************************/
InstanceGblSecIncrLong (&AccountingPtr->CacheLoadCount);
CacheLoadCount++;
CacheHits0++;
/* move entry to the head of the cache list */
ListMoveHead (&CacheList, captr);
if (rqptr->rqPathSet.CachePermanent)
{
/* permanent cache entry */
captr->EntryPermanent = true;
CachePermEntryCount++;
CacheEntryCount--;
CachePermMemoryInUse += rqptr->rqCache.ContentBufferSize;
}
else
CacheMemoryInUse += rqptr->rqCache.ContentBufferSize;
captr->ContentPtr = rqptr->rqCache.ContentPtr;
captr->EntrySize = rqptr->rqCache.ContentBufferSize;
captr->ContentLength = rqptr->rqCache.ContentLength;
rqptr->rqCache.ContentPtr = NULL;
captr->HitCount = 0;
captr->DataLoading = false;
captr->EntryValid = true;
/* quadword time file was loaded/validated, created, last modified */
captr->LoadTime64 = rqptr->rqTime.BeginTime64;
captr->ValidateTime64 = rqptr->rqTime.BeginTime64;
/* some file details (if applicable) */
if (ftkptr = rqptr->FileTaskPtr)
{
captr->EndOfFileVbn = ftkptr->FileOds.FileQio.EndOfFileVbn;
captr->FirstFreeByte = ftkptr->FileOds.FileQio.FirstFreeByte;
captr->UicGroup = (ftkptr->FileOds.FileQio.AtrUic & 0x0fff0000) >> 16;
captr->UicMember = (ftkptr->FileOds.FileQio.AtrUic & 0x0000ffff);
captr->Protection = ftkptr->FileOds.FileQio.AtrFpro;
captr->CdtTime64 = ftkptr->FileOds.FileQio.CdtTime64;
captr->RdtTime64 = ftkptr->FileOds.FileQio.RdtTime64;
strcpy (captr->EntityTag, ftkptr->EntityTag);
/* copy the entire on-disk structure from file to cache */
OdsCopyStructure (&captr->FileOds, &ftkptr->FileOds);
/* the cache entry will reuse the original content handler (if any) */
captr->ContentHandlerFunction = ftkptr->ContentHandlerFunction;
/* drop through to buffer the content-type */
cptr = ftkptr->ContentTypePtr;
}
else
{
captr->FirstFreeByte = captr->EndOfFileVbn =
captr->UicGroup = captr->UicMember = captr->Protection = 0;
memset (&captr->FileOds, 0, sizeof(captr->FileOds));
captr->CdtTime64 = rqptr->rqTime.BeginTime64;
captr->RdtTime64 = rqptr->rqTime.BeginTime64;
strcpy (captr->EntityTag, rqptr->rqCache.ResponseEntityTag);
captr->ContentHandlerFunction = NULL;
/* add the path purely for cache report purposes */
zptr = (sptr = captr->FileOds.ExpFileName) +
sizeof(captr->FileOds.ExpFileName)-1;
for (cptr = rqptr->ServicePtr->ServerHostPort;
*cptr && sptr < zptr;
*sptr++ = *cptr++);
for (cptr = rqptr->rqHeader.RequestUriPtr;
*cptr && *cptr != '?' && sptr < zptr;
*sptr++ = *cptr++);
if (rqptr->rqPathSet.CacheQuery)
{
/* those cached regardless include any request query string */
while (*cptr && sptr < zptr) *sptr++ = *cptr++;
}
*sptr = '\0';
/* drop through to buffer the content-type */
cptr = rqptr->rqCache.ContentTypePtr;
}
/* note if the cached content contains any CGI header fields */
if (captr->FromScript && rqptr->rqCgi.HeaderLength)
captr->CgiHeaderLength = rqptr->rqCgi.HeaderLength;
/* buffer the content type */
if (!cptr) cptr = "";
zptr = (sptr = captr->ContentType) + sizeof(captr->ContentType)-1;
while (*cptr && sptr < zptr) *sptr++ = *cptr++;
if (sptr >= zptr) ErrorNoticed (rqptr, SS$_RESULTOVF, NULL, FI_LI);
*sptr = '\0';
if (GzipResponse)
{
/*************************************/
/* generated GZIP compressed content */
/*************************************/
if (captr->ContentLength)
if (GzipShouldDeflate (rqptr, captr->ContentType,
captr->ContentLength))
GzipDeflateCache (rqptr, captr);
}
/********************/
/* set entry expiry */
/********************/
/* for max-age, etc. */
captr->LoadSeconds = HttpdTickSecond;
captr->ExpiresAfterPeriod = rqptr->rqPathSet.CacheExpiresAfter;
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_DAY)
captr->ExpiresAfterTime = HttpdTime7[2];
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_HOUR)
captr->ExpiresAfterTime = HttpdTime7[3];
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_MINUTE)
captr->ExpiresAfterTime = HttpdTime7[4];
else
if (captr->ExpiresAfterPeriod == CACHE_EXPIRES_NONE)
captr->ExpiresTickSecond = 0xffffffff;
else
if (captr->ExpiresAfterPeriod)
captr->ExpiresTickSecond = HttpdTickSecond + captr->ExpiresAfterPeriod;
else
captr->ExpiresTickSecond = HttpdTickSecond + CacheValidateSeconds;
captr->GuardSeconds = rqptr->rqPathSet.CacheGuardSeconds;
if (captr->GuardSeconds)
captr->GuardTickSecond = HttpdTickSecond + captr->GuardSeconds;
else
captr->GuardTickSecond = HttpdTickSecond + CacheGuardSeconds;
/* if we're using too much cache memory */
if ((CacheMemoryInUse >> 10) > CacheTotalKBytesMax)
{
/******************/
/* reclaim memory */
/******************/
CacheReclaimCount++;
ReclaimEntryCount = ReclaimEntryBytes = 0;
/* mark the current one just so *it* won't be reclaimed */
captr->InUseCount++;
/* process the cache entry list from least to most recent */
for (leptr = CacheList.TailPtr; leptr; leptr = leptr->PrevPtr)
{
/* remember, use a separate pointer or we get very confused :^) */
lcaptr = (FILE_CENTRY*)leptr;
if (WATCHPNT(rqptr) &&
WATCH_MODULE(WATCH_MOD_CACHE) &&
WATCH_MODULE(WATCH_MOD__DETAIL))
WatchThis (WATCHALL, WATCH_MOD_CACHE,
"!&Z !UL !UL !&B !&B !UL",
captr->FileOds.ExpFileName,
captr->EntrySize, captr->ContentLength,
captr->EntryValid, captr->EntryRevalidating,
captr->InUseCount);
/* if it's permanent or in use in some way then just continue */
if (lcaptr->EntryPermanent || lcaptr->InUseCount) continue;
ReclaimEntryCount++;
ReclaimEntryBytes += lcaptr->EntrySize;
/* entry no longer valid */
CacheRemoveEntry (lcaptr, false);
lcaptr->EntryReclaimed = true;
/* if we've reclaimed enough memory */
if ((CacheMemoryInUse >> 10) <= CacheTotalKBytesMax) break;
}
/* remove the reclaim prophylactic */
captr->InUseCount--;
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE load, reclaim !UL entries, !UL kBytes",
ReclaimEntryCount, ReclaimEntryBytes >> 10);
}
}
/*****************************************************************************/
/*
Copy the referenced data into the cache pre-allocated buffer (if there's still
space available).
*/
int CacheLoadData
(
REQUEST_STRUCT *rqptr,
char *DataPtr,
int DataLength
)
{
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"CacheLoadData() file:!&B cgi:!&B net:!&B !UL+!UL=!UL !UL-!UL=!UL",
rqptr->rqCache.LoadFromFile,
rqptr->rqCache.LoadFromCgi,
rqptr->rqCache.LoadFromNet,
rqptr->rqCache.ContentLength, DataLength,
rqptr->rqCache.ContentLength + DataLength,
rqptr->rqCache.ContentBufferSize,
rqptr->rqCache.ContentLength + DataLength,
rqptr->rqCache.ContentBufferSize -
rqptr->rqCache.ContentLength - DataLength);
if (DataLength <= rqptr->rqCache.ContentRemaining)
{
memcpy (rqptr->rqCache.CurrentPtr, DataPtr, DataLength);
rqptr->rqCache.CurrentPtr += DataLength;
rqptr->rqCache.ContentLength += DataLength;
rqptr->rqCache.ContentRemaining -= DataLength;
return (SS$_NORMAL);
}
return (rqptr->rqCache.LoadStatus = SS$_BUFFEROVF_ERROR);
}
/*****************************************************************************/
/*
Allocate a cache entry ready for data loading. Returns true if entry
available, false if not. Sets 'rqCache.CacheEntry' to point to the allocated
entry.
*/
BOOL CacheAllocateEntry (REQUEST_STRUCT *rqptr)
{
int HashValue;
FILE_CENTRY *captr, *lcaptr;
LIST_ENTRY *leptr;
MD5_HASH *md5ptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "CacheAllocateEntry() !16&H",
rqptr->FileTaskPtr ? &rqptr->FileTaskPtr->Md5Hash :
&rqptr->Md5HashPath);
if (rqptr->FileTaskPtr)
md5ptr = &rqptr->FileTaskPtr->Md5Hash;
else
md5ptr = &rqptr->Md5HashPath;
/**********************************/
/* check it doesn't already exist */
/**********************************/
/* 12 bit hash value, 0..4095 from a fixed 3 bytes of the MD5 hash */
HashValue = md5ptr->HashLong[0] & 0xfff;
for (captr = CacheHashTable[HashValue];
captr;
captr = captr->HashCollisionNextPtr)
{
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"file:!&B valid:!&B revalidating:!&B !AZ !16&H !&?match\rno-match\r",
captr->FromFile, captr->EntryValid,
captr->EntryRevalidating, captr->FileOds.ExpFileName,
&captr->Md5Hash,
MATCH16 (&captr->Md5Hash, md5ptr));
if (!MATCH16 (&captr->Md5Hash, md5ptr)) continue;
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "entry exists");
return (false);
}
/**********************/
/* find a cache entry */
/**********************/
captr = (FILE_CENTRY*)CacheList.TailPtr;
if (captr && !captr->EntryValid && !captr->InUseCount)
{
/****************************/
/* reuse invalid tail entry */
/****************************/
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE load, reuse entry");
}
else
if (CacheEntryCount + CachePermEntryCount >= CacheEntriesMax)
{
/***********************/
/* reuse a cache entry */
/***********************/
/* process the cache entry list from least to most recent */
for (leptr = CacheList.TailPtr; leptr; leptr = leptr->PrevPtr)
{
captr = (FILE_CENTRY*)leptr;
if (WATCHPNT(rqptr) &&
WATCH_MODULE(WATCH_MOD_CACHE) && WATCH_MODULE(WATCH_MOD__DETAIL))
WatchThis (WATCHALL, WATCH_MOD_CACHE,
"!&Z !UL !UL !&B !&B !UL",
captr->FileOds.ExpFileName,
captr->EntrySize, captr->ContentLength,
captr->EntryValid, captr->EntryRevalidating,
captr->InUseCount);
/* if it's permanent or in use in some way then just continue */
if (captr->EntryPermanent || captr->InUseCount) continue;
/* if it can be considered frequently hit */
if (captr->EntryValid &&
CacheFrequentHits &&
captr->HitCount > CacheFrequentHits &&
captr->FrequentTickSecond > HttpdTickSecond) continue;
/* entry no longer valid */
CacheRemoveEntry (captr, false);
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE load, reuse entry");
break;
}
/* if we got to the end of the list */
if (!leptr)
{
/**********************/
/* all entries in use */
/**********************/
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE,
"CACHE load, all entries in use");
return (false);
}
}
else
{
/*******************/
/* new cache entry */
/*******************/
captr = VmGet (sizeof(FILE_CENTRY));
CacheEntryCount++;
/* add it to the list */
ListAddTail (&CacheList, captr, LIST_ENTRY_TYPE_CACHE);
if (WATCHING (rqptr, WATCH_RESPONSE))
WatchThis (WATCHITM(rqptr), WATCH_RESPONSE, "CACHE load, new entry");
}
/**************/
/* init entry */
/**************/
captr->EntryReclaimed =
captr->EntryRevalidating =
captr->EntryValid =
captr->FromScript =
captr->FromNet =
captr->Purge =
captr->PurgeCompletely = false;
captr->ContentPtr = NULL;
captr->CgiHeaderLength = captr->EntrySize = 0;
if (rqptr->FileTaskPtr)
captr->FromFile = true;
else
captr->FromFile = false;
captr->DataLoading = true;
captr->InUseCount++;
/*************************/
/* add to the hash table */
/*************************/
memcpy (&captr->Md5Hash, md5ptr, sizeof(MD5_HASH));
/* 12 bit hash value, 0..4095 from a fixed 3 bytes of the MD5 hash */
HashValue = md5ptr->HashLong[0] & 0xfff;
if (!CacheHashTable[HashValue])
{
/* set hash table index */
CacheHashTable[HashValue] = captr;
captr->HashCollisionPrevPtr = captr->HashCollisionNextPtr = NULL;
}
else
{
/* add to head of hash-collision list */
lcaptr = CacheHashTable[HashValue];
lcaptr->HashCollisionPrevPtr = captr;
captr->HashCollisionPrevPtr = NULL;
captr->HashCollisionNextPtr = lcaptr;
CacheHashTable[HashValue] = captr;
}
rqptr->rqCache.EntryPtr = captr;
return (true);
}
/*****************************************************************************/
/*
Purge a cache entry, either just the data, or completely from the cache list.
*/
void CacheRemoveEntry
(
FILE_CENTRY *captr,
BOOL Completely
)
{
int HashValue;
/*********/
/* begin */
/*********/
if (WATCH_MODULE(WATCH_MOD_CACHE))
WatchThis (WATCHALL, WATCH_MOD_CACHE,
"CacheRemoveEntry() !&B", Completely);
if (captr->InUseCount)
{
if (Completely)
captr->Purge = captr->PurgeCompletely = true;
else
captr->Purge = true;
return;
}
/* note the number of entries loaded but never subsequently hit */
if (captr->EntryValid && !captr->HitCount) CacheNoHitsCount++;
if (captr->EntryPermanent)
{
/* permanent entry reverts to volatile when purged */
captr->EntryPermanent = false;
if (captr->ContentPtr)
{
VmFreePermCache (captr->ContentPtr, FI_LI);
CachePermMemoryInUse -= captr->EntrySize;
captr->ContentPtr = NULL;
captr->EntrySize = 0;
}
if (captr->GzipContentPtr)
{
VmFreePermCache (captr->GzipContentPtr, FI_LI);
CachePermMemoryInUse -= captr->GzipEntrySize;
captr->GzipContentPtr = NULL;
captr->GzipContentLength = captr->GzipEntrySize = 0;
}
CacheEntryCount++;
CachePermEntryCount--;
}
else
{
if (captr->ContentPtr)
{
VmFreeCache (captr->ContentPtr, FI_LI);
CacheMemoryInUse -= captr->EntrySize;
captr->ContentPtr = NULL;
captr->EntrySize = 0;
}
if (captr->GzipContentPtr)
{
VmFreeCache (captr->GzipContentPtr, FI_LI);
CacheMemoryInUse -= captr->GzipEntrySize;
captr->GzipContentPtr = NULL;
captr->GzipContentLength = captr->GzipEntrySize = 0;
}
}
captr->DataLoading =
captr->EntryValid =
captr->Purge =
captr->PurgeCompletely = false;
/* 12 bit hash value, 0..4095 from a fixed 3 bytes of the MD5 hash */
HashValue = captr->Md5Hash.HashLong[0] & 0xfff;
if ((FILE_CENTRY*)(CacheHashTable[HashValue]) == captr)
{
/* must be at the head of any collision list */
CacheHashTable[HashValue] = captr->HashCollisionNextPtr;
if (captr->HashCollisionNextPtr)
captr->HashCollisionNextPtr->HashCollisionPrevPtr =
captr->HashCollisionPrevPtr;
}
else
{
/* if somewhere along the collision list */
if (captr->HashCollisionPrevPtr)
captr->HashCollisionPrevPtr->HashCollisionNextPtr =
captr->HashCollisionNextPtr;
/*
*** SITE OF ONE OF MY MOST STUPID AND COSTLY PROGRAMMING ERRORS ***
If this isn't an argument against coding for speed and efficiency
instead of with tested and common code routines I don't know what is!
*/
if (captr->HashCollisionNextPtr)
captr->HashCollisionNextPtr->HashCollisionPrevPtr =
captr->HashCollisionPrevPtr;
}
captr->HashCollisionPrevPtr = captr->HashCollisionNextPtr = NULL;
if (Completely)
{
ListRemove (&CacheList, captr);
VmFree (captr, FI_LI);
}
}
/*****************************************************************************/
/*
Scan through the cache list. If a cache entry is currently not in use then
free the data memory associated with it. If purge completely then also remove
the entry from the list and free it's memory. If the entry is currently in use
then mark it for purge and if necessary for complete removal.
*/
void CachePurge
(
BOOL Completely,
int *PurgeCountPtr,
int *MarkedForPurgeCountPtr
)
{
int PurgeCount,
MarkedForPurgeCount;
FILE_CENTRY *captr;
LIST_ENTRY *leptr;
/*********/
/* begin */
/*********/
if (WATCH_MODULE(WATCH_MOD_CACHE))
WatchThis (WATCHALL, WATCH_MOD_CACHE,
"CachePurge() !&B", Completely);
CacheZeroCounters ();
PurgeCount = MarkedForPurgeCount = 0;
/* do it backwards! seeing they are pushed to the tail of the list */
leptr = CacheList.TailPtr;
while (leptr)
{
captr = (FILE_CENTRY*)leptr;
/* now, before stuffing around with the entry get the next one */
leptr = leptr->PrevPtr;
if (WATCH_MODULE(WATCH_MOD_CACHE) && WATCH_MODULE(WATCH_MOD__DETAIL))
WatchThis (WATCHALL, WATCH_MOD_CACHE,
"!&Z !UL !UL !&B !&B !UL",
captr->FileOds.ExpFileName,
captr->EntrySize, captr->ContentLength,
captr->EntryValid, captr->EntryRevalidating,
captr->InUseCount);
if (captr->InUseCount)
{
if (Completely)
captr->Purge = captr->PurgeCompletely = true;
else
captr->Purge = true;
MarkedForPurgeCount++;
}
else
{
if (captr->EntrySize)
{
CacheRemoveEntry (captr, Completely);
PurgeCount++;
}
}
}
if (PurgeCountPtr) *PurgeCountPtr = PurgeCount;
if (MarkedForPurgeCountPtr)
*MarkedForPurgeCountPtr = MarkedForPurgeCount;
}
/*****************************************************************************/
/*
Return a report on cache usage. This function blocks while executing.
*/
void CacheReport
(
REQUEST_STRUCT *rqptr,
BOOL IncludeEntries
)
{
static char BeginPageFao [] =
"<p><table class=\"ctgry\">\n\
<tr><td>\n\
\
<table class=\"rghtlft\">\n\
<tr><th><u>Configuration</u></th></tr>\n\
<tr><td></td></tr>\n\
<tr><th>Caching:</th>\
<td style=\"text-align:left;\" colspan=\"2\">!AZ</td></tr>\n\
<tr><th>Memory /Permanent:</th>\
<td>!UL</td><td><font size=\"-1\">kB</font></td></tr>\n\
<tr><th>/Volatile:</th>\
<td>!UL</td><td><font size=\"-1\">kB</font></td></tr>\n\
<tr><th>/Max:</th>\
<td>!UL</td><td><font size=\"-1\">kB</font></td></tr>\n\
<tr><th>Entries /Permanent:</th>\
<td>!UL</td></tr>\n\
<tr><th>/Volatile:</th>\
<td>!UL</td></tr>\n\
<tr><th>/Max:</th>\
<td>!UL</td></tr>\n\
<tr><th>/Valid:</th>\
<td>!UL</td></tr>\n\
<tr><th>/In-Use:</th>\
<td>!UL</td></tr>\n\
<tr><th>/Loading:</th>\
<td>!UL</td></tr>\n\
<tr><th>/Reclaimed:</th>\
<td>!UL</td></tr>\n\
<tr><th>Max File Size:</th>\
<td>!UL</td><td><font size=\"-1\">kB</font></td></tr>\n\
<tr><th>Guard:</th>\
<td>!UL</td><td><font size=\"-1\">seconds</font></td></tr>\n\
<tr><th>Validate:</th>\
<td>!UL</td><td><font size=\"-1\">seconds</font></td></tr>\n\
<tr><th>Frequent /Hits:</th>\
<td>!UL</td><td><font size=\"-1\">hits</font></td></tr>\n\
<tr><th>/Within:</th>\
<td>!UL</td><td><font size=\"-1\">seconds</font></td></tr>\n\
</table>\n\
\
</td><td>\n\
<table class=\"rghtlft\">\n\
<tr><th><u>Activity</u></th></tr>\n\
<tr><td></td></tr>\n\
<tr><th>Search:</th><td>!UL</td></tr>\n\
<tr><th> <u>Hash Table</u></th></tr>\n\
<tr><th>Hit:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th>Miss:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th><u>Collision</u></th></tr>\n\
<tr><th>Total:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th>Hit:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th>Miss:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th><u>Memory</u></th></tr>\n\
<tr><th>Loading:</th>\
<td>!UL</td><td>!UL <font size=\"-1\">MB</font></td>\
<tr><th>Reclaim:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th> <u>GZIP Deflate</u></th></tr>\n\
<tr><th>Count:</th><td>!UL</td></tr>\n\
<tr><th>Bytes In:</th><td colspan=\"2\">!&,@SQ</td></tr>\n\
<tr><th>Bytes Out:</th><td colspan=\"2\">!&,@SQ</td></tr>\n\
<tr><th>Ratio:</th><td>!UL%</td></tr>\n\
</table>\n\
\
</td><td>\n\
<table class=\"rghtlft\">\n\
<tr><th><u>Entries</u></th></tr>\n\
<tr><td></td></tr>\n\
<tr><th>Load:</th><td>!UL</td></tr>\n\
<tr><th>Not Hit:</th>\
<td>!UL</td><td>(!UL%)</td><td></td></tr>\n\
<tr><th> Total Hit:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th>1-9:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th>10-99:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th>100-999:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
<tr><th>>1000:</th>\
<td>!UL</td><td>(!UL%)</td></tr>\n\
</table>\n\
\
</td></tr>\n\
</table>\n\
!&@";
/* the final column just adds a little white-space on the page far right */
static char EntriesFao [] =
"<p><table class=\"lftlft\">\n\
<tr>\
<th></th>\
<th class=\"sbttl\">Flags</th>\
<th class=\"sbttl\">Size / Length</th>\
<th class=\"sbttl\">GZ Size / Len / %</th>\
<th class=\"sbttl\"><nobr>In-Use</nobr></th>\
<th class=\"sbttl\">Hash</th>\
<th class=\"sbttl\">Revised</th>\
<th class=\"sbttl\">Validated</th>\
<th class=\"sbttl\">Loaded</th>\
<th colspan=\"2\" class=\"sbttl\">Hit / 304</th>\
</tr>\n";
/* the empty 99% column just forces the rest left with long request URIs */
static char CacheFao [] =
"<tr>\
<td><b><a href=\"?entry=!16&H\">!#ZL</a></b> </td>\
<td style=\"text-align:left;\">\
!&?P\rV\r\
!&?F\r\r!&?N\r\r!&?S\r\r\
!&?C\r<strike>C</strike>\r\
!&?T\r<strike>T</strike>\r\
</td>\
<td>!UL / !UL</td>\
<td>!UL / !UL / !UL</td>\
<td>!UL</td>\
<td>!UL / !UL</td>\
<td>!&@</td>\
<td>!&@</td>\
<td>!20%D</nobr></td>\
<td>!20%D</nobr></td>\
<td>!UL / !UL</td>\
</tr>\n\
<tr class=\"hlght\"><td></td>\
<td class=\"talft maxvis\" colspan=\"10\"><tt>!AZ</tt></td>\
</tr>\n";
static char EmptyCacheFao [] =
"<tr class=\"hlght\"><th>000</th>\
<td colspan=\"10\"><i>empty</i></td><tr>\n";
static char EntriesButtonFao [] =
"</table>\n\
<p><a class=\"abttn\" href=\"!AZ\">Entries</a>\n\
!AZ\
</div>\n\
</body>\n\
</html>\n";
static char EndPageFao [] =
"</table>\n\
!AZ\
</div>\n\
</body>\n\
</html>\n";
int cnt,
status,
Count,
GzipDeflatePercent,
HashCollisionListLength,
InUseEntryCount,
LoadingEntryCount,
ReclaimedEntryCount,
ValidEntryCount;
unsigned long FaoVector [64];
unsigned long *vecptr;
char *cptr, *sptr,
*LastColPtr;
FILE_CENTRY *captr;
LIST_ENTRY *leptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE, "CacheReport()");
InUseEntryCount = LoadingEntryCount =
ReclaimedEntryCount = ValidEntryCount = 0;
for (leptr = CacheList.HeadPtr; leptr; leptr = leptr->NextPtr)
{
captr = (FILE_CENTRY*)leptr;
if (captr->EntryValid) ValidEntryCount++;
if (captr->EntryReclaimed) ReclaimedEntryCount++;
if (captr->InUseCount) InUseEntryCount++;
if (captr->DataLoading) LoadingEntryCount++;
}
AdminPageTitle (rqptr, "Cache Report");
vecptr = FaoVector;
if (CacheEnabled)
*vecptr++ = "[enabled]";
else
*vecptr++ = "<font color=\"#ff000\">[disabled]</font>";
*vecptr++ = CachePermMemoryInUse >> 10;
*vecptr++ = CacheMemoryInUse >> 10;
*vecptr++ = CacheTotalKBytesMax;
*vecptr++ = CachePermEntryCount;
*vecptr++ = CacheEntryCount;
*vecptr++ = CacheEntriesMax;
*vecptr++ = ValidEntryCount;
*vecptr++ = InUseEntryCount;
*vecptr++ = LoadingEntryCount;
*vecptr++ = ReclaimedEntryCount;
*vecptr++ = CacheEntryKBytesMax;
*vecptr++ = CacheGuardSeconds;
*vecptr++ = CacheValidateSeconds;
*vecptr++ = CacheFrequentHits;
*vecptr++ = CacheFrequentSeconds;
*vecptr++ = CacheHashTableCount;
*vecptr++ = CacheHashTableHitCount;
if (CacheHashTableCount)
*vecptr++ = CacheHashTableHitCount * 100 / CacheHashTableCount;
else
*vecptr++ = 0;
*vecptr++ = CacheHashTableMissCount;
if (CacheHashTableCount)
*vecptr++ = CacheHashTableMissCount * 100 / CacheHashTableCount;
else
*vecptr++ = 0;
*vecptr++ = CacheHashTableCollsnCount;
if (CacheHashTableCount)
*vecptr++ = CacheHashTableCollsnCount * 100 / CacheHashTableCount;
else
*vecptr++ = 0;
*vecptr++ = CacheHashTableCollsnHitCount;
if (CacheHashTableCount)
*vecptr++ = CacheHashTableCollsnHitCount * 100 / CacheHashTableCount;
else
*vecptr++ = 0;
*vecptr++ = CacheHashTableCollsnMissCount;
if (CacheHashTableCount)
*vecptr++ = CacheHashTableCollsnMissCount * 100 / CacheHashTableCount;
else
*vecptr++ = 0;
*vecptr++ = CacheCurrentlyLoading;
*vecptr++ = CacheCurrentlyLoadingInUse >> 10;
*vecptr++ = CacheReclaimCount;
if (CacheLoadCount)
*vecptr++ = CacheReclaimCount * 100 / CacheLoadCount;
else
*vecptr++ = 0;
*vecptr++ = CacheGzipDeflateCount;
*vecptr++ = &CacheGzipDeflateBytesIn64;
*vecptr++ = &CacheGzipDeflateBytesOut64;
*vecptr++ = PercentOf64 (&CacheGzipDeflateBytesOut64,
&CacheGzipDeflateBytesIn64);
*vecptr++ = CacheLoadCount;
*vecptr++ = CacheHits0;
*vecptr++ = PercentOf32(CacheHits0,CacheLoadCount);
*vecptr++ = CacheHitCount;
*vecptr++ = PercentOf32(CacheHitCount,CacheLoadCount);
*vecptr++ = CacheHits10;
*vecptr++ = PercentOf32(CacheHits10,CacheLoadCount);
*vecptr++ = CacheHits100;
*vecptr++ = PercentOf32(CacheHits100,CacheLoadCount);
*vecptr++ = CacheHits1000;
*vecptr++ = PercentOf32(CacheHits1000,CacheLoadCount);
*vecptr++ = CacheHits1000plus;
*vecptr++ = PercentOf32(CacheHits1000plus,CacheLoadCount);
if (CacheEnabled && !IncludeEntries)
{
*vecptr++ = EntriesButtonFao;
*vecptr++ = ADMIN_REPORT_CACHE_ENTRIES;
*vecptr++ = AdminRefresh();
}
else
*vecptr++ = "";
status = FaolToNet (rqptr, BeginPageFao, &FaoVector);
if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI);
if (!CacheEnabled || !IncludeEntries)
{
rqptr->rqResponse.PreExpired = PRE_EXPIRE_ADMIN;
ResponseHeader200 (rqptr, "text/html", &rqptr->NetWriteBufferDsc);
AdminEnd (rqptr);
return;
}
/*****************/
/* cache entries */
/*****************/
status = FaolToNet (rqptr, EntriesFao, NULL);
if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI);
Count = 0;
if (WATCHPNT(rqptr) &&
WATCH_MODULE(WATCH_MOD_CACHE) && WATCH_MODULE(WATCH_MOD__DETAIL))
WatchThis (WATCHALL, WATCH_MOD_CACHE, "!&X !&X",
CacheList.HeadPtr, CacheList.TailPtr);
/* process the cache entry list from most to least recently hit */
for (leptr = CacheList.HeadPtr; leptr; leptr = leptr->NextPtr)
{
captr = (FILE_CENTRY*)leptr;
if (WATCHPNT(rqptr) &&
WATCH_MODULE(WATCH_MOD_CACHE) && WATCH_MODULE(WATCH_MOD__DETAIL))
WatchThis (WATCHALL, WATCH_MOD_CACHE, "!&X<-!&X->!&X !&X",
leptr->PrevPtr, leptr, leptr->NextPtr, captr);
HashCollisionListLength = 0;
/* count further down the list */
while (captr->HashCollisionNextPtr)
{
captr = captr->HashCollisionNextPtr;
HashCollisionListLength++;
}
captr = (FILE_CENTRY*)leptr;
/* count further up the list */
while (captr->HashCollisionPrevPtr)
{
captr = captr->HashCollisionPrevPtr;
HashCollisionListLength++;
}
captr = (FILE_CENTRY*)leptr;
vecptr = FaoVector;
*vecptr++ = &captr->Md5Hash;
if (CacheEntriesMax >= 10000)
*vecptr++ = 5;
else
if (CacheEntriesMax >= 1000)
*vecptr++ = 4;
else
*vecptr++ = 3;
*vecptr++ = ++Count;
*vecptr++ = captr->EntryPermanent;
*vecptr++ = captr->FromFile;
*vecptr++ = captr->FromNet;
*vecptr++ = captr->FromScript;
*vecptr++ = captr->CgiHeaderLength;
*vecptr++ = captr->ContentType[0];
*vecptr++ = captr->EntrySize;
*vecptr++ = captr->ContentLength;
*vecptr++ = captr->GzipEntrySize;
*vecptr++ = captr->GzipContentLength;
*vecptr++ = PercentOf32(captr->GzipContentLength,captr->ContentLength);
*vecptr++ = captr->InUseCount;
/* 12 bit hash value, 0..4095 from a fixed 3 bytes of the MD5 hash */
*vecptr++ = captr->Md5Hash.HashLong[0] & 0xfff;
*vecptr++ = HashCollisionListLength;
if (captr->FromFile)
{
*vecptr++ = "!20%D";
*vecptr++ = &captr->RdtTime64;
}
else
*vecptr++ = "n/a";
if (captr->FromFile &&
captr->EntryValid)
{
*vecptr++ = "!20%D !UL";
*vecptr++ = &captr->ValidateTime64;
*vecptr++ = captr->ValidatedCount;
}
else
{
if (captr->EntryReclaimed)
*vecptr++ = "RECLAIMED";
else
if (!captr->EntryValid)
*vecptr++ = "INVALID";
else
if (!captr->FromFile)
*vecptr++ = "n/a";
else
*vecptr++ = "?";
}
*vecptr++ = &captr->LoadTime64;
*vecptr++ = &captr->HitTime64;
*vecptr++ = captr->HitCount;
*vecptr++ = captr->HitNotModifiedCount;
*vecptr++ = captr->FileOds.ExpFileName;
status = FaolToNet (rqptr, CacheFao, &FaoVector);
if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI);
}
if (!CacheList.HeadPtr)
{
status = FaolToNet (rqptr, EmptyCacheFao, NULL);
if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI);
}
vecptr = FaoVector;
*vecptr++ = AdminRefresh();
status = FaolToNet (rqptr, EndPageFao, &FaoVector);
if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI);
rqptr->rqResponse.PreExpired = PRE_EXPIRE_ADMIN;
ResponseHeader200 (rqptr, "text/html", &rqptr->NetWriteBufferDsc);
AdminEnd (rqptr);
}
/*****************************************************************************/
/*
Return a report on a single cache entry.
*/
void CacheReportEntry
(
REQUEST_STRUCT *rqptr,
char *Md5HashHexString
)
{
static char BeginPageFao [] =
"<p><table class=\"ctgry\">\n\
<tr><td>\n\
<table class=\"rghtlft\">\n\
<tr><th>Resource:</th>\
<td style=\"text-align:left;\"><nobr>!&;AZ</nobr></td></tr>\n\
<tr><th>Entity Tag:</th>\
<td style=\"text-align:left;\">!AZ</td></tr>\n\
<tr><th>Flags:</th><td style=\"text-align:left;\">\
!&?Permanent\rVolatile\r, \
!&?File\r\r!&?Network\r\r!&?Script\r\r, \
!&?CGI-fields\r<strike>CGI-fields</strike>\r, \
!&?Content-Type\r<strike>Content-Type</strike>\r, \
<tr><th>Size:</th><td style=\"text-align:left;\">!UL byte!%s</td></tr>\n\
<tr><th>Length:</th><td style=\"text-align:left;\">!UL byte!%s</td></tr>\n\
<tr><th>GZIP Size:</th><td style=\"text-align:left;\">!UL byte!%s</td></tr>\n\
<tr><th>GZIP Length:</th>\
<td style=\"text-align:left;\">!UL byte!%s (!UL%)</td></tr>\n\
<tr><th>CGI Fields:</th>\
<td style=\"text-align:left;\">!UL byte!%s</td></tr>\n\
<tr><th>Content-Type:</th><td style=\"text-align:left;\">!&;AZ</td></tr>\n\
<tr><th><nobr>In-Use:</nobr></th><td style=\"text-align:left;\">!UL</td></tr>\n\
<tr><th><nobr>Hash/Idx/Colsn:</nobr></th>\
<td style=\"text-align:left;\">!16&H / !UL / !UL</td></tr>\n\
<tr><th>Revised:</th><td style=\"text-align:left;\">!&@</td></tr>\n\
<tr><th>Validated:</th><td style=\"text-align:left;\">!&@</td></tr>\n\
<tr><th>Loaded:</th><td style=\"text-align:left;\">!20%D</td></tr>\n\
<tr><th>Hit:</th>\
<td style=\"text-align:left;\">!20%D, !UL time!%s, 304 response !UL time!%s</td></tr>\n\
</table>\n\
</td></tr>\n\
</table>\n\
<p><pre>";
int idx, status,
ItemCount,
HashCollisionListLength;
unsigned long FaoVector [64];
unsigned long *vecptr;
char *cptr;
MD5_HASH Md5Hash;
FILE_CENTRY *captr;
LIST_ENTRY *leptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"CacheReportEntry() !&Z", Md5HashHexString);
/* convert hex string back into binary hash */
cptr = Md5HashHexString;
for (idx = 0; idx < sizeof(Md5Hash); idx++)
{
if (*cptr >= '0' && *cptr <= '9')
Md5Hash.HashChar[idx] = (*cptr - '0') << 4;
else
if (TOUP(*cptr) >= 'A' && TOUP(*cptr) <= 'F')
Md5Hash.HashChar[idx] = (*cptr - '7') << 4;
if (*cptr) cptr++;
if (*cptr >= '0' && *cptr <= '9')
Md5Hash.HashChar[idx] |= (*cptr - '0') & 0xf;
else
if (TOUP(*cptr) >= 'A' && TOUP(*cptr) <= 'F')
Md5Hash.HashChar[idx] |= (*cptr - '7') & 0xf;
if (*cptr) cptr++;
}
captr = NULL;
ItemCount = 0;
for (leptr = CacheList.HeadPtr; leptr; leptr = leptr->NextPtr)
{
captr = (FILE_CENTRY*)leptr;
if (!MATCH0 (&captr->Md5Hash, &Md5Hash, sizeof(Md5Hash))) continue;
break;
}
if (!leptr)
{
rqptr->rqResponse.HttpStatus = 400;
ErrorGeneral (rqptr, "Entry not found.", FI_LI);
AdminEnd (rqptr);
return;
}
AdminPageTitle (rqptr, "Cache Entry Report");
HashCollisionListLength = 0;
/* count further down the list */
while (captr->HashCollisionNextPtr)
{
captr = captr->HashCollisionNextPtr;
HashCollisionListLength++;
}
captr = (FILE_CENTRY*)leptr;
/* count further up the list */
while (captr->HashCollisionPrevPtr)
{
captr = captr->HashCollisionPrevPtr;
HashCollisionListLength++;
}
captr = (FILE_CENTRY*)leptr;
vecptr = FaoVector;
*vecptr++ = captr->FileOds.ExpFileName;
*vecptr++ = captr->EntityTag;
*vecptr++ = captr->EntryPermanent;
*vecptr++ = captr->FromFile;
*vecptr++ = captr->FromNet;
*vecptr++ = captr->FromScript;
*vecptr++ = captr->CgiHeaderLength;
*vecptr++ = captr->ContentType[0];
*vecptr++ = captr->EntrySize;
*vecptr++ = captr->ContentLength;
*vecptr++ = captr->GzipEntrySize;
*vecptr++ = captr->GzipContentLength;
*vecptr++ = PercentOf32(captr->GzipContentLength,captr->ContentLength);
*vecptr++ = captr->CgiHeaderLength;
if (captr->ContentType[0])
*vecptr++ = captr->ContentType;
else
*vecptr++ = "n/a";
*vecptr++ = captr->InUseCount;
*vecptr++ = &captr->Md5Hash.HashLong;
/* 12 bit hash value, 0..4095 from a fixed 3 bytes of the MD5 hash */
*vecptr++ = captr->Md5Hash.HashLong[0] & 0xfff;
*vecptr++ = HashCollisionListLength;
if (captr->FromFile)
{
*vecptr++ = "!20%D";
*vecptr++ = &captr->RdtTime64;
}
else
*vecptr++ = "n/a";
if (captr->FromFile &&
captr->EntryValid)
{
*vecptr++ = "!20%D, !UL time!%s";
*vecptr++ = &captr->ValidateTime64;
*vecptr++ = captr->ValidatedCount;
}
else
{
if (captr->EntryReclaimed)
*vecptr++ = "RECLAIMED";
else
if (!captr->EntryValid)
*vecptr++ = "INVALID";
else
if (!captr->FromFile)
*vecptr++ = "n/a";
else
*vecptr++ = "?";
}
*vecptr++ = &captr->LoadTime64;
*vecptr++ = &captr->HitTime64;
*vecptr++ = captr->HitCount;
*vecptr++ = captr->HitNotModifiedCount;
status = FaolToNet (rqptr, BeginPageFao, &FaoVector);
if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI);
vecptr = FaoVector;
if (captr->ContentPtr)
{
CacheDumpData (rqptr, captr->ContentPtr, captr->ContentLength);
NetWriteBuffered (rqptr, NULL,
"<hr size=\"1\" noshade width=\"60%\" align=\"left\">", -1);
}
if (captr->GzipContentPtr)
{
CacheDumpData (rqptr, captr->GzipContentPtr, captr->GzipContentLength);
NetWriteBuffered (rqptr, NULL,
"<hr size=\"1\" noshade width=\"60%\" align=\"left\">", -1);
}
NetWriteBuffered (rqptr, NULL, "</pre>\n</body>\n</html>\n", -1);
rqptr->rqResponse.PreExpired = PRE_EXPIRE_ADMIN;
ResponseHeader200 (rqptr, "text/html", &rqptr->NetWriteBufferDsc);
AdminEnd (rqptr);
}
/*****************************************************************************/
/*
Dump data a la WATCH.
*/
CacheDumpData
(
REQUEST_STRUCT *rqptr,
char *DataPtr,
int DataLength
)
{
/* 32 bytes by 128 lines comes out to 4096 bytes, the default buffer-full */
#define MAX_LINES 128
#define BYTES_PER_LINE 32
#define BYTES_PER_GROUP 4
#define GROUPS_PER_LINE (BYTES_PER_LINE / BYTES_PER_GROUP)
#define CHARS_PER_LINE ((BYTES_PER_LINE * 3) + GROUPS_PER_LINE + 1)
#define HTML_ESCAPE_SPACE 1024
static char HexDigits [] = "0123456789ABCDEF";
static char Woops [] = "ERROR: Buffer overflow!";
int ByteCount,
CurrentDataCount,
DataCount;
char *cptr, *sptr, *zptr,
*CurrentDataPtr,
*CurrentDumpPtr;
char DumpBuffer [(CHARS_PER_LINE * MAX_LINES)+HTML_ESCAPE_SPACE+1];
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_CACHE))
WatchThis (WATCHITM(rqptr), WATCH_MOD_CACHE,
"CacheDumpData() !&A !UL", DataPtr, DataLength);
if (!DataPtr) return;
zptr = (sptr = DumpBuffer) + sizeof(DumpBuffer)-1;
cptr = DataPtr;
DataCount = DataLength;
while (DataCount)
{
CurrentDumpPtr = sptr;
CurrentDataPtr = cptr;
CurrentDataCount = DataCount;
ByteCount = BYTES_PER_LINE;
while (ByteCount && DataCount)
{
if (sptr < zptr) *sptr++ = HexDigits[*(unsigned char*)cptr >> 4];
if (sptr < zptr) *sptr++ = HexDigits[*(unsigned char*)cptr & 0xf];
cptr++;
DataCount--;
ByteCount--;
if (!(ByteCount % BYTES_PER_GROUP) && sptr < zptr) *sptr++ = ' ';
}
while (ByteCount)
{
if (sptr < zptr) *sptr++ = ' ';
if (sptr < zptr) *sptr++ = ' ';
ByteCount--;
if (!(ByteCount % BYTES_PER_GROUP) && sptr < zptr) *sptr++ = ' ';
}
cptr = CurrentDataPtr;
DataCount = CurrentDataCount;
ByteCount = BYTES_PER_LINE;
while (ByteCount && DataCount)
{
if (isalnum(*cptr) || ispunct(*cptr) || *cptr == ' ')
{
if (*cptr == '<')
{
if (sptr < zptr) *sptr++ = '&';
if (sptr < zptr) *sptr++ = 'l';
if (sptr < zptr) *sptr++ = 't';
if (sptr < zptr) *sptr++ = ';';
cptr++;
}
else
if (*cptr == '&')
{
if (sptr < zptr) *sptr++ = '&';
if (sptr < zptr) *sptr++ = 'a';
if (sptr < zptr) *sptr++ = 'm';
if (sptr < zptr) *sptr++ = 'p';
if (sptr < zptr) *sptr++ = ';';
cptr++;
}
else
{
if (sptr < zptr) *sptr++ = *cptr;
cptr++;
}
}
else
{
if (sptr < zptr) *sptr++ = '.';
cptr++;
}
DataCount--;
ByteCount--;
}
/* ensure there is a right margin using a couple of spaces */
if (sptr < zptr) *sptr++ = ' ';
if (sptr < zptr) *sptr++ = ' ';
if (sptr < zptr) *sptr++ = '\n';
if (sptr >= zptr)
{
NetWriteBuffered (rqptr, NULL, Woops, sizeof(Woops)-1);
return;
}
if (!DataCount || !ByteCount)
{
*sptr = '\0';
NetWriteBuffered (rqptr, NULL, DumpBuffer, sptr - DumpBuffer);
zptr = (sptr = DumpBuffer) + sizeof(DumpBuffer)-1;
}
}
}
/*****************************************************************************/