| 278 | } |
| 279 | |
| 280 | void ScheduleRequest(TIntrusivePtr<TRequestSupervisor>& rs, const THandleRef& h, const TInstant& deadline) { |
| 281 | TJobPtr j(new TNewRequest(rs)); |
| 282 | JQ_.Enqueue(j); |
| 283 | if (!h->Signalled()) { |
| 284 | if (deadline.GetValue() < GetNearDeadline_()) { |
| 285 | Signal(); |
| 286 | } |
| 287 | } |
| 288 | } |
| 289 | |
| 290 | void ScheduleResponse(TRequestSupervisor* rs, THandleRef& h) { |
| 291 | TJobPtr j(new TNewResponse(rs, h)); |