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.
1 parent e3f2a9a commit e0115bbCopy full SHA for e0115bb
pkg/agent/clientset.go
@@ -275,11 +275,14 @@ func (cs *ClientSet) connectOnce() (int, error) {
275
if err != nil {
276
return serverCount, err
277
}
278
- cs.lastReceivedServerCount = receivedServerCount
279
if err := cs.AddClient(c.serverID, c); err != nil {
280
c.Close()
281
282
+ // By moving the update to here, we only accept the server count from a server
283
+ // that we have successfully added to our active client set, implicitly ignoring
284
+ // stale data from duplicate connection attempts.
285
+ cs.lastReceivedServerCount = receivedServerCount
286
klog.V(2).InfoS("sync added client connecting to proxy server", "serverID", c.serverID)
287
288
labels := runpprof.Labels(
0 commit comments