|
|
|
@ -639,7 +639,7 @@ void XdsClient::ChannelState::AdsCallState::OnResponseReceived( |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::ChannelState::AdsCallState::OnResponseReceivedLocked( |
|
|
|
|
void* arg, grpc_error* error) { |
|
|
|
|
void* arg, grpc_error* /*error*/) { |
|
|
|
|
AdsCallState* ads_calld = static_cast<AdsCallState*>(arg); |
|
|
|
|
XdsClient* xds_client = ads_calld->xds_client(); |
|
|
|
|
// Empty payload means the call was cancelled.
|
|
|
|
@ -1083,7 +1083,7 @@ void XdsClient::ChannelState::LrsCallState::OnInitialRequestSent( |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::ChannelState::LrsCallState::OnInitialRequestSentLocked( |
|
|
|
|
void* arg, grpc_error* error) { |
|
|
|
|
void* arg, grpc_error* /*error*/) { |
|
|
|
|
LrsCallState* lrs_calld = static_cast<LrsCallState*>(arg); |
|
|
|
|
// Clear the send_message_payload_.
|
|
|
|
|
grpc_byte_buffer_destroy(lrs_calld->send_message_payload_); |
|
|
|
@ -1102,7 +1102,7 @@ void XdsClient::ChannelState::LrsCallState::OnResponseReceived( |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::ChannelState::LrsCallState::OnResponseReceivedLocked( |
|
|
|
|
void* arg, grpc_error* error) { |
|
|
|
|
void* arg, grpc_error* /*error*/) { |
|
|
|
|
LrsCallState* lrs_calld = static_cast<LrsCallState*>(arg); |
|
|
|
|
XdsClient* xds_client = lrs_calld->xds_client(); |
|
|
|
|
// Empty payload means the call was cancelled.
|
|
|
|
@ -1286,17 +1286,17 @@ void XdsClient::Orphan() { |
|
|
|
|
Unref(DEBUG_LOCATION, "XdsClient::Orphan()"); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::WatchClusterData(StringView cluster, |
|
|
|
|
UniquePtr<ClusterWatcherInterface> watcher) { |
|
|
|
|
void XdsClient::WatchClusterData( |
|
|
|
|
StringView /*cluster*/, UniquePtr<ClusterWatcherInterface> /*watcher*/) { |
|
|
|
|
// TODO(juanlishen): Implement.
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::CancelClusterDataWatch(StringView cluster, |
|
|
|
|
ClusterWatcherInterface* watcher) { |
|
|
|
|
void XdsClient::CancelClusterDataWatch(StringView /*cluster*/, |
|
|
|
|
ClusterWatcherInterface* /*watcher*/) { |
|
|
|
|
// TODO(juanlishen): Implement.
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::WatchEndpointData(StringView cluster, |
|
|
|
|
void XdsClient::WatchEndpointData(StringView /*cluster*/, |
|
|
|
|
UniquePtr<EndpointWatcherInterface> watcher) { |
|
|
|
|
EndpointWatcherInterface* w = watcher.get(); |
|
|
|
|
cluster_state_.endpoint_watchers[w] = std::move(watcher); |
|
|
|
@ -1308,7 +1308,7 @@ void XdsClient::WatchEndpointData(StringView cluster, |
|
|
|
|
chand_->MaybeStartAdsCall(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::CancelEndpointDataWatch(StringView cluster, |
|
|
|
|
void XdsClient::CancelEndpointDataWatch(StringView /*cluster*/, |
|
|
|
|
EndpointWatcherInterface* watcher) { |
|
|
|
|
auto it = cluster_state_.endpoint_watchers.find(watcher); |
|
|
|
|
if (it != cluster_state_.endpoint_watchers.end()) { |
|
|
|
@ -1319,13 +1319,13 @@ void XdsClient::CancelEndpointDataWatch(StringView cluster, |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::AddClientStats(StringView cluster, |
|
|
|
|
void XdsClient::AddClientStats(StringView /*cluster*/, |
|
|
|
|
XdsClientStats* client_stats) { |
|
|
|
|
cluster_state_.client_stats.insert(client_stats); |
|
|
|
|
chand_->MaybeStartLrsCall(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void XdsClient::RemoveClientStats(StringView cluster, |
|
|
|
|
void XdsClient::RemoveClientStats(StringView /*cluster*/, |
|
|
|
|
XdsClientStats* client_stats) { |
|
|
|
|
// TODO(roth): In principle, we should try to send a final load report
|
|
|
|
|
// containing whatever final stats have been accumulated since the
|
|
|
|
|