Home
last modified time | relevance | path

Searched full:qps (Results 1 – 25 of 477) sorted by relevance

12345678910>>...20

/aosp_15_r20/external/grpc-grpc/src/ruby/
H A D.rubocop_todo.yml22 - 'qps/proxy-worker.rb'
37 - 'qps/client.rb'
56 - 'qps/client.rb'
57 - 'qps/histogram.rb'
58 - 'qps/proxy-worker.rb'
59 - 'qps/qps-common.rb'
60 - 'qps/server.rb'
61 - 'qps/worker.rb'
67 - 'qps/qps-common.rb'
86 - 'qps/src/proto/grpc/testing/benchmark_service_services_pb.rb'
[all …]
/aosp_15_r20/external/grpc-grpc/test/core/client_channel/lb_policy/
H A Dweighted_round_robin_test.cc168 double qps, double eps, in MakeBackendMetricData() argument
173 b.qps = qps; in MakeBackendMetricData()
206 backend_metric_data->qps = it->second.qps; in ReportBackendMetrics()
228 backend_metric_data.qps = p.second.qps; in ReportOobBackendMetrics()
343 /*qps=*/100.0, /*eps=*/0.0)}, in TEST_F()
345 /*qps=*/100.0, /*eps=*/0.0)}}, in TEST_F()
352 /*qps=*/100.0, /*eps=*/0.0)}, in TEST_F()
354 /*qps=*/100.0, /*eps=*/0.0)}, in TEST_F()
356 /*qps=*/100.0, /*eps=*/0.0)}}, in TEST_F()
371 /*qps=*/100.0, /*eps=*/0.0, in TEST_F()
[all …]
/aosp_15_r20/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
H A DAsyncClient.java17 package io.grpc.benchmarks.qps;
22 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.ADDRESS;
23 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.CHANNELS;
24 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.CLIENT_PAYLOAD;
25 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.DIRECTEXECUTOR;
26 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.DURATION;
27 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.FLOW_CONTROL_WINDOW;
28 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.OUTSTANDING_RPCS;
29 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.SAVE_HISTOGRAM;
30 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.SERVER_PAYLOAD;
[all …]
H A DOpenLoopClient.java17 package io.grpc.benchmarks.qps;
23 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.ADDRESS;
24 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.CLIENT_PAYLOAD;
25 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.DURATION;
26 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.FLOW_CONTROL_WINDOW;
27 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.SAVE_HISTOGRAM;
28 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.SERVER_PAYLOAD;
29 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.TARGET_QPS;
30 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.TESTCA;
31 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.TLS;
[all …]
/aosp_15_r20/external/grpc-grpc/doc/
H A Dxds-test-descriptions.md32 The base behavior of the xDS test client is to send a constant QPS of unary
50 * --qps=QPS
51 * The QPS per channel.
193 1. --qps=100
212 1. --qps=100
232 1. --qps=100
264 1. --qps=100
300 1. --qps=100
327 1. --qps=100
351 1. --qps=100
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/server/
Dbackend_metric_recorder.cc45 // Rate values (qps and eps) must be in [0, infy).
117 gpr_log(GPR_INFO, "[%p] QPS rejected: %f", this, value); in SetQps()
122 [value](BackendMetricData* data) { data->qps = value; }); in SetQps()
124 gpr_log(GPR_INFO, "[%p] QPS set: %f", this, value); in SetQps()
200 UpdateBackendMetricDataState([](BackendMetricData* data) { data->qps = -1; }); in ClearQps()
202 gpr_log(GPR_INFO, "[%p] QPS utilization cleared.", this); in ClearQps()
239 " cpu:%f mem:%f app:%f qps:%f eps:%f utilization size: %" PRIuPTR, in GetMetricsIfChanged()
241 data.mem_utilization, data.application_utilization, data.qps, in GetMetricsIfChanged()
299 gpr_log(GPR_INFO, "[%p] QPS value rejected: %f", this, value); in RecordQpsMetric()
305 gpr_log(GPR_INFO, "[%p] QPS recorded: %f", this, value); in RecordQpsMetric()
[all …]
/aosp_15_r20/external/grpc-grpc/src/cpp/server/
H A Dbackend_metric_recorder.cc45 // Rate values (qps and eps) must be in [0, infy).
117 gpr_log(GPR_INFO, "[%p] QPS rejected: %f", this, value); in SetQps()
122 [value](BackendMetricData* data) { data->qps = value; }); in SetQps()
124 gpr_log(GPR_INFO, "[%p] QPS set: %f", this, value); in SetQps()
200 UpdateBackendMetricDataState([](BackendMetricData* data) { data->qps = -1; }); in ClearQps()
202 gpr_log(GPR_INFO, "[%p] QPS utilization cleared.", this); in ClearQps()
239 " cpu:%f mem:%f app:%f qps:%f eps:%f utilization size: %" PRIuPTR, in GetMetricsIfChanged()
241 data.mem_utilization, data.application_utilization, data.qps, in GetMetricsIfChanged()
299 gpr_log(GPR_INFO, "[%p] QPS value rejected: %f", this, value); in RecordQpsMetric()
305 gpr_log(GPR_INFO, "[%p] QPS recorded: %f", this, value); in RecordQpsMetric()
[all …]
/aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests_py3_only/interop/
H A Dxds_interop_client.py363 qps: int,
374 self.qps = qps
397 if config.qps == 0:
403 duration_per_query = 1.0 / float(config.qps)
433 self, per_method_configs: Mapping[str, _ChannelConfiguration], qps: int
437 self._qps = qps
450 qps = self._qps
463 qps = 0
468 channel_config.qps = qps
509 qps = args.qps
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/run_tests/
Drun_performance_tests.py52 """Encapsulates a qps worker server job."""
121 """Runs one scenario using QPS driver."""
145 """Runs quit using QPS driver."""
302 """Creates QPS workers (but does not start them)."""
447 print('QPS worker "%s" is still running.' % job.host_and_port)
449 print('Killing all QPS workers.')
455 print('All QPS workers finished.')
483 'Collecting perf reports from qps workers',
489 'Collecting perf reports from qps workers',
507 'Run QPS driver on given host. By default, QPS driver is run locally.')
[all …]
/aosp_15_r20/external/grpc-grpc/tools/run_tests/
H A Drun_performance_tests.py47 """Encapsulates a qps worker server job."""
118 """Runs one scenario using QPS driver."""
151 """Runs quit using QPS driver."""
326 """Creates QPS workers (but does not start them)."""
512 print('QPS worker "%s" is still running.' % job.host_and_port)
514 print("Killing all QPS workers.")
520 print("All QPS workers finished.")
551 "START", "Collecting perf reports from qps workers", do_newline=True
557 "SUCCESS", "Collecting perf reports from qps workers", do_newline=True
576 "Run QPS driver on given host. By default, QPS driver is run"
[all …]
/aosp_15_r20/external/grpc-grpc/test/cpp/qps/
H A Dqps_json_driver.cc31 #include "test/cpp/qps/benchmark_config.h"
32 #include "test/cpp/qps/driver.h"
33 #include "test/cpp/qps/parse_json.h"
34 #include "test/cpp/qps/report.h"
35 #include "test/cpp/qps/server.h"
63 "Override QPS server target to configure in client configs."
72 "A map of QPS worker addresses to credential types. When creating a "
73 "channel to a QPS worker's driver port, the qps_json_driver first checks "
75 "credential type if so. If the QPS worker's 'name:port' string is not "
160 json_outfile << "{\"qps\": " << result->summary().qps() << "}\n"; in RunAndReport()
H A Dreport.cc19 #include "test/cpp/qps/report.h"
28 #include "test/cpp/qps/driver.h"
29 #include "test/cpp/qps/parse_json.h"
30 #include "test/cpp/qps/stats.h"
82 gpr_log(GPR_INFO, "QPS: %.1f", result.summary().qps()); in ReportQPS()
92 gpr_log(GPR_INFO, "QPS: %.1f (%.1f/server core)", result.summary().qps(), in ReportQPSPerCore()
H A Ddriver.cc19 #include "test/cpp/qps/driver.h"
43 #include "test/cpp/qps/client.h"
44 #include "test/cpp/qps/histogram.h"
45 #include "test/cpp/qps/qps_worker.h"
46 #include "test/cpp/qps/stats.h"
81 "Environment variable \"%s\" does not contain a list of QPS " in get_workers()
144 // Calculate qps and cpu load for each client and then aggregate results for in postprocess_scenario_result()
146 double qps = 0; in postprocess_scenario_result() local
150 qps += client_stat.latencies().count() / client_stat.time_elapsed(); in postprocess_scenario_result()
166 result->mutable_summary()->set_qps(qps); in postprocess_scenario_result()
[all …]
/aosp_15_r20/external/python/google-api-python-client/docs/dyn/
Dadexchangebuyer_v1_3.pretargetingConfig.html164 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
246 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
322 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
407 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
493 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
569 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
652 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
728 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
Dadexchangebuyer_v1_4.pretargetingConfig.html164 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
257 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
344 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
440 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
537 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
624 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
718 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
805 …QPS allocated to this pretargeting configuration, used for pretargeting-level QPS limits. By defau…
/aosp_15_r20/external/grpc-grpc/tools/run_tests/performance/templates/
H A Dloadtest_template_basic_all_languages.yaml60 - //test/cpp/qps:qps_worker
73 bazel-bin/test/cpp/qps/qps_worker --driver_port="${DRIVER_PORT}"
180 - //src/python/grpcio_tests/tests/qps:qps_worker
193 bazel-bin/src/python/grpcio_tests/tests/qps/qps_worker \
235 src/ruby/qps/worker.rb --driver_port="${DRIVER_PORT}"
287 - //test/cpp/qps:qps_worker
300 bazel-bin/test/cpp/qps/qps_worker --driver_port="${DRIVER_PORT}" \
372 - //src/python/grpcio_tests/tests/qps:qps_worker
385 bazel-bin/src/python/grpcio_tests/tests/qps/qps_worker \
427 src/ruby/qps/worker.rb --driver_port="${DRIVER_PORT}"
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/run_tests/performance/templates/
Dloadtest_template_basic_all_languages.yaml60 - //test/cpp/qps:qps_worker
73 bazel-bin/test/cpp/qps/qps_worker --driver_port="${DRIVER_PORT}"
180 - //src/python/grpcio_tests/tests/qps:qps_worker
193 bazel-bin/src/python/grpcio_tests/tests/qps/qps_worker \
235 src/ruby/qps/worker.rb --driver_port="${DRIVER_PORT}"
287 - //test/cpp/qps:qps_worker
300 bazel-bin/test/cpp/qps/qps_worker --driver_port="${DRIVER_PORT}" \
372 - //src/python/grpcio_tests/tests/qps:qps_worker
385 bazel-bin/src/python/grpcio_tests/tests/qps/qps_worker \
427 src/ruby/qps/worker.rb --driver_port="${DRIVER_PORT}"
/aosp_15_r20/external/grpc-grpc/src/ruby/pb/test/
H A Dxds_client.rb23 # --qps=<qps>"
218 # send 1 rpc every 1/qps second
302 :server, :stats_port, :qps)
332 opts.on('--qps QPS', 'qps') do |v|
333 GRPC.logger.info("ruby xds: qps is #{v}")
334 args['qps'] = v
364 target_seconds_between_rpcs = (1.0 / opts['qps'].to_f)
/aosp_15_r20/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
H A DMetricReport.java34 private double qps; field in MetricReport
40 double qps, double eps, Map<String, Double> requestCostMetrics, in MetricReport() argument
45 this.qps = qps; in MetricReport()
72 return qps; in getQps()
87 .add("qps", qps) in toString()
/aosp_15_r20/external/grpc-grpc-java/xds/third_party/envoy/src/main/proto/envoy/extensions/load_balancing_policies/client_side_weighted_round_robin/v3/
H A Dclient_side_weighted_round_robin.proto25 // qps (queries per second), eps (errors per second), and CPU utilization
27 // protocol. A query counts towards qps when successful, otherwise towards both
28 // qps and eps. What counts as an error is up to the endpoint to define.
30 // endpoint weights using eps and qps. The weight of a given endpoint is
31 // computed as: qps / (cpu_utilization + eps/qps * error_utilization_penalty)
65 // calculated as eps/qps. Default is 1.0.
/aosp_15_r20/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
H A DScenarioResultSummary.php24 * Generated from protobuf field <code>double qps = 1;</code>
26 protected $qps = 0.0; variable in Grpc\\Testing\\ScenarioResultSummary
28 * QPS per server core.
125 * @type float $qps
130 * QPS per server core.
171 * Generated from protobuf field <code>double qps = 1;</code>
176 return $this->qps;
184 * Generated from protobuf field <code>double qps = 1;</code>
191 $this->qps = $var;
197 * QPS per server core.
[all …]
/aosp_15_r20/external/grpc-grpc/tools/run_tests/sanity/
H A Dcheck_qps_scenario_changes.py21 os.chdir(os.path.join(os.path.dirname(sys.argv[0]), "../../../test/cpp/qps"))
27 qps_json_driver_bzl = "test/cpp/qps/qps_json_driver_scenarios.bzl"
28 json_run_localhost_bzl = "test/cpp/qps/json_run_localhost_scenarios.bzl"
32 "qps benchmark scenarios have been updated, please commit "
33 "test/cpp/qps/qps_json_driver_scenarios.bzl and/or "
34 "test/cpp/qps/json_run_localhost_scenarios.bzl"
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/run_tests/sanity/
Dcheck_qps_scenario_changes.py21 os.chdir(os.path.join(os.path.dirname(sys.argv[0]), '../../../test/cpp/qps'))
27 qps_json_driver_bzl = 'test/cpp/qps/qps_json_driver_scenarios.bzl'
28 json_run_localhost_bzl = 'test/cpp/qps/json_run_localhost_scenarios.bzl'
31 print('qps benchmark scenarios have been updated, please commit '
32 'test/cpp/qps/qps_json_driver_scenarios.bzl and/or '
33 'test/cpp/qps/json_run_localhost_scenarios.bzl')
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/profiling/qps/
Dqps_diff.py16 """ Computes the diff between two qps runs and outputs significant results """
41 argp = argparse.ArgumentParser(description='Perform diff on QPS Driver')
95 return json.loads(f.read())['qps']
127 headers = ['Benchmark', 'qps']
162 text = '[qps] Performance differences noted:\n%s' % diff_output
164 text = '[qps] No significant performance differences'
166 check_on_pr.check_on_pr('QPS', '```\n%s\n```' % text)
/aosp_15_r20/external/grpc-grpc/src/core/load_balancing/weighted_round_robin/
H A Dweighted_round_robin.cc200 void MaybeUpdateWeight(double qps, double eps, double utilization,
311 // endpoint-reported utilization and QPS.
422 double qps, double eps, double utilization, in MaybeUpdateWeight() argument
426 if (qps > 0 && utilization > 0) { in MaybeUpdateWeight()
429 penalty = eps / qps * error_utilization_penalty; in MaybeUpdateWeight()
431 weight = qps / (utilization + penalty); in MaybeUpdateWeight()
436 "[WRR %p] subchannel %s: qps=%f, eps=%f, utilization=%f: " in MaybeUpdateWeight()
438 wrr_.get(), key_.ToString().c_str(), qps, eps, utilization, in MaybeUpdateWeight()
448 "[WRR %p] subchannel %s: qps=%f, eps=%f, utilization=%f " in MaybeUpdateWeight()
451 wrr_.get(), key_.ToString().c_str(), qps, eps, utilization, in MaybeUpdateWeight()
[all …]

12345678910>>...20