Home
last modified time | relevance | path

Searched refs:serverlist (Results 1 – 5 of 5) 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()