There is 1 other session using the database when drop database

【故障现象描述】
When we drop database concurrently, we find errors below:
```
drop database IF EXISTS pl_test_cursor_part8;
ERROR: Database "pl_test_cursor_part8" is being accessed by other users. You can stop all connections by command: "clean connection to all force for database XXXX;" or wait for the sessions to end by querying view: "pg_stat_activity".
DETAIL: There is 1 other session using the database.
```

【故障复现步骤】
test script:
```
#!/bin/bash

for i in {1..1000}
do
    result=`./pg_regress --schedule=parallel_schedule0 -p 1234`
    echo $result
    fail=`echo $result|grep "failed"|wc -l`
    echo Time$i: $fail
    if [[ $fail > 0 ]]; then
        exit 1;
    fi
done
exit 0;
```

parallel_schedule0:
```
test: hw_cursor_part1 hw_cursor_part2 hw_cursor_part3 hw_cursor_part4 hw_cursor_part5 hw_cursor_part6 hw_cursor_part7 hw_cursor_part8
```

【开发定位初步原因】
Two cases which will cause this error:
case 1
TwoPhaseCleanerMain(), can avoid it by set guc `gs_clean_timeout=0`.
case 2
Add abort() at the place log error, we get the stack like below:
thread 1 stack: drop table
```
(gdb) bt
#0 0x00007fe2d1f223d7 in raise () from /lib64/libc.so.6
#1 0x00007fe2d1f23ac8 in abort () from /lib64/libc.so.6
#2 0x000000000160ff9d in dropdb (dbname=0x7fe21911d330 "pl_test_cursor_part8", missing_ok=true) at dbcommands.cpp:1070
#3 0x00000000018f5fcb in standard_ProcessUtility (parse_tree=0x7fe21911d398, query_string=0x7fe21911c060 "drop database IF EXISTS pl_test_cursor_part8;", params=0x0,
    is_top_level=true, dest=0x7fe21911d560, sent_to_remote=false, completion_tag=0x7fe224fbbf20 "", isCTAS=false) at utility.cpp:5248
#4 0x00007fe2c7b48a88 in gsaudit_ProcessUtility_hook (parsetree=0x7fe21911d398, queryString=0x7fe21911c060 "drop database IF EXISTS pl_test_cursor_part8;", params=0x0,
    isTopLevel=true, dest=0x7fe21911d560, sentToRemote=false, completionTag=0x7fe224fbbf20 "", isCTAS=false) at gs_policy_plugin.cpp:825
#5 0x00000000019060d8 in pgaudit_ProcessUtility (parsetree=0x7fe21911d398, queryString=0x7fe21911c060 "drop database IF EXISTS pl_test_cursor_part8;", params=0x0,
    isTopLevel=true, dest=0x7fe21911d560, sentToRemote=false, completionTag=0x7fe224fbbf20 "", isCTAS=false) at auditfuncs.cpp:1342
#6 0x000000000195f197 in hypo_utility_hook (parsetree=0x7fe21911d398, queryString=0x7fe21911c060 "drop database IF EXISTS pl_test_cursor_part8;", params=0x0, isTopLevel=true,
    dest=0x7fe21911d560, sentToRemote=false, completionTag=0x7fe224fbbf20 "", isCtas=false) at hypopg_index.cpp:174
#7 0x00000000018f12f8 in ProcessUtility (parse_tree=0x7fe21911d398, query_string=0x7fe21911c060 "drop database IF EXISTS pl_test_cursor_part8;", params=0x0, is_top_level=true,
    dest=0x7fe21911d560, sent_to_remote=false, completion_tag=0x7fe224fbbf20 "", isCTAS=false) at utility.cpp:1455
#8 0x00000000018ec465 in PortalRunUtility (portal=0x7fe1e1d88060, utilityStmt=0x7fe21911d398, isTopLevel=true, dest=0x7fe21911d560, completionTag=0x7fe224fbbf20 "")
    at pquery.cpp:1754
#9 0x00000000018ec919 in PortalRunMulti (portal=0x7fe1e1d88060, isTopLevel=true, dest=0x7fe21911d560, altdest=0x7fe21911d560, completionTag=0x7fe224fbbf20 "")
    at pquery.cpp:1933
#10 0x00000000018eae74 in PortalRun (portal=0x7fe1e1d88060, count=9223372036854775807, isTopLevel=true, dest=0x7fe21911d560, altdest=0x7fe21911d560,
    completionTag=0x7fe224fbbf20 "") at pquery.cpp:1191
#11 0x00000000018d141a in exec_simple_query (query_string=0x7fe21911c060 "drop database IF EXISTS pl_test_cursor_part8;", messageType=QUERY_MESSAGE, msg=0x7fe224fbc110)
    at postgres.cpp:2729
#12 0x00000000018de253 in PostgresMain (argc=1, argv=0x7fe21ef26dd8, dbname=0x0, username=0x0) at postgres.cpp:8585
#13 0x0000000001824f58 in BackendRun (port=0x7fe224fbc620) at postmaster.cpp:8031
#14 0x0000000001835401 in GaussDbThreadMain<(knl_thread_role)2> (arg=0x7fe2587c7e08) at postmaster.cpp:12193
#15 0x0000000001830c80 in InternalThreadFunc (args=0x7fe2587c7e08) at postmaster.cpp:12788
#16 0x00000000023437e4 in ThreadStarterFunc (arg=0x7fe2587c7df8) at gs_thread.cpp:382
#17 0x00007fe2d22c1ea5 in start_thread () from /lib64/libpthread.so.0
#18 0x00007fe2d1fea9fd in clone () from /lib64/libc.so.6
```
thread 47 stack: initSession
```
(gdb) bt
#0 0x00007fe2d1fec1f7 in semop () from /lib64/libc.so.6
#1 0x0000000000e142aa in PGSemaphoreLock (sema=0x7fe25e6eccd0, interruptOK=true) at pg_sema.cpp:407
#2 0x0000000002263d82 in ProcSleep (locallock=0x7fe2ced8fb88, lockMethodTable=0x70758c0 <default_lockmethod>, allow_con_update=false, waitSec=0) at proc.cpp:1887
#3 0x0000000002256ec7 in WaitOnLock (locallock=0x7fe2ced8fb88, owner=0x7fe2ced68060, allow_con_update=false, waitSec=0) at lock.cpp:1723
#4 0x0000000002254a01 in LockAcquireExtendedXC (locktag=0x7fe22b649d50, lockmode=3, sessionLock=false, dontWait=false, reportMemoryError=true, only_increment=false,
    allow_con_update=false, waitSec=0) at lock.cpp:1005
#5 0x000000000225328f in LockAcquireExtended (locktag=0x7fe22b649d50, lockmode=3, sessionLock=false, dontWait=false, reportMemoryError=true, allow_con_update=false, waitSec=0)
    at lock.cpp:548
#6 0x00000000022531e6 in LockAcquire (locktag=0x7fe22b649d50, lockmode=3, sessionLock=false, dontWait=false, allow_con_update=false, waitSec=0) at lock.cpp:516
#7 0x0000000002251312 in LockSharedObject (classid=1262, objid=575214, objsubid=0, lockmode=3) at lmgr.cpp:885
#8 0x00000000011489fb in PostgresInitializer::LockDatabase (this=0x7fe218be67b0) at postinit.cpp:2531
#9 0x0000000001148582 in PostgresInitializer::SetDatabase (this=0x7fe218be67b0) at postinit.cpp:2444
#10 0x00000000011478c7 in PostgresInitializer::InitSession (this=0x7fe218be67b0) at postinit.cpp:2112
#11 0x000000000191cbd7 in InitSession (worker=0x7fe255154630, session=0x7fe206d56060) at threadpool_worker.cpp:936
#12 0x000000000191c1de in ThreadPoolWorker::AttachSessionToThread (this=0x7fe255154630) at threadpool_worker.cpp:649
#13 0x000000000191a701 in ThreadPoolWorker::WaitMission (this=0x7fe255154630) at threadpool_worker.cpp:202
#14 0x00000000018dd809 in PostgresMain (argc=1, argv=0x7fe221bcadd8, dbname=0x0, username=0x0) at postgres.cpp:8260
#15 0x0000000001824f58 in BackendRun (port=0x7fe22b64a620) at postmaster.cpp:8031
#16 0x0000000001835401 in GaussDbThreadMain<(knl_thread_role)2> (arg=0x7fe2587c80e0) at postmaster.cpp:12193
#17 0x0000000001830c80 in InternalThreadFunc (args=0x7fe2587c80e0) at postmaster.cpp:12788
#18 0x00000000023437e4 in ThreadStarterFunc (arg=0x7fe2587c80d0) at gs_thread.cpp:382
#19 0x00007fe2d22c1ea5 in start_thread () from /lib64/libpthread.so.0
#20 0x00007fe2d1fea9fd in clone () from /lib64/libc.so.6
```
thread 21 stack: WLMProcessThreadMain
```
(gdb) bt
#0 0x00007fe2d1fdfccd in poll () from /lib64/libc.so.6
#1 0x0000000002327f4e in pqSocketPoll (sock=35, forRead=1, forWrite=0, end_time=-1) at fe-misc.cpp:1103
#2 0x0000000002327dd8 in pqSocketCheck (conn=0x7fe1e5040700, forRead=1, forWrite=0, end_time=-1) at fe-misc.cpp:1050
#3 0x0000000002327bc6 in pqWaitTimed (forRead=1, forWrite=0, conn=0x7fe1e5040700, finish_time=-1) at fe-misc.cpp:988
#4 0x0000000002313e2f in connectDBComplete (conn=0x7fe1e5040700) at fe-connect.cpp:1727
#5 0x0000000002310ef7 in PQconnectdb (conninfo=0x7fe1eca876b0 "dbname=pl_test_cursor_part8 port=1234 application_name='statctl'") at fe-connect.cpp:454
#6 0x0000000001356661 in WLMReadjustUserSpaceByQuery (username=0x6c095e5 "0000", database_name_list=0x7fe1e4ff6400) at statctl.cpp:1886
#7 0x00000000013574b4 in GetUserSpaceThroughAllDbs (username=0x6c095e5 "0000") at statctl.cpp:1949
#8 0x0000000001357854 in WLMReadjustUserSpaceThroughAllDbs (username=0x6c095e5 "0000") at statctl.cpp:2022
#9 0x000000000136d235 in WLMProcessThreadMain () at statctl.cpp:8125
#10 0x0000000001838562 in GaussDbThreadMain<(knl_thread_role)13> (arg=0x7fe2587c8658) at postmaster.cpp:12308
#11 0x0000000001830c80 in InternalThreadFunc (args=0x7fe2587c8658) at postmaster.cpp:12788
#12 0x00000000023437e4 in ThreadStarterFunc (arg=0x7fe2587c8648) at gs_thread.cpp:382
#13 0x00007fe2d22c1ea5 in start_thread () from /lib64/libpthread.so.0
#14 0x00007fe2d1fea9fd in clone () from /lib64/libc.so.6
```

openGauss/openGauss-server

内容风险标识

评论 (14)

openGauss/openGauss-server .gitee-modal { width: 500px !important; }

内容风险标识