173     struct wd_data *uadk_data = p->compress_data;  in multifd_uadk_send_prepare()  local
175     uint8_t *buf = uadk_data->buf;  in multifd_uadk_send_prepare()
184     prepare_next_iov(p, uadk_data->buf_hdr, hdr_size);  in multifd_uadk_send_prepare()
196         if (uadk_data->handle) {  in multifd_uadk_send_prepare()
197             ret = wd_do_comp_sync(uadk_data->handle, &creq);  in multifd_uadk_send_prepare()
204                 uadk_data->buf_hdr[i] = cpu_to_be32(creq.dst_len);  in multifd_uadk_send_prepare()
215         if (!uadk_data->handle || creq.dst_len >= p->page_size) {  in multifd_uadk_send_prepare()
216             uadk_data->buf_hdr[i] = cpu_to_be32(p->page_size);  in multifd_uadk_send_prepare()
278     struct wd_data *uadk_data = p->compress_data;  in multifd_uadk_recv()  local
283     uint8_t *buf = uadk_data->buf;  in multifd_uadk_recv()
300     ret = qio_channel_read_all(p->c, (void *) uadk_data->buf_hdr,  in multifd_uadk_recv()
307         uadk_data->buf_hdr[i] = be32_to_cpu(uadk_data->buf_hdr[i]);  in multifd_uadk_recv()
308         data_len += uadk_data->buf_hdr[i];  in multifd_uadk_recv()
309         assert(uadk_data->buf_hdr[i] <= p->page_size);  in multifd_uadk_recv()
323             .src_len = uadk_data->buf_hdr[i],  in multifd_uadk_recv()
328         if (uadk_data->buf_hdr[i] == p->page_size) {  in multifd_uadk_recv()
334         if (unlikely(!uadk_data->handle)) {  in multifd_uadk_recv()
340         ret = wd_do_comp_sync(uadk_data->handle, &creq);  in multifd_uadk_recv()
350         buf += uadk_data->buf_hdr[i];  in multifd_uadk_recv()