Remove the socket reader in shutdown

5 years ago · 65930d4be9
parent c82f28d428
commit 65930d4be9
1 changed files with 1 additions and 0 deletions
--- a/src/python/grpcio/grpc/_cython/_cygrpc/aio/completion_queue.pyx.pxi
+++ b/src/python/grpcio/grpc/_cython/_cygrpc/aio/completion_queue.pyx.pxi
@ -75,6 +75,7 @@ cdef class PollerCompletionQueue(BaseCompletionQueue):
            self._poll()

    cdef shutdown(self):
+        self._loop.remove_reader(self._read_socket)
        # TODO(https://github.com/grpc/grpc/issues/22365) perform graceful shutdown
        grpc_completion_queue_shutdown(self._cq)
        grpc_completion_queue_destroy(self._cq)