diff --git a/contrib/dblink/dblink.c b/contrib/dblink/dblink.c
index 8bf8fc8ea2f..d9e06915e3a 100644
--- a/contrib/dblink/dblink.c
+++ b/contrib/dblink/dblink.c
@@ -952,6 +952,8 @@ materializeResult(FunctionCallInfo fcinfo, PGconn *conn, PGresult *res)
 		{
 			HeapTuple	tuple;
 
+			CHECK_FOR_INTERRUPTS();
+
 			if (!is_sql_cmd)
 			{
 				int			i;
@@ -1894,6 +1896,8 @@ dblink_get_notify(PG_FUNCTION_ARGS)
 		Datum		values[DBLINK_NOTIFY_COLS];
 		bool		nulls[DBLINK_NOTIFY_COLS];
 
+		CHECK_FOR_INTERRUPTS();
+
 		memset(values, 0, sizeof(values));
 		memset(nulls, 0, sizeof(nulls));