As I mentioned, I think add this patch will solve the problem you worried about
LanceLiu <liu.lance...@gmail.com> 于2019年11月25日周一 下午7:23写道: > --- > src/remote/remote_daemon_stream.c | 14 +++++++------- > 1 file changed, 7 insertions(+), 7 deletions(-) > > diff --git a/src/remote/remote_daemon_stream.c > b/src/remote/remote_daemon_stream.c > index de0dca3..d206d12 100644 > --- a/src/remote/remote_daemon_stream.c > +++ b/src/remote/remote_daemon_stream.c > @@ -141,7 +141,7 @@ daemonStreamEvent(virStreamPtr st, int events, void > *opaque) > (events & VIR_STREAM_EVENT_WRITABLE)) { > if (daemonStreamHandleWrite(client, stream) < 0) { > daemonRemoveClientStream(client, stream); > - virNetServerClientClose(client); > + virNetServerClientImmediateClose(client); > goto cleanup; > } > } > @@ -151,7 +151,7 @@ daemonStreamEvent(virStreamPtr st, int events, void > *opaque) > events = events & ~(VIR_STREAM_EVENT_READABLE); > if (daemonStreamHandleRead(client, stream) < 0) { > daemonRemoveClientStream(client, stream); > - virNetServerClientClose(client); > + virNetServerClientImmediateClose(client); > goto cleanup; > } > /* If we detected EOF during read processing, > @@ -176,7 +176,7 @@ daemonStreamEvent(virStreamPtr st, int events, void > *opaque) > if (daemonStreamHandleFinish(client, stream, msg) < 0) { > virNetMessageFree(msg); > daemonRemoveClientStream(client, stream); > - virNetServerClientClose(client); > + virNetServerClientImmediateClose(client); > goto cleanup; > } > break; > @@ -186,7 +186,7 @@ daemonStreamEvent(virStreamPtr st, int events, void > *opaque) > if (daemonStreamHandleAbort(client, stream, msg) < 0) { > virNetMessageFree(msg); > daemonRemoveClientStream(client, stream); > - virNetServerClientClose(client); > + virNetServerClientImmediateClose(client); > goto cleanup; > } > break; > @@ -205,7 +205,7 @@ daemonStreamEvent(virStreamPtr st, int events, void > *opaque) > stream->recvEOF = true; > if (!(msg = virNetMessageNew(false))) { > daemonRemoveClientStream(client, stream); > - virNetServerClientClose(client); > + virNetServerClientImmediateClose(client); > goto cleanup; > } > msg->cb = daemonStreamMessageFinished; > @@ -219,7 +219,7 @@ daemonStreamEvent(virStreamPtr st, int events, void > *opaque) > "", 0) < 0) { > virNetMessageFree(msg); > daemonRemoveClientStream(client, stream); > - virNetServerClientClose(client); > + virNetServerClientImmediateClose(client); > goto cleanup; > } > } > @@ -262,7 +262,7 @@ daemonStreamEvent(virStreamPtr st, int events, void > *opaque) > } > daemonRemoveClientStream(client, stream); > if (ret < 0) > - virNetServerClientClose(client); > + virNetServerClientImmediateClose(client); > goto cleanup; > } > > -- > 1.8.3.1 > >
-- libvir-list mailing list libvir-list@redhat.com https://www.redhat.com/mailman/listinfo/libvir-list