Lines Matching refs:dag_h
81 RF_DagHeader_t *dag_h, void *bp,
86 rf_CreateNonredundantDAG(raidPtr, asmap, dag_h, bp, flags, allocList,
92 RF_DagHeader_t *dag_h, void *bp,
97 rf_CreateNonredundantDAG(raidPtr, asmap, dag_h, bp, flags, allocList,
103 RF_DagHeader_t *dag_h, void *bp,
108 rf_CommonCreateSmallWriteDAG(raidPtr, asmap, dag_h, bp, flags,
114 RF_DagHeader_t *dag_h, void *bp,
119 rf_CommonCreateLargeWriteDAG(raidPtr, asmap, dag_h, bp, flags,
165 RF_DagHeader_t *dag_h, void *bp,
194 dag_h->creator = "LargeWriteDAG";
196 dag_h->numCommitNodes = 1;
197 dag_h->numCommits = 0;
198 dag_h->numSuccedents = 1;
205 tmpNode->list_next = dag_h->nodes;
206 dag_h->nodes = tmpNode;
208 wndNodes = dag_h->nodes;
211 xorNode->list_next = dag_h->nodes;
212 dag_h->nodes = xorNode;
215 wnpNode->list_next = dag_h->nodes;
216 dag_h->nodes = wnpNode;
219 blockNode->list_next = dag_h->nodes;
220 dag_h->nodes = blockNode;
223 commitNode->list_next = dag_h->nodes;
224 dag_h->nodes = commitNode;
227 termNode->list_next = dag_h->nodes;
228 dag_h->nodes = termNode;
237 rf_MapUnaccessedPortionOfStripe(raidPtr, layoutPtr, asmap, dag_h,
243 tmpNode->list_next = dag_h->nodes;
244 dag_h->nodes = tmpNode;
246 rodNodes = dag_h->nodes;
255 dag_h, "Nil", allocList);
259 dag_h, "Nil", allocList);
264 dag_h, "Cmt", allocList);
267 dag_h, "Trm", allocList);
279 1, 1, 4, 0, dag_h,
301 dag_h, "Wnd", allocList);
316 nfaults, dag_h, "Xr ", allocList);
321 nfaults, dag_h, "Xr ", allocList);
357 xorNode->results[0] = rf_AllocBuffer(raidPtr, dag_h, rf_RaidAddressToByte(raidPtr, raidPtr->Layout.sectorsPerStripeUnit));
371 dag_h, "Wnp", allocList);
391 1, 1, 4, 0, dag_h, "Wnq", allocList);
406 dag_h->succedents[0] = blockNode;
523 RF_DagHeader_t *dag_h, void *bp,
563 dag_h->creator = "SmallWriteDAG";
565 dag_h->numCommitNodes = 1;
566 dag_h->numCommits = 0;
567 dag_h->numSuccedents = 1;
595 blockNode->list_next = dag_h->nodes;
596 dag_h->nodes = blockNode;
599 commitNode->list_next = dag_h->nodes;
600 dag_h->nodes = commitNode;
604 tmpNode->list_next = dag_h->nodes;
605 dag_h->nodes = tmpNode;
607 readDataNodes = dag_h->nodes;
611 tmpNode->list_next = dag_h->nodes;
612 dag_h->nodes = tmpNode;
614 readParityNodes = dag_h->nodes;
618 tmpNode->list_next = dag_h->nodes;
619 dag_h->nodes = tmpNode;
621 writeDataNodes = dag_h->nodes;
625 tmpNode->list_next = dag_h->nodes;
626 dag_h->nodes = tmpNode;
628 writeParityNodes = dag_h->nodes;
632 tmpNode->list_next = dag_h->nodes;
633 dag_h->nodes = tmpNode;
635 xorNodes = dag_h->nodes;
638 termNode->list_next = dag_h->nodes;
639 dag_h->nodes = termNode;
645 tmpNode->list_next = dag_h->nodes;
646 dag_h->nodes = tmpNode;
648 readQNodes = dag_h->nodes;
652 tmpNode->list_next = dag_h->nodes;
653 dag_h->nodes = tmpNode;
655 writeQNodes = dag_h->nodes;
659 tmpNode->list_next = dag_h->nodes;
660 dag_h->nodes = tmpNode;
662 qNodes = dag_h->nodes;
675 dag_h, "Nil", allocList);
680 (nfaults * numParityNodes), 0, 0, dag_h, "Cmt", allocList);
685 dag_h, "Trm", allocList);
693 1, 4, 0, dag_h, "Rod", allocList);
698 tmpreadDataNode->params[1].p = rf_AllocBuffer(raidPtr, dag_h, pda->numSector << raidPtr->logBytesPerSector);
718 dag_h, "Rop", allocList);
721 tmpreadParityNode->params[1].p = rf_AllocBuffer(raidPtr, dag_h, pda->numSector << raidPtr->logBytesPerSector);
742 1, 4, 0, dag_h, "Roq", allocList);
745 tmpreadQNode->params[1].p = rf_AllocBuffer(raidPtr, dag_h,
765 rf_GenericWakeupFunc, 1, 1, 4, 0, dag_h,
833 7, 1, dag_h, name, allocList);
850 7, 1, dag_h, qname, allocList);
874 dag_h, name, allocList);
906 dag_h, qname, allocList);
942 rf_GenericWakeupFunc, 1, 1, 4, 0, dag_h,
967 rf_GenericWakeupFunc, 1, 1, 4, 0, dag_h,
989 dag_h->succedents[0] = blockNode;
1199 RF_DagHeader_t *dag_h, void *bp,
1218 dag_h->creator = "RaidOneWriteDAG";
1234 tmpNode->list_next = dag_h->nodes;
1235 dag_h->nodes = tmpNode;
1237 wndNode = dag_h->nodes;
1241 tmpNode->list_next = dag_h->nodes;
1242 dag_h->nodes = tmpNode;
1244 wmirNode = dag_h->nodes;
1247 commitNode->list_next = dag_h->nodes;
1248 dag_h->nodes = commitNode;
1251 unblockNode->list_next = dag_h->nodes;
1252 dag_h->nodes = unblockNode;
1255 termNode->list_next = dag_h->nodes;
1256 dag_h->nodes = termNode;
1259 dag_h->numCommitNodes = 1;
1260 dag_h->numCommits = 0;
1261 dag_h->numSuccedents = 1;
1266 0, 0, 0, dag_h, "Cmt", allocList);
1269 0, 0, dag_h, "Nil", allocList);
1272 dag_h, "Trm", allocList);
1282 dag_h, "Wpd", allocList);
1302 dag_h, "Wsd", allocList);
1316 RF_ASSERT(dag_h->numSuccedents == 1);
1318 dag_h->succedents[0] = commitNode;