We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents f09b419 + 46fe4bb commit 62bba95Copy full SHA for 62bba95
pkg/agent/clientset.go
@@ -300,11 +300,14 @@ func (cs *ClientSet) connectOnce() (int, error) {
300
if err != nil {
301
return serverCount, err
302
}
303
- cs.lastReceivedServerCount = receivedServerCount
304
if err := cs.AddClient(c.serverID, c); err != nil {
305
c.Close()
306
307
+ // By moving the update to here, we only accept the server count from a server
308
+ // that we have successfully added to our active client set, implicitly ignoring
309
+ // stale data from duplicate connection attempts.
310
+ cs.lastReceivedServerCount = receivedServerCount
311
klog.V(2).InfoS("sync added client connecting to proxy server", "serverID", c.serverID)
312
313
labels := runpprof.Labels(
0 commit comments