Lines Matching refs:node
62 struct hsr_node *node; in hsr_addr_is_self() local
64 node = list_first_or_null_rcu(&hsr->self_node_db, struct hsr_node, in hsr_addr_is_self()
66 if (!node) { in hsr_addr_is_self()
71 if (ether_addr_equal(addr, node->MacAddressA)) in hsr_addr_is_self()
73 if (ether_addr_equal(addr, node->MacAddressB)) in hsr_addr_is_self()
84 struct hsr_node *node; in find_node_by_AddrA() local
86 list_for_each_entry_rcu(node, node_db, mac_list) { in find_node_by_AddrA()
87 if (ether_addr_equal(node->MacAddressA, addr)) in find_node_by_AddrA()
88 return node; in find_node_by_AddrA()
102 struct hsr_node *node, *oldnode; in hsr_create_self_node() local
104 node = kmalloc(sizeof(*node), GFP_KERNEL); in hsr_create_self_node()
105 if (!node) in hsr_create_self_node()
108 ether_addr_copy(node->MacAddressA, addr_a); in hsr_create_self_node()
109 ether_addr_copy(node->MacAddressB, addr_b); in hsr_create_self_node()
115 list_replace_rcu(&oldnode->mac_list, &node->mac_list); in hsr_create_self_node()
121 list_add_tail_rcu(&node->mac_list, self_node_db); in hsr_create_self_node()
135 struct hsr_node *node; in hsr_add_node() local
139 node = kzalloc(sizeof(*node), GFP_ATOMIC); in hsr_add_node()
140 if (!node) in hsr_add_node()
143 ether_addr_copy(node->MacAddressA, addr); in hsr_add_node()
150 node->time_in[i] = now; in hsr_add_node()
152 node->seq_out[i] = seq_out; in hsr_add_node()
154 list_add_tail_rcu(&node->mac_list, node_db); in hsr_add_node()
156 return node; in hsr_add_node()
165 struct hsr_node *node; in hsr_get_node() local
174 list_for_each_entry_rcu(node, node_db, mac_list) { in hsr_get_node()
175 if (ether_addr_equal(node->MacAddressA, ethhdr->h_source)) in hsr_get_node()
176 return node; in hsr_get_node()
177 if (ether_addr_equal(node->MacAddressB, ethhdr->h_source)) in hsr_get_node()
178 return node; in hsr_get_node()
267 void hsr_addr_subst_source(struct hsr_node *node, struct sk_buff *skb) in hsr_addr_subst_source() argument
274 memcpy(ð_hdr(skb)->h_source, node->MacAddressA, ETH_ALEN); in hsr_addr_subst_source()
311 void hsr_register_frame_in(struct hsr_node *node, struct hsr_port *port, in hsr_register_frame_in() argument
318 if (seq_nr_before(sequence_nr, node->seq_out[port->type])) in hsr_register_frame_in()
321 node->time_in[port->type] = jiffies; in hsr_register_frame_in()
322 node->time_in_stale[port->type] = false; in hsr_register_frame_in()
333 int hsr_register_frame_out(struct hsr_port *port, struct hsr_node *node, in hsr_register_frame_out() argument
336 if (seq_nr_before_or_eq(sequence_nr, node->seq_out[port->type])) in hsr_register_frame_out()
339 node->seq_out[port->type] = sequence_nr; in hsr_register_frame_out()
345 struct hsr_node *node) in get_late_port() argument
347 if (node->time_in_stale[HSR_PT_SLAVE_A]) in get_late_port()
349 if (node->time_in_stale[HSR_PT_SLAVE_B]) in get_late_port()
352 if (time_after(node->time_in[HSR_PT_SLAVE_B], in get_late_port()
353 node->time_in[HSR_PT_SLAVE_A] + in get_late_port()
356 if (time_after(node->time_in[HSR_PT_SLAVE_A], in get_late_port()
357 node->time_in[HSR_PT_SLAVE_B] + in get_late_port()
371 struct hsr_node *node; in hsr_prune_nodes() local
377 list_for_each_entry_rcu(node, &hsr->node_db, mac_list) { in hsr_prune_nodes()
379 time_a = node->time_in[HSR_PT_SLAVE_A]; in hsr_prune_nodes()
380 time_b = node->time_in[HSR_PT_SLAVE_B]; in hsr_prune_nodes()
384 node->time_in_stale[HSR_PT_SLAVE_A] = true; in hsr_prune_nodes()
386 node->time_in_stale[HSR_PT_SLAVE_B] = true; in hsr_prune_nodes()
393 if (node->time_in_stale[HSR_PT_SLAVE_A] || in hsr_prune_nodes()
394 (!node->time_in_stale[HSR_PT_SLAVE_B] && in hsr_prune_nodes()
402 port = get_late_port(hsr, node); in hsr_prune_nodes()
404 hsr_nl_ringerror(hsr, node->MacAddressA, port); in hsr_prune_nodes()
411 hsr_nl_nodedown(hsr, node->MacAddressA); in hsr_prune_nodes()
412 list_del_rcu(&node->mac_list); in hsr_prune_nodes()
414 kfree_rcu(node, rcu_head); in hsr_prune_nodes()
424 struct hsr_node *node; in hsr_get_next_node() local
427 node = list_first_or_null_rcu(&hsr->node_db, in hsr_get_next_node()
429 if (node) in hsr_get_next_node()
430 ether_addr_copy(addr, node->MacAddressA); in hsr_get_next_node()
431 return node; in hsr_get_next_node()
434 node = _pos; in hsr_get_next_node()
435 list_for_each_entry_continue_rcu(node, &hsr->node_db, mac_list) { in hsr_get_next_node()
436 ether_addr_copy(addr, node->MacAddressA); in hsr_get_next_node()
437 return node; in hsr_get_next_node()
453 struct hsr_node *node; in hsr_get_node_data() local
459 node = find_node_by_AddrA(&hsr->node_db, addr); in hsr_get_node_data()
460 if (!node) { in hsr_get_node_data()
465 ether_addr_copy(addr_b, node->MacAddressB); in hsr_get_node_data()
467 tdiff = jiffies - node->time_in[HSR_PT_SLAVE_A]; in hsr_get_node_data()
468 if (node->time_in_stale[HSR_PT_SLAVE_A]) in hsr_get_node_data()
477 tdiff = jiffies - node->time_in[HSR_PT_SLAVE_B]; in hsr_get_node_data()
478 if (node->time_in_stale[HSR_PT_SLAVE_B]) in hsr_get_node_data()
488 *if1_seq = node->seq_out[HSR_PT_SLAVE_B]; in hsr_get_node_data()
489 *if2_seq = node->seq_out[HSR_PT_SLAVE_A]; in hsr_get_node_data()
491 if (node->AddrB_port != HSR_PT_NONE) { in hsr_get_node_data()
492 port = hsr_port_get_hsr(hsr, node->AddrB_port); in hsr_get_node_data()