Lines Matching refs:rep_sq

380 	struct mlx5e_rep_sq *rep_sq, *tmp;  in mlx5e_sqs2vport_stop()  local
389 list_for_each_entry_safe(rep_sq, tmp, &rpriv->vport_sqs_list, list) { in mlx5e_sqs2vport_stop()
390 mlx5_eswitch_del_send_to_vport_rule(rep_sq->send_to_vport_rule); in mlx5e_sqs2vport_stop()
391 xa_for_each(&rep_sq->sq_peer, i, sq_peer) { in mlx5e_sqs2vport_stop()
395 xa_erase(&rep_sq->sq_peer, i); in mlx5e_sqs2vport_stop()
399 xa_destroy(&rep_sq->sq_peer); in mlx5e_sqs2vport_stop()
400 list_del(&rep_sq->list); in mlx5e_sqs2vport_stop()
401 kfree(rep_sq); in mlx5e_sqs2vport_stop()
406 struct mlx5e_rep_sq *rep_sq, int i) in mlx5e_sqs2vport_add_peers_rules() argument
422 rep, rep_sq->sqn); in mlx5e_sqs2vport_add_peers_rules()
430 err = xa_insert(&rep_sq->sq_peer, peer_rule_idx, sq_peer, GFP_KERNEL); in mlx5e_sqs2vport_add_peers_rules()
447 struct mlx5e_rep_sq *rep_sq; in mlx5e_sqs2vport_start() local
462 rep_sq = kzalloc(sizeof(*rep_sq), GFP_KERNEL); in mlx5e_sqs2vport_start()
463 if (!rep_sq) { in mlx5e_sqs2vport_start()
473 kfree(rep_sq); in mlx5e_sqs2vport_start()
476 rep_sq->send_to_vport_rule = flow_rule; in mlx5e_sqs2vport_start()
477 rep_sq->sqn = sqns_array[i]; in mlx5e_sqs2vport_start()
479 xa_init(&rep_sq->sq_peer); in mlx5e_sqs2vport_start()
481 err = mlx5e_sqs2vport_add_peers_rules(esw, rep, rep_sq, i); in mlx5e_sqs2vport_start()
483 mlx5_eswitch_del_send_to_vport_rule(rep_sq->send_to_vport_rule); in mlx5e_sqs2vport_start()
484 xa_destroy(&rep_sq->sq_peer); in mlx5e_sqs2vport_start()
485 kfree(rep_sq); in mlx5e_sqs2vport_start()
490 list_add(&rep_sq->list, &rpriv->vport_sqs_list); in mlx5e_sqs2vport_start()
1594 struct mlx5e_rep_sq *rep_sq; in mlx5e_vport_rep_event_unpair() local
1598 list_for_each_entry(rep_sq, &rpriv->vport_sqs_list, list) { in mlx5e_vport_rep_event_unpair()
1599 struct mlx5e_rep_sq_peer *sq_peer = xa_load(&rep_sq->sq_peer, i); in mlx5e_vport_rep_event_unpair()
1605 xa_erase(&rep_sq->sq_peer, i); in mlx5e_vport_rep_event_unpair()
1618 struct mlx5e_rep_sq *rep_sq; in mlx5e_vport_rep_event_pair() local
1622 list_for_each_entry(rep_sq, &rpriv->vport_sqs_list, list) { in mlx5e_vport_rep_event_pair()
1623 sq_peer = xa_load(&rep_sq->sq_peer, i); in mlx5e_vport_rep_event_pair()
1629 rep_sq->sqn); in mlx5e_vport_rep_event_pair()
1645 err = xa_insert(&rep_sq->sq_peer, i, sq_peer, GFP_KERNEL); in mlx5e_vport_rep_event_pair()