/src/sys/dev/raidframe/ |
rf_dagffrd.c | 132 RF_DagNode_t *diskNodes, *blockNode, *commitNode, *termNode; 194 blockNode = rf_AllocDAGNode(raidPtr); 195 blockNode->list_next = dag_h->nodes; 196 dag_h->nodes = blockNode; 209 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, 217 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, 247 RF_ASSERT(blockNode->numAntecedents == 0); 248 dag_h->succedents[0] = blockNode; 252 RF_ASSERT(blockNode->numSuccedents == n); 258 blockNode->succedents[i] = tmpdiskNode [all...] |
rf_dagffrd.c | 132 RF_DagNode_t *diskNodes, *blockNode, *commitNode, *termNode; 194 blockNode = rf_AllocDAGNode(raidPtr); 195 blockNode->list_next = dag_h->nodes; 196 dag_h->nodes = blockNode; 209 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, 217 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, 247 RF_ASSERT(blockNode->numAntecedents == 0); 248 dag_h->succedents[0] = blockNode; 252 RF_ASSERT(blockNode->numSuccedents == n); 258 blockNode->succedents[i] = tmpdiskNode [all...] |
rf_parityloggingdags.c | 88 *lpoNode, *blockNode, *unblockNode, *termNode; 113 blockNode = &nodes[i]; 132 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, NULL, nRodNodes + 1, 0, 0, 0, dag_h, "Nil", allocList); 207 RF_ASSERT(blockNode->numAntecedents == 0); 208 dag_h->succedents[0] = blockNode; 211 RF_ASSERT(blockNode->numSuccedents == nRodNodes + 1); 214 blockNode->succedents[i] = &rodNodes[i]; 215 rodNodes[i].antecedents[0] = blockNode; 222 blockNode->succedents[nRodNodes] = syncNode; 223 syncNode->antecedents[0] = blockNode; [all...] |
rf_parityloggingdags.c | 88 *lpoNode, *blockNode, *unblockNode, *termNode; 113 blockNode = &nodes[i]; 132 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, NULL, nRodNodes + 1, 0, 0, 0, dag_h, "Nil", allocList); 207 RF_ASSERT(blockNode->numAntecedents == 0); 208 dag_h->succedents[0] = blockNode; 211 RF_ASSERT(blockNode->numSuccedents == nRodNodes + 1); 214 blockNode->succedents[i] = &rodNodes[i]; 215 rodNodes[i].antecedents[0] = blockNode; 222 blockNode->succedents[nRodNodes] = syncNode; 223 syncNode->antecedents[0] = blockNode; [all...] |
rf_parityscan.c | 202 RF_DagNode_t *blockNode, *wrBlock; 230 blockNode = rd_dag_h->succedents[0]; 243 blockNode->succedents[i]->params[0].p = pda; 244 blockNode->succedents[i]->params[2].v = psID; 245 blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru); 253 blockNode->succedents[layoutPtr->numDataCol]->params[0].p = asmap->parityInfo; 426 RF_DagNode_t *nodes, *termNode, *blockNode, *unblockNode, *tmpNode; 453 blockNode = rf_AllocDAGNode(raidPtr); 454 blockNode->list_next = dag_h->nodes; 455 dag_h->nodes = blockNode; [all...] |
rf_raid1.c | 262 RF_DagNode_t *blockNode, *wrBlock; 320 blockNode = rd_dag_h->succedents[0]; 346 blockNode->succedents[i]->params[0].p = pda; 347 blockNode->succedents[i]->params[1].p = buf1; 348 blockNode->succedents[i]->params[2].v = psID; 349 blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru); 367 blockNode->succedents[i]->params[0].p = pda; 368 blockNode->succedents[i]->params[1].p = buf1; 369 blockNode->succedents[i]->params[2].v = psID; 370 blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru) [all...] |
rf_dagffwr.c | 172 RF_DagNode_t *blockNode, *commitNode, *termNode; 218 blockNode = rf_AllocDAGNode(raidPtr); 219 blockNode->list_next = dag_h->nodes; 220 dag_h->nodes = blockNode; 253 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, 257 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, 405 RF_ASSERT(blockNode->numAntecedents == 0); 406 dag_h->succedents[0] = blockNode; 410 RF_ASSERT(blockNode->numSuccedents == nRodNodes); 415 blockNode->succedents[i] = tmpNode [all...] |
rf_evenodd.c | 340 RF_DagNode_t *blockNode, *wrBlock; 370 blockNode = rd_dag_h->succedents[0]; 383 blockNode->succedents[i]->params[0].p = pda; 384 blockNode->succedents[i]->params[2].v = psID; 385 blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru); 393 blockNode->succedents[layoutPtr->numDataCol]->params[0].p = asmap->parityInfo; 403 blockNode->succedents[layoutPtr->numDataCol + 1]->params[0].p = asmap->qInfo;
|
rf_parityscan.c | 202 RF_DagNode_t *blockNode, *wrBlock; 230 blockNode = rd_dag_h->succedents[0]; 243 blockNode->succedents[i]->params[0].p = pda; 244 blockNode->succedents[i]->params[2].v = psID; 245 blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru); 253 blockNode->succedents[layoutPtr->numDataCol]->params[0].p = asmap->parityInfo; 426 RF_DagNode_t *nodes, *termNode, *blockNode, *unblockNode, *tmpNode; 453 blockNode = rf_AllocDAGNode(raidPtr); 454 blockNode->list_next = dag_h->nodes; 455 dag_h->nodes = blockNode; [all...] |
rf_raid1.c | 262 RF_DagNode_t *blockNode, *wrBlock; 320 blockNode = rd_dag_h->succedents[0]; 346 blockNode->succedents[i]->params[0].p = pda; 347 blockNode->succedents[i]->params[1].p = buf1; 348 blockNode->succedents[i]->params[2].v = psID; 349 blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru); 367 blockNode->succedents[i]->params[0].p = pda; 368 blockNode->succedents[i]->params[1].p = buf1; 369 blockNode->succedents[i]->params[2].v = psID; 370 blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru) [all...] |
rf_dagffwr.c | 172 RF_DagNode_t *blockNode, *commitNode, *termNode; 218 blockNode = rf_AllocDAGNode(raidPtr); 219 blockNode->list_next = dag_h->nodes; 220 dag_h->nodes = blockNode; 253 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, 257 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, 405 RF_ASSERT(blockNode->numAntecedents == 0); 406 dag_h->succedents[0] = blockNode; 410 RF_ASSERT(blockNode->numSuccedents == nRodNodes); 415 blockNode->succedents[i] = tmpNode [all...] |
rf_evenodd.c | 340 RF_DagNode_t *blockNode, *wrBlock; 370 blockNode = rd_dag_h->succedents[0]; 383 blockNode->succedents[i]->params[0].p = pda; 384 blockNode->succedents[i]->params[2].v = psID; 385 blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru); 393 blockNode->succedents[layoutPtr->numDataCol]->params[0].p = asmap->parityInfo; 403 blockNode->succedents[layoutPtr->numDataCol + 1]->params[0].p = asmap->qInfo;
|
rf_dagdegrd.c | 121 RF_DagNode_t *rdNode, *blockNode, *commitNode, *termNode; 148 blockNode = rf_AllocDAGNode(raidPtr); 149 blockNode->list_next = dag_h->nodes; 150 dag_h->nodes = blockNode; 168 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, 203 RF_ASSERT(blockNode->numAntecedents == 0); 204 dag_h->succedents[0] = blockNode; 207 RF_ASSERT(blockNode->numSuccedents == 1); 209 blockNode->succedents[0] = rdNode; 210 rdNode->antecedents[0] = blockNode; [all...] |
rf_dagdegwr.c | 130 * hdr -> blockNode -> Rod -> Xor -> Cmt -> Wnp ----> unblock -> term 168 RF_DagNode_t *blockNode, *unblockNode, *wnpNode, *termNode; 235 blockNode = rf_AllocDAGNode(raidPtr); 236 blockNode->list_next = dag_h->nodes; 237 dag_h->nodes = blockNode; 289 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, 472 RF_ASSERT(blockNode->numAntecedents == 0); 473 dag_h->succedents[0] = blockNode; 476 RF_ASSERT(blockNode->numSuccedents == nRrdNodes); 480 blockNode->succedents[i] = tmprrdNode [all...] |
rf_dagdegrd.c | 121 RF_DagNode_t *rdNode, *blockNode, *commitNode, *termNode; 148 blockNode = rf_AllocDAGNode(raidPtr); 149 blockNode->list_next = dag_h->nodes; 150 dag_h->nodes = blockNode; 168 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, 203 RF_ASSERT(blockNode->numAntecedents == 0); 204 dag_h->succedents[0] = blockNode; 207 RF_ASSERT(blockNode->numSuccedents == 1); 209 blockNode->succedents[0] = rdNode; 210 rdNode->antecedents[0] = blockNode; [all...] |
rf_dagdegwr.c | 130 * hdr -> blockNode -> Rod -> Xor -> Cmt -> Wnp ----> unblock -> term 168 RF_DagNode_t *blockNode, *unblockNode, *wnpNode, *termNode; 235 blockNode = rf_AllocDAGNode(raidPtr); 236 blockNode->list_next = dag_h->nodes; 237 dag_h->nodes = blockNode; 289 rf_InitNode(blockNode, rf_wait, RF_FALSE, rf_NullNodeFunc, rf_NullNodeUndoFunc, 472 RF_ASSERT(blockNode->numAntecedents == 0); 473 dag_h->succedents[0] = blockNode; 476 RF_ASSERT(blockNode->numSuccedents == nRrdNodes); 480 blockNode->succedents[i] = tmprrdNode [all...] |