From mboxrd@z Thu Jan 1 00:00:00 1970 Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.remote-ip=74.125.82.174 ARC-Seal: i=1; d=subspace.kernel.org; s=arc20261015; a=rsa-sha256; cv=none; t=1793412585; b=VdmyIcZK3M4ByPzk0hD0hqDOJrajv2YZdyUKby2Wg194Cq9NR+wpIDuObHX0JfKulPzP OeqcY9gacxFc12ZW9V3u+2JRSykoThpEkG5dgHMg0TggynggZ/WRynUzox1fcGRKXX40/ bxNHaskDCgo7DKIik7oUeLEV8KmZFZB+OsYTjT2g64zljtdDuFs2rizYLr7zYD4ncD1H4 kXF2sI1rd8JMDzl7ne+VyGU6wkLSKXwIgtatum4pP/gDBIhrYJs5nBcXXoC8ZCeM4Z4Z3 pBZOKibVc/tHseJMSJ1tc3Gt6YcHIdjtICxrDeMEzFzA0JMIdD/bJWS3+3FKYuoYqFQ== ARC-Message-Signature: i=1; d=subspace.kernel.org; s=arc20261015; a=rsa-sha256; c=relaxed/relaxed; t=1793412585; h=DMARC-Filter:Received:DKIM-Signature:X-Google-DKIM-Signature: X-Forwarded-Encrypted:X-Gm-Message-State:X-Gm-Gg:X-Received:Received: From:To:Cc:Subject:Date:Message-ID:X-Mailer:In-Reply-To:References: MIME-Version:Content-Transfer-Encoding; bh=bhNDjqO9TvYmvioIqiGGiLqz7fELlYmLdRUXFsLMln0=; b=MtiblrtUlyC3xCL4KfE4sRhuAlraVK1np5EZXvL0kcsxJ031BvH1J7e8Dz092aziV15u sugGJgIRNarEY9PMkWdURfRJhI1k2qeVkVId56mC5RdgKzN3JGllOhCkk8AA8SU5/vNmr WHqUIRO5pvB6BOgGraQ+Lek/eHrRt9vOzw2XsKHHgSZclhj5p2BEsOxPi4fKNZmLIbIXF +MpNM7Oqm1D665EY90YbmeCMt2WFLTqDEEjxNc18gha4J+r2FIsrYfLuXWrM6ANxcJMHe hU62LJ+f87P22MD4rtuV8OLBfAh924153rvOJ5mJJmihchSv8hdfzgDlTOJbTLZYpWQ== ARC-Authentication-Results: i=1; smtp.subspace.kernel.org; dmarc=pass header.from=gmail.com; spf=pass smtp.mailfrom=gmail.com; dkim=pass header.d=gmail.com header.i=@gmail.com header.a=rsa-sha256 header.s=20260707 header.b=fTzwE4Pn; arc=none smtp.remote-ip=74.125.82.174 Received: from mail-dy1-f174.google.com (mail-dy1-f174.google.com [74.125.82.174]) (using TLSv1.3 with cipher TLS_AES_128_GCM_SHA256 (128/128 bits) key-exchange X25519 server-signature ECDSA (prime256v1) server-digest SHA256) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id AF19C606A33B for ; Sat, 31 Oct 2026 02:09:44 +0000 (UTC) DMARC-Filter: OpenDMARC Filter v1.4.2 smtp.subspace.kernel.org AF19C606A33B Authentication-Results: smtp.subspace.kernel.org; dmarc=pass (p=none dis=none) header.from=gmail.com Authentication-Results: smtp.subspace.kernel.org; spf=pass smtp.mailfrom=gmail.com Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key, unprotected) header.d=gmail.com header.i=@gmail.com header.a=rsa-sha256 header.s=20260707 header.b=fTzwE4Pn Received: by mail-dy1-f174.google.com with SMTP id 5a478bee46e88-36a2551d7b5so3062071eec.1 for ; Fri, 30 Oct 2026 19:09:44 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20260707; t=1793412584; x=1794017384; darn=vger.kernel.org; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to:content-type; bh=bhNDjqO9TvYmvioIqiGGiLqz7fELlYmLdRUXFsLMln0=; b=fTzwE4PngQGwqpMMBgHBcuhmnZjg+XDzOwJDz9S1QXEU0GYPdBLQCsc6j9wD1WbV/X OnPLrQbh267GoEuCi9p+qs3zw64R0ZZeVTpcTooJNtQB9uhZNb+CmtkT7HuxyJNt20e0 aYkXGhScmaavMQiVkFVrUUiGDvC8fSxOuYq/9UkRejiXkJWzhWLlGRe4NusxSgeBKMAN QGMfnU07BLGjj83SnYkV0wXi7iGE8FH9qZquKk2ZGhkjfoz742ZL2pHoVnxuYz8Ojk/q cP28SUHP4VafQAnHWkqJFR4ldOB2EYDUen1rxX9GZgByssz54fHaO4ZLqGf1voA3v7o4 Brpw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20260707; t=1793412584; x=1794017384; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-gg:x-gm-message-state:from :to:cc:subject:date:message-id:reply-to:content-type; bh=bhNDjqO9TvYmvioIqiGGiLqz7fELlYmLdRUXFsLMln0=; b=E7HcEY7VHTH4R7eo9UrUi4vmqFA/D1oDPSagIjmx0afjYVzbqyr7eZ3NHNg5UBjOqm NkijNGq74HoPVuf5W4RZnGOT3DP5piaQNyPo28QKMUB75YkDQvrj3LB1xhJ1W+Q9b39/ TptSnLbB2ElR/R0jujtPY1nejQUrn39m/yQCcBL9nHWb9wEQVipi4TxVTWVDmCoyv+jT 3xh2CgDd4KKStbV1J7ufR/L0uWLAbFEIq98Rp7P63/l3h3es/u785U5EWAGPAD7gsz6D 9jNqEVgj1iI1wKuBlLnXsPikwrUFQWrzzQQGkAiSw8FyvvvF1yEyP1tLHdQlV2KRdxku 7GkQ== X-Forwarded-Encrypted: i=1; AKwUvBx8SlcPPH5SX13QlPNbSZF/bTdduEINfQEcKspJYVSNxg3r8/SOlwjPw32PqBiOI8HySTm49cWkTSk=@vger.kernel.org X-Gm-Message-State: AFq9FYIGZ8MLnEfzfTA4WJ38QTkpYIOLMe3McfUVLafkHMY0ICA8O/a5 LIwsl8PMhzJLxfeVkg3M8zPQTCmRfmgXt0LA8YRPRQ9oP2xowJktB4jn X-Gm-Gg: AYBFou1W5FQJGNwrDc4+vmcdxnYnv9Gz3W173g216Ja9szNg17uUZU/Jfm7fymnpTXh pxh1G7qA3ZF9qRO4kMgWzICY/m9mJ29ISiDby4j4ivDAVuCH0Wl6Sy9TxjzOyfEThzcD+uq7Me3 V5q8tUEimltjtvSOEuZwuTskhNHd9+5jGW4C8JVGiThvz9ms/PzCOFXF1yHFIeLemn5+BnHv4Xm iHXlcEHAjgKHhOTtvrLgUFtBkOIiIYI+RQ4PO1k4AMx+GQPlDnB/z97IVdvvPsp/Ss1igbynH8X pwz/ECOA7IOjAxyBEZTD4eTtB694IdzvrpfZuR+eQYZEZ45o9Dh06kBJwMNrbg8kHbBRt6zI8HY SFvyL6SgfM6IKlOtWUOv7omPVeuXWl0b3gmYpEgKFwLJYrkjWgawtWoV1DzzJYLWVMJ7Eh8L2Rp vNJyEWeMJIZCCMi91Giv9AfUfHefv9SsOXPwhiWLsrLHAsMuPfluL1KGDVYkqtm1TxlA1Hxtb87 ZbPJjCgoqygu67Q2UvR+O/ODnFnPD+AQXSzDWdaC+y+Y3rrYG+OqqWr0NjvHS7dg62h24YK3nPk UsNnt+cWB4KBtQBdnfxakVBk3L69pXBzMDaZRwPPZpREp4bY6wYwDvZdsjbmcVqJPTIYJgydi9Z YckkqgTqSTsVMHpFo/J+lMDnnaPchii7nvmW20lyO/8/Zbw== X-Received: by 2002:a05:693c:4088:b0:36a:2f6c:490e with SMTP id 5a478bee46e88-36a30009ecemr10595948eec.6.1793412583676; Fri, 30 Oct 2026 19:09:43 -0700 (PDT) Received: from localhost.localdomain ([180.182.24.11]) by smtp.gmail.com with ESMTPSA id 5a478bee46e88-36a42a77c0dsm13214096eec.26.2026.10.30.19.09.40 (version=TLS1_3 cipher=TLS_CHACHA20_POLY1305_SHA256 bits=256/256); Fri, 30 Oct 2026 19:09:43 -0700 (PDT) From: Joonho Lee To: linux-sound@vger.kernel.org Cc: tiwai@suse.de, perex@perex.cz, anton.yakovlev@opensynergy.com, mst@redhat.com, virtualization@lists.linux.dev, linux-kernel@vger.kernel.org, corbet@lwn.net, skhan@linuxfoundation.org, rdunlap@infradead.org, linux-doc@vger.kernel.org, Joonho Lee Subject: [PATCH v11 14/14] ALSA: virtio: rebase ordinary capture accounting on RESET Date: Sat, 31 Oct 2026 11:08:55 +0900 Message-ID: <20261031020855.2402-15-mynameisjune111@gmail.com> X-Mailer: git-send-email 2.54.0 In-Reply-To: <20261031020855.2402-1-mynameisjune111@gmail.com> References: <20261031020855.2402-1-mynameisjune111@gmail.com> X-Mailing-List: linux-doc@vger.kernel.org List-Id: List-Post: List-Help: List-Subscribe: List-Unsubscribe: List-Owner: Precedence: list MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Ordinary capture's indirect positions must follow the common RESET observation while preserving the device's fixed DMA ring offsets. Select its reset callback at open alongside the staged capture callback. Suppress nested ACK refills during snd_pcm_lib_reset(). For paused capture, hold the RX queue and substream locks while checking lifecycle state and observing the latest completed position. Update a local copy of the indirect state, return discarded RX space, and commit on success. This also keeps the observation boundary consistent with a late RX completion. Data arriving after the committed observation remains unread. Honor an existing XRUN before changing private paused accounting or refilling descriptors. On a refill failure, retain the error and complete the core rebase; the worker then reports XRUN. RESET can return zero while the error notification is pending. Prepare or reopen recovers the stream. Device reset suppresses fresh notifications until a usable queue exists. Set the ordinary notification floor to the RESET observation so queued work cannot report a discarded period as new progress. Native resume preserves the RX ring ownership established by the earlier patches. Fault tests covered late completions, existing XRUN, nested refill and refill failures with recovery and reopen. Ordinary and staged 70-second RW and MMAP captures matched the deterministic sequence, including PAUSE, RESET, resume and the intended discard boundary. The paused interleaving test verifies the atomic observation boundary; it does not establish sample loss in the original implementation. Link: https://sashiko.dev/#/patchset/20261030052629.27742-1-mynameisjune111%40gmail.com?part=14 Assisted-by: LLM Signed-off-by: Joonho Lee --- diff --git a/sound/virtio/virtio_pcm.h b/sound/virtio/virtio_pcm.h --- a/sound/virtio/virtio_pcm.h +++ b/sound/virtio/virtio_pcm.h @@ -76,6 +76,8 @@ * @release_required: Successful PREPARE still needs a successful RELEASE. * @control_uncertain: Native control result requires device reset before reuse. * @capture_reset_observing: Reclaim staged samples during RESET pointer capture. + * @indirect_reset_observing: Suppress ordinary ACK refill during RESET pointer + * capture; protected by the PCM stream lock. * @suspended: True if the substream is suspended and must be reconfigured on * the device side at resume. * @pause_restart_state: Device-side state for opt-in pause compatibility. @@ -127,6 +129,7 @@ bool release_required; bool control_uncertain; bool capture_reset_observing; + bool indirect_reset_observing; bool suspended; enum virtio_pcm_pause_restart_state pause_restart_state; struct virtio_pcm_msg **msgs; diff --git a/sound/virtio/virtio_pcm_ops.c b/sound/virtio/virtio_pcm_ops.c --- a/sound/virtio/virtio_pcm_ops.c +++ b/sound/virtio/virtio_pcm_ops.c @@ -10,6 +10,7 @@ #include "virtio_card.h" static const struct snd_pcm_ops virtsnd_pcm_capture_staged_ops; +static const struct snd_pcm_ops virtsnd_pcm_capture_indirect_ops; bool virtsnd_capture_staging; module_param_named(capture_staging, virtsnd_capture_staging, bool, 0444); @@ -398,6 +399,9 @@ &virtsnd_pcm_capture_staged_ops : &virtsnd_pcm_ops[substream->stream]; + if (vss->direction == SNDRV_PCM_STREAM_CAPTURE && !vss->capture_staging) + substream->ops = &virtsnd_pcm_capture_indirect_ops; + snd_pcm_hw_constraint_integer(substream->runtime, SNDRV_PCM_HW_PARAM_PERIODS); @@ -1724,9 +1728,13 @@ */ static int virtsnd_pcm_cp_ack(struct snd_pcm_substream *substream) { + struct virtio_pcm_substream *vss = snd_pcm_substream_chip(substream); struct snd_pcm_runtime *runtime = substream->runtime; int rc; + /* RESET observes the pointer before returning discarded RX space. */ + if (vss->indirect_reset_observing) + return 0; if (!mutex_trylock(&runtime->buffer_mutex)) return -EBADFD; rc = virtsnd_pcm_cp_ack_locked(substream); @@ -1759,6 +1767,89 @@ return 0; } return virtsnd_pcm_sync_stop_locked(substream); +} + +/* + * The PCM lock covers indirect accounting and core completion. Once lib_reset + * changes hw_ptr, complete the core rebase even if refilling fails. The latched + * XRUN rejects subsequent pointer/ACK operations; the worker publishes XRUN to + * paused streams too. RESET success therefore does not imply stream recovery. + */ +static int virtsnd_pcm_indirect_reset(struct snd_pcm_substream *substream) +{ + struct virtio_pcm_substream *vss = snd_pcm_substream_chip(substream); + struct snd_pcm_runtime *runtime = substream->runtime; + struct virtio_snd_queue *queue = virtsnd_pcm_queue(vss); + struct virtsnd_pcm_transfer transfer = {}; + snd_pcm_uframes_t paused_ptr = 0; + bool paused = runtime->state == SNDRV_PCM_STATE_PAUSED; + int rc; + + /* Only PCM-locked callbacks access this observation flag. */ + vss->indirect_reset_observing = true; + rc = snd_pcm_lib_reset(substream); + vss->indirect_reset_observing = false; + if (rc) + return rc; + guard(spinlock_irqsave)(&queue->lock); + guard(spinlock)(&vss->lock); + if (vss->resetting) + return 0; + if (vss->xfer_xrun) { + virtsnd_pcm_transfer_failed(vss); + virtsnd_pcm_schedule_period_elapsed(vss); + return 0; + } + if (!snd_pcm_running(substream) && !paused) + return 0; + if (!vss->prepared || vss->stopped) { + virtsnd_pcm_transfer_failed(vss); + vss->xfer_xrun = true; + virtsnd_pcm_schedule_period_elapsed(vss); + return 0; + } + + transfer.indirect = vss->pcm_indirect; + if (paused) { + /* Observe and reclaim paused completions in one queue transaction. */ + vss->capture_pointer_seen_total = vss->capture_copied_total; + vss->indirect_reset_observing = true; + paused_ptr = snd_pcm_indirect_capture_pointer(substream, + &transfer.indirect, vss->hw_ptr); + vss->indirect_reset_observing = false; + if (paused_ptr == SNDRV_PCM_POS_XRUN) { + virtsnd_pcm_transfer_failed(vss); + vss->xfer_xrun = true; + virtsnd_pcm_schedule_period_elapsed(vss); + return 0; + } + runtime->status->hw_ptr = paused_ptr; + } + transfer.indirect.sw_ready = 0; + /* Consume no application delta while returning discarded RX space. */ + transfer.indirect.appl_ptr = runtime->control->appl_ptr; + rc = snd_pcm_indirect_capture_transfer(substream, &transfer.indirect, + virtsnd_pcm_trans_copy); + if (!rc) + rc = transfer.error; + if (rc) { + virtsnd_pcm_transfer_failed(vss); + vss->xfer_xrun = true; + virtsnd_pcm_schedule_period_elapsed(vss); + return 0; + } + + /* RESET discards all samples through the observed software pointer. */ + transfer.indirect.sw_ready = 0; + transfer.indirect.appl_ptr = runtime->status->hw_ptr; + vss->pcm_indirect = transfer.indirect; + { + size_t period = snd_pcm_lib_period_bytes(substream); + + vss->capture_notified_periods = period ? + div64_ul(vss->capture_pointer_seen_total, period) : 0; + } + return 0; } /* The core holds the stream lock through the matching appl_ptr reset. */ @@ -1858,3 +1949,17 @@ .pointer = virtsnd_pcm_cp_pointer, .ack = virtsnd_pcm_cp_ack, }; + +static const struct snd_pcm_ops virtsnd_pcm_capture_indirect_ops = { + .open = virtsnd_pcm_open, + .close = virtsnd_pcm_close, + .ioctl = snd_pcm_lib_ioctl, + .reset = virtsnd_pcm_indirect_reset, + .hw_params = virtsnd_pcm_hw_params, + .hw_free = virtsnd_pcm_hw_free, + .prepare = virtsnd_pcm_prepare, + .trigger = virtsnd_pcm_trigger, + .sync_stop = virtsnd_pcm_sync_stop, + .pointer = virtsnd_pcm_cp_pointer, + .ack = virtsnd_pcm_cp_ack, +};