commit:     028590e4e5c04847f3e818d7e56df9ec4c1b638e
Author:     Mike Pagano <mpagano <AT> gentoo <DOT> org>
AuthorDate: Tue Sep 10 11:11:38 2019 +0000
Commit:     Mike Pagano <mpagano <AT> gentoo <DOT> org>
CommitDate: Tue Oct 29 13:59:02 2019 +0000
URL:        https://gitweb.gentoo.org/proj/linux-patches.git/commit/?id=028590e4

Linux patch 4.14.143

Signed-off-by: Mike Pagano <mpagano <AT> gentoo.org>

 0000_README               |    4 +
 1142_linux-4.14.143.patch | 1534 +++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 1538 insertions(+)

diff --git a/0000_README b/0000_README
index 1bb6a46..3e99608 100644
--- a/0000_README
+++ b/0000_README
@@ -611,6 +611,10 @@ Patch:  1141_linux-4.14.142.patch
 From:   https://www.kernel.org
 Desc:   Linux 4.14.142
 
+Patch:  1142_linux-4.14.143.patch
+From:   https://www.kernel.org
+Desc:   Linux 4.14.143
+
 Patch:  1500_XATTR_USER_PREFIX.patch
 From:   https://bugs.gentoo.org/show_bug.cgi?id=470644
 Desc:   Support for namespace user.pax.* on tmpfs.

