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

Fix epoll_ctl() error message on connection error

pull/3389/head
Marco Slot 2020-01-11 08:25:50 +01:00
parent 89d5bed88d
commit 82f1fffa28
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2294,8 +2294,8 @@ ManageWorkerPool(WorkerPool *workerPool)
/* create a session for the connection */ /* create a session for the connection */
WorkerSession *session = FindOrCreateWorkerSession(workerPool, connection); WorkerSession *session = FindOrCreateWorkerSession(workerPool, connection);
/* always poll the connection in the first round */ /* immediately run the state machine to handle potential failure */
UpdateConnectionWaitFlags(session, WL_SOCKET_READABLE | WL_SOCKET_WRITEABLE); ConnectionStateMachine(session);
} }
workerPool->lastConnectionOpenTime = GetCurrentTimestamp(); workerPool->lastConnectionOpenTime = GetCurrentTimestamp();