| 288 | } |
| 289 | |
| 290 | void ScheduleResponse(TRequestSupervisor* rs, THandleRef& h) { |
| 291 | TJobPtr j(new TNewResponse(rs, h)); |
| 292 | JQ_.Enqueue(j); |
| 293 | if (Y_UNLIKELY(Shutdown_)) { |
| 294 | CleanQueue(); |
| 295 | } else { |
| 296 | Signal(); |
| 297 | } |
| 298 | } |
| 299 | |
| 300 | //return true, if deadline re-installed to more late time |
| 301 | bool SetNearDeadline(const TInstant& deadline) { |