peranger/AimRT
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

minor modification to benchmark (#100)

Browse Source 
Co-authored-by: hanjun <hanjun@agibot.com>
This commit is contained in:
han J 2024-11-14 14:31:41 +08:00 committed by GitHub
parent b9d861c327
commit d4eefad587
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/examples/cpp/pb_chn/module/benchmark_subscriber_module/benchmark_subscriber_module.cc
View File

@ -175,7 +175,7 @@ void BenchmarkSubscriberModule::Evaluate() const {
size_t recv_count = statistics_array.size(); size_t recv_count = statistics_array.size();
double loss_rate = static_cast<double>(send_count - recv_count) / send_count; double loss_rate = static_cast<double>(send_count - recv_count) / send_count * 100.0;
std::sort(statistics_array.begin(), statistics_array.end()); std::sort(statistics_array.begin(), statistics_array.end());
@ -195,7 +195,7 @@ msg size: {} bytes
msg count per topic: {} msg count per topic: {}
send count : {} send count : {}
recv count: {} recv count: {}
loss rate: {} loss rate: {} %
min latency: {} us min latency: {} us
max latency: {} us max latency: {} us
avg latency: {} us avg latency: {} us

2
src/examples/cpp/pb_rpc/module/benchmark_rpc_client_module/benchmark_rpc_client_module.cc
View File

@ -232,7 +232,7 @@ co::Task<void> BenchmarkRpcClientModule::StartSinglePlan(uint32_t plan_id, Bench
uint64_t correct_count = gather_vec.size(); uint64_t correct_count = gather_vec.size();
uint64_t total_count = plan.msg_count * plan.parallel; uint64_t total_count = plan.msg_count * plan.parallel;
double error_rate = static_cast<double>(total_count - correct_count) / total_count; double error_rate = static_cast<double>(total_count - correct_count) / total_count * 100;
double qps = (total_count * 1000.0) / total_time_ms; double qps = (total_count * 1000.0) / total_time_ms;
std::sort(gather_vec.begin(), gather_vec.end()); std::sort(gather_vec.begin(), gather_vec.end());

2
src/examples/py/pb_chn_bench/benchmark_subscriber_module.py
View File

@ -168,7 +168,7 @@ class BenchmarkSubscriber(aimrt_py.ModuleBase):
result_str += f"\nmsg count per topic: {self.cur_bench_plan.send_num}" result_str += f"\nmsg count per topic: {self.cur_bench_plan.send_num}"
result_str += f"\nsend count: {send_count}" result_str += f"\nsend count: {send_count}"
result_str += f"\nrecv count: {recv_count}" result_str += f"\nrecv count: {recv_count}"
result_str += f"\nloss rate: {loss_rate:.2f}" result_str += f"\nloss rate: {loss_rate:.2f} % "
result_str += f"\nmin latency: {min_latency:.3f} us" result_str += f"\nmin latency: {min_latency:.3f} us"
result_str += f"\nmax latency: {max_latency:.3f} us" result_str += f"\nmax latency: {max_latency:.3f} us"
result_str += f"\navg latency: {avg_latency:.3f} us" result_str += f"\navg latency: {avg_latency:.3f} us"

2
src/examples/py/pb_rpc_bench/benchmark_rpc_client_module.py
View File

@ -168,7 +168,7 @@ class BenchmarkRpcClientModule(aimrt_py.ModuleBase):
correct_count = len(self.perf_data) correct_count = len(self.perf_data)
total_count = plan['parallel'] * plan['msg_count'] total_count = plan['parallel'] * plan['msg_count']
error_rate = (total_count - correct_count) / total_count error_rate = (total_count - correct_count) / total_count * 100.0
qps = (total_count * 1000.0) / total_time_ms qps = (total_count * 1000.0) / total_time_ms
min_latency = self.perf_data[0] min_latency = self.perf_data[0]