-

danolivo · danolivo · commit 72632bde8ff4 · 2019-05-22T08:24:27.000+05:00
diff --git a/contrib/pg_exchange/exchange.c b/contrib/pg_exchange/exchange.c
@@ -1147,7 +1147,7 @@ EXCHANGE_Execute(CustomScanState *node)
 		if ((state->activeRemotes > 0) && readRemote)
 		{
 			int status;
-
+elog(LOG, "Check msgs");
 			slot = RecvTuple(ss->ss_ScanTupleSlot->tts_tupleDescriptor,
 							 state->stream, &status);
 			switch (status)

Original file line number	Diff line number	Diff line change
`@@ -1147,7 +1147,7 @@ EXCHANGE_Execute(CustomScanState *node)`
`1147`	`1147`	`if ((state->activeRemotes > 0) && readRemote)`
`1148`	`1148`	`{`
`1149`	`1149`	`int status;`
`1150`		`-`
	`1150`	`+elog(LOG, "Check msgs");`
`1151`	`1151`	`slot = RecvTuple(ss->ss_ScanTupleSlot->tts_tupleDescriptor,`
`1152`	`1152`	`state->stream, &status);`
`1153`	`1153`	`switch (status)`