| 328 | } |
| 329 | |
| 330 | int |
| 331 | Http2CommonSession::do_complete_frame_read() |
| 332 | { |
| 333 | // XXX parse the frame and handle it ... |
| 334 | ink_release_assert(this->_read_buffer_reader->read_avail() >= this->current_hdr.length); |
| 335 | |
| 336 | Http2Frame frame(this->current_hdr, this->_read_buffer_reader, this->cur_frame_from_early_data); |
| 337 | this->_count_received_frames(frame.header().type); |
| 338 | connection_state.rcv_frame(&frame); |
| 339 | |
| 340 | // Check whether data is read from early data |
| 341 | if (this->read_from_early_data > 0) { |
| 342 | this->read_from_early_data -= |
| 343 | this->read_from_early_data > this->current_hdr.length ? this->current_hdr.length : this->read_from_early_data; |
| 344 | } |
| 345 | this->_read_buffer_reader->consume(this->current_hdr.length); |
| 346 | ++(this->_n_frame_read); |
| 347 | |
| 348 | // Set the event handler if there is no more data to process a new frame |
| 349 | HTTP2_SET_SESSION_HANDLER(&Http2CommonSession::state_start_frame_read); |
| 350 | |
| 351 | return 0; |
| 352 | } |
| 353 | |
| 354 | int |
| 355 | Http2CommonSession::do_process_frame_read(int /* event ATS_UNUSED */, VIO *vio, bool inside_frame) |
nothing calls this directly
no test coverage detected