| /third_party/grpc/test/cpp/qps/ |
| D | json_run_localhost_scenarios.bzl | 3 …resp_size": 50, "req_size": 300}}, "client_channels": 300, "threads_per_cq": 0, "client_processes"…
|
| D | qps_json_driver_scenarios.bzl | 3 …resp_size": 0, "req_size": 0}}, "client_channels": 64, "threads_per_cq": 3, "client_processes": 0}…
|
| D | server_async.cc | 563 int resp_size = payload_config.bytebuf_params().resp_size(); in ProcessGenericRPC() local
564 std::unique_ptr<char[]> buf(new char[resp_size]); in ProcessGenericRPC()
565 memset(buf.get(), 0, static_cast<size_t>(resp_size)); in ProcessGenericRPC()
566 Slice slice(buf.get(), resp_size); in ProcessGenericRPC()
|
| D | client.h | 74 req->set_response_size(payload_config.simple_params().resp_size()); in ClientRequestCreator()
|
| /third_party/grpc/tools/run_tests/performance/ |
| D | scenario_config.py | 72 def _payload_type(use_generic_payload, req_size, resp_size): argument
76 'resp_size': resp_size,
117 resp_size=0, argument
170 use_generic_payload, req_size, resp_size)
173 use_generic_payload, req_size, resp_size)
184 if outstanding_calls * max(req_size, resp_size) > MAX_MEMORY_USE:
186 MAX_MEMORY_USE / max(req_size, resp_size))
251 resp_size=1024 * 1024,
265 resp_size=1024 * 1024,
279 resp_size=50,
[all …]
|
| /third_party/grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | SimpleProtoParams.php | 23 protected $resp_size = 0; variable in Grpc\\Testing\\SimpleProtoParams
68 return $this->resp_size;
79 $this->resp_size = $var;
|
| D | ByteBufferParams.php | 23 protected $resp_size = 0; variable in Grpc\\Testing\\ByteBufferParams
68 return $this->resp_size;
79 $this->resp_size = $var;
|
| /third_party/grpc/src/python/grpcio_tests/tests/qps/ |
| D | benchmark_server.py | 36 def __init__(self, resp_size): argument
37 self._response = b'\0' * resp_size
|
| D | worker_server.py | 79 resp_size = config.payload_config.bytebuf_params.resp_size
80 servicer = benchmark_server.GenericBenchmarkServer(resp_size)
|
| D | benchmark_client.py | 70 response_size=config.payload_config.simple_params.resp_size)
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/benchmark/ |
| D | benchmark_servicer.py | 47 def __init__(self, resp_size): argument
48 self._response = '\0' * resp_size
|
| D | worker_servicer.py | 82 resp_size = config.payload_config.bytebuf_params.resp_size
83 servicer = benchmark_servicer.GenericBenchmarkServicer(resp_size)
|
| D | benchmark_client.py | 80 response_size=config.payload_config.simple_params.resp_size)
|
| /third_party/grpc/src/ruby/pb/test/ |
| D | server.rb | 154 resp_size = params.size
155 GRPC.logger.info("read a req, response size is #{resp_size}")
157 body: nulls(resp_size)))
|
| D | client.rb | 197 req_size, resp_size = m
200 response_parameters: [p_cls.new(size: resp_size)])
205 resp_size == resp.payload.body.length
|
| /third_party/grpc/src/proto/grpc/testing/ |
| D | payloads.proto | 21 int32 resp_size = 2; field
26 int32 resp_size = 2; field
|
| /third_party/mesa3d/src/asahi/lib/ |
| D | agx_device.c | 355 size_t resp_size = sizeof(resp); in agx_create_notification_queue() local
356 assert(resp_size == 0x10); in agx_create_notification_queue()
360 NULL, 0, &resp, &resp_size); in agx_create_notification_queue()
362 assert(resp_size == sizeof(resp)); in agx_create_notification_queue()
|
| /third_party/mesa3d/src/gallium/winsys/virgl/vtest/ |
| D | virgl_vtest_socket.c | 247 uint32_t resp_size = resp_buf[0] - 1; in virgl_vtest_send_get_caps() local
249 if (resp_size > caps_size) { in virgl_vtest_send_get_caps()
250 dummy_size = resp_size - caps_size; in virgl_vtest_send_get_caps()
251 resp_size = caps_size; in virgl_vtest_send_get_caps()
254 ret = virgl_block_read(vws->sock_fd, &caps->caps, resp_size); in virgl_vtest_send_get_caps()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/common/ |
| D | wpa_helpers.h | 15 char *resp, size_t resp_size);
|
| D | wpa_helpers.c | 62 char *resp, size_t resp_size) in wpa_command_resp() argument
71 len = resp_size; in wpa_command_resp()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/common/ |
| D | wpa_helpers.h | 15 char *resp, size_t resp_size);
|
| D | wpa_helpers.c | 62 char *resp, size_t resp_size) in wpa_command_resp() argument
71 len = resp_size; in wpa_command_resp()
|
| /third_party/grpc/src/ruby/qps/ |
| D | client.rb | 73 response_size: simple_params.resp_size,
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_trickle.cc | 83 size_t resp_size, size_t kilobits_per_second, in TrickledCHTTP2() argument
91 << "." << resp_size << "." << kilobits_per_second << ".csv"; in TrickledCHTTP2()
|