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

Fix concurrent create dolphin bug.

Browse Source
This commit is contained in:
TotaJ
2022-07-29 17:49:31 +08:00
parent 6c8e569752
commit 1c6332d508
5 changed files with 34 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/gausskernel/process/tcop/postgres.cpp
View File

@ -7142,6 +7142,29 @@ void RemoveTempNamespace()
}
}
#ifndef ENABLE_MULTIPLE_NODES
void LoadSqlPlugin()
{
if (u_sess->proc_cxt.MyDatabaseId != InvalidOid && DB_IS_CMPT(B_FORMAT)) {
if (!u_sess->attr.attr_sql.dolphin) {
/* recheck and load dolphin within lock */
pthread_mutex_lock(&g_instance.loadPluginLock[DB_CMPT_B]);
u_sess->attr.attr_sql.dolphin = CheckIfExtensionExists("dolphin");
if (!u_sess->attr.attr_sql.dolphin) {
LoadDolphinIfNeeded();
} else {
InitBSqlPluginHookIfNeeded();
}
pthread_mutex_unlock(&g_instance.loadPluginLock[DB_CMPT_B]);
} else {
InitBSqlPluginHookIfNeeded();
}
} else if (u_sess->proc_cxt.MyDatabaseId != InvalidOid && DB_IS_CMPT(A_FORMAT) && u_sess->attr.attr_sql.whale) {
InitASqlPluginHookIfNeeded();
}
}
#endif
/* ----------------------------------------------------------------
* PostgresMain
* openGauss main loop -- all backends, interactive or otherwise start here
@ -7599,15 +7622,7 @@ int PostgresMain(int argc, char* argv[], const char* dbname, const char* usernam
init_set_params_htab();
#ifndef ENABLE_MULTIPLE_NODES
if (u_sess->proc_cxt.MyDatabaseId != InvalidOid && DB_IS_CMPT(B_FORMAT)) {
if (!u_sess->attr.attr_sql.dolphin) {
LoadDolphinIfNeeded();
} else {
InitBSqlPluginHookIfNeeded();
}
} else if (u_sess->proc_cxt.MyDatabaseId != InvalidOid && DB_IS_CMPT(A_FORMAT) && u_sess->attr.attr_sql.whale) {
InitASqlPluginHookIfNeeded();
}
LoadSqlPlugin();
#endif
/*

5
src/gausskernel/process/threadpool/knl_instance.cpp
View File

@ -838,6 +838,11 @@ void knl_instance_init()
knl_g_csn_barrier_init(&g_instance.csn_barrier_cxt);
knl_g_audit_init(&g_instance.audit_cxt);
knl_plugin_vec_func_init(&g_instance.plugin_vec_func_cxt);
#ifndef ENABLE_MULTIPLE_NODES
for (int i = 0; i < DB_CMPT_MAX; i++) {
pthread_mutex_init(&g_instance.loadPluginLock[i], NULL);
}
#endif
}
void add_numa_alloc_info(void* numaAddr, size_t length)

10
src/gausskernel/process/threadpool/threadpool_worker.cpp
View File

@ -854,15 +854,7 @@ static bool InitSession(knl_session_context* session)
SetProcessingMode(NormalProcessing);
#ifndef ENABLE_MULTIPLE_NODES
if (u_sess->proc_cxt.MyDatabaseId != InvalidOid && DB_IS_CMPT(B_FORMAT)) {
if (!u_sess->attr.attr_sql.dolphin) {
LoadDolphinIfNeeded();
} else {
InitBSqlPluginHookIfNeeded();
}
} else if (u_sess->proc_cxt.MyDatabaseId != InvalidOid && DB_IS_CMPT(A_FORMAT) && u_sess->attr.attr_sql.whale) {
InitASqlPluginHookIfNeeded();
}
LoadSqlPlugin();
#endif
init_session_share_memory();

1
src/include/knl/knl_instance.h
View File

@ -1232,6 +1232,7 @@ typedef struct knl_instance_context {
void *raw_parser_hook[DB_CMPT_MAX];
void *plsql_parser_hook[DB_CMPT_MAX];
char *llvmIrFilePath[DB_CMPT_MAX];
pthread_mutex_t loadPluginLock[DB_CMPT_MAX];
#endif
pg_atomic_uint32 extensionNum;
knl_g_audit_context audit_cxt;

3
src/include/postgres.h
View File

@ -1001,6 +1001,9 @@ void log_disconnections(int code, Datum arg);
void cleanGPCPlanProcExit(int code, Datum arg);
void ResetInterruptCxt();
#ifndef ENABLE_MULTIPLE_NODES
void LoadSqlPlugin();
#endif
#define MSG_A_REPEAT_NUM_MAX 1024
#define OVERRIDE_STACK_LENGTH_MAX 1024