in cpp/acs_agent_client_reactor.cc [161:173]
void AcsAgentClientReactor::OnReadInitialMetadataDone(bool ok) {
if (!ok) {
ABSL_LOG(WARNING) << "OnReadInitialMetadataDone not ok";
return;
}
const std::multimap<grpc::string_ref, grpc::string_ref>& metadata =
context_.GetServerInitialMetadata();
absl::MutexLock lock(&status_mtx_);
messages_per_minute_quota_ = GetIntValueFromInitialMetadata<uint64_t>(
metadata, kMessagesPerMinuteQuotaKey);
bytes_per_minute_quota_ = GetIntValueFromInitialMetadata<uint64_t>(
metadata, kBytesPerMinuteQuotaKey);
}