[PBCKP-263] fix for tests.archive.ArchiveTest.test_archive_get_batching_sanity (#532)

kulaginm · funny-falcon · commit 9c20466fa0ea · 2022-10-14T20:40:05.000+03:00
diff --git a/src/archive.c b/src/archive.c
@@ -969,7 +969,7 @@ uint32 run_wal_prefetch(const char *prefetch_dir, const char *archive_dir,
 
 		/* init thread args */
 		threads = (pthread_t *) palloc(sizeof(pthread_t) * num_threads);
-		threads_args = (archive_get_arg *) palloc(sizeof(archive_get_arg) * num_threads);
+		threads_args = (archive_get_arg *) palloc0(sizeof(archive_get_arg) * num_threads);
 
 		for (i = 0; i < num_threads; i++)
 		{
@@ -980,6 +980,7 @@ uint32 run_wal_prefetch(const char *prefetch_dir, const char *archive_dir,
 
 			arg->thread_num = i+1;
 			arg->files = batch_files;
+			arg->n_fetched = 0;
 		}
 
 		/* Run threads */

Original file line number	Diff line number	Diff line change
`@@ -969,7 +969,7 @@ uint32 run_wal_prefetch(const char prefetch_dir, const char archive_dir,`
`969`	`969`
`970`	`970`	`/* init thread args */`
`971`	`971`	`threads = (pthread_t ) palloc(sizeof(pthread_t) num_threads);`
`972`		`- threads_args = (archive_get_arg ) palloc(sizeof(archive_get_arg) num_threads);`
	`972`	`+ threads_args = (archive_get_arg ) palloc0(sizeof(archive_get_arg) num_threads);`
`973`	`973`
`974`	`974`	`for (i = 0; i < num_threads; i++)`
`975`	`975`	`{`
`@@ -980,6 +980,7 @@ uint32 run_wal_prefetch(const char prefetch_dir, const char archive_dir,`
`980`	`980`
`981`	`981`	`arg->thread_num = i+1;`
`982`	`982`	`arg->files = batch_files;`
	`983`	`+ arg->n_fetched = 0;`
`983`	`984`	`}`
`984`	`985`
`985`	`986`	`/* Run threads */`