"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "pilot/pkg/xds/ads.go" between
istio-1.10.0.tar.gz and istio-1.10.1.tar.gz

About: Istio is a platform-independent service mesh that provides a uniform way to connect, secure, control, and observe microservices.

ads.go  (istio-1.10.0):ads.go  (istio-1.10.1)
skipping to change at line 366 skipping to change at line 366
// We do not have to respond in that case. In this case request's version info // We do not have to respond in that case. In this case request's version info
// will be different from the version sent. But it is fragile to rely on that. // will be different from the version sent. But it is fragile to rely on that.
if request.ErrorDetail != nil { if request.ErrorDetail != nil {
errCode := codes.Code(request.ErrorDetail.Code) errCode := codes.Code(request.ErrorDetail.Code)
log.Warnf("ADS:%s: ACK ERROR %s %s:%s", stype, con.ConID, errCode .String(), request.ErrorDetail.GetMessage()) log.Warnf("ADS:%s: ACK ERROR %s %s:%s", stype, con.ConID, errCode .String(), request.ErrorDetail.GetMessage())
incrementXDSRejects(request.TypeUrl, con.proxy.ID, errCode.String ()) incrementXDSRejects(request.TypeUrl, con.proxy.ID, errCode.String ())
if s.StatusGen != nil { if s.StatusGen != nil {
s.StatusGen.OnNack(con.proxy, request) s.StatusGen.OnNack(con.proxy, request)
} }
con.proxy.Lock() con.proxy.Lock()
con.proxy.WatchedResources[request.TypeUrl].NonceNacked = request if w, f := con.proxy.WatchedResources[request.TypeUrl]; f {
.ResponseNonce w.NonceNacked = request.ResponseNonce
}
con.proxy.Unlock() con.proxy.Unlock()
return false return false
} }
if shouldUnsubscribe(request) { if shouldUnsubscribe(request) {
log.Debugf("ADS:%s: UNSUBSCRIBE %s %s %s", stype, con.ConID, requ est.VersionInfo, request.ResponseNonce) log.Debugf("ADS:%s: UNSUBSCRIBE %s %s %s", stype, con.ConID, requ est.VersionInfo, request.ResponseNonce)
con.proxy.Lock() con.proxy.Lock()
delete(con.proxy.WatchedResources, request.TypeUrl) delete(con.proxy.WatchedResources, request.TypeUrl)
con.proxy.Unlock() con.proxy.Unlock()
return false return false
 End of changes. 1 change blocks. 
2 lines changed or deleted 3 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)