diff --git a/contrib/postgres_fdw/Makefile b/contrib/postgres_fdw/Makefile index b9fa699305..3e1260e125 100644 --- a/contrib/postgres_fdw/Makefile +++ b/contrib/postgres_fdw/Makefile @@ -16,7 +16,7 @@ SHLIB_LINK_INTERNAL = $(libpq) EXTENSION = postgres_fdw DATA = postgres_fdw--1.0.sql postgres_fdw--1.0--1.1.sql -REGRESS = postgres_fdw query_cancel +REGRESS = postgres_fdw query_cancel $(shell printf 'query_cancel %.0s' `seq 31`) ifdef USE_PGXS PG_CONFIG = pg_config diff --git a/contrib/postgres_fdw/postgres_fdw.c b/contrib/postgres_fdw/postgres_fdw.c index fc65d81e21..9190fbb3cb 100644 --- a/contrib/postgres_fdw/postgres_fdw.c +++ b/contrib/postgres_fdw/postgres_fdw.c @@ -1605,7 +1605,10 @@ postgresIterateForeignScan(ForeignScanState *node) * first call after Begin or ReScan. */ if (!fsstate->cursor_exists) +{ create_cursor(node); +pg_usleep(100000); +} /* * Get some more tuples, if we've run out. diff --git a/src/backend/tcop/postgres.c b/src/backend/tcop/postgres.c index a750dc800b..c281547e22 100644 --- a/src/backend/tcop/postgres.c +++ b/src/backend/tcop/postgres.c @@ -4717,6 +4717,10 @@ PostgresMain(const char *dbname, const char *username) idle_session_timeout_enabled = false; } +if (rand() % 10 == 0) +{ +pg_usleep(10000); +} /* * (5) disable async signal conditions again. *