Commit64985a1

committed

Minor fixes in pglogical receiver spill buffer

1 parent533c657 commit64985a1Copy full SHA for 64985a1

File tree

-4

lines changed

-4

lines changed

Lines changed: 2 additions & 2 deletions

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@`
`70`	`70`
`71`	`71`	`#defineMULTIMASTER_DEFAULT_ARBITER_PORT 5433`
`72`	`72`
`73`		`-#defineMB (1024*1024L)`
	`73`	`+#defineMB ((size_t)1024*1024)`
`74`	`74`
`75`	`75`	`#defineUSEC_TO_MSEC(t) ((t)/1000)`
`76`	`76`	`#defineMSEC_TO_USEC(t) ((timestamp_t)(t)*1000)`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1097,7 +1097,7 @@ void MtmExecutor(void* work, size_t size)`
`1097`	`1097`	`}`
`1098`	`1098`	`case'(':`
`1099`	`1099`	`{`
`1100`		`-int64size=pq_getmsgint(&s,4);`
	`1100`	`+size_tsize=pq_getmsgint(&s,4);`
`1101`	`1101`	`s.data=palloc(size);`
`1102`	`1102`	`save_cursor=s.cursor;`
`1103`	`1103`	`save_len=s.len;`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -583,6 +583,7 @@ pglogical_receiver_main(Datum main_arg)`
`583`	`583`	`}`
`584`	`584`	`}elseif (spill_file >=0) {`
`585`	`585`	`MtmCloseSpillFile(spill_file);`
	`586`	`+resetStringInfo(&spill_info);`
`586`	`587`	`spill_file=-1;`
`587`	`588`	`}`
`588`	`589`	`ByteBufferReset(&buf);`

Comments

(0)