Commitdf085fc

committed

Force active snapshot obtaining during insert.Fixes#18

1 parent10b1f04 commitdf085fcCopy full SHA for df085fc

File tree

-1

lines changed

-1

lines changed

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -672,6 +672,8 @@ process_remote_insert(StringInfo s, Relation rel)`
`672`	`672`	`ScanKey*index_keys;`
`673`	`673`	`inti;`
`674`	`674`
	`675`	`+PushActiveSnapshot(GetTransactionSnapshot());`
	`676`	`+`
`675`	`677`	`estate=create_rel_estate(rel);`
`676`	`678`	`newslot=ExecInitExtraTupleSlot(estate);`
`677`	`679`	`oldslot=ExecInitExtraTupleSlot(estate);`
`@@ -747,6 +749,9 @@ process_remote_insert(StringInfo s, Relation rel)`
`747`	`749`
`748`	`750`	`ExecCloseIndices(estate->es_result_relation_info);`
`749`	`751`
	`752`	`+if (ActiveSnapshotSet())`
	`753`	`+PopActiveSnapshot();`
	`754`	`+`
`750`	`755`	`heap_close(rel,NoLock);`
`751`	`756`	`ExecResetTupleTable(estate->es_tupleTable, true);`
`752`	`757`	`FreeExecutorState(estate);`

Lines changed: 1 addition & 1 deletion

Comments

(0)