Function processQueryResult

src/fe_utils/parallel_slot.c:40–52

* Process (and delete) a query result. Returns true if there's no problem, * false otherwise. It's up to the handler to decide what constitutes a * problem. */

 * problem.
 */
static bool
processQueryResult(ParallelSlot *slot, PGresult *result)
{
	Assert(slot->handler != NULL);

	/* On failure, the handler should return NULL after freeing the result */
	if (!slot->handler(result, slot->connection, slot->handler_context))
		return false;

	/* Ok, we have to free it ourself */
	PQclear(result);
	return true;
}

/*
 * Consume all the results generated for the given connection until