grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

grpc-js: xDS: Do not remove watchers in onResourceDoesNotExist

This commit is contained in:
Michael Lumish 2020-09-24 14:01:15 -07:00
parent 21adc97c4a
commit dcf47460da
2 changed files with 0 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/grpc-js/src/load-balancer-cds.ts
View File

@ -86,10 +86,6 @@ export class CdsLoadBalancer implements LoadBalancer {
); );
}, },
onResourceDoesNotExist: () => { onResourceDoesNotExist: () => {
this.xdsClient?.removeClusterWatcher(
this.latestConfig!.cds.cluster,
this.watcher
);
this.isWatcherActive = false; this.isWatcherActive = false;
this.channelControlHelper.updateState(ConnectivityState.TRANSIENT_FAILURE, new UnavailablePicker({code: Status.UNAVAILABLE, details: 'CDS resource does not exist', metadata: new Metadata()})); this.channelControlHelper.updateState(ConnectivityState.TRANSIENT_FAILURE, new UnavailablePicker({code: Status.UNAVAILABLE, details: 'CDS resource does not exist', metadata: new Metadata()}));
this.childBalancer.destroy(); this.childBalancer.destroy();

4
packages/grpc-js/src/load-balancer-eds.ts
View File

@ -140,10 +140,6 @@ export class EdsLoadBalancer implements LoadBalancer {
this.updateChild(); this.updateChild();
}, },
onResourceDoesNotExist: () => { onResourceDoesNotExist: () => {
this.xdsClient?.removeEndpointWatcher(
this.edsServiceName!,
this.watcher
);
this.isWatcherActive = false; this.isWatcherActive = false;
this.channelControlHelper.updateState(ConnectivityState.TRANSIENT_FAILURE, new UnavailablePicker({code: Status.UNAVAILABLE, details: 'EDS resource does not exist', metadata: new Metadata()})); this.channelControlHelper.updateState(ConnectivityState.TRANSIENT_FAILURE, new UnavailablePicker({code: Status.UNAVAILABLE, details: 'EDS resource does not exist', metadata: new Metadata()}));
this.childBalancer.destroy(); this.childBalancer.destroy();