acquireExit returns true if the acquire loop should exit
()
| 319 | |
| 320 | // acquireExit returns true if the acquire loop should exit |
| 321 | func (p *Server) acquireExit() bool { |
| 322 | p.mutex.Lock() |
| 323 | defer p.mutex.Unlock() |
| 324 | if p.closingB { |
| 325 | p.opts.Logger.Debug(p.closeContext, "exiting acquire; provisionerd is closing") |
| 326 | return true |
| 327 | } |
| 328 | if p.shuttingDownB { |
| 329 | p.opts.Logger.Debug(p.closeContext, "exiting acquire; provisionerd is shutting down") |
| 330 | return true |
| 331 | } |
| 332 | return false |
| 333 | } |
| 334 | |
| 335 | func (p *Server) acquireAndRunOne(client proto.DRPCProvisionerDaemonClient) error { |
| 336 | ctx := p.closeContext |
no test coverage detected