handleCancelRequestIsolated handles a cancel request in process isolation mode.
(params map[string]string)
| 2584 | if consecutiveFailures > 0 { |
| 2585 | slog.Info("S3 credential refresh recovered.", "after_failures", consecutiveFailures) |
| 2586 | } |
| 2587 | consecutiveFailures = 0 |
| 2588 | slog.Debug("Refreshed S3 credentials.") |
| 2589 | } |
| 2590 | case <-done: |
| 2591 | return |
| 2592 | } |
| 2593 | } |
| 2594 | }() |
| 2595 | |
| 2596 | var once sync.Once |
| 2597 | return func() { |
| 2598 | once.Do(func() { close(done) }) |
| 2599 | } |
| 2600 | } |
| 2601 | |
| 2602 | func (s *Server) handleConnection(conn net.Conn) { |
| 2603 | remoteAddr := conn.RemoteAddr() |
| 2604 | |
| 2605 | // Check rate limiting before doing anything |
| 2606 | if msg := s.rateLimiter.CheckConnection(remoteAddr); msg != "" { |
| 2607 | // Send PostgreSQL error and close |
no test coverage detected