Lines Matching refs:node
76 rf_RegularPEFunc(RF_DagNode_t *node) in rf_RegularPEFunc() argument
78 rf_RegularESubroutine(node, node->results[1]); in rf_RegularPEFunc()
79 rf_RegularXorFunc(node); /* Do the wakeup here ! */ in rf_RegularPEFunc()
112 rf_RegularONEFunc(RF_DagNode_t *node) in rf_RegularONEFunc() argument
114 RF_Raid_t *raidPtr = (RF_Raid_t *) node->params[node->numParams - 1].p; in rf_RegularONEFunc()
116 int EpdaIndex = (node->numParams - 1) / 2 - 1; /* in rf_RegularONEFunc()
125 RF_AccTraceEntry_t *tracerec = node->dagHdr->tracerec; in rf_RegularONEFunc()
128 node->params[EpdaIndex].p; in rf_RegularONEFunc()
143 ((RF_PhysDiskAddr_t *) node->params[k].p)->numSector); in rf_RegularONEFunc()
144 retcode = rf_bxor(node->params[k + EpdaIndex + 3].p, in rf_RegularONEFunc()
145 node->params[k + 1].p, length, node->dagHdr->bp); in rf_RegularONEFunc()
152 if (node->params[i + 1].p != node->results[0]) { in rf_RegularONEFunc()
154 pda = (RF_PhysDiskAddr_t *) node->params[i].p; in rf_RegularONEFunc()
155 srcbuf = (char *) node->params[i + 1].p; in rf_RegularONEFunc()
159 destbuf = ((char *) node->results[0]) + in rf_RegularONEFunc()
170 ((RF_PhysDiskAddr_t *) node->params[k].p)->numSector); in rf_RegularONEFunc()
171 retcode = rf_bxor(node->params[k + EpdaIndex + 3].p, in rf_RegularONEFunc()
172 node->params[k + 1].p, length, node->dagHdr->bp); in rf_RegularONEFunc()
177 rf_GenericWakeupFunc(node, 0); in rf_RegularONEFunc()
184 rf_SimpleONEFunc(RF_DagNode_t *node) in rf_SimpleONEFunc() argument
186 RF_Raid_t *raidPtr = (RF_Raid_t *) node->params[node->numParams - 1].p; in rf_SimpleONEFunc()
188 RF_PhysDiskAddr_t *pda = (RF_PhysDiskAddr_t *) node->params[0].p; in rf_SimpleONEFunc()
191 RF_AccTraceEntry_t *tracerec = node->dagHdr->tracerec; in rf_SimpleONEFunc()
196 RF_ASSERT(((RF_PhysDiskAddr_t *) node->params[2].p)->type == in rf_SimpleONEFunc()
198 if (node->dagHdr->status == rf_enable) { in rf_SimpleONEFunc()
202 ((RF_PhysDiskAddr_t *) node->params[4].p)->numSector); in rf_SimpleONEFunc()
204 retcode = rf_bxor(node->params[5].p, node->params[1].p, in rf_SimpleONEFunc()
205 length, node->dagHdr->bp); in rf_SimpleONEFunc()
211 srcbuf = node->params[1].p; in rf_SimpleONEFunc()
212 destbuf = node->params[3].p; in rf_SimpleONEFunc()
216 rf_bxor(node->params[5].p, node->params[1].p, length, in rf_SimpleONEFunc()
217 node->dagHdr->bp); in rf_SimpleONEFunc()
223 return (rf_GenericWakeupFunc(node, retcode)); /* in rf_SimpleONEFunc()
236 rf_RegularESubroutine(RF_DagNode_t *node, char *ebuf) in rf_RegularESubroutine() argument
238 RF_Raid_t *raidPtr = (RF_Raid_t *) node->params[node->numParams - 1].p; in rf_RegularESubroutine()
244 RF_AccTraceEntry_t *tracerec = node->dagHdr->tracerec; in rf_RegularESubroutine()
248 for (i = 0; i < node->numParams - 2; i += 2) { in rf_RegularESubroutine()
249 RF_ASSERT(node->params[i + 1].p != ebuf); in rf_RegularESubroutine()
250 pda = (RF_PhysDiskAddr_t *) node->params[i].p; in rf_RegularESubroutine()
253 srcbuf = (char *) node->params[i + 1].p; in rf_RegularESubroutine()
268 rf_RegularEFunc(RF_DagNode_t *node) in rf_RegularEFunc() argument
270 rf_RegularESubroutine(node, node->results[0]); in rf_RegularEFunc()
271 rf_GenericWakeupFunc(node, 0); in rf_RegularEFunc()
292 rf_DegrESubroutine(RF_DagNode_t *node, char *ebuf) in rf_DegrESubroutine() argument
294 RF_Raid_t *raidPtr = (RF_Raid_t *) node->params[node->numParams - 1].p; in rf_DegrESubroutine()
296 RF_PhysDiskAddr_t *failedPDA = (RF_PhysDiskAddr_t *) node->params[node->numParams - 2].p; in rf_DegrESubroutine()
301 RF_AccTraceEntry_t *tracerec = node->dagHdr->tracerec; in rf_DegrESubroutine()
305 for (i = 0; i < node->numParams - 2; i += 2) { in rf_DegrESubroutine()
306 RF_ASSERT(node->params[i + 1].p != ebuf); in rf_DegrESubroutine()
307 pda = (RF_PhysDiskAddr_t *) node->params[i].p; in rf_DegrESubroutine()
310 srcbuf = (char *) node->params[i + 1].p; in rf_DegrESubroutine()
328 rf_Degraded_100_EOFunc(RF_DagNode_t *node) in rf_Degraded_100_EOFunc() argument
330 rf_DegrESubroutine(node, node->results[1]); in rf_Degraded_100_EOFunc()
331 rf_RecoveryXorFunc(node); /* Does the wakeup here ! */ in rf_Degraded_100_EOFunc()
442 rf_RecoveryEFunc(RF_DagNode_t *node) in rf_RecoveryEFunc() argument
444 RF_Raid_t *raidPtr = (RF_Raid_t *) node->params[node->numParams - 1].p; in rf_RecoveryEFunc()
446 RF_PhysDiskAddr_t *failedPDA = (RF_PhysDiskAddr_t *) node->params[node->numParams - 2].p; in rf_RecoveryEFunc()
454 RF_AccTraceEntry_t *tracerec = node->dagHdr->tracerec; in rf_RecoveryEFunc()
457 bzero((char *) node->results[0], rf_RaidAddressToByte(raidPtr, failedPDA->numSector)); in rf_RecoveryEFunc()
458 if (node->dagHdr->status == rf_enable) { in rf_RecoveryEFunc()
460 for (i = 0; i < node->numParams - 2; i += 2) in rf_RecoveryEFunc()
461 if (node->params[i + 1].p != node->results[0]) { in rf_RecoveryEFunc()
462 pda = (RF_PhysDiskAddr_t *) node->params[i].p; in rf_RecoveryEFunc()
463 if (i == node->numParams - 4) in rf_RecoveryEFunc()
468 srcbuf = (char *) node->params[i + 1].p; in rf_RecoveryEFunc()
470 … destbuf = ((char *) node->results[0]) + rf_RaidAddressToByte(raidPtr, suoffset - failedSUOffset); in rf_RecoveryEFunc()
477 return (rf_GenericWakeupFunc(node, 0)); /* node execute successfully */ in rf_RecoveryEFunc()
486 rf_EO_DegradedWriteEFunc(RF_DagNode_t *node) in rf_EO_DegradedWriteEFunc() argument
488 rf_DegrESubroutine(node, node->results[0]); in rf_EO_DegradedWriteEFunc()
489 rf_GenericWakeupFunc(node, 0); in rf_EO_DegradedWriteEFunc()
708 rf_EvenOddDoubleRecoveryFunc(RF_DagNode_t *node) in rf_EvenOddDoubleRecoveryFunc() argument
711 int np = node->numParams; in rf_EvenOddDoubleRecoveryFunc()
713 node->params[np - 1].p; in rf_EvenOddDoubleRecoveryFunc()
714 RF_Raid_t *raidPtr = (RF_Raid_t *) node->params[np - 2].p; in rf_EvenOddDoubleRecoveryFunc()
716 int i, prm, sector, nresults = node->numResults; in rf_EvenOddDoubleRecoveryFunc()
732 RF_AccTraceEntry_t *tracerec = node->dagHdr->tracerec; in rf_EvenOddDoubleRecoveryFunc()
741 if (((RF_PhysDiskAddr_t *) node->params[i].p)->type != in rf_EvenOddDoubleRecoveryFunc()
756 ppda = node->params[np - 6].p; in rf_EvenOddDoubleRecoveryFunc()
757 ppda2 = node->params[np - 5].p; in rf_EvenOddDoubleRecoveryFunc()
759 epda = node->params[np - 4].p; in rf_EvenOddDoubleRecoveryFunc()
760 epda2 = node->params[np - 3].p; in rf_EvenOddDoubleRecoveryFunc()
764 ppda = node->params[np - 4].p; in rf_EvenOddDoubleRecoveryFunc()
765 epda = node->params[np - 3].p; in rf_EvenOddDoubleRecoveryFunc()
780 pda = node->results[0]; in rf_EvenOddDoubleRecoveryFunc()
808 pda0 = node->results[0]; in rf_EvenOddDoubleRecoveryFunc()
810 pda1 = node->results[1]; in rf_EvenOddDoubleRecoveryFunc()
836 pda = node->params[prm].p; in rf_EvenOddDoubleRecoveryFunc()
858 node->params[prm].p)->bufPtr + in rf_EvenOddDoubleRecoveryFunc()
871 node->results[0])->bufPtr + in rf_EvenOddDoubleRecoveryFunc()
880 node->results[0])->bufPtr + in rf_EvenOddDoubleRecoveryFunc()
890 node->results[1])->bufPtr + in rf_EvenOddDoubleRecoveryFunc()
930 rf_GenericWakeupFunc(node, 0); in rf_EvenOddDoubleRecoveryFunc()
945 rf_EOWriteDoubleRecoveryFunc(RF_DagNode_t *node) in rf_EOWriteDoubleRecoveryFunc() argument
947 int np = node->numParams; in rf_EOWriteDoubleRecoveryFunc()
949 (RF_AccessStripeMap_t *) node->params[np - 1].p; in rf_EOWriteDoubleRecoveryFunc()
950 RF_Raid_t *raidPtr = (RF_Raid_t *) node->params[np - 2].p; in rf_EOWriteDoubleRecoveryFunc()
969 RF_AccTraceEntry_t *tracerec = node->dagHdr->tracerec; in rf_EOWriteDoubleRecoveryFunc()
979 ppda = node->results[0]; /* in rf_EOWriteDoubleRecoveryFunc()
984 epda = node->results[1]; in rf_EOWriteDoubleRecoveryFunc()
996 pda = (RF_PhysDiskAddr_t *) node->params[prm].p; in rf_EOWriteDoubleRecoveryFunc()
1068 rf_bxor(((RF_PhysDiskAddr_t *) node->params[numDataCol].p)->bufPtr, in rf_EOWriteDoubleRecoveryFunc()
1069 olddata[0], numbytes, node->dagHdr->bp); in rf_EOWriteDoubleRecoveryFunc()
1084 rf_bxor(olddata[0], ppda->bufPtr, numbytes, node->dagHdr->bp); in rf_EOWriteDoubleRecoveryFunc()
1095 rf_GenericWakeupFunc(node, 0); in rf_EOWriteDoubleRecoveryFunc()