Home | History | Annotate | Download | only in raidframe

Lines Matching refs:writeDataNodes

333 	RF_DagNode_t *writeDataNodes, *lpuNodes;
380 	writeDataNodes = &nodes[i];
433 		rf_InitNode(&writeDataNodes[i], rf_wait, RF_TRUE, rf_DiskWriteFunc, rf_DiskWriteUndoFunc, rf_GenericWakeupFunc, 1, nNodes, 4, 0, dag_h, "Wnd", allocList);
434 		writeDataNodes[i].params[0].p = pda;	/* physical disk addr
436 		writeDataNodes[i].params[1].p = pda->bufPtr;	/* buffer holding new
438 		writeDataNodes[i].params[2].v = parityStripeID;
439 		writeDataNodes[i].params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru);
473 			xorNodes[i].params[4] = writeDataNodes[i].params[0];
474 			xorNodes[i].params[5] = writeDataNodes[i].params[1];
490 			xorNodes[0].params[2 * (numDataNodes + 1 + i) + 0] = writeDataNodes[i].params[0];	/* pda */
491 			xorNodes[0].params[2 * (numDataNodes + 1 + i) + 1] = writeDataNodes[i].params[1];	/* buffer pointer */
538 			RF_ASSERT(writeDataNodes[j].numAntecedents == numDataNodes + numParityNodes);
539 			readDataNodes[i].succedents[j] = &writeDataNodes[j];
540 			writeDataNodes[j].antecedents[i] = &readDataNodes[i];
542 				writeDataNodes[j].antType[i] = rf_antiData;
544 				writeDataNodes[j].antType[i] = rf_control;
561 			readParityNodes[i].succedents[j] = &writeDataNodes[j];
562 			writeDataNodes[j].antecedents[numDataNodes + i] = &readParityNodes[i];
563 			writeDataNodes[j].antType[numDataNodes + i] = rf_control;
586 		RF_ASSERT(writeDataNodes[i].numSuccedents == 1);
588 		writeDataNodes[i].succedents[0] = unblockNode;
589 		unblockNode->antecedents[i] = &writeDataNodes[i];