| 1062 | } |
| 1063 | |
| 1064 | int |
| 1065 | QPACK::_on_read_ready(VIO *vio) |
| 1066 | { |
| 1067 | int nread = 0; |
| 1068 | QUICStreamId stream_id = static_cast<QUICStreamVCAdapter *>(vio->vc_server)->stream().id(); |
| 1069 | |
| 1070 | if (stream_id == this->_decoder_stream_id) { |
| 1071 | nread = this->_on_decoder_stream_read_ready(*vio->get_reader()); |
| 1072 | } else if (stream_id == this->_encoder_stream_id) { |
| 1073 | nread = this->_on_encoder_stream_read_ready(*vio->get_reader()); |
| 1074 | } else { |
| 1075 | ink_assert(!"The stream ID must match either encoder stream id or decoder stream id"); |
| 1076 | } |
| 1077 | |
| 1078 | vio->ndone += nread; |
| 1079 | return EVENT_DONE; |
| 1080 | } |
| 1081 | |
| 1082 | int |
| 1083 | QPACK::_on_write_ready(VIO *vio) |
no test coverage detected