42     struct zstd_data *z = g_new0(struct zstd_data, 1);  in multifd_zstd_send_setup()  local
45     z->zcs = ZSTD_createCStream();  in multifd_zstd_send_setup()
46     if (!z->zcs) {  in multifd_zstd_send_setup()
47         g_free(z);  in multifd_zstd_send_setup()
52     res = ZSTD_initCStream(z->zcs, migrate_multifd_zstd_level());  in multifd_zstd_send_setup()
54         ZSTD_freeCStream(z->zcs);  in multifd_zstd_send_setup()
55         g_free(z);  in multifd_zstd_send_setup()
61     z->zbuff_len = ZSTD_compressBound(MULTIFD_PACKET_SIZE);  in multifd_zstd_send_setup()
62     z->zbuff = g_try_malloc(z->zbuff_len);  in multifd_zstd_send_setup()
63     if (!z->zbuff) {  in multifd_zstd_send_setup()
64         ZSTD_freeCStream(z->zcs);  in multifd_zstd_send_setup()
65         g_free(z);  in multifd_zstd_send_setup()
69     p->compress_data = z;  in multifd_zstd_send_setup()
78     struct zstd_data *z = p->compress_data;  in multifd_zstd_send_cleanup()  local
80     ZSTD_freeCStream(z->zcs);  in multifd_zstd_send_cleanup()
81     z->zcs = NULL;  in multifd_zstd_send_cleanup()
82     g_free(z->zbuff);  in multifd_zstd_send_cleanup()
83     z->zbuff = NULL;  in multifd_zstd_send_cleanup()
94     struct zstd_data *z = p->compress_data;  in multifd_zstd_send_prepare()  local
102     z->out.dst = z->zbuff;  in multifd_zstd_send_prepare()
103     z->out.size = z->zbuff_len;  in multifd_zstd_send_prepare()
104     z->out.pos = 0;  in multifd_zstd_send_prepare()
112         z->in.src = pages->block->host + pages->offset[i];  in multifd_zstd_send_prepare()
113         z->in.size = multifd_ram_page_size();  in multifd_zstd_send_prepare()
114         z->in.pos = 0;  in multifd_zstd_send_prepare()
125             ret = ZSTD_compressStream2(z->zcs, &z->out, &z->in, flush);  in multifd_zstd_send_prepare()
126         } while (ret > 0 && (z->in.size > z->in.pos)  in multifd_zstd_send_prepare()
127                          && (z->out.size > z->out.pos));  in multifd_zstd_send_prepare()
128         if (ret > 0 && (z->in.size > z->in.pos)) {  in multifd_zstd_send_prepare()
139     p->iov[p->iovs_num].iov_base = z->zbuff;  in multifd_zstd_send_prepare()
140     p->iov[p->iovs_num].iov_len = z->out.pos;  in multifd_zstd_send_prepare()
142     p->next_packet_size = z->out.pos;  in multifd_zstd_send_prepare()
152     struct zstd_data *z = g_new0(struct zstd_data, 1);  in multifd_zstd_recv_setup()  local
155     p->compress_data = z;  in multifd_zstd_recv_setup()
156     z->zds = ZSTD_createDStream();  in multifd_zstd_recv_setup()
157     if (!z->zds) {  in multifd_zstd_recv_setup()
158         g_free(z);  in multifd_zstd_recv_setup()
163     ret = ZSTD_initDStream(z->zds);  in multifd_zstd_recv_setup()
165         ZSTD_freeDStream(z->zds);  in multifd_zstd_recv_setup()
166         g_free(z);  in multifd_zstd_recv_setup()
173     z->zbuff_len = MULTIFD_PACKET_SIZE * 2;  in multifd_zstd_recv_setup()
174     z->zbuff = g_try_malloc(z->zbuff_len);  in multifd_zstd_recv_setup()
175     if (!z->zbuff) {  in multifd_zstd_recv_setup()
176         ZSTD_freeDStream(z->zds);  in multifd_zstd_recv_setup()
177         g_free(z);  in multifd_zstd_recv_setup()
186     struct zstd_data *z = p->compress_data;  in multifd_zstd_recv_cleanup()  local
188     ZSTD_freeDStream(z->zds);  in multifd_zstd_recv_cleanup()
189     z->zds = NULL;  in multifd_zstd_recv_cleanup()
190     g_free(z->zbuff);  in multifd_zstd_recv_cleanup()
191     z->zbuff = NULL;  in multifd_zstd_recv_cleanup()
203     struct zstd_data *z = p->compress_data;  in multifd_zstd_recv()  local
220     ret = qio_channel_read_all(p->c, (void *)z->zbuff, in_size, errp);  in multifd_zstd_recv()
226     z->in.src = z->zbuff;  in multifd_zstd_recv()
227     z->in.size = in_size;  in multifd_zstd_recv()
228     z->in.pos = 0;  in multifd_zstd_recv()
232         z->out.dst = p->host + p->normal[i];  in multifd_zstd_recv()
233         z->out.size = page_size;  in multifd_zstd_recv()
234         z->out.pos = 0;  in multifd_zstd_recv()
245             ret = ZSTD_decompressStream(z->zds, &z->out, &z->in);  in multifd_zstd_recv()
246         } while (ret > 0 && (z->in.size > z->in.pos)  in multifd_zstd_recv()
247                          && (z->out.pos < page_size));  in multifd_zstd_recv()
248         if (ret > 0 && (z->out.pos < page_size)) {  in multifd_zstd_recv()
258         out_size += z->out.pos;  in multifd_zstd_recv()