[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]
/*****************************************************************************/
/*
DAVmeta.c
The WASD WebDAV meta-data is used to store lock and 'dead' property data
potentially for each file-system object (file and directory) accessable from
the server using WebDAV. There are three locations used to store meta-data
files, the default and two by global or per-path configuration.
1. the same directory as the resource (default)
2. a specified subdirectory of the resource (e.g. [.^.dav]
3. a completely independent directory (e.g. DKA0:[WASDAV])
Meta-data files are stored using the same name as the resource, with "__wasdav"
concatenated to the file type (note the two underscores). Collection
(directory) meta-data is associated with the directory file (e.g.
A_Directory.DIR__wasdav). This was done for reasons of programmatic
simplicity, file-system efficiency, reducing WebDAV latency and for the
convenience of command-line management of the meta-data files. No specialised
tools are required. All non-WebDAV WASD functionality ignores *.*__wasdav;
files (e.g. directory listing, file GET).
1. Same Directory
A directory listing using the default metadata location (with the resource)
containing two resources with associated meta-data looks something like:
admin.c;1 125KB 3-JAN-2009 06:06:55.46
admin.c__wasdav;1 0.50KB 11-JUN-2009 18:26:27.82
admin.h;1 8KB 17-FEB-2008 15:02:53.32
auth.c;1 142KB 27-APR-2008 08:28:59.21
auth.c__wasdav;1 0.50KB 11-JUN-2009 18:27:17.02
auth.h;1 18KB 29-APR-2009 21:16:31.33
authaccess.c;1 16KB 6-AUG-2007 17:43:51.68
authacme.c;1 24KB 30-APR-2009 06:23:51.94
2. Specified Subdirectory
When meta-data files are stored in a subdirectory (automatically created) of
the resource location the associated files will look like:
admin.c;1 125KB 3-JAN-2009 06:06:55.46
admin.h;1 8KB 17-FEB-2008 15:02:53.32
auth.c;1 142KB 27-APR-2008 08:28:59.21
auth.h;1 18KB 29-APR-2009 21:16:31.33
authaccess.c;1 16KB 6-AUG-2007 17:43:51.68
authacme.c;1 24KB 30-APR-2009 06:23:51.94
[.^.dav]admin.c__wasdav;1 0.50KB 11-JUN-2009 18:26:27.82
[.^.dav]auth.c__wasdav;1 0.50KB 11-JUN-2009 18:27:17.02
Note: The meta-data for a directory is contained in the meta-data subdirectory
contained within that same directory, not in the parent where the directory
file ("whatever.DIR") actually resides, in a nameless file with the type
(extension) ".DIR__wasdav". For example, meta-data for the above directory
would be contained in "[.WHATEVER.^.DAV].DIR__wasdav".
3. Independent Directory
When meta-data files are stored in an independent directory they are
distributed into one of 16 (hexadecimally named, automatically created)
subdirectories. The full file path of the resource is ODS-5 escaped and used
to uniquely identify the meta-data. The above example translated into this
will look something like:
DKA0:[WASDAV.00]wasd_root^:^[src^.httpd^]admin.c__wasdav;1
DKA0:[WASDAV.05]wasd_root^:^[src^.httpd^]auth.c__wasdav;1
Of course this cannot be used within an ODS-2 environment (VAX) or in an
extended-capable environment on an ODS-2 volume.
META-DATA XML
-------------
Meta-data files contain XML. WASD name-space contains zero or more WASD lock
elements and/or zero or more property elements. If there is zero of both (as
might occur after an UNLOCK or PROPPATCH remove, the meta-data file is deleted.
The WASD element also contains the (file-system) resource the meta-data
represents (file or directory specification) and the date/time of the last
update to that meta-data.
The following is an example of this XML structure:
<?xml version="1.0" encoding="UTF-8"?>
<WASDAV:data xmlns:WASD="WASD.WebDAV"
updated="2007-07-23T01:39:11Z">
<WASDAV:lock ...>
...
</WASDAV:lock>
<WASDAV:prop>
...
</WASDAV:prop>
</WASDAV:data>
LOCK META-DATA
--------------
All lock characteristics except the potentially XML-containing owner element
are contained in attributes to the WASD lock element. One or more lock
elements may be present representing compatible locks against the resource.
Example lock meta-data:
<?xml version="1.0" encoding="UTF-8"?>
<WASDAV:data xmlns:WASDAV="WASD.VMS.WebDAV"
updated="2007-07-23T01:39:11Z">
<WASDAV:lock token="urn:uuid:833609C-647F-6BE8-1D27-E38A0FAC75061"
type="write" scope="exclusive" timeout="infinite" depth="0">
<WASDAV:owner><NS:owner xmlns:NS="whatever">blah blah</NS:owner></WASDAV:owner>
</WASDAV:lock>
</WASDAV:data>
PROPERTY META-DATA
------------------
The property elements are stored as-supplied by client. It is presumed that
their XML well-formedness is guaranteed by the original request XML parsing.
For ease of processing (by WASD DAV) each element in a property contains an
'xmlns=""' attribute.
An example of such meta-data generated by a Microsoft Windows (not Internet)
Explorer client (example is intentionally not wrapped):
<?xml version="1.0" encoding="UTF-8"?>
<WASDAV:data xmlns:WASDAV="WASD.VMS.WebDAV"
updated="2007-07-23T01:39:11Z">
<WASDAV:prop>
<NS:Win32CreationTime xmlns:NS="urn:schemas-microsoft-com:">Tue, 26 Jun 2007 02:00:48 GMT</NS:Win32CreationTime>
</WASDAV:prop>
<WASDAV:prop>
<NS:Win32LastAccessTime xmlns:NS="urn:schemas-microsoft-com:">Mon, 23 Jul 2007 01:52:32 GMT</NS:Win32LastAccessTime>
</WASDAV:prop>
<WASDAV:prop>
<NS:Win32LastModifiedTime xmlns:NS="urn:schemas-microsoft-com:">Mon, 23 Jul 2007 01:52:32 GMT</NS:Win32LastModifiedTime>
</WASDAV:prop>
<WASDAV:prop>
<NS:Win32FileAttributes xmlns:NS="urn:schemas-microsoft-com:">00000020</NS:Win32FileAttributes>
</WASDAV:prop>
</WASDAV:data>
VERSION HISTORY
---------------
04-OCT-2020 MGD DavMetaOds() ensure extended syntax only used ODS-5 volumes
24-SEP-2020 MGD bugfix; DavMetaCreateDir() and DavMetaDeleteDir()
allow for non-existant meta data files
bugfix; DavMetaName() no meta directory
03-DEC-2018 MGD bugfix; DavMetaDir() ACCVIO from !SAME2(mfdptr,'[.')
12-SEP-2018 MGD bugfix; significant refactor of locking
06-SEP-2018 MGD bugfix; DavMeta..() explicitly ->ReadOds.DeleteOnClose
17-MAY-2018 MGD DavXmlParserCreate() instead of XML_ParserCreateNS()
09-MAY-2018 MGD bugfix; DavMetaParseXml() detect out-of-memory
01-OCT-2014 MGD directory meta-data goes into its own metadata (sub)directory
27-SEP-2014 MGD bugfix; DavMetaOpenAst() retry after meta directory creation
05-JUL-2014 MGD configurable metadata (sub)directory
07-SEP-2013 MGD bugfix; DavMetaUpdate() abort if SetTimeout() fails
08-JUN-2010 MGD bugfix; DavMetaReadName() and DavMetaWriteName()
allow for typeless file names (e.g. ]AFILE.;)
10-MAY-2010 JPP bugfix; do not set new token when refreshing
02-SEP-2009 MGD bugfix; scanning backwards through extended file spec
31-DEC-2006 MGD initial
*/
/*****************************************************************************/
#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
#include <stdio.h>
#include <ctype.h>
#include <errno.h>
#include <lckdef.h>
#include <libdef.h>
#include "wasd.h"
#include "davweb.h"
#define WASD_MODULE "DAVMETA"
#ifndef WASD_WEBDAV
#define WASD_WEBDAV 1
#endif
#define DAVMETA_READ_CHUNK (512 * 32)
/* just reduce the amount of XML parse noise when WATCHing */
#define WATCH_XML 1
/******************/
/* global storage */
/******************/
/********************/
/* external storage */
/********************/
extern BOOL OdsExtended,
WebDavEnabled,
WebDavLockingEnabled;
extern int EfnWait,
EfnNoWait;
extern int64 HttpdTime64;
extern int ToLowerCase[],
ToUpperCase[];
extern unsigned long SysPrvMask[];
extern char ErrorSanityCheck[],
HttpdSoftwareIdName[],
HttpdVersion[];
extern ACCOUNTING_STRUCT *AccountingPtr;
extern CONFIG_STRUCT Config;
extern LIST_HEAD RequestList;
extern WATCH_STRUCT Watch;
/*****************************************************************************/
/*
Build the data buffer containing the XML formated WASD lock and properties
associated with the resource (file). This can then be written to disk.
The two descriptor collections, 'MetaLockDsc' containing any existing lock
elements, and 'MetaPropDsc', containing any existing property elements are
merged with the lock elements from the request contained in 'XmlLockSetDsc',
and the property elements in 'XmlPropSetDsc'.
The merging is performed by emptying any element of 'MetaLockDsc' or
'MetaPropDsc' that is to be removed, by overwriting any existing element that
is to be set, or appended to the collection any new element, both to
'MetaLockDsc' or 'MetaPropDsc' as required.
*/
int DavMetaBuild (WEBDAV_META *mtaptr)
{
int status,
ItemCount;
char *cptr, *czptr;
char DateTime [32];
STR_DSC *sdptr, *wdptr;
WEBDAV_LOCK *lckptr;
REQUEST_STRUCT *rqptr;
WEBDAV_TASK *tkptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "DavMetaBuild()");
tkptr = rqptr->WebDavTaskPtr;
/*************************/
/* remove/set properties */
/*************************/
StrDscColIfNotBegin (rqptr, &mtaptr->PropDsc, 256);
if (STR_DSC_LEN(&mtaptr->PropDsc))
{
/* remove properties specified in the request XML */
STR_DSC_ITERATE (sdptr, &tkptr->XmlData.PropRemoveDsc)
{
if (!STR_DSC_LEN(sdptr)) continue;
/* advise that DAV properties cannot be removed by clients */
for (czptr = (cptr = STR_DSC_PTR(sdptr)) + STR_DSC_LEN(sdptr);
cptr < czptr && (*cptr != 'x' || !MATCH6(cptr,"xmlns:"));
cptr++);
if (cptr < czptr && MATCH9(cptr+6,"NS=\"DAV:\""))
return (SS$_INCOMPAT);
DavMetaRemove (rqptr, &mtaptr->PropDsc, sdptr);
}
}
if (STR_DSC_LEN(&tkptr->XmlData.PropSetDsc))
{
/* set properties specified in the request XML */
STR_DSC_ITERATE (sdptr, &tkptr->XmlData.PropSetDsc)
{
if (!STR_DSC_LEN(sdptr)) continue;
/* ensure DAV properties are not overridden by (nefarious?) clients */
for (czptr = (cptr = STR_DSC_PTR(sdptr)) + STR_DSC_LEN(sdptr);
cptr < czptr && (*cptr != 'x' || !MATCH6(cptr,"xmlns:"));
cptr++);
if (cptr < czptr && MATCH9(cptr+6,"NS=\"DAV:\""))
return (SS$_INCOMPAT);
DavMetaSet (rqptr, &mtaptr->PropDsc, sdptr);
}
}
if (WATCHING (rqptr, WATCH_WEBDAV))
{
if (STR_DSC_LEN(&mtaptr->LockDsc))
{
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "LOCK built");
STR_DSC_ITERATE (sdptr, &mtaptr->LockDsc)
if (STR_DSC_LEN(sdptr))
WatchDataFormatted ("!AZ\n", STR_DSC_PTR(sdptr));
}
if (STR_DSC_LEN(&mtaptr->PropDsc))
{
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "PROP built");
STR_DSC_ITERATE (sdptr, &mtaptr->PropDsc)
if (STR_DSC_LEN(sdptr))
WatchDataFormatted ("!AZ\n", STR_DSC_PTR(sdptr));
}
}
/******************/
/* build meta XML */
/******************/
/* write will be by block and so must be evenly divisible by 512! */
wdptr = StrDscBegin (rqptr, &mtaptr->WriteDsc, 4096);
ItemCount = 0;
DavWebDateTimeTo3339 (DateTime, &HttpdTime64);
FaoToBuffer (wdptr, -1, NULL,
"<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n\
<WASDAV:data xmlns:WASDAV=\"" WEBDAV_NS_WASDAV "\"\n\
updated=\"!AZ !20%D\">\n",
DateTime, &HttpdTime64);
/* step through each lock in the list generating an XML text equivalent */
LIST_ITERATE (lckptr, &mtaptr->LockList)
{
DavLockXml (rqptr, lckptr, wdptr);
ItemCount++;
}
/* step through each property in the list adding the XML */
STR_DSC_ITERATE (sdptr, &mtaptr->PropDsc)
{
if (!STR_DSC_LEN(sdptr)) continue;
StrDscBuild (wdptr, NULL, "<WASDAV:prop>\n");
StrDscBuild (wdptr, sdptr, NULL);
StrDscNewLine (wdptr);
StrDscBuild (wdptr, NULL, "</WASDAV:prop>\n");
ItemCount++;
}
StrDscBuild (wdptr, NULL, "</WASDAV:data>\n");
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "!&Z", STR_DSC_PTR(wdptr));
if (ItemCount) return (SS$_NORMAL);
/* return this code to indicate the file is empty and should be deleted */
return (SS$_FORGET);
}
/*****************************************************************************/
/*
Add the XML element specified in 'adptr' to the descriptor collection specified
by 'cdptr'. Over-write an existing identical element in the collection.
Returns a pointer to the new (or over-written) element.
*/
STR_DSC* DavMetaSet
(
REQUEST_STRUCT *rqptr,
STR_DSC *cdptr,
STR_DSC *adptr
)
{
STR_DSC *sdptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "DavMetaSet()");
if (sdptr = DavMetaSearch (rqptr, cdptr, adptr))
{
/* overwite existing element */
STR_DSC_LEN(sdptr) = 0;
sdptr = StrDscBuild (sdptr, adptr, NULL);
}
else
sdptr = StrDscBuild (cdptr, adptr, NULL);
STR_DSC_SET_FROZEN(sdptr)
return (sdptr);
}
/*****************************************************************************/
/*
Remove the XML element specified in 'rdptr' from the descriptor collection
specified by 'cdptr'. Returns true if removed, false if not found.
*/
BOOL DavMetaRemove
(
REQUEST_STRUCT *rqptr,
STR_DSC *cdptr,
STR_DSC *rdptr
)
{
STR_DSC *sdptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "DavMetaRemove()");
if (sdptr = DavMetaSearch (rqptr, cdptr, rdptr))
{
STR_DSC_LEN(sdptr) = 0;
return (true);
}
return (false);
}
/*****************************************************************************/
/*
Search the collection specified by 'cdptr' for the element specified by
'edptr'. Return a pointer to the descriptor if found, otherwise return NULL.
*/
STR_DSC* DavMetaSearch
(
REQUEST_STRUCT *rqptr,
STR_DSC *cdptr,
STR_DSC *edptr
)
{
char *cptr, *sptr;
STR_DSC *sdptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "DavMetaSearch()");
if (!cdptr || !edptr) return (NULL);
STR_DSC_ITERATE (sdptr, cdptr)
{
if (!(cptr = STR_DSC_PTR(edptr))) continue;
if (!(sptr = STR_DSC_PTR(sdptr))) continue;
while (*cptr && *sptr && *cptr != '>' && *sptr != '>' && *cptr == *sptr)
{
cptr++;
sptr++;
}
/* if the two elements matched then it's a hit */
if (*cptr == '>' && *sptr == '>') return (sdptr);
}
return (NULL);
}
/*****************************************************************************/
/*
(EXPAT) XML parse the text read from the database file. This will parse the
lock elements into 'MetaLockDsc' and the property elements into 'MetaPropDsc'.
*/
int DavMetaParseXml (WEBDAV_META *mtaptr)
{
int status, xmlsts;
STR_DSC *sdptr;
REQUEST_STRUCT *rqptr;
WEBDAV_LOCK *lckptr;
WEBDAV_TASK *tkptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "DavMetaParseXml()");
sdptr = &mtaptr->ReadDsc;
/* shouldn't be calling this without content to parse! */
if (!(STR_DSC_SANITY(sdptr) && STR_DSC_LEN(sdptr))) return (SS$_BUGCHECK);
tkptr = rqptr->WebDavTaskPtr;
/* successful unless an error is encountered :-) */
status = SS$_NORMAL;
StrDscColIfNotBegin (rqptr, &mtaptr->PropDsc, 256);
mtaptr->ParseData = mtaptr->ParseLock =
mtaptr->ParseLockExpires = mtaptr->ParseLockOwner =
mtaptr->ParseProp = WEBDAV_STATE_NOT_PARSING;
tkptr->XmlData.ParserPtr = DavXmlParserCreate (rqptr);
if (!tkptr->XmlData.ParserPtr) return (vaxc$errno);
mtaptr->ElementDepth = 0;
XML_SetUserData (tkptr->XmlData.ParserPtr, mtaptr);
XML_SetElementHandler (tkptr->XmlData.ParserPtr, DavMetaStartElement,
DavMetaEndElement);
XML_SetCharacterDataHandler (tkptr->XmlData.ParserPtr, DavMetaCharData);
xmlsts = XML_Parse (tkptr->XmlData.ParserPtr,
STR_DSC_PTR(sdptr), STR_DSC_LEN(sdptr), 1);
if (xmlsts == XML_STATUS_ERROR)
{
DavXmlParseError (rqptr, tkptr->XmlData.ParserPtr,
sdptr, &mtaptr->ParseErrorDsc);
if (DavXmlMemoryError (rqptr, tkptr->XmlData.ParserPtr))
status = LIB$_INSVIRMEM;
}
if (tkptr->XmlData.ParserPtr) XML_ParserFree (tkptr->XmlData.ParserPtr);
if (xmlsts == XML_STATUS_ERROR)
{
/* shouldn't be getting parse errors from our own data */
ErrorNoticed (rqptr, status = SS$_BUGCHECK,
STR_DSC_PTR(&mtaptr->ParseErrorDsc), FI_LI);
}
else
{
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
{
if (STR_DSC_LEN(&mtaptr->LockDsc))
{
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "LOCKS current");
STR_DSC_ITERATE (sdptr, &mtaptr->LockDsc)
if (STR_DSC_LEN(sdptr))
WatchDataFormatted ("!AZ\n", STR_DSC_PTR(sdptr));
}
if (STR_DSC_LEN(&mtaptr->PropDsc))
{
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "META current");
STR_DSC_ITERATE (sdptr, &mtaptr->PropDsc)
if (STR_DSC_LEN(sdptr))
WatchDataFormatted ("!AZ\n", STR_DSC_PTR(sdptr));
}
}
}
return (status);
}
/*****************************************************************************/
/*
(EXPAT) This function and DavMetaEndElement() set various flags to indicate the
state of the current XML element. From those various flags indicating
properties to be manipulated are set.
This pretty-much assumes that the parsing library is ensuring document
well-formedness, so the checks on element nesting are very elementary.
*/
void XMLCALL DavMetaStartElement
(
WEBDAV_META *mtaptr,
char *ElementPtr,
char **AttrPtr
)
{
int idx, len, status;
char *cptr, *sptr, *zptr;
char ResourceBuffer [ODS_MAX_FILE_NAME_LENGTH+1];
STR_DSC *sdptr;
STR_DSC_AUTO (ScratchDsc);
REQUEST_STRUCT *rqptr;
WEBDAV_LOCK *lckptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCH_XML && WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaStartElement() !UL !&Z",
mtaptr->ElementDepth+1, ElementPtr);
mtaptr->ElementDepth++;
if (WATCH_XML && WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
{
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "ELEMENT !AZ", ElementPtr);
for (idx = 0; AttrPtr[idx]; idx += 2)
WatchDataFormatted ("!AZ=\"!AZ\"\n", AttrPtr[idx], AttrPtr[idx+1]);
}
sdptr = NULL;
if (WEBDAV_IS_PARSING(mtaptr->ParseLock))
{
/* the most recently added lock will be at the head of the list */
lckptr = LIST_GET_HEAD(&mtaptr->LockList);
if (WEBDAV_IS_PARSING(mtaptr->ParseLockOwner))
sdptr = &lckptr->OwnerDsc;
else
sdptr = &lckptr->LockDsc;
}
else
if (WEBDAV_IS_PARSING(mtaptr->ParseProp))
sdptr = &mtaptr->PropDsc;
if (WEBDAV_IS_WASDAVEL (ElementPtr, "data"))
{
/* should only be the one data element per meta-data file! */
if (WEBDAV_IS_PARSED(mtaptr->ParseData))
{
if (WATCHING (rqptr, WATCH_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV,
"META multiple <WASDAV:data> (ignoring subsequent)");
return;
}
WEBDAV_PARSING(mtaptr->ParseData);
}
else
if (WEBDAV_IS_WASDAVEL (ElementPtr, "lock"))
{
lckptr = (WEBDAV_LOCK*)VmGetHeap (rqptr, sizeof(WEBDAV_LOCK));
ListAddHead (&mtaptr->LockList, lckptr, LIST_ENTRY_TYPE_DAVLOCK);
StrDscColIfNotBegin (rqptr, &lckptr->LockDsc, 256);
StrDscBegin (rqptr, &lckptr->OwnerDsc, 256);
WEBDAV_PARSING(mtaptr->ParseLock);
sdptr = &lckptr->LockDsc;
sdptr = StrDscBuild (sdptr, NULL, "<WASDAV:lock");
for (idx = 0; AttrPtr[idx]; idx += 2)
{
StrDscBuild (sdptr, NULL, " ");
StrDscBuild (sdptr, NULL, AttrPtr[idx]);
StrDscBuild (sdptr, NULL, "=\"");
StrDscBuild (sdptr, NULL, AttrPtr[idx+1]);
StrDscBuild (sdptr, NULL, "\"");
if (WEBDAV_IS_PARSING(mtaptr->ParseLock) &&
!WEBDAV_IS_PARSING(mtaptr->ParseLockOwner))
{
if (!strcmp (AttrPtr[idx], "depth"))
{
if (!strcmp (AttrPtr[idx+1], "0"))
lckptr->Depth = WEBDAV_DEPTH_ZERO;
else
if (!strcmp (AttrPtr[idx+1], "1"))
lckptr->Depth = WEBDAV_DEPTH_ONE;
else
if (!strcmp (AttrPtr[idx+1], "infinity"))
lckptr->Depth = WEBDAV_DEPTH_INFINITY;
else
ErrorNoticed (rqptr, SS$_BUGCHECK, AttrPtr[idx+1], FI_LI);
}
else
if (!strcmp (AttrPtr[idx], "expires"))
{
zptr = (sptr = lckptr->ExpiresString) +
sizeof(lckptr->ExpiresString)-1;
for (cptr = AttrPtr[idx+1];
*cptr && sptr < zptr;
*sptr++ = *cptr++);
if (sptr < zptr)
{
*sptr = '\0';
status = DavWebDateTimeFrom3339 (lckptr->ExpiresString,
&lckptr->ExpiresTime64);
if (VMSnok (status))
ErrorNoticed (rqptr, status, AttrPtr[idx+1], FI_LI);
}
else
{
lckptr->ExpiresTime64 = 0;
lckptr->ExpiresString[0] = '\0';
ErrorNoticed (rqptr, SS$_BUGCHECK, AttrPtr[idx+1], FI_LI);
}
}
else
if (!strcmp (AttrPtr[idx], "token"))
{
zptr = (sptr = lckptr->TokenString) +
sizeof(lckptr->TokenString);
for (cptr = AttrPtr[idx+1];
*cptr && sptr < zptr;
*sptr++ = *cptr++);
if (sptr < zptr)
*sptr = '\0';
else
{
lckptr->TokenString[0] = '\0';
ErrorNoticed (rqptr, SS$_BUGCHECK, AttrPtr[idx+1], FI_LI);
}
}
else
if (!strcmp (AttrPtr[idx], "type"))
{
if (!strcmp (AttrPtr[idx+1], "write"))
lckptr->Type = WEBDAV_LOCK_TYPE_WRITE;
else
ErrorNoticed (rqptr, SS$_BUGCHECK, AttrPtr[idx+1], FI_LI);
}
else
if (!strcmp (AttrPtr[idx], "scope"))
{
if (!strcmp (AttrPtr[idx+1], "exclusive"))
lckptr->Scope = WEBDAV_LOCK_SCOPE_EXCLUSIVE;
else
if (!strcmp (AttrPtr[idx+1], "shared"))
lckptr->Scope = WEBDAV_LOCK_SCOPE_SHARED;
else
ErrorNoticed (rqptr, SS$_BUGCHECK, AttrPtr[idx+1], FI_LI);
}
else
if (!strcmp (AttrPtr[idx], "timeout"))
{
if (!strcmp (AttrPtr[idx+1], "infinite"))
{
lckptr->Timeout = WEBDAV_TIMEOUT_INFINITE;
strcpy (lckptr->TimeoutString, "infinite");
}
else
if (!strncmp (AttrPtr[idx+1], "Second-", 7) &&
isdigit(AttrPtr[idx+1][7]))
{
lckptr->Timeout = atoi(AttrPtr[idx+1]+7);
sprintf (lckptr->TimeoutString, "Second-%d", lckptr->Timeout);
}
else
ErrorNoticed (rqptr, SS$_BUGCHECK, AttrPtr[idx+1], FI_LI);
}
}
}
StrDscBuild (sdptr, NULL, ">\n");
sdptr = NULL;
}
else
if (WEBDAV_IS_WASDAVEL (ElementPtr, "owner"))
{
if (WEBDAV_IS_PARSING(mtaptr->ParseLock))
WEBDAV_PARSING(mtaptr->ParseLockOwner);
else
ErrorNoticed (rqptr, SS$_BUGCHECK, ErrorSanityCheck, FI_LI);
}
else
if (WEBDAV_IS_WASDAVEL (ElementPtr, "prop"))
WEBDAV_PARSING(mtaptr->ParseProp);
if (sdptr)
{
for (cptr = ElementPtr; *cptr && *cptr != ' '; cptr++);
sdptr = StrDscBuild (sdptr, NULL, "<NS:");
StrDscBuild (sdptr, NULL, cptr+1);
for (idx = 0; AttrPtr[idx]; idx += 2)
{
StrDscBuild (sdptr, NULL, " ");
StrDscBuild (sdptr, NULL, AttrPtr[idx]);
StrDscBuild (sdptr, NULL, "=\"");
StrDscBuild (sdptr, NULL, AttrPtr[idx+1]);
StrDscBuild (sdptr, NULL, "\"");
}
StrDscBuild (sdptr, NULL, " xmlns:NS=\"");
StrDscThis (NULL, &ScratchDsc, ElementPtr, cptr - ElementPtr);
StrDscBuild (sdptr, &ScratchDsc, NULL);
StrDscBuild (sdptr, NULL, "\">");
WEBDAV_PARSING(mtaptr->ParseCharData);
}
else
WEBDAV_NOT_PARSING(mtaptr->ParseCharData);
}
/*****************************************************************************/
/*
(EXPAT) This function and DavMetaStartElement() set various flags to indicate
the state of the current XML element.
*/
void XMLCALL DavMetaEndElement
(
WEBDAV_META *mtaptr,
char *ElementPtr
)
{
char *cptr, *sptr;
STR_DSC *sdptr;
STR_DSC_AUTO (ScratchDsc);
REQUEST_STRUCT *rqptr;
WEBDAV_LOCK *lckptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCH_XML && WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaEndElement() !UL !&Z",
mtaptr->ElementDepth, ElementPtr);
if (!WEBDAV_IS_PARSING(mtaptr->ParseData)) return;
if (WEBDAV_IS_PARSING(mtaptr->ParseLock))
{
if (WEBDAV_IS_WASDAVEL (ElementPtr, "lock"))
{
/* no longer parsing the lock, freeze current content */
WEBDAV_PARSED(mtaptr->ParseLock);
/* the most recently added lock will be at the head of the list */
lckptr = LIST_GET_HEAD(&mtaptr->LockList);
sdptr = &lckptr->LockDsc;
sdptr = StrDscBuild (sdptr, NULL, "</WASDAV:lock>");
StrDscTailFrozen (&lckptr->LockDsc);
}
else
if (WEBDAV_IS_WASDAVEL (ElementPtr, "owner"))
WEBDAV_PARSED(mtaptr->ParseLockOwner);
}
else
if (WEBDAV_IS_PARSING(mtaptr->ParseProp))
{
if (WEBDAV_IS_WASDAVEL (ElementPtr, "prop"))
{
/* no longer parsing this property, freeze current content */
WEBDAV_PARSED(mtaptr->ParseProp);
StrDscTailFrozen (&mtaptr->PropDsc);
}
}
else
/* as this is the level 0 element it MUST be the last checked! */
if (WEBDAV_IS_PARSING(mtaptr->ParseData))
{
if (WEBDAV_IS_WASDAVEL (ElementPtr, "data"))
WEBDAV_PARSED(mtaptr->ParseData);
}
sdptr = NULL;
if (WEBDAV_IS_PARSING(mtaptr->ParseLock))
{
/* the most recently added lock will be at the head of the list */
lckptr = LIST_GET_HEAD(&mtaptr->LockList);
if (WEBDAV_IS_PARSING(mtaptr->ParseLockOwner))
sdptr = &lckptr->OwnerDsc;
else
sdptr = &lckptr->LockDsc;
}
else
if (WEBDAV_IS_PARSING(mtaptr->ParseProp))
sdptr = &mtaptr->PropDsc;
if (sdptr)
{
for (cptr = ElementPtr; *cptr && *cptr != ' '; cptr++);
sdptr = StrDscBuild (sdptr, NULL, "</NS:");
StrDscBuild (sdptr, NULL, cptr+1);
StrDscBuild (sdptr, NULL, ">");
if (mtaptr->ElementDepth == 3)
{
if (WEBDAV_IS_PARSING(mtaptr->ParseProp))
{
/* end of this property, freeze current content */
STR_DSC_SET_FROZEN (sdptr)
}
WEBDAV_NOT_PARSING(mtaptr->ParseCharData);
}
else
WEBDAV_PARSING(mtaptr->ParseCharData);
}
else
WEBDAV_NOT_PARSING(mtaptr->ParseCharData);
if (mtaptr->ElementDepth) mtaptr->ElementDepth--;
}
/*****************************************************************************/
/*
(EXPAT) XML character data.
*/
void XMLCALL DavMetaCharData
(
WEBDAV_META *mtaptr,
XML_Char *DataPtr,
int DataLength
)
{
STR_DSC *sdptr;
STR_DSC_AUTO (CharDataDsc);
REQUEST_STRUCT *rqptr;
WEBDAV_LOCK *lckptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCH_XML && WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaCharData() !&B !UL |!#AZ",
mtaptr->ParseCharData, DataLength, DataLength, DataPtr);
if (!WEBDAV_IS_PARSING(mtaptr->ParseCharData)) return;
sdptr = NULL;
if (WEBDAV_IS_PARSING(mtaptr->ParseLock))
{
/* the most recently added lock will be at the head of the list */
lckptr = LIST_GET_HEAD(&mtaptr->LockList);
if (WEBDAV_IS_PARSING(mtaptr->ParseLockOwner))
sdptr = &lckptr->OwnerDsc;
else
sdptr = &lckptr->LockDsc;
}
else
if (WEBDAV_IS_PARSING(mtaptr->ParseProp))
sdptr = &mtaptr->PropDsc;
if (!sdptr) return;
StrDscThis (NULL, &CharDataDsc, DataPtr, DataLength);
StrDscBuild (sdptr, &CharDataDsc, NULL);
}
/*****************************************************************************/
/*
Generate the name of the meta-data file. If ReadWrite is 'r' then it generates
the read metadata filename. If 'w' then the write name.
*/
DavMetaName
(
WEBDAV_META *mtaptr,
char *FileSpec,
int ReadWrite
)
{
static char HexDigits [] = "0123456789ABCDEF";
int status,
BufferLength;
unsigned long BufferHash [4];
char *aptr, *cptr, *sptr, *zptr,
*BufferPtr,
*FilePtr,
*HexPtr;
REQUEST_STRUCT *rqptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaName() !&Z !&C", FileSpec, ReadWrite);
if (ReadWrite == 'r')
zptr = (sptr = mtaptr->ReadMetaName) + sizeof(mtaptr->ReadMetaName);
else
if (ReadWrite == 'w')
zptr = (sptr = mtaptr->WriteMetaName) + sizeof(mtaptr->WriteMetaName);
else
ErrorExitVmsStatus (SS$_BUGCHECK, ErrorSanityCheck, FI_LI);
zptr -= 3;
BufferPtr = FilePtr = sptr;
mtaptr->MetaDirNamePtr = NULL;
mtaptr->MetaDirNameLength = 0;
HexPtr = NULL;
if (mtaptr->TaskPtr->MetaFileDirPtr &&
SAME2(mtaptr->TaskPtr->MetaFileDirPtr,'[.'))
{
/****************/
/* subdirectory */
/****************/
/* subdirectory of file directory (e.g. "[.^.DAV]", "[.WHATEVER]") */
for (cptr = FileSpec;
*cptr && (*cptr != ']' || SAME2(cptr-1,'^]') || SAME2(cptr,']['))
&& sptr < zptr;
cptr++)
{
if (SAME2(cptr,']['))
cptr++;
else
*sptr++ = TOLO(*cptr);
}
if (*cptr == ']')
{
/* if the file type is ".DIR" then turn it into an effective ']' */
for (aptr = cptr; *aptr; aptr++);
while (aptr > cptr && (*aptr != '.' || SAME2(aptr-1,'^.'))) aptr--;
if (*aptr == '.' &&
(MATCH5(aptr,".DIR;") || MATCH5(aptr,".DIR") ||
MATCH5(aptr,".dir;") || MATCH5(aptr,".dir")))
{
/* insert the file name as part of the directory structure */
if (sptr < zptr) *sptr++ = '.';
for (cptr++; cptr < aptr && sptr < zptr; *sptr++ = *cptr++);
/* no (file) name anymore */
cptr = "";
}
/* insert the metadata subdirectory */
for (aptr = mtaptr->TaskPtr->MetaFileDirPtr+1;
*aptr && sptr < zptr;
*sptr++ = TOLO(*aptr++));
mtaptr->MetaDirNamePtr = BufferPtr;
mtaptr->MetaDirNameLength = sptr - BufferPtr;
/* append the file name and type */
for (cptr++; *cptr; *sptr++ = TOLO(*cptr++));
}
}
else
if (mtaptr->TaskPtr->MetaFileDirPtr)
{
/******************/
/* meta directory */
/******************/
/* independent metadata directory (e.g. "DKA0:[WASDAV_META]" */
for (cptr = mtaptr->TaskPtr->MetaFileDirPtr;
*cptr && sptr < zptr;
*sptr++ = TOLO(*cptr++));
*(sptr-1) = '.';
HexPtr = sptr;
*sptr++ = '0';
*sptr++ = '0';
*sptr++ = ']';
mtaptr->MetaDirNamePtr = BufferPtr;
mtaptr->MetaDirNameLength = sptr - BufferPtr;
/* hash is generated excluding the metadata directory */
FilePtr = sptr;
for (cptr = FileSpec; *cptr && sptr < zptr; *sptr++ = TOLO(*cptr++))
{
if ((*cptr == ':' && !SAME2(cptr-1,'^:')) ||
(*cptr == '[' && !SAME2(cptr-1,'^[')) ||
(*cptr == ']' && !SAME2(cptr-1,'^]')) ||
(*cptr == '.' && !SAME2(cptr-1,'^.')))
{
*sptr++ = '^';
if (*cptr == ']' && *(cptr+1) != '[') break;
}
}
while (*cptr && sptr < zptr) *sptr++ = TOLO(*cptr++);
}
else
{
/******************/
/* same directory */
/******************/
/* same directory as resource */
for (cptr = FileSpec; *cptr && sptr < zptr; *sptr++ = TOLO(*cptr++));
}
*sptr = '\0';
/**********************/
/* check ODS extended */
/**********************/
for (cptr = BufferPtr; *cptr && *cptr != '^'; cptr++);
/* if uses extended syntax */
if (*cptr)
if (DavMetaOds (BufferPtr) != 5)
{
/* disable the use of this meta-data file name */
*BufferPtr = '*';
ErrorNoticed (rqptr, SS$_NOTF11ODS5, FileSpec, FI_LI);
}
/************/
/* sentinal */
/************/
while (sptr > BufferPtr &&
(*sptr != ';' || SAME2(sptr-1,'^;')) &&
(*sptr != '.' || SAME2(sptr-1,'^.')) &&
(*sptr != ']' || SAME2(sptr-1,'^]'))) sptr--;
if (*sptr == ']')
{
while (*sptr) sptr++;
if (*(sptr-1) != ']' && !SAME2(sptr-2,'^]') && sptr < zptr)
*sptr++ = '.';
}
else
if (*sptr != ';')
while (*sptr) sptr++;
*sptr = '\0';
if (*(sptr-1) == ']')
{
/* special case - meta-data for a directory - no file name plus this */
for (cptr = ".DIR__wasdav"; *cptr && sptr < zptr; *sptr++ = *cptr++);
mtaptr->MetaForDir = true;
}
else
{
if (!mtaptr->TaskPtr->MetaFileDirPtr ||
!mtaptr->TaskPtr->MetaFileDirPtr[0])
{
/* in the subdirectory not the current directory */
if (sptr > BufferPtr-4 && (MATCH5(sptr-4,".DIR") ||
MATCH5(sptr-4,".dir")))
{
sptr -= 4;
*sptr-- = ']';
while (sptr > BufferPtr && *sptr != ']') sptr--;
*sptr++ = '.';
while (*sptr != ']') sptr++;
sptr++;
for (cptr = ".dir"; *cptr && sptr < zptr; *sptr++ = *cptr++);
}
}
/* append the WASD WebDAV sentinal to the current file type */
for (cptr = "__wasdav"; *cptr && sptr < zptr; *sptr++ = *cptr++);
}
*sptr = '\0';
BufferLength = sptr - BufferPtr;
if (sptr >= zptr)
{
/* disable the use of this meta-data file name */
*BufferPtr = '*';
ErrorNoticed (rqptr, SS$_BUFFEROVF, FileSpec, FI_LI);
}
/******************/
/* digest for DLM */
/******************/
Md5Digest (FilePtr, BufferLength-(FilePtr-BufferPtr), BufferHash);
if (HexPtr)
{
/* seamless expansion from 16 to 256 subdirectories (!) if necessary */
/** HexPtr[0] = HexDigits[BufferHash[0] & 0xf0]; **/
HexPtr[1] = HexDigits[BufferHash[0] & 0x0f];
}
if (ReadWrite == 'r')
{
mtaptr->ReadMetaNameLength = BufferLength;
mtaptr->ReadHash[0] = BufferHash[0];
mtaptr->ReadHash[1] = BufferHash[1];
mtaptr->ReadHash[2] = BufferHash[2];
mtaptr->ReadHash[3] = BufferHash[3];
}
else
{
mtaptr->WriteMetaNameLength = BufferLength;
mtaptr->WriteHash[0] = BufferHash[0];
mtaptr->WriteHash[1] = BufferHash[1];
mtaptr->WriteHash[2] = BufferHash[2];
mtaptr->WriteHash[3] = BufferHash[3];
}
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "!&Z !8XL!8XL!8XL!8XL",
BufferPtr, BufferHash[0], BufferHash[1],
BufferHash[2], BufferHash[3]);
}
/*****************************************************************************/
/*
Cache the ODS for individual device meta data.
The ODS integer (2 or 5) is stored as the first byte preceding the string.
*/
int DavMetaOds (char *FileSpec)
{
static int VolOdsCount;
static char VolOds [WEBDAV_META_VOLODS][65];
int idx, ods;
char *cptr, *sptr, *zptr;
/*********/
/* begin */
/*********/
#if WATCH_MOD
WatchThis (WATCHALL, WATCH_MOD_WEBDAV, "DavMetaOds() !&Z", FileSpec);
#endif
for (idx = 0; idx < VolOdsCount; idx++)
{
cptr = FileSpec;
sptr = VolOds[idx];
ods = *sptr++;
while (*cptr && *cptr != ':' && *sptr && *sptr != ':')
{
if (*cptr != *sptr) break;
cptr++;
sptr++;
}
#if WATCH_MOD
WatchThis (WATCHALL, WATCH_MOD_WEBDAV,
"[!UL] !UL !&Z", idx, (uchar)VolOds[idx][0], VolOds[idx]+1);
#endif
/* if hit */
if (*cptr == *sptr) return (ods);
}
sys$setprv (1, &SysPrvMask, 0, 0);
ods = OdsVolumeStructure (FileSpec);
sys$setprv (0, &SysPrvMask, 0, 0);
if (VolOdsCount >= WEBDAV_META_VOLODS)
{
VolOdsCount = 0;
ErrorNoticed (NULL, 0, "VolOds[] overflow", FI_LI);
}
idx = VolOdsCount++;
zptr = (sptr = VolOds[idx]) + sizeof(VolOds[idx])-1;
*sptr++ = ods;
for (cptr = FileSpec;
*cptr && *cptr != ':' && sptr < zptr;
*sptr++ = *cptr++);
*sptr++ = ':';
*sptr = '\0';
#if WATCH_MOD
WatchThis (WATCHALL, WATCH_MOD_WEBDAV,
"[!UL] !UL !&Z", idx, (uchar)VolOds[idx][0], VolOds[idx]+1);
#endif
return (ods);
}
/*****************************************************************************/
/*
Attempt to read a meta-data file corresponding to the file name provided in the
parameter. We're not sure whether such a meta-data file exists at this stage
so it might just end up a file-not-found at the AST.
*/
DavMetaRead
(
REQUEST_STRUCT *rqptr,
WEBDAV_META *mtaptr,
char *FileSpec,
REQUEST_AST AstFunction,
unsigned long AstParam
)
{
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaRead() !&Z", FileSpec);
InstanceGblSecIncrLong (&AccountingPtr->WebDavMetaReadAttemptCount);
/* dispose of dynamic buffers from any previous call */
StrDscEnd (&mtaptr->ReadDsc, FI_LI);
memset (mtaptr, 0, sizeof(WEBDAV_META));
mtaptr->RequestPtr = rqptr;
mtaptr->TaskPtr = rqptr->WebDavTaskPtr;
DavMetaName (mtaptr, FileSpec, 'r');
mtaptr->UpdateLocked = false;
mtaptr->ReadAstFunction = AstFunction;
mtaptr->ReadAstParam = AstParam;
DavWebDlmEnqueue (rqptr, &mtaptr->DlmData, mtaptr->ReadMetaName,
&mtaptr->ReadHash, false, false, DavMetaReadOpen, mtaptr);
}
/*****************************************************************************/
/*
AST from VMS lock enqueue attempt.
*/
DavMetaReadOpen (WEBDAV_META *mtaptr)
{
REQUEST_STRUCT *rqptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "DavMetaReadOpen() !UL !&Z",
mtaptr->ReadMetaNameLength, mtaptr->ReadMetaName);
mtaptr->VmsStatus = mtaptr->DlmData.LockSb.lksb$w_status;
if (VMSnok (mtaptr->VmsStatus))
{
/* VMS DLM enqueue failed, explicitly call any AST */
if (WATCHING (rqptr, WATCH_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "META read !AZ !&S",
mtaptr->ReadMetaName, mtaptr->VmsStatus);
SysDclAst (mtaptr->ReadAstFunction, mtaptr->ReadAstParam);
return;
}
/* turn on SYSPRV to allow access to the file */
sys$setprv (1, &SysPrvMask, 0, 0);
OdsOpen (&mtaptr->ReadOds,
mtaptr->ReadMetaName, mtaptr->ReadMetaNameLength, NULL, 0,
FAB$M_GET + FAB$M_BIO, 0, FAB$M_SHRGET,
&DavMetaOpenAst, mtaptr);
sys$setprv (0, &SysPrvMask, 0, 0);
}
/*****************************************************************************/
/*
Set up the meta-data creation attributes then queue an exclusive VMS LDM lock
on the meta-data hash. When granted this VMS DLM lock *queues* and blocks all
subsequent requests to modify the meta-data (and hence represented resource)
for the duration of the VMS DLM lock.
*/
DavMetaLock
(
REQUEST_STRUCT *rqptr,
WEBDAV_META *mtaptr,
char *FileSpec,
REQUEST_AST AstFunction,
unsigned long AstParam
)
{
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaLock() !&Z", FileSpec);
InstanceGblSecIncrLong (&AccountingPtr->WebDavMetaReadAttemptCount);
/* dispose of dynamic buffers from any previous call */
StrDscEnd (&mtaptr->ReadDsc, FI_LI);
memset (mtaptr, 0, sizeof(WEBDAV_META));
mtaptr->RequestPtr = rqptr;
mtaptr->TaskPtr = rqptr->WebDavTaskPtr;
DavMetaName (mtaptr, FileSpec, 'r');
mtaptr->UpdateLocked = true;
mtaptr->ReadAstFunction = AstFunction;
mtaptr->ReadAstParam = AstParam;
DavWebDlmEnqueue (rqptr, &mtaptr->DlmData, mtaptr->ReadMetaName,
&mtaptr->ReadHash, true, false, DavMetaLockAst, mtaptr);
}
/*****************************************************************************/
/*
Check the VMS DLM status value for success or failure. If failed then just
queue the AST with the status code set. For success, open a file for exclusive
access. Create it if it does not already exist. We're not sure whether such a
meta-data file exists at this stage so it might just end up a file-not-found at
the AST.
*/
DavMetaLockAst (WEBDAV_META *mtaptr)
{
REQUEST_STRUCT *rqptr;
WEBDAV_DLM *dlmptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "DavMetaLockAst()");
dlmptr = &mtaptr->DlmData;
mtaptr->VmsStatus = dlmptr->LockSb.lksb$w_status;
if (VMSnok (mtaptr->VmsStatus))
{
/* VMS DLM enqueue failed, explicitly call any AST */
if (WATCHING (rqptr, WATCH_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "META read !AZ !&S",
mtaptr->ReadMetaName, mtaptr->VmsStatus);
SysDclAst (mtaptr->ReadAstFunction, mtaptr->ReadAstParam);
return;
}
/* turn on SYSPRV to allow access to the file */
sys$setprv (1, &SysPrvMask, 0, 0);
OdsCreate (&mtaptr->ReadOds,
mtaptr->ReadMetaName, mtaptr->ReadMetaNameLength, NULL, 0,
FAB$M_PUT + FAB$M_GET + FAB$M_BIO + FAB$M_TRN,
FAB$M_CIF + FAB$M_TEF,
FAB$M_NIL, FAB$C_STMLF, FAB$M_CR, NULL,
&DavMetaOpenAst, mtaptr);
sys$setprv (0, &SysPrvMask, 0, 0);
}
/*****************************************************************************/
/*
If the open fails (for any reason, including file-not-found) explicitly call
the AST function. If the open succeeds allocate a dynamic buffer the same
size of the file and $READ that as blocks (if larger than a possible single
$READ) from the file call DavMetaReadAst() when complete.
*/
DavMetaOpenAst (WEBDAV_META *mtaptr)
{
int status;
REQUEST_STRUCT *rqptr;
WEBDAV_DLM *dlmptr;
WEBDAV_TASK *tkptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaOpenAst() !&S", mtaptr->ReadOds.Fab.fab$l_sts);
tkptr = rqptr->WebDavTaskPtr;
dlmptr = &mtaptr->DlmData;
if (VMSok (mtaptr->VmsStatus = mtaptr->ReadOds.Fab.fab$l_sts) &&
(mtaptr->ReadOds.Fab.fab$b_rfm == FAB$C_VAR ||
mtaptr->ReadOds.Fab.fab$b_rfm == FAB$C_VFC))
{
if (WATCHING (rqptr, WATCH_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV,
"META ***** MUST BE STREAM-LF FORMAT!! *****");
mtaptr->VmsStatus = SS$_ABORT;
}
if (VMSnok(mtaptr->VmsStatus))
{
if (mtaptr->MetaDirNameLength &&
mtaptr->VmsStatus == RMS$_DNF &&
/* meta-file directory created only when opened for write */
(mtaptr->ReadOds.Fab.fab$b_fac & FAB$M_PUT) &&
!mtaptr->MetaDirCreate)
{
DavMetaCreateDir (mtaptr);
/* retry the access (just the once) */
mtaptr->MetaDirCreate = true;
DavMetaLockAst (mtaptr);
return;
}
/* open failed, explicitly call any AST */
if (mtaptr->VmsStatus != RMS$_FNF || mtaptr->VmsStatus != RMS$_DNF)
if (WATCHING (rqptr, WATCH_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV,
"META read open !AZ !&S",
mtaptr->ReadMetaName,
mtaptr->VmsStatus);
mtaptr->UpdateLocked = false;
DavWebDequeue (&mtaptr->DlmData);
SysDclAst (mtaptr->ReadAstFunction, mtaptr->ReadAstParam);
return;
}
mtaptr->ReadOds.Rab = cc$rms_rab;
mtaptr->ReadOds.Rab.rab$l_fab = &mtaptr->ReadOds.Fab;
status = sys$connect (&mtaptr->ReadOds.Rab, 0, 0);
if (VMSnok (status))
ErrorNoticed (rqptr, status, mtaptr->ReadOds.ExpFileName, FI_LI);
mtaptr->ReadOds.Rab.rab$l_ctx = mtaptr;
mtaptr->ReadOds.Rab.rab$l_sts = mtaptr->ReadOds.Rab.rab$l_stv = 0;
if (mtaptr->VmsStatus == RMS$_CREATED)
{
/* if newly created, obviously nothing to read - fake the status */
mtaptr->MetaCreated = true;
mtaptr->ReadOds.Rab.rab$l_sts = RMS$_EOF;
mtaptr->ReadOds.DeleteOnClose = true;
SysDclAst (mtaptr->ReadAstFunction, mtaptr->ReadAstParam);
return;
}
/* access to the meta data was successful */
InstanceGblSecIncrLong (&AccountingPtr->WebDavMetaReadCount);
DavMetaReadAst (&mtaptr->ReadOds.Rab);
}
/*****************************************************************************/
/*
Create the metadata directory using lib$create_dir()!
*/
int DavMetaCreateDir (WEBDAV_META *mtaptr)
{
/* ensure SYSPRV can control the directory */
static unsigned short ProtEnable = 0x000f,
ProtValue = 0x0000; /* S:RWED */
static $DESCRIPTOR (DirNameDsc, "");
int status;
char ch;
REQUEST_STRUCT *rqptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaCreateDir() !UL !#AZ",
mtaptr->MetaDirNameLength, mtaptr->MetaDirNameLength,
mtaptr->MetaDirNamePtr);
if (!mtaptr->MetaDirNameLength) return (SS$_NORMAL);
ch = mtaptr->MetaDirNamePtr[mtaptr->MetaDirNameLength];
mtaptr->MetaDirNamePtr[mtaptr->MetaDirNameLength] = '\0';
DirNameDsc.dsc$a_pointer = mtaptr->MetaDirNamePtr;
DirNameDsc.dsc$w_length = mtaptr->MetaDirNameLength;
AuthAccessEnable (rqptr, DirNameDsc.dsc$a_pointer, AUTH_ACCESS_WRITE);
status = lib$create_dir (&DirNameDsc, 0, &ProtEnable, &ProtValue, 0, 0);
AuthAccessEnable (rqptr, 0, 0);
if (WATCHING (rqptr, WATCH_WEBDAV))
if (status == SS$_NORMAL)
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "META EXISTS !AZ",
mtaptr->MetaDirNamePtr);
else
if (status == SS$_CREATED)
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "META CREATED !AZ",
mtaptr->MetaDirNamePtr);
else
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "META FAILED !AZ !&S",
mtaptr->MetaDirNamePtr, status);
mtaptr->MetaDirNamePtr[mtaptr->MetaDirNameLength] = ch;
return (status);
}
/*****************************************************************************/
/*
Delete a metadata directory (allowed only if it is empty of course!)
It is intended to be used during WebDAV DELETE operations. When deleting a
directory file this function should be called to proactively delete any
[WebDavMetaDir] specified metadata directory file prior to trying to delete the
directory file itself.
*/
int DavMetaDeleteDir (WEBDAV_META *mtaptr)
{
int status,
DirFileNameLength;
char ch;
char DirFileName [ODS_MAX_FILE_NAME_LENGTH+1];
REQUEST_STRUCT *rqptr;
ODS_STRUCT DeleteOds;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaDeleteDir() !UL !#AZ",
mtaptr->MetaDirNameLength, mtaptr->MetaDirNameLength,
mtaptr->MetaDirNamePtr);
if (!mtaptr->MetaDirNameLength) return (SS$_NORMAL);
ch = mtaptr->MetaDirNamePtr[mtaptr->MetaDirNameLength];
mtaptr->MetaDirNamePtr[mtaptr->MetaDirNameLength] = '\0';
OdsNameOfDirectoryFile (mtaptr->MetaDirNamePtr,
mtaptr->MetaDirNameLength,
DirFileName, &DirFileNameLength);
mtaptr->MetaDirNamePtr[mtaptr->MetaDirNameLength] = ch;
OdsStructInit (&DeleteOds, true);
OdsParse (&DeleteOds, DirFileName, DirFileNameLength,
NULL, 0, NAM$M_SYNCHK, NULL, rqptr);
/* only if it is a metadata subdirectory */
if (DavMetaDir (rqptr, &DeleteOds))
{
if (VMSok (status = DeleteOds.Fab.fab$l_sts))
{
DeleteOds.NamVersionPtr[0] = '\0';
sys$setprv (1, &SysPrvMask, 0, 0);
status = sys$erase (&DeleteOds.Fab, 0, 0);
sys$setprv (0, &SysPrvMask, 0, 0);
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"sys$erase() !&Z !&S", DeleteOds.ExpFileName, status);
if (VMSnok (status) &&
status != RMS$_MKD &&
status != SS$_DIRNOTEMPTY)
ErrorNoticed (rqptr, status, DeleteOds.ExpFileName, FI_LI);
}
}
OdsParseRelease (&DeleteOds);
return (status);
}
/*****************************************************************************/
/*
The asynchronous $READ has completed. Check the status and the proportion of
the file read. If another $READ is required then queue that. Once the file
has been completely read, or at an error status, call the AST function.
*/
DavMetaReadAst (struct RAB *RabPtr)
{
int status,
BucketNumber,
SizeInBytes;
REQUEST_STRUCT *rqptr;
WEBDAV_LOCK *lckptr;
WEBDAV_META *mtaptr;
WEBDAV_TASK *tkptr;
/*********/
/* begin */
/*********/
mtaptr = RabPtr->rab$l_ctx;
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaReadAst() sts:!&X stv:!&X rsz:!UL",
RabPtr->rab$l_sts, RabPtr->rab$l_stv, RabPtr->rab$w_rsz);
tkptr = rqptr->WebDavTaskPtr;
if (mtaptr->ReadOds.Rab.rab$l_sts)
{
/*******************/
/* subsequent read */
/*******************/
mtaptr->VmsStatus = mtaptr->ReadOds.Rab.rab$l_sts;
if (VMSok (mtaptr->VmsStatus))
{
STR_DSC_LEN(&mtaptr->ReadDsc) += RabPtr->rab$w_rsz;
/* artifically generate an EOF as we've got all there is to get */
if (STR_DSC_LEN(&mtaptr->ReadDsc) >= STR_DSC_SIZE(&mtaptr->ReadDsc))
mtaptr->VmsStatus = RMS$_EOF;
}
}
else
{
/****************/
/* initial read */
/****************/
if (mtaptr->ReadOds.XabFhc.xab$l_ebk <= 1)
SizeInBytes = mtaptr->ReadOds.XabFhc.xab$w_ffb;
else
SizeInBytes = ((mtaptr->ReadOds.XabFhc.xab$l_ebk-1) << 9) +
mtaptr->ReadOds.XabFhc.xab$w_ffb;
/* unlikely to be legitimate meta-data if less than this */
if (SizeInBytes < 128)
{
/* can happen if the server exits without closing RMS$M_DLT files */
mtaptr->VmsStatus = SS$_ENDOFFILE;
}
else
{
StrDscBegin (rqptr, &mtaptr->ReadDsc, SizeInBytes);
/* asynchronous block $READs */
mtaptr->ReadOds.Rab.rab$l_rop = RAB$M_BIO | RAB$M_ASY;
mtaptr->VmsStatus = SS$_NORMAL;
}
}
if (VMSok (mtaptr->VmsStatus))
{
/*************/
/* read more */
/*************/
SizeInBytes = STR_DSC_SIZE(&mtaptr->ReadDsc) -
STR_DSC_LEN(&mtaptr->ReadDsc);
if (SizeInBytes > DAVMETA_READ_CHUNK) SizeInBytes = DAVMETA_READ_CHUNK;
BucketNumber = (STR_DSC_LEN(&mtaptr->ReadDsc) / 512) + 1;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV, "!UL-!UL=!UL !UL !UL",
STR_DSC_SIZE(&mtaptr->ReadDsc),
STR_DSC_LEN(&mtaptr->ReadDsc),
STR_DSC_SIZE(&mtaptr->ReadDsc) -
STR_DSC_LEN(&mtaptr->ReadDsc),
BucketNumber, SizeInBytes);
mtaptr->ReadOds.Rab.rab$l_ubf = STR_DSC_PTR(&mtaptr->ReadDsc) +
STR_DSC_LEN(&mtaptr->ReadDsc);
mtaptr->ReadOds.Rab.rab$w_usz = SizeInBytes;
mtaptr->ReadOds.Rab.rab$l_bkt = BucketNumber;
sys$read (&mtaptr->ReadOds.Rab, &DavMetaReadAst, &DavMetaReadAst);
return;
}
/*****************/
/* read finished */
/*****************/
/* if we retrieved the entire file then that's a good thing! */
if (mtaptr->VmsStatus == RMS$_EOF) mtaptr->VmsStatus = SS$_NORMAL;
if (WATCHING (rqptr, WATCH_WEBDAV))
{
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "META read !AZ !&S",
mtaptr->ReadOds.ExpFileName, mtaptr->VmsStatus);
if (VMSok(mtaptr->VmsStatus))
if (STR_DSC_LEN(&mtaptr->ReadDsc))
WatchDataFormatted ("!#AZ", STR_DSC_LEN(&mtaptr->ReadDsc),
STR_DSC_PTR(&mtaptr->ReadDsc));
}
if (VMSnok (mtaptr->VmsStatus))
{
/*******/
/* nbg */
/*******/
/* a fatal error so ensure the metadata file is deleted */
mtaptr->ReadOds.DeleteOnClose = true;
status = OdsClose (&mtaptr->ReadOds, NULL, NULL);
}
else
{
/*********/
/* parse */
/*********/
if (!mtaptr->UpdateLocked)
{
/* do NOT modify any meta newly SS$_CREATED setting */
status = OdsClose (&mtaptr->ReadOds, NULL, NULL);
if (VMSnok (status))
ErrorNoticed (rqptr, status, mtaptr->ReadMetaName, FI_LI);
}
mtaptr->VmsStatus = DavMetaParseXml (mtaptr);
if (VMSok (mtaptr->VmsStatus)) DavLockPreProcess (rqptr);
}
if (!mtaptr->UpdateLocked && !mtaptr->CopyLocked)
DavWebDequeue (&mtaptr->DlmData);
SysDclAst (mtaptr->ReadAstFunction, mtaptr->ReadAstParam);
}
/*****************************************************************************/
/*
The file has been opened for write exclusively locked by DavMetaRead(). If it
was an existing meta-data file the content can be updated or if it was created
the content can be 'updated' for the first time. If there are no properties
data to be written to the file then flag it for delete-on-close and close the
file, otherwise build a buffer of the properties data and queue an asynchronous
$WRITE.
*/
DavMetaUpdate
(
WEBDAV_META *mtaptr,
REQUEST_AST AstFunction,
unsigned long AstParam
)
{
int status,
MaxKbytes,
PropCount,
SizeInBytes;
STR_DSC *sdptr;
REQUEST_STRUCT *rqptr;
WEBDAV_LOCK *lckptr;
WEBDAV_TASK *tkptr;
/*********/
/* begin */
/*********/
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaUpdate() !&S", mtaptr->VmsStatus);
tkptr = rqptr->WebDavTaskPtr;
mtaptr->UpdateAstFunction = AstFunction;
mtaptr->UpdateAstParam = AstParam;
if (VMSnok (mtaptr->VmsStatus)) goto DavMetaUpdateAbort;
lckptr = NULL;
if (rqptr->rqHeader.Method == HTTP_METHOD_WEBDAV_LOCK)
{
/********/
/* lock */
/********/
/* if the request didn't supply complete lock data */
if (!(tkptr->LockData.Type && tkptr->LockData.Scope))
{
DavWebResponse (rqptr, 412, 0, "LOCK type/scope undefined", FI_LI);
goto DavMetaUpdateAbort;
}
/* search for an existing exclusive lock that matches an If: token */
if (lckptr = DavLockFindIf (rqptr, WEBDAV_LOCK_SCOPE_EXCLUSIVE))
if (lckptr == NOTPTR)
goto DavMetaUpdateAbort;
/* if DavLockFindIf() returned lock then it's an update */
if (lckptr)
{
/* check existing lock compatibility */
if (!(lckptr->Type == WEBDAV_LOCK_SCOPE_SHARED &&
tkptr->LockData.Type == WEBDAV_LOCK_SCOPE_SHARED))
{
DavWebResponse (rqptr, 412, 0, "LOCKS incomapatible", FI_LI);
goto DavMetaUpdateAbort;
}
}
else
{
/* new lock - add it to the list and generate a token */
ListAddHead (&mtaptr->LockList, lckptr = &tkptr->LockData,
LIST_ENTRY_TYPE_DAVLOCK);
DavLockSetUrnUuidToken (rqptr, lckptr);
mtaptr->LockCreated = true;
}
/* set or update (existing lock) the timeout value */
if (DavLockSetTimeout (rqptr, lckptr)) goto DavMetaUpdateAbort;
}
else
if (rqptr->rqHeader.Method == HTTP_METHOD_WEBDAV_UNLOCK)
{
/**********/
/* unlock */
/**********/
/* must be an existing lock */
lckptr = DavLockFindToken (rqptr);
if (!lckptr || lckptr == NOTPTR) goto DavMetaUpdateAbort;
/* simply remove the lock from the list */
ListRemove (&mtaptr->LockList, lckptr);
}
else
{
/******************/
/* something else */
/******************/
if (!mtaptr->MetaCreated)
{
/* if existing metadata */
if (lckptr = DavLockFindIf (rqptr, WEBDAV_LOCK_SCOPE_EXCLUSIVE))
if (lckptr == NOTPTR)
{
mtaptr->VmsStatus = SS$_ACCONFLICT;
goto DavMetaUpdateAbort;
}
/* if didn't return an exclusive lock look for a shared one */
if (!lckptr)
if (lckptr = DavLockFindIf (rqptr, WEBDAV_LOCK_SCOPE_SHARED))
if (lckptr == NOTPTR)
{
mtaptr->VmsStatus = SS$_ACCONFLICT;
goto DavMetaUpdateAbort;
}
}
}
/*******************/
/* build meta-data */
/*******************/
status = DavMetaBuild (mtaptr);
if (status == SS$_INCOMPAT)
{
/**********************/
/* forbidden metadata */
/**********************/
DavWebResponse (rqptr, 403, 0, "cannot patch property", FI_LI);
tkptr->MetaData.VmsStatus = status;
goto DavMetaUpdateAbort;
}
if (VMSnok(status) || status == SS$_FORGET)
{
/********************/
/* delete meta-data */
/********************/
tkptr->MetaData.VmsStatus = status;
mtaptr->ReadOds.DeleteOnClose = true;
goto DavMetaUpdateAbort;
}
/*******************/
/* limit meta size */
/*******************/
/* to something reasonable (say 1/32 of the maximum PUTable) */
SizeInBytes = 0;
for (sdptr = &mtaptr->WriteDsc; sdptr; sdptr = STR_DSC_NEXT(sdptr))
SizeInBytes += STR_DSC_LEN(sdptr);
if (!(MaxKbytes = rqptr->rqPathSet.PutMaxKbytes))
MaxKbytes = Config.cfMisc.PutMaxKbytes;
if ((SizeInBytes >> 10) > (MaxKbytes >> 5))
{
DavWebResponse (rqptr, 412, 0, "META too large", FI_LI);
mtaptr->ReadOds.DeleteOnClose = true;
goto DavMetaUpdateAbort;
}
/********************/
/* set up the write */
/********************/
mtaptr->ReadOds.Rab.rab$l_ctx = mtaptr;
mtaptr->ReadOds.Rab.rab$l_sts = mtaptr->ReadOds.Rab.rab$l_stv = 0;
DavMetaUpdateWrite (&mtaptr->ReadOds.Rab);
return;
DavMetaUpdateAbort:
{
/********************/
/* abort the update */
/********************/
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaUpdateAbort() !&B !&S",
mtaptr->ReadOds.DeleteOnClose, mtaptr->VmsStatus);
if (mtaptr->VmsStatus != SS$_FORGET &&
mtaptr->VmsStatus != SS$_INCOMPAT &&
mtaptr->VmsStatus != SS$_ACCONFLICT) mtaptr->VmsStatus = SS$_ABORT;
status = OdsClose (&mtaptr->ReadOds, NULL, NULL);
if (VMSnok (status))
ErrorNoticed (rqptr, status, mtaptr->ReadMetaName, FI_LI);
DavWebDequeue (&mtaptr->DlmData);
SysDclAst (mtaptr->UpdateAstFunction, mtaptr->UpdateAstParam);
}
}
/*****************************************************************************/
/*
This function queues $WRITEs of the meta-data and acts as it's own AST,
assessing the status of the previous write and queuing then next, if required.
When the write has completed (successfully or unsuccessfully) the
'MetaUpdateAstFunction' is called which should (as always) check 'MetaStatus'.
*/
DavMetaUpdateWrite (struct RAB *RabPtr)
{
int status;
REQUEST_STRUCT *rqptr;
STR_DSC *sdptr;
WEBDAV_META *mtaptr;
WEBDAV_TASK *tkptr;
/*********/
/* begin */
/*********/
mtaptr = RabPtr->rab$l_ctx;
rqptr = mtaptr->RequestPtr;
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaUpdateWrite() sts:!&S stv:!&S",
RabPtr->rab$l_sts, RabPtr->rab$l_stv);
tkptr = rqptr->WebDavTaskPtr;
if (mtaptr->ReadOds.Rab.rab$l_sts)
{
/********************/
/* subsequent write */
/********************/
status = mtaptr->VmsStatus = mtaptr->ReadOds.Rab.rab$l_sts;
if (VMSnok (status))
{
if (WATCHING (rqptr, WATCH_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "META update !AZ !&S",
mtaptr->ReadMetaName, status);
ErrorNoticed (rqptr, status, mtaptr->ReadMetaName, FI_LI);
/* a fatal error so ensure the metadata file is deleted */
mtaptr->ReadOds.DeleteOnClose = true;
status = OdsClose (&mtaptr->ReadOds, NULL, NULL);
if (VMSnok (status))
ErrorNoticed (rqptr, status, mtaptr->ReadMetaName, FI_LI);
DavWebDequeue (&mtaptr->DlmData);
SysDclAst (mtaptr->UpdateAstFunction, mtaptr->UpdateAstParam);
return;
}
}
else
{
/*****************/
/* initial write */
/*****************/
InstanceGblSecIncrLong (&AccountingPtr->WebDavMetaWriteAttemptCount);
/* check the data is acceptable for $WRITE */
for (sdptr = &mtaptr->WriteDsc; sdptr; sdptr = STR_DSC_NEXT(sdptr))
{
/* all but the last descriptor must be a full block */
if (STR_DSC_LEN(sdptr) > 0xffff ||
(STR_DSC_NEXT(sdptr) && STR_DSC_LEN(sdptr) % 512))
{
mtaptr->VmsStatus = SS$_BUGCHECK;
ErrorNoticed (rqptr, SS$_BUGCHECK, ErrorSanityCheck, FI_LI);
/* a fatal error so ensure the metadata file is deleted */
mtaptr->ReadOds.DeleteOnClose = true;
status = OdsClose (&mtaptr->ReadOds, NULL, NULL);
if (VMSnok (status))
ErrorNoticed (rqptr, status, mtaptr->ReadMetaName, FI_LI);
DavWebDequeue (&mtaptr->DlmData);
SysDclAst (mtaptr->UpdateAstFunction, mtaptr->UpdateAstParam);
return;
}
}
mtaptr->RabBucket = 1;
mtaptr->ReadOds.Rab.rab$l_rop = RAB$M_BIO | RAB$M_ASY | RAB$M_TPT;
}
/* find the next descriptor to be written */
for (sdptr = &mtaptr->WriteDsc; sdptr; sdptr = STR_DSC_NEXT(sdptr))
if (!STR_DSC_IS_NOTED(sdptr)) break;
if (!sdptr)
{
/***************/
/* end of data */
/***************/
if (WATCHING (rqptr, WATCH_WEBDAV))
{
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV, "META update !AZ !&S",
mtaptr->ReadOds.ExpFileName, SS$_NORMAL);
if (STR_DSC_LEN(&mtaptr->WriteDsc))
WatchDataFormatted ("!#AZ", STR_DSC_LEN(&mtaptr->WriteDsc),
STR_DSC_PTR(&mtaptr->WriteDsc));
}
mtaptr->VmsStatus = SS$_NORMAL;
/* success so need to undo any meta newly SS$_CREATED */
mtaptr->ReadOds.DeleteOnClose = false;
status = OdsClose (&mtaptr->ReadOds, NULL, NULL);
if (VMSok (status))
InstanceGblSecIncrLong (&AccountingPtr->WebDavMetaWriteCount);
else
ErrorNoticed (rqptr, status, mtaptr->ReadMetaName, FI_LI);
DavWebDequeue (&mtaptr->DlmData);
SysDclAst (mtaptr->UpdateAstFunction, mtaptr->UpdateAstParam);
return;
}
/**************/
/* write data */
/**************/
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"rsz: !UL", STR_DSC_LEN(sdptr));
mtaptr->ReadOds.Rab.rab$l_rbf = STR_DSC_PTR(sdptr);
mtaptr->ReadOds.Rab.rab$w_rsz = STR_DSC_LEN(sdptr);
mtaptr->ReadOds.Rab.rab$l_bkt = mtaptr->RabBucket;
mtaptr->RabBucket += STR_DSC_LEN(sdptr) / 512;
STR_DSC_SET_NOTED(sdptr)
sys$write (&mtaptr->ReadOds.Rab, &DavMetaUpdateWrite,
&DavMetaUpdateWrite);
}
/*****************************************************************************/
/*
WASD files containing WebDAV metadata have the same name with "__wasdav"
appended to the file type. Return true if the supplied file complies.
*/
BOOL DavMetaFile (ODS_STRUCT *odsptr)
{
/*********/
/* begin */
/*********/
if (WATCH_MODULE (WATCH_MOD_WEBDAV))
WatchThis (WATCHALL, WATCH_MOD_WEBDAV,
"DavMetaFile() !&Z", odsptr->NamDevicePtr);
if (odsptr->NamTypeLength < 8) return (false);
if (MATCH8 (odsptr->NamVersionPtr-8, "__wasdav")) return (true);
if (MATCH8 (odsptr->NamVersionPtr-8, "__WASDAV")) return (true);
return (false);
}
/*****************************************************************************/
/*
Return true if this specification is the meta-subdirectory or contains a
metadata subdirectory anywhere in the directory structure, and false if it
doesn't. If the metadata subdirectory is for example "[.meta]" then match
"[meta]", "[meta.", ".meta]" and "[.meta.", or if "[.^.dav]" then this function
must match file specifications containing "[^.dav]", "[^.dav.", ".^.dav." and
".^.dav]".
*/
BOOL DavMetaDir
(
REQUEST_STRUCT *rqptr,
ODS_STRUCT *odsptr
)
{
char *cptr, *mfdptr, *sptr, *zptr;
WEBDAV_TASK *tkptr;
/*********/
/* begin */
/*********/
if (WATCHMOD (rqptr, WATCH_MOD_WEBDAV))
WatchThis (WATCHITM(rqptr), WATCH_MOD_WEBDAV,
"DavMetaDir() !&Z", odsptr->NamDevicePtr);
if (tkptr = rqptr->WebDavTaskPtr)
mfdptr = tkptr->MetaFileDirPtr;
else
if (rqptr->rqPathSet.WebDavMetaDirPtr)
mfdptr = rqptr->rqPathSet.WebDavMetaDirPtr;
else
if (Config.cfWebDav.MetaFileDirectoryLength)
mfdptr = Config.cfWebDav.MetaFileDirectory;
else
return (false);
if (!mfdptr) return (false);
if (!SAME2(mfdptr,'[.')) return (false);
/* first check if it is the directory file itself */
cptr = odsptr->NamNamePtr;
sptr = mfdptr + 2;
if (MATCH2(cptr,sptr))
{
while (*cptr && *cptr != '.' && (TOLO(*cptr) == TOLO(*sptr)))
{
if (*cptr == '^' && *(cptr+1)) cptr++;
if (*sptr == '^' && *(sptr+1)) sptr++;
cptr++;
sptr++;
}
if (*cptr == '.' && *sptr == ']' &&
(MATCH5(cptr,".DIR;") || MATCH5(cptr,".dir;") ||
MATCH5(cptr,".DIR") || MATCH5(cptr,".dir")))
{
if (WATCHING (rqptr, WATCH_THIS))
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV,
"METADATA !AZ", odsptr->NamNamePtr);
return (true);
}
}
/* then check if directory name occurs anywhere in the specification */
for (cptr = odsptr->NamDirectoryPtr; *cptr; cptr++)
{
if (*cptr == '^')
{
/* absorb escaped characters */
if (*++cptr) cptr++;
continue;
}
if (*cptr == ']')
{
/* if concealed continue otherwise end of directory */
if (SAME3(cptr,'][.'))
cptr += 2;
else
break;
}
else
if (!(*cptr == '[' || *cptr == '.'))
/* just another non-significant character */
continue;
/* beginning of a directory */
cptr++;
sptr = mfdptr + 2;
while (*cptr && *cptr != '.' && *cptr != ']' &&
(TOLO(*cptr) == TOLO(*sptr)))
{
if (*cptr == '^' && *(cptr+1)) cptr++;
if (*sptr == '^' && *(sptr+1)) sptr++;
cptr++;
sptr++;
}
/* if it matched the meta directory */
if ((*cptr == ']' || *cptr == '.') && *sptr == ']')
{
if (WATCHING (rqptr, WATCH_THIS))
WatchThis (WATCHITM(rqptr), WATCH_WEBDAV,
"METADATA !AZ CONTAINS !AZ",
odsptr->NamDirectoryPtr, mfdptr);
return (true);
}
/* span to the end of the directory */
while (*cptr)
{
if (*cptr == '^')
{
if (*++cptr) cptr++;
continue;
}
if (*(cptr+1) == '.' || *(cptr+1) == ']') break;
cptr++;
}
}
return (false);
}
/*****************************************************************************/