| 975 | } |
| 976 | |
| 977 | void |
| 978 | QPACK::_decode(EThread *ethread, Continuation *cont, uint64_t stream_id, const uint8_t *header_block, size_t header_block_len, |
| 979 | HTTPHdr &hdr) |
| 980 | { |
| 981 | int event; |
| 982 | int res = this->_decode_header(header_block, header_block_len, hdr); |
| 983 | if (res < 0) { |
| 984 | event = QPACK_EVENT_DECODE_FAILED; |
| 985 | QPACKDebug("decoding header failed (%d)", res); |
| 986 | } else { |
| 987 | event = QPACK_EVENT_DECODE_COMPLETE; |
| 988 | this->_write_header_acknowledgement(stream_id); |
| 989 | } |
| 990 | ethread->schedule_imm(cont, event, &hdr); |
| 991 | } |
| 992 | |
| 993 | bool |
| 994 | QPACK::_add_to_blocked_list(DecodeRequest *decode_request) |
no test coverage detected