Add usleep for checksum cycle.

stalkerg · stalkerg · commit 9d273330d3fa · 2016-09-08T12:35:28.000+03:00
diff --git a/data.c b/data.c
@@ -194,6 +194,7 @@ backup_data_file(const char *from_root, const char *to_root,
 					if (try_checksum)
 					{
 						elog(WARNING, "File: %s blknum %u have wrong checksum, try again", file->path, blknum);
+						usleep(100);
 						fseek(in, -sizeof(page), SEEK_CUR);
 						fread(&page, 1, sizeof(page), in);
 					}
@@ -281,8 +282,6 @@ backup_data_file(const char *from_root, const char *to_root,
 					int i;
 
 					for(i=0; i<BLCKSZ && page.data[i] == 0; i++);
-
-
 					if (i == BLCKSZ)
 					{
 						elog(WARNING, "File: %s blknum %u, empty page", file->path, blknum);
@@ -306,6 +305,7 @@ backup_data_file(const char *from_root, const char *to_root,
 					if (try_checksum)
 					{
 						elog(WARNING, "File: %s blknum %u have wrong page header, try again", file->path, blknum);
+						usleep(100);
 						fseek(in, -sizeof(page), SEEK_CUR);
 						fread(&page, 1, sizeof(page), in);
 						continue;

Original file line number	Diff line number	Diff line change
`@@ -194,6 +194,7 @@ backup_data_file(const char from_root, const char to_root,`
`194`	`194`	`if (try_checksum)`
`195`	`195`	`{`
`196`	`196`	`elog(WARNING, "File: %s blknum %u have wrong checksum, try again", file->path, blknum);`
	`197`	`+ usleep(100);`
`197`	`198`	`fseek(in, -sizeof(page), SEEK_CUR);`
`198`	`199`	`fread(&page, 1, sizeof(page), in);`
`199`	`200`	`}`
`@@ -281,8 +282,6 @@ backup_data_file(const char from_root, const char to_root,`
`281`	`282`	`int i;`
`282`	`283`
`283`	`284`	`for(i=0; i<BLCKSZ && page.data[i] == 0; i++);`
`284`		`-`
`285`		`-`
`286`	`285`	`if (i == BLCKSZ)`
`287`	`286`	`{`
`288`	`287`	`elog(WARNING, "File: %s blknum %u, empty page", file->path, blknum);`
`@@ -306,6 +305,7 @@ backup_data_file(const char from_root, const char to_root,`
`306`	`305`	`if (try_checksum)`
`307`	`306`	`{`
`308`	`307`	`elog(WARNING, "File: %s blknum %u have wrong page header, try again", file->path, blknum);`
	`308`	`+ usleep(100);`
`309`	`309`	`fseek(in, -sizeof(page), SEEK_CUR);`
`310`	`310`	`fread(&page, 1, sizeof(page), in);`
`311`	`311`	`continue;`