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: Fix pick_first reconnecting without active calls

This commit is contained in:
Michael Lumish 2024-07-03 15:22:03 -07:00
parent c9342572aa
commit c1815e09e2
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
packages/grpc-js/src/load-balancer-pick-first.ts
View File

@ -32,7 +32,7 @@ import {
PickResultType, PickResultType,
UnavailablePicker, UnavailablePicker,
} from './picker'; } from './picker';
import { Endpoint, SubchannelAddress } from './subchannel-address'; import { Endpoint, SubchannelAddress, subchannelAddressToString } from './subchannel-address';
import * as logging from './logging'; import * as logging from './logging';
import { LogVerbosity } from './constants'; import { LogVerbosity } from './constants';
import { import {
@ -348,7 +348,6 @@ export class PickFirstLoadBalancer implements LoadBalancer {
if (newState !== ConnectivityState.READY) { if (newState !== ConnectivityState.READY) {
this.removeCurrentPick(); this.removeCurrentPick();
this.calculateAndReportNewState(); this.calculateAndReportNewState();
this.requestReresolution();
} }
return; return;
} }
@ -483,6 +482,13 @@ export class PickFirstLoadBalancer implements LoadBalancer {
subchannel: this.channelControlHelper.createSubchannel(address, {}), subchannel: this.channelControlHelper.createSubchannel(address, {}),
hasReportedTransientFailure: false, hasReportedTransientFailure: false,
})); }));
trace('connectToAddressList([' + addressList.map(address => subchannelAddressToString(address)) + '])');
for (const { subchannel } of newChildrenList) {
if (subchannel.getConnectivityState() === ConnectivityState.READY) {
this.pickSubchannel(subchannel);
return;
}
}
/* Ref each subchannel before resetting the list, to ensure that /* Ref each subchannel before resetting the list, to ensure that
* subchannels shared between the list don't drop to 0 refs during the * subchannels shared between the list don't drop to 0 refs during the
* transition. */ * transition. */
@ -527,6 +533,7 @@ export class PickFirstLoadBalancer implements LoadBalancer {
const rawAddressList = ([] as SubchannelAddress[]).concat( const rawAddressList = ([] as SubchannelAddress[]).concat(
...endpointList.map(endpoint => endpoint.addresses) ...endpointList.map(endpoint => endpoint.addresses)
); );
trace('updateAddressList([' + rawAddressList.map(address => subchannelAddressToString(address)) + '])');
if (rawAddressList.length === 0) { if (rawAddressList.length === 0) {
throw new Error('No addresses in endpoint list passed to pick_first'); throw new Error('No addresses in endpoint list passed to pick_first');
} }