Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.96) (envelope-from ) id 1vJQoo-006DfO-17 for pgsql-hackers@arkaria.postgresql.org; Thu, 13 Nov 2025 06:28:29 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.96) (envelope-from ) id 1vJQom-00Gl8J-0Q for pgsql-hackers@arkaria.postgresql.org; Thu, 13 Nov 2025 06:28:28 +0000 Received: from makus.postgresql.org ([2001:4800:3e1:1::229]) by malur.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.96) (envelope-from ) id 1vJQol-00GkwH-1M for pgsql-hackers@lists.postgresql.org; Thu, 13 Nov 2025 06:28:27 +0000 Received: from fhigh-a6-smtp.messagingengine.com ([103.168.172.157]) by makus.postgresql.org with smtp (Exim 4.96) (envelope-from ) id 1vJQoj-006rmA-1L for pgsql-hackers@postgresql.org; Thu, 13 Nov 2025 06:28:26 +0000 Received: from phl-compute-05.internal (phl-compute-05.internal [10.202.2.45]) by mailfhigh.phl.internal (Postfix) with ESMTP id 8A57B1400247; Thu, 13 Nov 2025 01:28:24 -0500 (EST) Received: from phl-imap-03 ([10.202.2.93]) by phl-compute-05.internal (MEProxy); Thu, 13 Nov 2025 01:28:24 -0500 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=compiler.org; h= cc:cc:content-transfer-encoding:content-type:content-type:date :date:from:from:in-reply-to:in-reply-to:message-id:mime-version :references:reply-to:subject:subject:to:to; s=fm3; t=1763015304; x=1763101704; bh=c2ok+HHWT/kMY9oVcGYBS0qqKuf/1lrfJuDr0QpsvSA=; b= BLWI9q83COhsGJ4QzixFdlwJcd5h2Pg/GC/TDdgVS8eq4a+LRh7kMHtZbN7Px5hV uHLTgsGyCm6ggAKz5LyHVM/j+FgG2spdSYMfgRY/94KMviWD32Q0u6THSdJedF3t jAzjo1ZorDki50ctJ3gM7n6ltcbhPE4fTw0wrMmDV69rEB9hdeG45h1Ha+CGS0sb E8P2XXJdYEzAm/Zlwn5orPW4K7aGwZxSnTwHnmnwz9kVz3JsGelL++cEix1wz7I2 5Js+3TpRvnILeniEYMtEVhZbQ1BeXqV6485FhYtSq2c5Jgr92xNR83OrggLbXFY/ fOTrs8uq24Me2nERlmIatg== DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d= messagingengine.com; h=cc:cc:content-transfer-encoding :content-type:content-type:date:date:feedback-id:feedback-id :from:from:in-reply-to:in-reply-to:message-id:mime-version :references:reply-to:subject:subject:to:to:x-me-proxy :x-me-sender:x-me-sender:x-sasl-enc; s=fm3; t=1763015304; x= 1763101704; bh=c2ok+HHWT/kMY9oVcGYBS0qqKuf/1lrfJuDr0QpsvSA=; b=v Ph0d/OcLl3IsAjTVbZ+FWn96rLsKV7y2YQgC5Zkq16I8tdwi0+NfEdyWU1/aiaF5 Pz3TGh6s1CXAC+eIDCHsDNCyVofVLy0eHEA0GvjuEUl3RC0g9HT0yZaOZoTuqYAL BwSgWps5lhvbV2YDbm5SgLKnLAyA9a2v3BoYo5CoahByE8a//58yTqWBrKg0ktjn SM11QwOun06DkpfmuDhyP/CNJ0gXYvsI3h3G6k5CJxHGBzH5M73xOSndDNLbX5H3 XQPjzo+/DLg2ldARb7MsrSlPrUvc7f55VF8kulko4AfvSXBbDGRgLbni4CASGW1l BWU6RPyfAQcEwXOjrhbGQ== X-ME-Sender: X-ME-Proxy-Cause: gggruggvucftvghtrhhoucdtuddrgeeffedrtdeggddvtdeivdefucetufdoteggodetrf dotffvucfrrhhofhhilhgvmecuhfgrshhtofgrihhlpdfurfetoffkrfgpnffqhgenuceu rghilhhouhhtmecufedttdenucenucfjughrpefoggffhffvvefkjghfufgtgfesthejre dtredttdenucfhrhhomhepfdflohgvlhculfgrtghosghsohhnfdcuoehjohgvlhestgho mhhpihhlvghrrdhorhhgqeenucggtffrrghtthgvrhhnpeefheelffegvdelfeevteejtd ekteefleeihfdtudelkeeijedtvefgueevieekieenucevlhhushhtvghrufhiiigvpedt necurfgrrhgrmhepmhgrihhlfhhrohhmpehjohgvlhestghomhhpihhlvghrrdhorhhgpd hnsggprhgtphhtthhopedvpdhmohguvgepshhmthhpohhuthdprhgtphhtthhopegrrhhs vghnihihrdhmuhhkhhhinhdruggvvhesghhmrghilhdrtghomhdprhgtphhtthhopehpgh hsqhhlqdhhrggtkhgvrhhssehpohhsthhgrhgvshhqlhdrohhrgh X-ME-Proxy: Feedback-ID: ic6394509:Fastmail Received: by mailuser.phl.internal (Postfix, from userid 501) id E78C918E0069; Thu, 13 Nov 2025 01:28:23 -0500 (EST) X-Mailer: MessagingEngine.com Webmail Interface MIME-Version: 1.0 X-ThreadId: AE1r89ybsZ1g Date: Thu, 13 Nov 2025 07:28:03 +0100 From: "Joel Jacobson" To: "Arseniy Mukhin" Cc: pgsql-hackers Message-Id: <0253b822-e8fd-4067-ab24-23493c115a2a@app.fastmail.com> In-Reply-To: References: <6899c044-4a82-49be-8117-e6f669765f7e@app.fastmail.com> <165530.1752362320@sss.pgh.pa.us> <02a7cd37-e2fc-4212-8b19-f8c239c95fb8@app.fastmail.com> <96f00bf1-cc9d-4520-9d02-9e14e7767c88@app.fastmail.com> <30c2aa7d-dd6c-4b68-a2e4-f217a1a34acf@app.fastmail.com> <0b4d402a-9ac2-4aa8-acf8-8231dbe579ea@app.fastmail.com> <3095599.1758644879@sss.pgh.pa.us> <0dc6a2cc-5216-4dc1-9dd2-430cafc6095b@app.fastmail.com> <52CC167F-763B-4ECA-B0B4-DAB381816828@gmail.com> <9186C6D0-F7A9-482A-9183-89E530B57E36@gmail.com> <1073593.1759423179@sss.pgh.pa.us> <4bd5e6c4-6fa7-44bb-869d-59a32a331fa8@app.fastmail.com> <85828f29-e72e-4400-94f3-9a69bc8dc239@app.fastmail.com> <2495353.1759860890@sss.pgh.pa.us> <8aeae418-92a6-4bbd-9c06-9574c79e59f7@app.fastmail.com> <2531672.1759868124@sss.pgh.pa.us> <474efa78-337c-41cd-a73a-f845a0115109@app.fastmail.com> <2749343.1759949176@sss.pgh.pa.us> <8bfca2be-1ec0-4e15-aafb-0b7b661fe936@app.fastmail.com> <9eba307f-f2fb-48f0-9507-2e197f39ef9e@app.fastmail.com> <8c71183a-0d28-4bcf-a806-78446ff95404@app.fastmail.com> <1009807.1760476747@sss.pgh.pa.us> <1F7227F5-C33D-4E2C-8511-33F1468590D0@gmail.com> <0a5a20d3-4621-46b3-b2ab-903f63a20dea@app.fastmail.com> <6F913129-ABEF-4004-AAF3-F22FC34!29AE8@gmail.com> <1547585.1760645808@sss.pgh.pa.us> <14865EB6-0BF4-462B-9072-10BDAC10C052@gmail.com> <0BCA1C2D-B92C-459E-B1A6-6D06BA4C62CF@gmail.com> <55d24cbb-e9ef-491f-a99b-b3dbd7cecdf9@app.fastmail.com> <38574cad-e90d-47b7-a015-753bb6bbc360@app.fastmail.com> <66631FB7-5BEA-4ED5-A694-9AD8B9CCFEE8@gmail.com> <4b7b49a5-5e1a-44a8-93e0-60457d15cb1d@app.fastmail.com> <82DEA2B6-6FC5-4A79-BDE3-1FD72F104A6E@gmail.com> <38de1036-d8cf-420c-b845-edb5a946b191@app.fastmail.com> <87E40BF8-8877-4DBD-9040-99AF8A4E6358@gmail.com> <7556f0d4-03fd-451a-bd34-5f62b424319a@app.fastmail.com> <290910DE-9A03-4AE6-B348-073D5DA96ACC@gmail.com> <4B243750-12BE-4C16-A769-A803268F40E3@gmail.com> <4605CAD6-69D5-4082-B96C-91FC0DE5399D@gmail.com> <294e1641-d658-4d43-8671-60e8ff860532@app.fastmail.com> <26d4dd6a-cfc5-4efc-9704-9cd3216ed712@app.fastmail.com> <7456ec96-7a9c-45a0-988e-ba1c7f9ec937@app.fastmail.com> Subject: Re: Optimize LISTEN/NOTIFY Content-Type: text/plain Content-Transfer-Encoding: 7bit List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk On Wed, Nov 12, 2025, at 17:57, Arseniy Mukhin wrote: > IIUC it's impossible for the listener to stop somewhere in between > queueHeadBeforeWrite and queueHeadAfterWrite. If the listener has > managed to read the first notification from the notifier, it means the > notifier transaction is complete and the listener should stop only > after reading all notifications (so we should always see pos = > queueHeadAfterWrite or further). > > So If I haven't missed anything, I think we can use QUEUE_POS_EQUAL as > direct advancement condition: > > if (!QUEUE_BACKEND_IS_ADVANCING(i) && QUEUE_POS_EQUAL(pos, > queueHeadBeforeWrite)) > { > QUEUE_BACKEND_POS(i) = queueHeadAfterWrite; > } I added some logging just to test the hypothesis: @@ -2072,6 +2082,12 @@ SignalBackends(void) { Assert(!QUEUE_POS_PRECEDES(pos, queueHeadBeforeWrite)); + if (!QUEUE_POS_EQUAL(pos, queueHeadBeforeWrite)) + elog(LOG, "Direct advancement: PID %d from pos (%lld,%d) to queueHeadAfterWrite (%lld,%d)", + pid, + (long long) QUEUE_POS_PAGE(pos), QUEUE_POS_OFFSET(pos), + (long long) QUEUE_POS_PAGE(queueHeadAfterWrite), QUEUE_POS_OFFSET(queueHeadAfterWrite)); + QUEUE_BACKEND_POS(i) = queueHeadAfterWrite; } } And I'm getting a lot of such log entries when benchmarking `./pg_async_notify_test --listeners 1 --notifiers 1 --channels 50` I think this confirms that listeners can actually stop somewhere in between queueHeadBeforeWrite and queueHeadAfterWrite. /Joel