Commit9f8df3f

committed

[Issue#90] minor changes

1 parent9b5f9b8 commit9f8df3fCopy full SHA for 9f8df3f

File tree

-4

lines changed

-4

lines changed

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -144,7 +144,7 @@ push_wal_file(const char from_path, const char to_path, bool is_compress,`
`144`	`144`	`interrno_temp;`
`145`	`145`	`/* partial handling */`
`146`	`146`	`structstatst;`
`147`		`-intpartial_file_timeout=0;`
	`147`	`+intpartial_try_count=0;`
`148`	`148`	`intpartial_file_size=0;`
`149`	`149`	`boolpartial_file_exists= false;`
`150`	`150`
`@@ -219,7 +219,7 @@ push_wal_file(const char from_path, const char to_path, bool is_compress,`
`219`	`219`	`*/`
`220`	`220`	`if (partial_file_exists)`
`221`	`221`	`{`
`222`		`-while (partial_file_timeout<PARTIAL_WAL_TIMER)`
	`222`	`+while (partial_try_count<PARTIAL_WAL_TIMER)`
`223`	`223`	`{`
`224`	`224`
`225`	`225`	`if (fio_stat(to_path_temp,&st, false,FIO_BACKUP_HOST)<0)`
`@@ -228,15 +228,15 @@ push_wal_file(const char from_path, const char to_path, bool is_compress,`
`228`	`228`	`strerror(errno));`
`229`	`229`
`230`	`230`	`/* first round */`
`231`		`-if (!partial_file_timeout)`
	`231`	`+if (!partial_try_count)`
`232`	`232`	`partial_file_size=st.st_size;`
`233`	`233`
`234`	`234`	`/* file size is changing */`
`235`	`235`	`if (st.st_size>partial_file_size)`
`236`	`236`	`elog(ERROR,"Destination temporary WAL file \"%s\" is not stale",to_path_temp);`
`237`	`237`
`238`	`238`	`sleep(1);`
`239`		`-partial_file_timeout++;`
	`239`	`+partial_try_count++;`
`240`	`240`	`}`
`241`	`241`
`242`	`242`	`/* Partial segment is considered stale, so reuse it */`

Comments

(0)