Lines Matching refs:stream

162 	void **stream;  member
426 z_stream stream; in compress_zlib() local
434 stream.zalloc = Z_NULL; in compress_zlib()
435 stream.zfree = Z_NULL; in compress_zlib()
436 stream.opaque = Z_NULL; in compress_zlib()
456 ret = deflateInit2(&stream, comp_level, Z_DEFLATED, in compress_zlib()
459 ret = deflateInit(&stream, Z_NO_COMPRESSION); in compress_zlib()
485 stream.avail_in = op->src.length; in compress_zlib()
486 stream.next_in = single_src_buf; in compress_zlib()
489 stream.avail_in = op->src.length; in compress_zlib()
490 stream.next_in = rte_pktmbuf_mtod_offset(op->m_src, uint8_t *, in compress_zlib()
504 stream.avail_out = op->m_dst->pkt_len; in compress_zlib()
505 stream.next_out = single_dst_buf; in compress_zlib()
508 stream.avail_out = op->m_dst->data_len; in compress_zlib()
509 stream.next_out = rte_pktmbuf_mtod_offset(op->m_dst, uint8_t *, in compress_zlib()
515 ret = deflate(&stream, zlib_flush); in compress_zlib()
517 if (stream.avail_in != 0) { in compress_zlib()
527 uint32_t remaining_data = stream.total_out; in compress_zlib()
547 op->consumed = stream.total_in; in compress_zlib()
551 op->produced = stream.total_out - (ZLIB_HEADER_SIZE + in compress_zlib()
556 op->produced = stream.total_out - (GZIP_HEADER_SIZE + in compress_zlib()
559 op->produced = stream.total_out; in compress_zlib()
562 op->output_chksum = stream.adler; in compress_zlib()
564 deflateReset(&stream); in compress_zlib()
568 deflateEnd(&stream); in compress_zlib()
579 z_stream stream; in decompress_zlib() local
587 stream.zalloc = Z_NULL; in decompress_zlib()
588 stream.zfree = Z_NULL; in decompress_zlib()
589 stream.opaque = Z_NULL; in decompress_zlib()
596 ret = inflateInit2(&stream, window_bits); in decompress_zlib()
626 stream.avail_in = op->src.length; in decompress_zlib()
627 stream.next_in = single_src_buf; in decompress_zlib()
628 stream.avail_out = rte_pktmbuf_pkt_len(op->m_dst); in decompress_zlib()
629 stream.next_out = single_dst_buf; in decompress_zlib()
632 stream.avail_in = op->src.length; in decompress_zlib()
633 stream.next_in = rte_pktmbuf_mtod(op->m_src, uint8_t *); in decompress_zlib()
634 stream.avail_out = op->m_dst->data_len; in decompress_zlib()
635 stream.next_out = rte_pktmbuf_mtod(op->m_dst, uint8_t *); in decompress_zlib()
640 ret = inflate(&stream, zlib_flush); in decompress_zlib()
642 if (stream.avail_in != 0) { in decompress_zlib()
651 uint32_t remaining_data = stream.total_out; in decompress_zlib()
671 op->consumed = stream.total_in; in decompress_zlib()
672 op->produced = stream.total_out; in decompress_zlib()
675 inflateReset(&stream); in decompress_zlib()
679 inflateEnd(&stream); in decompress_zlib()
1549 void **stream = test_priv_data->stream; in test_deflate_decomp_run() local
1685 decompress_xforms[0], stream); in test_deflate_decomp_run()
1695 ops[i]->stream = *stream; in test_deflate_decomp_run()
1992 void *stream = NULL; in test_deflate_comp_decomp() local
2032 test_priv_data.stream = &stream; in test_deflate_comp_decomp()
2145 if (stream != NULL) in test_deflate_comp_decomp()
2146 rte_compressdev_stream_free(0, stream); in test_deflate_comp_decomp()