[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]
/*****************************************************************************/
#ifdef COMMENTS_WITH_COMMENTS
/*
rawLIB.c
Collection of routines for WASD persistent RawSocket applications (CGIplus
scripts). Could have named it RSLIB (raw socket library) but RS means
different things to different people :-}
A "raw" socket is a variant of, and is heavily based on, the WASD WebSocket
infrastructure. It allows a service (listening host and port) to accept a
connection and immediately activate a configured WASD CGIplus script (in much
the same manner as a standard WebSocket script) to service that connection.
Full-duplex, asynchronous, bidirectional input/output is supported. While
being referred to as a "socket", and in the module as a "RawSocket", it of
course is not [BSD or any other abstraction] network socket communication, but
a read/write abstraction via mailbox I/O. Input is a stream of octets; output
a stream of octets. To these routines the streams are opaque. The "RawSocket"
is just WASD nomenclature for WebSocket-style scripting without the WebSocket
protocol.
These routines allow AST-driven, multi-client RawSocket applications. These
are *much* less complex than those in wsLIB as there is no protocol implemented
and no message/frame queue.
RAWSOCKET BASICS
----------------
The script when activated enters a CGIplus wait-service-wait loop using the
standard CGIplus mechanism. When a request activates the script it issues a
"100 Continue" CGI/HTTP header to signal the server that the request is being
processed. This header is NOT relayed to the client. The request parameters
are available via the usual CGI variables. The script can then read and write
to/from the RAWSOCKET_INPUT and RAWSOCKET_OUTPUT devices respectively. The
end-of-script is indicated using the same WebSocket EOF to the mailbox. The
script activation can be a long-lived as required and the server will not run a
request down for any timeout reason.
REQUEST SYNCHRONISATION
-----------------------
rawLIB start-of-request synchronisation is based on the wait-process-EOF-wait
loop model used by CGIlib, where RawLibCgiVar("") or RawLibCgiVarNull("") are
used to wait and continue when a new request is available. The example raw
[web]socket scripts use this approach by default. rawLIB also provides an
AST-driven model.
The RawLibOnNextRequest() function should be called once during script
initialisation specifying the address of the function to be notified of a new
request. At that point the CGI variables become available and remain so until
the script issues the CGIplus EOF sentinal, and the RawLibCgiVar..() family of
functions can be used to retrieve the CGI variable values. This asynchronous
and the synchronous RawLibCgiVar("") approaches to request synchronisation are
mutually exclusive and once one is used using the other results in a bugcheck.
CGI VARIABLES
-------------
CGI variables using the RawLibCgiVar..() functions are only available after the
next request has been indicated and before the CGIplus EOF sentinal is
signalled. Any that are required for further processing need to be copied into
separate storage from the pointer returned by the RawLibCgiVar..() functions.
With the request synchronisation provided by RawLibCgiVar("") this is usually
obvious enough. With the AST-driven request synchronisation provided by
RawLibOnNextRequest() it might be less obvious. In any case the
RawLibCgiVarAvailable() function can be used to test whether CGI variable are
available at that time or not.
FUNCTIONS
---------
struct RawLibStruct* RawLibCreate (void *UserDataPtr,
void *DestroyFunction)
Allocates a RawSocket structure, sets the user data pointer
to the supplied address, and returns a pointer to the new structure.
All subsequent associated websocket processing requires that pointer.
struct RawLibStruct* RawLibNext (struct RawLibStruct **RawLibCtx)
Step through the list of structures. RawLibCtx is the address of pointer to
RawLibStruct used to hold the context. Set to NULL to initialise. Returns
non-null pointers for each structure in the list, then NULL when exhausted.
Care must be exercised that multiple calls are not preempted by list
modification (i.e. use within AST delivery or with ASTs disabled).
int RawLibMsgDsc (struct RawLibStruct *rawptr,
struct dsc$descriptor_s *MsgDsc);
Sets the supplied descriptor to the latest error string.
int RawLibMsgLineNumber (struct RawLibStruct *rawptr)
Return the wsLIB source code line at which the last message occured.
char* RawLibMsgString (struct RawLibStruct *rawptr)
Returns a pointer to the latest error string.
int RawLibOpen (struct RawLibStruct *rawptr,
void *AstFunction)
Using the device names from the CGI variables RAWSOCKET_INPUT and
RAWSOCKET_OUTPUT assign channels in preparation for asynchronous I/O.
The AST function is called at RawSocket close.
int RawLibClose (struct RawLibStruct* rawptr)
Shut the RawSocket down.
int RawLibIsClosed (struct RawLibStruct* rawptr)
Return true if the RawSocket has been closed.
int RawLibConnected (struct RawLibStruct *rawptr)
Return true if the input/output channels are connected.
int RawLibRead (struct RawLibStruct *rawptr,
char *DataPtr,
int DataSize,
void *AstFunction)
Read data from the RawSocket into the supplied buffer.
Function is non-blocking if AST function is supplied, otherwise blocking.
The buffer must continue to exist until the read completes.
When the read completes the status can be returned by RawLibReadStatus(),
the read count by RawLibReadCount(), a pointer to the data buffer using
RawLibReadData(), and a pointer to the internal read string descriptor
using RawLibReadDataDsc().
int RawLibReadDsc (struct RawLibStruct *rawptr,
struct dsc$descriptor_s *DataDsc,
void *AstFunction)
Read data from the websocket into the buffer described by DataDsc.
Function is non-blocking if AST function is supplied, otherwise blocking.
When completed ReadDsc (if supplied) is modified to reflect the read.
int RawLibReadStatus (struct RawLibStruct *rawptr)
Return the status value of the most recent read.
int RawLibReadCount (struct RawLibStruct *rawptr)
Return the number of bytes in the most recent read.
char* RawLibReadData (struct RawLibStruct *rawptr)
Return a pointer to char of the most recent read buffer.
struct dsc$descriptor_s* RawLibReadDataDsc (struct RawLibStruct *rawptr)
Return a pointer to the internal descriptor for the most recent read.
ulong* RawLibReadTotal (struct RawLibStruct *rawptr)
Return a pointer to a quadword containing the total number of bytes read.
void RawLibResetMsg (struct RawLibStruct *rawptr)
Reset the latest message data.
unsigned int RawLibTime ();
Return the current wsLIB time in seconds (i.e. C-RTL, Unix time).
int RawLibWrite (struct RawLibStruct *rawptr,
char *DataPtr,
int DataCount,
void *AstFunction)
Write the supplied data to the websocket.
Function is non-blocking if AST function is supplied, otherwise blocking.
The data must continue to exist until the write completes.
int RawLibWriteDsc (struct RawLibStruct *rawptr,
struct dsc$descriptor_s *DataDsc,
void *AstFunction)
Write the data supplied by the descriptor to the websocket.
Function is non-blocking if AST function is supplied, otherwise blocking.
int RawLibWriteStatus (struct RawLibStruct *rawptr)
Return the status value of the most recent write.
int RawLibWriteCount (struct RawLibStruct *rawptr)
Return the number of bytes in the most recent write.
struct dsc$descriptor_s* RawLibWriteDataDsc (struct RawLibStruct *rawptr)
Return a pointer to the internal descriptor for the most recent write.
ulong* RawLibWriteTotal (struct RawLibStruct *rawptr)
Return a pointer to a quadword containing the total number of bytes written.
void RawLibSetUserData (struct RawLibStruct *rawptr,
void *UserDataPtr)
Set the RawSocket structure to point to the supplied user data.
void* RawLibGetUserData (struct RawLibStruct *rawptr)
Return the current pointer to the supplied user data.
void* RawLibSetCallout (struct RawLibStruct *rawptr,
void *AstFunction)
Set/reset the callout response AST.
Returns the previous callout pointer.
void* RawLibSetMsgCallback (struct RawLibStruct *rawptr,
void *CallbackFunction)
Set/reset the rawLIB error reporting callback.
Returns the previous callback pointer.
The error callback function is activated with a pointer to the RawLib
data structure that has the MsgLineNumber and timestamp set and
provides a descriptive string.
void RawLibSetIdleSecs (struct RawLibStruct *rawptr,
int IdleSecs);
Set number of seconds before a RawSocket is considered idle and closed.
If a RawSocket is not specified then set global value.
void RawLibSetLifeSecs (int LifeSecs);
Set number of seconds before the application is considered idle and exited.
void RawLibSetReadSecs (struct RawLibStruct *rawptr,
int IdleSecs);
Set number of seconds to wait for a read from a RawSocket before close.
If a RawSocket is not specified then set global value.
void* RawLibSetWakeCallback (struct RawLibStruct *rawptr,
void *CallbackFunction,
int WakesSecs)
Set/reset the wsLIB periodic wakeup callback.
Returns the previous callback pointer.
Set the number of seconds between wakeup calls (zero defaults).
void RawLibWatchScript (struct RawLibStruct *rawptr,
char *SourceModuleName,
int SourceLineNumber,
char *FormatString,
...)
Outputs the $FAO-formatted string to the WASD WATCH [x]Script item.
COPYRIGHT
---------
Copyright (C) 2016-2020 Mark G.Daniel
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
VERSION HISTORY
---------------
01-DEC-2016 MGD initial (heavily based on wsLIB)
*/
#endif /* COMMENTS_WITH_COMMENTS */
/*****************************************************************************/
#define SOFTWAREVN "1.0.0"
#define SOFTWARENM "RAWLIB"
#ifdef __ALPHA
# define SOFTWAREID SOFTWARENM " AXP-" SOFTWAREVN
#endif
#ifdef __ia64
# define SOFTWAREID SOFTWARENM " IA64-" SOFTWAREVN
#endif
#ifdef __VAX
# define SOFTWAREID SOFTWARENM " VAX-" SOFTWAREVN
#endif
#ifdef __x86_64
# define SOFTWAREID SOFTWARENM " X86-" SOFTWAREVN
#endif
#include <stdarg.h>
#include <ctype.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <descrip.h>
#include <iodef.h>
#include <lib$routines.h>
#include <ssdef.h>
#include <starlet.h>
#include <stsdef.h>
#include <unixlib.h>
#include "rawlib.h"
/* from libmsg.h */
#define LIB$_INVSTRDES 1409572
#ifndef EFN$C_ENF
# define EFN$C_ENF 128 /* Event No Flag (no stored state) */
#endif
#define AGN$M_READONLY 0x01
#define AGN$M_WRITEONLY 0x02
#define VMSok(x) ((x) & STS$M_SUCCESS)
#define VMSnok(x) !(((x) & STS$M_SUCCESS))
#define RAWLIB_STRUCT_BUFFER_SIZE 4096
#define FI_LI "RAWLIB", __LINE__
#if 1
#define WATCH_RAWLIB if(rawptr->WatchScript)RawLibWatchScript
#else
#define WATCH_RAWLIB if(0)RawLibWatchScript
#endif
/* used by RAWLIBCL.C */
static int EfnWait,
EfnNoWait;
static int CalloutDone = 0,
CgiPlusEofLength = 0,
CgiPlusEotLength = 0,
CgiPlusEscLength = 0,
CgiVariablesAvailable = 0,
StructBufferLength = 0,
StructBufferSize = 0,
WwwPrefix = 0;
static ushort CgiPlusInChannel;
static ulong CurrentTime,
WatchDogWakeTime;
static ulong CurrentBinTime [2];
#define DEFAULT_WATCHDOG_IDLE_SECS 120
#define DEFAULT_WATCHDOG_LIFE_SECS 120
#define DEFAULT_WATCHDOG_READ_SECS 60
#define DEFAULT_WATCHDOG_WAKE_SECS 60
static ulong WatchDogIdleSecs = DEFAULT_WATCHDOG_IDLE_SECS,
WatchDogLifeSecs = DEFAULT_WATCHDOG_LIFE_SECS,
WatchDogReadSecs = DEFAULT_WATCHDOG_READ_SECS,
WatchDogWakeSecs = DEFAULT_WATCHDOG_WAKE_SECS;
static char *CgiPlusEofPtr = NULL,
*CgiPlusEotPtr = NULL,
*CgiPlusEscPtr = NULL,
*NextVarNamePtr = NULL,
*StructBufferPtr = NULL;
static struct RawLibStruct *ListHead;
static void (*RequestSynchronisation)() = NULL,
(*WakeCallbackFunction)() = NULL;
static char SoftwareID [] = SOFTWAREID;
#define SYI$_VERSION 4096
int sys$getsyi(__unknown_params);
/***
#define __VAX
#undef __ALPHA
***/
/*****************************************************************************/
/*
Initialise the library.
*/
void RawLibInit ()
{
static char GetSyiVer [8];
static struct
{
ushort buf_len;
ushort item;
void *buf_addr;
void *ret_len;
} SyiItem [] =
{
{ sizeof(GetSyiVer)-1, SYI$_VERSION, &GetSyiVer, 0 },
{ 0,0,0,0 }
};
int status,
VersionInteger;
/*********/
/* begin */
/*********/
/* just the once! */
if (EfnWait) return;
status = sys$getsyiw (0, 0, 0, &SyiItem, 0, 0, 0);
if (VMSnok (status)) RawLibExit (NULL, FI_LI, status);
VersionInteger = ((GetSyiVer[1]-48) * 100) + ((GetSyiVer[3]-48) * 10);
if (GetSyiVer[4] == '-') VersionInteger += GetSyiVer[5]-48;
if (VersionInteger >= 700)
EfnWait = EfnNoWait = EFN$C_ENF;
else
{
if (VMSnok (status = lib$get_ef (&EfnWait)))
RawLibExit (NULL, FI_LI, status);;
if (VMSnok (status = lib$get_ef (&EfnNoWait)))
RawLibExit (NULL, FI_LI, status);;
}
WatchDog ();
}
/*****************************************************************************/
/*
Return a pointer to the wsLIB version string.
*/
char* RawLibVersion ()
{
/*********/
/* begin */
/*********/
return (SoftwareID);
}
/*****************************************************************************/
/*
Sanity check the incoming request. Provide error or continue/upgrade response.
Allocate a RawSocket I/O structure and set the internal user data storage.
Insert at the head of the list. Return a pointer to the allocated structure.
Can only WATCH_RAWLIB after RawLibOpen().
*/
struct RawLibStruct* RawLibCreate
(
void *UserDataPtr,
void *DestroyFunction
)
{
int astatus,
SecRawSocketVersion;
char *cptr, *sptr;
struct RawLibStruct *rawptr;
/*********/
/* begin */
/*********/
if (!EfnWait) RawLibInit ();
astatus = sys$setast (0);
rawptr = (struct RawLibStruct*) calloc (1, sizeof(struct RawLibStruct));
if (!rawptr) RawLibExit (NULL, FI_LI, vaxc$errno);
if ((cptr = getenv ("WASD_RAWLIB_WATCH_LOG")) != NULL)
if ((rawptr->WatchLog = fopen (cptr, "w", "shr=get")) == NULL)
RawLibExit (NULL, FI_LI, vaxc$errno);
if (cptr = RawLibCgiVarNull("RAWSOCKET_INPUT_MRS"))
rawptr->InputMrs = atoi(cptr);
else
RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
if (cptr = RawLibCgiVarNull("RAWSOCKET_OUTPUT_MRS"))
rawptr->OutputMrs = atoi(cptr);
else
RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
/* connection acceptance response */
fprintf (stdout, "Status: 101 Switching Protocols\r\n\r\n");
fflush (stdout);
rawptr->UserDataPtr = UserDataPtr;
rawptr->DestroyAstFunction = DestroyFunction;
rawptr->NextPtr = ListHead;
ListHead = rawptr;
if (astatus == SS$_WASSET) sys$setast (1);
return (rawptr);
}
/*****************************************************************************/
/*
Remove from the list and free the allocated memory. Return any user data.
*/
static void Destroy (struct RawLibStruct *rawptr)
{
int astatus, cnt, status;
struct RawLibStruct *wslptr;
void *UserDataPtr;
FILE *WatchLog;
/*********/
/* begin */
/*********/
if (!rawptr) return;
WATCH_RAWLIB (rawptr, FI_LI, "DESTROY");
WatchLog = rawptr->WatchLog;
astatus = sys$setast (0);
UserDataPtr = rawptr->UserDataPtr;
if (rawptr->MsgStringSize) free (rawptr->MsgStringPtr);
if ((wslptr = ListHead) == rawptr)
ListHead = wslptr->NextPtr;
else
{
while (wslptr->NextPtr != rawptr) wslptr = wslptr->NextPtr;
wslptr->NextPtr = rawptr->NextPtr;
}
sys$dassgn (rawptr->OutputChannel);
free (rawptr);
if (astatus == SS$_WASSET) sys$setast (1);
if (WatchLog) fclose (WatchLog);
}
/*****************************************************************************/
/*
Step through the list of structures. RawLibCtx is the address of a pointer
used to hold the context. Set to NULL to initialise. Returns non-null
pointers for each structure in the list, then NULL when list exhausted, to
begin non-null pointers again. Care must be exercised that multiple calls are
not preempted by a list modification (i.e. use within AST delivery or with ASTs
disabled).
*/
struct RawLibStruct* RawLibNext (struct RawLibStruct **RawLibCtx)
{
int astatus;
struct RawLibStruct *rawptr, *wslptr;
/*********/
/* begin */
/*********/
astatus = sys$setast (0);
/* let's be overcautious and make sure it's still in the list! */
if (rawptr = *RawLibCtx)
{
for (wslptr = ListHead; wslptr; wslptr = wslptr->NextPtr)
if (wslptr == rawptr) break;
if (!wslptr) RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
*RawLibCtx = rawptr->NextPtr;
}
else
*RawLibCtx = ListHead;
if (astatus == SS$_WASSET) sys$setast (1);
return (*RawLibCtx);
}
/*****************************************************************************/
/*
Using the device names from the CGI variables RAWSOCKET_INPUT and
RAWSOCKET_OUTPUT assign channels in preparation for asynchronous I/O.
*/
int RawLibOpen (struct RawLibStruct *rawptr)
{
int status;
char *cptr, *sptr, *zptr;
$DESCRIPTOR (MbxDsc, "");
/*********/
/* begin */
/*********/
rawptr->ReadDataDsc.dsc$b_class =
rawptr->ReadResultDsc.dsc$b_class =
rawptr->WriteDataDsc.dsc$b_class = DSC$K_CLASS_S;
rawptr->ReadDataDsc.dsc$b_dtype =
rawptr->ReadResultDsc.dsc$b_dtype =
rawptr->WriteDataDsc.dsc$b_dtype = DSC$K_DTYPE_T;
if (!(cptr = RawLibCgiVarNull("RAWSOCKET_INPUT"))) return (SS$_BUGCHECK);
zptr = (sptr = rawptr->InputDevName) + sizeof(rawptr->InputDevName)-1;
while (*cptr && sptr < zptr) *sptr++ = *cptr++;
*sptr = '\0';
rawptr->InputDevDsc.dsc$b_class = DSC$K_CLASS_S;
rawptr->InputDevDsc.dsc$b_dtype = DSC$K_DTYPE_T;
rawptr->InputDevDsc.dsc$a_pointer = rawptr->InputDevName;
rawptr->InputDevDsc.dsc$w_length = sptr - rawptr->InputDevName;
if (!(cptr = RawLibCgiVarNull("RAWSOCKET_OUTPUT"))) return (SS$_BUGCHECK);
zptr = (sptr = rawptr->OutputDevName) + sizeof(rawptr->OutputDevName)-1;
while (*cptr && sptr < zptr) *sptr++ = *cptr++;
*sptr = '\0';
rawptr->OutputDevDsc.dsc$b_class = DSC$K_CLASS_S;
rawptr->OutputDevDsc.dsc$b_dtype = DSC$K_DTYPE_T;
rawptr->OutputDevDsc.dsc$a_pointer = rawptr->OutputDevName;
rawptr->OutputDevDsc.dsc$w_length = sptr - rawptr->OutputDevName;
status = sys$assign (&rawptr->InputDevDsc, &rawptr->InputChannel, 0, 0,
AGN$M_READONLY);
if (VMSnok (status)) return (status);
status = sys$assign (&rawptr->OutputDevDsc, &rawptr->OutputChannel, 0, 0,
AGN$M_WRITEONLY);
if (VMSnok (status))
{
sys$dassgn (rawptr->InputChannel);
rawptr->InputChannel = 0;
return (status);
}
if (VMSnok (status))
{
sys$dassgn (rawptr->InputChannel);
sys$dassgn (rawptr->OutputChannel);
rawptr->InputChannel = rawptr->OutputChannel = 0;
return (status);
}
if (!(rawptr->WatchScript = (rawptr->WatchLog != NULL)))
rawptr->WatchScript = (RawLibCgiVarNull("WATCH_SCRIPT") != NULL);
WATCH_RAWLIB (rawptr, FI_LI, "OPEN !AZ", SOFTWAREID);
return (SS$_NORMAL);
}
/*****************************************************************************/
/*
Initiate a close from the application end.
*/
void RawLibClose (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
WATCH_RAWLIB (rawptr, FI_LI, "CLOSE closed:!UL", rawptr->RawSocketClosed);
rawptr->RawSocketClosed = 1;
Shut (rawptr);
}
/*****************************************************************************/
/*
Return true if the RawSocket has been closed.
*/
int RawLibIsClosed (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->RawSocketClosed);
}
/*****************************************************************************/
/*
Shutdown the websocket (this is different to the close handshake).
Cancel any outstanding I/O and deassign channels.
Call any supplied closure AST function.
This function call be called multiple times before full shutdown accomplished.
Returns success status when finally shut, abort if not (fully) shut (yet).
*/
int Shut (struct RawLibStruct *rawptr)
{
int astatus, status;
/*********/
/* begin */
/*********/
if (rawptr->WatchLog)
WATCH_RAWLIB (rawptr, FI_LI,
"Shut() destroy:!8XL(!UL) shut:!UL/!UL closed:!UL input:!UL output:!UL",
rawptr->DestroyAstFunction,
rawptr->DestroyAstFunction == &Destroy,
rawptr->RawSocketShut, rawptr->ShutCount,
rawptr->RawSocketClosed, rawptr->QueuedInput,
rawptr->QueuedOutput);
if (rawptr->DestroyAstFunction == &Destroy) return (SS$_NORMAL);
if (!rawptr->RawSocketShut)
{
if (rawptr->QueuedInput) sys$cancel (rawptr->InputChannel);
/* advise the server that the connection is being shut down */
astatus = sys$setast (0);
status = sys$qio (EfnNoWait, rawptr->OutputChannel,
IO$_WRITEOF | IO$M_NORSWAIT, 0,
WriteEofAst, rawptr,
0, 0, 0, 0, 0, 0);
if (VMSok(status)) rawptr->QueuedOutput++;
if (astatus == SS$_WASSET) sys$setast (1);
/* can be shut without having been closed (e.g. network error) */
rawptr->RawSocketShut = rawptr->RawSocketClosed = 1;
}
else
if (rawptr->QueuedOutput)
if (rawptr->ShutCount++ > rawptr->QueuedOutput)
sys$cancel (rawptr->OutputChannel);
/* if outstanding I/O */
if (rawptr->QueuedInput || rawptr->QueuedOutput) return (SS$_ABORT);
/* deassign of output channel is handled during destroy */
sys$dassgn (rawptr->InputChannel);
rawptr->InputChannel = 0;
/* first queue any client's destruction code */
if (rawptr->DestroyAstFunction)
sys$dclast (rawptr->DestroyAstFunction, rawptr, 0, 0);
/* then queue the rawLIB structure destruction */
sys$dclast ((rawptr->DestroyAstFunction = &Destroy), rawptr, 0, 0);
return (SS$_NORMAL);
}
/*****************************************************************************/
/*
Server has been advised of the closing connection (or t least the EOF has been
queued). Decrement the queued I/O counter and then recall the shut function.
*/
static void WriteEofAst (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
if (rawptr->QueuedOutput)
rawptr->QueuedOutput--;
else
RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
Shut (rawptr);
}
/*****************************************************************************/
/*
Return true if both input and output channel connected.
*/
int RawLibConnected (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->InputChannel && rawptr->OutputChannel);
}
/*****************************************************************************/
/*
Read data from the RawSocket client using a descriptor to describe the input
buffer.
*/
int RawLibReadDsc
(
struct RawLibStruct *rawptr,
struct dsc$descriptor_s *DataDsc,
struct dsc$descriptor_s *ResultDsc,
void *AstFunction
)
{
int status;
struct dsc$descriptor_s ScratchDsc;
/*********/
/* begin */
/*********/
if (DataDsc->dsc$b_class != DSC$K_CLASS_S &&
DataDsc->dsc$b_dtype != DSC$K_DTYPE_T) return (LIB$_INVSTRDES);
rawptr->ReadDataDscPtr = DataDsc;
rawptr->ReadResultDscPtr = ResultDsc;
status = RawLibRead (rawptr, DataDsc->dsc$a_pointer,
DataDsc->dsc$w_length, AstFunction);
return (status);
}
/*****************************************************************************/
/*
Read RawSocket data from RAWSOCKET_INPUT. If an AST function is supplied
then the read is asynchronous, otherwise blocking. When the read is complete
the status can be returned by RawLibReadStatus(), the read count by
RawLibReadCount(), a pointer to the data buffer using RawLibReadData(), and a
pointer to the read string descriptor with RawLibReadDataDsc().
*/
int RawLibRead
(
struct RawLibStruct *rawptr,
char *DataPtr,
int DataSize,
void *AstFunction
)
{
int astatus, status;
struct RawLibIoStruct *ioptr;
/*********/
/* begin */
/*********/
WATCH_RAWLIB (rawptr, FI_LI, "READ size:!UL", DataSize);
if (rawptr->RawSocketClosed)
{
MsgCallback (rawptr, __LINE__, SS$_SHUT, "can't read; closed");
rawptr->ReadStatus = SS$_SHUT;
if (AstFunction) ((void(*)())AstFunction)(rawptr);
return (SS$_SHUT);
}
/* if descriptor is not initialised (by not using RawLibReadDsc()) */
if (!rawptr->ReadDataDscPtr)
{
rawptr->ReadDataDscPtr = &rawptr->ReadDataDsc;
rawptr->ReadDataDscPtr->dsc$b_class = DSC$K_CLASS_S;
rawptr->ReadDataDscPtr->dsc$b_dtype = DSC$K_DTYPE_T;
rawptr->ReadDataDscPtr->dsc$a_pointer = DataPtr;
rawptr->ReadDataDscPtr->dsc$w_length = DataSize;
}
ioptr = calloc (1, sizeof(struct RawLibIoStruct));
ioptr->RawLibPtr = rawptr;
ioptr->DataPtr = DataPtr;
ioptr->DataSize = DataSize;
ioptr->DataDscPtr = rawptr->ReadDataDscPtr;
ioptr->ResultDscPtr = rawptr->ReadResultDscPtr;
if (ioptr->AstFunction = AstFunction)
{
/* asynchronous read */
astatus = sys$setast (0);
status = sys$qio (EfnNoWait, rawptr->InputChannel,
IO$_READLBLK | IO$M_STREAM | IO$M_WRITERCHECK,
&ioptr->IOsb, ReadDataAst, ioptr,
DataPtr, DataSize, 0, 0, 0, 0);
if (VMSok(status)) rawptr->QueuedInput++;
if (astatus == SS$_WASSET) sys$setast (1);
}
else
{
/* synchronous read */
status = sys$qiow (EfnWait, rawptr->InputChannel,
IO$_READLBLK | IO$M_STREAM | IO$M_WRITERCHECK,
&ioptr->IOsb, 0, 0,
DataPtr, DataSize, 0, 0, 0, 0);
if (VMSok(status))
{
if (VMSok(status)) status = ioptr->IOsb.iosb$w_status;
rawptr->QueuedInput++;
ReadDataAst (ioptr);
}
}
return (status);
}
/*****************************************************************************/
/*
*/
static void ReadDataAst (struct RawLibIoStruct *ioptr)
{
int astatus, cnt, status,
DataCount,
DataSize;
char *DataPtr;
struct RawLibStruct *rawptr;
/*********/
/* begin */
/*********/
rawptr = ioptr->RawLibPtr;
WATCH_RAWLIB (rawptr, FI_LI, "READ AST %X!8XL !UL bytes",
ioptr->IOsb.iosb$w_status, ioptr->IOsb.iosb$w_bcnt);
if (rawptr->QueuedInput)
rawptr->QueuedInput--;
else
RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
if (rawptr->WatchDogReadSecs)
rawptr->WatchDogReadTime = CurrentTime + rawptr->WatchDogReadSecs;
if (rawptr->WatchDogIdleSecs)
rawptr->WatchDogIdleTime = CurrentTime + rawptr->WatchDogIdleSecs;
/* these remain current for the duration of any AST */
rawptr->ReadDataPtr = ioptr->DataPtr;
rawptr->ReadDataSize = ioptr->DataSize;
rawptr->ReadDataDscPtr = ioptr->DataDscPtr;
rawptr->ReadResultDscPtr = ioptr->ResultDscPtr;
if (VMSok (rawptr->ReadStatus = ioptr->IOsb.iosb$w_status))
{
#ifdef __VAX
/* close enough! */
rawptr->InputMsgCount[0]++;
#else
*(__int64*)rawptr->InputMsgCount = *(__int64*)rawptr->InputMsgCount + 1;
#endif
}
rawptr->ReadDataCount = ioptr->IOsb.iosb$w_bcnt;
/* update result length if originally provided, otherwise data length */
if (rawptr->ReadResultDscPtr)
rawptr->ReadResultDscPtr->dsc$w_length = ioptr->IOsb.iosb$w_bcnt;
else
rawptr->ReadDataDscPtr->dsc$w_length = ioptr->IOsb.iosb$w_bcnt;
if (ioptr->AstFunction) ((void(*)())ioptr->AstFunction)(rawptr);
/* reset after any AST has been delivered */
rawptr->ReadDataPtr = NULL;
rawptr->ReadDataCount = rawptr->ReadDataSize = 0;
rawptr->ReadDataDscPtr = rawptr->ReadResultDscPtr = NULL;
rawptr->WatchDogReadTime = 0;
if (rawptr->WatchDogIdleSecs)
rawptr->WatchDogIdleTime = CurrentTime + rawptr->WatchDogIdleSecs;
if (rawptr->WatchDogWakeSecs)
rawptr->WatchDogWakeTime = CurrentTime + rawptr->WatchDogWakeSecs;
if (rawptr->RawSocketShut) Shut (rawptr);
free (ioptr);
}
/*****************************************************************************/
/*
Return the (most recent) read status value.
*/
int RawLibReadStatus (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->ReadStatus);
}
/*****************************************************************************/
/*
Return the (most recent) read buffer size (longword).
*/
int RawLibReadSize (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->ReadDataSize);
}
/*****************************************************************************/
/*
Return the (most recent) read count value (longword).
*/
int RawLibReadCount (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->ReadDataCount);
}
/*****************************************************************************/
/*
Return a pointer to the (most recent) read buffer.
*/
char* RawLibReadData (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->ReadDataPtr);
}
/*****************************************************************************/
/*
Return a pointer to the (most recent) read data descriptor.
*/
struct dsc$descriptor_s* RawLibReadDataDsc (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (&rawptr->ReadDataDsc);
}
/*****************************************************************************/
/*
Return a pointer to the total read count value (quadword).
*/
ulong* RawLibReadTotal (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return ((ulong*)&rawptr->InputCount);
}
/*****************************************************************************/
/*
Return a pointer to the total messages read value (quadword).
*/
ulong* RawLibReadMsgTotal (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return ((ulong*)&rawptr->InputMsgCount);
}
/*****************************************************************************/
/*
Write the data pointed to by the supplied string descriptor.
*/
int RawLibWriteDsc
(
struct RawLibStruct *rawptr,
struct dsc$descriptor_s *DataDsc,
void *AstFunction
)
{
int status;
/*********/
/* begin */
/*********/
if (DataDsc->dsc$b_class != DSC$K_CLASS_S &&
DataDsc->dsc$b_dtype != DSC$K_DTYPE_T) return (LIB$_INVSTRDES);
rawptr->WriteDataDscPtr = DataDsc;
status = RawLibWrite (rawptr, DataDsc->dsc$a_pointer,
DataDsc->dsc$w_length, AstFunction);
return (status);
}
/*****************************************************************************/
/*
Queue a write to the client RAWSOCKET_OUTPUT mailbox. If an AST function is
supplied then the write is asynchronous, otherwise blocking.
*/
int RawLibWrite
(
struct RawLibStruct *rawptr,
char *DataPtr,
int DataCount,
void *AstFunction
)
{
int astatus, status;
uchar *cptr, *czptr, *sptr;
struct RawLibIoStruct *ioptr;
/*********/
/* begin */
/*********/
WATCH_RAWLIB (rawptr, FI_LI, "WRITE !UL bytes", DataCount);
if (rawptr->RawSocketClosed)
{
MsgCallback (rawptr, __LINE__, SS$_SHUT, "can't write; closed");
rawptr->WriteStatus = SS$_SHUT;
if (AstFunction && AstFunction != RAWLIB_ASYNCH)
((void(*)())AstFunction)(rawptr);
return (SS$_SHUT);
}
ioptr = calloc (1, sizeof(struct RawLibIoStruct));
ioptr->RawLibPtr = rawptr;
ioptr->DataPtr = DataPtr;
ioptr->DataCount = DataCount;
ioptr->DataDscPtr = rawptr->WriteDataDscPtr;
if (ioptr->AstFunction = AstFunction)
{
/* asynchronous */
astatus = sys$setast (0);
status = sys$qio (EfnNoWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK,
&ioptr->IOsb, WriteDataAst, ioptr,
DataPtr, DataCount, 0, 0, 0, 0);
if (VMSok(status)) rawptr->QueuedOutput++;
if (astatus == SS$_WASSET) sys$setast (1);
}
else
{
/* synchronous */
status = sys$qiow (EfnWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK,
&ioptr->IOsb, 0, 0,
DataPtr, DataCount, 0, 0, 0, 0);
if (VMSok(status)) status = ioptr->IOsb.iosb$w_status;
rawptr->QueuedOutput++;
WriteDataAst (ioptr);
}
return (status);
}
/*****************************************************************************/
/*
Write the message to the RawSocket. Message may be automatically fragmented.
Can AST back to this function one or more times with asycnchronous I/O.
*/
static void WriteDataAst (struct RawLibIoStruct *ioptr)
{
int astatus, cnt, count, hcnt, length, status,
DataCount;
char *DataPtr;
struct RawLibStruct *rawptr;
/*********/
/* begin */
/*********/
rawptr = ioptr->RawLibPtr;
WATCH_RAWLIB (rawptr, FI_LI, "WRITE AST %X!8XL",
ioptr->IOsb.iosb$w_status);
if (rawptr->QueuedOutput)
rawptr->QueuedOutput--;
else
RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
if (rawptr->WatchDogIdleSecs)
rawptr->WatchDogIdleTime = CurrentTime + rawptr->WatchDogIdleSecs;
/* these remain current for the duration of any AST */
rawptr->WriteDataPtr = ioptr->DataPtr;
rawptr->WriteDataCount = ioptr->DataCount;
rawptr->WriteDataDscPtr = ioptr->DataDscPtr;
if (VMSok (rawptr->WriteStatus = ioptr->IOsb.iosb$w_status))
{
#ifdef __VAX
/* close enough! */
rawptr->OutputMsgCount[0]++;
#else
*(__int64*)rawptr->OutputMsgCount = *(__int64*)rawptr->OutputMsgCount + 1;
#endif
}
if (rawptr->WatchDogIdleSecs)
rawptr->WatchDogIdleTime = CurrentTime + rawptr->WatchDogIdleSecs;
if (rawptr->WatchDogWakeSecs)
rawptr->WatchDogWakeTime = CurrentTime + rawptr->WatchDogWakeSecs;
if (ioptr->AstFunction && ioptr->AstFunction != RAWLIB_ASYNCH)
((void(*)())ioptr->AstFunction)(rawptr);
free (ioptr);
}
/*****************************************************************************/
/*
Return the (most recent) write status value.
*/
int RawLibWriteStatus (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->WriteStatus);
}
/*****************************************************************************/
/*
Return the (most recent) write count value (longword).
*/
int RawLibWriteCount (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->WriteDataCount);
}
/*****************************************************************************/
/*
Return a pointer to the (most recent) write data descriptor.
*/
struct dsc$descriptor_s* RawLibWriteDataDsc (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (&rawptr->WriteDataDsc);
}
/*****************************************************************************/
/*
Return a pointer to the total write count value (quadword).
*/
ulong* RawLibWriteTotal (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return ((ulong*)&rawptr->OutputCount);
}
/*****************************************************************************/
/*
Return a pointer to the total write message value (quadword).
*/
ulong* RawLibWriteMsgTotal (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return ((ulong*)&rawptr->OutputMsgCount);
}
/*****************************************************************************/
/*
Set the pointer to the user data associated with the RawSocket structure.
*/
void RawLibSetUserData
(
struct RawLibStruct *rawptr,
void *UserDataPtr
)
{
/*********/
/* begin */
/*********/
rawptr->UserDataPtr = UserDataPtr;
}
/*****************************************************************************/
/*
Return the pointer to the user data.
*/
void* RawLibGetUserData (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->UserDataPtr);
}
/*****************************************************************************/
/*
Set/reset the callout response AST. Returns the previous callout pointer.
*/
void* RawLibSetCallout
(
struct RawLibStruct *rawptr,
void *AstFunction
)
{
void *PrevCallout;
/*********/
/* begin */
/*********/
PrevCallout = rawptr->CalloutAstFunction;
rawptr->CalloutAstFunction = AstFunction;
return (PrevCallout);
}
/*****************************************************************************/
/*
Set number of seconds before the application is considered idle and exited.
*/
void RawLibSetLifeSecs (int LifeSecs)
{
/*********/
/* begin */
/*********/
if (!(WatchDogLifeSecs = LifeSecs))
WatchDogLifeSecs = DEFAULT_WATCHDOG_IDLE_SECS;
}
/*****************************************************************************/
/*
Set number of seconds before a RawSocket is considered idle and closed.
If a RawSocket is not specified then set global value.
*/
void RawLibSetIdleSecs
(
struct RawLibStruct *rawptr,
int IdleSecs
)
{
/*********/
/* begin */
/*********/
if (rawptr)
{
/* set RawSocket values */
if (!(rawptr->WatchDogIdleSecs = IdleSecs))
rawptr->WatchDogIdleSecs = WatchDogIdleSecs;
rawptr->WatchDogIdleTime = CurrentTime + rawptr->WatchDogIdleSecs;
}
else
{
/* set global values */
if (!(WatchDogIdleSecs = IdleSecs))
WatchDogIdleSecs = DEFAULT_WATCHDOG_IDLE_SECS;
}
}
/*****************************************************************************/
/*
Set number of seconds a RawSocket read will wait on the client.
If a RawSocket is not specified then set global value.
*/
void RawLibSetReadSecs
(
struct RawLibStruct *rawptr,
int ReadSecs
)
{
/*********/
/* begin */
/*********/
if (rawptr)
{
/* set RawSocket values */
if (!(rawptr->WatchDogReadSecs = ReadSecs))
rawptr->WatchDogReadSecs = WatchDogReadSecs;
}
else
{
/* set global values */
if (!(WatchDogReadSecs = ReadSecs))
WatchDogReadSecs = DEFAULT_WATCHDOG_IDLE_SECS;
}
}
/*****************************************************************************/
/*
Set/reset the wake callback function to the specified number of seconds
(defaults to the global setting). Returns the previous callback pointer.
*/
void* RawLibSetWakeCallback
(
struct RawLibStruct *rawptr,
void *AstFunction,
int WakeSecs
)
{
void *PrevCallback;
/*********/
/* begin */
/*********/
if (rawptr)
{
/* set RawSocket values */
if (!(rawptr->WatchDogWakeSecs = WakeSecs))
rawptr->WatchDogWakeSecs = WatchDogWakeSecs;
rawptr->WatchDogWakeTime = CurrentTime + rawptr->WatchDogWakeSecs;
PrevCallback = rawptr->WakeCallbackFunction;
rawptr->WakeCallbackFunction = AstFunction;
}
else
{
/* set global values */
if (!(WatchDogWakeSecs = WakeSecs))
WatchDogWakeSecs = DEFAULT_WATCHDOG_WAKE_SECS;
WatchDogWakeTime = CurrentTime + WatchDogWakeSecs;
PrevCallback = WakeCallbackFunction;
WakeCallbackFunction = AstFunction;
}
return (PrevCallback);
}
/*****************************************************************************/
/*
Set/reset the error callback function. Returns the previous callback pointer.
*/
void* RawLibSetMsgCallback
(
struct RawLibStruct *rawptr,
void *AstFunction
)
{
void *PrevCallback;
/*********/
/* begin */
/*********/
PrevCallback = rawptr->MsgCallbackFunction;
rawptr->MsgCallbackFunction = AstFunction;
return (PrevCallback);
}
/*****************************************************************************/
/*
Set wsLIB message data. The 'FormatString' must be a $FAO compiliant
null-terminated string, with following parametersif required. Activate any set
message callback.
*/
static void MsgCallback
(
struct RawLibStruct *rawptr,
int LineNumber,
int VmsStatus,
char *FormatString,
...
)
{
static $DESCRIPTOR (FormatFaoDsc, "");
int argcnt, cnt, status;
ushort slen = 0;
ulong *vecptr;
ulong FaoVector [32];
char *cptr, *sptr, *zptr;
char FormatBuffer [128];
va_list argptr;
/*********/
/* begin */
/*********/
va_count (argcnt);
/* bit of a sanity check */
if (argcnt-4 > 32) RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
cnt = 0;
/* some VERY basic sanity checking */
for (cptr = FormatString; *cptr; cptr++)
{
if (*cptr != '!') continue;
cptr++;
if (*cptr == '!') continue;
cnt++;
if (*cptr == '#') cnt++;
if (*(USHORTPTR)cptr == '%T') cnt++;
if (*(USHORTPTR)cptr == '%D') cnt++;
}
if (argcnt-4 != cnt) RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
zptr = (sptr = FormatBuffer) + sizeof(FormatBuffer)-1;
for (cptr = "%X!8XL "; *cptr; *sptr++ = *cptr++);
for (cptr = FormatString; *cptr && sptr < zptr; *sptr++ = *cptr++);
*sptr = '\0';
FormatFaoDsc.dsc$a_pointer = FormatBuffer;
FormatFaoDsc.dsc$w_length = sptr - FormatBuffer;
vecptr = FaoVector;
*vecptr++ = VmsStatus;
va_start (argptr, FormatString);
for (argcnt -= 4; argcnt; argcnt--)
*vecptr++ = va_arg (argptr, ulong);
va_end (argptr);
rawptr->MsgDsc.dsc$b_class = DSC$K_CLASS_S;
rawptr->MsgDsc.dsc$b_dtype = DSC$K_DTYPE_T;
for (;;)
{
if (rawptr->MsgStringSize)
{
rawptr->MsgDsc.dsc$a_pointer = rawptr->MsgStringPtr;
rawptr->MsgDsc.dsc$w_length = rawptr->MsgStringSize;
status = sys$faol (&FormatFaoDsc, &slen, &rawptr->MsgDsc, &FaoVector);
if (VMSnok (status)) RawLibExit (NULL, FI_LI, status);
if (status != SS$_BUFFEROVF) break;
}
if (rawptr->MsgStringSize) free (rawptr->MsgStringPtr);
rawptr->MsgStringSize += 127;
rawptr->MsgStringPtr = calloc (1, rawptr->MsgStringSize+1);
if (!rawptr->MsgStringPtr) RawLibExit (NULL, FI_LI, vaxc$errno);
}
rawptr->MsgStringPtr[rawptr->MsgStringLength=slen] = '\0';
rawptr->MsgDsc.dsc$w_length = slen;
rawptr->MsgLineNumber = LineNumber;
sys$gettim (&rawptr->MsgBinTime);
if (rawptr->MsgCallbackFunction) (*rawptr->MsgCallbackFunction)(rawptr);
}
/****************************************************************************/
/*
Return a pointer to the string descriptor of the latest error string.
*/
struct dsc$descriptor_s* RawLibMsgDsc (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (&rawptr->MsgDsc);
}
/****************************************************************************/
/*
Return a pointer to the latest error string.
*/
char* RawLibMsgString (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->MsgStringPtr);
}
/****************************************************************************/
/*
Return the wsLIB source code line at which the last error occured.
*/
int RawLibMsgLineNumber (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
return (rawptr->MsgLineNumber);
}
/*****************************************************************************/
/*
Return the current wsLIB time in seconds (i.e. C-RTL, Unix time).
*/
unsigned int RawLibTime ()
{
/*********/
/* begin */
/*********/
return (CurrentTime);
}
/*****************************************************************************/
/*
Called every second to maintain various events in the RawSocket and application
life-cycle.
*/
static void WatchDog ()
{
static int DebugWatchDog = 0;
static ulong OneSecondDelta [2] = { -10000000, -1 };
static ulong ExitTime;
int status,
StringLength;
char StringBuffer [256];
struct RawLibStruct *rawptr;
/*********/
/* begin */
/*********/
sys$gettim (&CurrentBinTime);
CurrentTime = decc$fix_time (&CurrentBinTime);
if (DebugWatchDog && ListHead)
RawLibWatchScript (ListHead, FI_LI, "WATCHDOG !UL", CurrentTime);
if (ListHead)
ExitTime = 0;
else
if (!ExitTime)
ExitTime = CurrentTime + WatchDogLifeSecs;
else
if (ExitTime < CurrentTime)
exit (SS$_NORMAL);
if (WatchDogWakeTime &&
WatchDogWakeTime < CurrentTime)
{
/* wake globally if requested */
WatchDogWakeTime = CurrentTime + WatchDogWakeSecs - 1;
if (WakeCallbackFunction) sys$dclast (WakeCallbackFunction, 0, 0, 0);
}
for (rawptr = ListHead; rawptr; rawptr = rawptr->NextPtr)
{
if (DebugWatchDog)
RawLibWatchScript (ListHead, FI_LI, "WATCHDOG 0x!8XL !UL !UL !UL",
rawptr,
rawptr->WatchDogIdleTime,
rawptr->WatchDogReadTime,
rawptr->WatchDogWakeTime);
/* flush any watch log to disk every second */
if (rawptr->WatchLog) fsync (fileno(rawptr->WatchLog));
if (rawptr->WatchDogReadTime &&
rawptr->WatchDogReadTime < CurrentTime)
{
if (rawptr->WatchScript)
WATCH_RAWLIB (rawptr, FI_LI, "READ expired 0x!8XL", rawptr);
RawLibClose (rawptr);
}
else
if (rawptr->WatchDogIdleTime &&
rawptr->WatchDogIdleTime < CurrentTime)
{
if (rawptr->WatchScript)
WATCH_RAWLIB (rawptr, FI_LI, "IDLE expired 0x!8XL", rawptr);
RawLibClose (rawptr);
}
else
if (rawptr->WatchDogWakeTime &&
rawptr->WatchDogWakeTime < CurrentTime)
{
/* wake if requested */
rawptr->WatchDogWakeTime = CurrentTime + rawptr->WatchDogWakeSecs - 1;
if (rawptr->WakeCallbackFunction)
{
if (rawptr->WatchScript)
WATCH_RAWLIB (rawptr, FI_LI, "WAKE expired 0x!8XL", rawptr);
sys$dclast (rawptr->WakeCallbackFunction, rawptr, 0, 0);
}
}
}
status = sys$setimr (0, &OneSecondDelta, WatchDog, 0, 0);
if (VMSnok(status)) RawLibExit (NULL, FI_LI, status);
}
/*****************************************************************************/
/*
Exit from the current image reporting to the server RAWSOCKET_OUTPUT stream (if
a channel assigned) or (last-ditch) to <stdout> the exit code module name and
line number.
*/
void RawLibExit
(
struct RawLibStruct *rawptr,
char *SourceModuleName,
int SourceLineNumber,
int status
)
{
static ulong OneSecondDelta [2] = { -10000000, -1 };
static $DESCRIPTOR (FaoDsc, "BYE-BYE [!AZ:!UL] %X!8XL\n\0");
short slen;
char MsgBuffer [256];
$DESCRIPTOR (MsgDsc, MsgBuffer);
/*********/
/* begin */
/*********/
sys$fao (&FaoDsc, &slen, &MsgDsc,
SourceModuleName, SourceLineNumber, status);
if (rawptr && rawptr->OutputChannel)
sys$qiow (EfnWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK, 0, 0, 0,
MsgBuffer, slen-1, 0, 0, 0, 0);
else
{
fputs (MsgBuffer, stdout);
fflush (stdout);
}
sys$schdwk (0, 0, OneSecondDelta, 0);
sys$hiber ();
sys$delprc (0, 0, 0);
}
/*****************************************************************************/
/*
The 'FormatString' must be a $FAO compliant null-terminated string, with
following parameters.
*/
void RawLibCallout
(
struct RawLibStruct *rawptr,
char *FormatString,
...
)
{
static $DESCRIPTOR (ErrorFaoDsc, "!!WATCH: $FAO %X!8XL");
int argcnt, astatus, cnt, status;
ushort slen = 0;
ulong *vecptr;
ulong FaoVector [32];
char *aptr, *cptr;
char CalloutBuffer [1024];
va_list argptr;
$DESCRIPTOR (CalloutBufferDsc, CalloutBuffer);
$DESCRIPTOR (FormatDsc, "");
/*********/
/* begin */
/*********/
if (!CgiPlusEscLength && !CgiPlusEotLength) return;
if (!rawptr->OutputChannel) return;
va_count (argcnt);
/* can't call callout while in a callout response delivery */
if (rawptr->CalloutInProgress) RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
/* bit of a sanity check */
if (argcnt-2 > 32) RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
cnt = 0;
for (cptr = FormatString; *cptr; cptr++)
if (*cptr == '!' && *(USHORTPTR)cptr != '!!') cnt++;
if (argcnt-2 != cnt) RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
FormatDsc.dsc$a_pointer = FormatString;
FormatDsc.dsc$w_length = strlen(FormatString);
vecptr = FaoVector;
va_start (argptr, FormatString);
for (argcnt -= 2; argcnt; argcnt--)
*vecptr++ = va_arg (argptr, ulong);
va_end (argptr);
status = sys$faol (&FormatDsc, &slen, &CalloutBufferDsc, &FaoVector);
if (VMSnok(status))
status = sys$fao (&ErrorFaoDsc, &slen, &CalloutBufferDsc, status);
/* allocate a pointer plus a buffer (freed by WriteFreeAst()) */
aptr = calloc (1, sizeof(struct RawLibStruct*) + slen);
if (!aptr) RawLibExit (rawptr, FI_LI, vaxc$errno);
*(struct RawLibStruct**)aptr = rawptr;
cptr = aptr + sizeof(struct RawLibStruct*);
memcpy (cptr, CalloutBuffer, slen);
astatus = sys$setast (0);
status = sys$qio (EfnNoWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK,
0, WriteOutputAst, rawptr,
CgiPlusEscPtr, CgiPlusEscLength, 0, 0, 0, 0);
if (VMSok(status))
{
rawptr->QueuedOutput++;
status = sys$qio (EfnNoWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK,
0, WriteFreeAst, aptr,
cptr, slen, 0, 0, 0, 0);
if (VMSok(status))
{
rawptr->QueuedOutput++;
status = sys$qio (EfnNoWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK,
0, WriteOutputAst, rawptr,
CgiPlusEotPtr, CgiPlusEotLength, 0, 0, 0, 0);
if (VMSok(status)) rawptr->QueuedOutput++;
}
}
if (astatus == SS$_WASSET) sys$setast (1);
}
/*****************************************************************************/
/*
Send a script "WATCH:" callout to the server (if [x]script enabled). The
'SourceModuleName' can be NULL. The 'FormatString' must be a $FAO compiliant
null-terminated string, with following parameters. A specific channel is
assigned for WATCH output so that it can be deassigned as late in request
processing as possible.
*/
void RawLibWatchScript
(
struct RawLibStruct *rawptr,
char *SourceModuleName,
int SourceLineNumber,
char *FormatString,
...
)
{
static $DESCRIPTOR (ErrorFaoDsc, "!!WATCH: $FAO %X!8XL");
static $DESCRIPTOR (TimeFaoDsc, "!%T\0");
static $DESCRIPTOR (Watch1FaoDsc, "!!!!WATCH: [!AZ:!4ZL] !AZ");
static $DESCRIPTOR (Watch2FaoDsc, "!!!!WATCH: !AZ");
static struct RawLibStruct FakeIt;
int argcnt, astatus, cnt, status;
ushort slen = 0;
ulong *vecptr;
ulong FaoVector [32];
char *aptr, *cptr;
char TimeBuffer [32],
WatchBuffer [1024],
WatchFao [256];
va_list argptr;
$DESCRIPTOR (FaoDsc, WatchFao);
$DESCRIPTOR (TimeBufferDsc, TimeBuffer);
$DESCRIPTOR (WatchBufferDsc, WatchBuffer);
/*********/
/* begin */
/*********/
if (!rawptr)
{
rawptr = &FakeIt;
if (!rawptr->WatchScript)
{
rawptr->WatchScript = 1;
if ((cptr = getenv ("WASD_RAWLIB_WATCH_LOG")) != NULL)
if ((rawptr->WatchLog = fopen (cptr, "w", "shr=get")) != NULL)
RawLibExit (NULL, FI_LI, vaxc$errno);
}
if (!rawptr->WatchLog) return;
}
else
{
if (!rawptr->WatchScript) return;
if (!rawptr->OutputChannel) return;
/* can't call callout while in a callout response delivery */
if (rawptr->CalloutInProgress) RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
}
va_count (argcnt);
/* bit of a sanity check */
if (argcnt-4 > 32) RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
cnt = 0;
for (cptr = FormatString; *cptr; cptr++)
{
if (*cptr != '!') continue;
cptr++;
if (*cptr == '!') continue;
cnt++;
if (*cptr == '#') cnt++;
if (*(USHORTPTR)cptr == '%T') cnt++;
if (*(USHORTPTR)cptr == '%D') cnt++;
}
if (argcnt-4 != cnt) RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
if (SourceModuleName)
sys$fao (&Watch1FaoDsc, &slen, &FaoDsc,
SourceModuleName, SourceLineNumber, FormatString);
else
sys$fao (&Watch2FaoDsc, &slen, &FaoDsc, FormatString);
FaoDsc.dsc$w_length = slen;
vecptr = FaoVector;
va_start (argptr, FormatString);
for (argcnt -= 4; argcnt; argcnt--)
*vecptr++ = va_arg (argptr, ulong);
va_end (argptr);
status = sys$faol (&FaoDsc, &slen, &WatchBufferDsc, &FaoVector);
if (!(status & 1))
status = sys$fao (&ErrorFaoDsc, &slen, &WatchBufferDsc, status);
if (!CgiPlusEscLength && !CgiPlusEotLength)
{
fprintf (stdout, "%*.*s\n", slen, slen, WatchBuffer);
return;
}
if (rawptr->WatchLog)
{
sys$fao (&TimeFaoDsc, 0, &TimeBufferDsc, 0);
fprintf (rawptr->WatchLog, "%s %*.*s\n",
TimeBuffer, slen-8, slen-8, WatchBuffer+8);
return;
}
/* allocate a pointer plus a buffer (freed by WriteFreeAst()) */
aptr = calloc (1, sizeof(struct RawLibStruct*) + slen);
if (!aptr) RawLibExit (rawptr, FI_LI, vaxc$errno);
*(struct RawLibStruct**)aptr = rawptr;
cptr = aptr + sizeof(struct RawLibStruct*);
memcpy (cptr, WatchBuffer, slen);
astatus = sys$setast (0);
status = sys$qio (EfnNoWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK,
0, WriteOutputAst, rawptr,
CgiPlusEscPtr, CgiPlusEscLength, 0, 0, 0, 0);
if (VMSok(status))
{
rawptr->QueuedOutput++;
status = sys$qio (EfnNoWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK,
0, WriteFreeAst, aptr,
cptr, slen, 0, 0, 0, 0);
if (VMSok(status))
{
rawptr->QueuedOutput++;
status = sys$qio (EfnNoWait, rawptr->OutputChannel,
IO$_WRITELBLK | IO$M_READERCHECK,
0, WriteOutputAst, rawptr,
CgiPlusEotPtr, CgiPlusEotLength, 0, 0, 0, 0);
if (VMSok(status)) rawptr->QueuedOutput++;
}
}
if (VMSnok (status)) RawLibExit (rawptr, FI_LI, status);
if (astatus == SS$_WASSET) sys$setast (1);
}
/*****************************************************************************/
/*
Just decrement the queued output counter.
*/
void WriteOutputAst (struct RawLibStruct *rawptr)
{
/*********/
/* begin */
/*********/
if (rawptr->QueuedOutput)
rawptr->QueuedOutput--;
else
RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
if (rawptr->RawSocketShut) Shut (rawptr);
}
/*****************************************************************************/
/*
The parameter is an address to allocated memory. The memory contains a pointer
to a RawLib structure and after that opaque data (actually just a write buffer
but what the hey). Get the pointer to the owning RawLib structure. Free the
allocated memory. Decrement the RawLib structure's queued output counter.
*/
void WriteFreeAst (char *aptr)
{
struct RawLibStruct *rawptr;
/*********/
/* begin */
/*********/
rawptr = *(struct RawLibStruct**)aptr;
free (aptr);
if (rawptr->QueuedOutput)
rawptr->QueuedOutput--;
else
RawLibExit (rawptr, FI_LI, SS$_BUGCHECK);
if (rawptr->RawSocketShut) Shut (rawptr);
}
/*****************************************************************************/
/*
If a CGIplus environment then output the end-of-request sentinal.
*/
void RawLibCgiPlusEof ()
{
/*********/
/* begin */
/*********/
if (!CgiPlusEofLength) return;
fflush (stdout);
fputs (CgiPlusEofPtr, stdout);
fflush (stdout);
}
/*****************************************************************************/
/*
Output the callout end sentinal.
*/
void RawLibCgiPlusEot ()
{
/*********/
/* begin */
/*********/
if (!CgiPlusEotLength) return;
fflush (stdout);
fputs (CgiPlusEotPtr, stdout);
fflush (stdout);
}
/*****************************************************************************/
/*
Output the callout begin sentinal.
*/
void RawLibCgiPlusEsc ()
{
/*********/
/* begin */
/*********/
if (!CgiPlusEscLength) return;
fflush (stdout);
fputs (CgiPlusEscPtr, stdout);
fflush (stdout);
}
/*****************************************************************************/
/*
Output the callout begin sentinal.
*/
void RawLibCalloutStart ()
{
/*********/
/* begin */
/*********/
if (!CgiPlusEscLength) return;
fflush (stdout);
fputs (CgiPlusEscPtr, stdout);
fflush (stdout);
}
/*****************************************************************************/
/*
Return true if it's a CGIplus execution environment.
*/
int RawLibIsCgiPlus ()
{
static int InitIs;
/*********/
/* begin */
/*********/
if (!InitIs)
{
InitIs = 1;
if (CgiPlusEofPtr = getenv("CGIPLUSEOF"))
CgiPlusEofLength = strlen(CgiPlusEofPtr);
if (CgiPlusEscPtr = getenv("CGIPLUSESC"))
CgiPlusEscLength = strlen(CgiPlusEscPtr);
if (CgiPlusEotPtr = getenv("CGIPLUSEOT"))
CgiPlusEotLength = strlen(CgiPlusEotPtr);
}
return (CgiPlusEofLength);
}
/*****************************************************************************/
/*
Are CGI variables currently available? Returns true or false.
*/
int RawLibCgiVarAvailable ()
{
/*********/
/* begin */
/*********/
return (CgiVariablesAvailable);
}
/*****************************************************************************/
/*
String descriptor equivalent of RawLibCgiVar() with the same requirements and
constraints. Set 'ValueDsc' to the value of the CGI variable (or empty if it
doesn't exist). Return the length of the value of -1 if the CGI variable name
does not exist.
*/
int RawLibCgiVarDsc
(
struct dsc$descriptor_s *NameDsc,
struct dsc$descriptor_s *ValueDsc
)
{
char *cptr, *czptr, *sptr, *zptr;
char VarName [256];
/*********/
/* begin */
/*********/
if (NameDsc->dsc$b_class != DSC$K_CLASS_S &&
ValueDsc->dsc$b_dtype != DSC$K_DTYPE_T) return (LIB$_INVSTRDES);
if (ValueDsc->dsc$b_class != DSC$K_CLASS_S &&
ValueDsc->dsc$b_dtype != DSC$K_DTYPE_T) return (LIB$_INVSTRDES);
zptr = (sptr = VarName) + sizeof(VarName)-1;
czptr = (cptr = NameDsc->dsc$a_pointer) + NameDsc->dsc$w_length;
while (cptr < czptr && sptr < zptr) *sptr++ = *cptr++;
*sptr = '\0';
if (cptr = RawLibCgiVarNull (VarName))
{
for (sptr = cptr; *sptr; sptr++);
ValueDsc->dsc$w_length = sptr - cptr;
ValueDsc->dsc$a_pointer = cptr;
return (SS$_NORMAL);
}
else
return (SS$_ITEMNOTFOUND);
}
/*****************************************************************************/
/*
Return empty string rather than NULL if the CGI variable does not exist.
*/
char* RawLibCgiVar (char* VarName)
{
char *cptr;
/*********/
/* begin */
/*********/
if (cptr = RawLibCgiVarNull (VarName))
return (cptr);
else
return ("");
}
/*****************************************************************************/
/*
Return the value of a CGI variable regardless of whether it is used in a
standard CGI environment or a WASD CGIplus environment. Automatically switches
WASD V7.2 into 'struct' mode for significantly improved performance.
Call with 'VarName' empty ("") to synchronize CGIplus requests. This waits for
a CGIplus variable stream, checks if it's in 'record' or 'struct' mode, reads
the stream appropriately before returning ready to provide variables.
DO NOT modify the character string returned by this function. Copy to other
storage if this is necessary. The behaviour is indeterminate if the returned
values are modified in any way!
All CGIplus variables may be returned by making successive calls using a
'VarName' of "*" (often useful when debugging). NULL is returned when
variables exhausted.
*/
char* RawLibCgiVarNull (char *VarName)
{
#define SOUS sizeof(ushort)
static FILE *CgiPlusIn;
int Length;
char WwwVarName [256];
char *bptr, *cptr, *sptr;
/*********/
/* begin */
/*********/
/* if not using the AST-driven RawLibOnNextRequest() */
if (!CgiPlusInChannel)
{
if (!StructBufferSize)
{
/**************/
/* initialise */
/**************/
if (RawLibIsCgiPlus())
{
if ((cptr = getenv ("WASD_RAWLIB_STRUCT_BUFFER_SIZE")) != NULL)
StructBufferSize = atoi(cptr);
if (StructBufferSize < RAWLIB_STRUCT_BUFFER_SIZE)
StructBufferSize = RAWLIB_STRUCT_BUFFER_SIZE;
StructBufferPtr = calloc (1, StructBufferSize);
if (!StructBufferPtr) RawLibExit (NULL, FI_LI, vaxc$errno);
StructBufferLength = 0;
}
else
StructBufferSize = -1;
}
if (VarName == NULL || !VarName[0])
{
/* initialize */
StructBufferLength = WwwPrefix = 0;
NextVarNamePtr = StructBufferPtr;
if (CgiPlusEofPtr == NULL)
WwwPrefix = (getenv ("WWW_SERVER_SOFTWARE") != NULL);
if (VarName == NULL) return (NULL);
}
}
if (VarName[0])
{
/***************************/
/* return a variable value */
/***************************/
if (*(ULONGPTR)VarName == 'WWW_' && !WwwPrefix)
VarName += 4;
else
if (*(ULONGPTR)VarName != 'WWW_' && WwwPrefix)
{
strcpy (WwwVarName, "WWW_");
strcpy (WwwVarName+4, VarName);
VarName = WwwVarName;
}
if (CgiPlusEofPtr == NULL)
{
/* standard CGI environment */
CgiVariablesAvailable = 1;
return (getenv (VarName));
}
if (!CgiVariablesAvailable) return (NULL);
if (VarName[0] == '*')
{
/* return each CGIplus variable in successive calls */
if (!(Length = *(USHORTPTR)NextVarNamePtr))
{
NextVarNamePtr = StructBufferPtr;
return (NULL);
}
sptr = (NextVarNamePtr += SOUS);
NextVarNamePtr += Length;
return (sptr);
}
/* return a pointer to this CGIplus variable's value */
for (bptr = StructBufferPtr;
Length = *(USHORTPTR)bptr;
bptr += Length)
{
sptr = (bptr += SOUS);
for (cptr = VarName; *cptr && *sptr && *sptr != '='; cptr++, sptr++)
if (toupper(*cptr) != toupper(*sptr)) break;
/* if found return a pointer to the value */
if (!*cptr && *sptr == '=') return (sptr+1);
}
/* not found */
return (NULL);
}
/*****************************/
/* get the CGIplus variables */
/*****************************/
if (RequestSynchronisation == NULL)
RequestSynchronisation = (void*)RawLibCgiVarNull;
else
if (RequestSynchronisation != (void*)RawLibCgiVarNull)
RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
/* cannot "sync" in a non-CGIplus environment */
if (CgiPlusEofPtr == NULL) return (NULL);
/* the CGIPLUSIN stream can be left open */
if (CgiPlusIn == NULL)
if ((CgiPlusIn = fopen (getenv("CGIPLUSIN"), "r")) == NULL)
RawLibExit (NULL, FI_LI, vaxc$errno);
CgiVariablesAvailable = WwwPrefix = 0;
/* get the starting record (the essentially discardable one) */
for (;;)
{
cptr = fgets (StructBufferPtr, StructBufferSize, CgiPlusIn);
if (cptr == NULL) RawLibExit (NULL, FI_LI, vaxc$errno);
/* if the starting sentinal is detected then break */
if (*(USHORTPTR)cptr == '!\0' ||
*(USHORTPTR)cptr == '!\n' ||
(*(USHORTPTR)cptr == '!!' && isdigit(*(cptr+2)))) break;
}
if (*(USHORTPTR)cptr == '!!')
{
/********************/
/* CGIplus 'struct' */
/********************/
/* get the size of the binary structure */
StructBufferLength = atoi(cptr+2);
if (StructBufferLength <= 0) RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
if (StructBufferLength > StructBufferSize)
{
while (StructBufferLength > StructBufferSize) StructBufferSize *= 2;
free (StructBufferPtr);
StructBufferPtr = calloc (1, StructBufferSize);
if (!StructBufferPtr) RawLibExit (NULL, FI_LI, vaxc$errno);
NextVarNamePtr = StructBufferPtr;
}
if (!fread (StructBufferPtr, 1, StructBufferLength, CgiPlusIn))
RawLibExit (NULL, FI_LI, vaxc$errno);
}
else
{
/*********************/
/* CGIplus 'records' */
/*********************/
/* reconstructs the original 'struct'ure from the records */
sptr = (bptr = StructBufferPtr) + StructBufferSize;
while (fgets (bptr+SOUS, sptr-(bptr+SOUS), CgiPlusIn) != NULL)
{
/* first empty record (line) terminates variables */
if (bptr[SOUS] == '\n') break;
/* note the location of the length word */
cptr = bptr;
for (bptr += SOUS; *bptr && *bptr != '\n'; bptr++);
if (*bptr != '\n') RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
*bptr++ = '\0';
if (bptr >= sptr) RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
/* update the length word */
*(USHORTPTR)cptr = bptr - (cptr + SOUS);
}
if (bptr >= sptr) RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
/* terminate with a zero-length entry */
*(USHORTPTR)bptr = 0;
StructBufferLength = (bptr + SOUS) - StructBufferPtr;
}
/***********************/
/* variables available */
/***********************/
CgiVariablesAvailable = 1;
sptr = StructBufferPtr + SOUS;
if (*(ULONGPTR)sptr == 'WWW_') WwwPrefix = 1;
if (!CalloutDone)
{
/* provide the CGI callout to set CGIplus into 'struct' mode */
fflush (stdout);
fputs (CgiPlusEscPtr, stdout);
fflush (stdout);
/* the leading '!' indicates we're not going to read the response */
fputs ("!CGIPLUS: struct", stdout);
fflush (stdout);
fputs (CgiPlusEotPtr, stdout);
fflush (stdout);
/* don't need to do this again (the '!!' tells us what mode) */
CalloutDone = 1;
}
return (NULL);
# undef SOUS
}
/*****************************************************************************/
/*
Asynchronous notification of the next request becoming available. This
function should be called once during script initialisation specifying the
address of the function to be notified of a new request. Until the script
issues the CGIplus EOF sentinal the RawLibCgiVar..() family of functions can be
used to retrieve the CGI variable values. This asynchronous and the
synchronous RawLibCgiVar("") approaches to request synchronisation are mutually
exclusive and once one is used, using the other results in a bugcheck.
*/
void RawLibOnNextRequest (void *AstFunction)
{
#define SOUS sizeof(ushort)
static int CGIplusStruct = 0,
StartSentinal = 0;
static char SentinalBuffer [256];
static $DESCRIPTOR (CgiPlusInDsc, "");
static struct RawLibIOsb IOsb;
static void *RequestAstFunction;
int bcnt, status;
char *bptr, *cptr;
/*********/
/* begin */
/*********/
if (RequestSynchronisation == NULL)
RequestSynchronisation = RawLibOnNextRequest;
else
if (RequestSynchronisation != RawLibOnNextRequest)
RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
if (!CgiPlusInChannel)
{
/**************/
/* initialise */
/**************/
/* ensure initialisation */
if (!RawLibIsCgiPlus())
{
/* hmmm, standard CGI environment - do something sensible */
sys$dclast (AstFunction, 0, 0, 0);
return;
}
if (!AstFunction) RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
RequestAstFunction = AstFunction;
if ((cptr = getenv("CGIPLUSIN")) == NULL)
RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
CgiPlusInDsc.dsc$a_pointer = cptr;
CgiPlusInDsc.dsc$w_length = strlen(cptr);
status = sys$assign (&CgiPlusInDsc, &CgiPlusInChannel, 0, 0);
if (VMSnok(status)) RawLibExit (NULL, FI_LI, status);
if ((cptr = getenv ("WASD_RAWLIB_STRUCT_BUFFER_SIZE")) != NULL)
StructBufferSize = atoi(cptr);
if (StructBufferSize < RAWLIB_STRUCT_BUFFER_SIZE)
StructBufferSize = RAWLIB_STRUCT_BUFFER_SIZE;
StructBufferPtr = calloc (1, StructBufferSize+2);
if (!StructBufferPtr) RawLibExit (NULL, FI_LI, vaxc$errno);
StructBufferLength = 0;
status = sys$qio (EfnNoWait, CgiPlusInChannel,
IO$_READLBLK, &IOsb,
RawLibOnNextRequest, NULL,
SentinalBuffer, sizeof(SentinalBuffer)-1,
0, 0, 0, 0);
if (VMSnok(status)) RawLibExit (NULL, FI_LI, status);
return;
}
else
if (AstFunction)
{
/* modify AST function */
RequestAstFunction = AstFunction;
return;
}
/***************/
/* read stream */
/***************/
if (!CgiPlusInChannel) RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
if (AstFunction) RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
if (IOsb.iosb$w_status && VMSnok(IOsb.iosb$w_status))
RawLibExit (NULL, FI_LI, IOsb.iosb$w_status);
if (!StartSentinal)
{
cptr = SentinalBuffer;
cptr[IOsb.iosb$w_bcnt] = '\0';
/* if the starting sentinal is not detected then ignore */
if (!(*(USHORTPTR)cptr == '!\0' ||
*(USHORTPTR)cptr == '!\n' ||
(*(USHORTPTR)cptr == '!!' && isdigit(*(cptr+2)))))
{
status = sys$qio (EfnNoWait, CgiPlusInChannel,
IO$_READLBLK, &IOsb,
RawLibOnNextRequest, NULL,
SentinalBuffer, sizeof(SentinalBuffer)-1,
0, 0, 0, 0);
if (VMSnok(status)) RawLibExit (NULL, FI_LI, status);
return;
}
StartSentinal = 1;
bcnt = CgiVariablesAvailable = StructBufferLength = 0;
if (*(USHORTPTR)cptr == '!!' && isdigit(*(cptr+2)))
{
/* get the size of the binary structure */
StructBufferLength = atoi(cptr+2);
if (StructBufferLength <= 0)
RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
if (StructBufferLength > StructBufferSize)
{
while (StructBufferLength > StructBufferSize)
StructBufferSize *= 2;
free (StructBufferPtr);
StructBufferPtr = calloc (1, StructBufferSize+2);
if (!StructBufferPtr) RawLibExit (NULL, FI_LI, vaxc$errno);
NextVarNamePtr = StructBufferPtr;
}
CGIplusStruct = 1;
/* drop through to the structure processing code */
}
else
{
/* read the first variable record */
status = sys$qio (EfnNoWait, CgiPlusInChannel,
IO$_READLBLK, &IOsb,
RawLibOnNextRequest, NULL,
StructBufferPtr + SOUS,
StructBufferSize - SOUS,
0, 0, 0, 0);
if (VMSnok(status)) RawLibExit (NULL, FI_LI, status);
CGIplusStruct = 0;
return;
}
}
else
if (CGIplusStruct)
{
cptr = StructBufferPtr + StructBufferLength;
cptr[bcnt = IOsb.iosb$w_bcnt] = '\0';
}
else
{
cptr = StructBufferPtr + StructBufferLength + SOUS;
cptr[bcnt = IOsb.iosb$w_bcnt] = '\0';
}
if (CGIplusStruct)
{
/********************/
/* CGIplus 'struct' */
/********************/
if (bcnt < StructBufferLength)
{
status = sys$qio (EfnNoWait, CgiPlusInChannel,
IO$_READLBLK, &IOsb,
RawLibOnNextRequest, NULL,
StructBufferPtr,
StructBufferLength, 0, 0, 0, 0);
if (VMSnok(status)) RawLibExit (NULL, FI_LI, status);
return;
}
if (bcnt > StructBufferLength)
RawLibExit (NULL, FI_LI, SS$_BUGCHECK);
}
else
{
/*********************/
/* CGIplus 'records' */
/*********************/
/* first empty record terminates variables */
if (bcnt)
{
/* reconstructs the original 'struct'ure from the records */
bptr = StructBufferPtr + StructBufferLength;
/* update the length word */
*(USHORTPTR)bptr = bcnt;
/* terminate with a zero-length entry */
bptr += bcnt + SOUS;
*(USHORTPTR)bptr = 0;
StructBufferLength = bptr - StructBufferPtr;
status = sys$qio (EfnNoWait, CgiPlusInChannel,
IO$_READLBLK, &IOsb,
RawLibOnNextRequest, NULL,
StructBufferPtr + StructBufferLength + SOUS,
StructBufferSize - StructBufferLength - SOUS,
0, 0, 0, 0);
if (VMSnok(status)) RawLibExit (NULL, FI_LI, status);
return;
}
}
/***********************/
/* variables available */
/***********************/
bptr = StructBufferPtr + SOUS;
if (*(ULONGPTR)bptr == 'WWW_') WwwPrefix = 1;
if (!CalloutDone)
{
/* provide the CGI callout to set CGIplus into 'struct' mode */
fflush (stdout);
fputs (CgiPlusEscPtr, stdout);
fflush (stdout);
/* the leading '!' indicates we're not going to read the response */
fputs ("!CGIPLUS: struct", stdout);
fflush (stdout);
fputs (CgiPlusEotPtr, stdout);
fflush (stdout);
/* don't need to do this again */
CalloutDone = 1;
}
CgiVariablesAvailable = 1;
sys$dclast (RequestAstFunction, 0, 0, 0);
/********************************/
/* queue ready for next request */
/********************************/
StartSentinal = 0;
status = sys$qio (EfnNoWait, CgiPlusInChannel,
IO$_READLBLK, &IOsb,
RawLibOnNextRequest, NULL,
SentinalBuffer, sizeof(SentinalBuffer)-1,
0, 0, 0, 0);
if (VMSnok(status)) RawLibExit (NULL, FI_LI, status);
# undef SOUS
}
/*****************************************************************************/