if (unlikely(!mlx5e_xsk_is_pool_sane(pool)))
return -EINVAL;
- cparam = kvzalloc_obj(*cparam, GFP_KERNEL);
++ cparam = kvzalloc_obj(*cparam);
+ if (!cparam)
+ return -ENOMEM;
+
err = mlx5e_xsk_map_pool(mlx5_sd_ch_ix_get_dev(priv->mdev, ix), pool);
if (unlikely(err))
- return err;
+ goto err_free_cparam;
err = mlx5e_xsk_add_pool(&priv->xsk, pool, ix);
if (unlikely(err))
struct request_sock *req,
struct dst_entry *dst,
struct request_sock *req_unhash,
- bool *own_req);
+ bool *own_req,
+ void (*opt_child_init)(struct sock *newsk,
+ const struct sock *sk));
- u16 net_header_len;
int (*setsockopt)(struct sock *sk, int level, int optname,
sockptr_t optval, unsigned int optlen);
int (*getsockopt)(struct sock *sk, int level, int optname,
import datetime
import random
import re
+ import time
++from lib.py import ksft_disruptive
from lib.py import ksft_run, ksft_pr, ksft_exit
from lib.py import ksft_eq, ksft_ne, ksft_ge, ksft_in, ksft_lt, ksft_true, ksft_raises
from lib.py import NetDrvEpEnv
from lib.py import EthtoolFamily, NetdevFamily
from lib.py import KsftSkipEx, KsftFailEx
-from lib.py import ksft_disruptive
-from lib.py import rand_port
-from lib.py import cmd, ethtool, ip, defer, GenerateTraffic, CmdExitFailure, wait_file
+from lib.py import rand_port, rand_ports
- from lib.py import ethtool, ip, defer, GenerateTraffic, CmdExitFailure
++from lib.py import cmd, ethtool, ip, defer, CmdExitFailure, wait_file
++from lib.py import GenerateTraffic
def _rss_key_str(key):