()
| 139 | } |
| 140 | |
| 141 | func (s *sourceManager) currentUploader() *upload.Uploader { |
| 142 | s.sourceMutex.RLock() |
| 143 | defer s.sourceMutex.RUnlock() |
| 144 | |
| 145 | return s.uploader |
| 146 | } |
| 147 | |
| 148 | func (s *sourceManager) setUploader(u *upload.Uploader) { |
| 149 | s.sourceMutex.Lock() |