| 1005 | } |
| 1006 | |
| 1007 | void |
| 1008 | Http2Stream::reenable(VIO *vio) |
| 1009 | { |
| 1010 | if (this->_proxy_ssn) { |
| 1011 | if (vio->op == VIO::WRITE) { |
| 1012 | SCOPED_MUTEX_LOCK(lock, this->mutex, this_ethread()); |
| 1013 | update_write_request(true); |
| 1014 | } else if (vio->op == VIO::READ) { |
| 1015 | SCOPED_MUTEX_LOCK(ssn_lock, _proxy_ssn->mutex, this_ethread()); |
| 1016 | Http2ConnectionState &connection_state = this->get_connection_state(); |
| 1017 | connection_state.restart_receiving(this); |
| 1018 | } |
| 1019 | } |
| 1020 | } |
| 1021 | |
| 1022 | IOBufferReader * |
| 1023 | Http2Stream::get_data_reader_for_send() const |
no test coverage detected