Lines Matching refs:rb_node
82 struct bpf_rb_node rb_node; member
124 private(A) struct bpf_rb_root fq_delayed __contains(fq_flow_node, rb_node);
160 flow_a = container_of(a, struct fq_flow_node, rb_node); in fn_time_next_packet_less()
161 flow_b = container_of(b, struct fq_flow_node, rb_node); in fn_time_next_packet_less()
406 flow = container_of(node, struct fq_flow_node, rb_node); in fq_unset_throttled_flows()
413 node = bpf_rbtree_remove(&fq_delayed, &flow->rb_node); in fq_unset_throttled_flows()
420 flow = container_of(node, struct fq_flow_node, rb_node); in fq_unset_throttled_flows()
435 bpf_rbtree_add(&fq_delayed, &flow->rb_node, fn_time_next_packet_less); in fq_flow_set_throttled()
462 struct bpf_rb_node *rb_node; in fq_dequeue_nonprio_flows() local
498 rb_node = bpf_rbtree_first(&flow->queue); in fq_dequeue_nonprio_flows()
499 if (!rb_node) { in fq_dequeue_nonprio_flows()
511 skbn = container_of(rb_node, struct skb_node, node); in fq_dequeue_nonprio_flows()
523 rb_node = bpf_rbtree_remove(&flow->queue, rb_node); in fq_dequeue_nonprio_flows()
526 if (!rb_node) in fq_dequeue_nonprio_flows()
529 skbn = container_of(rb_node, struct skb_node, node); in fq_dequeue_nonprio_flows()
551 struct bpf_rb_node *rb_node; in fq_dequeue_prio() local
565 rb_node = bpf_rbtree_first(&flow->queue); in fq_dequeue_prio()
566 if (!rb_node) { in fq_dequeue_prio()
571 skbn = container_of(rb_node, struct skb_node, node); in fq_dequeue_prio()
572 rb_node = bpf_rbtree_remove(&flow->queue, &skbn->node); in fq_dequeue_prio()
575 if (!rb_node) in fq_dequeue_prio()
578 skbn = container_of(rb_node, struct skb_node, node); in fq_dequeue_prio()