| 418 | } |
| 419 | |
| 420 | bool |
| 421 | Http2CommonSession::_should_do_something_else() |
| 422 | { |
| 423 | if (this->get_proxy_session()->is_peer_closed()) { |
| 424 | return false; |
| 425 | } |
| 426 | if (this->_interrupt_reading_frames) { |
| 427 | this->_interrupt_reading_frames = false; |
| 428 | return true; |
| 429 | } |
| 430 | // Do something else every 128 incoming frames if connection state isn't closed |
| 431 | return (this->_n_frame_read & 0x7F) == 0 && !connection_state.is_state_closed(); |
| 432 | } |
| 433 | |
| 434 | void |
| 435 | Http2CommonSession::interrupt_reading_frames() |
no test coverage detected