Commitf84be93

committed

1 parent72632bd commitf84be93Copy full SHA for f84be93

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1133,7 +1133,7 @@ EXCHANGE_Execute(CustomScanState *node)`
`1133`	`1133`	`ScanState*ss=&node->ss;`
`1134`	`1134`	`ScanState*subPlanState=linitial(node->custom_ps);`
`1135`	`1135`	`ExchangeStatestate= (ExchangeState)node;`
`1136`		`-boolreadRemote=true;`
	`1136`	`+boolreadRemote=false;`
`1137`	`1137`
`1138`	`1138`	`init_state_ifany(state);`
`1139`	`1139`
`@@ -1147,7 +1147,7 @@ EXCHANGE_Execute(CustomScanState *node)`
`1147`	`1147`	`if ((state->activeRemotes>0)&&readRemote)`
`1148`	`1148`	`{`
`1149`	`1149`	`intstatus;`
`1150`		`-elog(LOG,"Check msgs");`
	`1150`	`+`
`1151`	`1151`	`slot=RecvTuple(ss->ss_ScanTupleSlot->tts_tupleDescriptor,`
`1152`	`1152`	`state->stream,&status);`
`1153`	`1153`	`switch (status)`

Comments

(0)