external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #642 from citusdata/bugfix/realtime_poll_timeout 

Fix bug related to poll timeout
pull/672/head
Önder Kalacı 2016-07-26 10:21:37 +03:00 committed by GitHub
parent 0c540e741d 56c0b0825f
commit 34d3df5a7b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/executor/multi_client_executor.c
View File

@ -800,14 +800,14 @@ MultiClientRegisterWait(WaitInfo *waitInfo, TaskExecutionStatus executionStatus,
void void
MultiClientWait(WaitInfo *waitInfo) MultiClientWait(WaitInfo *waitInfo)
{ {
long sleepIntervalPerCycle = RemoteTaskCheckInterval * 1000L;
/* /*
* If we had a failure, we always want to sleep for a bit, to prevent * If we had a failure, we always want to sleep for a bit, to prevent
* flooding the other system, probably making the situation worse. * flooding the other system, probably making the situation worse.
*/ */
if (waitInfo->haveFailedWaiter) if (waitInfo->haveFailedWaiter)
{ {
long sleepIntervalPerCycle = RemoteTaskCheckInterval * 1000L;
pg_usleep(sleepIntervalPerCycle); pg_usleep(sleepIntervalPerCycle);
return; return;
} }
@ -828,7 +828,7 @@ MultiClientWait(WaitInfo *waitInfo)
* times as long. * times as long.
*/ */
int rc = poll(waitInfo->pollfds, waitInfo->registeredWaiters, int rc = poll(waitInfo->pollfds, waitInfo->registeredWaiters,
sleepIntervalPerCycle * 10); RemoteTaskCheckInterval * 10);
if (rc < 0) if (rc < 0)
{ {