archive-gh-me/grpc-node
1
0
Fork 0
mirror of https://github.com/grpc/grpc-node.git synced 2025-12-08 18:23:54 +00:00
Code Issues Projects Releases Wiki Activity

grpc-js-xds: Start resource timers for resources requested after stream start

Browse Source
This commit is contained in:
Michael Lumish 2025-01-14 13:35:36 -08:00
parent bfebbe7047
commit 198ff4e9ea
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
packages/grpc-js-xds/src/xds-client.ts
View File

@ -296,6 +296,7 @@ class AdsCallState {
public typeStates: Map<XdsResourceType, ResourceTypeState> = new Map();
private receivedAnyResponse = false;
private sentInitialMessage = false;
private streamStarted = false;
constructor(public client: XdsSingleServerClient, private call: AdsCall, private node: Node) {
// Populate subscription map with existing subscriptions
for (const [authority, authorityState] of client.xdsClient.authorityStateMap) {
@ -438,6 +439,9 @@ class AdsCallState {
}
if (!authorityMap.has(name.key)) {
const timer = new ResourceTimer(this, type, name);
if (this.streamStarted) {
timer.markAdsStreamStarted();
}
authorityMap.set(name.key, timer);
if (!delaySend) {
this.updateNames(type);
@ -502,6 +506,7 @@ class AdsCallState {
* stream.
*/
markStreamStarted() {
this.streamStarted = true;
for (const [type, typeState] of this.typeStates) {
for (const [authority, authorityMap] of typeState.subscribedResources) {
for (const resourceTimer of authorityMap.values()) {