(download []*remote.Change)
| 274 | } |
| 275 | |
| 276 | func (d *downstream) updateDownloadChanges(download []*remote.Change) []*remote.Change { |
| 277 | d.sync.fileIndex.fileMapMutex.Lock() |
| 278 | defer d.sync.fileIndex.fileMapMutex.Unlock() |
| 279 | |
| 280 | newChanges := make([]*remote.Change, 0, len(download)) |
| 281 | for _, change := range download { |
| 282 | if d.shouldKeep(change) { |
| 283 | newChanges = append(newChanges, change) |
| 284 | } |
| 285 | } |
| 286 | |
| 287 | return newChanges |
| 288 | } |
| 289 | |
| 290 | func (d *downstream) initDownload(download []*remote.Change) error { |
| 291 | reader, writer := io.Pipe() |
no test coverage detected