From 90cc4ad15a891b175cdb2c2a121c5b3143444269 Mon Sep 17 00:00:00 2001 From: maxiang <8185929+Xiao__Ma@user.noreply.gitee.com> Date: Sun, 14 Mar 2021 21:34:56 +0800 Subject: [PATCH] =?UTF-8?q?update=20src/gausskernel/storage/replication/lo?= =?UTF-8?q?gical/logical.cpp.=20=E8=A7=A3=E5=86=B3JDBC=E8=BF=9E=E6=8E=A5?= =?UTF-8?q?=E5=A4=87=E6=9C=BA=E8=BF=9B=E8=A1=8C=E9=80=BB=E8=BE=91=E8=A7=A3?= =?UTF-8?q?=E7=A0=81=EF=BC=8C=E4=B8=8D=E8=83=BD=E6=AD=A3=E5=B8=B8=E6=8E=A8?= =?UTF-8?q?=E8=BF=9B=E9=97=AE=E9=A2=98=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/storage/replication/logical/logical.cpp | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/src/gausskernel/storage/replication/logical/logical.cpp b/src/gausskernel/storage/replication/logical/logical.cpp index 5c771a8fa..85eaffb9b 100644 --- a/src/gausskernel/storage/replication/logical/logical.cpp +++ b/src/gausskernel/storage/replication/logical/logical.cpp @@ -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)))); }