in callouts/python/extproc/service/callout_server.py [0:0]
def __init__(self, processor, *args, **kwargs):
self._processor = processor
self._server = grpc.server(
futures.ThreadPoolExecutor(max_workers=processor.server_thread_count))
add_ExternalProcessorServicer_to_server(self, self._server)
server_credentials = grpc.ssl_server_credentials(
private_key_certificate_chain_pairs=[(processor.private_key,
processor.cert_chain)])
address_str = _addr_to_str(processor.address)
self._server.add_secure_port(address_str, server_credentials)
self._start_msg = f'GRPC callout server started, listening on {address_str}.'
if processor.plaintext_address:
plaintext_address_str = _addr_to_str(processor.plaintext_address)
self._server.add_insecure_port(plaintext_address_str)
self._start_msg += f' (secure) and {plaintext_address_str} (plaintext)'