Method sendChangesToUpstream

pkg/devspace/sync/sync.go:372–402

(changes []*FileInformation, remove bool)

}

func (s *Sync) sendChangesToUpstream(changes []*FileInformation, remove bool) {
	for j := 0; j < len(changes); j += initialUpstreamBatchSize {
		// Wait till upstream channel is empty
		for len(s.upstream.events) > 0 {
			time.Sleep(time.Millisecond * 500)
		}

		// Now we send them to upstream
		sendBatch := make([]*FileInformation, 0, initialUpstreamBatchSize)
		s.fileIndex.fileMapMutex.Lock()

		for i := j; i < (j+initialUpstreamBatchSize) && i < len(changes); i++ {
			if remove {
				sendBatch = append(sendBatch, changes[i])
			} else if s.fileIndex.fileMap[changes[i].Name] == nil || !equalFilePermissions(changes[i].Mode, s.fileIndex.fileMap[changes[i].Name].Mode) || changes[i].Mtime != s.fileIndex.fileMap[changes[i].Name].Mtime || changes[i].Size != s.fileIndex.fileMap[changes[i].Name].Size {
				sendBatch = append(sendBatch, changes[i])
			}
		}

		s.fileIndex.fileMapMutex.Unlock()

		// We do this out of the fileIndex lock, because otherwise this could cause a deadlock
		// (Upstream waits in getfileInformationFromEvent and upstream.events buffer is full)
		for i := 0; i < len(sendBatch); i++ {
			s.upstream.isBusyMutex.Lock()
			s.upstream.isBusy = true
			s.upstream.events <- sendBatch[i]
			s.upstream.isBusyMutex.Unlock()
		}
	}
}

func equalFilePermissions(mode os.FileMode, mode2 os.FileMode) bool {
	if runtime.GOOS != "linux" && runtime.GOOS != "darwin" {