From cc44099d9ef62034a1db6bc6e4f6c5efa802ce03 Mon Sep 17 00:00:00 2001 From: chendong76 <1209756284@qq.com> Date: Tue, 3 Jan 2023 19:24:36 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=8F=E5=9E=8B=E5=8C=96=E5=88=A0=E9=99=A4?= =?UTF-8?q?=E5=85=B1=E4=BA=AB=E5=AD=98=E5=82=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/CMakeLists.txt | 2 +- src/bin/initdb/initdb.cpp | 8 +++++++ src/bin/pg_controldata/pg_controldata.cpp | 4 ++++ src/bin/pg_probackup/help.cpp | 24 +++++++++++++++++++ src/bin/pg_probackup/pg_probackup.cpp | 4 ++-- src/bin/pg_probackup/pg_probackupc.h | 4 ++++ src/bin/pg_resetxlog/pg_resetxlog.cpp | 4 ++++ src/gausskernel/Makefile | 2 ++ src/gausskernel/ddes/CMakeLists.txt | 6 +++-- src/gausskernel/ddes/adapter/ss_aio.cpp | 10 ++++++++ .../storage/replication/syncrep.cpp | 2 +- src/include/ddes/dms/ss_common_attr.h | 7 ++++++ src/include/miscadmin.h | 5 ++++ 13 files changed, 76 insertions(+), 6 deletions(-) diff --git a/src/CMakeLists.txt b/src/CMakeLists.txt index ec682ea4b..41278eaf9 100755 --- a/src/CMakeLists.txt +++ b/src/CMakeLists.txt @@ -193,7 +193,7 @@ endif() if("${ENABLE_MULTIPLE_NODES}" STREQUAL "OFF") install(DIRECTORY ${DCF_LIB_PATH} DESTINATION .) endif() -if(${ENABLE_MULTIPLE_NODES}_${ENABLE_PRIVATEGAUSS} STREQUAL OFF_OFF) +if(${ENABLE_MULTIPLE_NODES}_${ENABLE_PRIVATEGAUSS} STREQUAL OFF_OFF AND NOT ${ENABLE_LITE_MODE} STREQUAL ON) if(EXISTS ${DMS_LIB_PATH}) install(DIRECTORY ${DMS_LIB_PATH} DESTINATION .) endif() diff --git a/src/bin/initdb/initdb.cpp b/src/bin/initdb/initdb.cpp index e8fe4f081..86cc20e70 100644 --- a/src/bin/initdb/initdb.cpp +++ b/src/bin/initdb/initdb.cpp @@ -3797,7 +3797,9 @@ static void usage(const char* prog_name) #ifndef ENABLE_MULTIPLE_NODES printf(_(" -c, --enable-dcf enable DCF mode\n")); #endif +#ifndef ENABLE_LITE_MODE printf(_(" --enable-dss enable shared storage mode\n")); +#endif printf(_(" [-D, --pgdata=]DATADIR location for this database cluster\n")); #ifdef ENABLE_MULTIPLE_NODES printf(_(" --nodename=NODENAME name of openGauss node initialized\n")); @@ -3805,9 +3807,11 @@ static void usage(const char* prog_name) #else printf(_(" --nodename=NODENAME name of single node initialized\n")); #endif +#ifndef ENABLE_LITE_MODE printf(_(" --vgname=VGNAME name of dss volume group\n")); printf(_(" --socketpath=SOCKETPATH\n" " dss connect socket file path\n")); +#endif printf(_(" -E, --encoding=ENCODING set default encoding for new databases\n")); printf(_(" --locale=LOCALE set default locale for new databases\n")); printf(_(" --dbcompatibility=DBCOMPATIBILITY set default dbcompatibility for new database\n")); @@ -3891,6 +3895,7 @@ static bool is_file_exist(const char* path) return isExist; } +#ifndef ENABLE_LITE_MODE static void parse_vgname_args(char* args) { vgname = xstrdup(args); @@ -3920,6 +3925,7 @@ static void parse_vgname_args(char* args) exit(1); } } +#endif int main(int argc, char* argv[]) { @@ -4255,6 +4261,7 @@ int main(int argc, char* argv[]) } g_bucket_len = atoi(optarg); break; +#ifndef ENABLE_LITE_MODE case 15: FREE_NOT_STATIC_ZERO_STRING(vgname); FREE_NOT_STATIC_ZERO_STRING(vgdata); @@ -4274,6 +4281,7 @@ int main(int argc, char* argv[]) check_input_spec_char(optarg); ss_nodedatainfo = xstrdup(optarg); break; +#endif default: /* getopt_long already emitted a complaint */ write_stderr(_("Try \"%s --help\" for more information.\n"), progname); diff --git a/src/bin/pg_controldata/pg_controldata.cpp b/src/bin/pg_controldata/pg_controldata.cpp index 8ebaca9ef..f65db9682 100644 --- a/src/bin/pg_controldata/pg_controldata.cpp +++ b/src/bin/pg_controldata/pg_controldata.cpp @@ -43,11 +43,13 @@ static void usage(const char* prog_name) printf(_("Usage:\n")); printf(_(" %s [OPTION] [DATADIR]\n"), prog_name); printf(_("\nOptions:\n")); +#ifndef ENABLE_LITE_MODE printf(_(" -I, --instance-id=INSTANCE_ID\n")); printf(_(" display information of specified instance (default all)\n")); printf(_(" --enable-dss enable shared storage mode\n")); printf(_(" --socketpath=SOCKETPATH\n")); printf(_(" dss connect socket file path\n")); +#endif printf(_(" -V, --version output version information, then exit\n")); printf(_(" -?, --help show this help, then exit\n")); printf(_("\nIf no data directory (DATADIR) is specified, " @@ -263,6 +265,7 @@ int main(int argc, char* argv[]) while ((option_value = getopt_long(argc, argv, "I:V", long_options, &option_index)) != -1) { switch (option_value) { +#ifndef ENABLE_LITE_MODE case 'I': if (atoi(optarg) < MIN_INSTANCEID || atoi(optarg) > MAX_INSTANCEID) { fprintf(stderr, _("%s: unexpected node id specified, valid range is %d - %d\n"), @@ -279,6 +282,7 @@ int main(int argc, char* argv[]) enable_dss = true; socketpath = strdup(optarg); break; +#endif default: /* getopt_long already emitted a complaint */ fprintf(stderr, _("Try \"%s --help\" for more information.\n"), progname); diff --git a/src/bin/pg_probackup/help.cpp b/src/bin/pg_probackup/help.cpp index 28852c527..a16180ae6 100644 --- a/src/bin/pg_probackup/help.cpp +++ b/src/bin/pg_probackup/help.cpp @@ -86,8 +86,10 @@ void help_pg_probackup(void) printf(_(" [--remote-path=path] [--remote-user=username]\n")); printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n")); printf(_(" [--remote-libpath=libpath]\n")); +#ifndef ENABLE_LITE_MODE printf(_(" [--enable-dss] [--instance-id=instance_id]\n")); printf(_(" [--vgname=\"vgdata,vglog\"] [--socketpath=socketpath]\n")); +#endif printf(_(" [--help]\n")); printf(_("\n %s del-instance -B backup-path --instance=instance_name\n"), PROGRAM_NAME); @@ -113,8 +115,10 @@ void help_pg_probackup(void) printf(_(" [--remote-path=path] [--remote-user=username]\n")); printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n")); printf(_(" [--remote-libpath=libpath]\n")); +#ifndef ENABLE_LITE_MODE printf(_(" [--enable-dss] [--instance-id=instance_id]\n")); printf(_(" [--vgname=\"vgdata,vglog\"] [--socketpath=socketpath]\n")); +#endif printf(_(" [--help]\n")); printf(_("\n %s set-backup -B backup-path --instance=instance_name -i backup-id\n"), PROGRAM_NAME); @@ -157,8 +161,10 @@ void help_pg_probackup(void) printf(_(" [--remote-path=path] [--remote-user=username]\n")); printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n")); printf(_(" [--remote-libpath=libpath]\n")); +#ifndef ENABLE_LITE_MODE printf(_(" [--enable-dss] [--instance-id=instance_id]\n")); printf(_(" [--vgname=\"vgdata,vglog\"] [--socketpath=socketpath]\n")); +#endif printf(_(" [--ttl=interval] [--expire-time=time]\n")); printf(_(" [--backup-pg-replslot]\n")); printf(_(" [--help]\n")); @@ -175,8 +181,10 @@ void help_pg_probackup(void) printf(_(" [--remote-path=path] [--remote-user=username]\n")); printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n")); printf(_(" [--remote-libpath=libpath]\n")); +#ifndef ENABLE_LITE_MODE printf(_(" [--enable-dss] [--instance-id=instance_id]\n")); printf(_(" [--vgname=\"vgdata,vglog\"] [--socketpath=socketpath]\n")); +#endif printf(_(" [--log-level-console=log-level-console]\n")); printf(_(" [--log-level-file=log-level-file]\n")); printf(_(" [--log-filename=log-filename]\n")); @@ -246,8 +254,10 @@ static void help_add_instance(void) printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n\n")); printf(_(" [--remote-libpath=libpath]\n")); printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n")); +#ifndef ENABLE_LITE_MODE printf(_(" [--enable-dss] [--instance-id=instance_id]\n")); printf(_(" [--vgname=\"vgdata,vglog\"] [--socketpath=socketpath]\n\n")); +#endif printf(_(" -B, --backup-path=backup-path location of the backup storage area\n")); printf(_(" -D, --pgdata=pgdata-path location of the database storage area\n")); @@ -268,11 +278,13 @@ static void help_add_instance(void) printf(_(" --ssh-options=ssh_options additional ssh options (default: none)\n")); printf(_(" (example: --ssh-options='-c cipher_spec -F configfile')\n")); +#ifndef ENABLE_LITE_MODE printf(_("\n DSS options:\n")); printf(_(" --enable-dss enable shared storage mode\n")); printf(_(" --vgname=\"vgdata,vglog\" name of dss volume group\n")); printf(_(" --instance-id=instance_id instance id of backup node\n")); printf(_(" --socketpath=socketpath dss connect socket file path\n\n")); +#endif } static void help_del_instance(void) @@ -306,8 +318,10 @@ static void help_set_config(void) printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n\n")); printf(_(" [--remote-libpath=libpath]\n")); printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n")); +#ifndef ENABLE_LITE_MODE printf(_(" [--enable-dss] [--instance-id=instance_id]\n")); printf(_(" [--vgname=\"vgdata,vglog\"] [--socketpath=socketpath]\n\n")); +#endif printf(_(" -B, --backup-path=backup-path location of the backup storage area\n")); printf(_(" --instance=instance_name name of the instance\n")); @@ -370,11 +384,13 @@ static void help_set_config(void) printf(_(" --ssh-options=ssh_options additional ssh options (default: none)\n")); printf(_(" (example: --ssh-options='-c cipher_spec -F configfile')\n")); +#ifndef ENABLE_LITE_MODE printf(_("\n DSS options:\n")); printf(_(" --enable-dss enable shared storage mode\n")); printf(_(" --vgname=\"vgdata,vglog\" name of dss volume group\n")); printf(_(" --instance-id=instance_id instance id of backup node\n")); printf(_(" --socketpath=socketpath dss connect socket file path\n\n")); +#endif } static void help_set_backup(void) @@ -446,8 +462,10 @@ static void help_backup(void) printf(_(" [--remote-path=path] [--remote-user=username]\n")); printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n")); printf(_(" [--remote-libpath=libpath]\n")); +#ifndef ENABLE_LITE_MODE printf(_(" [--enable-dss] [--instance-id=instance_id]\n")); printf(_(" [--vgname=\"vgdata,vglog\"] [--socketpath=socketpath]\n")); +#endif printf(_(" [--ttl=interval] [--expire-time=time]\n\n")); printf(_(" [--backup-pg-replslot]\n")); @@ -535,11 +553,13 @@ static void help_backup(void) printf(_(" --ssh-options=ssh_options additional ssh options (default: none)\n")); printf(_(" (example: --ssh-options='-c cipher_spec -F configfile')\n")); +#ifndef ENABLE_LITE_MODE printf(_("\n DSS options:\n")); printf(_(" --enable-dss enable shared storage mode\n")); printf(_(" --vgname=\"vgdata,vglog\" name of dss volume group\n")); printf(_(" --instance-id=instance_id instance id of backup node\n")); printf(_(" --socketpath=socketpath dss connect socket file path\n")); +#endif printf(_("\n Pinning options:\n")); printf(_(" --ttl=interval pin backup for specified amount of time; 0 unpin\n")); @@ -563,8 +583,10 @@ static void help_restore(void) printf(_(" [--remote-path=path] [--remote-user=username]\n")); printf(_(" [--remote-port=port] [--ssh-options=ssh_options]\n")); printf(_(" [--remote-libpath=libpath]\n")); +#ifndef ENABLE_LITE_MODE printf(_(" [--enable-dss] [--instance-id=instance_id]\n")); printf(_(" [--vgname=\"vgdata,vglog\"] [--socketpath=socketpath]\n")); +#endif printf(_(" [--log-level-console=log-level-console]\n")); printf(_(" [--log-level-file=log-level-file]\n")); printf(_(" [--log-filename=log-filename]\n")); @@ -613,11 +635,13 @@ static void help_restore(void) printf(_(" --ssh-options=ssh_options additional ssh options (default: none)\n")); printf(_(" (example: --ssh-options='-c cipher_spec -F configfile')\n")); +#ifndef ENABLE_LITE_MODE printf(_("\n DSS options:\n")); printf(_(" --enable-dss enable shared storage mode\n")); printf(_(" --vgname=\"vgdata,vglog\" name of dss volume group\n")); printf(_(" --instance-id=instance_id instance id of backup node\n")); printf(_(" --socketpath=socketpath dss connect socket file path\n")); +#endif printf(_("\n Logging options:\n")); printf(_(" --log-level-console=log-level-console\n")); diff --git a/src/bin/pg_probackup/pg_probackup.cpp b/src/bin/pg_probackup/pg_probackup.cpp index 8d84f937d..794242745 100644 --- a/src/bin/pg_probackup/pg_probackup.cpp +++ b/src/bin/pg_probackup/pg_probackup.cpp @@ -927,14 +927,14 @@ compress_init(void) static void dss_init(void) { - if (instance_config.dss.enable_dss) { + if (IsDssMode()) { /* skip in some special backup modes */ if (backup_subcmd == DELETE_CMD || backup_subcmd == DELETE_INSTANCE_CMD) { return; } /* register for dssapi */ - if (dss_device_init(instance_config.dss.socketpath, instance_config.dss.enable_dss) != DSS_SUCCESS) { + if (dss_device_init(instance_config.dss.socketpath, IsDssMode()) != DSS_SUCCESS) { elog(ERROR, "fail to init dss device"); return; } diff --git a/src/bin/pg_probackup/pg_probackupc.h b/src/bin/pg_probackup/pg_probackupc.h index dcad6c37e..25c6a595c 100644 --- a/src/bin/pg_probackup/pg_probackupc.h +++ b/src/bin/pg_probackup/pg_probackupc.h @@ -26,7 +26,11 @@ strspn(fname, "0123456789ABCDEF") == XLOG_FNAME_LEN && \ strcmp((fname) + XLOG_FNAME_LEN, ".gz.part") == 0) +#ifdef ENABLE_LITE_MODE +#define IsDssMode() false +#else #define IsDssMode() (instance_config.dss.enable_dss == true) +#endif #define IsSshProtocol() (instance_config.remote.host && strcmp(instance_config.remote.proto, "ssh") == 0) /* directory options */ diff --git a/src/bin/pg_resetxlog/pg_resetxlog.cpp b/src/bin/pg_resetxlog/pg_resetxlog.cpp index 77bafd0cb..b5e31d2f0 100644 --- a/src/bin/pg_resetxlog/pg_resetxlog.cpp +++ b/src/bin/pg_resetxlog/pg_resetxlog.cpp @@ -225,6 +225,7 @@ int main(int argc, char* argv[]) minXlogSegNo = (uint64)log_temp * XLogSegmentsPerXLogId + seg_temp; break; +#ifndef ENABLE_LITE_MODE case 1: dss.enable_dss = true; break; @@ -236,6 +237,7 @@ int main(int argc, char* argv[]) case 3: dss.vgname = strdup(optarg); break; +#endif default: fprintf(stderr, _("Try \"%s --help\" for more information.\n"), progname); @@ -1182,11 +1184,13 @@ static void usage(void) printf(_(" -V, --version output version information, then exit\n")); printf(_(" -x XID set next transaction ID\n")); printf(_(" -?, --help show this help, then exit\n")); +#ifndef ENABLE_LITE_MODE printf(_(" --vgname\n")); printf(_(" the dss data on dss mode\n")); printf(_(" --enable-dss enable shared storage mode\n")); printf(_(" --socketpath=SOCKETPATH\n")); printf(_(" dss connect socket file path\n")); +#endif #if ((defined(ENABLE_MULTIPLE_NODES)) || (defined(ENABLE_PRIVATEGAUSS))) printf("\nReport bugs to GaussDB support.\n"); #else diff --git a/src/gausskernel/Makefile b/src/gausskernel/Makefile index 0dd8214d9..5202a277e 100755 --- a/src/gausskernel/Makefile +++ b/src/gausskernel/Makefile @@ -671,6 +671,7 @@ endif ifneq ($(with_openeuler_os), yes) cp '$(LIBOPENSSL_BIN_PATH)/openssl' '$(DESTDIR)$(bindir)/openssl' ifeq ($(enable_multiple_nodes), no) +ifeq ($(enable_lite_mode), no) cp '$(DCF_LIB_PATH)/libdcf.so' '$(DESTDIR)$(libdir)/libdcf.so' @if test -f $(DSS_LIB_PATH)/libdssaio.so; then cp $(DSS_LIB_PATH)/libdssaio.so $(DESTDIR)$(libdir)/libdssaio.so; fi @if test -f $(DSS_LIB_PATH)/libdssapi.so; then cp $(DSS_LIB_PATH)/libdssapi.so $(DESTDIR)$(libdir)/libdssapi.so; fi @@ -681,6 +682,7 @@ ifeq ($(enable_multiple_nodes), no) @if test -f $(DMS_LIB_PATH)/libdms.so; then cp $(DMS_LIB_PATH)/libdms.so $(DESTDIR)$(libdir)/libdms.so; fi @if test -f $(top_builddir)/src/gausskernel/ddes/script/dms_contrl.sh; then cp $(top_builddir)/src/gausskernel/ddes/script/dms_contrl.sh $(DESTDIR)$(bindir)/dms_contrl.sh; fi @if test -f $(top_builddir)/src/gausskernel/ddes/script/dss_contrl.sh; then cp $(top_builddir)/src/gausskernel/ddes/script/dss_contrl.sh $(DESTDIR)$(bindir)/dss_contrl.sh; fi +endif endif cp '$(ZSTD_LIB_PATH)'/libzstd.so* '$(DESTDIR)$(libdir)/' diff --git a/src/gausskernel/ddes/CMakeLists.txt b/src/gausskernel/ddes/CMakeLists.txt index b61b3c527..4b384bb10 100644 --- a/src/gausskernel/ddes/CMakeLists.txt +++ b/src/gausskernel/ddes/CMakeLists.txt @@ -8,7 +8,9 @@ set(CMAKE_MODULE_PATH ${PROJECT_OPENGS_DIR}/src/gausskernel/ddes/adapter ) -install(FILES ${CMAKE_CURRENT_SOURCE_DIR}/script/dms_contrl.sh DESTINATION bin) -install(FILES ${CMAKE_CURRENT_SOURCE_DIR}/script/dss_contrl.sh DESTINATION bin) +if(NOT "${ENABLE_LITE_MODE}" STREQUAL "ON") + install(FILES ${CMAKE_CURRENT_SOURCE_DIR}/script/dms_contrl.sh DESTINATION bin) + install(FILES ${CMAKE_CURRENT_SOURCE_DIR}/script/dss_contrl.sh DESTINATION bin) +endif() add_subdirectory(adapter) \ No newline at end of file diff --git a/src/gausskernel/ddes/adapter/ss_aio.cpp b/src/gausskernel/ddes/adapter/ss_aio.cpp index e9a890544..d0067a2b2 100644 --- a/src/gausskernel/ddes/adapter/ss_aio.cpp +++ b/src/gausskernel/ddes/adapter/ss_aio.cpp @@ -25,6 +25,7 @@ #include "ddes/dms/ss_aio.h" #include "utils/elog.h" +#ifndef ENABLE_LITE_MODE static void WaitDSSAioComplete(DSSAioCxt *aio_cxt, int index) { AioUtil *aio = &aio_cxt->aio[index]; @@ -59,9 +60,11 @@ static void WaitDSSAioComplete(DSSAioCxt *aio_cxt, int index) 0, sizeof(struct io_event) * DSS_AIO_BATCH_SIZE); securec_check_c(ret, "\0", "\0"); } +#endif void DSSAioFlush(DSSAioCxt *aio_cxt) { +#ifndef ENABLE_LITE_MODE bool need_wait = false; AioUtil *aio = &aio_cxt->aio[aio_cxt->index]; if (aio->iocount > 0) { @@ -81,10 +84,12 @@ void DSSAioFlush(DSSAioCxt *aio_cxt) if (need_wait) { WaitDSSAioComplete(aio_cxt, aio_cxt->index); } +#endif } void DSSAioAppendIOCB(DSSAioCxt *aio_cxt, struct iocb *iocb_ptr) { +#ifndef ENABLE_LITE_MODE AioUtil *aio = &aio_cxt->aio[aio_cxt->index]; aio->iocbs_ptr[aio->iocount] = iocb_ptr; aio->iocount++; @@ -100,6 +105,7 @@ void DSSAioAppendIOCB(DSSAioCxt *aio_cxt, struct iocb *iocb_ptr) WaitDSSAioComplete(aio_cxt, aio_cxt->index); } } +#endif } struct iocb* DSSAioGetIOCB(DSSAioCxt *aio_cxt) @@ -116,6 +122,7 @@ int DSSAioGetIOCBIndex(DSSAioCxt *aio_cxt) void DSSAioInitialize(DSSAioCxt *aio_cxt, aio_callback callback) { +#ifndef ENABLE_LITE_MODE errno_t err = memset_s(aio_cxt, sizeof(DSSAioCxt), 0, sizeof(DSSAioCxt)); securec_check_ss(err, "\0", "\0"); @@ -131,10 +138,12 @@ void DSSAioInitialize(DSSAioCxt *aio_cxt, aio_callback callback) aio_cxt->initialized = true; aio_cxt->aiocb = callback; aio_cxt->index = 0; +#endif } void DSSAioDestroy(DSSAioCxt *aio_cxt) { +#ifndef ENABLE_LITE_MODE if (aio_cxt->initialized) { (void)io_destroy(aio_cxt->aio[0].handle); (void)io_destroy(aio_cxt->aio[1].handle); @@ -142,5 +151,6 @@ void DSSAioDestroy(DSSAioCxt *aio_cxt) errno_t err = memset_s(aio_cxt, sizeof(DSSAioCxt), 0, sizeof(DSSAioCxt)); securec_check_ss(err, "\0", "\0"); } +#endif } diff --git a/src/gausskernel/storage/replication/syncrep.cpp b/src/gausskernel/storage/replication/syncrep.cpp index 5747a39e9..cbb46e1b9 100755 --- a/src/gausskernel/storage/replication/syncrep.cpp +++ b/src/gausskernel/storage/replication/syncrep.cpp @@ -737,7 +737,7 @@ static SyncStandbyNumState check_sync_standbys_num(const SyncRepStandbyData* syn { int i; int* num_group_standbys; - const SyncRepStandbyData* stby; + const SyncRepStandbyData* stby = sync_standbys; SyncStandbyNumState res = STANDBIES_ENOUGH; diff --git a/src/include/ddes/dms/ss_common_attr.h b/src/include/ddes/dms/ss_common_attr.h index 969c33e60..e45190e4e 100644 --- a/src/include/ddes/dms/ss_common_attr.h +++ b/src/include/ddes/dms/ss_common_attr.h @@ -31,10 +31,17 @@ #include "dms_api.h" #include "ss_init.h" +#ifdef ENABLE_LITE_MODE +#define ENABLE_DMS false +#define ENABLE_SS_LOG false +#define ENABLE_REFORM false +#define ENABLE_VERIFY_PAGE_VERSION false +#else #define ENABLE_DMS (g_instance.attr.attr_storage.dms_attr.enable_dms && !IsInitdb) #define ENABLE_SS_LOG (g_instance.attr.attr_storage.dms_attr.enable_log_level) #define ENABLE_REFORM (g_instance.attr.attr_storage.dms_attr.enable_reform) #define ENABLE_VERIFY_PAGE_VERSION (g_instance.attr.attr_storage.dms_attr.enable_verify_page) +#endif #define SS_REFORM_REFORMER \ (ENABLE_DMS && (g_instance.dms_cxt.SSReformInfo.in_reform == true) \ diff --git a/src/include/miscadmin.h b/src/include/miscadmin.h index 96ebc115b..1f691bd0a 100644 --- a/src/include/miscadmin.h +++ b/src/include/miscadmin.h @@ -467,8 +467,13 @@ extern bool CheckExecDirectPrivilege(const char* query); /* check user have priv u_sess->misc_cxt.Mode = (mode); \ } while (0) +#ifdef ENABLE_LITE_MODE +#define ENABLE_DSS false +#define ENABLE_DSS_AIO false +#else #define ENABLE_DSS (g_instance.attr.attr_storage.dss_attr.ss_enable_dss) #define ENABLE_DSS_AIO (ENABLE_DSS && g_instance.attr.attr_storage.dms_attr.enable_dss_aio && !IsInitdb) +#endif /* * Auxiliary-process type identifiers.