|
2 | 2 | * |
3 | 3 | * catchup.c: sync DB cluster |
4 | 4 | * |
5 | | - * Copyright (c) 2021, Postgres Professional |
| 5 | + * Copyright (c) 2021-2022, Postgres Professional |
6 | 6 | * |
7 | 7 | *------------------------------------------------------------------------- |
8 | 8 | */ |
@@ -203,7 +203,7 @@ catchup_preflight_checks(PGNodeInfo *source_node_info, PGconn *source_conn, |
203 | 203 |
|
204 | 204 | /* fill dest_redo.lsn and dest_redo.tli */ |
205 | 205 | get_redo(dest_pgdata,FIO_LOCAL_HOST,&dest_redo); |
206 | | -elog(VERBOSE,"source.tli = %X, dest_redo.lsn = %X/%X, dest_redo.tli = %X", |
| 206 | +elog(LOG,"source.tli = %X, dest_redo.lsn = %X/%X, dest_redo.tli = %X", |
207 | 207 | current.tli, (uint32) (dest_redo.lsn >>32), (uint32)dest_redo.lsn,dest_redo.tli); |
208 | 208 |
|
209 | 209 | if (current.tli!=1) |
@@ -447,12 +447,12 @@ catchup_thread_runner(void *arg) |
447 | 447 |
|
448 | 448 | if (file->write_size==BYTES_INVALID) |
449 | 449 | { |
450 | | -elog(VERBOSE,"Skipping the unchanged file: \"%s\", read %li bytes",from_fullpath,file->read_size); |
| 450 | +elog(LOG,"Skipping the unchanged file: \"%s\", read %li bytes",from_fullpath,file->read_size); |
451 | 451 | continue; |
452 | 452 | } |
453 | 453 |
|
454 | 454 | arguments->transfered_bytes+=file->write_size; |
455 | | -elog(VERBOSE,"File \"%s\". Copied "INT64_FORMAT" bytes", |
| 455 | +elog(LOG,"File \"%s\". Copied "INT64_FORMAT" bytes", |
456 | 456 | from_fullpath,file->write_size); |
457 | 457 | } |
458 | 458 |
|
@@ -603,7 +603,7 @@ filter_filelist(parray *filelist, const char *pgdata, |
603 | 603 | &&parray_bsearch(exclude_relative_paths_list,file->rel_path,pgPrefixCompareString)!=NULL) |
604 | 604 | ) |
605 | 605 | { |
606 | | -elog(LOG,"%s file \"%s\" excluded with --exclude-path option",logging_string,full_path); |
| 606 | +elog(INFO,"%s file \"%s\" excluded with --exclude-path option",logging_string,full_path); |
607 | 607 | file->excluded= true; |
608 | 608 | } |
609 | 609 | } |
@@ -646,7 +646,7 @@ do_catchup(const char *source_pgdata, const char *dest_pgdata, int num_threads, |
646 | 646 | if (exclude_relative_paths_list!=NULL) |
647 | 647 | parray_qsort(exclude_relative_paths_list,pgCompareString); |
648 | 648 |
|
649 | | -elog(LOG,"Database catchup start"); |
| 649 | +elog(INFO,"Database catchup start"); |
650 | 650 |
|
651 | 651 | if (current.backup_mode!=BACKUP_MODE_FULL) |
652 | 652 | { |
@@ -693,7 +693,7 @@ do_catchup(const char *source_pgdata, const char *dest_pgdata, int num_threads, |
693 | 693 |
|
694 | 694 | /* Call pg_start_backup function in PostgreSQL connect */ |
695 | 695 | pg_start_backup(label,smooth_checkpoint,¤t,&source_node_info,source_conn); |
696 | | -elog(LOG,"pg_start_backup START LSN %X/%X", (uint32) (current.start_lsn >>32), (uint32) (current.start_lsn)); |
| 696 | +elog(INFO,"pg_start_backup START LSN %X/%X", (uint32) (current.start_lsn >>32), (uint32) (current.start_lsn)); |
697 | 697 | } |
698 | 698 |
|
699 | 699 | /* Sanity: source cluster must be "in future" relatively to dest cluster */ |
@@ -763,11 +763,11 @@ do_catchup(const char *source_pgdata, const char *dest_pgdata, int num_threads, |
763 | 763 | elog(INFO,"Source PGDATA size: %s (excluded %s)",pretty_source_bytes,pretty_bytes); |
764 | 764 | } |
765 | 765 |
|
766 | | -elog(LOG,"Start LSN (source): %X/%X, TLI: %X", |
| 766 | +elog(INFO,"Start LSN (source): %X/%X, TLI: %X", |
767 | 767 | (uint32) (current.start_lsn >>32), (uint32) (current.start_lsn), |
768 | 768 | current.tli); |
769 | 769 | if (current.backup_mode!=BACKUP_MODE_FULL) |
770 | | -elog(LOG,"LSN in destination: %X/%X, TLI: %X", |
| 770 | +elog(INFO,"LSN in destination: %X/%X, TLI: %X", |
771 | 771 | (uint32) (dest_redo.lsn >>32), (uint32) (dest_redo.lsn), |
772 | 772 | dest_redo.tli); |
773 | 773 |
|
@@ -821,7 +821,7 @@ do_catchup(const char *source_pgdata, const char *dest_pgdata, int num_threads, |
821 | 821 |
|
822 | 822 | join_path_components(dirpath,dest_pgdata,file->rel_path); |
823 | 823 |
|
824 | | -elog(VERBOSE,"Create directory '%s'",dirpath); |
| 824 | +elog(LOG,"Create directory '%s'",dirpath); |
825 | 825 | fio_mkdir(dirpath,DIR_PERMISSION,FIO_LOCAL_HOST); |
826 | 826 | } |
827 | 827 | else |
@@ -850,7 +850,7 @@ do_catchup(const char *source_pgdata, const char *dest_pgdata, int num_threads, |
850 | 850 |
|
851 | 851 | join_path_components(to_path,dest_pgdata,file->rel_path); |
852 | 852 |
|
853 | | -elog(VERBOSE,"Create directory \"%s\" and symbolic link \"%s\"", |
| 853 | +elog(INFO,"Create directory \"%s\" and symbolic link \"%s\"", |
854 | 854 | linked_path,to_path); |
855 | 855 |
|
856 | 856 | /* create tablespace directory */ |
@@ -931,7 +931,7 @@ do_catchup(const char *source_pgdata, const char *dest_pgdata, int num_threads, |
931 | 931 |
|
932 | 932 | join_path_components(fullpath,dest_pgdata,file->rel_path); |
933 | 933 | fio_delete(file->mode,fullpath,FIO_LOCAL_HOST); |
934 | | -elog(VERBOSE,"Deleted file \"%s\"",fullpath); |
| 934 | +elog(LOG,"Deleted file \"%s\"",fullpath); |
935 | 935 |
|
936 | 936 | /* shrink dest pgdata list */ |
937 | 937 | pgFileFree(file); |
|