Method updateMapping

lib/nat/service.go:204–218

updateMapping compares the addresses of the existing mapping versus the natds discovered, and removes any addresses of natds that do not exist, or tries to acquire mappings for natds which the mapping was unaware of before. Optionally takes renew flag which indicates whether or not we should renew m

(ctx context.Context, mapping *Mapping, nats map[string]Device, renew bool)

// Optionally takes renew flag which indicates whether or not we should renew
// mappings with existing natds
func (s *Service) updateMapping(ctx context.Context, mapping *Mapping, nats map[string]Device, renew bool) {
	renewalTime := time.Duration(s.cfg.Options().NATRenewalM) * time.Minute

	mapping.mut.Lock()

	mapping.expires = time.Now().Add(renewalTime)
	change := s.verifyExistingLocked(ctx, mapping, nats, renew)
	add := s.acquireNewLocked(ctx, mapping, nats)

	mapping.mut.Unlock()

	if change || add {
		mapping.notify()
	}
}

func (s *Service) verifyExistingLocked(ctx context.Context, mapping *Mapping, nats map[string]Device, renew bool) (change bool) {
	leaseTime := time.Duration(s.cfg.Options().NATLeaseM) * time.Minute