8000 [6693] Refactoring source code of pg_query_state. · postgrespro/pg_query_state@618cd44 · GitHub
[go: up one dir, main page]
Skip to content

Commit 618cd44

Browse files
author
Ekaterina Sokolova
committed
[6693] Refactoring source code of pg_query_state.
Tags: pg_query_state.
1 parent bf7eef4 commit 618cd44

File tree

2 files changed

+26
-26
lines changed

2 files changed

+26
-26
lines changed

‎pg_query_state.c

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -101,10 +101,10 @@ static List *GetRemoteBackendQueryStates(PGPROC *leader,
101101
ExplainFormat format);
102102

103103
/* Shared memory variables */
104-
shm_toc *toc = NULL;
104+
shm_toc *toc = NULL;
105105
RemoteUserIdResult *counterpart_userid = NULL;
106-
pg_qs_params *params = NULL;
107-
shm_mq *mq = NULL;
106+
pg_qs_params *params = NULL;
107+
shm_mq *mq = NULL;
108108

109109
/*
110110
* Estimate amount of shared memory needed.
@@ -208,7 +208,7 @@ _PG_init(void)
208208
|| UserIdPollReason == INVALID_PROCSIGNAL)
209209
{
210210
ereport(WARNING, (errcode(ERRCODE_INSUFFICIENT_RESOURCES),
211-
errmsg("pg_query_state isn't loaded: insufficient custom ProcSignal slots")));
211+
errmsg("pg_query_state isn't loaded: insufficient custom ProcSignal slots")));
212212
return;
213213
}
214214

@@ -435,7 +435,7 @@ deserialize_stack(char *src, int stack_depth)
435435
{
436436
List *result = NIL;
437437
char *curr_ptr = src;
438-
int i;
438+
int i;
439439

440440
for (i = 0; i < stack_depth; i++)
441441
{
@@ -599,10 +599,10 @@ pg_query_state(PG_FUNCTION_ARGS)
599599
/* print warnings if exist */
600600
if (msg->warnings & TIMINIG_OFF_WARNING)
601601
ereport(WARNING, (errcode(ERRCODE_WARNING),
602-
errmsg("timing statistics disabled")));
602+
errmsg("timing statistics disabled")));
603603
if (msg->warnings & BUFFERS_OFF_WARNING)
604604
ereport(WARNING, (errcode(ERRCODE_WARNING),
605-
errmsg("buffers statistics disabled")));
605+
errmsg("buffers statistics disabled")));
606606

607607
oldcontext = MemoryContextSwitchTo(funcctx->multi_call_memory_ctx);
608608

@@ -864,7 +864,7 @@ SendBgWorkerPids(void)
864864
int i;
865865
shm_mq_handle *mqh;
866866
LOCKTAG tag;
867-
shm_mq_result result;
867+
shm_mq_result result;
868868

869869
LockShmem(&tag, PG_QS_SND_KEY);
870870

@@ -961,10 +961,10 @@ GetRemoteBackendWorkers(PGPROC *proc)
961961

962962
signal_error:
963963
ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR),
964-
errmsg("invalid send signal")));
964+
errmsg("invalid send signal")));
965965
mq_error:
966966
ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR),
967-
errmsg("error in message queue data transmitting")));
967+
errmsg("error in message queue data transmitting")));
968968

969969
return NIL;
970970
}
@@ -982,12 +982,12 @@ static shm_mq_result
982982
receive_msg_by_parts(shm_mq_handle *mqh, Size *total, void **datap,
983983
int64 timeout, int *rc, bool nowait)
984984
{
985-
shm_mq_result mq_receive_result;
986-
shm_mq_msg *buff;
987-
int offset;
988-
Size *expected;
989-
Size expected_data;
990-
Size len;
985+
shm_mq_result mq_receive_result;
986+
shm_mq_msg *buff;
987+
int offset;
988+
Size *expected;
989+
Size expected_data;
990+
Size len;
991991

992992
/* Get the expected number of bytes in message */
993993
mq_receive_result = shm_mq_receive(mqh, &len, (void **) &expected, nowait);
@@ -1115,7 +1115,7 @@ GetRemoteBackendQueryStates(PGPROC *leader,
11151115
mqh = shm_mq_attach(mq, NULL, NULL);
11161116
elog(DEBUG1, "Wait response from leader %d", leader->pid);
11171117
mq_receive_result = receive_msg_by_parts(mqh, &len, (void **) &msg,
1118-
0, NULL, false);
1118+
0, NULL, false);
11191119
if (mq_receive_result != SHM_MQ_SUCCESS)
11201120
goto mq_error;
11211121
if (msg->reqid != reqid)
@@ -1134,7 +1134,7 @@ GetRemoteBackendQueryStates(PGPROC *leader,
11341134
*/
11351135
foreach(iter, alive_procs)
11361136
{
1137-
PGPROC *proc = (PGPROC *) lfirst(iter);
1137+
PGPROC *proc = (PGPROC *) lfirst(iter);
11381138

11391139
/* prepare message queue to transfer data */
11401140
elog(DEBUG1, "Wait response from worker %d", proc->pid);
@@ -1174,15 +1174,15 @@ GetRemoteBackendQueryStates(PGPROC *leader,
11741174

11751175
signal_error:
11761176
ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR),
1177-
errmsg("invalid send signal")));
1177+
errmsg("invalid send signal")));
11781178
mq_error:
11791179
#if PG_VERSION_NUM < 100000
11801180
shm_mq_detach(mq);
11811181
#else
11821182
shm_mq_detach(mqh);
11831183
#endif
11841184
ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR),
1185-
errmsg("error in message queue data transmitting")));
1185+
errmsg("error in message queue data transmitting")));
11861186

11871187
return NIL;
11881188
}

‎signal_handler.c

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -224,12 +224,12 @@ send_msg_by_parts(shm_mq_handle *mqh, Size nbytes, const void *data)
224224
void
225225
SendQueryState(void)
226226
{
227-
shm_mq_handle *mqh;
228-
instr_time start_time;
229-
instr_time cur_time;
230-
int64 delay = MAX_SND_TIMEOUT;
231-
int reqid = params->reqid;
232-
LOCKTAG tag;
227+
shm_mq_handle *mqh;
228+
instr_time start_time;
229+
instr_time cur_time;
230+
int64 delay = MAX_SND_TIMEOUT;
231+
int reqid = params->reqid;
232+
LOCKTAG tag;
233233

234234
INSTR_TIME_SET_CURRENT(start_time);
235235

0 commit comments

Comments
 (0)
0