Lines Matching refs:readDataNodes
332 RF_DagNode_t *readDataNodes, *readParityNodes; in rf_CommonCreateParityLoggingSmallWriteDAG() local
376 readDataNodes = &nodes[i]; in rf_CommonCreateParityLoggingSmallWriteDAG()
403 …rf_InitNode(&readDataNodes[i], rf_wait, RF_FALSE, rf_DiskReadFunc, rf_DiskReadUndoFunc, rf_Generic… in rf_CommonCreateParityLoggingSmallWriteDAG()
405 readDataNodes[i].params[0].p = pda; /* physical disk addr in rf_CommonCreateParityLoggingSmallWriteDAG()
407 …readDataNodes[i].params[1].p = rf_AllocBuffer(raidPtr, dag_h, pda->numSector << raidPtr->logBytesP… in rf_CommonCreateParityLoggingSmallWriteDAG()
408 readDataNodes[i].params[2].v = parityStripeID; in rf_CommonCreateParityLoggingSmallWriteDAG()
409 readDataNodes[i].params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru); in rf_CommonCreateParityLoggingSmallWriteDAG()
411 readDataNodes[i].propList[0] = NULL; in rf_CommonCreateParityLoggingSmallWriteDAG()
412 readDataNodes[i].propList[1] = NULL; in rf_CommonCreateParityLoggingSmallWriteDAG()
469 xorNodes[i].params[0] = readDataNodes[i].params[0]; in rf_CommonCreateParityLoggingSmallWriteDAG()
470 xorNodes[i].params[1] = readDataNodes[i].params[1]; in rf_CommonCreateParityLoggingSmallWriteDAG()
485 xorNodes[0].params[2 * i + 0] = readDataNodes[i].params[0]; /* pda */ in rf_CommonCreateParityLoggingSmallWriteDAG()
486 xorNodes[0].params[2 * i + 1] = readDataNodes[i].params[1]; /* buffer pointer */ in rf_CommonCreateParityLoggingSmallWriteDAG()
520 blockNode->succedents[i] = &readDataNodes[i]; in rf_CommonCreateParityLoggingSmallWriteDAG()
521 RF_ASSERT(readDataNodes[i].numAntecedents == 1); in rf_CommonCreateParityLoggingSmallWriteDAG()
522 readDataNodes[i].antecedents[0] = blockNode; in rf_CommonCreateParityLoggingSmallWriteDAG()
523 readDataNodes[i].antType[0] = rf_control; in rf_CommonCreateParityLoggingSmallWriteDAG()
536 RF_ASSERT(readDataNodes[i].numSuccedents == numDataNodes + numParityNodes); in rf_CommonCreateParityLoggingSmallWriteDAG()
539 readDataNodes[i].succedents[j] = &writeDataNodes[j]; in rf_CommonCreateParityLoggingSmallWriteDAG()
540 writeDataNodes[j].antecedents[i] = &readDataNodes[i]; in rf_CommonCreateParityLoggingSmallWriteDAG()
552 readDataNodes[i].succedents[numDataNodes + j] = &xorNodes[j]; in rf_CommonCreateParityLoggingSmallWriteDAG()
553 xorNodes[j].antecedents[i] = &readDataNodes[i]; in rf_CommonCreateParityLoggingSmallWriteDAG()