From 4471584379eeb9c25810764d75cf776be086bacf Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Thu, 18 Aug 2022 17:25:16 +0200 Subject: [PATCH] WIP --- src/backend/distributed/transaction/backend_data.c | 2 ++ .../regress/spec/isolation_get_distributed_wait_queries_mx.spec | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/backend/distributed/transaction/backend_data.c b/src/backend/distributed/transaction/backend_data.c index 5d16b92b7..3de8e80f3 100644 --- a/src/backend/distributed/transaction/backend_data.c +++ b/src/backend/distributed/transaction/backend_data.c @@ -867,6 +867,7 @@ AssignDistributedTransactionId(void) void AssignGlobalPID(void) { + elog(WARNING, "AssignGlobalPID"); uint64 globalPID = INVALID_CITUS_INTERNAL_BACKEND_GPID; bool distributedCommandOriginator = false; @@ -901,6 +902,7 @@ AssignGlobalPID(void) void SetBackendDataGlobalPID(uint64 globalPID) { + elog(WARNING, "SetBackendDataGlobalPID"); SpinLockAcquire(&MyBackendData->mutex); MyBackendData->globalPID = globalPID; diff --git a/src/test/regress/spec/isolation_get_distributed_wait_queries_mx.spec b/src/test/regress/spec/isolation_get_distributed_wait_queries_mx.spec index 03512f343..d29b4cdb7 100644 --- a/src/test/regress/spec/isolation_get_distributed_wait_queries_mx.spec +++ b/src/test/regress/spec/isolation_get_distributed_wait_queries_mx.spec @@ -166,7 +166,7 @@ step "s3-select-distributed-waiting-queries" // only works for the coordinator step "s3-show-actual-gpids" { - SELECT global_pid > 0 as gpid_exists, query FROM citus_stat_activity WHERE state = 'active' AND query IN (SELECT blocked_statement FROM citus_lock_waits UNION SELECT current_statement_in_blocking_process FROM citus_lock_waits) ORDER BY 1 DESC; + SELECT global_pid > 0 as gpid_exists, global_pid, query FROM citus_stat_activity WHERE state = 'active' AND query IN (SELECT blocked_statement FROM citus_lock_waits UNION SELECT current_statement_in_blocking_process FROM citus_lock_waits) ORDER BY 1 DESC; } // session s1 and s4 executes the commands on the same worker node