Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1oxJZs-0006X4-GL for pgsql-hackers@arkaria.postgresql.org; Tue, 22 Nov 2022 03:04:04 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.92) (envelope-from ) id 1oxJZr-0000mb-CA for pgsql-hackers@arkaria.postgresql.org; Tue, 22 Nov 2022 03:04:03 +0000 Received: from makus.postgresql.org ([2001:4800:3e1:1::229]) by malur.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1oxJZq-0000mR-TB for pgsql-hackers@lists.postgresql.org; Tue, 22 Nov 2022 03:04:03 +0000 Received: from esa8.fujitsucc.c3s2.iphmx.com ([68.232.159.88]) by makus.postgresql.org with esmtps (TLS1.2:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1oxJZn-0003aF-Ld for pgsql-hackers@postgresql.org; Tue, 22 Nov 2022 03:04:01 +0000 DKIM-Signature: v=1; a=rsa-sha256; c=simple/simple; d=fujitsu.com; i=@fujitsu.com; q=dns/txt; s=fj1; t=1669086239; x=1700622239; h=from:to:cc:subject:date:message-id:references: in-reply-to:content-transfer-encoding:mime-version; bh=ywXVIu3zDvGei1FUxNJEFw5kxWRVL9wPsBXhl3lExrw=; b=rqnJMl4gLnlVwihaGN/4SS1NVDxmlb0Zdb0RTMFH2KJqwYMa6PI3rxz7 dREaC0XZl3aCpKjV+aCk4owILiQwYdItwOBgz8Fay/IvXojBMyrprHHZj 9R4DGEzsqv4WxSLhjRyDNs+TQp6uaVu23NYiwVRqO/r9+lGrwKVLAfns9 zttYxJtfs1qdV5XU1NpZmLh9SqAIvY4C8FgWg5wcYQ6+qpDSUrvygj//s hBolj75FuFeCC7T3PQDRM/+8IzMZMQH1fVBN0hhzkoAMw2P9q6FzD4DsL SC7IjQeKyCnJHvi+53QHGh2A6BUUMdffrtTVnlb+yaLgpLvdgx2gjr+Qz w==; X-IronPort-AV: E=McAfee;i="6500,9779,10538"; a="70585892" X-IronPort-AV: E=Sophos;i="5.96,182,1665414000"; d="scan'208";a="70585892" Received: from mail-tycjpn01lp2171.outbound.protection.outlook.com (HELO JPN01-TYC-obe.outbound.protection.outlook.com) ([104.47.23.171]) by ob1.fujitsucc.c3s2.iphmx.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 22 Nov 2022 12:03:55 +0900 ARC-Seal: i=1; a=rsa-sha256; s=arcselector9901; d=microsoft.com; cv=none; b=H2m9cJPbA0xfnBXu1AWUiINhQUtXnanP3n05Zwu5UuConGMYd4w2h9O32Gjg7uk2bKy0VTM+7KicUE3FL6lWdwXGA7LCc5JhltPuPETaUGSIuYBx7X8rFxQ4Uv/9SD+PrrT7oaYIBMDq1N8Zvi32HkwKENU3X/MfCB1GiMf/GCE/fp0h7LZwnKvQ7M/qI6XUZHK1ul5WZLhpP1eYkjss4K+wr10rejjsS/k96Fu4EKjUOkd5ppidwf5hNne0rYGPClB+ezex3+7DTsjuaMrkghi0EVp34tLJjjraGS/fW6U3/6hl20VKD8eiF0yKpAokaaX+VUCRK9Nmhr0cfP0EeQ== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com; s=arcselector9901; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-AntiSpam-MessageData-ChunkCount:X-MS-Exchange-AntiSpam-MessageData-0:X-MS-Exchange-AntiSpam-MessageData-1; bh=ywXVIu3zDvGei1FUxNJEFw5kxWRVL9wPsBXhl3lExrw=; b=ENcufb+cOCisz/MNjThDPdSQF3UmTgpOhqwNRn8XMwyRkeL3blAwpvwLDKqYk2rDgkp+mE+PSQR4CBcZWsnUGQv/6HO3NygWkrpVVjfmmnzAfTb/OXqFo8P7macUGWgYG8NY7HnjDWilVpoxWMcgjxfYisNyEv94ZG8i1dZD2JNtUTBCzCek70zmnMeil8B2x52j9H4lviBTjEAniA8CK8PFgakKxdJjYvW1BXeMca65HAdCfnV2NNjox3X9BAr9d5yWjVfoW0k1X74zRnLY5WE+xdQF2ccIKE7hogkYtTCkhFycc+z/lIXSUSPDzXet0LAHQs4Sk9RgYOhJY615Ow== ARC-Authentication-Results: i=1; mx.microsoft.com 1; spf=pass smtp.mailfrom=fujitsu.com; dmarc=pass action=none header.from=fujitsu.com; dkim=pass header.d=fujitsu.com; arc=none Received: from TYAPR01MB5866.jpnprd01.prod.outlook.com (2603:1096:404:8056::13) by OS0PR01MB5619.jpnprd01.prod.outlook.com (2603:1096:604:bf::7) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.5834.15; Tue, 22 Nov 2022 03:03:53 +0000 Received: from TYAPR01MB5866.jpnprd01.prod.outlook.com ([fe80::f4b:1dbf:dc2:dc91]) by TYAPR01MB5866.jpnprd01.prod.outlook.com ([fe80::f4b:1dbf:dc2:dc91%5]) with mapi id 15.20.5834.015; Tue, 22 Nov 2022 03:03:53 +0000 From: "Hayato Kuroda (Fujitsu)" To: 'Nathan Bossart' CC: "pgsql-hackers@postgresql.org" Subject: RE: wake up logical workers after ALTER SUBSCRIPTION Thread-Topic: wake up logical workers after ALTER SUBSCRIPTION Thread-Index: AQHY/gstJTOw1KVvYkmzgq5jwtGOWq5KPp3g Date: Tue, 22 Nov 2022 03:03:52 +0000 Message-ID: References: <20221122004119.GA132961@nathanxps13> In-Reply-To: <20221122004119.GA132961@nathanxps13> Accept-Language: ja-JP, en-US Content-Language: ja-JP X-MS-Has-Attach: X-MS-TNEF-Correlator: msip_labels: MSIP_Label_a7295cc1-d279-42ac-ab4d-3b0f4fece050_Enabled=true; MSIP_Label_a7295cc1-d279-42ac-ab4d-3b0f4fece050_SetDate=2022-11-22T03:03:51Z; MSIP_Label_a7295cc1-d279-42ac-ab4d-3b0f4fece050_Method=Standard; MSIP_Label_a7295cc1-d279-42ac-ab4d-3b0f4fece050_Name=FUJITSU-RESTRICTED?; MSIP_Label_a7295cc1-d279-42ac-ab4d-3b0f4fece050_SiteId=a19f121d-81e1-4858-a9d8-736e267fd4c7; MSIP_Label_a7295cc1-d279-42ac-ab4d-3b0f4fece050_ActionId=11b22a3b-5534-4ad2-931e-8ec88afc4a21; MSIP_Label_a7295cc1-d279-42ac-ab4d-3b0f4fece050_ContentBits=0 authentication-results: dkim=none (message not signed) header.d=none;dmarc=none action=none header.from=fujitsu.com; x-ms-publictraffictype: Email x-ms-traffictypediagnostic: TYAPR01MB5866:EE_|OS0PR01MB5619:EE_ x-ms-office365-filtering-correlation-id: fd1eb76b-5d5f-4bb9-4a45-08dacc362fee x-ms-exchange-senderadcheck: 1 x-ms-exchange-antispam-relay: 0 x-microsoft-antispam: BCL:0; x-microsoft-antispam-message-info: HOoPl/oVSM+rYW8lREPgXYYBq/ykFInilMD8XWeOgvM6vBqg2PQ9RQx3ZUkVySrHO665ui0bpqPwG6qpXKswQ0uVASrYmzjfCVVYNHtn/7R8Gxjzz46I0rVt1JaCHqInOYKLS7fdOqBLK0qlC+EwIvX19lu9wWV1/KnW9wHK5yMqE5+tvC8bi7Q1J9vkyB/K1D6jCE7JgHCGpJDt5/UrxD4cX9/rBwnCjQ79464j29kAPjNOyk9LrEp0CjApG9pCkLKfRQET+UhQch4Hw5px5Qgi4qsIOTUNlWw7gI3v1tvG7awFNt9hOn+XWqmawC+My9+aBeXfv1j4Qi2QnSOF9xIaVGqv9yjKEIBX0sDADQM58t7ayCIWEy2MPLEUZuugRQpbPIhR2PNJM+dFslTqFduPFfRKzvSfbxLD85QSiwcYFvFLhC9Wm3rv1M5EXCh1mkbUUQ5fIy5+aLwANFGLKpuL7K77jhC5tcDXqQS2Z2sGpZXz0w+xCSjeLEuqCYULZnio7CRy8W1vXYCgsPE7ATS8nSsw1mWzx0j4txTFwkXxXSD0KIWk33n4tL8B/DqrqmGtQzgGMfZfffvftQENpqfLHO9PrPbwhJAK/mqAliv5XPsa5347IhXHaGni2fity5fAXG+6+YJysOVJ44oTMhhWCrMN88HttaEaMHp3kP4i3JgcFLw3YKOyJNP8BhZNdz/uduD+cBWE+7RysQPyf/uoyRGuiXQbS55BsFqGXWATO9cHJpR+4a1v4kX7iAtRiK3Y4UCgYg/Hgj+Ot4K9jw== x-forefront-antispam-report: CIP:255.255.255.255;CTRY:;LANG:en;SCL:1;SRV:;IPV:NLI;SFV:NSPM;H:TYAPR01MB5866.jpnprd01.prod.outlook.com;PTR:;CAT:NONE;SFS:(13230022)(4636009)(346002)(136003)(376002)(366004)(39860400002)(396003)(1590799012)(451199015)(122000001)(86362001)(83380400001)(38100700002)(41300700001)(38070700005)(82960400001)(2906002)(4744005)(52536014)(8936002)(5660300002)(478600001)(55016003)(6506007)(7696005)(66446008)(4326008)(66476007)(66556008)(8676002)(76116006)(316002)(66946007)(9686003)(26005)(966005)(186003)(6916009)(71200400001)(64756008)(85182001)(33656002)(1580799009);DIR:OUT;SFP:1101; x-ms-exchange-antispam-messagedata-chunkcount: 1 x-ms-exchange-antispam-messagedata-0: =?iso-2022-jp?B?SU85YUdqWDdjU1lZTGtMOVpiYzNkcWFCOGRSSXZScUE5UmVnQ0pQaytB?= =?iso-2022-jp?B?d2FmU3dtRmxZb0ljRE5UWHVNUE9CWlBNSHVicDdYSUhJQ2x1S3FmTjVL?= =?iso-2022-jp?B?cFA0MWVHWW9qbjRXSGVGaVVHMXVPMDRMMlZqMUtTVmtvRGQxeWVkZFYx?= =?iso-2022-jp?B?VENEUDRIdHpKRHQ5MWN2c1FrbHRpVWxzdGo5RTA5ZnV0RlhjS29Pbkk4?= =?iso-2022-jp?B?eThMMzlJZ0RLTjltMGlGVXZmV1R1VmZyaXdESEFnbUtLWDkyUUZsZUhI?= =?iso-2022-jp?B?ZFBwS3ZJa3V3eXhFcXZiVnJNbW05VGlHK1VySHZaMWh2b0JMZXE1RGFT?= =?iso-2022-jp?B?b0xrd2svaFVLeXdnSXZFRXFqWEhxeXc1aTZUaGppQmp5MlpOcGl1d0xk?= =?iso-2022-jp?B?VEllSHREWVRvTnRvaEplTEpvRld0cm5yOEtZV0VvOVlGREdRbVhNM1VZ?= =?iso-2022-jp?B?S3RyRG56NEsyUU5RZTVkNnpyQmhpQ3lJdmdWU2d1YVlYcFJKY2k2bzFF?= =?iso-2022-jp?B?UHhldkpJK0FxV0paK2tBWU1kNFBXSmtyb0k2emw3WFJySmZuUURwU2Q4?= =?iso-2022-jp?B?a3J3RWs1cmdwdTFTUzdMampNeTRCM3dXYVZ6TlRjemV0U0JubXVFRFly?= =?iso-2022-jp?B?MFcwaTB3cDlNU1ZrZThZWFlnZlBxZFdPWmZpbTI4Z3Ywek5qZEd2QVRY?= =?iso-2022-jp?B?K0tmay8xaWVJd3orMzQzTUY4SzRWSG9yYUxkTFZSL0tGMlFNRlV2Z3py?= =?iso-2022-jp?B?a2lITk42SXNxTFFnbS95MXMxTitlUzMrMjNKbjZZNWo1dURCSDlTSHg2?= =?iso-2022-jp?B?RmViVExxVXBMdWlEYWVuREh4M2hxeHdYNzI0czdzWnhvRzd0dkIwMUQy?= =?iso-2022-jp?B?SXRZNm9xZWJpQ2Zvb2hiM3lrckQ1SUx4YWdqMHAwSWRicWhRWVlPc2NM?= =?iso-2022-jp?B?ZDlYdHJldnMyUXZKajVlU1FVa0FFWE45QnREWnZVTDAxOU83WnB6UWQy?= =?iso-2022-jp?B?UEtVbG9BWmduemtlQ0d3UVBERWozeTliVTV4NVppN3FML0pTVVIwZUc4?= =?iso-2022-jp?B?ZzV4K29zMEkrQitMZGhEQ1FlTU5aczBQZjJkbW53TGpaNWg0OVZvUUJH?= =?iso-2022-jp?B?aTZPbCtVcFJGdzJyc0E3NXlVVzV5OFBZbVJHNU9OYnNHT01oS1dYVHha?= =?iso-2022-jp?B?TXd6OW9vb2hITTBoVUFQZzY5VTFZbm9KT0E4YitDdndMbzI1V0FYMFJE?= =?iso-2022-jp?B?Uzd6dmU5alVmUi9ReDBhR29NNVc5Z1A5Y2MyT09pNlplTDI2M1p0TXFj?= =?iso-2022-jp?B?Zm1xU00wVmxpaTV1aEVRZHF6MitKSHJHbFMwUEVPdDhnQkFUR2JWTmdJ?= =?iso-2022-jp?B?ZU9vWVo4MXpDTXlicjZtT1h5QjMyenlmQllTc2VMZkt6ZmpTemFWd25h?= =?iso-2022-jp?B?Zy9udWUxMCt4OVBXdjkvbVZVTnlxdElDSUMwRWdJSVEvSkxNUEttQURE?= =?iso-2022-jp?B?aGpTaGR1eWhZUHdVRTY5Si9xaENLTnYwdXBmbWRnVWdJNXBMemZCSWFQ?= =?iso-2022-jp?B?S0R4L0ErRjkva1FDRzlJL1Y2bXJBcjVNT0Y5d2QzajVpTG03bytvUjRk?= =?iso-2022-jp?B?ejVxeXJHT3lEQzBuN1pnZWNJZ251SVhsQ2wrRmxSQ0VSby9LUzlkakxy?= =?iso-2022-jp?B?MzNqL08yeEdpYXdwVXJLK055ZnVwU1dZb0NYMW1SdFJ5dy83VkZJM2xu?= =?iso-2022-jp?B?S1Y1SVF5enpUdllXc05XMWZaNWNwRzBzR1ZLQzJweENvU1haWVozTzFK?= =?iso-2022-jp?B?ZTNBM0VKVHZjaVhpZjJlTFRMVXlmdGVEcmNOaWpnUG5zT3plQm1QSUp4?= =?iso-2022-jp?B?a094VVFsVjBnQ2p1d2tsZXJXenpTNnFjblVRSkdDMkhvWFpjenYveVRp?= =?iso-2022-jp?B?R3l5T25FbWlZMHowSjBFeVRHVXdBM0tZN2V1RUZnc2Zqdkc5WDliaUM2?= =?iso-2022-jp?B?bGk1TUMzRDBDSUlybU5vZ3NscklwNG15ZGdUTk1VQXczTE8ybnAxVEYy?= =?iso-2022-jp?B?R1dZNWczUXh1SUNqS3JZbHVBM1BGM3RUOW5mc1VSNEdPUGF5VXBhZEph?= =?iso-2022-jp?B?cUtqaUViejQwZTNtM21MU0J5dVI2U1VQN2JUbC9zeU5sOVNSdHVRWFVP?= =?iso-2022-jp?B?amtXTE9EeEpPcUsxbmRCRExiUXZIWFdJQytmR3pmZUN6enUxWHAwOFp0?= =?iso-2022-jp?B?SmFxTTFZeU01TkM4Tzk1aVRseEtnTTc4WVpNQUdVOXZ4cVZsVTIrcXhi?= =?iso-2022-jp?B?M3BBVnJGZmlrRWw2aTFoRE00ZG0xMUZuMUE9PQ==?= Content-Type: text/plain; charset="iso-2022-jp" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-MS-Exchange-AntiSpam-ExternalHop-MessageData-ChunkCount: 1 X-MS-Exchange-AntiSpam-ExternalHop-MessageData-0: IFgdm4PknPiC2wDLz2bHp0Kb67lTkEUkEiwuTQR5yLIDKIqnJtgx+nM4dlNDn1pqbq6951tYlZJng5VPVbwYKqwobj8R77aooYiF0usdLh6LzmTatXoQMBHlbzs6kU7Y1HGB6MIu5YXe9wnjCbR5lCS+8BLuXkPLtX1DMms5hdA7sMkaPchuT6c/y/Q5y90Bz/w90xVR/y3CdmPKkp7943VJZCyYQ5EHY81KTaOBFf6+TCQdgN8zx8TS3kNG1zSnLGYz8BN9/kT+qvQxkJ6STyARcSjIBNzodWGI53SHjsiq7/Ee6AfpRwaYjhGKiDlEwbz6+xOXPTK3LW0qRIBTX9pwAfNoklxtcxMh86EkkFVEAuDmtVrCj48O7M4HoLz91yGBP3RuhhU7dnAlAp5RDXD1RhwTnycxhcK8yVVjx5QiiZ00QgQ6sIoHk6/bCVRezQK9RwE2vo1zU0DYV0yaTZ7XBD3MGibxhZXF7acmG3VddwJsrMVYjGB0M6LAr5ciNGeXA+pRA1e+qeqLuPzuqNmSRm1GeVUGsCUJ+QyrGInxeJgaRFPGW24CE6Vgt5E51CyGLSCNkk7Nw/0Zq0SQrjEYCyDKKEWmTGFGdDy6fhDmbHl9F+HYQwHD7+7VnA00r4eYd9bN3NGayWLTewHP47OSD4/HQGi9WcrJ4fUhQd9yGBY+o4pzZ2BuCTUpHNsr/25AfLZiA8W3lwZJ4QONjpJ7xhpJFGFoVEYlJfqkjV7iQz9NY3ZPgM4hZcGuxzDLLtU/rgwwf4OzNRElvjvYZw6IgfGxsH63bY/JloV8jeg= X-OriginatorOrg: fujitsu.com X-MS-Exchange-CrossTenant-AuthAs: Internal X-MS-Exchange-CrossTenant-AuthSource: TYAPR01MB5866.jpnprd01.prod.outlook.com X-MS-Exchange-CrossTenant-Network-Message-Id: fd1eb76b-5d5f-4bb9-4a45-08dacc362fee X-MS-Exchange-CrossTenant-originalarrivaltime: 22 Nov 2022 03:03:53.0167 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Hosted X-MS-Exchange-CrossTenant-id: a19f121d-81e1-4858-a9d8-736e267fd4c7 X-MS-Exchange-CrossTenant-mailboxtype: HOSTED X-MS-Exchange-CrossTenant-userprincipalname: mr6MQ4a8wZCdRT7UaxvyBf+OM8BfohyrbEXsqo9t7V4Ux+R7QvvkeY7YWqxHxkY5FuZUmRCInzWN5ZQhR6jBnM/exKmsQgtw9MqS1yL3RLE= X-MS-Exchange-Transport-CrossTenantHeadersStamped: OS0PR01MB5619 List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk Hi Nathan, I have done almost same thing locally for [1], but I thought your code seem= ed better. Just One comment: IIUC the statement "ALTER SUBSCRIPTION" can be executed inside the transaction. So if two subscriptions are altered in the same transaction, only one of them will awake. Is it expected behavior? I think we can hold a suboid list and record oids when the subscription are altered, and then the backend process can consume all of list cells at the = end of the transaction. How do you think? [1]: https://commitfest.postgresql.org/40/3581/ Best Regards, Hayato Kuroda FUJITSU LIMITED