From 909202096c93b36a4e078db537c53d8b43d07d35 Mon Sep 17 00:00:00 2001 From: Jelte Fennema Date: Mon, 10 Oct 2022 15:45:33 +0200 Subject: [PATCH] Some logs --- src/backend/distributed/metadata/metadata_cache.c | 2 ++ src/backend/distributed/shared_library_init.c | 1 + .../udfs/citus_isolation_test_session_is_blocked/11.2-1.sql | 4 ++-- src/backend/distributed/transaction/backend_data.c | 4 ++++ 4 files changed, 9 insertions(+), 2 deletions(-) diff --git a/src/backend/distributed/metadata/metadata_cache.c b/src/backend/distributed/metadata/metadata_cache.c index cffa666fc..c82507e17 100644 --- a/src/backend/distributed/metadata/metadata_cache.c +++ b/src/backend/distributed/metadata/metadata_cache.c @@ -4626,6 +4626,7 @@ InvalidateDistRelationCacheCallback(Datum argument, Oid relationId) */ if (relationId == MetadataCache.distPartitionRelationId) { + elog(LOG, "NOOO: pg_dist_partition changed"); InvalidateMetadataSystemCache(); } @@ -4774,6 +4775,7 @@ CreateDistObjectCache(void) void InvalidateMetadataSystemCache(void) { + elog(LOG, "INVALIDATING METADA SYSTEM CACHE"); InvalidateConnParamsHashEntries(); memset(&MetadataCache, 0, sizeof(MetadataCache)); diff --git a/src/backend/distributed/shared_library_init.c b/src/backend/distributed/shared_library_init.c index 4fef57630..ce845b6fe 100644 --- a/src/backend/distributed/shared_library_init.c +++ b/src/backend/distributed/shared_library_init.c @@ -664,6 +664,7 @@ StartupCitusBackend(void) * INVALID_CITUS_INTERNAL_BACKEND_GPID, since we override it again two * lines below. */ + elog(LOG, "STARTUP CITUS BACKEND %s", application_name); InitializeBackendData(INVALID_CITUS_INTERNAL_BACKEND_GPID); AssignGlobalPID(); RegisterConnectionCleanup(); diff --git a/src/backend/distributed/sql/udfs/citus_isolation_test_session_is_blocked/11.2-1.sql b/src/backend/distributed/sql/udfs/citus_isolation_test_session_is_blocked/11.2-1.sql index 9f4261734..35aa16365 100644 --- a/src/backend/distributed/sql/udfs/citus_isolation_test_session_is_blocked/11.2-1.sql +++ b/src/backend/distributed/sql/udfs/citus_isolation_test_session_is_blocked/11.2-1.sql @@ -25,9 +25,9 @@ RETURNS boolean AS $$ END IF; RAISE WARNING E'DETECTING BLOCKS FOR %', mBlockedGlobalPid; - FOR r IN select p.blocking_global_pid, a1.query blocking_query, p.waiting_global_pid, a2.query waiting_query from citus_internal_global_blocked_processes() p join pg_stat_activity a1 on p.blocking_pid = a1.pid join pg_stat_activity a2 on p.waiting_pid = a2.pid + FOR r IN select p.blocking_global_pid, p.blocking_pid, a1.application_name blocking_app, a1.query blocking_query, p.waiting_global_pid, p.waiting_pid, a2.application_name waiting_app, a2.query waiting_query from citus_internal_global_blocked_processes() p join pg_stat_activity a1 on p.blocking_pid = a1.pid join pg_stat_activity a2 on p.waiting_pid = a2.pid LOOP - RAISE WARNING E'GPID: % %\nBLOCKS\nGPID: % %', r.blocking_global_pid, r.blocking_query, r.waiting_global_pid, r.waiting_query; + RAISE WARNING E'GPID: % % % %\nBLOCKS\nGPID: % % % %', r.blocking_global_pid, r.blocking_pid, r.blocking_app, r.blocking_query, r.waiting_global_pid, r.waiting_pid, r.waiting_app, r.waiting_query; END LOOP; IF current_setting('citus.isolation_test_check_all_blocks') = 'off' THEN diff --git a/src/backend/distributed/transaction/backend_data.c b/src/backend/distributed/transaction/backend_data.c index 201240cbb..d32bc3ee0 100644 --- a/src/backend/distributed/transaction/backend_data.c +++ b/src/backend/distributed/transaction/backend_data.c @@ -702,6 +702,8 @@ InitializeBackendData(const char *applicationName) UnSetDistributedTransactionId(); UnSetGlobalPID(); + elog(LOG, "INITIALIZE BACKEND DATA %lu", gpid); + SpinLockAcquire(&MyBackendData->mutex); MyBackendData->distributedCommandOriginator = IsExternalClientBackend(); MyBackendData->globalPID = gpid; @@ -749,6 +751,7 @@ UnSetGlobalPID(void) /* backend does not exist if the extension is not created */ if (MyBackendData) { + elog(LOG, "UNSETTING GLOBAL PID"); SpinLockAcquire(&MyBackendData->mutex); MyBackendData->globalPID = 0; @@ -888,6 +891,7 @@ AssignGlobalPID(void) globalPID = ExtractGlobalPID(application_name); } + elog(LOG, "ASSIGNING GLOBAL PID %lu", globalPID); Oid userId = GetUserId(); SpinLockAcquire(&MyBackendData->mutex);