NotificationsYou must be signed in to change notification settings
Fork86
Star739

Commit2022487

committed

PGPRO-2065: cleanup

1 parent340e694 commit2022487Copy full SHA for 2022487

File tree

2 files changed

+15

-23

lines changed

src
- backup.c
- utils
  - pgut.c

2 files changed

+15

-23

lines changed

`‎src/backup.c`

Lines changed: 15 additions & 16 deletions

Original file line number	Diff line number	Diff line change
`@@ -95,7 +95,7 @@ static bool pg_stop_backup_is_sent = false;`
`95`	`95`	`*/`
`96`	`96`	`staticvoidbackup_cleanup(boolfatal,void*userdata);`
`97`	`97`	`staticvoidbackup_disconnect(boolfatal,void*userdata);`
`98`		`-staticvoidthreads_conn_disconnect(boolfatal,void*userdata);`
	`98`	`+//static void threads_conn_disconnect(bool fatal, void *userdata);`
`99`	`99`
`100`	`100`	`staticvoidpgdata_basic_setup(void);`
`101`	`101`
`@@ -2535,21 +2535,20 @@ backup_disconnect(bool fatal, void *userdata)`
`2535`	`2535`	`/*`
`2536`	`2536`	`* Disconnect checkdb connections created in threads during quit pg_probackup.`
`2537`	`2537`	`*/`
`2538`		`-staticvoid`
`2539`		`-threads_conn_disconnect(boolfatal,void*userdata)`
`2540`		`-{`
`2541`		`-inti;`
`2542`		`-`
`2543`		`-backup_files_argarguments= (backup_files_arg)userdata;`
`2544`		`-`
`2545`		`-elog(VERBOSE,"threads_conn_disconnect, num_threads %d",arguments->thread_num);`
`2546`		`-`
`2547`		`-if (arguments->backup_conn)`
`2548`		`-{`
`2549`		`-pgut_cancel(arguments->backup_conn);`
`2550`		`-pgut_disconnect(arguments->backup_conn);`
`2551`		`-}`
`2552`		`-}`
	`2538`	`+//static void`
	`2539`	`+//threads_conn_disconnect(bool fatal, void *userdata)`
	`2540`	`+//{`
	`2541`	`+//`
	`2542`	`+//backup_files_arg arguments = (backup_files_arg ) userdata;`
	`2543`	`+//`
	`2544`	`+//elog(VERBOSE, "threads_conn_disconnect, num_threads %d", arguments->thread_num);`
	`2545`	`+//`
	`2546`	`+//if (arguments->backup_conn)`
	`2547`	`+//{`
	`2548`	`+//pgut_cancel(arguments->backup_conn);`
	`2549`	`+//pgut_disconnect(arguments->backup_conn);`
	`2550`	`+//}`
	`2551`	`+//}`
`2553`	`2552`
`2554`	`2553`	`staticvoid*`
`2555`	`2554`	`check_files(void*arg)`

`‎src/utils/pgut.c`

Lines changed: 0 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -365,13 +365,6 @@ pgut_execute_parallel(PGconn* conn,`
`365`	`365`	`booltext_result,boolok_error,boolasync)`
`366`	`366`	`{`
`367`	`367`	`PGresult*res;`
`368`		`-intret=0;`
`369`		`-PGconn*connections[1];`
`370`		`-`
`371`		`-structtimevaltimeout;`
`372`		`-`
`373`		`-timeout.tv_sec=100;`
`374`		`-timeout.tv_usec=200;`
`375`	`368`
`376`	`369`	`if (interrupted&& !in_cleanup)`
`377`	`370`	`elog(ERROR,"interrupted");`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

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

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit2022487

File tree

2 files changed

2 files changed

`‎src/backup.c`

`‎src/utils/pgut.c`

0 commit comments