()
| 229 | } |
| 230 | |
| 231 | func (s *sourceManager) runReadOnly() { |
| 232 | s.sourceMutex.Lock() |
| 233 | s.isReadOnly = true |
| 234 | s.sourceMutex.Unlock() |
| 235 | s.setStatus("REMOTE") |
| 236 | |
| 237 | // wait until closed |
| 238 | <-s.closed |
| 239 | } |
| 240 | |
| 241 | func (s *sourceManager) scheduleSnapshotNow() { |
| 242 | s.sourceMutex.Lock() |