Lines Matching defs:rdNode
121 RF_DagNode_t *rdNode, *blockNode, *commitNode, *termNode;
144 rdNode = rf_AllocDAGNode(raidPtr);
145 rdNode->list_next = dag_h->nodes;
146 dag_h->nodes = rdNode;
183 rf_InitNode(rdNode, rf_wait, RF_FALSE, rf_DiskReadFunc, rf_DiskReadUndoFunc,
185 rdNode->params[0].p = pda;
186 rdNode->params[1].p = pda->bufPtr;
187 rdNode->params[2].v = parityStripeID;
188 rdNode->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY,
192 rf_InitNode(rdNode, rf_wait, RF_FALSE, rf_DiskReadFunc, rf_DiskReadUndoFunc,
194 rdNode->params[0].p = asmap->parityInfo;
195 rdNode->params[1].p = pda->bufPtr;
196 rdNode->params[2].v = parityStripeID;
197 rdNode->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY,
208 RF_ASSERT(rdNode->numAntecedents == 1);
209 blockNode->succedents[0] = rdNode;
210 rdNode->antecedents[0] = blockNode;
211 rdNode->antType[0] = rf_control;
214 RF_ASSERT(rdNode->numSuccedents == 1);
216 rdNode->succedents[0] = commitNode;
217 commitNode->antecedents[0] = rdNode;
580 RF_DagNode_t *nodes, *rdNode, *blockNode, *commitNode, *termNode;
610 rdNode = &nodes[i];
643 rf_InitNode(rdNode, rf_wait, RF_FALSE, rf_DiskReadFunc, rf_DiskReadUndoFunc,
647 rdNode->params[0].p = asmap->parityInfo;
648 rdNode->params[1].p = pda->bufPtr;
649 rdNode->params[2].v = parityStripeID;
650 rdNode->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru);
653 rdNode->params[0].p = pda;
654 rdNode->params[1].p = pda->bufPtr;
655 rdNode->params[2].v = parityStripeID;
656 rdNode->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru);
660 rf_InitNode(rdNode, rf_wait, RF_FALSE, rf_DiskReadFunc, rf_DiskReadUndoFunc,
662 rdNode->params[0].p = asmap->parityInfo;
663 rdNode->params[1].p = pda->bufPtr;
664 rdNode->params[2].v = parityStripeID;
665 rdNode->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru);
675 RF_ASSERT(rdNode->numAntecedents == 1);
676 blockNode->succedents[0] = rdNode;
677 rdNode->antecedents[0] = blockNode;
678 rdNode->antType[0] = rf_control;
681 RF_ASSERT(rdNode->numSuccedents == 1);
683 rdNode->succedents[0] = commitNode;
684 commitNode->antecedents[0] = rdNode;