Home
last modified time | relevance | path

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

/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dload_balancer_api.cc45 grpc_grpclb_serverlist* serverlist; member
52 GPR_ASSERT(dec_arg->serverlist->num_servers >= dec_arg->decoding_idx); in decode_serverlist()
60 dec_arg->serverlist->servers[dec_arg->decoding_idx++] = server; in decode_serverlist()
212 decode_arg.serverlist = sl; in grpc_grpclb_response_parse_serverlist()
226 void grpc_grpclb_destroy_serverlist(grpc_grpclb_serverlist* serverlist) { in grpc_grpclb_destroy_serverlist() argument
227 if (serverlist == nullptr) { in grpc_grpclb_destroy_serverlist()
230 for (size_t i = 0; i < serverlist->num_servers; i++) { in grpc_grpclb_destroy_serverlist()
231 gpr_free(serverlist->servers[i]); in grpc_grpclb_destroy_serverlist()
233 gpr_free(serverlist->servers); in grpc_grpclb_destroy_serverlist()
234 gpr_free(serverlist); in grpc_grpclb_destroy_serverlist()
Dgrpclb.cc442 grpc_lb_addresses* ProcessServerlist(const grpc_grpclb_serverlist* serverlist) { in ProcessServerlist() argument
446 for (size_t i = 0; i < serverlist->num_servers; ++i) { in ProcessServerlist()
447 if (IsServerValid(serverlist->servers[i], i, true)) ++num_valid; in ProcessServerlist()
457 for (size_t sl_idx = 0; sl_idx < serverlist->num_servers; ++sl_idx) { in ProcessServerlist()
458 const grpc_grpclb_server* server = serverlist->servers[sl_idx]; in ProcessServerlist()
459 if (!IsServerValid(serverlist->servers[sl_idx], sl_idx, false)) continue; in ProcessServerlist()
763 grpc_grpclb_serverlist* serverlist; in OnBalancerMessageReceivedLocked() local
786 } else if ((serverlist = grpc_grpclb_response_parse_serverlist( in OnBalancerMessageReceivedLocked()
793 grpclb_policy, serverlist->num_servers); in OnBalancerMessageReceivedLocked()
794 for (size_t i = 0; i < serverlist->num_servers; ++i) { in OnBalancerMessageReceivedLocked()
[all …]
Dload_balancer_api.h76 void grpc_grpclb_destroy_serverlist(grpc_grpclb_serverlist* serverlist);
/external/grpc-grpc/test/core/nanopb/
Dfuzzer_serverlist.cc36 grpc_grpclb_serverlist* serverlist; in LLVMFuzzerTestOneInput() local
37 if ((serverlist = grpc_grpclb_response_parse_serverlist(slice))) { in LLVMFuzzerTestOneInput()
38 grpc_grpclb_destroy_serverlist(serverlist); in LLVMFuzzerTestOneInput()
/external/grpc-grpc/test/cpp/grpclb/
Dgrpclb_api_test.cc91 auto* serverlist = response.mutable_server_list(); in TEST_F() local
92 auto* server = serverlist->add_servers(); in TEST_F()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc295 explicit Serverlist(std::vector<GrpcLbServer> serverlist) in Serverlist() argument
296 : serverlist_(std::move(serverlist)) {} in Serverlist()
300 const std::vector<GrpcLbServer>& serverlist() const { return serverlist_; } in serverlist() function in grpc_core::__anon194416590111::GrpcLb::Serverlist
333 Picker(RefCountedPtr<Serverlist> serverlist, in Picker() argument
336 : serverlist_(std::move(serverlist)), in Picker()
702 RefCountedPtr<Serverlist> serverlist; in UpdateState() local
706 serverlist = parent_->serverlist_; in UpdateState()
718 status.ToString().c_str(), picker.get(), serverlist.get(), in UpdateState()
723 absl::make_unique<Picker>(std::move(serverlist), std::move(picker), in UpdateState()
1080 MakeRefCounted<Serverlist>(std::move(response.serverlist)); in OnBalancerMessageReceivedLocked()
[all …]
Dload_balancer_api.h53 std::vector<GrpcLbServer> serverlist; member
Dload_balancer_api.cc166 if (ParseServerList(*response, &result->serverlist)) { in GrpcLbResponseParse()