| 690 | } |
| 691 | |
| 692 | void |
| 693 | FetchSM::ext_write_data(const void *data, size_t len) |
| 694 | { |
| 695 | if (write_vio == nullptr) { |
| 696 | return; |
| 697 | } |
| 698 | if (fetch_flags & TS_FETCH_FLAGS_NEWLOCK) { |
| 699 | MUTEX_TAKE_LOCK(mutex, this_ethread()); |
| 700 | } |
| 701 | req_buffer->write(data, len); |
| 702 | |
| 703 | Dbg(dbg_ctl, "[%s] re-enabling write_vio, header_done %u", __FUNCTION__, header_done); |
| 704 | write_vio->reenable(); |
| 705 | |
| 706 | if (fetch_flags & TS_FETCH_FLAGS_NEWLOCK) { |
| 707 | MUTEX_UNTAKE_LOCK(mutex, this_ethread()); |
| 708 | } |
| 709 | } |
| 710 | |
| 711 | ssize_t |
| 712 | FetchSM::ext_read_data(char *buf, size_t len) |
no test coverage detected