(absPath string)
| 630 | } |
| 631 | |
| 632 | func (u *upstream) RemoveSymlinks(absPath string) { |
| 633 | for key, symlink := range u.symlinks { |
| 634 | if key == absPath || strings.Index(filepath.ToSlash(key)+"/", filepath.ToSlash(absPath)) == 0 { |
| 635 | symlink.Stop() |
| 636 | delete(u.symlinks, key) |
| 637 | } |
| 638 | } |
| 639 | } |
| 640 | |
| 641 | func (u *upstream) applyChanges(changes []*FileInformation) error { |
| 642 | u.sync.log.Debugf("Upstream - Start applying %d changes", len(changes)) |