Lines Matching refs:node
43 struct hsr_node *node;
45 node = list_first_or_null_rcu(&hsr->self_node_db, struct hsr_node,
47 if (!node) {
48 WARN_ONCE(1, "HSR: No self node\n");
52 if (ether_addr_equal(addr, node->macaddress_A))
54 if (ether_addr_equal(addr, node->macaddress_B))
65 struct hsr_node *node;
67 list_for_each_entry_rcu(node, node_db, mac_list) {
68 if (ether_addr_equal(node->macaddress_A, addr))
69 return node;
83 struct hsr_node *node, *oldnode;
85 node = kmalloc(sizeof(*node), GFP_KERNEL);
86 if (!node)
89 ether_addr_copy(node->macaddress_A, addr_a);
90 ether_addr_copy(node->macaddress_B, addr_b);
96 list_replace_rcu(&oldnode->mac_list, &node->mac_list);
100 list_add_tail_rcu(&node->mac_list, self_node_db);
110 struct hsr_node *node;
113 node = list_first_or_null_rcu(self_node_db, struct hsr_node, mac_list);
114 if (node) {
115 list_del_rcu(&node->mac_list);
116 kfree_rcu(node, rcu_head);
123 struct hsr_node *node;
126 list_for_each_entry_safe(node, tmp, node_db, mac_list)
127 kfree(node);
131 struct hsr_node *node)
133 /* Mark if the SAN node is over LAN_A or LAN_B */
135 node->san_a = true;
140 node->san_b = true;
143 /* Allocate an hsr_node and add it to node_db. 'addr' is the node's address_A;
145 * originating from the newly added node.
153 struct hsr_node *new_node, *node;
179 list_for_each_entry_rcu(node, node_db, mac_list,
181 if (ether_addr_equal(node->macaddress_A, addr))
183 if (ether_addr_equal(node->macaddress_B, addr))
192 return node;
195 void prp_update_san_info(struct hsr_node *node, bool is_sup)
200 node->san_a = false;
201 node->san_b = false;
211 struct hsr_node *node;
222 list_for_each_entry_rcu(node, node_db, mac_list) {
223 if (ether_addr_equal(node->macaddress_A, ethhdr->h_source)) {
225 hsr->proto_ops->update_san_info(node, is_sup);
226 return node;
228 if (ether_addr_equal(node->macaddress_B, ethhdr->h_source)) {
230 hsr->proto_ops->update_san_info(node, is_sup);
231 return node;
235 /* Everyone may create a node entry, connected node to a HSR/PRP
261 * node.
304 /* No frame received from AddrA of this node yet */
344 * If the frame was sent by a node's B interface, replace the source
345 * address with that node's "official" address (macaddress_A) so that upper
348 void hsr_addr_subst_source(struct hsr_node *node, struct sk_buff *skb)
355 memcpy(ð_hdr(skb)->h_source, node->macaddress_A, ETH_ALEN);
384 netdev_err(skb->dev, "%s: Unknown node\n", __func__);
394 void hsr_register_frame_in(struct hsr_node *node, struct hsr_port *port,
401 if (seq_nr_before(sequence_nr, node->seq_out[port->type]))
404 node->time_in[port->type] = jiffies;
405 node->time_in_stale[port->type] = false;
416 int hsr_register_frame_out(struct hsr_port *port, struct hsr_node *node,
419 spin_lock_bh(&node->seq_out_lock);
420 if (seq_nr_before_or_eq(sequence_nr, node->seq_out[port->type]) &&
421 time_is_after_jiffies(node->time_out[port->type] +
423 spin_unlock_bh(&node->seq_out_lock);
427 node->time_out[port->type] = jiffies;
428 node->seq_out[port->type] = sequence_nr;
429 spin_unlock_bh(&node->seq_out_lock);
434 struct hsr_node *node)
436 if (node->time_in_stale[HSR_PT_SLAVE_A])
438 if (node->time_in_stale[HSR_PT_SLAVE_B])
441 if (time_after(node->time_in[HSR_PT_SLAVE_B],
442 node->time_in[HSR_PT_SLAVE_A] +
445 if (time_after(node->time_in[HSR_PT_SLAVE_A],
446 node->time_in[HSR_PT_SLAVE_B] +
459 struct hsr_node *node;
466 list_for_each_entry_safe(node, tmp, &hsr->node_db, mac_list) {
467 /* Don't prune own node. Neither time_in[HSR_PT_SLAVE_A]
469 * the master port. Thus the master node will be repeatedly
472 if (hsr_addr_is_self(hsr, node->macaddress_A))
476 time_a = node->time_in[HSR_PT_SLAVE_A];
477 time_b = node->time_in[HSR_PT_SLAVE_B];
481 node->time_in_stale[HSR_PT_SLAVE_A] = true;
483 node->time_in_stale[HSR_PT_SLAVE_B] = true;
485 /* Get age of newest frame from node.
490 if (node->time_in_stale[HSR_PT_SLAVE_A] ||
491 (!node->time_in_stale[HSR_PT_SLAVE_B] &&
499 port = get_late_port(hsr, node);
501 hsr_nl_ringerror(hsr, node->macaddress_A, port);
508 hsr_nl_nodedown(hsr, node->macaddress_A);
509 list_del_rcu(&node->mac_list);
511 kfree_rcu(node, rcu_head);
524 struct hsr_node *node;
527 node = list_first_or_null_rcu(&hsr->node_db,
529 if (node)
530 ether_addr_copy(addr, node->macaddress_A);
531 return node;
534 node = _pos;
535 list_for_each_entry_continue_rcu(node, &hsr->node_db, mac_list) {
536 ether_addr_copy(addr, node->macaddress_A);
537 return node;
552 struct hsr_node *node;
556 node = find_node_by_addr_A(&hsr->node_db, addr);
557 if (!node)
560 ether_addr_copy(addr_b, node->macaddress_B);
562 tdiff = jiffies - node->time_in[HSR_PT_SLAVE_A];
563 if (node->time_in_stale[HSR_PT_SLAVE_A])
572 tdiff = jiffies - node->time_in[HSR_PT_SLAVE_B];
573 if (node->time_in_stale[HSR_PT_SLAVE_B])
583 *if1_seq = node->seq_out[HSR_PT_SLAVE_B];
584 *if2_seq = node->seq_out[HSR_PT_SLAVE_A];
586 if (node->addr_B_port != HSR_PT_NONE) {
587 port = hsr_port_get_hsr(hsr, node->addr_B_port);