@@ -102,7 +102,8 @@ static void test_decoding_xact_callback(XactEvent event, void *arg);
102
102
103
103
static void test_decoding_process_utility (PlannedStmt * pstmt ,
104
104
const char * queryString ,ProcessUtilityContext context ,
105
- ParamListInfo params ,DestReceiver * dest ,char * completionTag );
105
+ ParamListInfo params ,QueryEnvironment * queryEnv ,
106
+ DestReceiver * dest ,char * completionTag );
106
107
107
108
static bool test_decoding_twophase_commit ();
108
109
@@ -188,7 +189,8 @@ test_decoding_executor_finish(QueryDesc *queryDesc)
188
189
static void
189
190
test_decoding_process_utility (PlannedStmt * pstmt ,
190
191
const char * queryString ,ProcessUtilityContext context ,
191
- ParamListInfo params ,DestReceiver * dest ,char * completionTag )
192
+ ParamListInfo params ,QueryEnvironment * queryEnv ,
193
+ DestReceiver * dest ,char * completionTag )
192
194
{
193
195
Node * parsetree = pstmt -> utilityStmt ;
194
196
@@ -267,13 +269,13 @@ test_decoding_process_utility(PlannedStmt *pstmt,
267
269
268
270
if (PreviousProcessUtilityHook != NULL )
269
271
{
270
- PreviousProcessUtilityHook (pstmt ,queryString ,context ,
271
- params , dest ,completionTag );
272
+ PreviousProcessUtilityHook (pstmt ,queryString ,context ,params , queryEnv ,
273
+ dest ,completionTag );
272
274
}
273
275
else
274
276
{
275
- standard_ProcessUtility (pstmt ,queryString ,context ,
276
- params , dest ,completionTag );
277
+ standard_ProcessUtility (pstmt ,queryString ,context ,params , queryEnv ,
278
+ dest ,completionTag );
277
279
}
278
280
}
279
281