For the purpose to achieve a slightly deterministic result from`pg_query_state` function under regression tests this module introduces specificfucntions fortracingquery running on external backend process. In this case query is suspended after any node has worked off one step in pipeline structure of plan tree execution. Thus we can execute query specific number of steps and get its state which will be deterministic at least on number ofemmited rows of each node.

For the purpose to achieve a slightly deterministic result from`pg_query_state` function under regression tests this module introduces specificfunctions for querytracingrunning on external backend process. In this case query is suspended after any node has worked off one step in pipeline structure of plan tree execution. Thus we can execute query specific number of steps and get its state which will be deterministic at least on number ofemitted rows of each node.

Function`executor_step` which takes`pid` of traceable backend provides facility to perform single step of query execution. Function`executor_continue` which also takes`pid` completes query without trace interrupts.

if (!pg_qs_enable)

{

shm_mq_msgmsg= {

.length=BASE_SIZEOF_SHM_MQ_MSG,

.result_code=STAT_DISABLED

};

shm_mq_msgmsg= {BASE_SIZEOF_SHM_MQ_MSG,STAT_DISABLED };

shm_mq_send(mqh,msg.length,&msg, false);

}

elseif (!(caller->superuser|| (GetUserId()==caller->user_id)))

{

shm_mq_msgmsg= {

.length=BASE_SIZEOF_SHM_MQ_MSG,

.result_code=PERM_DENIED

};

shm_mq_msgmsg= {BASE_SIZEOF_SHM_MQ_MSG,PERM_DENIED };

shm_mq_send(mqh,msg.length,&msg, false);

}

elseif (list_length(QueryDescStack)==0)

{

shm_mq_msgmsg= {

.length=BASE_SIZEOF_SHM_MQ_MSG,

.result_code=QUERY_NOT_RUNNING

};

shm_mq_msgmsg= {BASE_SIZEOF_SHM_MQ_MSG,QUERY_NOT_RUNNING };

shm_mq_send(mqh,msg.length,&msg, false);

}