Method applyChanges

pkg/devspace/sync/upstream.go:641–714

(changes []*FileInformation)

}

func (u *upstream) applyChanges(changes []*FileInformation) error {
	u.sync.log.Debugf("Upstream - Start applying %d changes", len(changes))
	defer u.sync.log.Debugf("Upstream - Done applying changes")

	var creates []*FileInformation
	var removes []*FileInformation

	// First we cluster changes into remove and create changes
	for _, element := range changes {
		// We determine if a change is a remove or create change by setting
		// the mtime to 0 in the fileinformation for remove changes
		if element.Mtime > 0 {
			creates = append(creates, element)
		} else {
			removes = append(removes, element)
		}
	}

	// Apply removes
	if len(removes) > 0 {
		err := u.applyRemoves(removes)
		if err != nil {
			return errors.Wrap(err, "apply removes")
		}
	}

	// Apply creates
	var writtenChanges map[string]*FileInformation
	if len(creates) > 0 {
		var err error
		writtenChanges, err = func() (map[string]*FileInformation, error) {
			u.sync.fileIndex.fileMapMutex.Lock()
			defer u.sync.fileIndex.fileMapMutex.Unlock()

			for i := 0; i < syncRetries; i++ {
				changes, err := u.applyCreates(creates)
				if err == nil {
					return changes, nil
				} else if i+1 >= syncRetries {
					return nil, errors.Wrap(err, "apply creates")
				} else if strings.Contains(err.Error(), "closed pipe") || strings.Contains(err.Error(), "transport is closing") || strings.Contains(err.Error(), "broken pipe") {
					return nil, errors.Wrap(err, "apply creates")
				}

				u.sync.log.Infof("Upstream - Retry upload because of error: %v", err)
				creates = u.updateUploadChanges(creates)
				if len(creates) == 0 {
					break
				}
			}

			return nil, nil
		}()
		if err != nil {
			return err
		}
	}