Fix race between stopping old and starting new endpoint

This commit is contained in:
vikaschoudhary16 2018-04-24 22:22:39 -04:00
parent 4344d33772
commit c846d5fe63

View File

@ -333,6 +333,7 @@ func (m *ManagerImpl) addEndpoint(r *pluginapi.RegisterRequest) {
// to avoid potential orphaned devices upon re-registration
devices := make(map[string]pluginapi.Device)
for _, device := range old.getDevices() {
device.Health = pluginapi.Unhealthy
devices[device.ID] = device
}
existingDevs = devices