!1917 修复发布端订阅自己时阻塞无法取消的问题
Merge pull request !1917 from chenxiaobin/initial_data
This commit is contained in:
@ -1202,6 +1202,8 @@ static PGresult *libpqrcv_PQexec(const char *query)
|
||||
* blocking.
|
||||
*/
|
||||
while (PQisBusy(t_thrd.libwalreceiver_cxt.streamConn)) {
|
||||
CHECK_FOR_INTERRUPTS();
|
||||
|
||||
/*
|
||||
* We don't need to break down the sleep into smaller increments,
|
||||
* and check for interrupts after each nap, since we can just
|
||||
|
||||
Reference in New Issue
Block a user