Lines Matching refs:i
163 int nWndNodes, nRodNodes, i, nodeNum, asmNum; in rf_CommonCreateLargeWriteDAG() local
188 i = 0; in rf_CommonCreateLargeWriteDAG()
189 wndNodes = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
190 i += nWndNodes; in rf_CommonCreateLargeWriteDAG()
191 xorNode = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
192 i += 1; in rf_CommonCreateLargeWriteDAG()
193 wnpNode = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
194 i += 1; in rf_CommonCreateLargeWriteDAG()
195 blockNode = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
196 i += 1; in rf_CommonCreateLargeWriteDAG()
197 commitNode = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
198 i += 1; in rf_CommonCreateLargeWriteDAG()
199 termNode = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
200 i += 1; in rf_CommonCreateLargeWriteDAG()
202 wnqNode = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
203 i += 1; in rf_CommonCreateLargeWriteDAG()
258 for (i = 0; i < nWndNodes; i++) { in rf_CommonCreateLargeWriteDAG()
259 rf_InitNode(&wndNodes[i], rf_wait, RF_FALSE, rf_DiskWriteFunc, in rf_CommonCreateLargeWriteDAG()
263 wndNodes[i].params[0].p = pda; in rf_CommonCreateLargeWriteDAG()
264 wndNodes[i].params[1].p = pda->bufPtr; in rf_CommonCreateLargeWriteDAG()
265 wndNodes[i].params[2].v = parityStripeID; in rf_CommonCreateLargeWriteDAG()
266 wndNodes[i].params[3].v = in rf_CommonCreateLargeWriteDAG()
284 for (i = 0; i < nWndNodes; i++) { in rf_CommonCreateLargeWriteDAG()
285 xorNode->params[2 * i + 0] = in rf_CommonCreateLargeWriteDAG()
286 wndNodes[i].params[0]; /* pda */ in rf_CommonCreateLargeWriteDAG()
287 xorNode->params[2 * i + 1] = in rf_CommonCreateLargeWriteDAG()
288 wndNodes[i].params[1]; /* buf ptr */ in rf_CommonCreateLargeWriteDAG()
290 for (i = 0; i < nRodNodes; i++) { in rf_CommonCreateLargeWriteDAG()
291 xorNode->params[2 * (nWndNodes + i) + 0] = in rf_CommonCreateLargeWriteDAG()
292 rodNodes[i].params[0]; /* pda */ in rf_CommonCreateLargeWriteDAG()
293 xorNode->params[2 * (nWndNodes + i) + 1] = in rf_CommonCreateLargeWriteDAG()
294 rodNodes[i].params[1]; /* buf ptr */ in rf_CommonCreateLargeWriteDAG()
306 for (i = 0; i < nRodNodes; i++) { in rf_CommonCreateLargeWriteDAG()
307 if (((RF_PhysDiskAddr_t *) rodNodes[i].params[0].p) in rf_CommonCreateLargeWriteDAG()
312 if ((!allowBufferRecycle) || (i == nRodNodes)) { in rf_CommonCreateLargeWriteDAG()
318 xorNode->results[0] = rodNodes[i].params[1].p; in rf_CommonCreateLargeWriteDAG()
367 for (i = 0; i < nRodNodes; i++) { in rf_CommonCreateLargeWriteDAG()
368 RF_ASSERT(rodNodes[i].numAntecedents == 1); in rf_CommonCreateLargeWriteDAG()
369 blockNode->succedents[i] = &rodNodes[i]; in rf_CommonCreateLargeWriteDAG()
370 rodNodes[i].antecedents[0] = blockNode; in rf_CommonCreateLargeWriteDAG()
371 rodNodes[i].antType[0] = rf_control; in rf_CommonCreateLargeWriteDAG()
374 RF_ASSERT(rodNodes[i].numSuccedents == 1); in rf_CommonCreateLargeWriteDAG()
375 rodNodes[i].succedents[0] = xorNode; in rf_CommonCreateLargeWriteDAG()
376 xorNode->antecedents[i] = &rodNodes[i]; in rf_CommonCreateLargeWriteDAG()
377 xorNode->antType[i] = rf_trueData; in rf_CommonCreateLargeWriteDAG()
397 for (i = 0; i < nWndNodes; i++) { in rf_CommonCreateLargeWriteDAG()
399 commitNode->succedents[i] = &wndNodes[i]; in rf_CommonCreateLargeWriteDAG()
400 wndNodes[i].antecedents[0] = commitNode; in rf_CommonCreateLargeWriteDAG()
401 wndNodes[i].antType[0] = rf_control; in rf_CommonCreateLargeWriteDAG()
416 for (i = 0; i < nWndNodes; i++) { in rf_CommonCreateLargeWriteDAG()
418 wndNodes[i].succedents[0] = termNode; in rf_CommonCreateLargeWriteDAG()
419 termNode->antecedents[i] = &wndNodes[i]; in rf_CommonCreateLargeWriteDAG()
420 termNode->antType[i] = rf_control; in rf_CommonCreateLargeWriteDAG()
475 int i, j, nNodes, totalNumNodes, lu_flag; in rf_CommonCreateSmallWriteDAG() local
534 i = 0; in rf_CommonCreateSmallWriteDAG()
535 blockNode = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
536 i += 1; in rf_CommonCreateSmallWriteDAG()
537 commitNode = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
538 i += 1; in rf_CommonCreateSmallWriteDAG()
539 readDataNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
540 i += numDataNodes; in rf_CommonCreateSmallWriteDAG()
541 readParityNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
542 i += numParityNodes; in rf_CommonCreateSmallWriteDAG()
543 writeDataNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
544 i += numDataNodes; in rf_CommonCreateSmallWriteDAG()
545 writeParityNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
546 i += numParityNodes; in rf_CommonCreateSmallWriteDAG()
547 xorNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
548 i += numParityNodes; in rf_CommonCreateSmallWriteDAG()
549 termNode = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
550 i += 1; in rf_CommonCreateSmallWriteDAG()
552 unlockDataNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
553 i += numDataNodes; in rf_CommonCreateSmallWriteDAG()
554 unlockParityNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
555 i += numParityNodes; in rf_CommonCreateSmallWriteDAG()
560 readQNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
561 i += numParityNodes; in rf_CommonCreateSmallWriteDAG()
562 writeQNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
563 i += numParityNodes; in rf_CommonCreateSmallWriteDAG()
564 qNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
565 i += numParityNodes; in rf_CommonCreateSmallWriteDAG()
567 unlockQNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
568 i += numParityNodes; in rf_CommonCreateSmallWriteDAG()
575 RF_ASSERT(i == totalNumNodes); in rf_CommonCreateSmallWriteDAG()
597 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
598 rf_InitNode(&readDataNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
604 readDataNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
606 readDataNodes[i].params[1].p = rf_AllocBuffer(raidPtr, in rf_CommonCreateSmallWriteDAG()
608 readDataNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAG()
609 readDataNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAG()
613 for (j = 0; j < readDataNodes[i].numSuccedents; j++) { in rf_CommonCreateSmallWriteDAG()
614 readDataNodes[i].propList[j] = NULL; in rf_CommonCreateSmallWriteDAG()
620 i = 0; in rf_CommonCreateSmallWriteDAG()
621 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
623 rf_InitNode(&readParityNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
626 readParityNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
628 readParityNodes[i].params[1].p = rf_AllocBuffer(raidPtr, in rf_CommonCreateSmallWriteDAG()
630 readParityNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAG()
631 readParityNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAG()
635 for (j = 0; j < readParityNodes[i].numSuccedents; j++) { in rf_CommonCreateSmallWriteDAG()
636 readParityNodes[i].propList[0] = NULL; in rf_CommonCreateSmallWriteDAG()
643 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
645 rf_InitNode(&readQNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
649 readQNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
651 readQNodes[i].params[1].p = rf_AllocBuffer(raidPtr, in rf_CommonCreateSmallWriteDAG()
653 readQNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAG()
654 readQNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAG()
658 for (j = 0; j < readQNodes[i].numSuccedents; j++) { in rf_CommonCreateSmallWriteDAG()
659 readQNodes[i].propList[0] = NULL; in rf_CommonCreateSmallWriteDAG()
665 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
667 rf_InitNode(&writeDataNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
672 writeDataNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
674 writeDataNodes[i].params[1].p = pda->bufPtr; in rf_CommonCreateSmallWriteDAG()
675 writeDataNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAG()
676 writeDataNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAG()
680 rf_InitNode(&unlockDataNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
685 unlockDataNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
686 unlockDataNodes[i].params[1].v = in rf_CommonCreateSmallWriteDAG()
736 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
738 rf_InitNode(&xorNodes[i], rf_wait, RF_FALSE, func, in rf_CommonCreateSmallWriteDAG()
741 xorNodes[i].flags |= RF_DAGNODE_FLAG_YIELD; in rf_CommonCreateSmallWriteDAG()
742 xorNodes[i].params[0] = readDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAG()
743 xorNodes[i].params[1] = readDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAG()
744 xorNodes[i].params[2] = readParityNodes[i].params[0]; in rf_CommonCreateSmallWriteDAG()
745 xorNodes[i].params[3] = readParityNodes[i].params[1]; in rf_CommonCreateSmallWriteDAG()
746 xorNodes[i].params[4] = writeDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAG()
747 xorNodes[i].params[5] = writeDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAG()
748 xorNodes[i].params[6].p = raidPtr; in rf_CommonCreateSmallWriteDAG()
750 xorNodes[i].results[0] = readParityNodes[i].params[1].p; in rf_CommonCreateSmallWriteDAG()
753 rf_InitNode(&qNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
757 qNodes[i].params[0] = in rf_CommonCreateSmallWriteDAG()
758 readDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAG()
759 qNodes[i].params[1] = in rf_CommonCreateSmallWriteDAG()
760 readDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAG()
761 qNodes[i].params[2] = readQNodes[i].params[0]; in rf_CommonCreateSmallWriteDAG()
762 qNodes[i].params[3] = readQNodes[i].params[1]; in rf_CommonCreateSmallWriteDAG()
763 qNodes[i].params[4] = in rf_CommonCreateSmallWriteDAG()
764 writeDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAG()
765 qNodes[i].params[5] = in rf_CommonCreateSmallWriteDAG()
766 writeDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAG()
767 qNodes[i].params[6].p = raidPtr; in rf_CommonCreateSmallWriteDAG()
769 qNodes[i].results[0] = in rf_CommonCreateSmallWriteDAG()
770 readQNodes[i].params[1].p; in rf_CommonCreateSmallWriteDAG()
780 for (i = 0; i < numDataNodes + 1; i++) { in rf_CommonCreateSmallWriteDAG()
782 xorNodes[0].params[2 * i + 0] = in rf_CommonCreateSmallWriteDAG()
783 readDataNodes[i].params[0]; /* pda */ in rf_CommonCreateSmallWriteDAG()
784 xorNodes[0].params[2 * i + 1] = in rf_CommonCreateSmallWriteDAG()
785 readDataNodes[i].params[1]; /* buffer ptr */ in rf_CommonCreateSmallWriteDAG()
787 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
789 xorNodes[0].params[2 * (numDataNodes + 1 + i) + 0] = in rf_CommonCreateSmallWriteDAG()
790 writeDataNodes[i].params[0]; /* pda */ in rf_CommonCreateSmallWriteDAG()
791 xorNodes[0].params[2 * (numDataNodes + 1 + i) + 1] = in rf_CommonCreateSmallWriteDAG()
792 writeDataNodes[i].params[1]; /* buffer ptr */ in rf_CommonCreateSmallWriteDAG()
803 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
805 qNodes[0].params[2 * i + 0] = in rf_CommonCreateSmallWriteDAG()
806 readDataNodes[i].params[0]; /* pda */ in rf_CommonCreateSmallWriteDAG()
807 qNodes[0].params[2 * i + 1] = in rf_CommonCreateSmallWriteDAG()
808 readDataNodes[i].params[1]; /* buffer ptr */ in rf_CommonCreateSmallWriteDAG()
815 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
818 [2 * (numDataNodes + 1 + i) + 0] = in rf_CommonCreateSmallWriteDAG()
820 writeDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAG()
822 [2 * (numDataNodes + 1 + i) + 1] = in rf_CommonCreateSmallWriteDAG()
824 writeDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAG()
835 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
836 rf_InitNode(&writeParityNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
842 writeParityNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
844 writeParityNodes[i].params[1].p = xorNodes[i].results[0]; in rf_CommonCreateSmallWriteDAG()
845 writeParityNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAG()
846 writeParityNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAG()
850 rf_InitNode(&unlockParityNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
855 unlockParityNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
856 unlockParityNodes[i].params[1].v = in rf_CommonCreateSmallWriteDAG()
866 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
867 rf_InitNode(&writeQNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAG()
873 writeQNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
874 writeQNodes[i].params[1].p = qNodes[i].results[0]; in rf_CommonCreateSmallWriteDAG()
876 writeQNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAG()
877 writeQNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAG()
882 rf_InitNode(&unlockQNodes[i], rf_wait, in rf_CommonCreateSmallWriteDAG()
888 unlockQNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAG()
889 unlockQNodes[i].params[1].v = in rf_CommonCreateSmallWriteDAG()
906 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
907 blockNode->succedents[i] = &readDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
908 RF_ASSERT(readDataNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
909 readDataNodes[i].antecedents[0] = blockNode; in rf_CommonCreateSmallWriteDAG()
910 readDataNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAG()
914 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
915 blockNode->succedents[numDataNodes + i] = &readParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
916 RF_ASSERT(readParityNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
917 readParityNodes[i].antecedents[0] = blockNode; in rf_CommonCreateSmallWriteDAG()
918 readParityNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAG()
923 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
924 blockNode->succedents[numDataNodes + numParityNodes + i] in rf_CommonCreateSmallWriteDAG()
925 = &readQNodes[i]; in rf_CommonCreateSmallWriteDAG()
926 RF_ASSERT(readQNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
927 readQNodes[i].antecedents[0] = blockNode; in rf_CommonCreateSmallWriteDAG()
928 readQNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAG()
932 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
933 RF_ASSERT(readDataNodes[i].numSuccedents == in rf_CommonCreateSmallWriteDAG()
938 readDataNodes[i].succedents[j] = &xorNodes[j]; in rf_CommonCreateSmallWriteDAG()
939 xorNodes[j].antecedents[i] = &readDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
940 xorNodes[j].antType[i] = rf_trueData; in rf_CommonCreateSmallWriteDAG()
946 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
950 readDataNodes[i].succedents[numParityNodes + j] in rf_CommonCreateSmallWriteDAG()
952 qNodes[j].antecedents[i] = &readDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
953 qNodes[j].antType[i] = rf_trueData; in rf_CommonCreateSmallWriteDAG()
958 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
959 RF_ASSERT(readParityNodes[i].numSuccedents == numParityNodes); in rf_CommonCreateSmallWriteDAG()
961 readParityNodes[i].succedents[j] = &xorNodes[j]; in rf_CommonCreateSmallWriteDAG()
962 xorNodes[j].antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
963 &readParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
964 xorNodes[j].antType[numDataNodes + i] = rf_trueData; in rf_CommonCreateSmallWriteDAG()
970 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
971 RF_ASSERT(readParityNodes[i].numSuccedents == in rf_CommonCreateSmallWriteDAG()
974 readQNodes[i].succedents[j] = &qNodes[j]; in rf_CommonCreateSmallWriteDAG()
975 qNodes[j].antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
976 &readQNodes[i]; in rf_CommonCreateSmallWriteDAG()
977 qNodes[j].antType[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
984 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
985 RF_ASSERT(xorNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
986 xorNodes[i].succedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
987 commitNode->antecedents[i] = &xorNodes[i]; in rf_CommonCreateSmallWriteDAG()
988 commitNode->antType[i] = rf_control; in rf_CommonCreateSmallWriteDAG()
993 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
994 RF_ASSERT(qNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
995 qNodes[i].succedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
996 commitNode->antecedents[i + numParityNodes] = in rf_CommonCreateSmallWriteDAG()
997 &qNodes[i]; in rf_CommonCreateSmallWriteDAG()
998 commitNode->antType[i + numParityNodes] = rf_control; in rf_CommonCreateSmallWriteDAG()
1004 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
1005 RF_ASSERT(writeDataNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
1006 commitNode->succedents[i] = &writeDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
1007 writeDataNodes[i].antecedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
1008 writeDataNodes[i].antType[0] = rf_trueData; in rf_CommonCreateSmallWriteDAG()
1010 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
1011 RF_ASSERT(writeParityNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
1012 commitNode->succedents[i + numDataNodes] = &writeParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
1013 writeParityNodes[i].antecedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
1014 writeParityNodes[i].antType[0] = rf_trueData; in rf_CommonCreateSmallWriteDAG()
1017 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
1018 RF_ASSERT(writeQNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
1020 [i + numDataNodes + numParityNodes] = in rf_CommonCreateSmallWriteDAG()
1021 &writeQNodes[i]; in rf_CommonCreateSmallWriteDAG()
1022 writeQNodes[i].antecedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
1023 writeQNodes[i].antType[0] = rf_trueData; in rf_CommonCreateSmallWriteDAG()
1029 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
1032 RF_ASSERT(writeDataNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1033 RF_ASSERT(unlockDataNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
1034 writeDataNodes[i].succedents[0] = &unlockDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
1035 unlockDataNodes[i].antecedents[0] = &writeDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
1036 unlockDataNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAG()
1039 RF_ASSERT(unlockDataNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1040 unlockDataNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAG()
1041 termNode->antecedents[i] = &unlockDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
1042 termNode->antType[i] = rf_control; in rf_CommonCreateSmallWriteDAG()
1045 RF_ASSERT(writeDataNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1048 writeDataNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAG()
1049 termNode->antecedents[i] = &writeDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
1050 termNode->antType[i] = rf_control; in rf_CommonCreateSmallWriteDAG()
1054 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
1057 RF_ASSERT(writeParityNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1058 RF_ASSERT(unlockParityNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
1059 writeParityNodes[i].succedents[0] = in rf_CommonCreateSmallWriteDAG()
1060 &unlockParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
1061 unlockParityNodes[i].antecedents[0] = in rf_CommonCreateSmallWriteDAG()
1062 &writeParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
1063 unlockParityNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAG()
1066 RF_ASSERT(unlockParityNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1067 unlockParityNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAG()
1068 termNode->antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
1069 &unlockParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
1070 termNode->antType[numDataNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAG()
1072 RF_ASSERT(writeParityNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1073 writeParityNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAG()
1074 termNode->antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
1075 &writeParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
1076 termNode->antType[numDataNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAG()
1081 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAG()
1084 RF_ASSERT(writeQNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1085 RF_ASSERT(unlockQNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAG()
1086 writeQNodes[i].succedents[0] = &unlockQNodes[i]; in rf_CommonCreateSmallWriteDAG()
1087 unlockQNodes[i].antecedents[0] = in rf_CommonCreateSmallWriteDAG()
1088 &writeQNodes[i]; in rf_CommonCreateSmallWriteDAG()
1089 unlockQNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAG()
1092 RF_ASSERT(unlockQNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1093 unlockQNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAG()
1095 [numDataNodes + numParityNodes + i] = in rf_CommonCreateSmallWriteDAG()
1096 &unlockQNodes[i]; in rf_CommonCreateSmallWriteDAG()
1098 [numDataNodes + numParityNodes + i] = in rf_CommonCreateSmallWriteDAG()
1101 RF_ASSERT(writeQNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAG()
1102 writeQNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAG()
1104 [numDataNodes + numParityNodes + i] = in rf_CommonCreateSmallWriteDAG()
1105 &writeQNodes[i]; in rf_CommonCreateSmallWriteDAG()
1107 [numDataNodes + numParityNodes + i] = in rf_CommonCreateSmallWriteDAG()
1138 int nWndNodes, nWmirNodes, i; in rf_CreateRaidOneWriteDAG() local
1166 i = 0; in rf_CreateRaidOneWriteDAG()
1167 wndNode = &nodes[i]; in rf_CreateRaidOneWriteDAG()
1168 i += nWndNodes; in rf_CreateRaidOneWriteDAG()
1169 wmirNode = &nodes[i]; in rf_CreateRaidOneWriteDAG()
1170 i += nWmirNodes; in rf_CreateRaidOneWriteDAG()
1171 commitNode = &nodes[i]; in rf_CreateRaidOneWriteDAG()
1172 i += 1; in rf_CreateRaidOneWriteDAG()
1173 unblockNode = &nodes[i]; in rf_CreateRaidOneWriteDAG()
1174 i += 1; in rf_CreateRaidOneWriteDAG()
1175 termNode = &nodes[i]; in rf_CreateRaidOneWriteDAG()
1176 i += 1; in rf_CreateRaidOneWriteDAG()
1177 RF_ASSERT(i == (nWndNodes + nWmirNodes + 3)); in rf_CreateRaidOneWriteDAG()
1197 for (i = 0; i < nWndNodes; i++) { in rf_CreateRaidOneWriteDAG()
1198 rf_InitNode(&wndNode[i], rf_wait, RF_FALSE, in rf_CreateRaidOneWriteDAG()
1203 wndNode[i].params[0].p = pda; in rf_CreateRaidOneWriteDAG()
1204 wndNode[i].params[1].p = pda->bufPtr; in rf_CreateRaidOneWriteDAG()
1205 wndNode[i].params[2].v = parityStripeID; in rf_CreateRaidOneWriteDAG()
1206 wndNode[i].params[3].v = in rf_CreateRaidOneWriteDAG()
1217 for (i = 0; i < nWmirNodes; i++) { in rf_CreateRaidOneWriteDAG()
1218 rf_InitNode(&wmirNode[i], rf_wait, RF_FALSE, in rf_CreateRaidOneWriteDAG()
1223 wmirNode[i].params[0].p = pdaP; in rf_CreateRaidOneWriteDAG()
1224 wmirNode[i].params[1].p = pda->bufPtr; in rf_CreateRaidOneWriteDAG()
1225 wmirNode[i].params[2].v = parityStripeID; in rf_CreateRaidOneWriteDAG()
1226 wmirNode[i].params[3].v = in rf_CreateRaidOneWriteDAG()
1242 for (i = 0; i < nWndNodes; i++) { in rf_CreateRaidOneWriteDAG()
1243 RF_ASSERT(wndNode[i].numAntecedents == 1); in rf_CreateRaidOneWriteDAG()
1244 commitNode->succedents[i] = &wndNode[i]; in rf_CreateRaidOneWriteDAG()
1245 wndNode[i].antecedents[0] = commitNode; in rf_CreateRaidOneWriteDAG()
1246 wndNode[i].antType[0] = rf_control; in rf_CreateRaidOneWriteDAG()
1248 for (i = 0; i < nWmirNodes; i++) { in rf_CreateRaidOneWriteDAG()
1249 RF_ASSERT(wmirNode[i].numAntecedents == 1); in rf_CreateRaidOneWriteDAG()
1250 commitNode->succedents[i + nWndNodes] = &wmirNode[i]; in rf_CreateRaidOneWriteDAG()
1251 wmirNode[i].antecedents[0] = commitNode; in rf_CreateRaidOneWriteDAG()
1252 wmirNode[i].antType[0] = rf_control; in rf_CreateRaidOneWriteDAG()
1257 for (i = 0; i < nWndNodes; i++) { in rf_CreateRaidOneWriteDAG()
1258 RF_ASSERT(wndNode[i].numSuccedents == 1); in rf_CreateRaidOneWriteDAG()
1259 wndNode[i].succedents[0] = unblockNode; in rf_CreateRaidOneWriteDAG()
1260 unblockNode->antecedents[i] = &wndNode[i]; in rf_CreateRaidOneWriteDAG()
1261 unblockNode->antType[i] = rf_control; in rf_CreateRaidOneWriteDAG()
1263 for (i = 0; i < nWmirNodes; i++) { in rf_CreateRaidOneWriteDAG()
1264 RF_ASSERT(wmirNode[i].numSuccedents == 1); in rf_CreateRaidOneWriteDAG()
1265 wmirNode[i].succedents[0] = unblockNode; in rf_CreateRaidOneWriteDAG()
1266 unblockNode->antecedents[i + nWndNodes] = &wmirNode[i]; in rf_CreateRaidOneWriteDAG()
1267 unblockNode->antType[i + nWndNodes] = rf_control; in rf_CreateRaidOneWriteDAG()
1299 int nWndNodes, nRodNodes, i, nodeNum, asmNum; in rf_CommonCreateLargeWriteDAGFwd() local
1323 i = 0; in rf_CommonCreateLargeWriteDAGFwd()
1324 wndNodes = &nodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1325 i += nWndNodes; in rf_CommonCreateLargeWriteDAGFwd()
1326 xorNode = &nodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1327 i += 1; in rf_CommonCreateLargeWriteDAGFwd()
1328 wnpNode = &nodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1329 i += 1; in rf_CommonCreateLargeWriteDAGFwd()
1330 blockNode = &nodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1331 i += 1; in rf_CommonCreateLargeWriteDAGFwd()
1332 syncNode = &nodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1333 i += 1; in rf_CommonCreateLargeWriteDAGFwd()
1334 termNode = &nodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1335 i += 1; in rf_CommonCreateLargeWriteDAGFwd()
1337 wnqNode = &nodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1338 i += 1; in rf_CommonCreateLargeWriteDAGFwd()
1396 for (i = 0; i < nWndNodes; i++) { in rf_CommonCreateLargeWriteDAGFwd()
1397 rf_InitNode(&wndNodes[i], rf_wait, RF_FALSE, rf_DiskWriteFunc, in rf_CommonCreateLargeWriteDAGFwd()
1401 wndNodes[i].params[0].p = pda; in rf_CommonCreateLargeWriteDAGFwd()
1402 wndNodes[i].params[1].p = pda->bufPtr; in rf_CommonCreateLargeWriteDAGFwd()
1403 wndNodes[i].params[2].v = parityStripeID; in rf_CommonCreateLargeWriteDAGFwd()
1404 wndNodes[i].params[3].v = in rf_CommonCreateLargeWriteDAGFwd()
1414 for (i = 0; i < nWndNodes; i++) { in rf_CommonCreateLargeWriteDAGFwd()
1415 xorNode->params[2 * i + 0] = in rf_CommonCreateLargeWriteDAGFwd()
1416 wndNodes[i].params[0]; /* pda */ in rf_CommonCreateLargeWriteDAGFwd()
1417 xorNode->params[2 * i + 1] = in rf_CommonCreateLargeWriteDAGFwd()
1418 wndNodes[i].params[1]; /* buf ptr */ in rf_CommonCreateLargeWriteDAGFwd()
1420 for (i = 0; i < nRodNodes; i++) { in rf_CommonCreateLargeWriteDAGFwd()
1421 xorNode->params[2 * (nWndNodes + i) + 0] = in rf_CommonCreateLargeWriteDAGFwd()
1422 rodNodes[i].params[0]; /* pda */ in rf_CommonCreateLargeWriteDAGFwd()
1423 xorNode->params[2 * (nWndNodes + i) + 1] = in rf_CommonCreateLargeWriteDAGFwd()
1424 rodNodes[i].params[1]; /* buf ptr */ in rf_CommonCreateLargeWriteDAGFwd()
1436 for (i = 0; i < nRodNodes; i++) in rf_CommonCreateLargeWriteDAGFwd()
1437 if (((RF_PhysDiskAddr_t *) rodNodes[i].params[0].p) in rf_CommonCreateLargeWriteDAGFwd()
1441 if ((!allowBufferRecycle) || (i == nRodNodes)) { in rf_CommonCreateLargeWriteDAGFwd()
1447 xorNode->results[0] = rodNodes[i].params[1].p; in rf_CommonCreateLargeWriteDAGFwd()
1494 for (i = 0; i < nRodNodes; i++) { in rf_CommonCreateLargeWriteDAGFwd()
1495 RF_ASSERT(rodNodes[i].numAntecedents == 1); in rf_CommonCreateLargeWriteDAGFwd()
1496 blockNode->succedents[i] = &rodNodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1497 rodNodes[i].antecedents[0] = blockNode; in rf_CommonCreateLargeWriteDAGFwd()
1498 rodNodes[i].antType[0] = rf_control; in rf_CommonCreateLargeWriteDAGFwd()
1501 RF_ASSERT(rodNodes[i].numSuccedents == 1); in rf_CommonCreateLargeWriteDAGFwd()
1502 rodNodes[i].succedents[0] = syncNode; in rf_CommonCreateLargeWriteDAGFwd()
1503 syncNode->antecedents[i] = &rodNodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1504 syncNode->antType[i] = rf_trueData; in rf_CommonCreateLargeWriteDAGFwd()
1517 for (i = 0; i < nWndNodes; i++) { in rf_CommonCreateLargeWriteDAGFwd()
1519 syncNode->succedents[i] = &wndNodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1520 wndNodes[i].antecedents[0] = syncNode; in rf_CommonCreateLargeWriteDAGFwd()
1521 wndNodes[i].antType[0] = rf_control; in rf_CommonCreateLargeWriteDAGFwd()
1545 for (i = 0; i < nWndNodes; i++) { in rf_CommonCreateLargeWriteDAGFwd()
1547 wndNodes[i].succedents[0] = termNode; in rf_CommonCreateLargeWriteDAGFwd()
1548 termNode->antecedents[i] = &wndNodes[i]; in rf_CommonCreateLargeWriteDAGFwd()
1549 termNode->antType[i] = rf_control; in rf_CommonCreateLargeWriteDAGFwd()
1606 int i, j, nNodes, totalNumNodes, lu_flag; in rf_CommonCreateSmallWriteDAGFwd() local
1663 i = 0; in rf_CommonCreateSmallWriteDAGFwd()
1664 blockNode = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1665 i += 1; in rf_CommonCreateSmallWriteDAGFwd()
1666 readDataNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1667 i += numDataNodes; in rf_CommonCreateSmallWriteDAGFwd()
1668 readParityNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1669 i += numParityNodes; in rf_CommonCreateSmallWriteDAGFwd()
1670 writeDataNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1671 i += numDataNodes; in rf_CommonCreateSmallWriteDAGFwd()
1672 writeParityNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1673 i += numParityNodes; in rf_CommonCreateSmallWriteDAGFwd()
1674 xorNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1675 i += numParityNodes; in rf_CommonCreateSmallWriteDAGFwd()
1676 termNode = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1677 i += 1; in rf_CommonCreateSmallWriteDAGFwd()
1679 unlockDataNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1680 i += numDataNodes; in rf_CommonCreateSmallWriteDAGFwd()
1681 unlockParityNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1682 i += numParityNodes; in rf_CommonCreateSmallWriteDAGFwd()
1687 readQNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1688 i += numParityNodes; in rf_CommonCreateSmallWriteDAGFwd()
1689 writeQNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1690 i += numParityNodes; in rf_CommonCreateSmallWriteDAGFwd()
1691 qNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1692 i += numParityNodes; in rf_CommonCreateSmallWriteDAGFwd()
1694 unlockQNodes = &nodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
1695 i += numParityNodes; in rf_CommonCreateSmallWriteDAGFwd()
1702 RF_ASSERT(i == totalNumNodes); in rf_CommonCreateSmallWriteDAGFwd()
1717 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1718 rf_InitNode(&readDataNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1724 readDataNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAGFwd()
1726 readDataNodes[i].params[1].p = rf_AllocBuffer(raidPtr, dag_h, in rf_CommonCreateSmallWriteDAGFwd()
1728 readDataNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAGFwd()
1729 readDataNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAGFwd()
1733 for (j = 0; j < readDataNodes[i].numSuccedents; j++) in rf_CommonCreateSmallWriteDAGFwd()
1734 readDataNodes[i].propList[j] = NULL; in rf_CommonCreateSmallWriteDAGFwd()
1739 i = 0; in rf_CommonCreateSmallWriteDAGFwd()
1740 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1742 rf_InitNode(&readParityNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1745 readParityNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAGFwd()
1747 readParityNodes[i].params[1].p = rf_AllocBuffer(raidPtr, in rf_CommonCreateSmallWriteDAGFwd()
1749 readParityNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAGFwd()
1750 readParityNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAGFwd()
1753 for (j = 0; j < readParityNodes[i].numSuccedents; j++) in rf_CommonCreateSmallWriteDAGFwd()
1754 readParityNodes[i].propList[0] = NULL; in rf_CommonCreateSmallWriteDAGFwd()
1761 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1763 rf_InitNode(&readQNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1767 readQNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAGFwd()
1769 readQNodes[i].params[1].p = rf_AllocBuffer(raidPtr, in rf_CommonCreateSmallWriteDAGFwd()
1771 readQNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAGFwd()
1772 readQNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAGFwd()
1775 for (j = 0; j < readQNodes[i].numSuccedents; j++) in rf_CommonCreateSmallWriteDAGFwd()
1776 readQNodes[i].propList[0] = NULL; in rf_CommonCreateSmallWriteDAGFwd()
1782 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1784 rf_InitNode(&writeDataNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1789 writeDataNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAGFwd()
1791 writeDataNodes[i].params[1].p = pda->bufPtr; in rf_CommonCreateSmallWriteDAGFwd()
1792 writeDataNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAGFwd()
1793 writeDataNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAGFwd()
1798 rf_InitNode(&unlockDataNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1803 unlockDataNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAGFwd()
1804 unlockDataNodes[i].params[1].v = in rf_CommonCreateSmallWriteDAGFwd()
1846 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1848 rf_InitNode(&xorNodes[i], rf_wait, RF_FALSE, func, in rf_CommonCreateSmallWriteDAGFwd()
1851 xorNodes[i].flags |= RF_DAGNODE_FLAG_YIELD; in rf_CommonCreateSmallWriteDAGFwd()
1852 xorNodes[i].params[0] = readDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAGFwd()
1853 xorNodes[i].params[1] = readDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAGFwd()
1854 xorNodes[i].params[2] = readParityNodes[i].params[0]; in rf_CommonCreateSmallWriteDAGFwd()
1855 xorNodes[i].params[3] = readParityNodes[i].params[1]; in rf_CommonCreateSmallWriteDAGFwd()
1856 xorNodes[i].params[4] = writeDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAGFwd()
1857 xorNodes[i].params[5] = writeDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAGFwd()
1858 xorNodes[i].params[6].p = raidPtr; in rf_CommonCreateSmallWriteDAGFwd()
1860 xorNodes[i].results[0] = readParityNodes[i].params[1].p; in rf_CommonCreateSmallWriteDAGFwd()
1863 rf_InitNode(&qNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1867 qNodes[i].params[0] = in rf_CommonCreateSmallWriteDAGFwd()
1868 readDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAGFwd()
1869 qNodes[i].params[1] = in rf_CommonCreateSmallWriteDAGFwd()
1870 readDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAGFwd()
1871 qNodes[i].params[2] = readQNodes[i].params[0]; in rf_CommonCreateSmallWriteDAGFwd()
1872 qNodes[i].params[3] = readQNodes[i].params[1]; in rf_CommonCreateSmallWriteDAGFwd()
1873 qNodes[i].params[4] = in rf_CommonCreateSmallWriteDAGFwd()
1874 writeDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAGFwd()
1875 qNodes[i].params[5] = in rf_CommonCreateSmallWriteDAGFwd()
1876 writeDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAGFwd()
1877 qNodes[i].params[6].p = raidPtr; in rf_CommonCreateSmallWriteDAGFwd()
1879 qNodes[i].results[0] = in rf_CommonCreateSmallWriteDAGFwd()
1880 readQNodes[i].params[1].p; in rf_CommonCreateSmallWriteDAGFwd()
1890 for (i = 0; i < numDataNodes + 1; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1892 xorNodes[0].params[2 * i + 0] = in rf_CommonCreateSmallWriteDAGFwd()
1893 readDataNodes[i].params[0]; /* pda */ in rf_CommonCreateSmallWriteDAGFwd()
1894 xorNodes[0].params[2 * i + 1] = in rf_CommonCreateSmallWriteDAGFwd()
1895 readDataNodes[i].params[1]; /* buffer pointer */ in rf_CommonCreateSmallWriteDAGFwd()
1897 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1899 xorNodes[0].params[2 * (numDataNodes + 1 + i) + 0] = in rf_CommonCreateSmallWriteDAGFwd()
1900 writeDataNodes[i].params[0]; /* pda */ in rf_CommonCreateSmallWriteDAGFwd()
1901 xorNodes[0].params[2 * (numDataNodes + 1 + i) + 1] = in rf_CommonCreateSmallWriteDAGFwd()
1902 writeDataNodes[i].params[1]; /* buffer pointer */ in rf_CommonCreateSmallWriteDAGFwd()
1913 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1916 qNodes[0].params[2 * i + 0] = in rf_CommonCreateSmallWriteDAGFwd()
1917 readDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAGFwd()
1919 qNodes[0].params[2 * i + 1] = in rf_CommonCreateSmallWriteDAGFwd()
1920 readDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAGFwd()
1927 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1931 [2 * (numDataNodes + 1 + i) + 0] = in rf_CommonCreateSmallWriteDAGFwd()
1932 writeDataNodes[i].params[0]; in rf_CommonCreateSmallWriteDAGFwd()
1935 [2 * (numDataNodes + 1 + i) + 1] = in rf_CommonCreateSmallWriteDAGFwd()
1936 writeDataNodes[i].params[1]; in rf_CommonCreateSmallWriteDAGFwd()
1948 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1949 rf_InitNode(&writeParityNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1955 writeParityNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAGFwd()
1957 writeParityNodes[i].params[1].p = xorNodes[i].results[0]; in rf_CommonCreateSmallWriteDAGFwd()
1958 writeParityNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAGFwd()
1959 writeParityNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAGFwd()
1964 rf_InitNode(&unlockParityNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1968 unlockParityNodes[i].params[0].p = in rf_CommonCreateSmallWriteDAGFwd()
1970 unlockParityNodes[i].params[1].v = in rf_CommonCreateSmallWriteDAGFwd()
1980 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1981 rf_InitNode(&writeQNodes[i], rf_wait, RF_FALSE, in rf_CommonCreateSmallWriteDAGFwd()
1987 writeQNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAGFwd()
1989 writeQNodes[i].params[1].p = qNodes[i].results[0]; in rf_CommonCreateSmallWriteDAGFwd()
1990 writeQNodes[i].params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAGFwd()
1991 writeQNodes[i].params[3].v = in rf_CommonCreateSmallWriteDAGFwd()
1997 rf_InitNode(&unlockQNodes[i], rf_wait, in rf_CommonCreateSmallWriteDAGFwd()
2003 unlockQNodes[i].params[0].p = pda; in rf_CommonCreateSmallWriteDAGFwd()
2004 unlockQNodes[i].params[1].v = in rf_CommonCreateSmallWriteDAGFwd()
2019 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2020 blockNode->succedents[i] = &readDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2021 RF_ASSERT(readDataNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2022 readDataNodes[i].antecedents[0] = blockNode; in rf_CommonCreateSmallWriteDAGFwd()
2023 readDataNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2027 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2028 blockNode->succedents[numDataNodes + i] = &readParityNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2029 RF_ASSERT(readParityNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2030 readParityNodes[i].antecedents[0] = blockNode; in rf_CommonCreateSmallWriteDAGFwd()
2031 readParityNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2036 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2038 numParityNodes + i] = &readQNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2039 RF_ASSERT(readQNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2040 readQNodes[i].antecedents[0] = blockNode; in rf_CommonCreateSmallWriteDAGFwd()
2041 readQNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2045 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2046 RF_ASSERT(readDataNodes[i].numSuccedents == in rf_CommonCreateSmallWriteDAGFwd()
2048 RF_ASSERT(writeDataNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2049 readDataNodes[i].succedents[0] = &writeDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2050 writeDataNodes[i].antecedents[0] = &readDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2051 writeDataNodes[i].antType[0] = rf_antiData; in rf_CommonCreateSmallWriteDAGFwd()
2055 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2059 readDataNodes[i].succedents[1 + j] = &xorNodes[j]; in rf_CommonCreateSmallWriteDAGFwd()
2060 xorNodes[j].antecedents[i] = &readDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2061 xorNodes[j].antType[i] = rf_trueData; in rf_CommonCreateSmallWriteDAGFwd()
2067 for (i = 0; i < numDataNodes; i++) in rf_CommonCreateSmallWriteDAGFwd()
2071 readDataNodes[i].succedents in rf_CommonCreateSmallWriteDAGFwd()
2073 qNodes[j].antecedents[i] = &readDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2074 qNodes[j].antType[i] = rf_trueData; in rf_CommonCreateSmallWriteDAGFwd()
2078 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2080 RF_ASSERT(readParityNodes[i].numSuccedents == in rf_CommonCreateSmallWriteDAGFwd()
2082 readParityNodes[i].succedents[j] = &xorNodes[j]; in rf_CommonCreateSmallWriteDAGFwd()
2083 xorNodes[j].antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2084 &readParityNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2085 xorNodes[j].antType[numDataNodes + i] = rf_trueData; in rf_CommonCreateSmallWriteDAGFwd()
2091 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2093 RF_ASSERT(readQNodes[i].numSuccedents == in rf_CommonCreateSmallWriteDAGFwd()
2095 readQNodes[i].succedents[j] = &qNodes[j]; in rf_CommonCreateSmallWriteDAGFwd()
2096 qNodes[j].antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2097 &readQNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2098 qNodes[j].antType[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2104 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2105 RF_ASSERT(writeParityNodes[i].numAntecedents == numParityNodes); in rf_CommonCreateSmallWriteDAGFwd()
2108 xorNodes[i].succedents[j] = &writeParityNodes[j]; in rf_CommonCreateSmallWriteDAGFwd()
2109 writeParityNodes[j].antecedents[i] = &xorNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2110 writeParityNodes[j].antType[i] = rf_trueData; in rf_CommonCreateSmallWriteDAGFwd()
2116 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2117 RF_ASSERT(writeQNodes[i].numAntecedents == in rf_CommonCreateSmallWriteDAGFwd()
2121 qNodes[i].succedents[j] = &writeQNodes[j]; in rf_CommonCreateSmallWriteDAGFwd()
2122 writeQNodes[j].antecedents[i] = &qNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2123 writeQNodes[j].antType[i] = rf_trueData; in rf_CommonCreateSmallWriteDAGFwd()
2130 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2133 RF_ASSERT(writeDataNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2134 RF_ASSERT(unlockDataNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2135 writeDataNodes[i].succedents[0] = &unlockDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2136 unlockDataNodes[i].antecedents[0] = &writeDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2137 unlockDataNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2140 RF_ASSERT(unlockDataNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2141 unlockDataNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAGFwd()
2142 termNode->antecedents[i] = &unlockDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2143 termNode->antType[i] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2146 RF_ASSERT(writeDataNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2149 writeDataNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAGFwd()
2150 termNode->antecedents[i] = &writeDataNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2151 termNode->antType[i] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2155 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2158 RF_ASSERT(writeParityNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2159 RF_ASSERT(unlockParityNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2160 writeParityNodes[i].succedents[0] = in rf_CommonCreateSmallWriteDAGFwd()
2161 &unlockParityNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2162 unlockParityNodes[i].antecedents[0] = in rf_CommonCreateSmallWriteDAGFwd()
2163 &writeParityNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2164 unlockParityNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2167 RF_ASSERT(unlockParityNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2168 unlockParityNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAGFwd()
2169 termNode->antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2170 &unlockParityNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2171 termNode->antType[numDataNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2173 RF_ASSERT(writeParityNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2174 writeParityNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAGFwd()
2175 termNode->antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2176 &writeParityNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2177 termNode->antType[numDataNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2182 for (i = 0; i < numParityNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2185 RF_ASSERT(writeQNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2186 RF_ASSERT(unlockQNodes[i].numAntecedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2187 writeQNodes[i].succedents[0] = &unlockQNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2188 unlockQNodes[i].antecedents[0] = in rf_CommonCreateSmallWriteDAGFwd()
2189 &writeQNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2190 unlockQNodes[i].antType[0] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2193 RF_ASSERT(unlockQNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2194 unlockQNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAGFwd()
2196 numParityNodes + i] = &unlockQNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2198 numParityNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2200 RF_ASSERT(writeQNodes[i].numSuccedents == 1); in rf_CommonCreateSmallWriteDAGFwd()
2201 writeQNodes[i].succedents[0] = termNode; in rf_CommonCreateSmallWriteDAGFwd()
2203 numParityNodes + i] = &writeQNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2205 numParityNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2235 int nWndNodes, nWmirNodes, i; in rf_CreateRaidOneWriteDAGFwd() local
2261 i = 0; in rf_CreateRaidOneWriteDAGFwd()
2262 wndNode = &nodes[i]; in rf_CreateRaidOneWriteDAGFwd()
2263 i += nWndNodes; in rf_CreateRaidOneWriteDAGFwd()
2264 wmirNode = &nodes[i]; in rf_CreateRaidOneWriteDAGFwd()
2265 i += nWmirNodes; in rf_CreateRaidOneWriteDAGFwd()
2266 blockNode = &nodes[i]; in rf_CreateRaidOneWriteDAGFwd()
2267 i += 1; in rf_CreateRaidOneWriteDAGFwd()
2268 unblockNode = &nodes[i]; in rf_CreateRaidOneWriteDAGFwd()
2269 i += 1; in rf_CreateRaidOneWriteDAGFwd()
2270 termNode = &nodes[i]; in rf_CreateRaidOneWriteDAGFwd()
2271 i += 1; in rf_CreateRaidOneWriteDAGFwd()
2272 RF_ASSERT(i == (nWndNodes + nWmirNodes + 3)); in rf_CreateRaidOneWriteDAGFwd()
2292 for (i = 0; i < nWndNodes; i++) { in rf_CreateRaidOneWriteDAGFwd()
2293 rf_InitNode(&wndNode[i], rf_wait, RF_FALSE, in rf_CreateRaidOneWriteDAGFwd()
2298 wndNode[i].params[0].p = pda; in rf_CreateRaidOneWriteDAGFwd()
2299 wndNode[i].params[1].p = pda->bufPtr; in rf_CreateRaidOneWriteDAGFwd()
2300 wndNode[i].params[2].v = parityStripeID; in rf_CreateRaidOneWriteDAGFwd()
2301 wndNode[i].params[3].v = in rf_CreateRaidOneWriteDAGFwd()
2312 for (i = 0; i < nWmirNodes; i++) { in rf_CreateRaidOneWriteDAGFwd()
2313 rf_InitNode(&wmirNode[i], rf_wait, RF_FALSE, in rf_CreateRaidOneWriteDAGFwd()
2318 wmirNode[i].params[0].p = pdaP; in rf_CreateRaidOneWriteDAGFwd()
2319 wmirNode[i].params[1].p = pda->bufPtr; in rf_CreateRaidOneWriteDAGFwd()
2320 wmirNode[i].params[2].v = parityStripeID; in rf_CreateRaidOneWriteDAGFwd()
2321 wmirNode[i].params[3].v = in rf_CreateRaidOneWriteDAGFwd()
2337 for (i = 0; i < nWndNodes; i++) { in rf_CreateRaidOneWriteDAGFwd()
2338 RF_ASSERT(wndNode[i].numAntecedents == 1); in rf_CreateRaidOneWriteDAGFwd()
2339 blockNode->succedents[i] = &wndNode[i]; in rf_CreateRaidOneWriteDAGFwd()
2340 wndNode[i].antecedents[0] = blockNode; in rf_CreateRaidOneWriteDAGFwd()
2341 wndNode[i].antType[0] = rf_control; in rf_CreateRaidOneWriteDAGFwd()
2343 for (i = 0; i < nWmirNodes; i++) { in rf_CreateRaidOneWriteDAGFwd()
2344 RF_ASSERT(wmirNode[i].numAntecedents == 1); in rf_CreateRaidOneWriteDAGFwd()
2345 blockNode->succedents[i + nWndNodes] = &wmirNode[i]; in rf_CreateRaidOneWriteDAGFwd()
2346 wmirNode[i].antecedents[0] = blockNode; in rf_CreateRaidOneWriteDAGFwd()
2347 wmirNode[i].antType[0] = rf_control; in rf_CreateRaidOneWriteDAGFwd()
2352 for (i = 0; i < nWndNodes; i++) { in rf_CreateRaidOneWriteDAGFwd()
2353 RF_ASSERT(wndNode[i].numSuccedents == 1); in rf_CreateRaidOneWriteDAGFwd()
2354 wndNode[i].succedents[0] = unblockNode; in rf_CreateRaidOneWriteDAGFwd()
2355 unblockNode->antecedents[i] = &wndNode[i]; in rf_CreateRaidOneWriteDAGFwd()
2356 unblockNode->antType[i] = rf_control; in rf_CreateRaidOneWriteDAGFwd()
2358 for (i = 0; i < nWmirNodes; i++) { in rf_CreateRaidOneWriteDAGFwd()
2359 RF_ASSERT(wmirNode[i].numSuccedents == 1); in rf_CreateRaidOneWriteDAGFwd()
2360 wmirNode[i].succedents[0] = unblockNode; in rf_CreateRaidOneWriteDAGFwd()
2361 unblockNode->antecedents[i + nWndNodes] = &wmirNode[i]; in rf_CreateRaidOneWriteDAGFwd()
2362 unblockNode->antType[i + nWndNodes] = rf_control; in rf_CreateRaidOneWriteDAGFwd()