mirror of
https://gitlab.com/libvirt/libvirt.git
synced 2024-12-22 21:55:25 +00:00
Revert "rpc: Discard non-blocking calls only when necessary"
This reverts commit b1e374a7ac
, which was
rather bad since I failed to consider all sides of the issue. The main
things I didn't consider properly are:
- a thread which sends a non-blocking call waits for the thread with
the buck to process the call
- the code doesn't expect non-blocking calls to remain in the queue
unless they were already partially sent
Thus, the reverted patch actually breaks more than what it fixes and
clients (which may even be libvirtd during p2p migrations) will likely
end up in a deadlock.
This commit is contained in:
parent
db19417fc0
commit
63643f67ab
@ -1265,13 +1265,6 @@ static void virNetClientIOEventLoopPassTheBuck(virNetClientPtr client, virNetCli
|
||||
}
|
||||
client->haveTheBuck = false;
|
||||
|
||||
/* Remove non-blocking calls from the dispatch list since there is no
|
||||
* call with a thread in the list which could take care of them.
|
||||
*/
|
||||
virNetClientCallRemovePredicate(&client->waitDispatch,
|
||||
virNetClientIOEventLoopRemoveNonBlocking,
|
||||
thiscall);
|
||||
|
||||
VIR_DEBUG("No thread to pass the buck to");
|
||||
if (client->wantClose) {
|
||||
virNetClientCloseLocked(client);
|
||||
@ -1315,9 +1308,12 @@ static int virNetClientIOEventLoop(virNetClientPtr client,
|
||||
if (virNetSocketHasCachedData(client->sock) || client->wantClose)
|
||||
timeout = 0;
|
||||
|
||||
/* If we are non-blocking, we don't want to sleep in poll()
|
||||
/* If there are any non-blocking calls in the queue,
|
||||
* then we don't want to sleep in poll()
|
||||
*/
|
||||
if (thiscall->nonBlock)
|
||||
if (virNetClientCallMatchPredicate(client->waitDispatch,
|
||||
virNetClientIOEventLoopWantNonBlock,
|
||||
NULL))
|
||||
timeout = 0;
|
||||
|
||||
fds[0].events = fds[0].revents = 0;
|
||||
@ -1422,6 +1418,13 @@ static int virNetClientIOEventLoop(virNetClientPtr client,
|
||||
virNetClientIOEventLoopRemoveDone,
|
||||
thiscall);
|
||||
|
||||
/* Iterate through waiting calls and if any are
|
||||
* non-blocking, remove them from the dispatch list...
|
||||
*/
|
||||
virNetClientCallRemovePredicate(&client->waitDispatch,
|
||||
virNetClientIOEventLoopRemoveNonBlocking,
|
||||
thiscall);
|
||||
|
||||
/* Now see if *we* are done */
|
||||
if (thiscall->mode == VIR_NET_CLIENT_MODE_COMPLETE) {
|
||||
virNetClientCallRemove(&client->waitDispatch, thiscall);
|
||||
|
Loading…
Reference in New Issue
Block a user