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

修复资源池化checkpoint创建发布订阅复制槽异常的问题

Browse Source
This commit is contained in:
arcoalien@qq.com
2023-07-19 20:55:28 +08:00
parent 4ad5b447f4
commit f0e67b816e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/gausskernel/storage/replication/logical/origin.cpp
View File

@ -438,7 +438,7 @@ Size ReplicationOriginShmemSize(void)
* we keep the replay state of *remote* transactions. But for now it seems
* sufficient to reuse it, lest we introduce a separate guc.
*/
if (g_instance.attr.attr_storage.max_replication_slots == 0)
if (g_instance.attr.attr_storage.max_replication_slots == 0 || ENABLE_DMS)
return size;
size = add_size(size, offsetof(ReplicationStateShmStruct, states));
@ -520,7 +520,7 @@ void CheckPointReplicationOrigin(void)
pg_crc32c crc;
struct stat st;
if (g_instance.attr.attr_storage.max_replication_slots == 0) {
if (g_instance.attr.attr_storage.max_replication_slots == 0 || ENABLE_DMS) {
return;
}
@ -645,7 +645,7 @@ void StartupReplicationOrigin(void)
pg_crc32c file_crc;
pg_crc32c crc;
if (g_instance.attr.attr_storage.max_replication_slots == 0)
if (g_instance.attr.attr_storage.max_replication_slots == 0 || ENABLE_DMS)
return;
INIT_CRC32C(crc);