Lines Matching refs:nodes
62 * through the graph, blindly executing nodes until it reaches the end.
142 * All nodes are before the commit node (Cmt) are assumed to be atomic and
200 /* alloc the nodes: Wnd, xor, commit, block, term, and Wnp */
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;
243 tmpNode->list_next = dag_h->nodes;
244 dag_h->nodes = tmpNode;
246 rodNodes = dag_h->nodes;
269 /* initialize the Rod nodes */
294 /* initialize the wnd nodes */
401 * Connect nodes to form graph.
409 /* connect the block node to the Rod nodes */
419 /* connect the Rod nodes to the Xor node */
442 /* connect the commit node to the write nodes */
464 /* connect the write nodes to the term node */
571 * 1. count the number of nodes in the DAG
572 * 2. create the nodes
573 * 3. initialize the nodes
574 * 4. connect the nodes
578 * Step 1. compute number of nodes in the graph
581 /* number of nodes: a read and write for each data unit a
591 * Step 2. create the nodes
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;
669 * Step 3. initialize the nodes
687 /* initialize nodes which read old data (Rod) */
709 /* initialize nodes which read old parity (Rop) */
733 /* initialize nodes which read old Q (Roq) */
758 /* initialize nodes which write new data (Wnd) */
779 * Initialize nodes which compute new parity and Q.
815 * Initialize the xor nodes: params are {pda,buf}
816 * from {Rod,Wnd,Rop} nodes, and raidPtr
879 /* set up params related to Rod nodes */
890 /* set up params related to Wnd and Wnp nodes */
921 /* set up params related to Wnd nodes */
935 /* initialize nodes which write new parity (Wnp) */
959 /* initialize nodes which write new Q (Wnq) */
985 * Step 4. connect the nodes.
991 /* connect block node to read old data nodes */
1002 /* connect block node to read old parity nodes */
1013 /* connect block node to read old Q nodes */
1025 /* connect read old data nodes to xor nodes */
1041 /* connect read old data nodes to q nodes */
1057 /* connect read old parity nodes to xor nodes */
1072 /* connect read old q nodes to q nodes */
1090 /* connect xor nodes to commit node */
1102 /* connect q nodes to commit node */
1114 /* connect commit node to write nodes */
1148 /* connect write new data nodes to term node */
1224 /* alloc the Wnd nodes and the Wmir node */
1230 /* total number of nodes = nWndNodes + nWmirNodes + (commit + unblock
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;
1263 /* initialize the commit, unblock, and term nodes */
1274 /* initialize the wnd nodes */
1293 /* initialize the mirror nodes */
1320 /* link the commit node to the write nodes */
1339 /* link the write nodes to the unblock node */
Indexes created Sun Oct 12 02:09:55 GMT 2025