mirror of
https://github.com/openziti/ziti.git
synced 2026-10-23 04:06:50 +00:00
Merge pull request #659 from openziti/fix-service-list-handler
Move service list handler invoke out of decode loop
This commit is contained in:
@@ -66,6 +66,6 @@ func (self *ServiceListHandler) handleServicesList(list *edge_ctrl_pb.ServicesLi
|
||||
}
|
||||
|
||||
serviceList = append(serviceList, service)
|
||||
self.handler(list.LastUpdate, serviceList)
|
||||
}
|
||||
self.handler(list.LastUpdate, serviceList)
|
||||
}
|
||||
|
||||
@@ -80,7 +80,7 @@ func (self *servicePoller) handleServiceListUpdate(lastUpdateToken []byte, servi
|
||||
|
||||
// Adds and Updates
|
||||
for _, s := range services {
|
||||
self.services.Upsert(s.Name, s, func(exist bool, valueInMap interface{}, newValue interface{}) interface{} {
|
||||
self.services.Upsert(s.Id, s, func(exist bool, valueInMap interface{}, newValue interface{}) interface{} {
|
||||
if !exist {
|
||||
self.serviceListener.HandleServicesChange(ziti.ServiceAdded, s)
|
||||
return s
|
||||
|
||||
Reference in New Issue
Block a user