Searched refs:numSuccedents (Results 1 – 10 of 10) sorted by relevance
176 dag_h->numSuccedents = 1; in rf_CreateNonredundantDAG()252 RF_ASSERT(blockNode->numSuccedents == n); in rf_CreateNonredundantDAG()263 RF_ASSERT(tmpdiskNode->numSuccedents == 1); in rf_CreateNonredundantDAG()270 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateNonredundantDAG()272 RF_ASSERT(termNode->numSuccedents == 0); in rf_CreateNonredundantDAG()279 RF_ASSERT(blockNode->numSuccedents == 1); in rf_CreateNonredundantDAG()285 RF_ASSERT(commitNode->numSuccedents == n); in rf_CreateNonredundantDAG()287 RF_ASSERT(termNode->numSuccedents == 0); in rf_CreateNonredundantDAG()297 RF_ASSERT(tmpdiskNode->numSuccedents == 1); in rf_CreateNonredundantDAG()347 dag_h->numSuccedents = 1; in CreateMirrorReadDAG()[all …]
124 dag_h->numSuccedents = 1; in rf_CommonCreateParityLoggingLargeWriteDAG()206 RF_ASSERT(dag_h->numSuccedents == 1); in rf_CommonCreateParityLoggingLargeWriteDAG()211 RF_ASSERT(blockNode->numSuccedents == nRodNodes + 1); in rf_CommonCreateParityLoggingLargeWriteDAG()234 RF_ASSERT(syncNode->numSuccedents == nWndNodes + 1); in rf_CommonCreateParityLoggingLargeWriteDAG()249 RF_ASSERT(xorNode->numSuccedents == 1); in rf_CommonCreateParityLoggingLargeWriteDAG()258 RF_ASSERT(wndNodes->numSuccedents == 1); in rf_CommonCreateParityLoggingLargeWriteDAG()265 RF_ASSERT(lpoNode->numSuccedents == 1); in rf_CommonCreateParityLoggingLargeWriteDAG()271 RF_ASSERT(unblockNode->numSuccedents == 1); in rf_CommonCreateParityLoggingLargeWriteDAG()273 RF_ASSERT(termNode->numSuccedents == 0); in rf_CommonCreateParityLoggingLargeWriteDAG()367 dag_h->numSuccedents = 1; in rf_CommonCreateParityLoggingSmallWriteDAG()[all …]
198 dag_h->numSuccedents = 1; in rf_CommonCreateLargeWriteDAG()410 RF_ASSERT(blockNode->numSuccedents == nRodNodes); in rf_CommonCreateLargeWriteDAG()420 RF_ASSERT(tmpNode->numSuccedents == 1); in rf_CommonCreateLargeWriteDAG()428 RF_ASSERT(blockNode->numSuccedents == 1); in rf_CommonCreateLargeWriteDAG()436 RF_ASSERT(xorNode->numSuccedents == 1); in rf_CommonCreateLargeWriteDAG()443 RF_ASSERT(commitNode->numSuccedents == nWndNodes + nfaults); in rf_CommonCreateLargeWriteDAG()466 RF_ASSERT(termNode->numSuccedents == 0); in rf_CommonCreateLargeWriteDAG()469 RF_ASSERT(wndNodes->numSuccedents == 1); in rf_CommonCreateLargeWriteDAG()475 RF_ASSERT(wnpNode->numSuccedents == 1); in rf_CommonCreateLargeWriteDAG()481 RF_ASSERT(wnqNode->numSuccedents == 1); in rf_CommonCreateLargeWriteDAG()[all …]
119 node->numSuccedents = nSucc; in rf_InitNode()559 node->numSuccedents, node->numSuccFired, node->numSuccDone, in rf_RecurPrintDAG()561 for (i = 0; i < node->numSuccedents; i++) { in rf_RecurPrintDAG()563 ((i == node->numSuccedents - 1) ? "\0" : " ")); in rf_RecurPrintDAG()588 for (i = 0; i < node->numSuccedents; i++) { in rf_RecurPrintDAG()621 status, dag_h->numSuccedents, dag_h->numCommitNodes, dag_h->numCommits); in rf_PrintDAG()622 for (i = 0; i < dag_h->numSuccedents; i++) { in rf_PrintDAG()624 ((i == dag_h->numSuccedents - 1) ? "\0" : " ")); in rf_PrintDAG()627 for (i = 0; i < dag_h->numSuccedents; i++) { in rf_PrintDAG()644 for (i = 0; i < dag_h->numSuccedents; i++) { in rf_AssignNodeNums()[all …]
165 dag_h->numSuccedents = 1; in rf_CreateRaidOneDegradedReadDAG()202 RF_ASSERT(dag_h->numSuccedents == 1); in rf_CreateRaidOneDegradedReadDAG()207 RF_ASSERT(blockNode->numSuccedents == 1); in rf_CreateRaidOneDegradedReadDAG()214 RF_ASSERT(rdNode->numSuccedents == 1); in rf_CreateRaidOneDegradedReadDAG()221 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateRaidOneDegradedReadDAG()223 RF_ASSERT(termNode->numSuccedents == 0); in rf_CreateRaidOneDegradedReadDAG()357 dag_h->numSuccedents = 1; in rf_CreateDegradedReadDAG()491 RF_ASSERT(dag_h->numSuccedents == 1); in rf_CreateDegradedReadDAG()496 RF_ASSERT(blockNode->numSuccedents == (1 + nRrdNodes + nRudNodes)); in rf_CreateDegradedReadDAG()503 RF_ASSERT(tmprrdNode->numSuccedents == 1); in rf_CreateDegradedReadDAG()[all …]
202 for (i = 0; i < node->numSuccedents; i++)242 RF_ASSERT(node->numSuccDone <= node->numSuccedents); in NodeReady()243 RF_ASSERT(node->numSuccFired <= node->numSuccedents); in NodeReady()246 (node->numSuccDone == node->numSuccedents)) in NodeReady()445 RF_ASSERT(a->numSuccFired <= a->numSuccedents); in PropagateResults()452 for (i = 0; i < node->numSuccedents; i++) { in PropagateResults()557 RF_ASSERT(a->numSuccDone <= a->numSuccedents); in PropagateResults()736 FireNodeArray(dag->numSuccedents, dag->succedents); in rf_DispatchDAG()778 if (nd->numSuccedents == 0) { in DAGExecutionThread()
286 dag_h->numSuccedents = 1; in rf_CommonCreateSimpleDegradedWriteDAG()476 RF_ASSERT(blockNode->numSuccedents == nRrdNodes); in rf_CommonCreateSimpleDegradedWriteDAG()490 RF_ASSERT(tmprrdNode->numSuccedents == 1); in rf_CommonCreateSimpleDegradedWriteDAG()498 RF_ASSERT(xorNode->numSuccedents == 1); in rf_CommonCreateSimpleDegradedWriteDAG()505 RF_ASSERT(commitNode->numSuccedents == nfaults + nWndNodes); in rf_CommonCreateSimpleDegradedWriteDAG()532 RF_ASSERT(tmpwndNode->numSuccedents == 1); in rf_CommonCreateSimpleDegradedWriteDAG()540 RF_ASSERT(wnpNode->numSuccedents == 1); in rf_CommonCreateSimpleDegradedWriteDAG()548 RF_ASSERT(wnqNode->numSuccedents == 1); in rf_CommonCreateSimpleDegradedWriteDAG()555 RF_ASSERT(unblockNode->numSuccedents == 1); in rf_CommonCreateSimpleDegradedWriteDAG()557 RF_ASSERT(termNode->numSuccedents == 0); in rf_CommonCreateSimpleDegradedWriteDAG()[all …]
101 int numSuccedents; /* number of succedents */ member155 int numSuccedents; /* DAG may be a tree, i.e. may have > 1 root */ member
435 dag_h->numSuccedents = 1; in rf_MakeSimpleDAG()
64 (*hdr)->numSuccedents = 0; in InitHdrNode()