Lines Matching defs:readParityNodes
332 RF_DagNode_t *readDataNodes, *readParityNodes;
378 readParityNodes = &nodes[i];
420 rf_InitNode(&readParityNodes[i], rf_wait, RF_FALSE, rf_DiskReadFunc, rf_DiskReadUndoFunc, rf_GenericWakeupFunc, nNodes, 1, 4, 0, dag_h, "Rop", allocList);
421 readParityNodes[i].params[0].p = pda;
422 readParityNodes[i].params[1].p = rf_AllocBuffer(raidPtr, dag_h, pda->numSector << raidPtr->logBytesPerSector); /* buffer to hold old parity */
423 readParityNodes[i].params[2].v = parityStripeID;
424 readParityNodes[i].params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru);
425 readParityNodes[i].propList[0] = NULL;
471 xorNodes[i].params[2] = readParityNodes[i].params[0];
472 xorNodes[i].params[3] = readParityNodes[i].params[1];
476 xorNodes[i].results[0] = readParityNodes[i].params[1].p; /* use old parity buf as
495 xorNodes[0].results[0] = readParityNodes[0].params[1].p;
528 blockNode->succedents[numDataNodes + i] = &readParityNodes[i];
529 RF_ASSERT(readParityNodes[i].numAntecedents == 1);
530 readParityNodes[i].antecedents[0] = blockNode;
531 readParityNodes[i].antType[0] = rf_control;
559 RF_ASSERT(readParityNodes[i].numSuccedents == numDataNodes + numParityNodes);
561 readParityNodes[i].succedents[j] = &writeDataNodes[j];
562 writeDataNodes[j].antecedents[numDataNodes + i] = &readParityNodes[i];
570 readParityNodes[i].succedents[numDataNodes + j] = &xorNodes[j];
571 xorNodes[j].antecedents[numDataNodes + i] = &readParityNodes[i];