(maxParallel int)
| 517 | } |
| 518 | |
| 519 | func (s *Server) setMaxParallelSnapshotsLocked(maxParallel int) { |
| 520 | s.parallelSnapshotsMutex.Lock() |
| 521 | defer s.parallelSnapshotsMutex.Unlock() |
| 522 | |
| 523 | s.maxParallelSnapshots = maxParallel |
| 524 | s.parallelSnapshotsChanged.Broadcast() |
| 525 | } |
| 526 | |
| 527 | func (s *Server) beginUpload(ctx context.Context, src snapshot.SourceInfo) bool { |
| 528 | s.parallelSnapshotsMutex.Lock() |
no test coverage detected