Searched refs:qps (Results 1 – 25 of 49) sorted by relevance
12
17 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 …]
17 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 …]
17 package io.grpc.benchmarks.qps;
38 qps = self._get_qps()39 return [metrics_pb2.GaugeResponse(name=GAUGE_NAME, long_value=qps)]44 qps = self._get_qps()45 return metrics_pb2.GaugeResponse(name=GAUGE_NAME, long_value=qps)
27 from tests.qps import histogram
36 --grpc_out=src/ruby/qps \37 --ruby_out=src/ruby/qps \42 --grpc_out=src/ruby/qps \43 --ruby_out=src/ruby/qps \
26 """Script to run qps benchmark."""29 load("//test/cpp/qps:qps_json_driver_scenarios.bzl", "QPS_JSON_DRIVER_SCENARIOS")30 load("//test/cpp/qps:json_run_localhost_scenarios.bzl", "JSON_RUN_LOCALHOST_SCENARIOS")67 "//test/cpp/qps:qps_json_driver",68 "//test/cpp/qps:qps_worker",
82 gpr_log(GPR_INFO, "QPS: %.1f", result.summary().qps()); in ReportQPS()122 gpr_log(GPR_INFO, "QPS: %.1f (%.1f/server core)", result.summary().qps(), in ReportQPSPerCore()
18 load("//test/cpp/qps:qps_benchmark_script.bzl", "qps_json_driver_batch", "json_run_localhost_batch")20 grpc_package(name = "test/cpp/qps")
121 auto qps = histogram.Count() / time_estimate; in postprocess_scenario_result() local122 auto qps_per_server_core = qps / sum(result->server_cores(), Cores); in postprocess_scenario_result()124 result->mutable_summary()->set_qps(qps); in postprocess_scenario_result()
111 json_outfile << "{\"qps\": " << result->summary().qps() << "}\n"; in RunAndReport()
54 mainClassName = "io.grpc.benchmarks.qps.AsyncClient"64 mainClassName = "io.grpc.benchmarks.qps.OpenLoopClient"74 mainClassName = "io.grpc.benchmarks.qps.AsyncServer"
27 from tests.qps import benchmark_client28 from tests.qps import benchmark_server29 from tests.qps import client_runner30 from tests.qps import histogram
22 from tests.qps import worker_server
257 long qps = GetQpsAndReset(); in GetGauge()262 LongValue = qps in GetGauge()270 long qps = GetQpsAndReset(); in GetAllGauges()275 LongValue = qps in GetAllGauges()
24 private $qps = 0.0; variable in Grpc\\Testing\\ScenarioResultSummary127 return $this->qps;140 $this->qps = $var;
52 $qps = round($count / ($current_time - $start_time));53 socket_write($client_connection, "qps: $qps");
21 ruby src/ruby/qps/worker.rb "$@"
22 ruby src/ruby/qps/proxy-worker.rb "$@"
20 …o_tests:src/python/gens py27_native/bin/python src/python/grpcio_tests/tests/qps/qps_worker.py "$@"
23 cd src/php/tests/qps
399 for (double qps : qpsToTest) { in testTimeToWarmUpIsHonouredEvenWithWeights()403 long warmupMillis = (long) ((2 * maxPermits / qps) * 1000.0); in testTimeToWarmUpIsHonouredEvenWithWeights()405 stopwatch, qps, warmupMillis, MILLISECONDS); in testTimeToWarmUpIsHonouredEvenWithWeights()
9 declare <8 x float> @llvm.x86.avx512.gather.qps.512 (<8 x float>, i8*, <8 x i64>, i8, i32)10 declare void @llvm.x86.avx512.scatter.qps.512 (i8*, i8, <8 x i64>, <8 x float>, i32)56 …%x = call <8 x float> @llvm.x86.avx512.gather.qps.512 (<8 x float> %src, i8* %base, <8 x i64>%ind,…58 …call void @llvm.x86.avx512.scatter.qps.512 (i8* %stbuf, i8 %mask, <8 x i64>%ind2, <8 x float> %x, …198 …%res = call <8 x float> @llvm.x86.avx512.gather.qps.512 (<8 x float> %src, i8* %base, <8 x i64>%in…250 …call void @llvm.x86.avx512.scatter.qps.512 (i8* %stbuf, i8 %mask, <8 x i64>%ind, <8 x float> %x, i…265 …%x = call <8 x float> @llvm.x86.avx512.gather.qps.512 (<8 x float> %src, i8* %base, <8 x i64>%ind,…267 …call void @llvm.x86.avx512.scatter.qps.512 (i8* %stbuf, i8 -1, <8 x i64>%ind2, <8 x float> %x, i32…271 declare void @llvm.x86.avx512.gatherpf.qps.512(i8, <8 x i64>, i8* , i32, i32);272 declare void @llvm.x86.avx512.scatterpf.qps.512(i8, <8 x i64>, i8* , i32, i32);[all …]
9 declare <8 x float> @llvm.x86.avx512.gather.qps.512 (<8 x float>, i8*, <8 x i64>, i8, i32)10 declare void @llvm.x86.avx512.scatter.qps.512 (i8*, i8, <8 x i64>, <8 x float>, i32)53 …%x = call <8 x float> @llvm.x86.avx512.gather.qps.512 (<8 x float> %src, i8* %base, <8 x i64>%ind,…55 …call void @llvm.x86.avx512.scatter.qps.512 (i8* %stbuf, i8 %mask, <8 x i64>%ind2, <8 x float> %x, …188 …%res = call <8 x float> @llvm.x86.avx512.gather.qps.512 (<8 x float> %src, i8* %base, <8 x i64>%in…236 …call void @llvm.x86.avx512.scatter.qps.512 (i8* %stbuf, i8 %mask, <8 x i64>%ind, <8 x float> %x, i…249 …%x = call <8 x float> @llvm.x86.avx512.gather.qps.512 (<8 x float> %src, i8* %base, <8 x i64>%ind,…251 …call void @llvm.x86.avx512.scatter.qps.512 (i8* %stbuf, i8 -1, <8 x i64>%ind2, <8 x float> %x, i32…255 declare void @llvm.x86.avx512.gatherpf.qps.512(i8, <8 x i64>, i8* , i32, i32);256 declare void @llvm.x86.avx512.scatterpf.qps.512(i8, <8 x i64>, i8* , i32, i32);[all …]