Lines Matching refs:sq_peer

381 	struct mlx5e_rep_sq_peer *sq_peer;  in mlx5e_sqs2vport_stop()  local
391 xa_for_each(&rep_sq->sq_peer, i, sq_peer) { in mlx5e_sqs2vport_stop()
392 if (sq_peer->rule) in mlx5e_sqs2vport_stop()
393 mlx5_eswitch_del_send_to_vport_rule(sq_peer->rule); in mlx5e_sqs2vport_stop()
395 xa_erase(&rep_sq->sq_peer, i); in mlx5e_sqs2vport_stop()
396 kfree(sq_peer); in mlx5e_sqs2vport_stop()
399 xa_destroy(&rep_sq->sq_peer); in mlx5e_sqs2vport_stop()
414 struct mlx5e_rep_sq_peer *sq_peer; in mlx5e_sqs2vport_add_peers_rules() local
417 sq_peer = kzalloc(sizeof(*sq_peer), GFP_KERNEL); in mlx5e_sqs2vport_add_peers_rules()
418 if (!sq_peer) in mlx5e_sqs2vport_add_peers_rules()
424 kfree(sq_peer); in mlx5e_sqs2vport_add_peers_rules()
428 sq_peer->rule = flow_rule; in mlx5e_sqs2vport_add_peers_rules()
429 sq_peer->peer = peer_esw; 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()
432 kfree(sq_peer); in mlx5e_sqs2vport_add_peers_rules()
479 xa_init(&rep_sq->sq_peer); in mlx5e_sqs2vport_start()
484 xa_destroy(&rep_sq->sq_peer); in mlx5e_sqs2vport_start()
1599 struct mlx5e_rep_sq_peer *sq_peer = xa_load(&rep_sq->sq_peer, i); in mlx5e_vport_rep_event_unpair() local
1601 if (!sq_peer || sq_peer->peer != peer_esw) in mlx5e_vport_rep_event_unpair()
1604 mlx5_eswitch_del_send_to_vport_rule(sq_peer->rule); in mlx5e_vport_rep_event_unpair()
1605 xa_erase(&rep_sq->sq_peer, i); in mlx5e_vport_rep_event_unpair()
1606 kfree(sq_peer); in mlx5e_vport_rep_event_unpair()
1616 struct mlx5e_rep_sq_peer *sq_peer; in mlx5e_vport_rep_event_pair() local
1623 sq_peer = xa_load(&rep_sq->sq_peer, i); in mlx5e_vport_rep_event_pair()
1625 if (sq_peer && sq_peer->peer) in mlx5e_vport_rep_event_pair()
1635 if (sq_peer) { in mlx5e_vport_rep_event_pair()
1636 sq_peer->rule = flow_rule; in mlx5e_vport_rep_event_pair()
1637 sq_peer->peer = peer_esw; in mlx5e_vport_rep_event_pair()
1640 sq_peer = kzalloc(sizeof(*sq_peer), GFP_KERNEL); in mlx5e_vport_rep_event_pair()
1641 if (!sq_peer) { 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()
1648 sq_peer->rule = flow_rule; in mlx5e_vport_rep_event_pair()
1649 sq_peer->peer = peer_esw; in mlx5e_vport_rep_event_pair()
1654 kfree(sq_peer); in mlx5e_vport_rep_event_pair()