()
| 225 | } |
| 226 | |
| 227 | func (s *Service) stop() { |
| 228 | if s.stopCh != nil { |
| 229 | select { |
| 230 | case <-s.stopCh: |
| 231 | default: |
| 232 | close(s.stopCh) |
| 233 | } |
| 234 | } |
| 235 | s.server.Stop() |
| 236 | s.wg.Wait() |
| 237 | } |
| 238 | |
| 239 | // Query mocks DBS.Query for mirrored database. |
| 240 | func (s *Service) Query(req *types.Request, res *types.Response) (err error) { |
no test coverage detected