Home
last modified time | relevance | path

Searched refs:commitNode (Results 1 – 7 of 7) sorted by relevance

/mirbsd/src/sys/dev/raidframe/
Drf_dagffrd.c146 RF_DagNode_t *nodes, *diskNodes, *blockNode, *commitNode, *termNode; in rf_CreateNonredundantDAG() local
199 commitNode = &nodes[i]; in rf_CreateNonredundantDAG()
211 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateNonredundantDAG()
222 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateNonredundantDAG()
257 RF_ASSERT(commitNode->numAntecedents == n); in rf_CreateNonredundantDAG()
267 diskNodes[i].succedents[0] = commitNode; in rf_CreateNonredundantDAG()
268 commitNode->antecedents[i] = &diskNodes[i]; in rf_CreateNonredundantDAG()
269 commitNode->antType[i] = rf_control; in rf_CreateNonredundantDAG()
272 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateNonredundantDAG()
275 commitNode->succedents[0] = termNode; in rf_CreateNonredundantDAG()
[all …]
Drf_dagdegrd.c122 RF_DagNode_t *nodes, *rdNode, *blockNode, *commitNode, *termNode; in rf_CreateRaidOneDegradedReadDAG() local
149 commitNode = &nodes[i]; in rf_CreateRaidOneDegradedReadDAG()
166 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateRaidOneDegradedReadDAG()
213 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateRaidOneDegradedReadDAG()
214 rdNode->succedents[0] = commitNode; in rf_CreateRaidOneDegradedReadDAG()
215 commitNode->antecedents[0] = rdNode; in rf_CreateRaidOneDegradedReadDAG()
216 commitNode->antType[0] = rf_control; in rf_CreateRaidOneDegradedReadDAG()
219 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateRaidOneDegradedReadDAG()
222 commitNode->succedents[0] = termNode; in rf_CreateRaidOneDegradedReadDAG()
223 termNode->antecedents[0] = commitNode; in rf_CreateRaidOneDegradedReadDAG()
[all …]
Drf_dagffwr.c162 RF_DagNode_t *wnqNode, *blockNode, *commitNode, *termNode; in rf_CommonCreateLargeWriteDAG() local
197 commitNode = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
227 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CommonCreateLargeWriteDAG()
390 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CommonCreateLargeWriteDAG()
391 xorNode->succedents[0] = commitNode; in rf_CommonCreateLargeWriteDAG()
392 commitNode->antecedents[0] = xorNode; in rf_CommonCreateLargeWriteDAG()
393 commitNode->antType[0] = rf_control; in rf_CommonCreateLargeWriteDAG()
396 RF_ASSERT(commitNode->numSuccedents == nWndNodes + nfaults); in rf_CommonCreateLargeWriteDAG()
399 commitNode->succedents[i] = &wndNodes[i]; in rf_CommonCreateLargeWriteDAG()
400 wndNodes[i].antecedents[0] = commitNode; in rf_CommonCreateLargeWriteDAG()
[all …]
Drf_dagdegwr.c162 RF_DagNode_t *nodes, *wndNodes, *rrdNodes, *xorNode, *commitNode; in rf_CommonCreateSimpleDegradedWriteDAG() local
238 commitNode = &nodes[i]; in rf_CommonCreateSimpleDegradedWriteDAG()
272 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CommonCreateSimpleDegradedWriteDAG()
494 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CommonCreateSimpleDegradedWriteDAG()
495 xorNode->succedents[0] = commitNode; in rf_CommonCreateSimpleDegradedWriteDAG()
496 commitNode->antecedents[0] = xorNode; in rf_CommonCreateSimpleDegradedWriteDAG()
497 commitNode->antType[0] = rf_control; in rf_CommonCreateSimpleDegradedWriteDAG()
500 RF_ASSERT(commitNode->numSuccedents == nfaults + nWndNodes); in rf_CommonCreateSimpleDegradedWriteDAG()
503 commitNode->succedents[i] = &wndNodes[i]; in rf_CommonCreateSimpleDegradedWriteDAG()
504 wndNodes[i].antecedents[0] = commitNode; in rf_CommonCreateSimpleDegradedWriteDAG()
[all …]
Drf_engine.c378 if (node->commitNode) in rf_FireNodeArray()
387 RF_ASSERT(node->commitNode == RF_FALSE); in rf_FireNodeArray()
424 if (node->commitNode) in rf_FireNodeList()
435 RF_ASSERT(node->commitNode == RF_FALSE); in rf_FireNodeList()
586 if (skiplist->commitNode) { in rf_PropagateResults()
598 if (finishlist->commitNode) in rf_PropagateResults()
Drf_dag.h141 int commitNode; /* member
Drf_dagutils.c96 node->commitNode = commit; in rf_InitNode()
366 node->nodeNum, node->commitNode, node->name, in rf_RecurPrintDAG()
691 if (nodes[i]->commitNode) in rf_ValidateDAG()