(signal_number, stack_frame)
| 88 | sock = eventlet.listen((host, port)) |
| 89 | |
| 90 | def queue_shutdown(signal_number, stack_frame): |
| 91 | deregister_service(STREAM) |
| 92 | eventlet.spawn_n( |
| 93 | shutdown_server_kill_pending_requests, |
| 94 | sock=sock, |
| 95 | worker_pool=worker_pool, |
| 96 | wait_time=WSGI_SERVER_REQUEST_SHUTDOWN_TIME, |
| 97 | ) |
| 98 | |
| 99 | # We register a custom SIGINT handler which allows us to kill long running active requests. |
| 100 | # Note: Eventually we will support draining (waiting for short-running requests), but we |
nothing calls this directly
no test coverage detected