mirror of https://github.com/citusdata/citus.git
remove_socket_check
parent
1e5096e29d
commit
ffd627a6e4
|
@ -5490,8 +5490,8 @@ BuildWaitEventSet(List *sessionList, bool socketClosedOnly)
|
||||||
|
|
||||||
if (!socketClosedOnly)
|
if (!socketClosedOnly)
|
||||||
{
|
{
|
||||||
CitusAddWaitEventSetToSet(waitEventSet, WL_LATCH_SET, PGINVALID_SOCKET, MyLatch,
|
CitusAddWaitEventSetToSet(waitEventSet, WL_LATCH_SET, PGINVALID_SOCKET, MyLatch,
|
||||||
NULL);
|
NULL);
|
||||||
}
|
}
|
||||||
|
|
||||||
return waitEventSet;
|
return waitEventSet;
|
||||||
|
@ -5538,8 +5538,9 @@ AddSessionToWaitEventSet(WorkerSession *session, WaitEventSet *waitEventSet,
|
||||||
sock,
|
sock,
|
||||||
NULL, (void *) session);
|
NULL, (void *) session);
|
||||||
#else
|
#else
|
||||||
/* socketClosedOnly is only true for */
|
|
||||||
Assert (false);
|
/* socketClosedOnly is only true for */
|
||||||
|
Assert(false);
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
|
Loading…
Reference in New Issue