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

Move slow start increment to generic place

pull/4895/head
Onder Kalaci 2021-04-08 17:15:26 +02:00
parent 54c9bf8342
commit 28b0b4ebd1
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/distributed/executor/adaptive_executor.c
View File

@ -2454,6 +2454,9 @@ ManageWorkerPool(WorkerPool *workerPool)
return; return;
} }
/* increase the open rate every cycle (like TCP slow start) */
workerPool->maxNewConnectionsPerCycle += 1;
OpenNewConnections(workerPool, newConnectionCount, execution->transactionProperties); OpenNewConnections(workerPool, newConnectionCount, execution->transactionProperties);
/* /*
@ -2641,10 +2644,7 @@ CalculateNewConnectionCount(WorkerPool *workerPool)
*/ */
newConnectionCount = Min(newConnectionsForReadyTasks, maxNewConnectionCount); newConnectionCount = Min(newConnectionsForReadyTasks, maxNewConnectionCount);
if (newConnectionCount > 0) if (newConnectionCount > 0)
{ { }
/* increase the open rate every cycle (like TCP slow start) */
workerPool->maxNewConnectionsPerCycle += 1;
}
} }
return newConnectionCount; return newConnectionCount;
} }