| 115 | } |
| 116 | |
| 117 | VIO * |
| 118 | HQTransaction::do_io_read(Continuation *c, int64_t nbytes, MIOBuffer *buf) |
| 119 | { |
| 120 | if (buf) { |
| 121 | this->_read_vio.set_writer(buf); |
| 122 | } else { |
| 123 | this->_read_vio.buffer.clear(); |
| 124 | } |
| 125 | |
| 126 | this->_read_vio.mutex = c ? c->mutex : this->mutex; |
| 127 | this->_read_vio.cont = c; |
| 128 | this->_read_vio.nbytes = nbytes; |
| 129 | this->_read_vio.ndone = 0; |
| 130 | this->_read_vio.vc_server = this; |
| 131 | this->_read_vio.op = VIO::READ; |
| 132 | |
| 133 | if (buf) { |
| 134 | this->_process_read_vio(); |
| 135 | this->_schedule_read_ready_event(); |
| 136 | } |
| 137 | |
| 138 | return &this->_read_vio; |
| 139 | } |
| 140 | |
| 141 | VIO * |
| 142 | HQTransaction::do_io_write(Continuation *c, int64_t nbytes, IOBufferReader *buf, bool /* owner ATS_UNUSED */) |
no test coverage detected