Home
last modified time | relevance | path

Searched refs:drop_token_counts (Results 1 – 8 of 8) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dload_balancer_api.cc79 const GrpcLbClientStats::DroppedCallCounts* drop_token_counts, in GrpcLbLoadReportRequestCreate() argument
93 if (drop_token_counts != nullptr) { in GrpcLbLoadReportRequestCreate()
94 for (size_t i = 0; i < drop_token_counts->size(); ++i) { in GrpcLbLoadReportRequestCreate()
95 const GrpcLbClientStats::DropTokenCount& cur = (*drop_token_counts)[i]; in GrpcLbLoadReportRequestCreate()
Dgrpclb_client_stats.cc82 std::unique_ptr<DroppedCallCounts>* drop_token_counts) { in Get() argument
90 *drop_token_counts = std::move(drop_token_counts_); in Get()
Dload_balancer_api.h64 const GrpcLbClientStats::DroppedCallCounts* drop_token_counts,
Dgrpclb_client_stats.h55 std::unique_ptr<DroppedCallCounts>* drop_token_counts);
Dgrpclb.cc940 std::unique_ptr<GrpcLbClientStats::DroppedCallCounts> drop_token_counts; in SendClientLoadReportLocked() local
943 &num_calls_finished_known_received, &drop_token_counts); in SendClientLoadReportLocked()
949 (drop_token_counts == nullptr || drop_token_counts->empty())) { in SendClientLoadReportLocked()
963 num_calls_finished_known_received, drop_token_counts.get(), arena.ptr()); in SendClientLoadReportLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb_client_stats.cc76 UniquePtr<DroppedCallCounts>* drop_token_counts) { in GetLocked() argument
83 *drop_token_counts = std::move(drop_token_counts_); in GetLocked()
Dgrpclb_client_stats.h57 UniquePtr<DroppedCallCounts>* drop_token_counts);
/external/grpc-grpc/test/cpp/end2end/
Dgrpclb_end2end_test.cc174 std::map<grpc::string, size_t> drop_token_counts; member
183 for (const auto& p : other.drop_token_counts) { in operator +=()
184 drop_token_counts[p.first] += p.second; in operator +=()
262 .drop_token_counts[drop_token_count.load_balance_token()] += in BalanceLoad()
291 const std::map<grpc::string, size_t>& drop_token_counts) { in BuildResponseForBackends() argument
293 for (const auto& drop_token_count : drop_token_counts) { in BuildResponseForBackends()
1437 EXPECT_THAT(client_stats.drop_token_counts, ::testing::ElementsAre()); in TEST_F()
1504 client_stats.drop_token_counts, in TEST_F()