| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | load_balancer_api.cc | 111 grpc_core::GrpcLbClientStats* client_stats) { in grpc_grpclb_load_report_request_create_locked() argument
115 req->client_stats.has_timestamp = true; in grpc_grpclb_load_report_request_create_locked()
116 populate_timestamp(gpr_now(GPR_CLOCK_REALTIME), &req->client_stats.timestamp); in grpc_grpclb_load_report_request_create_locked()
117 req->client_stats.has_num_calls_started = true; in grpc_grpclb_load_report_request_create_locked()
118 req->client_stats.has_num_calls_finished = true; in grpc_grpclb_load_report_request_create_locked()
119 req->client_stats.has_num_calls_finished_with_client_failed_to_send = true; in grpc_grpclb_load_report_request_create_locked()
120 req->client_stats.has_num_calls_finished_with_client_failed_to_send = true; in grpc_grpclb_load_report_request_create_locked()
121 req->client_stats.has_num_calls_finished_known_received = true; in grpc_grpclb_load_report_request_create_locked()
122 req->client_stats.calls_finished_with_drop.funcs.encode = encode_drops; in grpc_grpclb_load_report_request_create_locked()
125 client_stats->GetLocked( in grpc_grpclb_load_report_request_create_locked()
[all …]
|
| D | client_load_reporting_filter.cc | 41 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats; member
77 calld->client_stats = static_cast<grpc_core::GrpcLbClientStats*>( in init_call_elem()
81 calld->client_stats->AddCallStarted(); in init_call_elem()
90 if (calld->client_stats != nullptr) { in destroy_call_elem()
93 calld->client_stats->AddCallFinished( in destroy_call_elem()
98 calld->client_stats.reset(); in destroy_call_elem()
106 if (calld->client_stats != nullptr) { in start_transport_stream_op_batch()
|
| D | grpclb.cc | 166 RefCountedPtr<GrpcLbClientStats> client_stats; member
184 GrpcLbClientStats* client_stats() const { return client_stats_.get(); } in client_stats() function in grpc_core::__anon21ecf8450111::GrpcLb::BalancerCallState
671 request->client_stats.calls_finished_with_drop.arg); in LoadReportCountersAreZero()
672 return request->client_stats.num_calls_started == 0 && in LoadReportCountersAreZero()
673 request->client_stats.num_calls_finished == 0 && in LoadReportCountersAreZero()
674 request->client_stats.num_calls_finished_with_client_failed_to_send == in LoadReportCountersAreZero()
676 request->client_stats.num_calls_finished_known_received == 0 && in LoadReportCountersAreZero()
1535 if (pp->client_stats != nullptr) { in PendingPickSetMetadataAndContext()
1537 pp->client_stats.release(); in PendingPickSetMetadataAndContext()
1542 pp->client_stats.reset(); in PendingPickSetMetadataAndContext()
[all …]
|
| D | load_balancer_api.h | 47 grpc_core::GrpcLbClientStats* client_stats);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 44 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats; member
87 if (calld->client_stats != nullptr) { in clr_destroy_call_elem()
90 calld->client_stats->AddCallFinished( in clr_destroy_call_elem()
114 grpc_core::GrpcLbClientStats* client_stats = in clr_start_transport_stream_op_batch() local
118 if (client_stats != nullptr) { in clr_start_transport_stream_op_batch()
119 calld->client_stats.reset(client_stats); in clr_start_transport_stream_op_batch()
|
| D | grpclb.cc | 176 GrpcLbClientStats* client_stats() const { return client_stats_.get(); } in client_stats() function in grpc_core::__anon194416590111::GrpcLb::BalancerCallState
243 RefCountedPtr<GrpcLbClientStats> client_stats) in SubchannelWrapper() argument
246 client_stats_(std::move(client_stats)) {} in SubchannelWrapper()
249 GrpcLbClientStats* client_stats() const { return client_stats_.get(); } in client_stats() function in grpc_core::__anon194416590111::GrpcLb::SubchannelWrapper
260 RefCountedPtr<GrpcLbClientStats> client_stats) in TokenAndClientStatsAttribute() argument
262 client_stats_(std::move(client_stats)) {} in TokenAndClientStatsAttribute()
283 RefCountedPtr<GrpcLbClientStats> client_stats() const { in client_stats() function in grpc_core::__anon194416590111::GrpcLb::TokenAndClientStatsAttribute
307 GrpcLbClientStats* client_stats) const;
335 RefCountedPtr<GrpcLbClientStats> client_stats) in Picker() argument
338 client_stats_(std::move(client_stats)) {} in Picker()
[all …]
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | grpclb_end2end_test.cc | 251 request.client_stats().num_calls_started(); in BalanceLoad()
253 request.client_stats().num_calls_finished(); in BalanceLoad()
255 request.client_stats() in BalanceLoad()
258 request.client_stats().num_calls_finished_known_received(); in BalanceLoad()
260 request.client_stats().calls_finished_with_drop()) { in BalanceLoad()
426 ClientStats client_stats; in WaitForLoadReports() local
428 client_stats += balancer->WaitForLoadReport(); in WaitForLoadReports()
430 return client_stats; in WaitForLoadReports()
1429 const ClientStats client_stats = WaitForLoadReports(); in TEST_F() local
1431 client_stats.num_calls_started); in TEST_F()
[all …]
|
| /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | ScenarioResult.php | 35 private $client_stats; variable in Grpc\\Testing\\ScenarioResult
136 return $this->client_stats;
149 $this->client_stats = $arr;
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/proto/grpc/lb/v1/ |
| D | load_balancer.pb.c | 14 …PB_FIELD( 2, MESSAGE , OPTIONAL, STATIC , OTHER, grpc_lb_v1_LoadBalanceRequest, client_stats, in…
74 …tial_request) < 65536 && pb_membersize(grpc_lb_v1_LoadBalanceRequest, client_stats) < 65536 && pb_…
85 …nitial_request) < 256 && pb_membersize(grpc_lb_v1_LoadBalanceRequest, client_stats) < 256 && pb_me…
|
| D | load_balancer.pb.h | 77 grpc_lb_v1_ClientStats client_stats; member
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | driver.cc | 120 auto time_estimate = average(result->client_stats(), WallTime); in postprocess_scenario_result()
138 auto client_system_time = 100.0 * sum(result->client_stats(), SystemTime) / in postprocess_scenario_result()
139 sum(result->client_stats(), WallTime); in postprocess_scenario_result()
140 auto client_user_time = 100.0 * sum(result->client_stats(), UserTime) / in postprocess_scenario_result()
141 sum(result->client_stats(), WallTime); in postprocess_scenario_result()
177 sum(result->client_stats(), CliPollCount) / histogram.Count()); in postprocess_scenario_result()
185 histogram.Count() / (sum(result->client_stats(), SystemTime) + in postprocess_scenario_result()
186 sum(result->client_stats(), UserTime)); in postprocess_scenario_result()
|
| D | report.cc | 90 if (result.client_stats(i).has_core_stats()) { in ReportQPS()
91 ReportCoreStats("CLIENT", i, result.client_stats(i).core_stats()); in ReportQPS()
|
| /external/grpc-grpc/src/proto/grpc/lb/v1/ |
| D | load_balancer.proto | 43 ClientStats client_stats = 2; field
|
| /external/grpc-grpc-java/grpclb/src/main/proto/grpc/lb/v1/ |
| D | load_balancer.proto | 43 ClientStats client_stats = 2; field
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/lb/v1/ |
| D | load_balancer.proto | 43 ClientStats client_stats = 2; field
|
| /external/grpc-grpc/src/proto/grpc/testing/ |
| D | control.proto | 264 repeated ClientStats client_stats = 3; field
|
| /external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/ |
| D | control.proto | 247 repeated ClientStats client_stats = 3; field
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/ |
| D | control.proto | 277 repeated ClientStats client_stats = 3; field
|