database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!812 解决JDBC连接备机进行逻辑解码，不能正常推进的问题

Browse Source 
Merge pull request !812 from maxiang/DRS_sender
This commit is contained in:
opengauss-bot
2021-03-15 19:50:32 +08:00
committed by Gitee
parent 41ecd688b0 90cc4ad15a
commit a200436e49
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/gausskernel/storage/replication/logical/logical.cpp
View File

@ -933,10 +933,7 @@ void LogicalAdvanceConnect()
"%s dbname=replication replication=true "
"fallback_application_name=%s "
"connect_timeout=%d",
conninfo,
(u_sess->attr.attr_common.application_name &&
strlen(u_sess->attr.attr_common.application_name) > 0) ?
u_sess->attr.attr_common.application_name : "pg_recvlogical_sender",
conninfo, "DRS_sender",
u_sess->attr.attr_storage.wal_receiver_connect_timeout);
securec_check_ss(nRet, "", "");
@ -946,7 +943,7 @@ retry:
if (PQstatus(t_thrd.walsender_cxt.advancePrimaryConn) != CONNECTION_OK) {
if (++count < retryNum) {
ereport(LOG,
(errmsg("pg_recvlogical_sender could not connect to the remote server, "
(errmsg("DRS_sender could not connect to the remote server, "
"the connection info :%s : %s",
conninfo, PQerrorMessage(t_thrd.walsender_cxt.advancePrimaryConn))));
@ -958,7 +955,7 @@ retry:
goto retry;
}
ereport(FATAL,
(errmsg("pg_recvlogical_sender could not connect to the remote server, "
(errmsg("DRS_sender could not connect to the remote server, "
"we have tried %d times, the connection info :%s : %s",
count, conninfo, PQerrorMessage(t_thrd.walsender_cxt.advancePrimaryConn))));
}