Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 40) sorted by relevance

12

/dpdk/drivers/compress/isal/
H A Disal_compress_pmd.c265 if (unlikely(!qp->stream->next_in || !qp->stream->next_out)) { in chained_mbuf_compression()
274 qp->stream->end_of_stream = 1; in chained_mbuf_compression()
277 ret = isal_deflate(qp->stream); in chained_mbuf_compression()
287 if (qp->stream->avail_in == 0 && in chained_mbuf_compression()
291 qp->stream->next_in = in chained_mbuf_compression()
293 qp->stream->avail_in = in chained_mbuf_compression()
303 if (qp->stream->avail_out == 0 && in chained_mbuf_compression()
307 qp->stream->next_out = in chained_mbuf_compression()
425 isal_deflate_init(qp->stream); in process_isal_deflate()
433 qp->stream->flush = NO_FLUSH; in process_isal_deflate()
[all …]
H A Disal_compress_pmd_ops.c180 if (qp->stream) in isal_comp_pmd_qp_release()
181 rte_free(qp->stream->level_buf); in isal_comp_pmd_qp_release()
185 rte_free(qp->stream); in isal_comp_pmd_qp_release()
255 qp->stream = rte_zmalloc_socket("Isa-l compression stream ", in isal_comp_pmd_qp_setup()
258 if (qp->stream == NULL) { in isal_comp_pmd_qp_setup()
263 qp->stream->level_buf = rte_zmalloc_socket("Isa-l compression lev_buf", in isal_comp_pmd_qp_setup()
266 if (qp->stream->level_buf == NULL) { in isal_comp_pmd_qp_setup()
304 if (qp->stream) in isal_comp_pmd_qp_setup()
305 rte_free(qp->stream->level_buf); in isal_comp_pmd_qp_setup()
306 rte_free(qp->stream); in isal_comp_pmd_qp_setup()
H A Disal_compress_pmd_private.h32 struct isal_zstream *stream; member
/dpdk/drivers/compress/qat/
H A Dqat_comp.c119 stream = op->stream; in qat_comp_build_request()
134 stream = NULL; in qat_comp_build_request()
226 if (stream) in qat_comp_build_request()
246 if (stream) in qat_comp_build_request()
267 if (stream) in qat_comp_build_request()
287 if (stream) in qat_comp_build_request()
568 stream = rx_op->stream; in qat_comp_process_response()
573 stream = NULL; in qat_comp_process_response()
687 if (stream) in qat_comp_process_response()
1057 if (stream) { in qat_comp_stream_reset()
[all …]
H A Dqat_comp_pmd.c367 struct qat_comp_stream *stream = obj; in qat_comp_stream_init() local
402 memset(stream, 0, qat_comp_stream_size()); in qat_comp_stream_init()
403 stream->memzone = memzone; in qat_comp_stream_init()
404 stream->state_registers_decomp = memzone->addr; in qat_comp_stream_init()
405 stream->state_registers_decomp_phys = memzone->iova; in qat_comp_stream_init()
406 stream->inflate_context = ((uint8_t *) memzone->addr) in qat_comp_stream_init()
408 stream->inflate_context_phys = memzone->iova in qat_comp_stream_init()
417 struct qat_comp_stream *stream = obj; in qat_comp_stream_destroy() local
419 rte_memzone_free(stream->memzone); in qat_comp_stream_destroy()
H A Dqat_comp.h139 void **stream);
142 qat_comp_stream_free(struct rte_compressdev *dev, void *stream);
/dpdk/drivers/compress/zlib/
H A Dzlib_pmd_ops.c223 struct zlib_stream *stream; in zlib_pmd_stream_create() local
235 stream = *((struct zlib_stream **)zstream); in zlib_pmd_stream_create()
237 ret = zlib_set_stream_parameters(xform, stream); in zlib_pmd_stream_create()
242 memset(stream, 0, sizeof(struct zlib_stream)); in zlib_pmd_stream_create()
244 rte_mempool_put(internals->mp, stream); in zlib_pmd_stream_create()
265 struct zlib_stream *stream = (struct zlib_stream *)zstream; in zlib_pmd_stream_free() local
266 if (!stream) in zlib_pmd_stream_free()
269 stream->free(&stream->strm); in zlib_pmd_stream_free()
271 memset(stream, 0, sizeof(struct zlib_stream)); in zlib_pmd_stream_free()
272 struct rte_mempool *mp = rte_mempool_from_obj(stream); in zlib_pmd_stream_free()
[all …]
H A Dzlib_pmd.c198 struct zlib_stream *stream; in process_zlib_op() local
209 stream = &private_xform->stream; in process_zlib_op()
210 stream->comp(op, &stream->strm); in process_zlib_op()
221 struct zlib_stream *stream) in zlib_set_stream_parameters() argument
224 z_stream *strm = &stream->strm; in zlib_set_stream_parameters()
233 stream->comp = process_zlib_deflate; in zlib_set_stream_parameters()
234 stream->free = deflateEnd; in zlib_set_stream_parameters()
293 stream->comp = process_zlib_inflate; in zlib_set_stream_parameters()
294 stream->free = inflateEnd; in zlib_set_stream_parameters()
H A Dzlib_pmd_private.h61 struct zlib_stream stream; member
66 struct zlib_stream *stream);
/dpdk/drivers/net/qede/base/
H A Dbcm_osal.c232 p_hwfn->stream->next_in = input_buf; in qede_unzip_data()
233 p_hwfn->stream->avail_in = input_len; in qede_unzip_data()
234 p_hwfn->stream->next_out = unzip_buf; in qede_unzip_data()
235 p_hwfn->stream->avail_out = max_size; in qede_unzip_data()
237 rc = inflateInit2(p_hwfn->stream, MAX_WBITS); in qede_unzip_data()
245 rc = inflate(p_hwfn->stream, Z_FINISH); in qede_unzip_data()
246 inflateEnd(p_hwfn->stream); in qede_unzip_data()
250 "FW unzip error: %s, rc=%d\n", p_hwfn->stream->msg, in qede_unzip_data()
255 return p_hwfn->stream->total_out / 4; in qede_unzip_data()
/dpdk/app/test/
H A Dtest_compressdev.c162 void **stream; member
426 z_stream stream; in compress_zlib() local
435 stream.zfree = Z_NULL; in compress_zlib()
568 deflateEnd(&stream); in compress_zlib()
579 z_stream stream; in decompress_zlib() local
679 inflateEnd(&stream); in decompress_zlib()
1549 void **stream = test_priv_data->stream; in test_deflate_decomp_run() local
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()
[all …]
/dpdk/doc/guides/prog_guide/
H A Dcompressdev.rst228 next op in the stream should continue on from op.consumed+1.
441 a particular stream at a time and must attach stream handle
456 Unlike priv_xforms, stream is always a NON_SHAREABLE entity. One stream handle must be attached to …
506 /* create stream */
507 void *stream;
508 rte_compressdev_stream_create(cdev_id, &compress_xform, &stream);
527 op->stream = stream;
563 If enabled, digest buffer will contain valid digest after last op in stream
569 If enabled, checksum will only be available after last op in stream
591 as each op is attached to a different stream i.e. a burst can look like:
[all …]
H A Dgraph_lib.rst283 pointer from current node's stream to next node's stream could be avoided.
285 just move stream from the current node to the next node with least number of cycles.
295 2. Get the next_node stream array with required space using
312 to single next node. So, the current stream can be moved to next node using
330 stream when walking over the graph, and variable-length memory to store
345 This node does ``rte_eth_rx_burst()`` into stream buffer passed to it
346 (src node stream) and does ``rte_node_next_stream_move()`` only when
H A Dtrace_lib.rst256 the metadata stream. It contains exactly what you would expect: data about the
257 trace itself. The metadata stream contains a textual description of the binary
262 The purpose of the metadata stream is to make CTF readers know how to parse a
264 The only stream layout known in advance is, in fact, the metadata stream's one.
H A Dpcapng_lib.rst26 The output stream is created with ``rte_pcapng_fdopen``,
H A Dbbdev.rst666 The input encoded CB data is the Virtual Circular Buffer data stream, wk, with
727 | Set to bypass bit-level interleaver on output stream |
898 | Set for bit-level de-interleaver bypass on input stream |
901 | Set for HARQ combined input stream enable |
904 | Set for HARQ combined output stream enable |
912 | Set for soft-output stream enable |
915 | Set for Rate-Matching bypass on soft-out stream |
918 | Set for bit-level de-interleaver bypass on soft-output stream |
1035 and is the Virtual Circular Buffer data stream with null padding.
/dpdk/drivers/compress/octeontx/
H A Dotx_zip_pmd.c438 const struct rte_comp_xform *xform, void **stream) in zip_pmd_stream_create() argument
455 *stream = strm; in zip_pmd_stream_create()
460 zip_pmd_stream_free(struct rte_compressdev *dev, void *stream) in zip_pmd_stream_free() argument
465 if (stream == NULL) in zip_pmd_stream_free()
468 z_stream = (struct zip_stream *)stream; in zip_pmd_stream_free()
476 memset(stream, 0, sizeof(struct zip_stream)); in zip_pmd_stream_free()
477 rte_free(stream); in zip_pmd_stream_free()
/dpdk/lib/compressdev/
H A Drte_compressdev_pmd.h193 const struct rte_comp_xform *xform, void **stream);
210 void *stream);
H A Drte_compressdev.h503 void **stream);
523 rte_compressdev_stream_free(uint8_t dev_id, void *stream);
H A Drte_compressdev.c707 void **stream) in rte_compressdev_stream_create() argument
714 if (xform == NULL || dev == NULL || stream == NULL) in rte_compressdev_stream_create()
718 ret = (*dev->dev_ops->stream_create)(dev, xform, stream); in rte_compressdev_stream_create()
731 rte_compressdev_stream_free(uint8_t dev_id, void *stream) in rte_compressdev_stream_free() argument
738 if (dev == NULL || stream == NULL) in rte_compressdev_stream_free()
742 ret = dev->dev_ops->stream_free(dev, stream); in rte_compressdev_stream_free()
H A Drte_comp.h294 void *stream; member
/dpdk/doc/guides/nics/
H A Dpcap_ring.rst37 The name is unique for each device. Each device can have multiple stream options and multiple devic…
39 Device name and stream options must be separated by commas as shown below:
50 Multiple ways of stream definitions can be assessed and combined as long as the following two rules…
56 The different stream types are:
58 * rx_pcap: Defines a reception stream based on a pcap file.
64 * tx_pcap: Defines a transmission stream based on a pcap file.
71 * rx_iface: Defines a reception stream based on a network interface name.
78 * rx_iface_in: Defines a reception stream based on a network interface name.
85 * tx_iface: Defines a transmission stream based on a network interface name.
188 by reading the first 512 packets on every RX stream and discarding them.
/dpdk/examples/bpf/
H A DREADME6 for execution on a packet stream. See `bpf-load` and `bpf-unload`
/dpdk/drivers/net/qede/
H A Dqede_main.c106 p_hwfn->stream = OSAL_ZALLOC(p_hwfn->p_dev, GFP_KERNEL, in qed_alloc_stream_mem()
107 sizeof(*p_hwfn->stream)); in qed_alloc_stream_mem()
108 if (!p_hwfn->stream) in qed_alloc_stream_mem()
122 if (!p_hwfn->stream) in qed_free_stream_mem()
125 OSAL_FREE(p_hwfn->p_dev, p_hwfn->stream); in qed_free_stream_mem()
/dpdk/doc/guides/sample_app_ug/
H A Dpacket_ordering.rst7 The Packet Ordering sample app simply shows the impact of reordering a stream.

12