diff --git a/1142_linux-4.14.143.patch b/1142_linux-4.14.143.patch
new file mode 100644
index 0000000..cbe0fd9
--- /dev/null
+++ b/1142_linux-4.14.143.patch
@@ -0,0 +1,1534 @@
+diff --git a/Makefile b/Makefile
+index ccced427d9de..caa2fba089a5 100644
+--- a/Makefile
++++ b/Makefile
+@@ -1,7 +1,7 @@
+ # SPDX-License-Identifier: GPL-2.0
+ VERSION = 4
+ PATCHLEVEL = 14
+-SUBLEVEL = 142
++SUBLEVEL = 143
+ EXTRAVERSION =
+ NAME = Petit Gorille
+ 
+diff --git a/arch/x86/include/asm/bootparam_utils.h 
b/arch/x86/include/asm/bootparam_utils.h
+index d3983fdf1012..8fa49cf1211d 100644
+--- a/arch/x86/include/asm/bootparam_utils.h
++++ b/arch/x86/include/asm/bootparam_utils.h
+@@ -71,6 +71,7 @@ static void sanitize_boot_params(struct boot_params 
*boot_params)
+                       BOOT_PARAM_PRESERVE(eddbuf_entries),
+                       BOOT_PARAM_PRESERVE(edd_mbr_sig_buf_entries),
+                       BOOT_PARAM_PRESERVE(edd_mbr_sig_buffer),
++                      BOOT_PARAM_PRESERVE(secure_boot),
+                       BOOT_PARAM_PRESERVE(hdr),
+                       BOOT_PARAM_PRESERVE(e820_table),
+                       BOOT_PARAM_PRESERVE(eddbuf),
+diff --git a/arch/x86/kernel/apic/apic.c b/arch/x86/kernel/apic/apic.c
+index 8199b7e4aff9..f8f9cfded97d 100644
+--- a/arch/x86/kernel/apic/apic.c
++++ b/arch/x86/kernel/apic/apic.c
+@@ -1148,10 +1148,6 @@ void clear_local_APIC(void)
+       apic_write(APIC_LVT0, v | APIC_LVT_MASKED);
+       v = apic_read(APIC_LVT1);
+       apic_write(APIC_LVT1, v | APIC_LVT_MASKED);
+-      if (!x2apic_enabled()) {
+-              v = apic_read(APIC_LDR) & ~APIC_LDR_MASK;
+-              apic_write(APIC_LDR, v);
+-      }
+       if (maxlvt >= 4) {
+               v = apic_read(APIC_LVTPC);
+               apic_write(APIC_LVTPC, v | APIC_LVT_MASKED);
+diff --git a/drivers/bluetooth/btqca.c b/drivers/bluetooth/btqca.c
+index 0bbdfcef2aa8..a48a61f22f82 100644
+--- a/drivers/bluetooth/btqca.c
++++ b/drivers/bluetooth/btqca.c
+@@ -363,6 +363,9 @@ int qca_uart_setup_rome(struct hci_dev *hdev, uint8_t 
baudrate)
+               return err;
+       }
+ 
++      /* Give the controller some time to get ready to receive the NVM */
++      msleep(10);
++
+       /* Download NVM configuration */
+       config.type = TLV_TYPE_NVM;
+       snprintf(config.fwname, sizeof(config.fwname), "qca/nvm_%08x.bin",
+diff --git a/drivers/gpu/drm/mediatek/mtk_drm_drv.c 
b/drivers/gpu/drm/mediatek/mtk_drm_drv.c
+index cada1c75c41c..034b50080304 100644
+--- a/drivers/gpu/drm/mediatek/mtk_drm_drv.c
++++ b/drivers/gpu/drm/mediatek/mtk_drm_drv.c
+@@ -185,6 +185,7 @@ static int mtk_drm_kms_init(struct drm_device *drm)
+       struct mtk_drm_private *private = drm->dev_private;
+       struct platform_device *pdev;
+       struct device_node *np;
++      struct device *dma_dev;
+       int ret;
+ 
+       if (!iommu_present(&platform_bus_type))
+@@ -242,7 +243,29 @@ static int mtk_drm_kms_init(struct drm_device *drm)
+               goto err_component_unbind;
+       }
+ 
+-      private->dma_dev = &pdev->dev;
++      dma_dev = &pdev->dev;
++      private->dma_dev = dma_dev;
++
++      /*
++       * Configure the DMA segment size to make sure we get contiguous IOVA
++       * when importing PRIME buffers.
++       */
++      if (!dma_dev->dma_parms) {
++              private->dma_parms_allocated = true;
++              dma_dev->dma_parms =
++                      devm_kzalloc(drm->dev, sizeof(*dma_dev->dma_parms),
++                                   GFP_KERNEL);
++      }
++      if (!dma_dev->dma_parms) {
++              ret = -ENOMEM;
++              goto err_component_unbind;
++      }
++
++      ret = dma_set_max_seg_size(dma_dev, (unsigned int)DMA_BIT_MASK(32));
++      if (ret) {
++              dev_err(dma_dev, "Failed to set DMA segment size\n");
++              goto err_unset_dma_parms;
++      }
+ 
+       /*
+        * We don't use the drm_irq_install() helpers provided by the DRM
+@@ -252,13 +275,16 @@ static int mtk_drm_kms_init(struct drm_device *drm)
+       drm->irq_enabled = true;
+       ret = drm_vblank_init(drm, MAX_CRTC);
+       if (ret < 0)
+-              goto err_component_unbind;
++              goto err_unset_dma_parms;
+ 
+       drm_kms_helper_poll_init(drm);
+       drm_mode_config_reset(drm);
+ 
+       return 0;
+ 
++err_unset_dma_parms:
++      if (private->dma_parms_allocated)
++              dma_dev->dma_parms = NULL;
+ err_component_unbind:
+       component_unbind_all(drm->dev, drm);
+ err_config_cleanup:
+@@ -269,9 +295,14 @@ err_config_cleanup:
+ 
+ static void mtk_drm_kms_deinit(struct drm_device *drm)
+ {
++      struct mtk_drm_private *private = drm->dev_private;
++
+       drm_kms_helper_poll_fini(drm);
+       drm_atomic_helper_shutdown(drm);
+ 
++      if (private->dma_parms_allocated)
++              private->dma_dev->dma_parms = NULL;
++
+       component_unbind_all(drm->dev, drm);
+       drm_mode_config_cleanup(drm);
+ }
+@@ -287,6 +318,18 @@ static const struct file_operations mtk_drm_fops = {
+       .compat_ioctl = drm_compat_ioctl,
+ };
+ 
++/*
++ * We need to override this because the device used to import the memory is
++ * not dev->dev, as drm_gem_prime_import() expects.
++ */
++struct drm_gem_object *mtk_drm_gem_prime_import(struct drm_device *dev,
++                                              struct dma_buf *dma_buf)
++{
++      struct mtk_drm_private *private = dev->dev_private;
++
++      return drm_gem_prime_import_dev(dev, dma_buf, private->dma_dev);
++}
++
+ static struct drm_driver mtk_drm_driver = {
+       .driver_features = DRIVER_MODESET | DRIVER_GEM | DRIVER_PRIME |
+                          DRIVER_ATOMIC,
+@@ -298,7 +341,7 @@ static struct drm_driver mtk_drm_driver = {
+       .prime_handle_to_fd = drm_gem_prime_handle_to_fd,
+       .prime_fd_to_handle = drm_gem_prime_fd_to_handle,
+       .gem_prime_export = drm_gem_prime_export,
+-      .gem_prime_import = drm_gem_prime_import,
++      .gem_prime_import = mtk_drm_gem_prime_import,
+       .gem_prime_get_sg_table = mtk_gem_prime_get_sg_table,
+       .gem_prime_import_sg_table = mtk_gem_prime_import_sg_table,
+       .gem_prime_mmap = mtk_drm_gem_mmap_buf,
+diff --git a/drivers/gpu/drm/mediatek/mtk_drm_drv.h 
b/drivers/gpu/drm/mediatek/mtk_drm_drv.h
+index c3378c452c0a..445dd45e65eb 100644
+--- a/drivers/gpu/drm/mediatek/mtk_drm_drv.h
++++ b/drivers/gpu/drm/mediatek/mtk_drm_drv.h
+@@ -56,6 +56,8 @@ struct mtk_drm_private {
+       } commit;
+ 
+       struct drm_atomic_state *suspend_state;
++
++      bool dma_parms_allocated;
+ };
+ 
+ extern struct platform_driver mtk_ddp_driver;
+diff --git a/drivers/hid/hid-cp2112.c b/drivers/hid/hid-cp2112.c
+index 4e940a096b2a..abf107945766 100644
+--- a/drivers/hid/hid-cp2112.c
++++ b/drivers/hid/hid-cp2112.c
+@@ -1149,8 +1149,6 @@ static unsigned int cp2112_gpio_irq_startup(struct 
irq_data *d)
+ 
+       INIT_DELAYED_WORK(&dev->gpio_poll_worker, cp2112_gpio_poll_callback);
+ 
+-      cp2112_gpio_direction_input(gc, d->hwirq);
+-
+       if (!dev->gpio_poll) {
+               dev->gpio_poll = true;
+               schedule_delayed_work(&dev->gpio_poll_worker, 0);
+@@ -1198,6 +1196,12 @@ static int __maybe_unused cp2112_allocate_irq(struct 
cp2112_device *dev,
+               return PTR_ERR(dev->desc[pin]);
+       }
+ 
++      ret = cp2112_gpio_direction_input(&dev->gc, pin);
++      if (ret < 0) {
++              dev_err(dev->gc.parent, "Failed to set GPIO to input dir\n");
++              goto err_desc;
++      }
++
+       ret = gpiochip_lock_as_irq(&dev->gc, pin);
+       if (ret) {
+               dev_err(dev->gc.parent, "Failed to lock GPIO as interrupt\n");
+diff --git a/drivers/infiniband/hw/mlx4/mad.c 
b/drivers/infiniband/hw/mlx4/mad.c
+index d604b3d5aa3e..c69158ccab82 100644
+--- a/drivers/infiniband/hw/mlx4/mad.c
++++ b/drivers/infiniband/hw/mlx4/mad.c
+@@ -1680,8 +1680,6 @@ tx_err:
+                                   tx_buf_size, DMA_TO_DEVICE);
+               kfree(tun_qp->tx_ring[i].buf.addr);
+       }
+-      kfree(tun_qp->tx_ring);
+-      tun_qp->tx_ring = NULL;
+       i = MLX4_NUM_TUNNEL_BUFS;
+ err:
+       while (i > 0) {
+@@ -1690,6 +1688,8 @@ err:
+                                   rx_buf_size, DMA_FROM_DEVICE);
+               kfree(tun_qp->ring[i].addr);
+       }
++      kfree(tun_qp->tx_ring);
++      tun_qp->tx_ring = NULL;
+       kfree(tun_qp->ring);
+       tun_qp->ring = NULL;
+       return -ENOMEM;
+diff --git a/drivers/input/serio/hyperv-keyboard.c 
b/drivers/input/serio/hyperv-keyboard.c
+index 55288a026e4e..c137ffa6fdec 100644
+--- a/drivers/input/serio/hyperv-keyboard.c
++++ b/drivers/input/serio/hyperv-keyboard.c
+@@ -245,40 +245,17 @@ static void hv_kbd_handle_received_packet(struct 
hv_device *hv_dev,
+ 
+ static void hv_kbd_on_channel_callback(void *context)
+ {
++      struct vmpacket_descriptor *desc;
+       struct hv_device *hv_dev = context;
+-      void *buffer;
+-      int bufferlen = 0x100; /* Start with sensible size */
+       u32 bytes_recvd;
+       u64 req_id;
+-      int error;
+ 
+-      buffer = kmalloc(bufferlen, GFP_ATOMIC);
+-      if (!buffer)
+-              return;
+-
+-      while (1) {
+-              error = vmbus_recvpacket_raw(hv_dev->channel, buffer, bufferlen,
+-                                           &bytes_recvd, &req_id);
+-              switch (error) {
+-              case 0:
+-                      if (bytes_recvd == 0) {
+-                              kfree(buffer);
+-                              return;
+-                      }
+-
+-                      hv_kbd_handle_received_packet(hv_dev, buffer,
+-                                                    bytes_recvd, req_id);
+-                      break;
++      foreach_vmbus_pkt(desc, hv_dev->channel) {
++              bytes_recvd = desc->len8 * 8;
++              req_id = desc->trans_id;
+ 
+-              case -ENOBUFS:
+-                      kfree(buffer);
+-                      /* Handle large packet */
+-                      bufferlen = bytes_recvd;
+-                      buffer = kmalloc(bytes_recvd, GFP_ATOMIC);
+-                      if (!buffer)
+-                              return;
+-                      break;
+-              }
++              hv_kbd_handle_received_packet(hv_dev, desc, bytes_recvd,
++                                            req_id);
+       }
+ }
+ 
+diff --git a/drivers/net/ethernet/cavium/liquidio/request_manager.c 
b/drivers/net/ethernet/cavium/liquidio/request_manager.c
+index 1e0fbce86d60..55e873126463 100644
+--- a/drivers/net/ethernet/cavium/liquidio/request_manager.c
++++ b/drivers/net/ethernet/cavium/liquidio/request_manager.c
+@@ -232,8 +232,10 @@ int octeon_setup_iq(struct octeon_device *oct,
+       }
+ 
+       oct->num_iqs++;
+-      if (oct->fn_list.enable_io_queues(oct))
++      if (oct->fn_list.enable_io_queues(oct)) {
++              octeon_delete_instr_queue(oct, iq_no);
+               return 1;
++      }
+ 
+       return 0;
+ }
+diff --git a/drivers/net/ethernet/chelsio/cxgb4/cxgb4_debugfs.c 
b/drivers/net/ethernet/chelsio/cxgb4/cxgb4_debugfs.c
+index 76540b0e082d..9e5cd18e7358 100644
+--- a/drivers/net/ethernet/chelsio/cxgb4/cxgb4_debugfs.c
++++ b/drivers/net/ethernet/chelsio/cxgb4/cxgb4_debugfs.c
+@@ -2777,8 +2777,10 @@ static ssize_t blocked_fl_write(struct file *filp, 
const char __user *ubuf,
+               return -ENOMEM;
+ 
+       err = bitmap_parse_user(ubuf, count, t, adap->sge.egr_sz);
+-      if (err)
++      if (err) {
++              kvfree(t);
+               return err;
++      }
+ 
+       bitmap_copy(adap->sge.blocked_fl, t, adap->sge.egr_sz);
+       kvfree(t);
+diff --git a/drivers/net/ethernet/ibm/ibmveth.c 
b/drivers/net/ethernet/ibm/ibmveth.c
+index 754dff4c1771..880d925438c1 100644
+--- a/drivers/net/ethernet/ibm/ibmveth.c
++++ b/drivers/net/ethernet/ibm/ibmveth.c
+@@ -1618,7 +1618,7 @@ static int ibmveth_probe(struct vio_dev *dev, const 
struct vio_device_id *id)
+       struct net_device *netdev;
+       struct ibmveth_adapter *adapter;
+       unsigned char *mac_addr_p;
+-      unsigned int *mcastFilterSize_p;
++      __be32 *mcastFilterSize_p;
+       long ret;
+       unsigned long ret_attr;
+ 
+@@ -1640,8 +1640,9 @@ static int ibmveth_probe(struct vio_dev *dev, const 
struct vio_device_id *id)
+               return -EINVAL;
+       }
+ 
+-      mcastFilterSize_p = (unsigned int *)vio_get_attribute(dev,
+-                                              VETH_MCAST_FILTER_SIZE, NULL);
++      mcastFilterSize_p = (__be32 *)vio_get_attribute(dev,
++                                                      VETH_MCAST_FILTER_SIZE,
++                                                      NULL);
+       if (!mcastFilterSize_p) {
+               dev_err(&dev->dev, "Can't find VETH_MCAST_FILTER_SIZE "
+                       "attribute\n");
+@@ -1658,7 +1659,7 @@ static int ibmveth_probe(struct vio_dev *dev, const 
struct vio_device_id *id)
+ 
+       adapter->vdev = dev;
+       adapter->netdev = netdev;
+-      adapter->mcastFilterSize = *mcastFilterSize_p;
++      adapter->mcastFilterSize = be32_to_cpu(*mcastFilterSize_p);
+       adapter->pool_config = 0;
+ 
+       netif_napi_add(netdev, &adapter->napi, ibmveth_poll, 16);
+diff --git a/drivers/net/ethernet/myricom/myri10ge/myri10ge.c 
b/drivers/net/ethernet/myricom/myri10ge/myri10ge.c
+index b171ed2015fe..a0a555052d8c 100644
+--- a/drivers/net/ethernet/myricom/myri10ge/myri10ge.c
++++ b/drivers/net/ethernet/myricom/myri10ge/myri10ge.c
+@@ -3922,7 +3922,7 @@ static int myri10ge_probe(struct pci_dev *pdev, const 
struct pci_device_id *ent)
+        * setup (if available). */
+       status = myri10ge_request_irq(mgp);
+       if (status != 0)
+-              goto abort_with_firmware;
++              goto abort_with_slices;
+       myri10ge_free_irq(mgp);
+ 
+       /* Save configuration space to be restored if the
+diff --git a/drivers/net/ethernet/renesas/ravb_main.c 
b/drivers/net/ethernet/renesas/ravb_main.c
+index ce79af4a7f6f..d73617cc3b15 100644
+--- a/drivers/net/ethernet/renesas/ravb_main.c
++++ b/drivers/net/ethernet/renesas/ravb_main.c
+@@ -1,6 +1,6 @@
+ /* Renesas Ethernet AVB device driver
+  *
+- * Copyright (C) 2014-2015 Renesas Electronics Corporation
++ * Copyright (C) 2014-2019 Renesas Electronics Corporation
+  * Copyright (C) 2015 Renesas Solutions Corp.
+  * Copyright (C) 2015-2016 Cogent Embedded, Inc. <sou...@cogentembedded.com>
+  *
+@@ -513,7 +513,10 @@ static void ravb_get_tx_tstamp(struct net_device *ndev)
+                       kfree(ts_skb);
+                       if (tag == tfa_tag) {
+                               skb_tstamp_tx(skb, &shhwtstamps);
++                              dev_consume_skb_any(skb);
+                               break;
++                      } else {
++                              dev_kfree_skb_any(skb);
+                       }
+               }
+               ravb_modify(ndev, TCCR, TCCR_TFR, TCCR_TFR);
+@@ -1576,7 +1579,7 @@ static netdev_tx_t ravb_start_xmit(struct sk_buff *skb, 
struct net_device *ndev)
+                                        DMA_TO_DEVICE);
+                       goto unmap;
+               }
+-              ts_skb->skb = skb;
++              ts_skb->skb = skb_get(skb);
+               ts_skb->tag = priv->ts_skb_tag++;
+               priv->ts_skb_tag &= 0x3ff;
+               list_add_tail(&ts_skb->list, &priv->ts_skb_list);
+@@ -1704,6 +1707,7 @@ static int ravb_close(struct net_device *ndev)
+       /* Clear the timestamp list */
+       list_for_each_entry_safe(ts_skb, ts_skb2, &priv->ts_skb_list, list) {
+               list_del(&ts_skb->list);
++              kfree_skb(ts_skb->skb);
+               kfree(ts_skb);
+       }
+ 
+diff --git a/drivers/net/ethernet/stmicro/stmmac/dwmac-rk.c 
b/drivers/net/ethernet/stmicro/stmmac/dwmac-rk.c
+index 01787344f6e5..712b5eb3507a 100644
+--- a/drivers/net/ethernet/stmicro/stmmac/dwmac-rk.c
++++ b/drivers/net/ethernet/stmicro/stmmac/dwmac-rk.c
+@@ -1145,10 +1145,8 @@ static int phy_power_on(struct rk_priv_data *bsp_priv, 
bool enable)
+       int ret;
+       struct device *dev = &bsp_priv->pdev->dev;
+ 
+-      if (!ldo) {
+-              dev_err(dev, "no regulator found\n");
+-              return -1;
+-      }
++      if (!ldo)
++              return 0;
+ 
+       if (enable) {
+               ret = regulator_enable(ldo);
+diff --git a/drivers/net/ethernet/toshiba/tc35815.c 
b/drivers/net/ethernet/toshiba/tc35815.c
+index cce9c9ed46aa..9146068979d2 100644
+--- a/drivers/net/ethernet/toshiba/tc35815.c
++++ b/drivers/net/ethernet/toshiba/tc35815.c
+@@ -1497,7 +1497,7 @@ tc35815_rx(struct net_device *dev, int limit)
+                       pci_unmap_single(lp->pci_dev,
+                                        lp->rx_skbs[cur_bd].skb_dma,
+                                        RX_BUF_SIZE, PCI_DMA_FROMDEVICE);
+-                      if (!HAVE_DMA_RXALIGN(lp) && NET_IP_ALIGN)
++                      if (!HAVE_DMA_RXALIGN(lp) && NET_IP_ALIGN != 0)
+                               memmove(skb->data, skb->data - NET_IP_ALIGN,
+                                       pkt_len);
+                       data = skb_put(skb, pkt_len);
+diff --git a/drivers/net/ethernet/tundra/tsi108_eth.c 
b/drivers/net/ethernet/tundra/tsi108_eth.c
+index c2d15d9c0c33..455979e47424 100644
+--- a/drivers/net/ethernet/tundra/tsi108_eth.c
++++ b/drivers/net/ethernet/tundra/tsi108_eth.c
+@@ -381,9 +381,10 @@ tsi108_stat_carry_one(int carry, int carry_bit, int 
carry_shift,
+ static void tsi108_stat_carry(struct net_device *dev)
+ {
+       struct tsi108_prv_data *data = netdev_priv(dev);
++      unsigned long flags;
+       u32 carry1, carry2;
+ 
+-      spin_lock_irq(&data->misclock);
++      spin_lock_irqsave(&data->misclock, flags);
+ 
+       carry1 = TSI_READ(TSI108_STAT_CARRY1);
+       carry2 = TSI_READ(TSI108_STAT_CARRY2);
+@@ -451,7 +452,7 @@ static void tsi108_stat_carry(struct net_device *dev)
+                             TSI108_STAT_TXPAUSEDROP_CARRY,
+                             &data->tx_pause_drop);
+ 
+-      spin_unlock_irq(&data->misclock);
++      spin_unlock_irqrestore(&data->misclock, flags);
+ }
+ 
+ /* Read a stat counter atomically with respect to carries.
+diff --git a/drivers/net/hyperv/netvsc_drv.c b/drivers/net/hyperv/netvsc_drv.c
+index eb92720dd1c4..33c1f6548fb7 100644
+--- a/drivers/net/hyperv/netvsc_drv.c
++++ b/drivers/net/hyperv/netvsc_drv.c
+@@ -1170,12 +1170,15 @@ static void netvsc_get_stats64(struct net_device *net,
+                              struct rtnl_link_stats64 *t)
+ {
+       struct net_device_context *ndev_ctx = netdev_priv(net);
+-      struct netvsc_device *nvdev = rcu_dereference_rtnl(ndev_ctx->nvdev);
++      struct netvsc_device *nvdev;
+       struct netvsc_vf_pcpu_stats vf_tot;
+       int i;
+ 
++      rcu_read_lock();
++
++      nvdev = rcu_dereference(ndev_ctx->nvdev);
+       if (!nvdev)
+-              return;
++              goto out;
+ 
+       netdev_stats_to_stats64(t, &net->stats);
+ 
+@@ -1214,6 +1217,8 @@ static void netvsc_get_stats64(struct net_device *net,
+               t->rx_packets   += packets;
+               t->multicast    += multicast;
+       }
++out:
++      rcu_read_unlock();
+ }
+ 
+ static int netvsc_set_mac_addr(struct net_device *ndev, void *p)
+diff --git a/drivers/net/usb/cx82310_eth.c b/drivers/net/usb/cx82310_eth.c
+index 947bea81d924..dfbdea22fbad 100644
+--- a/drivers/net/usb/cx82310_eth.c
++++ b/drivers/net/usb/cx82310_eth.c
+@@ -175,7 +175,8 @@ static int cx82310_bind(struct usbnet *dev, struct 
usb_interface *intf)
+       }
+       if (!timeout) {
+               dev_err(&udev->dev, "firmware not ready in time\n");
+-              return -ETIMEDOUT;
++              ret = -ETIMEDOUT;
++              goto err;
+       }
+ 
+       /* enable ethernet mode (?) */
+diff --git a/drivers/net/usb/kalmia.c b/drivers/net/usb/kalmia.c
+index ce0b0b4e3a57..c677ec2bae18 100644
+--- a/drivers/net/usb/kalmia.c
++++ b/drivers/net/usb/kalmia.c
+@@ -117,16 +117,16 @@ kalmia_init_and_get_ethernet_addr(struct usbnet *dev, u8 
*ethernet_addr)
+       status = kalmia_send_init_packet(dev, usb_buf, sizeof(init_msg_1)
+               / sizeof(init_msg_1[0]), usb_buf, 24);
+       if (status != 0)
+-              return status;
++              goto out;
+ 
+       memcpy(usb_buf, init_msg_2, 12);
+       status = kalmia_send_init_packet(dev, usb_buf, sizeof(init_msg_2)
+               / sizeof(init_msg_2[0]), usb_buf, 28);
+       if (status != 0)
+-              return status;
++              goto out;
+ 
+       memcpy(ethernet_addr, usb_buf + 10, ETH_ALEN);
+-
++out:
+       kfree(usb_buf);
+       return status;
+ }
+diff --git a/drivers/net/usb/lan78xx.c b/drivers/net/usb/lan78xx.c
+index b62c41114e34..24b994c68bcc 100644
+--- a/drivers/net/usb/lan78xx.c
++++ b/drivers/net/usb/lan78xx.c
+@@ -3645,7 +3645,7 @@ static int lan78xx_probe(struct usb_interface *intf,
+       ret = register_netdev(netdev);
+       if (ret != 0) {
+               netif_err(dev, probe, netdev, "couldn't register the device\n");
+-              goto out3;
++              goto out4;
+       }
+ 
+       usb_set_intfdata(intf, dev);
+@@ -3660,12 +3660,14 @@ static int lan78xx_probe(struct usb_interface *intf,
+ 
+       ret = lan78xx_phy_init(dev);
+       if (ret < 0)
+-              goto out4;
++              goto out5;
+ 
+       return 0;
+ 
+-out4:
++out5:
+       unregister_netdev(netdev);
++out4:
++      usb_free_urb(dev->urb_intr);
+ out3:
+       lan78xx_unbind(dev, intf);
+ out2:
+diff --git a/drivers/net/wimax/i2400m/fw.c b/drivers/net/wimax/i2400m/fw.c
+index a89b5685e68b..4577ee5bbddd 100644
+--- a/drivers/net/wimax/i2400m/fw.c
++++ b/drivers/net/wimax/i2400m/fw.c
+@@ -351,13 +351,15 @@ int i2400m_barker_db_init(const char *_options)
+                       }
+                       result = i2400m_barker_db_add(barker);
+                       if (result < 0)
+-                              goto error_add;
++                              goto error_parse_add;
+               }
+               kfree(options_orig);
+       }
+       return 0;
+ 
++error_parse_add:
+ error_parse:
++      kfree(options_orig);
+ error_add:
+       kfree(i2400m_barker_db);
+       return result;
+diff --git a/drivers/spi/spi-bcm2835aux.c b/drivers/spi/spi-bcm2835aux.c
+index bd00b7cc8b78..5c89bbb05441 100644
+--- a/drivers/spi/spi-bcm2835aux.c
++++ b/drivers/spi/spi-bcm2835aux.c
+@@ -178,24 +178,14 @@ static void bcm2835aux_spi_reset_hw(struct 
bcm2835aux_spi *bs)
+                     BCM2835_AUX_SPI_CNTL0_CLEARFIFO);
+ }
+ 
+-static irqreturn_t bcm2835aux_spi_interrupt(int irq, void *dev_id)
++static void bcm2835aux_spi_transfer_helper(struct bcm2835aux_spi *bs)
+ {
+-      struct spi_master *master = dev_id;
+-      struct bcm2835aux_spi *bs = spi_master_get_devdata(master);
+-      irqreturn_t ret = IRQ_NONE;
+-
+-      /* IRQ may be shared, so return if our interrupts are disabled */
+-      if (!(bcm2835aux_rd(bs, BCM2835_AUX_SPI_CNTL1) &
+-            (BCM2835_AUX_SPI_CNTL1_TXEMPTY | BCM2835_AUX_SPI_CNTL1_IDLE)))
+-              return ret;
++      u32 stat = bcm2835aux_rd(bs, BCM2835_AUX_SPI_STAT);
+ 
+       /* check if we have data to read */
+-      while (bs->rx_len &&
+-             (!(bcm2835aux_rd(bs, BCM2835_AUX_SPI_STAT) &
+-                BCM2835_AUX_SPI_STAT_RX_EMPTY))) {
++      for (; bs->rx_len && (stat & BCM2835_AUX_SPI_STAT_RX_LVL);
++           stat = bcm2835aux_rd(bs, BCM2835_AUX_SPI_STAT))
+               bcm2835aux_rd_fifo(bs);
+-              ret = IRQ_HANDLED;
+-      }
+ 
+       /* check if we have data to write */
+       while (bs->tx_len &&
+@@ -203,16 +193,21 @@ static irqreturn_t bcm2835aux_spi_interrupt(int irq, 
void *dev_id)
+              (!(bcm2835aux_rd(bs, BCM2835_AUX_SPI_STAT) &
+                 BCM2835_AUX_SPI_STAT_TX_FULL))) {
+               bcm2835aux_wr_fifo(bs);
+-              ret = IRQ_HANDLED;
+       }
++}
+ 
+-      /* and check if we have reached "done" */
+-      while (bs->rx_len &&
+-             (!(bcm2835aux_rd(bs, BCM2835_AUX_SPI_STAT) &
+-                BCM2835_AUX_SPI_STAT_BUSY))) {
+-              bcm2835aux_rd_fifo(bs);
+-              ret = IRQ_HANDLED;
+-      }
++static irqreturn_t bcm2835aux_spi_interrupt(int irq, void *dev_id)
++{
++      struct spi_master *master = dev_id;
++      struct bcm2835aux_spi *bs = spi_master_get_devdata(master);
++
++      /* IRQ may be shared, so return if our interrupts are disabled */
++      if (!(bcm2835aux_rd(bs, BCM2835_AUX_SPI_CNTL1) &
++            (BCM2835_AUX_SPI_CNTL1_TXEMPTY | BCM2835_AUX_SPI_CNTL1_IDLE)))
++              return IRQ_NONE;
++
++      /* do common fifo handling */
++      bcm2835aux_spi_transfer_helper(bs);
+ 
+       if (!bs->tx_len) {
+               /* disable tx fifo empty interrupt */
+@@ -226,8 +221,7 @@ static irqreturn_t bcm2835aux_spi_interrupt(int irq, void 
*dev_id)
+               complete(&master->xfer_completion);
+       }
+ 
+-      /* and return */
+-      return ret;
++      return IRQ_HANDLED;
+ }
+ 
+ static int __bcm2835aux_spi_transfer_one_irq(struct spi_master *master,
+@@ -273,7 +267,6 @@ static int bcm2835aux_spi_transfer_one_poll(struct 
spi_master *master,
+ {
+       struct bcm2835aux_spi *bs = spi_master_get_devdata(master);
+       unsigned long timeout;
+-      u32 stat;
+ 
+       /* configure spi */
+       bcm2835aux_wr(bs, BCM2835_AUX_SPI_CNTL1, bs->cntl[1]);
+@@ -284,24 +277,9 @@ static int bcm2835aux_spi_transfer_one_poll(struct 
spi_master *master,
+ 
+       /* loop until finished the transfer */
+       while (bs->rx_len) {
+-              /* read status */
+-              stat = bcm2835aux_rd(bs, BCM2835_AUX_SPI_STAT);
+-
+-              /* fill in tx fifo with remaining data */
+-              if ((bs->tx_len) && (!(stat & BCM2835_AUX_SPI_STAT_TX_FULL))) {
+-                      bcm2835aux_wr_fifo(bs);
+-                      continue;
+-              }
+ 
+-              /* read data from fifo for both cases */
+-              if (!(stat & BCM2835_AUX_SPI_STAT_RX_EMPTY)) {
+-                      bcm2835aux_rd_fifo(bs);
+-                      continue;
+-              }
+-              if (!(stat & BCM2835_AUX_SPI_STAT_BUSY)) {
+-                      bcm2835aux_rd_fifo(bs);
+-                      continue;
+-              }
++              /* do common fifo handling */
++              bcm2835aux_spi_transfer_helper(bs);
+ 
+               /* there is still data pending to read check the timeout */
+               if (bs->rx_len && time_after(jiffies, timeout)) {
+diff --git a/fs/ceph/caps.c b/fs/ceph/caps.c
+index 238d24348a98..df95e39ccd45 100644
+--- a/fs/ceph/caps.c
++++ b/fs/ceph/caps.c
+@@ -1162,6 +1162,7 @@ static int __send_cap(struct ceph_mds_client *mdsc, 
struct ceph_cap *cap,
+ {
+       struct ceph_inode_info *ci = cap->ci;
+       struct inode *inode = &ci->vfs_inode;
++      struct ceph_buffer *old_blob = NULL;
+       struct cap_msg_args arg;
+       int held, revoking, dropping;
+       int wake = 0;
+@@ -1227,7 +1228,7 @@ static int __send_cap(struct ceph_mds_client *mdsc, 
struct ceph_cap *cap,
+       ci->i_requested_max_size = arg.max_size;
+ 
+       if (flushing & CEPH_CAP_XATTR_EXCL) {
+-              __ceph_build_xattrs_blob(ci);
++              old_blob = __ceph_build_xattrs_blob(ci);
+               arg.xattr_version = ci->i_xattrs.version;
+               arg.xattr_buf = ci->i_xattrs.blob;
+       } else {
+@@ -1262,6 +1263,8 @@ static int __send_cap(struct ceph_mds_client *mdsc, 
struct ceph_cap *cap,
+ 
+       spin_unlock(&ci->i_ceph_lock);
+ 
++      ceph_buffer_put(old_blob);
++
+       ret = send_cap_msg(&arg);
+       if (ret < 0) {
+               dout("error sending cap msg, must requeue %p\n", inode);
+diff --git a/fs/ceph/inode.c b/fs/ceph/inode.c
+index f2b722f0df5d..9bda8c7a80a0 100644
+--- a/fs/ceph/inode.c
++++ b/fs/ceph/inode.c
+@@ -730,6 +730,7 @@ static int fill_inode(struct inode *inode, struct page 
*locked_page,
+       int issued = 0, implemented, new_issued;
+       struct timespec mtime, atime, ctime;
+       struct ceph_buffer *xattr_blob = NULL;
++      struct ceph_buffer *old_blob = NULL;
+       struct ceph_string *pool_ns = NULL;
+       struct ceph_cap *new_cap = NULL;
+       int err = 0;
+@@ -847,7 +848,7 @@ static int fill_inode(struct inode *inode, struct page 
*locked_page,
+       if ((ci->i_xattrs.version == 0 || !(issued & CEPH_CAP_XATTR_EXCL))  &&
+           le64_to_cpu(info->xattr_version) > ci->i_xattrs.version) {
+               if (ci->i_xattrs.blob)
+-                      ceph_buffer_put(ci->i_xattrs.blob);
++                      old_blob = ci->i_xattrs.blob;
+               ci->i_xattrs.blob = xattr_blob;
+               if (xattr_blob)
+                       memcpy(ci->i_xattrs.blob->vec.iov_base,
+@@ -993,8 +994,8 @@ static int fill_inode(struct inode *inode, struct page 
*locked_page,
+ out:
+       if (new_cap)
+               ceph_put_cap(mdsc, new_cap);
+-      if (xattr_blob)
+-              ceph_buffer_put(xattr_blob);
++      ceph_buffer_put(old_blob);
++      ceph_buffer_put(xattr_blob);
+       ceph_put_string(pool_ns);
+       return err;
+ }
+diff --git a/fs/ceph/snap.c b/fs/ceph/snap.c
+index a7e763dac038..29ed1688a1d3 100644
+--- a/fs/ceph/snap.c
++++ b/fs/ceph/snap.c
+@@ -460,6 +460,7 @@ void ceph_queue_cap_snap(struct ceph_inode_info *ci)
+       struct inode *inode = &ci->vfs_inode;
+       struct ceph_cap_snap *capsnap;
+       struct ceph_snap_context *old_snapc, *new_snapc;
++      struct ceph_buffer *old_blob = NULL;
+       int used, dirty;
+ 
+       capsnap = kzalloc(sizeof(*capsnap), GFP_NOFS);
+@@ -536,7 +537,7 @@ void ceph_queue_cap_snap(struct ceph_inode_info *ci)
+       capsnap->gid = inode->i_gid;
+ 
+       if (dirty & CEPH_CAP_XATTR_EXCL) {
+-              __ceph_build_xattrs_blob(ci);
++              old_blob = __ceph_build_xattrs_blob(ci);
+               capsnap->xattr_blob =
+                       ceph_buffer_get(ci->i_xattrs.blob);
+               capsnap->xattr_version = ci->i_xattrs.version;
+@@ -579,6 +580,7 @@ update_snapc:
+       }
+       spin_unlock(&ci->i_ceph_lock);
+ 
++      ceph_buffer_put(old_blob);
+       kfree(capsnap);
+       ceph_put_snap_context(old_snapc);
+ }
+diff --git a/fs/ceph/super.h b/fs/ceph/super.h
+index 60b70f0985f6..46f600107cb5 100644
+--- a/fs/ceph/super.h
++++ b/fs/ceph/super.h
+@@ -835,7 +835,7 @@ extern int ceph_getattr(const struct path *path, struct 
kstat *stat,
+ int __ceph_setxattr(struct inode *, const char *, const void *, size_t, int);
+ ssize_t __ceph_getxattr(struct inode *, const char *, void *, size_t);
+ extern ssize_t ceph_listxattr(struct dentry *, char *, size_t);
+-extern void __ceph_build_xattrs_blob(struct ceph_inode_info *ci);
++extern struct ceph_buffer *__ceph_build_xattrs_blob(struct ceph_inode_info 
*ci);
+ extern void __ceph_destroy_xattrs(struct ceph_inode_info *ci);
+ extern void __init ceph_xattr_init(void);
+ extern void ceph_xattr_exit(void);
+diff --git a/fs/ceph/xattr.c b/fs/ceph/xattr.c
+index 0376db8a74f8..3a166f860b6c 100644
+--- a/fs/ceph/xattr.c
++++ b/fs/ceph/xattr.c
+@@ -681,12 +681,15 @@ static int __get_required_blob_size(struct 
ceph_inode_info *ci, int name_size,
+ 
+ /*
+  * If there are dirty xattrs, reencode xattrs into the prealloc_blob
+- * and swap into place.
++ * and swap into place.  It returns the old i_xattrs.blob (or NULL) so
++ * that it can be freed by the caller as the i_ceph_lock is likely to be
++ * held.
+  */
+-void __ceph_build_xattrs_blob(struct ceph_inode_info *ci)
++struct ceph_buffer *__ceph_build_xattrs_blob(struct ceph_inode_info *ci)
+ {
+       struct rb_node *p;
+       struct ceph_inode_xattr *xattr = NULL;
++      struct ceph_buffer *old_blob = NULL;
+       void *dest;
+ 
+       dout("__build_xattrs_blob %p\n", &ci->vfs_inode);
+@@ -717,12 +720,14 @@ void __ceph_build_xattrs_blob(struct ceph_inode_info *ci)
+                       dest - ci->i_xattrs.prealloc_blob->vec.iov_base;
+ 
+               if (ci->i_xattrs.blob)
+-                      ceph_buffer_put(ci->i_xattrs.blob);
++                      old_blob = ci->i_xattrs.blob;
+               ci->i_xattrs.blob = ci->i_xattrs.prealloc_blob;
+               ci->i_xattrs.prealloc_blob = NULL;
+               ci->i_xattrs.dirty = false;
+               ci->i_xattrs.version++;
+       }
++
++      return old_blob;
+ }
+ 
+ static inline int __get_request_mask(struct inode *in) {
+@@ -955,6 +960,7 @@ int __ceph_setxattr(struct inode *inode, const char *name,
+       struct ceph_inode_info *ci = ceph_inode(inode);
+       struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc;
+       struct ceph_cap_flush *prealloc_cf = NULL;
++      struct ceph_buffer *old_blob = NULL;
+       int issued;
+       int err;
+       int dirty = 0;
+@@ -1023,13 +1029,15 @@ retry:
+               struct ceph_buffer *blob;
+ 
+               spin_unlock(&ci->i_ceph_lock);
+-              dout(" preaallocating new blob size=%d\n", required_blob_size);
++              ceph_buffer_put(old_blob); /* Shouldn't be required */
++              dout(" pre-allocating new blob size=%d\n", required_blob_size);
+               blob = ceph_buffer_new(required_blob_size, GFP_NOFS);
+               if (!blob)
+                       goto do_sync_unlocked;
+               spin_lock(&ci->i_ceph_lock);
++              /* prealloc_blob can't be released while holding i_ceph_lock */
+               if (ci->i_xattrs.prealloc_blob)
+-                      ceph_buffer_put(ci->i_xattrs.prealloc_blob);
++                      old_blob = ci->i_xattrs.prealloc_blob;
+               ci->i_xattrs.prealloc_blob = blob;
+               goto retry;
+       }
+@@ -1045,6 +1053,7 @@ retry:
+       }
+ 
+       spin_unlock(&ci->i_ceph_lock);
++      ceph_buffer_put(old_blob);
+       if (lock_snap_rwsem)
+               up_read(&mdsc->snap_rwsem);
+       if (dirty)
+diff --git a/fs/read_write.c b/fs/read_write.c
+index d6f8bfb0f794..38a8bcccf0dd 100644
+--- a/fs/read_write.c
++++ b/fs/read_write.c
+@@ -1882,10 +1882,7 @@ int vfs_clone_file_range(struct file *file_in, loff_t 
pos_in,
+ }
+ EXPORT_SYMBOL(vfs_clone_file_range);
+ 
+-/*
+- * Read a page's worth of file data into the page cache.  Return the page
+- * locked.
+- */
++/* Read a page's worth of file data into the page cache. */
+ static struct page *vfs_dedupe_get_page(struct inode *inode, loff_t offset)
+ {
+       struct address_space *mapping;
+@@ -1901,10 +1898,32 @@ static struct page *vfs_dedupe_get_page(struct inode 
*inode, loff_t offset)
+               put_page(page);
+               return ERR_PTR(-EIO);
+       }
+-      lock_page(page);
+       return page;
+ }
+ 
++/*
++ * Lock two pages, ensuring that we lock in offset order if the pages are from
++ * the same file.
++ */
++static void vfs_lock_two_pages(struct page *page1, struct page *page2)
++{
++      /* Always lock in order of increasing index. */
++      if (page1->index > page2->index)
++              swap(page1, page2);
++
++      lock_page(page1);
++      if (page1 != page2)
++              lock_page(page2);
++}
++
++/* Unlock two pages, being careful not to unlock the same page twice. */
++static void vfs_unlock_two_pages(struct page *page1, struct page *page2)
++{
++      unlock_page(page1);
++      if (page1 != page2)
++              unlock_page(page2);
++}
++
+ /*
+  * Compare extents of two files to see if they are the same.
+  * Caller must have locked both inodes to prevent write races.
+@@ -1942,10 +1961,24 @@ int vfs_dedupe_file_range_compare(struct inode *src, 
loff_t srcoff,
+               dest_page = vfs_dedupe_get_page(dest, destoff);
+               if (IS_ERR(dest_page)) {
+                       error = PTR_ERR(dest_page);
+-                      unlock_page(src_page);
+                       put_page(src_page);
+                       goto out_error;
+               }
++
++              vfs_lock_two_pages(src_page, dest_page);
++
++              /*
++               * Now that we've locked both pages, make sure they're still
++               * mapped to the file data we're interested in.  If not,
++               * someone is invalidating pages on us and we lose.
++               */
++              if (!PageUptodate(src_page) || !PageUptodate(dest_page) ||
++                  src_page->mapping != src->i_mapping ||
++                  dest_page->mapping != dest->i_mapping) {
++                      same = false;
++                      goto unlock;
++              }
++
+               src_addr = kmap_atomic(src_page);
+               dest_addr = kmap_atomic(dest_page);
+ 
+@@ -1957,8 +1990,8 @@ int vfs_dedupe_file_range_compare(struct inode *src, 
loff_t srcoff,
+ 
+               kunmap_atomic(dest_addr);
+               kunmap_atomic(src_addr);
+-              unlock_page(dest_page);
+-              unlock_page(src_page);
++unlock:
++              vfs_unlock_two_pages(src_page, dest_page);
+               put_page(dest_page);
+               put_page(src_page);
+ 
+diff --git a/include/linux/ceph/buffer.h b/include/linux/ceph/buffer.h
+index 5e58bb29b1a3..11cdc7c60480 100644
+--- a/include/linux/ceph/buffer.h
++++ b/include/linux/ceph/buffer.h
+@@ -30,7 +30,8 @@ static inline struct ceph_buffer *ceph_buffer_get(struct 
ceph_buffer *b)
+ 
+ static inline void ceph_buffer_put(struct ceph_buffer *b)
+ {
+-      kref_put(&b->kref, ceph_buffer_release);
++      if (b)
++              kref_put(&b->kref, ceph_buffer_release);
+ }
+ 
+ extern int ceph_decode_buffer(struct ceph_buffer **b, void **p, void *end);
+diff --git a/include/linux/gpio.h b/include/linux/gpio.h
+index 8ef7fc0ce0f0..b2f103b170a9 100644
+--- a/include/linux/gpio.h
++++ b/include/linux/gpio.h
+@@ -230,30 +230,6 @@ static inline int irq_to_gpio(unsigned irq)
+       return -EINVAL;
+ }
+ 
+-static inline int
+-gpiochip_add_pin_range(struct gpio_chip *chip, const char *pinctl_name,
+-                     unsigned int gpio_offset, unsigned int pin_offset,
+-                     unsigned int npins)
+-{
+-      WARN_ON(1);
+-      return -EINVAL;
+-}
+-
+-static inline int
+-gpiochip_add_pingroup_range(struct gpio_chip *chip,
+-                      struct pinctrl_dev *pctldev,
+-                      unsigned int gpio_offset, const char *pin_group)
+-{
+-      WARN_ON(1);
+-      return -EINVAL;
+-}
+-
+-static inline void
+-gpiochip_remove_pin_ranges(struct gpio_chip *chip)
+-{
+-      WARN_ON(1);
+-}
+-
+ static inline int devm_gpio_request(struct device *dev, unsigned gpio,
+                                   const char *label)
+ {
+diff --git a/include/net/act_api.h b/include/net/act_api.h
+index a10a3b1813f3..775387d6ca95 100644
+--- a/include/net/act_api.h
++++ b/include/net/act_api.h
+@@ -14,6 +14,7 @@
+ struct tcf_idrinfo {
+       spinlock_t      lock;
+       struct idr      action_idr;
++      struct net      *net;
+ };
+ 
+ struct tc_action_ops;
+@@ -104,7 +105,7 @@ struct tc_action_net {
+ };
+ 
+ static inline
+-int tc_action_net_init(struct tc_action_net *tn,
++int tc_action_net_init(struct net *net, struct tc_action_net *tn,
+                      const struct tc_action_ops *ops)
+ {
+       int err = 0;
+@@ -113,6 +114,7 @@ int tc_action_net_init(struct tc_action_net *tn,
+       if (!tn->idrinfo)
+               return -ENOMEM;
+       tn->ops = ops;
++      tn->idrinfo->net = net;
+       spin_lock_init(&tn->idrinfo->lock);
+       idr_init(&tn->idrinfo->action_idr);
+       return err;
+diff --git a/include/net/psample.h b/include/net/psample.h
+index 9b80f814ab04..94cb37a7bf75 100644
+--- a/include/net/psample.h
++++ b/include/net/psample.h
+@@ -12,6 +12,7 @@ struct psample_group {
+       u32 group_num;
+       u32 refcount;
+       u32 seq;
++      struct rcu_head rcu;
+ };
+ 
+ struct psample_group *psample_group_get(struct net *net, u32 group_num);
+diff --git a/kernel/kprobes.c b/kernel/kprobes.c
+index ec11bb986a8b..c43bc2bc5b2c 100644
+--- a/kernel/kprobes.c
++++ b/kernel/kprobes.c
+@@ -483,6 +483,7 @@ static DECLARE_DELAYED_WORK(optimizing_work, 
kprobe_optimizer);
+  */
+ static void do_optimize_kprobes(void)
+ {
++      lockdep_assert_held(&text_mutex);
+       /*
+        * The optimization/unoptimization refers online_cpus via
+        * stop_machine() and cpu-hotplug modifies online_cpus.
+@@ -500,9 +501,7 @@ static void do_optimize_kprobes(void)
+           list_empty(&optimizing_list))
+               return;
+ 
+-      mutex_lock(&text_mutex);
+       arch_optimize_kprobes(&optimizing_list);
+-      mutex_unlock(&text_mutex);
+ }
+ 
+ /*
+@@ -513,6 +512,7 @@ static void do_unoptimize_kprobes(void)
+ {
+       struct optimized_kprobe *op, *tmp;
+ 
++      lockdep_assert_held(&text_mutex);
+       /* See comment in do_optimize_kprobes() */
+       lockdep_assert_cpus_held();
+ 
+@@ -520,7 +520,6 @@ static void do_unoptimize_kprobes(void)
+       if (list_empty(&unoptimizing_list))
+               return;
+ 
+-      mutex_lock(&text_mutex);
+       arch_unoptimize_kprobes(&unoptimizing_list, &freeing_list);
+       /* Loop free_list for disarming */
+       list_for_each_entry_safe(op, tmp, &freeing_list, list) {
+@@ -537,7 +536,6 @@ static void do_unoptimize_kprobes(void)
+               } else
+                       list_del_init(&op->list);
+       }
+-      mutex_unlock(&text_mutex);
+ }
+ 
+ /* Reclaim all kprobes on the free_list */
+@@ -563,6 +561,7 @@ static void kprobe_optimizer(struct work_struct *work)
+ {
+       mutex_lock(&kprobe_mutex);
+       cpus_read_lock();
++      mutex_lock(&text_mutex);
+       /* Lock modules while optimizing kprobes */
+       mutex_lock(&module_mutex);
+ 
+@@ -590,6 +589,7 @@ static void kprobe_optimizer(struct work_struct *work)
+       do_free_cleaned_kprobes();
+ 
+       mutex_unlock(&module_mutex);
++      mutex_unlock(&text_mutex);
+       cpus_read_unlock();
+       mutex_unlock(&kprobe_mutex);
+ 
+diff --git a/net/core/netpoll.c b/net/core/netpoll.c
+index 912731bed7b7..abab3753a9e0 100644
+--- a/net/core/netpoll.c
++++ b/net/core/netpoll.c
+@@ -122,7 +122,7 @@ static void queue_process(struct work_struct *work)
+               txq = netdev_get_tx_queue(dev, q_index);
+               HARD_TX_LOCK(dev, txq, smp_processor_id());
+               if (netif_xmit_frozen_or_stopped(txq) ||
+-                  netpoll_start_xmit(skb, dev, txq) != NETDEV_TX_OK) {
++                  !dev_xmit_complete(netpoll_start_xmit(skb, dev, txq))) {
+                       skb_queue_head(&npinfo->txq, skb);
+                       HARD_TX_UNLOCK(dev, txq);
+                       local_irq_restore(flags);
+@@ -357,7 +357,7 @@ void netpoll_send_skb_on_dev(struct netpoll *np, struct 
sk_buff *skb,
+ 
+                               HARD_TX_UNLOCK(dev, txq);
+ 
+-                              if (status == NETDEV_TX_OK)
++                              if (dev_xmit_complete(status))
+                                       break;
+ 
+                       }
+@@ -374,7 +374,7 @@ void netpoll_send_skb_on_dev(struct netpoll *np, struct 
sk_buff *skb,
+ 
+       }
+ 
+-      if (status != NETDEV_TX_OK) {
++      if (!dev_xmit_complete(status)) {
+               skb_queue_tail(&npinfo->txq, skb);
+               schedule_delayed_work(&npinfo->tx_work,0);
+       }
+diff --git a/net/ipv4/tcp.c b/net/ipv4/tcp.c
+index 541686f3f835..5ce069ce2a97 100644
+--- a/net/ipv4/tcp.c
++++ b/net/ipv4/tcp.c
+@@ -914,6 +914,22 @@ static int tcp_send_mss(struct sock *sk, int *size_goal, 
int flags)
+       return mss_now;
+ }
+ 
++/* In some cases, both sendpage() and sendmsg() could have added
++ * an skb to the write queue, but failed adding payload on it.
++ * We need to remove it to consume less memory, but more
++ * importantly be able to generate EPOLLOUT for Edge Trigger epoll()
++ * users.
++ */
++static void tcp_remove_empty_skb(struct sock *sk, struct sk_buff *skb)
++{
++      if (skb && !skb->len) {
++              tcp_unlink_write_queue(skb, sk);
++              if (tcp_write_queue_empty(sk))
++                      tcp_chrono_stop(sk, TCP_CHRONO_BUSY);
++              sk_wmem_free_skb(sk, skb);
++      }
++}
++
+ ssize_t do_tcp_sendpages(struct sock *sk, struct page *page, int offset,
+                        size_t size, int flags)
+ {
+@@ -1034,6 +1050,7 @@ out:
+       return copied;
+ 
+ do_error:
++      tcp_remove_empty_skb(sk, tcp_write_queue_tail(sk));
+       if (copied)
+               goto out;
+ out_err:
+@@ -1412,17 +1429,11 @@ out_nopush:
+       sock_zerocopy_put(uarg);
+       return copied + copied_syn;
+ 
++do_error:
++      skb = tcp_write_queue_tail(sk);
+ do_fault:
+-      if (!skb->len) {
+-              tcp_unlink_write_queue(skb, sk);
+-              /* It is the one place in all of TCP, except connection
+-               * reset, where we can be unlinking the send_head.
+-               */
+-              tcp_check_send_head(sk, skb);
+-              sk_wmem_free_skb(sk, skb);
+-      }
++      tcp_remove_empty_skb(sk, skb);
+ 
+-do_error:
+       if (copied + copied_syn)
+               goto out;
+ out_err:
+diff --git a/net/ipv4/tcp_output.c b/net/ipv4/tcp_output.c
+index a99086bf26ea..5b808089eff8 100644
+--- a/net/ipv4/tcp_output.c
++++ b/net/ipv4/tcp_output.c
+@@ -2025,7 +2025,7 @@ static bool tcp_can_coalesce_send_queue_head(struct sock 
*sk, int len)
+               if (len <= skb->len)
+                       break;
+ 
+-              if (unlikely(TCP_SKB_CB(skb)->eor))
++              if (unlikely(TCP_SKB_CB(skb)->eor) || tcp_has_tx_tstamp(skb))
+                       return false;
+ 
+               len -= skb->len;
+@@ -2148,6 +2148,7 @@ static int tcp_mtu_probe(struct sock *sk)
+                        * we need to propagate it to the new skb.
+                        */
+                       TCP_SKB_CB(nskb)->eor = TCP_SKB_CB(skb)->eor;
++                      tcp_skb_collapse_tstamp(nskb, skb);
+                       tcp_unlink_write_queue(skb, sk);
+                       sk_wmem_free_skb(sk, skb);
+               } else {
+diff --git a/net/ipv6/mcast.c b/net/ipv6/mcast.c
+index bd269e78272a..611dc5d55fa0 100644
+--- a/net/ipv6/mcast.c
++++ b/net/ipv6/mcast.c
+@@ -772,12 +772,13 @@ static void mld_del_delrec(struct inet6_dev *idev, 
struct ifmcaddr6 *im)
+               im->idev = pmc->idev;
+               im->mca_crcount = idev->mc_qrv;
+               if (im->mca_sfmode == MCAST_INCLUDE) {
+-                      im->mca_tomb = pmc->mca_tomb;
+-                      im->mca_sources = pmc->mca_sources;
++                      swap(im->mca_tomb, pmc->mca_tomb);
++                      swap(im->mca_sources, pmc->mca_sources);
+                       for (psf = im->mca_sources; psf; psf = psf->sf_next)
+                               psf->sf_crcount = im->mca_crcount;
+               }
+               in6_dev_put(pmc->idev);
++              ip6_mc_clear_src(pmc);
+               kfree(pmc);
+       }
+       spin_unlock_bh(&im->mca_lock);
+diff --git a/net/psample/psample.c b/net/psample/psample.c
+index 64f95624f219..4cea353221da 100644
+--- a/net/psample/psample.c
++++ b/net/psample/psample.c
+@@ -156,7 +156,7 @@ static void psample_group_destroy(struct psample_group 
*group)
+ {
+       psample_group_notify(group, PSAMPLE_CMD_DEL_GROUP);
+       list_del(&group->list);
+-      kfree(group);
++      kfree_rcu(group, rcu);
+ }
+ 
+ static struct psample_group *
+diff --git a/net/sched/act_bpf.c b/net/sched/act_bpf.c
+index 364a878e51cb..bdc8885c0448 100644
+--- a/net/sched/act_bpf.c
++++ b/net/sched/act_bpf.c
+@@ -402,7 +402,7 @@ static __net_init int bpf_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, bpf_net_id);
+ 
+-      return tc_action_net_init(tn, &act_bpf_ops);
++      return tc_action_net_init(net, tn, &act_bpf_ops);
+ }
+ 
+ static void __net_exit bpf_exit_net(struct net *net)
+diff --git a/net/sched/act_connmark.c b/net/sched/act_connmark.c
+index 10b7a8855a6c..de0cd73a5a5d 100644
+--- a/net/sched/act_connmark.c
++++ b/net/sched/act_connmark.c
+@@ -206,7 +206,7 @@ static __net_init int connmark_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, connmark_net_id);
+ 
+-      return tc_action_net_init(tn, &act_connmark_ops);
++      return tc_action_net_init(net, tn, &act_connmark_ops);
+ }
+ 
+ static void __net_exit connmark_exit_net(struct net *net)
+diff --git a/net/sched/act_csum.c b/net/sched/act_csum.c
+index d836f998117b..a449594553d0 100644
+--- a/net/sched/act_csum.c
++++ b/net/sched/act_csum.c
+@@ -632,7 +632,7 @@ static __net_init int csum_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, csum_net_id);
+ 
+-      return tc_action_net_init(tn, &act_csum_ops);
++      return tc_action_net_init(net, tn, &act_csum_ops);
+ }
+ 
+ static void __net_exit csum_exit_net(struct net *net)
+diff --git a/net/sched/act_gact.c b/net/sched/act_gact.c
+index a0ac42b3ed06..69512d3d0818 100644
+--- a/net/sched/act_gact.c
++++ b/net/sched/act_gact.c
+@@ -232,7 +232,7 @@ static __net_init int gact_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, gact_net_id);
+ 
+-      return tc_action_net_init(tn, &act_gact_ops);
++      return tc_action_net_init(net, tn, &act_gact_ops);
+ }
+ 
+ static void __net_exit gact_exit_net(struct net *net)
+diff --git a/net/sched/act_ife.c b/net/sched/act_ife.c
+index 16a403d17f44..aea8ee40e76b 100644
+--- a/net/sched/act_ife.c
++++ b/net/sched/act_ife.c
+@@ -837,7 +837,7 @@ static __net_init int ife_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, ife_net_id);
+ 
+-      return tc_action_net_init(tn, &act_ife_ops);
++      return tc_action_net_init(net, tn, &act_ife_ops);
+ }
+ 
+ static void __net_exit ife_exit_net(struct net *net)
+diff --git a/net/sched/act_ipt.c b/net/sched/act_ipt.c
+index 18b2fd2ba7d7..a2687dd95a3d 100644
+--- a/net/sched/act_ipt.c
++++ b/net/sched/act_ipt.c
+@@ -65,12 +65,13 @@ static int ipt_init_target(struct net *net, struct 
xt_entry_target *t,
+       return 0;
+ }
+ 
+-static void ipt_destroy_target(struct xt_entry_target *t)
++static void ipt_destroy_target(struct xt_entry_target *t, struct net *net)
+ {
+       struct xt_tgdtor_param par = {
+               .target   = t->u.kernel.target,
+               .targinfo = t->data,
+               .family   = NFPROTO_IPV4,
++              .net      = net,
+       };
+       if (par.target->destroy != NULL)
+               par.target->destroy(&par);
+@@ -82,7 +83,7 @@ static void tcf_ipt_release(struct tc_action *a, int bind)
+       struct tcf_ipt *ipt = to_ipt(a);
+ 
+       if (ipt->tcfi_t) {
+-              ipt_destroy_target(ipt->tcfi_t);
++              ipt_destroy_target(ipt->tcfi_t, a->idrinfo->net);
+               kfree(ipt->tcfi_t);
+       }
+       kfree(ipt->tcfi_tname);
+@@ -172,7 +173,7 @@ static int __tcf_ipt_init(struct net *net, unsigned int 
id, struct nlattr *nla,
+ 
+       spin_lock_bh(&ipt->tcf_lock);
+       if (ret != ACT_P_CREATED) {
+-              ipt_destroy_target(ipt->tcfi_t);
++              ipt_destroy_target(ipt->tcfi_t, net);
+               kfree(ipt->tcfi_tname);
+               kfree(ipt->tcfi_t);
+       }
+@@ -337,7 +338,7 @@ static __net_init int ipt_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, ipt_net_id);
+ 
+-      return tc_action_net_init(tn, &act_ipt_ops);
++      return tc_action_net_init(net, tn, &act_ipt_ops);
+ }
+ 
+ static void __net_exit ipt_exit_net(struct net *net)
+@@ -387,7 +388,7 @@ static __net_init int xt_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, xt_net_id);
+ 
+-      return tc_action_net_init(tn, &act_xt_ops);
++      return tc_action_net_init(net, tn, &act_xt_ops);
+ }
+ 
+ static void __net_exit xt_exit_net(struct net *net)
+diff --git a/net/sched/act_mirred.c b/net/sched/act_mirred.c
+index 6ce8de373f83..529bb064c4a4 100644
+--- a/net/sched/act_mirred.c
++++ b/net/sched/act_mirred.c
+@@ -343,7 +343,7 @@ static __net_init int mirred_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, mirred_net_id);
+ 
+-      return tc_action_net_init(tn, &act_mirred_ops);
++      return tc_action_net_init(net, tn, &act_mirred_ops);
+ }
+ 
+ static void __net_exit mirred_exit_net(struct net *net)
+diff --git a/net/sched/act_nat.c b/net/sched/act_nat.c
+index c365d01b99c8..5a136943af27 100644
+--- a/net/sched/act_nat.c
++++ b/net/sched/act_nat.c
+@@ -307,7 +307,7 @@ static __net_init int nat_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, nat_net_id);
+ 
+-      return tc_action_net_init(tn, &act_nat_ops);
++      return tc_action_net_init(net, tn, &act_nat_ops);
+ }
+ 
+ static void __net_exit nat_exit_net(struct net *net)
+diff --git a/net/sched/act_pedit.c b/net/sched/act_pedit.c
+index 656b6ada9221..b6f6bfad8b2a 100644
+--- a/net/sched/act_pedit.c
++++ b/net/sched/act_pedit.c
+@@ -458,7 +458,7 @@ static __net_init int pedit_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, pedit_net_id);
+ 
+-      return tc_action_net_init(tn, &act_pedit_ops);
++      return tc_action_net_init(net, tn, &act_pedit_ops);
+ }
+ 
+ static void __net_exit pedit_exit_net(struct net *net)
+diff --git a/net/sched/act_police.c b/net/sched/act_police.c
+index c16127109f21..a7fcc591c241 100644
+--- a/net/sched/act_police.c
++++ b/net/sched/act_police.c
+@@ -331,7 +331,7 @@ static __net_init int police_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, police_net_id);
+ 
+-      return tc_action_net_init(tn, &act_police_ops);
++      return tc_action_net_init(net, tn, &act_police_ops);
+ }
+ 
+ static void __net_exit police_exit_net(struct net *net)
+diff --git a/net/sched/act_sample.c b/net/sched/act_sample.c
+index 64fd1e9818a6..489db1064d5b 100644
+--- a/net/sched/act_sample.c
++++ b/net/sched/act_sample.c
+@@ -92,13 +92,16 @@ static int tcf_sample_init(struct net *net, struct nlattr 
*nla,
+                       tcf_idr_release(*a, bind);
+               return -ENOMEM;
+       }
+-      RCU_INIT_POINTER(s->psample_group, psample_group);
++      rcu_swap_protected(s->psample_group, psample_group,
++                         lockdep_is_held(&s->tcf_lock));
+ 
+       if (tb[TCA_SAMPLE_TRUNC_SIZE]) {
+               s->truncate = true;
+               s->trunc_size = nla_get_u32(tb[TCA_SAMPLE_TRUNC_SIZE]);
+       }
+ 
++      if (psample_group)
++              psample_group_put(psample_group);
+       if (ret == ACT_P_CREATED)
+               tcf_idr_insert(tn, *a);
+       return ret;
+@@ -249,7 +252,7 @@ static __net_init int sample_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, sample_net_id);
+ 
+-      return tc_action_net_init(tn, &act_sample_ops);
++      return tc_action_net_init(net, tn, &act_sample_ops);
+ }
+ 
+ static void __net_exit sample_exit_net(struct net *net)
+diff --git a/net/sched/act_simple.c b/net/sched/act_simple.c
+index f3ed63aa4111..86d8b66b9928 100644
+--- a/net/sched/act_simple.c
++++ b/net/sched/act_simple.c
+@@ -198,7 +198,7 @@ static __net_init int simp_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, simp_net_id);
+ 
+-      return tc_action_net_init(tn, &act_simp_ops);
++      return tc_action_net_init(net, tn, &act_simp_ops);
+ }
+ 
+ static void __net_exit simp_exit_net(struct net *net)
+diff --git a/net/sched/act_skbedit.c b/net/sched/act_skbedit.c
+index 6e749497009e..1a8a49e33320 100644
+--- a/net/sched/act_skbedit.c
++++ b/net/sched/act_skbedit.c
+@@ -239,7 +239,7 @@ static __net_init int skbedit_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, skbedit_net_id);
+ 
+-      return tc_action_net_init(tn, &act_skbedit_ops);
++      return tc_action_net_init(net, tn, &act_skbedit_ops);
+ }
+ 
+ static void __net_exit skbedit_exit_net(struct net *net)
+diff --git a/net/sched/act_skbmod.c b/net/sched/act_skbmod.c
+index d227599f7e73..20ea9d11821b 100644
+--- a/net/sched/act_skbmod.c
++++ b/net/sched/act_skbmod.c
+@@ -267,7 +267,7 @@ static __net_init int skbmod_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, skbmod_net_id);
+ 
+-      return tc_action_net_init(tn, &act_skbmod_ops);
++      return tc_action_net_init(net, tn, &act_skbmod_ops);
+ }
+ 
+ static void __net_exit skbmod_exit_net(struct net *net)
+diff --git a/net/sched/act_tunnel_key.c b/net/sched/act_tunnel_key.c
+index cd51f2ed55fa..62e22738022d 100644
+--- a/net/sched/act_tunnel_key.c
++++ b/net/sched/act_tunnel_key.c
+@@ -324,7 +324,7 @@ static __net_init int tunnel_key_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, tunnel_key_net_id);
+ 
+-      return tc_action_net_init(tn, &act_tunnel_key_ops);
++      return tc_action_net_init(net, tn, &act_tunnel_key_ops);
+ }
+ 
+ static void __net_exit tunnel_key_exit_net(struct net *net)
+diff --git a/net/sched/act_vlan.c b/net/sched/act_vlan.c
+index 5c10a0fce35b..c9a3eeb351fa 100644
+--- a/net/sched/act_vlan.c
++++ b/net/sched/act_vlan.c
+@@ -271,7 +271,7 @@ static __net_init int vlan_init_net(struct net *net)
+ {
+       struct tc_action_net *tn = net_generic(net, vlan_net_id);
+ 
+-      return tc_action_net_init(tn, &act_vlan_ops);
++      return tc_action_net_init(net, tn, &act_vlan_ops);
+ }
+ 
+ static void __net_exit vlan_exit_net(struct net *net)
+diff --git a/tools/hv/hv_kvp_daemon.c b/tools/hv/hv_kvp_daemon.c
+index 0ef215061fb5..1b917eaffad8 100644
+--- a/tools/hv/hv_kvp_daemon.c
++++ b/tools/hv/hv_kvp_daemon.c
+@@ -867,7 +867,7 @@ kvp_get_ip_info(int family, char *if_name, int op,
+       int sn_offset = 0;
+       int error = 0;
+       char *buffer;
+-      struct hv_kvp_ipaddr_value *ip_buffer;
++      struct hv_kvp_ipaddr_value *ip_buffer = NULL;
+       char cidr_mask[5]; /* /xyz */
+       int weight;
+       int i;
+diff --git a/virt/kvm/arm/mmio.c b/virt/kvm/arm/mmio.c
+index 08443a15e6be..3caee91bca08 100644
+--- a/virt/kvm/arm/mmio.c
++++ b/virt/kvm/arm/mmio.c
+@@ -98,6 +98,12 @@ int kvm_handle_mmio_return(struct kvm_vcpu *vcpu, struct 
kvm_run *run)
+       unsigned int len;
+       int mask;
+ 
++      /* Detect an already handled MMIO return */
++      if (unlikely(!vcpu->mmio_needed))
++              return 0;
++
++      vcpu->mmio_needed = 0;
++
+       if (!run->mmio.is_write) {
+               len = run->mmio.len;
+               if (len > sizeof(unsigned long))
+@@ -200,6 +206,7 @@ int io_mem_abort(struct kvm_vcpu *vcpu, struct kvm_run 
*run,
+       run->mmio.is_write      = is_write;
+       run->mmio.phys_addr     = fault_ipa;
+       run->mmio.len           = len;
++      vcpu->mmio_needed       = 1;
+ 
+       if (!ret) {
+               /* We handled the access successfully in the kernel. */

Reply via email to