From: | Fujii Masao <masao(dot)fujii(at)gmail(dot)com> |
---|---|
To: | Rintaro Ikeda <ikedarintarof(at)oss(dot)nttdata(dot)com> |
Cc: | Yugo Nagata <nagata(at)sraoss(dot)co(dot)jp>, Jakub Wartak <jakub(dot)wartak(at)enterprisedb(dot)com>, "Hayato Kuroda (Fujitsu)" <kuroda(dot)hayato(at)fujitsu(dot)com>, "slpmcf(at)gmail(dot)com" <slpmcf(at)gmail(dot)com>, "boekewurm+postgres(at)gmail(dot)com" <boekewurm+postgres(at)gmail(dot)com>, "pgsql-hackers(at)postgresql(dot)org" <pgsql-hackers(at)postgresql(dot)org>, Srinath Reddy Sadipiralla <srinath2133(at)gmail(dot)com>, Dilip Kumar <dilipbalaut(at)gmail(dot)com> |
Subject: | Re: Suggestion to add --continue-client-on-abort option to pgbench |
Date: | 2025-09-24 17:19:27 |
Message-ID: | CAHGQGwGK67emP1ToeMvbC+LouCx6VcHWMgtTO9zk0TtKQBZJiA@mail.gmail.com |
Views: | Whole Thread | Raw Message | Download mbox | Resend email |
Thread: | |
Lists: | pgsql-hackers |
On Tue, Sep 23, 2025 at 11:58 AM Rintaro Ikeda
<ikedarintarof(at)oss(dot)nttdata(dot)com> wrote:
> I think the issue is a new bug because we have transitioned to CSTATE_ABORT
> immediately after queries failed, without executing discardUntilSync().
If so, the fix in discardUntilSync() should be part of the continue-on-error
patch. The assertion failure fix should be a separate patch, since only
that needs to be backpatched (the failure can also occur in back branches).
> I've attached a patch that fixes the assertion error. The content of v1 patch by
> Mr. Nagata is also included. I would appreciate it if you review my patch.
+ if (received_sync == true)
For boolean flags, we usually just use the variable itself instead of
"== true/false".
+ switch (PQresultStatus(res))
+ {
+ case PGRES_PIPELINE_SYNC:
+ received_sync = true;
In the PGRES_PIPELINE_SYNC case, PQclear(res) isn't called but should be.
+ case PGRES_FATAL_ERROR:
+ PQclear(res);
+ goto done;
I don't think we need goto here. How about this instead?
-----------------------
@@ -3525,11 +3525,18 @@ discardUntilSync(CState *st)
* results have been discarded.
*/
st->num_syncs = 0;
- PQclear(res);
break;
}
+ /*
+ * Stop receiving further results if PGRES_FATAL_ERROR
is returned
+ * (e.g., due to a connection failure) before
PGRES_PIPELINE_SYNC,
+ * since PGRES_PIPELINE_SYNC will never arrive.
+ */
+ else if (PQresultStatus(res) == PGRES_FATAL_ERROR)
+ break;
PQclear(res);
}
+ PQclear(res);
/* exit pipeline */
if (PQexitPipelineMode(st->con) != 1)
-----------------------
Regards,
--
Fujii Masao
From | Date | Subject | |
---|---|---|---|
Next Message | Christoph Berg | 2025-09-24 17:27:39 | Re: "openssl" should not be optional |
Previous Message | Masahiko Sawada | 2025-09-24 17:11:20 | Re: Add memory_limit_hits to pg_stat_replication_slots |