| 414 | } |
| 415 | |
| 416 | func copyState(state map[string]*remote.Change) map[string]*remote.Change { |
| 417 | newState := make(map[string]*remote.Change, len(state)) |
| 418 | for k, v := range state { |
| 419 | newState[k] = &remote.Change{ |
| 420 | ChangeType: v.ChangeType, |
| 421 | Path: v.Path, |
| 422 | MtimeUnix: v.MtimeUnix, |
| 423 | MtimeUnixNano: v.MtimeUnixNano, |
| 424 | Size: v.Size, |
| 425 | Mode: v.Mode, |
| 426 | IsDir: v.IsDir, |
| 427 | } |
| 428 | } |
| 429 | |
| 430 | return newState |
| 431 | } |
| 432 | |
| 433 | func streamChanges(basePath string, oldState map[string]*remote.Change, newState map[string]*remote.Change, stream remote.Downstream_ChangesServer, throttle time.Duration) (int64, error) { |
| 434 | changeAmount := int64(0) |