Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit49a6ef0

Browse files
committed
Enqueue thread context in terninated list with blocked signals
1 parent2e08861 commit49a6ef0

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

‎src/backend/postmaster/postmaster.c

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3976,16 +3976,16 @@ TerminateChildren(int signal)
39763976
}
39773977

39783978
staticThreadContext*terminated_queue;
3979-
staticpthread_mutex_tteminated_queue_mutex=PTHREAD_MUTEX_INITIALIZER;
3979+
staticpthread_mutex_tterminated_queue_mutex=PTHREAD_MUTEX_INITIALIZER;
39803980

39813981
staticThreadContext*get_terminated_thread()
39823982
{
39833983
ThreadContext*tc;
3984-
pthread_mutex_lock(&teminated_queue_mutex);
3984+
pthread_mutex_lock(&terminated_queue_mutex);
39853985
tc=terminated_queue;
39863986
if (tc!=NULL)
39873987
terminated_queue=tc->next;
3988-
pthread_mutex_unlock(&teminated_queue_mutex);
3988+
pthread_mutex_unlock(&terminated_queue_mutex);
39893989
returntc;
39903990
}
39913991

@@ -4001,10 +4001,10 @@ static void thread_cleanup(void* arg)
40014001
MemoryContextReset(TopMemoryContext);
40024002
free(TopMemoryContext);
40034003

4004-
pthread_mutex_lock(&teminated_queue_mutex);
4004+
pthread_mutex_lock(&terminated_queue_mutex);
40054005
ctx->next=terminated_queue;
40064006
terminated_queue=ctx;
4007-
pthread_mutex_unlock(&teminated_queue_mutex);
4007+
pthread_mutex_unlock(&terminated_queue_mutex);
40084008
elog(DEBUG1,"Thread %ld is terminated",ctx->tid);
40094009
Assert(PostmasterPid!=0);
40104010
rc=pthread_kill(PostmasterPid,SIGUSR1);
@@ -4814,13 +4814,13 @@ static void sigusr1_handler(SIGNAL_ARGS)
48144814

48154815
elog(DEBUG2,"postmaster_sigusr1_handler");
48164816

4817+
PG_SETMASK(&BlockSig);
4818+
48174819
while ((tc=get_terminated_thread())!=NULL)
48184820
{
48194821
reaper(tc);
48204822
}
48214823

4822-
PG_SETMASK(&BlockSig);
4823-
48244824
/* Process background worker state change. */
48254825
if (CheckPostmasterSignal(PMSIGNAL_BACKGROUND_WORKER_CHANGE))
48264826
{

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp