| 184 | } |
| 185 | |
| 186 | void |
| 187 | HQTransaction::reenable(VIO *vio) |
| 188 | { |
| 189 | if (vio->op == VIO::READ) { |
| 190 | int64_t len = this->_process_read_vio(); |
| 191 | this->_info.read_vio->reenable(); |
| 192 | |
| 193 | if (len > 0) { |
| 194 | this->_signal_read_event(); |
| 195 | } |
| 196 | } else if (vio->op == VIO::WRITE) { |
| 197 | int64_t len = this->_process_write_vio(); |
| 198 | this->_info.write_vio->reenable(); |
| 199 | |
| 200 | if (len > 0) { |
| 201 | this->_signal_write_event(); |
| 202 | } |
| 203 | } |
| 204 | } |
| 205 | |
| 206 | void |
| 207 | HQTransaction::transaction_done() |
no test coverage detected