Merge git://git.kernel.org/pub/scm/linux/kernel/git/davem/net
Pull networking fixes from David Miller: 1) When dcbnl_cee_fill() fails to be able to push a new netlink attribute, it return 0 instead of an error code. From Pan Bian. 2) Two suffix handling fixes to FIB trie code, from Alexander Duyck. 3) bnxt_hwrm_stat_ctx_alloc() goes through all the trouble of setting and maintaining a return code 'rc' but fails to actually return it. Also from Pan Bian. 4) ping socket ICMP handler needs to validate ICMP header length, from Kees Cook. 5) caif_sktinit_module() has this interesting logic: int err = sock_register(...); if (!err) return err; return 0; Just return sock_register()'s return value directly which is the only possible correct thing to do. 6) Two bnx2x driver fixes from Yuval Mintz, return a reasonable estimate from get_ringparam() ethtool op when interface is down and avoid trying to use UDP port based tunneling on 577xx chips. 7) Fix ep93xx_eth crash on module unload from Florian Fainelli. 8) Missing uapi exports, from Stephen Hemminger. 9) Don't schedule work from sk_destruct(), because the socket will be freed upon return from that function. From Herbert Xu. 10) Buggy drivers, of which we know there is at least one, can send a huge packet into the TCP stack but forget to set the gso_size in the SKB, which causes all kinds of problems. Correct this when it happens, and emit a one-time warning with the device name included so that it can be diagnosed more easily. From Marcelo Ricardo Leitner. 11) virtio-net does DMA off the stack causes hiccups with VMAP_STACK, fix from Andy Lutomirski. 12) Fix fec driver compilation with CONFIG_M5272, from Nikita Yushchenko. 13) mlx5 fixes from Kamal Heib, Saeed Mahameed, and Mohamad Haj Yahia. (erroneously flushing queues on error, module parameter validation, etc) * git://git.kernel.org/pub/scm/linux/kernel/git/davem/net: (34 commits) net/mlx5e: Change the SQ/RQ operational state to positive logic net/mlx5e: Don't flush SQ on error net/mlx5e: Don't notify HW when filling the edge of ICO SQ net/mlx5: Fix query ISSI flow net/mlx5: Remove duplicate pci dev name print net/mlx5: Verify module parameters net: fec: fix compile with CONFIG_M5272 be2net: Add DEVSEC privilege to SET_HSW_CONFIG command. virtio-net: Fix DMA-from-the-stack in virtnet_set_mac_address() tcp: warn on bogus MSS and try to amend it uapi glibc compat: fix outer guard of net device flags enum net: stmmac: clear reset value of snps, wr_osr_lmt/snps, rd_osr_lmt before writing netlink: Do not schedule work from sk_destruct uapi: export nf_log.h uapi: export tc_skbmod.h net: ep93xx_eth: Do not crash unloading module bnx2x: Prevent tunnel config for 577xx bnx2x: Correct ringparam estimate when DOWN isdn: hisax: set error code on failure net: bnx2x: fix improper return value ...
This commit is contained in:
commit
da1b466fa4
|
@ -1727,7 +1727,7 @@ static int eni_do_init(struct atm_dev *dev)
|
|||
printk("\n");
|
||||
printk(KERN_ERR DEV_LABEL "(itf %d): can't set up page "
|
||||
"mapping\n",dev->number);
|
||||
return error;
|
||||
return -ENOMEM;
|
||||
}
|
||||
eni_dev->ioaddr = base;
|
||||
eni_dev->base_diff = real_base - (unsigned long) base;
|
||||
|
|
|
@ -2143,6 +2143,7 @@ static int lanai_dev_open(struct atm_dev *atmdev)
|
|||
lanai->base = (bus_addr_t) ioremap(raw_base, LANAI_MAPPING_SIZE);
|
||||
if (lanai->base == NULL) {
|
||||
printk(KERN_ERR DEV_LABEL ": couldn't remap I/O space\n");
|
||||
result = -ENOMEM;
|
||||
goto error_pci;
|
||||
}
|
||||
/* 3.3: Reset lanai and PHY */
|
||||
|
|
|
@ -1499,6 +1499,7 @@ hfc4s8s_probe(struct pci_dev *pdev, const struct pci_device_id *ent)
|
|||
printk(KERN_INFO
|
||||
"HFC-4S/8S: failed to request address space at 0x%04x\n",
|
||||
hw->iobase);
|
||||
err = -EBUSY;
|
||||
goto out;
|
||||
}
|
||||
|
||||
|
|
|
@ -1872,8 +1872,16 @@ static void bnx2x_get_ringparam(struct net_device *dev,
|
|||
|
||||
ering->rx_max_pending = MAX_RX_AVAIL;
|
||||
|
||||
/* If size isn't already set, we give an estimation of the number
|
||||
* of buffers we'll have. We're neglecting some possible conditions
|
||||
* [we couldn't know for certain at this point if number of queues
|
||||
* might shrink] but the number would be correct for the likely
|
||||
* scenario.
|
||||
*/
|
||||
if (bp->rx_ring_size)
|
||||
ering->rx_pending = bp->rx_ring_size;
|
||||
else if (BNX2X_NUM_RX_QUEUES(bp))
|
||||
ering->rx_pending = MAX_RX_AVAIL / BNX2X_NUM_RX_QUEUES(bp);
|
||||
else
|
||||
ering->rx_pending = MAX_RX_AVAIL;
|
||||
|
||||
|
|
|
@ -10138,7 +10138,7 @@ static void __bnx2x_add_udp_port(struct bnx2x *bp, u16 port,
|
|||
{
|
||||
struct bnx2x_udp_tunnel *udp_port = &bp->udp_tunnel_ports[type];
|
||||
|
||||
if (!netif_running(bp->dev) || !IS_PF(bp))
|
||||
if (!netif_running(bp->dev) || !IS_PF(bp) || CHIP_IS_E1x(bp))
|
||||
return;
|
||||
|
||||
if (udp_port->count && udp_port->dst_port == port) {
|
||||
|
@ -10163,7 +10163,7 @@ static void __bnx2x_del_udp_port(struct bnx2x *bp, u16 port,
|
|||
{
|
||||
struct bnx2x_udp_tunnel *udp_port = &bp->udp_tunnel_ports[type];
|
||||
|
||||
if (!IS_PF(bp))
|
||||
if (!IS_PF(bp) || CHIP_IS_E1x(bp))
|
||||
return;
|
||||
|
||||
if (!udp_port->count || udp_port->dst_port != port) {
|
||||
|
@ -13505,6 +13505,7 @@ static int bnx2x_init_firmware(struct bnx2x *bp)
|
|||
|
||||
/* Initialize the pointers to the init arrays */
|
||||
/* Blob */
|
||||
rc = -ENOMEM;
|
||||
BNX2X_ALLOC_AND_SET(init_data, request_firmware_exit, be32_to_cpu_n);
|
||||
|
||||
/* Opcodes */
|
||||
|
|
|
@ -4120,7 +4120,7 @@ static int bnxt_hwrm_stat_ctx_alloc(struct bnxt *bp)
|
|||
bp->grp_info[i].fw_stats_ctx = cpr->hw_stats_ctx_id;
|
||||
}
|
||||
mutex_unlock(&bp->hwrm_cmd_lock);
|
||||
return 0;
|
||||
return rc;
|
||||
}
|
||||
|
||||
static int bnxt_hwrm_func_qcfg(struct bnxt *bp)
|
||||
|
|
|
@ -468,6 +468,9 @@ static void ep93xx_free_buffers(struct ep93xx_priv *ep)
|
|||
struct device *dev = ep->dev->dev.parent;
|
||||
int i;
|
||||
|
||||
if (!ep->descs)
|
||||
return;
|
||||
|
||||
for (i = 0; i < RX_QUEUE_ENTRIES; i++) {
|
||||
dma_addr_t d;
|
||||
|
||||
|
@ -490,6 +493,7 @@ static void ep93xx_free_buffers(struct ep93xx_priv *ep)
|
|||
|
||||
dma_free_coherent(dev, sizeof(struct ep93xx_descs), ep->descs,
|
||||
ep->descs_dma_addr);
|
||||
ep->descs = NULL;
|
||||
}
|
||||
|
||||
static int ep93xx_alloc_buffers(struct ep93xx_priv *ep)
|
||||
|
|
|
@ -90,7 +90,8 @@ static struct be_cmd_priv_map cmd_priv_map[] = {
|
|||
{
|
||||
OPCODE_COMMON_SET_HSW_CONFIG,
|
||||
CMD_SUBSYSTEM_COMMON,
|
||||
BE_PRIV_DEVCFG | BE_PRIV_VHADM
|
||||
BE_PRIV_DEVCFG | BE_PRIV_VHADM |
|
||||
BE_PRIV_DEVSEC
|
||||
},
|
||||
{
|
||||
OPCODE_COMMON_GET_EXT_FAT_CAPABILITIES,
|
||||
|
|
|
@ -2313,6 +2313,8 @@ static const struct fec_stat {
|
|||
{ "IEEE_rx_octets_ok", IEEE_R_OCTETS_OK },
|
||||
};
|
||||
|
||||
#define FEC_STATS_SIZE (ARRAY_SIZE(fec_stats) * sizeof(u64))
|
||||
|
||||
static void fec_enet_update_ethtool_stats(struct net_device *dev)
|
||||
{
|
||||
struct fec_enet_private *fep = netdev_priv(dev);
|
||||
|
@ -2330,7 +2332,7 @@ static void fec_enet_get_ethtool_stats(struct net_device *dev,
|
|||
if (netif_running(dev))
|
||||
fec_enet_update_ethtool_stats(dev);
|
||||
|
||||
memcpy(data, fep->ethtool_stats, ARRAY_SIZE(fec_stats) * sizeof(u64));
|
||||
memcpy(data, fep->ethtool_stats, FEC_STATS_SIZE);
|
||||
}
|
||||
|
||||
static void fec_enet_get_strings(struct net_device *netdev,
|
||||
|
@ -2355,6 +2357,12 @@ static int fec_enet_get_sset_count(struct net_device *dev, int sset)
|
|||
return -EOPNOTSUPP;
|
||||
}
|
||||
}
|
||||
|
||||
#else /* !defined(CONFIG_M5272) */
|
||||
#define FEC_STATS_SIZE 0
|
||||
static inline void fec_enet_update_ethtool_stats(struct net_device *dev)
|
||||
{
|
||||
}
|
||||
#endif /* !defined(CONFIG_M5272) */
|
||||
|
||||
static int fec_enet_nway_reset(struct net_device *dev)
|
||||
|
@ -3293,8 +3301,7 @@ fec_probe(struct platform_device *pdev)
|
|||
|
||||
/* Init network device */
|
||||
ndev = alloc_etherdev_mqs(sizeof(struct fec_enet_private) +
|
||||
ARRAY_SIZE(fec_stats) * sizeof(u64),
|
||||
num_tx_qs, num_rx_qs);
|
||||
FEC_STATS_SIZE, num_tx_qs, num_rx_qs);
|
||||
if (!ndev)
|
||||
return -ENOMEM;
|
||||
|
||||
|
|
|
@ -268,11 +268,6 @@ static void dump_buf(void *buf, int size, int data_only, int offset)
|
|||
pr_debug("\n");
|
||||
}
|
||||
|
||||
enum {
|
||||
MLX5_DRIVER_STATUS_ABORTED = 0xfe,
|
||||
MLX5_DRIVER_SYND = 0xbadd00de,
|
||||
};
|
||||
|
||||
static int mlx5_internal_err_ret_value(struct mlx5_core_dev *dev, u16 op,
|
||||
u32 *synd, u8 *status)
|
||||
{
|
||||
|
|
|
@ -241,7 +241,7 @@ struct mlx5e_tstamp {
|
|||
};
|
||||
|
||||
enum {
|
||||
MLX5E_RQ_STATE_FLUSH,
|
||||
MLX5E_RQ_STATE_ENABLED,
|
||||
MLX5E_RQ_STATE_UMR_WQE_IN_PROGRESS,
|
||||
MLX5E_RQ_STATE_AM,
|
||||
};
|
||||
|
@ -394,7 +394,7 @@ struct mlx5e_sq_dma {
|
|||
};
|
||||
|
||||
enum {
|
||||
MLX5E_SQ_STATE_FLUSH,
|
||||
MLX5E_SQ_STATE_ENABLED,
|
||||
MLX5E_SQ_STATE_BF_ENABLE,
|
||||
};
|
||||
|
||||
|
|
|
@ -759,6 +759,7 @@ static int mlx5e_open_rq(struct mlx5e_channel *c,
|
|||
if (err)
|
||||
goto err_destroy_rq;
|
||||
|
||||
set_bit(MLX5E_RQ_STATE_ENABLED, &rq->state);
|
||||
err = mlx5e_modify_rq_state(rq, MLX5_RQC_STATE_RST, MLX5_RQC_STATE_RDY);
|
||||
if (err)
|
||||
goto err_disable_rq;
|
||||
|
@ -773,6 +774,7 @@ static int mlx5e_open_rq(struct mlx5e_channel *c,
|
|||
return 0;
|
||||
|
||||
err_disable_rq:
|
||||
clear_bit(MLX5E_RQ_STATE_ENABLED, &rq->state);
|
||||
mlx5e_disable_rq(rq);
|
||||
err_destroy_rq:
|
||||
mlx5e_destroy_rq(rq);
|
||||
|
@ -782,7 +784,7 @@ err_destroy_rq:
|
|||
|
||||
static void mlx5e_close_rq(struct mlx5e_rq *rq)
|
||||
{
|
||||
set_bit(MLX5E_RQ_STATE_FLUSH, &rq->state);
|
||||
clear_bit(MLX5E_RQ_STATE_ENABLED, &rq->state);
|
||||
napi_synchronize(&rq->channel->napi); /* prevent mlx5e_post_rx_wqes */
|
||||
cancel_work_sync(&rq->am.work);
|
||||
|
||||
|
@ -1006,7 +1008,6 @@ static int mlx5e_enable_sq(struct mlx5e_sq *sq, struct mlx5e_sq_param *param)
|
|||
MLX5_SET(sqc, sqc, min_wqe_inline_mode, sq->min_inline_mode);
|
||||
MLX5_SET(sqc, sqc, state, MLX5_SQC_STATE_RST);
|
||||
MLX5_SET(sqc, sqc, tis_lst_sz, param->type == MLX5E_SQ_ICO ? 0 : 1);
|
||||
MLX5_SET(sqc, sqc, flush_in_error_en, 1);
|
||||
|
||||
MLX5_SET(wq, wq, wq_type, MLX5_WQ_TYPE_CYCLIC);
|
||||
MLX5_SET(wq, wq, uar_page, sq->uar.index);
|
||||
|
@ -1083,6 +1084,7 @@ static int mlx5e_open_sq(struct mlx5e_channel *c,
|
|||
if (err)
|
||||
goto err_destroy_sq;
|
||||
|
||||
set_bit(MLX5E_SQ_STATE_ENABLED, &sq->state);
|
||||
err = mlx5e_modify_sq(sq, MLX5_SQC_STATE_RST, MLX5_SQC_STATE_RDY,
|
||||
false, 0);
|
||||
if (err)
|
||||
|
@ -1096,6 +1098,7 @@ static int mlx5e_open_sq(struct mlx5e_channel *c,
|
|||
return 0;
|
||||
|
||||
err_disable_sq:
|
||||
clear_bit(MLX5E_SQ_STATE_ENABLED, &sq->state);
|
||||
mlx5e_disable_sq(sq);
|
||||
err_destroy_sq:
|
||||
mlx5e_destroy_sq(sq);
|
||||
|
@ -1112,7 +1115,7 @@ static inline void netif_tx_disable_queue(struct netdev_queue *txq)
|
|||
|
||||
static void mlx5e_close_sq(struct mlx5e_sq *sq)
|
||||
{
|
||||
set_bit(MLX5E_SQ_STATE_FLUSH, &sq->state);
|
||||
clear_bit(MLX5E_SQ_STATE_ENABLED, &sq->state);
|
||||
/* prevent netif_tx_wake_queue */
|
||||
napi_synchronize(&sq->channel->napi);
|
||||
|
||||
|
@ -3092,7 +3095,7 @@ static void mlx5e_tx_timeout(struct net_device *dev)
|
|||
if (!netif_xmit_stopped(netdev_get_tx_queue(dev, i)))
|
||||
continue;
|
||||
sched_work = true;
|
||||
set_bit(MLX5E_SQ_STATE_FLUSH, &sq->state);
|
||||
clear_bit(MLX5E_SQ_STATE_ENABLED, &sq->state);
|
||||
netdev_err(dev, "TX timeout on queue: %d, SQ: 0x%x, CQ: 0x%x, SQ Cons: 0x%x SQ Prod: 0x%x\n",
|
||||
i, sq->sqn, sq->cq.mcq.cqn, sq->cc, sq->pc);
|
||||
}
|
||||
|
@ -3147,13 +3150,13 @@ static int mlx5e_xdp_set(struct net_device *netdev, struct bpf_prog *prog)
|
|||
for (i = 0; i < priv->params.num_channels; i++) {
|
||||
struct mlx5e_channel *c = priv->channel[i];
|
||||
|
||||
set_bit(MLX5E_RQ_STATE_FLUSH, &c->rq.state);
|
||||
clear_bit(MLX5E_RQ_STATE_ENABLED, &c->rq.state);
|
||||
napi_synchronize(&c->napi);
|
||||
/* prevent mlx5e_poll_rx_cq from accessing rq->xdp_prog */
|
||||
|
||||
old_prog = xchg(&c->rq.xdp_prog, prog);
|
||||
|
||||
clear_bit(MLX5E_RQ_STATE_FLUSH, &c->rq.state);
|
||||
set_bit(MLX5E_RQ_STATE_ENABLED, &c->rq.state);
|
||||
/* napi_schedule in case we have missed anything */
|
||||
set_bit(MLX5E_CHANNEL_NAPI_SCHED, &c->flags);
|
||||
napi_schedule(&c->napi);
|
||||
|
|
|
@ -340,7 +340,7 @@ static inline void mlx5e_post_umr_wqe(struct mlx5e_rq *rq, u16 ix)
|
|||
while ((pi = (sq->pc & wq->sz_m1)) > sq->edge) {
|
||||
sq->db.ico_wqe[pi].opcode = MLX5_OPCODE_NOP;
|
||||
sq->db.ico_wqe[pi].num_wqebbs = 1;
|
||||
mlx5e_send_nop(sq, true);
|
||||
mlx5e_send_nop(sq, false);
|
||||
}
|
||||
|
||||
wqe = mlx5_wq_cyc_get_wqe(wq, pi);
|
||||
|
@ -412,7 +412,7 @@ void mlx5e_post_rx_mpwqe(struct mlx5e_rq *rq)
|
|||
|
||||
clear_bit(MLX5E_RQ_STATE_UMR_WQE_IN_PROGRESS, &rq->state);
|
||||
|
||||
if (unlikely(test_bit(MLX5E_RQ_STATE_FLUSH, &rq->state))) {
|
||||
if (unlikely(!test_bit(MLX5E_RQ_STATE_ENABLED, &rq->state))) {
|
||||
mlx5e_free_rx_mpwqe(rq, &rq->mpwqe.info[wq->head]);
|
||||
return;
|
||||
}
|
||||
|
@ -445,7 +445,7 @@ void mlx5e_dealloc_rx_mpwqe(struct mlx5e_rq *rq, u16 ix)
|
|||
}
|
||||
|
||||
#define RQ_CANNOT_POST(rq) \
|
||||
(test_bit(MLX5E_RQ_STATE_FLUSH, &rq->state) || \
|
||||
(!test_bit(MLX5E_RQ_STATE_ENABLED, &rq->state) || \
|
||||
test_bit(MLX5E_RQ_STATE_UMR_WQE_IN_PROGRESS, &rq->state))
|
||||
|
||||
bool mlx5e_post_rx_wqes(struct mlx5e_rq *rq)
|
||||
|
@ -924,7 +924,7 @@ int mlx5e_poll_rx_cq(struct mlx5e_cq *cq, int budget)
|
|||
struct mlx5e_sq *xdp_sq = &rq->channel->xdp_sq;
|
||||
int work_done = 0;
|
||||
|
||||
if (unlikely(test_bit(MLX5E_RQ_STATE_FLUSH, &rq->state)))
|
||||
if (unlikely(!test_bit(MLX5E_RQ_STATE_ENABLED, &rq->state)))
|
||||
return 0;
|
||||
|
||||
if (cq->decmprs_left)
|
||||
|
|
|
@ -409,7 +409,7 @@ bool mlx5e_poll_tx_cq(struct mlx5e_cq *cq, int napi_budget)
|
|||
|
||||
sq = container_of(cq, struct mlx5e_sq, cq);
|
||||
|
||||
if (unlikely(test_bit(MLX5E_SQ_STATE_FLUSH, &sq->state)))
|
||||
if (unlikely(!test_bit(MLX5E_SQ_STATE_ENABLED, &sq->state)))
|
||||
return false;
|
||||
|
||||
npkts = 0;
|
||||
|
|
|
@ -56,7 +56,7 @@ static void mlx5e_poll_ico_cq(struct mlx5e_cq *cq)
|
|||
struct mlx5_cqe64 *cqe;
|
||||
u16 sqcc;
|
||||
|
||||
if (unlikely(test_bit(MLX5E_SQ_STATE_FLUSH, &sq->state)))
|
||||
if (unlikely(!test_bit(MLX5E_SQ_STATE_ENABLED, &sq->state)))
|
||||
return;
|
||||
|
||||
cqe = mlx5e_get_cqe(cq);
|
||||
|
@ -113,7 +113,7 @@ static inline bool mlx5e_poll_xdp_tx_cq(struct mlx5e_cq *cq)
|
|||
|
||||
sq = container_of(cq, struct mlx5e_sq, cq);
|
||||
|
||||
if (unlikely(test_bit(MLX5E_SQ_STATE_FLUSH, &sq->state)))
|
||||
if (unlikely(!test_bit(MLX5E_SQ_STATE_ENABLED, &sq->state)))
|
||||
return false;
|
||||
|
||||
/* sq->cc must be updated only after mlx5_cqwq_update_db_record(),
|
||||
|
|
|
@ -62,13 +62,13 @@ MODULE_DESCRIPTION("Mellanox Connect-IB, ConnectX-4 core driver");
|
|||
MODULE_LICENSE("Dual BSD/GPL");
|
||||
MODULE_VERSION(DRIVER_VERSION);
|
||||
|
||||
int mlx5_core_debug_mask;
|
||||
module_param_named(debug_mask, mlx5_core_debug_mask, int, 0644);
|
||||
unsigned int mlx5_core_debug_mask;
|
||||
module_param_named(debug_mask, mlx5_core_debug_mask, uint, 0644);
|
||||
MODULE_PARM_DESC(debug_mask, "debug mask: 1 = dump cmd data, 2 = dump cmd exec time, 3 = both. Default=0");
|
||||
|
||||
#define MLX5_DEFAULT_PROF 2
|
||||
static int prof_sel = MLX5_DEFAULT_PROF;
|
||||
module_param_named(prof_sel, prof_sel, int, 0444);
|
||||
static unsigned int prof_sel = MLX5_DEFAULT_PROF;
|
||||
module_param_named(prof_sel, prof_sel, uint, 0444);
|
||||
MODULE_PARM_DESC(prof_sel, "profile selector. Valid range 0 - 2");
|
||||
|
||||
enum {
|
||||
|
@ -732,13 +732,15 @@ static int mlx5_core_set_issi(struct mlx5_core_dev *dev)
|
|||
u8 status;
|
||||
|
||||
mlx5_cmd_mbox_status(query_out, &status, &syndrome);
|
||||
if (status == MLX5_CMD_STAT_BAD_OP_ERR) {
|
||||
pr_debug("Only ISSI 0 is supported\n");
|
||||
return 0;
|
||||
if (!status || syndrome == MLX5_DRIVER_SYND) {
|
||||
mlx5_core_err(dev, "Failed to query ISSI err(%d) status(%d) synd(%d)\n",
|
||||
err, status, syndrome);
|
||||
return err;
|
||||
}
|
||||
|
||||
pr_err("failed to query ISSI err(%d)\n", err);
|
||||
return err;
|
||||
mlx5_core_warn(dev, "Query ISSI is not supported by FW, ISSI is 0\n");
|
||||
dev->issi = 0;
|
||||
return 0;
|
||||
}
|
||||
|
||||
sup_issi = MLX5_GET(query_issi_out, query_out, supported_issi_dw0);
|
||||
|
@ -752,7 +754,8 @@ static int mlx5_core_set_issi(struct mlx5_core_dev *dev)
|
|||
err = mlx5_cmd_exec(dev, set_in, sizeof(set_in),
|
||||
set_out, sizeof(set_out));
|
||||
if (err) {
|
||||
pr_err("failed to set ISSI=1 err(%d)\n", err);
|
||||
mlx5_core_err(dev, "Failed to set ISSI to 1 err(%d)\n",
|
||||
err);
|
||||
return err;
|
||||
}
|
||||
|
||||
|
@ -1227,13 +1230,6 @@ static int init_one(struct pci_dev *pdev,
|
|||
|
||||
dev->pdev = pdev;
|
||||
dev->event = mlx5_core_event;
|
||||
|
||||
if (prof_sel < 0 || prof_sel >= ARRAY_SIZE(profile)) {
|
||||
mlx5_core_warn(dev,
|
||||
"selected profile out of range, selecting default (%d)\n",
|
||||
MLX5_DEFAULT_PROF);
|
||||
prof_sel = MLX5_DEFAULT_PROF;
|
||||
}
|
||||
dev->profile = &profile[prof_sel];
|
||||
|
||||
INIT_LIST_HEAD(&priv->ctx_list);
|
||||
|
@ -1450,10 +1446,22 @@ static struct pci_driver mlx5_core_driver = {
|
|||
.sriov_configure = mlx5_core_sriov_configure,
|
||||
};
|
||||
|
||||
static void mlx5_core_verify_params(void)
|
||||
{
|
||||
if (prof_sel >= ARRAY_SIZE(profile)) {
|
||||
pr_warn("mlx5_core: WARNING: Invalid module parameter prof_sel %d, valid range 0-%zu, changing back to default(%d)\n",
|
||||
prof_sel,
|
||||
ARRAY_SIZE(profile) - 1,
|
||||
MLX5_DEFAULT_PROF);
|
||||
prof_sel = MLX5_DEFAULT_PROF;
|
||||
}
|
||||
}
|
||||
|
||||
static int __init init(void)
|
||||
{
|
||||
int err;
|
||||
|
||||
mlx5_core_verify_params();
|
||||
mlx5_register_debugfs();
|
||||
|
||||
err = pci_register_driver(&mlx5_core_driver);
|
||||
|
|
|
@ -44,11 +44,11 @@
|
|||
|
||||
#define MLX5_TOTAL_VPORTS(mdev) (1 + pci_sriov_get_totalvfs(mdev->pdev))
|
||||
|
||||
extern int mlx5_core_debug_mask;
|
||||
extern uint mlx5_core_debug_mask;
|
||||
|
||||
#define mlx5_core_dbg(__dev, format, ...) \
|
||||
dev_dbg(&(__dev)->pdev->dev, "%s:%s:%d:(pid %d): " format, \
|
||||
(__dev)->priv.name, __func__, __LINE__, current->pid, \
|
||||
dev_dbg(&(__dev)->pdev->dev, "%s:%d:(pid %d): " format, \
|
||||
__func__, __LINE__, current->pid, \
|
||||
##__VA_ARGS__)
|
||||
|
||||
#define mlx5_core_dbg_mask(__dev, mask, format, ...) \
|
||||
|
@ -63,8 +63,8 @@ do { \
|
|||
##__VA_ARGS__)
|
||||
|
||||
#define mlx5_core_warn(__dev, format, ...) \
|
||||
dev_warn(&(__dev)->pdev->dev, "%s:%s:%d:(pid %d): " format, \
|
||||
(__dev)->priv.name, __func__, __LINE__, current->pid, \
|
||||
dev_warn(&(__dev)->pdev->dev, "%s:%d:(pid %d): " format, \
|
||||
__func__, __LINE__, current->pid, \
|
||||
##__VA_ARGS__)
|
||||
|
||||
#define mlx5_core_info(__dev, format, ...) \
|
||||
|
@ -75,6 +75,11 @@ enum {
|
|||
MLX5_CMD_TIME, /* print command execution time */
|
||||
};
|
||||
|
||||
enum {
|
||||
MLX5_DRIVER_STATUS_ABORTED = 0xfe,
|
||||
MLX5_DRIVER_SYND = 0xbadd00de,
|
||||
};
|
||||
|
||||
int mlx5_query_hca_caps(struct mlx5_core_dev *dev);
|
||||
int mlx5_query_board_id(struct mlx5_core_dev *dev);
|
||||
int mlx5_cmd_init_hca(struct mlx5_core_dev *dev);
|
||||
|
|
|
@ -1730,6 +1730,7 @@ static int qed_ll2_start_xmit(struct qed_dev *cdev, struct sk_buff *skb)
|
|||
mapping))) {
|
||||
DP_NOTICE(cdev,
|
||||
"Unable to map frag - dropping packet\n");
|
||||
rc = -ENOMEM;
|
||||
goto err;
|
||||
}
|
||||
} else {
|
||||
|
|
|
@ -43,9 +43,11 @@ static void dwmac1000_dma_axi(void __iomem *ioaddr, struct stmmac_axi *axi)
|
|||
if (axi->axi_xit_frm)
|
||||
value |= DMA_AXI_LPI_XIT_FRM;
|
||||
|
||||
value &= ~DMA_AXI_WR_OSR_LMT;
|
||||
value |= (axi->axi_wr_osr_lmt & DMA_AXI_WR_OSR_LMT_MASK) <<
|
||||
DMA_AXI_WR_OSR_LMT_SHIFT;
|
||||
|
||||
value &= ~DMA_AXI_RD_OSR_LMT;
|
||||
value |= (axi->axi_rd_osr_lmt & DMA_AXI_RD_OSR_LMT_MASK) <<
|
||||
DMA_AXI_RD_OSR_LMT_SHIFT;
|
||||
|
||||
|
|
|
@ -30,9 +30,11 @@ static void dwmac4_dma_axi(void __iomem *ioaddr, struct stmmac_axi *axi)
|
|||
if (axi->axi_xit_frm)
|
||||
value |= DMA_AXI_LPI_XIT_FRM;
|
||||
|
||||
value &= ~DMA_AXI_WR_OSR_LMT;
|
||||
value |= (axi->axi_wr_osr_lmt & DMA_AXI_OSR_MAX) <<
|
||||
DMA_AXI_WR_OSR_LMT_SHIFT;
|
||||
|
||||
value &= ~DMA_AXI_RD_OSR_LMT;
|
||||
value |= (axi->axi_rd_osr_lmt & DMA_AXI_OSR_MAX) <<
|
||||
DMA_AXI_RD_OSR_LMT_SHIFT;
|
||||
|
||||
|
|
|
@ -126,8 +126,10 @@ static struct stmmac_axi *stmmac_axi_setup(struct platform_device *pdev)
|
|||
axi->axi_mb = of_property_read_bool(np, "snps,axi_mb");
|
||||
axi->axi_rb = of_property_read_bool(np, "snps,axi_rb");
|
||||
|
||||
of_property_read_u32(np, "snps,wr_osr_lmt", &axi->axi_wr_osr_lmt);
|
||||
of_property_read_u32(np, "snps,rd_osr_lmt", &axi->axi_rd_osr_lmt);
|
||||
if (of_property_read_u32(np, "snps,wr_osr_lmt", &axi->axi_wr_osr_lmt))
|
||||
axi->axi_wr_osr_lmt = 1;
|
||||
if (of_property_read_u32(np, "snps,rd_osr_lmt", &axi->axi_rd_osr_lmt))
|
||||
axi->axi_rd_osr_lmt = 1;
|
||||
of_property_read_u32_array(np, "snps,blen", axi->axi_blen, AXI_BLEN);
|
||||
of_node_put(np);
|
||||
|
||||
|
|
|
@ -1723,6 +1723,7 @@ static int irda_usb_probe(struct usb_interface *intf,
|
|||
/* Don't change this buffer size and allocation without doing
|
||||
* some heavy and complete testing. Don't ask why :-(
|
||||
* Jean II */
|
||||
ret = -ENOMEM;
|
||||
self->speed_buff = kzalloc(IRDA_USB_SPEED_MTU, GFP_KERNEL);
|
||||
if (!self->speed_buff)
|
||||
goto err_out_3;
|
||||
|
|
|
@ -3395,6 +3395,7 @@ static int lan78xx_probe(struct usb_interface *intf,
|
|||
if (buf) {
|
||||
dev->urb_intr = usb_alloc_urb(0, GFP_KERNEL);
|
||||
if (!dev->urb_intr) {
|
||||
ret = -ENOMEM;
|
||||
kfree(buf);
|
||||
goto out3;
|
||||
} else {
|
||||
|
|
|
@ -969,12 +969,17 @@ static int virtnet_set_mac_address(struct net_device *dev, void *p)
|
|||
struct virtnet_info *vi = netdev_priv(dev);
|
||||
struct virtio_device *vdev = vi->vdev;
|
||||
int ret;
|
||||
struct sockaddr *addr = p;
|
||||
struct sockaddr *addr;
|
||||
struct scatterlist sg;
|
||||
|
||||
ret = eth_prepare_mac_addr_change(dev, p);
|
||||
addr = kmalloc(sizeof(*addr), GFP_KERNEL);
|
||||
if (!addr)
|
||||
return -ENOMEM;
|
||||
memcpy(addr, p, sizeof(*addr));
|
||||
|
||||
ret = eth_prepare_mac_addr_change(dev, addr);
|
||||
if (ret)
|
||||
return ret;
|
||||
goto out;
|
||||
|
||||
if (virtio_has_feature(vdev, VIRTIO_NET_F_CTRL_MAC_ADDR)) {
|
||||
sg_init_one(&sg, addr->sa_data, dev->addr_len);
|
||||
|
@ -982,7 +987,8 @@ static int virtnet_set_mac_address(struct net_device *dev, void *p)
|
|||
VIRTIO_NET_CTRL_MAC_ADDR_SET, &sg)) {
|
||||
dev_warn(&vdev->dev,
|
||||
"Failed to set mac address by vq command.\n");
|
||||
return -EINVAL;
|
||||
ret = -EINVAL;
|
||||
goto out;
|
||||
}
|
||||
} else if (virtio_has_feature(vdev, VIRTIO_NET_F_MAC) &&
|
||||
!virtio_has_feature(vdev, VIRTIO_F_VERSION_1)) {
|
||||
|
@ -996,8 +1002,11 @@ static int virtnet_set_mac_address(struct net_device *dev, void *p)
|
|||
}
|
||||
|
||||
eth_commit_mac_addr_change(dev, p);
|
||||
ret = 0;
|
||||
|
||||
return 0;
|
||||
out:
|
||||
kfree(addr);
|
||||
return ret;
|
||||
}
|
||||
|
||||
static struct rtnl_link_stats64 *virtnet_stats(struct net_device *dev,
|
||||
|
|
|
@ -31,7 +31,7 @@
|
|||
#include <linux/hdlc/ioctl.h>
|
||||
|
||||
/* For glibc compatibility. An empty enum does not compile. */
|
||||
#if __UAPI_DEF_IF_NET_DEVICE_FLAGS_LOWER_UP_DORMANT_ECHO != 0 && \
|
||||
#if __UAPI_DEF_IF_NET_DEVICE_FLAGS_LOWER_UP_DORMANT_ECHO != 0 || \
|
||||
__UAPI_DEF_IF_NET_DEVICE_FLAGS != 0
|
||||
/**
|
||||
* enum net_device_flags - &struct net_device flags
|
||||
|
@ -99,7 +99,7 @@ enum net_device_flags {
|
|||
IFF_ECHO = 1<<18, /* volatile */
|
||||
#endif /* __UAPI_DEF_IF_NET_DEVICE_FLAGS_LOWER_UP_DORMANT_ECHO */
|
||||
};
|
||||
#endif /* __UAPI_DEF_IF_NET_DEVICE_FLAGS_LOWER_UP_DORMANT_ECHO != 0 && __UAPI_DEF_IF_NET_DEVICE_FLAGS != 0 */
|
||||
#endif /* __UAPI_DEF_IF_NET_DEVICE_FLAGS_LOWER_UP_DORMANT_ECHO != 0 || __UAPI_DEF_IF_NET_DEVICE_FLAGS != 0 */
|
||||
|
||||
/* for compatibility with glibc net/if.h */
|
||||
#if __UAPI_DEF_IF_NET_DEVICE_FLAGS
|
||||
|
|
|
@ -5,6 +5,7 @@ header-y += nf_conntrack_ftp.h
|
|||
header-y += nf_conntrack_sctp.h
|
||||
header-y += nf_conntrack_tcp.h
|
||||
header-y += nf_conntrack_tuple_common.h
|
||||
header-y += nf_log.h
|
||||
header-y += nf_tables.h
|
||||
header-y += nf_tables_compat.h
|
||||
header-y += nf_nat.h
|
||||
|
|
|
@ -12,3 +12,4 @@ header-y += tc_bpf.h
|
|||
header-y += tc_connmark.h
|
||||
header-y += tc_ife.h
|
||||
header-y += tc_tunnel_key.h
|
||||
header-y += tc_skbmod.h
|
||||
|
|
|
@ -3282,7 +3282,7 @@ static bool batadv_send_my_tt_response(struct batadv_priv *bat_priv,
|
|||
&tvlv_tt_data,
|
||||
&tt_change,
|
||||
&tt_len);
|
||||
if (!tt_len)
|
||||
if (!tt_len || !tvlv_len)
|
||||
goto unlock;
|
||||
|
||||
/* Copy the last orig_node's OGM buffer */
|
||||
|
@ -3300,7 +3300,7 @@ static bool batadv_send_my_tt_response(struct batadv_priv *bat_priv,
|
|||
&tvlv_tt_data,
|
||||
&tt_change,
|
||||
&tt_len);
|
||||
if (!tt_len)
|
||||
if (!tt_len || !tvlv_len)
|
||||
goto out;
|
||||
|
||||
/* fill the rest of the tvlv with the real TT entries */
|
||||
|
|
|
@ -898,6 +898,7 @@ int br_sysfs_addbr(struct net_device *dev)
|
|||
if (!br->ifobj) {
|
||||
pr_info("%s: can't add kobject (directory) %s/%s\n",
|
||||
__func__, dev->name, SYSFS_BRIDGE_PORT_SUBDIR);
|
||||
err = -ENOMEM;
|
||||
goto out3;
|
||||
}
|
||||
return 0;
|
||||
|
|
|
@ -1107,10 +1107,7 @@ static struct net_proto_family caif_family_ops = {
|
|||
|
||||
static int __init caif_sktinit_module(void)
|
||||
{
|
||||
int err = sock_register(&caif_family_ops);
|
||||
if (!err)
|
||||
return err;
|
||||
return 0;
|
||||
return sock_register(&caif_family_ops);
|
||||
}
|
||||
|
||||
static void __exit caif_sktexit_module(void)
|
||||
|
|
|
@ -1353,6 +1353,7 @@ static int dcbnl_cee_fill(struct sk_buff *skb, struct net_device *netdev)
|
|||
dcb_unlock:
|
||||
spin_unlock_bh(&dcb_lock);
|
||||
nla_put_failure:
|
||||
err = -EMSGSIZE;
|
||||
return err;
|
||||
}
|
||||
|
||||
|
|
|
@ -719,6 +719,13 @@ static unsigned char update_suffix(struct key_vector *tn)
|
|||
{
|
||||
unsigned char slen = tn->pos;
|
||||
unsigned long stride, i;
|
||||
unsigned char slen_max;
|
||||
|
||||
/* only vector 0 can have a suffix length greater than or equal to
|
||||
* tn->pos + tn->bits, the second highest node will have a suffix
|
||||
* length at most of tn->pos + tn->bits - 1
|
||||
*/
|
||||
slen_max = min_t(unsigned char, tn->pos + tn->bits - 1, tn->slen);
|
||||
|
||||
/* search though the list of children looking for nodes that might
|
||||
* have a suffix greater than the one we currently have. This is
|
||||
|
@ -736,12 +743,8 @@ static unsigned char update_suffix(struct key_vector *tn)
|
|||
slen = n->slen;
|
||||
i &= ~(stride - 1);
|
||||
|
||||
/* if slen covers all but the last bit we can stop here
|
||||
* there will be nothing longer than that since only node
|
||||
* 0 and 1 << (bits - 1) could have that as their suffix
|
||||
* length.
|
||||
*/
|
||||
if ((slen + 1) >= (tn->pos + tn->bits))
|
||||
/* stop searching if we have hit the maximum possible value */
|
||||
if (slen >= slen_max)
|
||||
break;
|
||||
}
|
||||
|
||||
|
@ -913,39 +916,27 @@ static struct key_vector *resize(struct trie *t, struct key_vector *tn)
|
|||
return collapse(t, tn);
|
||||
|
||||
/* update parent in case halve failed */
|
||||
tp = node_parent(tn);
|
||||
|
||||
/* Return if at least one deflate was run */
|
||||
if (max_work != MAX_WORK)
|
||||
return tp;
|
||||
|
||||
/* push the suffix length to the parent node */
|
||||
if (tn->slen > tn->pos) {
|
||||
unsigned char slen = update_suffix(tn);
|
||||
|
||||
if (slen > tp->slen)
|
||||
tp->slen = slen;
|
||||
}
|
||||
|
||||
return tp;
|
||||
return node_parent(tn);
|
||||
}
|
||||
|
||||
static void leaf_pull_suffix(struct key_vector *tp, struct key_vector *l)
|
||||
static void node_pull_suffix(struct key_vector *tn, unsigned char slen)
|
||||
{
|
||||
while ((tp->slen > tp->pos) && (tp->slen > l->slen)) {
|
||||
if (update_suffix(tp) > l->slen)
|
||||
unsigned char node_slen = tn->slen;
|
||||
|
||||
while ((node_slen > tn->pos) && (node_slen > slen)) {
|
||||
slen = update_suffix(tn);
|
||||
if (node_slen == slen)
|
||||
break;
|
||||
tp = node_parent(tp);
|
||||
|
||||
tn = node_parent(tn);
|
||||
node_slen = tn->slen;
|
||||
}
|
||||
}
|
||||
|
||||
static void leaf_push_suffix(struct key_vector *tn, struct key_vector *l)
|
||||
static void node_push_suffix(struct key_vector *tn, unsigned char slen)
|
||||
{
|
||||
/* if this is a new leaf then tn will be NULL and we can sort
|
||||
* out parent suffix lengths as a part of trie_rebalance
|
||||
*/
|
||||
while (tn->slen < l->slen) {
|
||||
tn->slen = l->slen;
|
||||
while (tn->slen < slen) {
|
||||
tn->slen = slen;
|
||||
tn = node_parent(tn);
|
||||
}
|
||||
}
|
||||
|
@ -1066,6 +1057,7 @@ static int fib_insert_node(struct trie *t, struct key_vector *tp,
|
|||
}
|
||||
|
||||
/* Case 3: n is NULL, and will just insert a new leaf */
|
||||
node_push_suffix(tp, new->fa_slen);
|
||||
NODE_INIT_PARENT(l, tp);
|
||||
put_child_root(tp, key, l);
|
||||
trie_rebalance(t, tp);
|
||||
|
@ -1107,7 +1099,7 @@ static int fib_insert_alias(struct trie *t, struct key_vector *tp,
|
|||
/* if we added to the tail node then we need to update slen */
|
||||
if (l->slen < new->fa_slen) {
|
||||
l->slen = new->fa_slen;
|
||||
leaf_push_suffix(tp, l);
|
||||
node_push_suffix(tp, new->fa_slen);
|
||||
}
|
||||
|
||||
return 0;
|
||||
|
@ -1499,6 +1491,8 @@ static void fib_remove_alias(struct trie *t, struct key_vector *tp,
|
|||
* out parent suffix lengths as a part of trie_rebalance
|
||||
*/
|
||||
if (hlist_empty(&l->leaf)) {
|
||||
if (tp->slen == l->slen)
|
||||
node_pull_suffix(tp, tp->pos);
|
||||
put_child_root(tp, l->key, NULL);
|
||||
node_free(l);
|
||||
trie_rebalance(t, tp);
|
||||
|
@ -1511,7 +1505,7 @@ static void fib_remove_alias(struct trie *t, struct key_vector *tp,
|
|||
|
||||
/* update the trie with the latest suffix length */
|
||||
l->slen = fa->fa_slen;
|
||||
leaf_pull_suffix(tp, l);
|
||||
node_pull_suffix(tp, fa->fa_slen);
|
||||
}
|
||||
|
||||
/* Caller must hold RTNL. */
|
||||
|
@ -1783,6 +1777,10 @@ void fib_table_flush_external(struct fib_table *tb)
|
|||
if (IS_TRIE(pn))
|
||||
break;
|
||||
|
||||
/* update the suffix to address pulled leaves */
|
||||
if (pn->slen > pn->pos)
|
||||
update_suffix(pn);
|
||||
|
||||
/* resize completed node */
|
||||
pn = resize(t, pn);
|
||||
cindex = get_index(pkey, pn);
|
||||
|
@ -1849,6 +1847,10 @@ int fib_table_flush(struct net *net, struct fib_table *tb)
|
|||
if (IS_TRIE(pn))
|
||||
break;
|
||||
|
||||
/* update the suffix to address pulled leaves */
|
||||
if (pn->slen > pn->pos)
|
||||
update_suffix(pn);
|
||||
|
||||
/* resize completed node */
|
||||
pn = resize(t, pn);
|
||||
cindex = get_index(pkey, pn);
|
||||
|
|
|
@ -657,6 +657,10 @@ int ping_common_sendmsg(int family, struct msghdr *msg, size_t len,
|
|||
if (len > 0xFFFF)
|
||||
return -EMSGSIZE;
|
||||
|
||||
/* Must have at least a full ICMP header. */
|
||||
if (len < icmph_len)
|
||||
return -EINVAL;
|
||||
|
||||
/*
|
||||
* Check the flags.
|
||||
*/
|
||||
|
|
|
@ -128,6 +128,23 @@ int sysctl_tcp_invalid_ratelimit __read_mostly = HZ/2;
|
|||
#define REXMIT_LOST 1 /* retransmit packets marked lost */
|
||||
#define REXMIT_NEW 2 /* FRTO-style transmit of unsent/new packets */
|
||||
|
||||
static void tcp_gro_dev_warn(struct sock *sk, const struct sk_buff *skb)
|
||||
{
|
||||
static bool __once __read_mostly;
|
||||
|
||||
if (!__once) {
|
||||
struct net_device *dev;
|
||||
|
||||
__once = true;
|
||||
|
||||
rcu_read_lock();
|
||||
dev = dev_get_by_index_rcu(sock_net(sk), skb->skb_iif);
|
||||
pr_warn("%s: Driver has suspect GRO implementation, TCP performance may be compromised.\n",
|
||||
dev ? dev->name : "Unknown driver");
|
||||
rcu_read_unlock();
|
||||
}
|
||||
}
|
||||
|
||||
/* Adapt the MSS value used to make delayed ack decision to the
|
||||
* real world.
|
||||
*/
|
||||
|
@ -144,7 +161,10 @@ static void tcp_measure_rcv_mss(struct sock *sk, const struct sk_buff *skb)
|
|||
*/
|
||||
len = skb_shinfo(skb)->gso_size ? : skb->len;
|
||||
if (len >= icsk->icsk_ack.rcv_mss) {
|
||||
icsk->icsk_ack.rcv_mss = len;
|
||||
icsk->icsk_ack.rcv_mss = min_t(unsigned int, len,
|
||||
tcp_sk(sk)->advmss);
|
||||
if (unlikely(icsk->icsk_ack.rcv_mss != len))
|
||||
tcp_gro_dev_warn(sk, skb);
|
||||
} else {
|
||||
/* Otherwise, we make more careful check taking into account,
|
||||
* that SACKs block is variable.
|
||||
|
|
|
@ -1252,7 +1252,7 @@ static int rtm_to_route_config(struct sk_buff *skb, struct nlmsghdr *nlh,
|
|||
if (!nla)
|
||||
continue;
|
||||
|
||||
switch(index) {
|
||||
switch (index) {
|
||||
case RTA_OIF:
|
||||
cfg->rc_ifindex = nla_get_u32(nla);
|
||||
break;
|
||||
|
|
|
@ -322,11 +322,13 @@ static void netlink_skb_set_owner_r(struct sk_buff *skb, struct sock *sk)
|
|||
sk_mem_charge(sk, skb->truesize);
|
||||
}
|
||||
|
||||
static void __netlink_sock_destruct(struct sock *sk)
|
||||
static void netlink_sock_destruct(struct sock *sk)
|
||||
{
|
||||
struct netlink_sock *nlk = nlk_sk(sk);
|
||||
|
||||
if (nlk->cb_running) {
|
||||
if (nlk->cb.done)
|
||||
nlk->cb.done(&nlk->cb);
|
||||
module_put(nlk->cb.module);
|
||||
kfree_skb(nlk->cb.skb);
|
||||
}
|
||||
|
@ -348,21 +350,7 @@ static void netlink_sock_destruct_work(struct work_struct *work)
|
|||
struct netlink_sock *nlk = container_of(work, struct netlink_sock,
|
||||
work);
|
||||
|
||||
nlk->cb.done(&nlk->cb);
|
||||
__netlink_sock_destruct(&nlk->sk);
|
||||
}
|
||||
|
||||
static void netlink_sock_destruct(struct sock *sk)
|
||||
{
|
||||
struct netlink_sock *nlk = nlk_sk(sk);
|
||||
|
||||
if (nlk->cb_running && nlk->cb.done) {
|
||||
INIT_WORK(&nlk->work, netlink_sock_destruct_work);
|
||||
schedule_work(&nlk->work);
|
||||
return;
|
||||
}
|
||||
|
||||
__netlink_sock_destruct(sk);
|
||||
sk_free(&nlk->sk);
|
||||
}
|
||||
|
||||
/* This lock without WQ_FLAG_EXCLUSIVE is good on UP and it is _very_ bad on
|
||||
|
@ -667,8 +655,18 @@ out_module:
|
|||
static void deferred_put_nlk_sk(struct rcu_head *head)
|
||||
{
|
||||
struct netlink_sock *nlk = container_of(head, struct netlink_sock, rcu);
|
||||
struct sock *sk = &nlk->sk;
|
||||
|
||||
sock_put(&nlk->sk);
|
||||
if (!atomic_dec_and_test(&sk->sk_refcnt))
|
||||
return;
|
||||
|
||||
if (nlk->cb_running && nlk->cb.done) {
|
||||
INIT_WORK(&nlk->work, netlink_sock_destruct_work);
|
||||
schedule_work(&nlk->work);
|
||||
return;
|
||||
}
|
||||
|
||||
sk_free(sk);
|
||||
}
|
||||
|
||||
static int netlink_release(struct socket *sock)
|
||||
|
|
Loading…
Reference in New Issue