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

Commit47283e1

Browse files
committed
PGPRO-2065: add thread number to elog messages
1 parent030832c commit47283e1

File tree

2 files changed

+11
-8
lines changed

2 files changed

+11
-8
lines changed

‎src/backup.c

Lines changed: 10 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@ const char *progname = "pg_probackup";
4949
staticparray*backup_files_list=NULL;
5050
staticparray*index_list=NULL;
5151

52-
5352
/* We need critical section for datapagemap_add() in case of using threads */
5453
staticpthread_mutex_tbackup_pagemap_mutex=PTHREAD_MUTEX_INITIALIZER;
5554

@@ -1102,6 +1101,7 @@ do_amcheck(void)
11021101
arg->prev_start_lsn=InvalidXLogRecPtr;
11031102
arg->backup_conn=NULL;
11041103
arg->cancel_conn=NULL;
1104+
arg->thread_num=j+1;
11051105
/* By default there are some error */
11061106
arg->ret=1;
11071107
}
@@ -2659,11 +2659,13 @@ check_indexes(void *arg)
26592659

26602660
/* check for interrupt */
26612661
if (interrupted||thread_interrupted)
2662-
elog(ERROR,"interrupted during checkdb --amcheck");
2662+
elog(ERROR,"Thread [%d]: interrupted during checkdb --amcheck",
2663+
arguments->thread_num);
26632664

26642665
if (progress)
2665-
elog(INFO,"Progress: (%d/%d). Processing index '%s.%s'",
2666-
i+1,n_indexes,ind->amcheck_nspname,ind->name);
2666+
elog(INFO,"Thread [%d]. Progress: (%d/%d). Processing index '%s.%s'",
2667+
arguments->thread_num,i+1,n_indexes,
2668+
ind->amcheck_nspname,ind->name);
26672669

26682670
if (arguments->backup_conn==NULL)
26692671
{
@@ -3593,17 +3595,17 @@ amcheck_one_index(backup_files_arg *arguments,
35933595

35943596
if (PQresultStatus(res)!=PGRES_TUPLES_OK)
35953597
{
3596-
elog(WARNING,"Amcheck failed for index: '%s.%s': %s",
3597-
ind->amcheck_nspname,
3598+
elog(WARNING,"Thread [%d].Amcheck failed for index: '%s.%s': %s",
3599+
arguments->thread_num,ind->amcheck_nspname,
35983600
ind->name,PQresultErrorMessage(res));
35993601

36003602
pfree(params[0]);
36013603
PQclear(res);
36023604
return false;
36033605
}
36043606
else
3605-
elog(LOG,"Amcheck succeeded for index: '%s.%s'",
3606-
ind->amcheck_nspname,ind->name);
3607+
elog(LOG,"Thread [%d].Amcheck succeeded for index: '%s.%s'",
3608+
arguments->thread_num,ind->amcheck_nspname,ind->name);
36073609

36083610
pfree(params[0]);
36093611
PQclear(res);

‎src/pg_probackup.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -318,6 +318,7 @@ typedef struct
318318
PGconn*backup_conn;
319319
PGcancel*cancel_conn;
320320
parray*index_list;
321+
intthread_num;
321322

322323
/*
323324
* Return value from the thread.

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp