@@ -327,7 +327,7 @@ remote_copy_file(PGconn *conn, pgFile* file)
327327 {
328328 write_buffer_size = Min (row_length , sizeof (buf ));
329329 memcpy (buf , copybuf , write_buffer_size );
330- COMP_CRC32C (file -> crc , & buf , write_buffer_size );
330+ COMP_CRC32C (file -> crc , buf , write_buffer_size );
331331
332332 /* TODO calc checksum*/
333333 if (fwrite (buf , 1 , write_buffer_size , out ) != write_buffer_size )
@@ -724,7 +724,7 @@ do_backup_instance(void)
724724 else
725725 pthread_create (& backup_threads [i ], NULL , remote_backup_files , arg );
726726 }
727-
727+
728728 /* Wait threads */
729729 for (i = 0 ; i < num_threads ; i ++ )
730730 {
@@ -844,7 +844,7 @@ do_backup(time_t start_time)
844844 elog (WARNING , "This PostgreSQL instance was initialized without data block checksums. "
845845 "pg_probackup have no way to detect data block corruption without them. "
846846 "Reinitialize PGDATA with option '--data-checksums'." );
847-
847+
848848 StrNCpy (current .server_version , server_version_str ,
849849 sizeof (current .server_version ));
850850 current .stream = stream_wal ;
@@ -1020,7 +1020,7 @@ check_system_identifiers(void)
10201020
10211021 system_id_pgdata = get_system_identifier (pgdata );
10221022 system_id_conn = get_remote_system_identifier (backup_conn );
1023-
1023+
10241024 if (system_id_conn != system_identifier )
10251025 elog (ERROR , "Backup data directory was initialized for system id %ld, but connected instance system id is %ld" ,
10261026 system_identifier , system_id_conn );
@@ -1043,13 +1043,13 @@ confirm_block_size(const char *name, int blcksz)
10431043 res = pgut_execute (backup_conn , "SELECT pg_catalog.current_setting($1)" , 1 , & name );
10441044 if (PQntuples (res ) != 1 || PQnfields (res ) != 1 )
10451045 elog (ERROR , "cannot get %s: %s" , name , PQerrorMessage (backup_conn ));
1046-
1046+
10471047 block_size = strtol (PQgetvalue (res , 0 , 0 ), & endp , 10 );
10481048 if ((endp && * endp ) || block_size != blcksz )
10491049 elog (ERROR ,
10501050 "%s(%d) is not compatible(%d expected)" ,
10511051 name , block_size , blcksz );
1052-
1052+
10531053 PQclear (res );
10541054}
10551055
@@ -2024,7 +2024,7 @@ backup_files(void *arg)
20242024
20252025 pgFile * file = (pgFile * ) parray_get (arguments -> backup_files_list , i );
20262026 elog (VERBOSE , "Copying file: \"%s\" " , file -> path );
2027- if (!pg_atomic_test_set_flag (& file -> lock ))
2027+ if (!pg_atomic_test_set_flag (& file -> lock ))
20282028 continue ;
20292029
20302030 /* check for interrupt */
0 commit comments