(block protocol.BlockInfo)
| 261 | } |
| 262 | |
| 263 | func (s *sharedPullerState) copyDone(block protocol.BlockInfo) { |
| 264 | s.mut.Lock() |
| 265 | s.copyNeeded-- |
| 266 | s.updated = time.Now() |
| 267 | s.available = append(s.available, int(block.Offset/int64(s.file.BlockSize()))) |
| 268 | s.availableUpdated = time.Now() |
| 269 | l.Debugln("sharedPullerState", s.folder, s.file.Name, "copyNeeded ->", s.copyNeeded) |
| 270 | s.mut.Unlock() |
| 271 | } |
| 272 | |
| 273 | func (s *sharedPullerState) copiedFromOrigin(bytes int) { |
| 274 | s.mut.Lock() |