@@ -159,9 +159,9 @@ pg_qs_shmem_startup(void)
159159{
160160toc = shm_toc_attach (PG_QS_MODULE_KEY ,shmem );
161161
162- counterpart_userid = shm_toc_lookup (toc ,num_toc ++ );
163- params = shm_toc_lookup (toc ,num_toc ++ );
164- mq = shm_toc_lookup (toc ,num_toc ++ );
162+ counterpart_userid = shm_toc_lookup (toc ,num_toc ++ , false );
163+ params = shm_toc_lookup (toc ,num_toc ++ , false );
164+ mq = shm_toc_lookup (toc ,num_toc ++ , false );
165165}
166166
167167if (prev_shmem_startup_hook )
@@ -872,7 +872,7 @@ GetRemoteBackendWorkers(PGPROC *proc)
872872result = lcons (proc ,result );
873873}
874874
875- shm_mq_detach (mq );
875+ shm_mq_detach (mqh );
876876
877877return result ;
878878
@@ -962,7 +962,7 @@ GetRemoteBackendQueryStates(PGPROC *leader,
962962gotomq_error ;
963963Assert (len == msg -> length );
964964result = lappend (result ,copy_msg (msg ));
965- shm_mq_detach (mq );
965+ shm_mq_detach (mqh );
966966
967967/*
968968 * collect results from all alived parallel workers
@@ -993,7 +993,7 @@ GetRemoteBackendQueryStates(PGPROC *leader,
993993/* aggregate result data */
994994result = lappend (result ,copy_msg (msg ));
995995
996- shm_mq_detach (mq );
996+ shm_mq_detach (mqh );
997997}
998998
999999return result ;