| 505 | } |
| 506 | |
| 507 | VIO * |
| 508 | Http2Stream::do_io_read(Continuation *c, int64_t nbytes, MIOBuffer *buf) |
| 509 | { |
| 510 | if (buf) { |
| 511 | read_vio.set_writer(buf); |
| 512 | } else { |
| 513 | read_vio.buffer.clear(); |
| 514 | } |
| 515 | |
| 516 | read_vio.mutex = c ? c->mutex : this->mutex; |
| 517 | read_vio.cont = c; |
| 518 | read_vio.nbytes = nbytes; |
| 519 | read_vio.ndone = 0; |
| 520 | read_vio.vc_server = this; |
| 521 | read_vio.op = VIO::READ; |
| 522 | |
| 523 | // TODO: re-enable read_vio |
| 524 | |
| 525 | return &read_vio; |
| 526 | } |
| 527 | |
| 528 | VIO * |
| 529 | Http2Stream::do_io_write(Continuation *c, int64_t nbytes, IOBufferReader *abuffer, bool /* owner ATS_UNUSED */) |
no test coverage detected