Home
last modified time | relevance | path

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

/netbsd-src/sys/dev/raidframe/
H A Drf_dagffrd.c132 RF_DagNode_t *diskNodes, *blockNode, *commitNode, *termNode; in rf_CreateNonredundantDAG() local
198 commitNode = rf_AllocDAGNode(raidPtr); in rf_CreateNonredundantDAG()
199 commitNode->list_next = dag_h->nodes; in rf_CreateNonredundantDAG()
200 dag_h->nodes = commitNode; in rf_CreateNonredundantDAG()
211 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CreateNonredundantDAG()
219 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CreateNonredundantDAG()
253 RF_ASSERT(commitNode->numAntecedents == n); in rf_CreateNonredundantDAG()
264 tmpdiskNode->succedents[0] = commitNode; in rf_CreateNonredundantDAG()
265 commitNode->antecedents[i] = tmpdiskNode; in rf_CreateNonredundantDAG()
266 commitNode->antType[i] = rf_control; in rf_CreateNonredundantDAG()
[all …]
H A Drf_dagffwr.c172 RF_DagNode_t *blockNode, *commitNode, *termNode; in rf_CommonCreateLargeWriteDAG() local
222 commitNode = rf_AllocDAGNode(raidPtr); in rf_CommonCreateLargeWriteDAG()
223 commitNode->list_next = dag_h->nodes; in rf_CommonCreateLargeWriteDAG()
224 dag_h->nodes = commitNode; in rf_CommonCreateLargeWriteDAG()
262 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CommonCreateLargeWriteDAG()
437 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CommonCreateLargeWriteDAG()
438 xorNode->succedents[0] = commitNode; in rf_CommonCreateLargeWriteDAG()
439 commitNode->antecedents[0] = xorNode; in rf_CommonCreateLargeWriteDAG()
440 commitNode->antType[0] = rf_control; in rf_CommonCreateLargeWriteDAG()
443 RF_ASSERT(commitNode->numSuccedents == nWndNodes + nfaults); in rf_CommonCreateLargeWriteDAG()
[all …]
H A Drf_dagdegrd.c121 RF_DagNode_t *rdNode, *blockNode, *commitNode, *termNode; in rf_CreateRaidOneDegradedReadDAG() local
152 commitNode = rf_AllocDAGNode(raidPtr); in rf_CreateRaidOneDegradedReadDAG()
153 commitNode->list_next = dag_h->nodes; in rf_CreateRaidOneDegradedReadDAG()
154 dag_h->nodes = commitNode; in rf_CreateRaidOneDegradedReadDAG()
170 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CreateRaidOneDegradedReadDAG()
215 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateRaidOneDegradedReadDAG()
216 rdNode->succedents[0] = commitNode; in rf_CreateRaidOneDegradedReadDAG()
217 commitNode->antecedents[0] = rdNode; in rf_CreateRaidOneDegradedReadDAG()
218 commitNode->antType[0] = rf_control; in rf_CreateRaidOneDegradedReadDAG()
221 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateRaidOneDegradedReadDAG()
[all …]
H A Drf_dagdegwr.c172 RF_DagNode_t *wndNodes, *rrdNodes, *xorNode, *commitNode; in rf_CommonCreateSimpleDegradedWriteDAG() local
239 commitNode = rf_AllocDAGNode(raidPtr); in rf_CommonCreateSimpleDegradedWriteDAG()
240 commitNode->list_next = dag_h->nodes; in rf_CommonCreateSimpleDegradedWriteDAG()
241 dag_h->nodes = commitNode; in rf_CommonCreateSimpleDegradedWriteDAG()
291 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CommonCreateSimpleDegradedWriteDAG()
499 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CommonCreateSimpleDegradedWriteDAG()
500 xorNode->succedents[0] = commitNode; in rf_CommonCreateSimpleDegradedWriteDAG()
501 commitNode->antecedents[0] = xorNode; in rf_CommonCreateSimpleDegradedWriteDAG()
502 commitNode->antType[0] = rf_control; in rf_CommonCreateSimpleDegradedWriteDAG()
505 RF_ASSERT(commitNode->numSuccedents == nfaults + nWndNodes); in rf_CommonCreateSimpleDegradedWriteDAG()
[all …]
H A Drf_engine.c339 if (node->commitNode) in FireNodeArray()
348 RF_ASSERT(node->commitNode == RF_FALSE); in FireNodeArray()
384 if (node->commitNode) in FireNodeList()
393 RF_ASSERT(node->commitNode == RF_FALSE); in FireNodeList()
523 if (skiplist->commitNode) { in PropagateResults()
535 if (finishlist->commitNode) in PropagateResults()
H A Drf_dag.h106 int commitNode; /* boolean flag - if true, this is a commit member
H A Drf_dagutils.c107 node->commitNode = commit; in rf_InitNode()
558 node->nodeNum, node->commitNode, node->name, rf_NodeStatusString(node), in rf_RecurPrintDAG()
857 if (nodes[i]->commitNode) in rf_ValidateDAG()