tests.stress.unary_stream_benchmark Namespace Reference

Functions
def	_running_server ()
def	main ()
def	profile (message_size, response_count)

Variables
list	_GRPC_CHANNEL_OPTIONS
int	_MESSAGE_SIZE = 4
int	_PORT = 5741
int	_RESPONSE_COUNT = 32 * 1024
string	_SERVER_CODE

Function Documentation

_running_server()

def tests.stress.unary_stream_benchmark._running_server ( )

private

Definition at line 64 of file unary_stream_benchmark.py.

main()

def tests.stress.unary_stream_benchmark.main

(

)

Definition at line 92 of file unary_stream_benchmark.py.

profile()

def tests.stress.unary_stream_benchmark.profile	(		message_size,
			response_count
	)

Definition at line 78 of file unary_stream_benchmark.py.

Variable Documentation

_GRPC_CHANNEL_OPTIONS

list tests.stress.unary_stream_benchmark._GRPC_CHANNEL_OPTIONS

private

Initial value:

=  [
        ('grpc.max_metadata_size', 16 * 1024 * 1024),
        ('grpc.max_receive_message_length', 64 * 1024 * 1024),
        (grpc.experimental.ChannelOptions.SingleThreadedUnaryStream, 1),
    ]

Definition at line 57 of file unary_stream_benchmark.py.

_MESSAGE_SIZE

int tests.stress.unary_stream_benchmark._MESSAGE_SIZE = 4

private

Definition at line 26 of file unary_stream_benchmark.py.

_PORT

int tests.stress.unary_stream_benchmark._PORT = 5741

private

Definition at line 25 of file unary_stream_benchmark.py.

_RESPONSE_COUNT

int tests.stress.unary_stream_benchmark._RESPONSE_COUNT = 32 * 1024

private

Definition at line 27 of file unary_stream_benchmark.py.

_SERVER_CODE

string tests.stress.unary_stream_benchmark._SERVER_CODE

private

Initial value:

=  """
import datetime
import threading
import grpc
from concurrent import futures
from src.python.grpcio_tests.tests.stress import unary_stream_benchmark_pb2
from src.python.grpcio_tests.tests.stress import unary_stream_benchmark_pb2_grpc
 
class Handler(unary_stream_benchmark_pb2_grpc.UnaryStreamBenchmarkServiceServicer):
 
  def Benchmark(self, request, context):
    payload = b'\\x00\\x01' * int(request.message_size / 2)
    for _ in range(request.response_count):
      yield unary_stream_benchmark_pb2.BenchmarkResponse(response=payload)
 
 
server = grpc.server(futures.ThreadPoolExecutor(max_workers=1))
server.add_insecure_port('[::]:%d')
unary_stream_benchmark_pb2_grpc.add_UnaryStreamBenchmarkServiceServicer_to_server(Handler(), server)
server.start()
server.wait_for_termination()
""" % _PORT

Definition at line 29 of file unary_stream_benchmark.py.