From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S966667AbcCPNmt (ORCPT ); Wed, 16 Mar 2016 09:42:49 -0400 Received: from mout.web.de ([212.227.17.12]:60348 "EHLO mout.web.de" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S966012AbcCPNmr (ORCPT ); Wed, 16 Mar 2016 09:42:47 -0400 Subject: [PATCH RESEND] media: dvb_ringbuffer: Add memory barriers To: Mauro Carvalho Chehab References: <1451248920-4935-1-git-send-email-smoch@web.de> Cc: Soeren Moch , linux-media@vger.kernel.org, linux-kernel@vger.kernel.org From: Soeren Moch Message-ID: <56E962C2.4060001@web.de> Date: Wed, 16 Mar 2016 14:42:26 +0100 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:38.0) Gecko/20100101 Thunderbird/38.6.0 MIME-Version: 1.0 In-Reply-To: <1451248920-4935-1-git-send-email-smoch@web.de> Content-Type: text/plain; charset=windows-1252 Content-Transfer-Encoding: 7bit X-Provags-ID: V03:K0:pidWQkkheNfR/4Fe6xSkf1jQJLkvI9P08kl2913vX4tt4KPR4iD uuPxwoDM9f211ITVF3tWD/FCgXAaTVERPqyLsdLbHRJvY475hTKpVkXT8DV3JJTZq1UlhqA X8zUH22HA8VZ2ME8mphButXnouxqDoyrEs+Lsg6d7Ms6TynDYReq0PO2qNxyuRoZZnE9oPa oRy8111elCR1fzCXTNcfw== X-UI-Out-Filterresults: notjunk:1;V01:K0:EGeTsc9iuMA=:QXU5IPN0eQZlktjvN8tXov o2uhWUSPDzPAM+AnzZaYPje3jIfjViLN3cLRoKlDRzT7QLMEhCFROqDr8JixAUJogMrF0YLqX gx+eTJNAGS/PolXVBTmDDRU1Njc6XGm3iHRNHEA3tVMX8t/F0joBMSSm19asZzgQoKvc29TCo Zuwm8xVZyclt70QzR+FzaVK49so0OP2JhqyHsP9HbmmxY7vgjhm7hNZpC9/WW+giFwhEgtQc7 WE64MWjzkn1gQtbPGE1wrjcQn3B+73xDnd8B3ZLdznHcUi9o+vWl+adA7CQOLJsOMCztNBJt6 eRFe1/cllU+i3Jn7D+RyEYe3YHu7kOueQl5ocOMOXMmlCVH5yxOjX+mWc+1PpdPUVwmSMNT+3 0pIsGi295ObLjb8QFJ8mca6DUwX3WsHd6wsYKia1im+VFCVmAru3A8wk7lfjWKC8b/PnThhyU FV5X+1hJaX92UBHAO8kXHlV6Yup5CXuKm41Y7C0nndY2DbYMAWLryKkEFTScVH7tQ4Q4zgX9l J896H3rar3y8PLv4DlBx1ogjNViOW/p4/u65poKwYkYQbHhjWFL0EQJBa6I2cVPBUKWo0x2BR 5n0CI6tq1POLoblz/xL+KoHFRCjoG4Zv2SZGrw7YT8IkMdtv0zY7JzTmJPwRLAdcRgLN3uwYz xrYD+fa7xi+PEHHG8BJzNKMi9xjgarXxqN9kUMkkqWg3L1b4mrn49KAXp4vWgQuC/1BBmzzKM U8L3C7VFFNLEdz23CXQw/A0Fu5hWDyhW6inF4shb2fnkc5AW/ZdKP6MnxkiZVFCOKFIepB94v Gp1V75zjvDKhCeYLa7HGXCAHzgDCQ== Sender: linux-kernel-owner@vger.kernel.org List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Implement memory barriers according to Documentation/circular-buffers.txt: - use smp_store_release() to update ringbuffer read/write pointers - use smp_load_acquire() to load write pointer on reader side - use ACCESS_ONCE() to load read pointer on writer side This fixes data stream corruptions observed e.g. on an ARM Cortex-A9 quad core system with different types (PCI, USB) of DVB tuners. Signed-off-by: Soeren Moch Cc: stable@vger.kernel.org # 3.14+ --- Cc: Mauro Carvalho Chehab Cc: linux-media@vger.kernel.org Cc: linux-kernel@vger.kernel.org Since smp_store_release() and smp_load_acquire() were introduced in linux-3.14, a 3.14+ stable tag was added. Is it desired to apply a similar patch to older stable kernels? --- drivers/media/dvb-core/dvb_ringbuffer.c | 27 ++++++++++++++------------- 1 file changed, 14 insertions(+), 13 deletions(-) diff --git a/drivers/media/dvb-core/dvb_ringbuffer.c b/drivers/media/dvb-core/dvb_ringbuffer.c index 1100e98..58b5968 100644 --- a/drivers/media/dvb-core/dvb_ringbuffer.c +++ b/drivers/media/dvb-core/dvb_ringbuffer.c @@ -55,7 +55,7 @@ void dvb_ringbuffer_init(struct dvb_ringbuffer *rbuf, void *data, size_t len) int dvb_ringbuffer_empty(struct dvb_ringbuffer *rbuf) { - return (rbuf->pread==rbuf->pwrite); + return (rbuf->pread == smp_load_acquire(&rbuf->pwrite)); } @@ -64,7 +64,7 @@ ssize_t dvb_ringbuffer_free(struct dvb_ringbuffer *rbuf) { ssize_t free; - free = rbuf->pread - rbuf->pwrite; + free = ACCESS_ONCE(rbuf->pread) - rbuf->pwrite; if (free <= 0) free += rbuf->size; return free-1; @@ -76,7 +76,7 @@ ssize_t dvb_ringbuffer_avail(struct dvb_ringbuffer *rbuf) { ssize_t avail; - avail = rbuf->pwrite - rbuf->pread; + avail = smp_load_acquire(&rbuf->pwrite) - rbuf->pread; if (avail < 0) avail += rbuf->size; return avail; @@ -86,14 +86,15 @@ ssize_t dvb_ringbuffer_avail(struct dvb_ringbuffer *rbuf) void dvb_ringbuffer_flush(struct dvb_ringbuffer *rbuf) { - rbuf->pread = rbuf->pwrite; + smp_store_release(&rbuf->pread, smp_load_acquire(&rbuf->pwrite)); rbuf->error = 0; } EXPORT_SYMBOL(dvb_ringbuffer_flush); void dvb_ringbuffer_reset(struct dvb_ringbuffer *rbuf) { - rbuf->pread = rbuf->pwrite = 0; + smp_store_release(&rbuf->pread, 0); + smp_store_release(&rbuf->pwrite, 0); rbuf->error = 0; } @@ -119,12 +120,12 @@ ssize_t dvb_ringbuffer_read_user(struct dvb_ringbuffer *rbuf, u8 __user *buf, si return -EFAULT; buf += split; todo -= split; - rbuf->pread = 0; + smp_store_release(&rbuf->pread, 0); } if (copy_to_user(buf, rbuf->data+rbuf->pread, todo)) return -EFAULT; - rbuf->pread = (rbuf->pread + todo) % rbuf->size; + smp_store_release(&rbuf->pread, (rbuf->pread + todo) % rbuf->size); return len; } @@ -139,11 +140,11 @@ void dvb_ringbuffer_read(struct dvb_ringbuffer *rbuf, u8 *buf, size_t len) memcpy(buf, rbuf->data+rbuf->pread, split); buf += split; todo -= split; - rbuf->pread = 0; + smp_store_release(&rbuf->pread, 0); } memcpy(buf, rbuf->data+rbuf->pread, todo); - rbuf->pread = (rbuf->pread + todo) % rbuf->size; + smp_store_release(&rbuf->pread, (rbuf->pread + todo) % rbuf->size); } @@ -158,10 +159,10 @@ ssize_t dvb_ringbuffer_write(struct dvb_ringbuffer *rbuf, const u8 *buf, size_t memcpy(rbuf->data+rbuf->pwrite, buf, split); buf += split; todo -= split; - rbuf->pwrite = 0; + smp_store_release(&rbuf->pwrite, 0); } memcpy(rbuf->data+rbuf->pwrite, buf, todo); - rbuf->pwrite = (rbuf->pwrite + todo) % rbuf->size; + smp_store_release(&rbuf->pwrite, (rbuf->pwrite + todo) % rbuf->size); return len; } @@ -181,12 +182,12 @@ ssize_t dvb_ringbuffer_write_user(struct dvb_ringbuffer *rbuf, return len - todo; buf += split; todo -= split; - rbuf->pwrite = 0; + smp_store_release(&rbuf->pwrite, 0); } status = copy_from_user(rbuf->data+rbuf->pwrite, buf, todo); if (status) return len - todo; - rbuf->pwrite = (rbuf->pwrite + todo) % rbuf->size; + smp_store_release(&rbuf->pwrite, (rbuf->pwrite + todo) % rbuf->size); return len; } -- 1.9.1