Lines Matching defs:nodes
87 RF_DagNode_t *nodes, *wndNodes, *rodNodes = NULL, *syncNode, *xorNode,
103 /* alloc the Wnd nodes, the xor node, and the Lpo node */
105 nodes = RF_MallocAndAdd((nWndNodes + 6) * sizeof(*nodes), allocList);
107 wndNodes = &nodes[i];
109 xorNode = &nodes[i];
111 lpoNode = &nodes[i];
113 blockNode = &nodes[i];
115 syncNode = &nodes[i];
117 unblockNode = &nodes[i];
119 termNode = &nodes[i];
137 /* initialize the Rod nodes */
154 /* initialize the wnd nodes */
203 /* connect nodes to form graph */
210 /* connect the block node to the Rod nodes */
226 /* connect the Rod nodes to the syncNode */
240 /* connect the sync node to the Wnd nodes */
255 /* connect the Wnd nodes to the unblock node */
308 * case, there are exactly 2 Rod nodes, and each sends one output to one X node.
311 * The block and unblock nodes are unused. See comment above CreateFaultFreeReadDAG.
331 RF_DagNode_t *xorNodes, *blockNode, *unblockNode, *nodes;
351 /* DAG creation occurs in three steps: 1. count the number of nodes in
352 * the DAG 2. create the nodes 3. initialize the nodes 4. connect the
353 * nodes */
355 /* Step 1. compute number of nodes in the graph */
357 /* number of nodes: a read and write for each data unit a redundancy
369 /* Step 2. create the nodes */
370 nodes = RF_MallocAndAdd(totalNumNodes * sizeof(*nodes), allocList);
372 blockNode = &nodes[i];
374 unblockNode = &nodes[i];
376 readDataNodes = &nodes[i];
378 readParityNodes = &nodes[i];
380 writeDataNodes = &nodes[i];
382 lpuNodes = &nodes[i];
384 xorNodes = &nodes[i];
386 termNode = &nodes[i];
391 /* Step 3. initialize the nodes */
401 /* initialize nodes which read old data (Rod) */
415 /* initialize nodes which read old parity (Rop) */
429 /* initialize nodes which write new data (Wnd) */
445 /* initialize nodes which compute new parity */
462 /* initialize the xor nodes: params are {pda,buf} from {Rod,Wnd,Rop}
463 * nodes, and raidPtr */
484 /* set up params related to Rod and Rop nodes */
489 /* set up params related to Wnd and Wnp nodes */
510 /* Step 4. connect the nodes */
517 /* connect block node to read old data nodes */
526 /* connect block node to read old parity nodes */
534 /* connect read old data nodes to write new data nodes */
548 /* connect read old data nodes to xor nodes */
557 /* connect read old parity nodes to write new data nodes */
567 /* connect read old parity nodes to xor nodes */
575 /* connect xor nodes to write new parity nodes */
585 /* connect write new data nodes to unblock node */
593 /* connect write new parity nodes to unblock node */
Indexes created Mon Sep 29 21:09:56 GMT 2025