Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit618cd44

Browse files
author
Ekaterina Sokolova
committed
[6693] Refactoring source code of pg_query_state.
Tags: pg_query_state.
1 parentbf7eef4 commit618cd44

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
ExplainFormatformat);
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-
inti;
438+
inti;
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
inti;
865865
shm_mq_handle*mqh;
866866
LOCKTAGtag;
867-
shm_mq_resultresult;
867+
shm_mq_resultresult;
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
returnNIL;
970970
}
@@ -982,12 +982,12 @@ static shm_mq_result
982982
receive_msg_by_parts(shm_mq_handle*mqh,Size*total,void**datap,
983983
int64timeout,int*rc,boolnowait)
984984
{
985-
shm_mq_resultmq_receive_result;
986-
shm_mq_msg*buff;
987-
intoffset;
988-
Size*expected;
989-
Sizeexpected_data;
990-
Sizelen;
985+
shm_mq_resultmq_receive_result;
986+
shm_mq_msg*buff;
987+
intoffset;
988+
Size*expected;
989+
Sizeexpected_data;
990+
Sizelen;
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
gotomq_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
#ifPG_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
returnNIL;
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_timestart_time;
229-
instr_timecur_time;
230-
int64delay=MAX_SND_TIMEOUT;
231-
intreqid=params->reqid;
232-
LOCKTAGtag;
227+
shm_mq_handle*mqh;
228+
instr_timestart_time;
229+
instr_timecur_time;
230+
int64delay=MAX_SND_TIMEOUT;
231+
intreqid=params->reqid;
232+
LOCKTAGtag;
233233

234234
INSTR_TIME_SET_CURRENT(start_time);
235235

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp