+checklocksread:s.serverMutex
(src snapshot.SourceInfo)
| 1007 | |
| 1008 | // +checklocksread:s.serverMutex |
| 1009 | func (s *Server) isLocal(src snapshot.SourceInfo) bool { |
| 1010 | return s.rep.ClientOptions().Hostname == src.Host && !s.rep.ClientOptions().ReadOnly |
| 1011 | } |
| 1012 | |
| 1013 | func (s *Server) getOrCreateSourceManager(ctx context.Context, src snapshot.SourceInfo) *sourceManager { |
| 1014 | s.serverMutex.Lock() |
no test coverage detected