(ctx context.Context, src snapshot.SourceInfo)
| 1026 | } |
| 1027 | |
| 1028 | func (s *Server) deleteSourceManager(ctx context.Context, src snapshot.SourceInfo) bool { |
| 1029 | s.serverMutex.Lock() |
| 1030 | sm := s.sourceManagers[src] |
| 1031 | delete(s.sourceManagers, src) |
| 1032 | s.serverMutex.Unlock() |
| 1033 | |
| 1034 | if sm == nil { |
| 1035 | return false |
| 1036 | } |
| 1037 | |
| 1038 | sm.stop(ctx) |
| 1039 | sm.waitUntilStopped() |
| 1040 | |
| 1041 | return true |
| 1042 | } |
| 1043 | |
| 1044 | func (s *Server) snapshotAllSourceManagers() map[snapshot.SourceInfo]*sourceManager { |
| 1045 | s.serverMutex.RLock() |
nothing calls this directly
no test coverage detected