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 1vfMXY-001Ks8-0a for pgsql-hackers@arkaria.postgresql.org; Mon, 12 Jan 2026 18:21:20 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.96) (envelope-from ) id 1vfMXW-001RlR-1K for pgsql-hackers@arkaria.postgresql.org; Mon, 12 Jan 2026 18:21:18 +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 1vfMXW-001RlJ-0L for pgsql-hackers@lists.postgresql.org; Mon, 12 Jan 2026 18:21:18 +0000 Received: from mail-lf1-x135.google.com ([2a00:1450:4864:20::135]) by makus.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 (Exim 4.96) (envelope-from ) id 1vfMXT-0003yB-1r for pgsql-hackers@lists.postgresql.org; Mon, 12 Jan 2026 18:21:17 +0000 Received: by mail-lf1-x135.google.com with SMTP id 2adb3069b0e04-59b79f700a1so3876231e87.0 for ; Mon, 12 Jan 2026 10:21:16 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20230601; t=1768242073; x=1768846873; darn=lists.postgresql.org; h=cc:to:subject:message-id:date:from:in-reply-to:references :mime-version:from:to:cc:subject:date:message-id:reply-to; bh=VK3qsTd0E5XK9RLoTlNbpwa8WPkXmOSMKPHjH7desZk=; b=OENY1P/yLP5QoOKv4q1lEGyBNJOvMAkXrmuuUzUgpEaZy7q9OUFjDW9/cybPyEXqc5 uyDPzvBnyS6KhECoNoN89bTmim+wY6GZlpUzKNr2ELXPKYqgKH7jdoqgmIbULXhuG4L4 +Ne6dtMAi9EOnMhSfbQB6pC52QYnAOVpZJitfeckjiaH/TjTHPyCpZ+DvDrXhjAx4keK 0iju/3tlyB3C99zvdia6V8yLDgU0TMQNpa4wesoR4Z2m8bRRkrKBC0sZ09qZp1ksCWvJ piPfWogt6/KNxkgG7jjHxV7XNVBcH2rLSDL/g/FoKi5iJiMuWr/3SKAHoI5LhhwmYzrg 2NAQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1768242073; x=1768846873; h=cc:to:subject:message-id:date:from:in-reply-to:references :mime-version:x-gm-gg:x-gm-message-state:from:to:cc:subject:date :message-id:reply-to; bh=VK3qsTd0E5XK9RLoTlNbpwa8WPkXmOSMKPHjH7desZk=; b=dO/VCNLxnihadQ6tTjU96+GgtbnfkiykU/lvnb0Xq2Ac1KIWes3XKI7Bk6IwbG5KH+ i7wYXsOEQkHoNQlScRYEpeXRcpD4enP47VGRRQW/IDz/vDVrT0ZP9DDSGCwcJvm95wL7 hJ9s5SuiH8xgZhzl5sM2P3C/d9Njy0OVECkNvW8Ioc47PhLpIvXXTOY8Sz/D+kXrfxu7 aBFSPQAAZ1FUGRIqYNuDQV6h3pMhIX7KR3un5nnXgNZHo5STyVYLK/AmRAWAdNRHbhUP EAKAzyE1nekQm87aeeaKrgkxfAovqQrHtz48NWjDPfLB65kWRE4dROfqkBZZm25IaIjb Nj6Q== X-Forwarded-Encrypted: i=1; AJvYcCXRFfdvsJdpsLke9Mwoh1Vx9etbfK6cBa0SQm17T5l9fo35JR7fvONXj4Y4QmPQOJrhtSk4tPf9iV/N5PqR@lists.postgresql.org X-Gm-Message-State: AOJu0YxMaHtyxLlzCLuK73PoxSE1cOPEgtyMUxEcQh8e8Xl3uO1476xp 8ultyadHGWZ5+Vuu4EbHrtDfxd5mHoNCT3zutqRYXCe7AVGPyfZDCBmMLbP8I/t8msHdnXlWT3Y ExrqsD9CEo+a6QKLSotF/hG4Ma+b7yfs= X-Gm-Gg: AY/fxX4PgM2dt5U+VIPAYXqh8NTv0qiq4rKW/DmsDkW2uK8ZmF0OCOnj7iJiauVB0h+ KFg9/SHj80J1YUPmgrN+9NR2P2+ADCHAjlMpFpD0J+XZ5kxrancbWBYJfxuvll6h5GFMLqIUK0O GKgLwUURwj3pfii6bM6X4KTS27Ae9WbJedgp+GQCuf5dE63ME1apDZ3TgWk640ikmVtyHYLMqHb Iyr4bVjF3OfIY6cNNmXhwM/j/tJ27lR1ljHRSUSeVIe5A9krWq9mFNIgBJ4u3OnGy/f2zlkH1uH CVx6vuNFJ4D4SHnY59PvgEsrK4eW2pmACN6G8E1g/2RWtKimmJdVrJazG06TQnkt+qzq X-Google-Smtp-Source: AGHT+IH6EJ9I5KOJoMjN0q22VaIDWcwFx8/9+4+2md3X2uCPTQpE2EugqQ/wfQRg2LmqTLYFnZD6EpXShkxyRsL08jA= X-Received: by 2002:ac2:430b:0:b0:59b:72ad:f554 with SMTP id 2adb3069b0e04-59b993fc54dmr55397e87.12.1768242072887; Mon, 12 Jan 2026 10:21:12 -0800 (PST) MIME-Version: 1.0 References: <202512151349.vlq3mpfniyk3@alvherre.pgsql> <11247.1767609087@localhost> <11558.1767609632@localhost> <141054.1767891540@localhost> <137668.1768235610@localhost> In-Reply-To: <137668.1768235610@localhost> From: Mihail Nikalayeu Date: Mon, 12 Jan 2026 21:20:35 +0300 X-Gm-Features: AZwV_QjYDXFmJgxmjo7vqXTdRGUq1Xw9gYYY5MI669ltxvsoy7_6pIoAvwlcueM Message-ID: Subject: Re: Adding REPACK [concurrently] To: Antonin Houska Cc: Alvaro Herrera , Pg Hackers , Robert Treat Content-Type: text/plain; charset="UTF-8" List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk Hello, Antonin! More comments - now for 0005 (but v29, but I think they are mostly up to date). --- 0005 --- > potentiallly extra 'l' in commit message > Memory the queue is located int. "in"? > again if its still eligible if it's still eligible > int initialized; probably better to be bool (as in shared) > DecodingWorkerState such type does not exists in commit > REPACK_WORKER_MAIN Not used in code anywhere. > int64 timeout = 0; > WaitLSNResult res; formatting issue here (tab vs space) > if (size >= MaxAllocSize) Seems like we lost that check, I think it may be executed on storing the data or before "tup = (HeapTuple) palloc(HEAPTUPLESIZE + t_len);" in apply_concurrent_changes > bool done; I still think it is a confusing name. > chgdst.file_seq = WORKER_FILE_SNAPSHOT + 1; I think it is better to increment it once a snapshot is received. And rename to last_processed/last_improrted to be aligned with last_exported. Best regards, Mikhail.