PostgreSQL Source Code git master
Functions | Variables
delay_execution.c File Reference
#include "postgres.h"
#include <limits.h>
#include "optimizer/planner.h"
#include "utils/fmgrprotos.h"
#include "utils/guc.h"
#include "utils/inval.h"
Include dependency graph for delay_execution.c:

Go to the source code of this file.

Functions

static PlannedStmt *  delay_execution_planner (Query *parse, const char *query_string, int cursorOptions, ParamListInfo boundParams, ExplainState *es)
 
void  _PG_init (void)
 

Variables

  PG_MODULE_MAGIC
 
static int  post_planning_lock_id = 0
 
static planner_hook_type  prev_planner_hook = NULL
 

Function Documentation

◆ _PG_init()

void _PG_init ( void  )

Definition at line 76 of file delay_execution.c.

77{
78 /* Set up the GUC to control which lock is used */
79 DefineCustomIntVariable("delay_execution.post_planning_lock_id",
80 "Sets the advisory lock ID to be locked/unlocked after planning.",
81 "Zero disables the delay.",
83 0,
84 0, INT_MAX,
86 0,
87 NULL,
88 NULL,
89 NULL);
90
91 MarkGUCPrefixReserved("delay_execution");
92
93 /* Install our hook */
96}
static planner_hook_type prev_planner_hook
static PlannedStmt * delay_execution_planner(Query *parse, const char *query_string, int cursorOptions, ParamListInfo boundParams, ExplainState *es)
static int post_planning_lock_id
void MarkGUCPrefixReserved(const char *className)
Definition: guc.c:5302
void DefineCustomIntVariable(const char *name, const char *short_desc, const char *long_desc, int *valueAddr, int bootValue, int minValue, int maxValue, GucContext context, int flags, GucIntCheckHook check_hook, GucIntAssignHook assign_hook, GucShowHook show_hook)
Definition: guc.c:5181
@ PGC_USERSET
Definition: guc.h:79
planner_hook_type planner_hook
Definition: planner.c:74

References DefineCustomIntVariable(), delay_execution_planner(), MarkGUCPrefixReserved(), PGC_USERSET, planner_hook, post_planning_lock_id, and prev_planner_hook.

◆ delay_execution_planner()

static PlannedStmt * delay_execution_planner ( Query *  parse,
const char *  query_string,
int  cursorOptions,
ParamListInfo  boundParams,
ExplainState *  es 
)
static

Definition at line 42 of file delay_execution.c.

45{
46 PlannedStmt *result;
47
48 /* Invoke the planner, possibly via a previous hook user */
50 result = prev_planner_hook(parse, query_string, cursorOptions,
51 boundParams, es);
52 else
53 result = standard_planner(parse, query_string, cursorOptions,
54 boundParams, es);
55
56 /* If enabled, delay by taking and releasing the specified lock */
57 if (post_planning_lock_id != 0)
58 {
63
64 /*
65 * Ensure that we notice any pending invalidations, since the advisory
66 * lock functions don't do this.
67 */
69 }
70
71 return result;
72}
int64_t int64
Definition: c.h:535
#define DirectFunctionCall1(func, arg1)
Definition: fmgr.h:682
void AcceptInvalidationMessages(void)
Definition: inval.c:930
Datum pg_advisory_unlock_int8(PG_FUNCTION_ARGS)
Definition: lockfuncs.c:772
Datum pg_advisory_lock_int8(PG_FUNCTION_ARGS)
Definition: lockfuncs.c:626
PlannedStmt * standard_planner(Query *parse, const char *query_string, int cursorOptions, ParamListInfo boundParams, ExplainState *es)
Definition: planner.c:333
static Datum Int64GetDatum(int64 X)
Definition: postgres.h:403
static struct subre * parse(struct vars *v, int stopper, int type, struct state *init, struct state *final)
Definition: regcomp.c:717

References AcceptInvalidationMessages(), DirectFunctionCall1, Int64GetDatum(), parse(), pg_advisory_lock_int8(), pg_advisory_unlock_int8(), post_planning_lock_id, prev_planner_hook, and standard_planner().

Referenced by _PG_init().

Variable Documentation

◆ PG_MODULE_MAGIC

PG_MODULE_MAGIC

Definition at line 31 of file delay_execution.c.

◆ post_planning_lock_id

int post_planning_lock_id = 0
static

Definition at line 34 of file delay_execution.c.

Referenced by _PG_init(), and delay_execution_planner().

◆ prev_planner_hook

planner_hook_type prev_planner_hook = NULL
static

Definition at line 37 of file delay_execution.c.

Referenced by _PG_init(), and delay_execution_planner().

AltStyle によって変換されたページ (->オリジナル) /