From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1761024AbdJQVE7 (ORCPT ); Tue, 17 Oct 2017 17:04:59 -0400 Received: from userp1040.oracle.com ([156.151.31.81]:29855 "EHLO userp1040.oracle.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1754128AbdJQVE5 (ORCPT ); Tue, 17 Oct 2017 17:04:57 -0400 Subject: Re: [PATCH v5 09/13] xen/pvcalls: implement sendmsg To: Stefano Stabellini , xen-devel@lists.xen.org References: <1507336227-20477-1-git-send-email-sstabellini@kernel.org> <1507336227-20477-9-git-send-email-sstabellini@kernel.org> Cc: linux-kernel@vger.kernel.org, jgross@suse.com, Stefano Stabellini From: Boris Ostrovsky Message-ID: Date: Tue, 17 Oct 2017 17:06:32 -0400 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:45.0) Gecko/20100101 Thunderbird/45.8.0 MIME-Version: 1.0 In-Reply-To: <1507336227-20477-9-git-send-email-sstabellini@kernel.org> Content-Type: text/plain; charset=windows-1252 Content-Transfer-Encoding: 7bit X-Source-IP: aserv0021.oracle.com [141.146.126.233] Sender: linux-kernel-owner@vger.kernel.org List-ID: X-Mailing-List: linux-kernel@vger.kernel.org > +static int __write_ring(struct pvcalls_data_intf *intf, > + struct pvcalls_data *data, > + struct iov_iter *msg_iter, > + int len) > +{ > + RING_IDX cons, prod, size, masked_prod, masked_cons; > + RING_IDX array_size = XEN_FLEX_RING_SIZE(PVCALLS_RING_ORDER); > + int32_t error; > + > + error = intf->out_error; > + if (error < 0) > + return error; > + cons = intf->out_cons; > + prod = intf->out_prod; > + /* read indexes before continuing */ > + virt_mb(); > + > + size = pvcalls_queued(prod, cons, array_size); > + if (size >= array_size) > + return 0; I thought you were going to return an error here? If this can only be due to someone messing up indexes is there a reason to continue trying to write? What are the chances that the index will get corrected? -boris > + if (len > array_size - size) > + len = array_size - size; > + > + masked_prod = pvcalls_mask(prod, array_size); > + masked_cons = pvcalls_mask(cons, array_size); > + > + if (masked_prod < masked_cons) { > + copy_from_iter(data->out + masked_prod, len, msg_iter); > + } else { > + if (len > array_size - masked_prod) { > + copy_from_iter(data->out + masked_prod, > + array_size - masked_prod, msg_iter); > + copy_from_iter(data->out, > + len - (array_size - masked_prod), > + msg_iter); > + } else { > + copy_from_iter(data->out + masked_prod, len, msg_iter); > + } > + } > + /* write to ring before updating pointer */ > + virt_wmb(); > + intf->out_prod += len; > + > + return len; > +}