Commitd79e373

Maksim Milyutin

committed

Increase waiting timeout under backend polling

1 parent7159978 commitd79e373Copy full SHA for d79e373

File tree

-2

lines changed

-2

lines changed

Lines changed: 6 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -36,6 +36,8 @@ PG_MODULE_MAGIC;`
`36`	`36`	`#definePG_QS_MODULE_KEY0xCA94B108`
`37`	`37`	`#definePG_QUERY_STATE_KEY0`
`38`	`38`
	`39`	`+#defineMIN_TIMEOUT 5000`
	`40`	`+`
`39`	`41`	`#defineTEXT_CSTR_CMP(text,cstr) \`
`40`	`42`	`(memcmp(VARDATA(text), (cstr), VARSIZE(text) - VARHDRSZ))`
`41`	`43`
`@@ -847,7 +849,9 @@ GetRemoteBackendWorkers(PGPROC *proc)`
`847`	`849`	`returnNIL;`
`848`	`850`
`849`	`851`	`mqh=shm_mq_attach(mq,NULL,NULL);`
`850`		`-mq_receive_result=shm_mq_receive_with_timeout(mqh,&msg_len, (void**)&msg,1000);`
	`852`	`+mq_receive_result=shm_mq_receive_with_timeout(mqh,&msg_len,`
	`853`	`+ (void**)&msg,`
	`854`	`+MIN_TIMEOUT);`
`851`	`855`	`if (mq_receive_result!=SHM_MQ_SUCCESS)`
`852`	`856`	`returnNIL;`
`853`	`857`
`@@ -943,7 +947,7 @@ GetRemoteBackendQueryStates(List *procs,`
`943`	`947`	`mq_receive_result=shm_mq_receive_with_timeout(mqh,`
`944`	`948`	`&len,`
`945`	`949`	`(void**)&msg,`
`946`		`-5000);`
	`950`	`+MIN_TIMEOUT);`
`947`	`951`	`if (mq_receive_result!=SHM_MQ_SUCCESS)`
`948`	`952`	`/* counterpart is died, not consider it */`
`949`	`953`	`continue;`

Comments

(0)