condition acquire and release with context manager

Was previously unfamiliar with the contex manager wrapper around
threading primitives.
pull/20077/head
Neeraj Kashyap 6 years ago
parent 1ab9225dce
commit 5c173084f8
  1. 5
      src/python/grpcio_testing/grpc_testing/_server/_servicer_context.py

@ -74,9 +74,8 @@ class ServicerContext(grpc.ServicerContext):
_common.fuss_with_metadata(trailing_metadata))
def abort(self, code, details):
self._rpc._condition.acquire()
self._rpc._abort(code, details)
self._rpc._condition.release()
with self._rpc._condition:
self._rpc._abort(code, details)
def abort_with_status(self, status):
raise NotImplementedError()

Loading…
Cancel
Save