src/python/grpcio/grpc/_cython/_cygrpc/aio/grpc_aio.pyx.pxi

   1 # Copyright 2019 gRPC authors.
   2 #
   3 # Licensed under the Apache License, Version 2.0 (the "License");
   4 # you may not use this file except in compliance with the License.
   5 # You may obtain a copy of the License at
   6 #
   7 #     http://www.apache.org/licenses/LICENSE-2.0
   8 #
   9 # Unless required by applicable law or agreed to in writing, software
  10 # distributed under the License is distributed on an "AS IS" BASIS,
  11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 # See the License for the specific language governing permissions and
  13 # limitations under the License.
  14
  15
  16 cdef bint _grpc_aio_initialized = 0
  17
  18
  19 def init_grpc_aio():
  20     global _grpc_aio_initialized
  21
  22     if _grpc_aio_initialized:
  23         return
  24
  25     install_asyncio_iomgr()
  26     grpc_init()
  27
  28     # Timers are triggered by the Asyncio loop. We disable
  29     # the background thread that is being used by the native
  30     # gRPC iomgr.
  31     grpc_timer_manager_set_threading(False)
  32
  33     # gRPC callbaks are executed within the same thread used by the Asyncio
  34     # event loop, as it is being done by the other Asyncio callbacks.
  35     Executor.SetThreadingAll(False)
  36
  37     _grpc_aio_initialized = 1