-

danolivo · danolivo · commit 5076166159e5 · 2019-05-22T07:54:36.000+05:00
diff --git a/contrib/pg_exchange/exchange.c b/contrib/pg_exchange/exchange.c
@@ -1196,8 +1196,8 @@ EXCHANGE_Execute(CustomScanState *node)
 
 		if ((state->activeRemotes == 0) && (!state->hasLocal))
 		{
-//			elog(LOG, "[%s] Exchange returns NULL. Tuples: local=%d, remote=%d",
-//					state->stream, state->ltuples, state->rtuples);
+			elog(LOG, "[%s] Exchange returns NULL. Tuples: local=%d, remote=%d, send=%d",
+					state->stream, state->ltuples, state->rtuples, state->stuples);
 			return NULL;
 		}
 
@@ -1234,6 +1234,7 @@ EXCHANGE_Execute(CustomScanState *node)
 		{
 			state->stuples++;
 			SendTuple(dest, state->stream, slot, false);
+			elog(LOG, "Send tuple: %d", state->stuples);
 		}
 	}
 	return NULL;

Original file line number	Diff line number	Diff line change
`@@ -1196,8 +1196,8 @@ EXCHANGE_Execute(CustomScanState *node)`
`1196`	`1196`
`1197`	`1197`	`if ((state->activeRemotes == 0) && (!state->hasLocal))`
`1198`	`1198`	`{`
`1199`		`-// elog(LOG, "[%s] Exchange returns NULL. Tuples: local=%d, remote=%d",`
`1200`		`-// state->stream, state->ltuples, state->rtuples);`
	`1199`	`+ elog(LOG, "[%s] Exchange returns NULL. Tuples: local=%d, remote=%d, send=%d",`
	`1200`	`+ state->stream, state->ltuples, state->rtuples, state->stuples);`
`1201`	`1201`	`return NULL;`
`1202`	`1202`	`}`
`1203`	`1203`
`@@ -1234,6 +1234,7 @@ EXCHANGE_Execute(CustomScanState *node)`
`1234`	`1234`	`{`
`1235`	`1235`	`state->stuples++;`
`1236`	`1236`	`SendTuple(dest, state->stream, slot, false);`
	`1237`	`+ elog(LOG, "Send tuple: %d", state->stuples);`
`1237`	`1238`	`}`
`1238`	`1239`	`}`
`1239`	`1240`	`return NULL;`