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

!3805 【bug fix】【资源池化】修复checkpoint走到发布订阅相关持久化的逻辑中创建文件异常的问题

Browse Source 
Merge pull request !3805 from cchen676/1207master
This commit is contained in:
opengauss_bot
2023-07-24 07:34:24 +00:00
committed by Gitee
parent d3f1b84069 f0e67b816e
commit c552b4231a
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);