Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit357012e

Browse files
committed
In successful pg_recvlogical, end PGRES_COPY_OUT cleanly.
pg_recvlogical merely called PQfinish(), so the backend sent messagesafter the disconnect. When that caused EPIPE in internal_flush(),before a LogicalConfirmReceivedLocation(), the next pg_recvlogical wouldrepeat already-acknowledged records. Whether or not the defect causesEPIPE, post-disconnect messages could contain an ErrorResponse that theuser should see. One properly ends PGRES_COPY_OUT by repeatingPQgetCopyData() until it returns a negative value. Augment one of thetests to cover the case of WAL past --endpos. Back-patch to v10, wherecommit7c03078 first appeared. Beforethat commit, pg_recvlogical never reached PGRES_COPY_OUT.Reported by Thomas Munro.Discussion:https://postgr.es/m/CAEepm=1MzM2Z_xNe4foGwZ1a+MO_2S9oYDq3M5D11=JDU_+0Nw@mail.gmail.com
1 parentd439e27 commit357012e

File tree

2 files changed

+36
-5
lines changed

2 files changed

+36
-5
lines changed

‎src/bin/pg_basebackup/pg_recvlogical.c

Lines changed: 30 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -605,14 +605,40 @@ StreamLogicalLog(void)
605605
res=PQgetResult(conn);
606606
if (PQresultStatus(res)==PGRES_COPY_OUT)
607607
{
608+
PQclear(res);
609+
608610
/*
609611
* We're doing a client-initiated clean exit and have sent CopyDone to
610-
* the server. We've already sent replay confirmation and fsync'd so
611-
* we can just clean up the connection now.
612+
* the server. Drain any messages, so we don't miss a last-minute
613+
* ErrorResponse. The walsender stops generating XLogData records once
614+
* it sees CopyDone, so expect this to finish quickly. After CopyDone,
615+
* it's too late for sendFeedback(), even if this were to take a long
616+
* time. Hence, use synchronous-mode PQgetCopyData().
612617
*/
613-
gotoerror;
618+
while (1)
619+
{
620+
intr;
621+
622+
if (copybuf!=NULL)
623+
{
624+
PQfreemem(copybuf);
625+
copybuf=NULL;
626+
}
627+
r=PQgetCopyData(conn,&copybuf,0);
628+
if (r==-1)
629+
break;
630+
if (r==-2)
631+
{
632+
fprintf(stderr,_("%s: could not read COPY data: %s"),
633+
progname,PQerrorMessage(conn));
634+
time_to_abort= false;/* unclean exit */
635+
gotoerror;
636+
}
637+
}
638+
639+
res=PQgetResult(conn);
614640
}
615-
elseif (PQresultStatus(res)!=PGRES_COMMAND_OK)
641+
if (PQresultStatus(res)!=PGRES_COMMAND_OK)
616642
{
617643
fprintf(stderr,
618644
_("%s: unexpected termination of replication stream: %s"),

‎src/test/recovery/t/006_logical_decoding.pl

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,11 @@
7171
);
7272
print"waiting to replay$endpos\n";
7373

74+
# Insert some rows after $endpos, which we won't read.
75+
$node_master->safe_psql('postgres',
76+
qq[INSERT INTO decoding_test(x,y) SELECT s, s::text FROM generate_series(5,50) s;]
77+
);
78+
7479
my$stdout_recv =$node_master->pg_recvlogical_upto(
7580
'postgres','test_slot',$endpos, 180,
7681
'include-xids'=>'0',
@@ -89,7 +94,7 @@
8994
'skip-empty-xacts'=>'1');
9095
chomp($stdout_recv);
9196
is($stdout_recv,'',
92-
'pg_recvlogical acknowledged changes, nothing pending on slot');
97+
'pg_recvlogical acknowledged changes');
9398

9499
$node_master->safe_psql('postgres','CREATE DATABASE otherdb');
95100

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp