Home
last modified time | relevance | path

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

123456789

/f-stack/freebsd/amd64/amd64/
H A Dbpf_jit_machdep.h152 emitm(&stream, \
481 emitm(&stream, stream.refs[stream.bpf_pc + ins->jt] - \
482 stream.refs[stream.bpf_pc] + 5, 4); \
483 JMP(stream.refs[stream.bpf_pc + ins->jf] - \
484 stream.refs[stream.bpf_pc]); \
487 emitm(&stream, stream.refs[stream.bpf_pc + ins->jt] - \
488 stream.refs[stream.bpf_pc], 4); \
491 emitm(&stream, stream.refs[stream.bpf_pc + ins->jf] - \
492 stream.refs[stream.bpf_pc], 4); \
498 JMP(stream.refs[stream.bpf_pc + (off)] - \
[all …]
H A Dbpf_jit_machdep.c69 (stream->refs)[stream->bpf_pc] += len; in emit_length()
82 stream->ibuf[stream->cur_ip] = (u_char)value; in emit_code()
83 stream->cur_ip++; in emit_code()
87 *((u_short *)(void *)(stream->ibuf + stream->cur_ip)) = in emit_code()
89 stream->cur_ip += 2; in emit_code()
93 *((u_int *)(void *)(stream->ibuf + stream->cur_ip)) = value; in emit_code()
94 stream->cur_ip += 4; in emit_code()
181 memset(&stream, 0, sizeof(stream)); in bpf_jit_compile()
218 stream.bpf_pc++; in bpf_jit_compile()
623 stream.refs[i] += stream.refs[i - 1]; in bpf_jit_compile()
[all …]
/f-stack/freebsd/i386/i386/
H A Dbpf_jit_machdep.h119 emitm(&stream, \
426 emitm(&stream, stream.refs[stream.bpf_pc + ins->jt] - \
427 stream.refs[stream.bpf_pc] + 5, 4); \
428 JMP(stream.refs[stream.bpf_pc + ins->jf] - \
429 stream.refs[stream.bpf_pc]); \
432 emitm(&stream, stream.refs[stream.bpf_pc + ins->jt] - \
433 stream.refs[stream.bpf_pc], 4); \
436 emitm(&stream, stream.refs[stream.bpf_pc + ins->jf] - \
437 stream.refs[stream.bpf_pc], 4); \
443 JMP(stream.refs[stream.bpf_pc + (off)] - \
[all …]
H A Dbpf_jit_machdep.c69 (stream->refs)[stream->bpf_pc] += len; in emit_length()
70 stream->cur_ip += len; in emit_length()
82 stream->ibuf[stream->cur_ip] = (u_char)value; in emit_code()
83 stream->cur_ip++; in emit_code()
87 *((u_short *)(void *)(stream->ibuf + stream->cur_ip)) = in emit_code()
89 stream->cur_ip += 2; in emit_code()
93 *((u_int *)(void *)(stream->ibuf + stream->cur_ip)) = value; in emit_code()
94 stream->cur_ip += 4; in emit_code()
183 memset(&stream, 0, sizeof(stream)); in bpf_jit_compile()
223 stream.bpf_pc++; in bpf_jit_compile()
[all …]
/f-stack/freebsd/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_zlib.c64 stream->opaque = NULL; in zlib_deflateInit()
65 stream->zfree = zcfree; in zlib_deflateInit()
86 stream->opaque = NULL; in zlib_inflateInit()
87 stream->zfree = zcfree; in zlib_inflateInit()
146 z_stream stream; in z_compress_level() local
149 bzero(&stream, sizeof (stream)); in z_compress_level()
154 stream.opaque = NULL; in z_compress_level()
161 if (!stream.opaque) in z_compress_level()
201 z_stream stream; in z_uncompress() local
204 bzero(&stream, sizeof (stream)); in z_uncompress()
[all …]
/f-stack/freebsd/contrib/openzfs/module/os/linux/spl/
H A Dspl-zlib.c99 z_stream stream; in z_compress_level() local
104 stream.next_out = dest; in z_compress_level()
111 if (!stream.workspace) in z_compress_level()
122 zlib_deflateEnd(&stream); in z_compress_level()
126 *destLen = stream.total_out; in z_compress_level()
128 err = zlib_deflateEnd(&stream); in z_compress_level()
153 z_stream stream; in z_uncompress() local
158 stream.next_out = dest; in z_uncompress()
165 if (!stream.workspace) in z_uncompress()
176 zlib_inflateEnd(&stream); in z_uncompress()
[all …]
/f-stack/freebsd/contrib/libsodium/src/libsodium/randombytes/salsa20/
H A Drandombytes_salsa20_random.c332 memset(stream.rnd32, 0, sizeof stream.rnd32); in randombytes_salsa20_random_stir()
345 arc4random_buf(stream.key, sizeof stream.key); in randombytes_salsa20_random_stir()
407 sodium_memzero(&stream, sizeof stream); in randombytes_salsa20_random_close()
437 sodium_memzero(&stream, sizeof stream); in randombytes_salsa20_random_close()
504 stream.nonce++; in randombytes_salsa20_random_buf()
505 crypto_stream_salsa20_xor(stream.key, stream.key, sizeof stream.key, in randombytes_salsa20_random_buf()
522 COMPILER_ASSERT(((sizeof stream.rnd32) - (sizeof stream.key)) in randombytes_salsa20_random()
532 stream.rnd32_outleft = (sizeof stream.rnd32) - (sizeof stream.key); in randombytes_salsa20_random()
535 memset(&stream.rnd32[stream.rnd32_outleft], 0, sizeof stream.key); in randombytes_salsa20_random()
539 memcpy(&val, &stream.rnd32[stream.rnd32_outleft], sizeof val); in randombytes_salsa20_random()
[all …]
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/tests/functional/redacted_send/
H A Dredacted_origin.ksh38 typeset stream=$(mktemp $tmpdir/stream.XXXX)
53 log_must eval "zfs send --redact BCD $dsA >$stream"
54 log_must eval "zfs receive $POOL2/rBCD <$stream"
55 log_must eval "zfs receive $targ <$stream"
58 log_must eval "zfs send --redact BC $dsA >$stream"
59 log_must eval "zfs receive $POOL2/rBC <$stream"
62 log_must eval "zfs send --redact E $dsA >$stream"
63 log_must eval "zfs receive $POOL2/rE <$stream"
65 log_must eval "zfs send $dsF >$stream"
81 log_must eval "zfs send -i $sendfs#BC $dsF >$stream"
[all …]
H A Dredacted_incrementals.ksh37 typeset stream=$(mktemp $tmpdir/stream.XXXX)
49 log_must eval "zfs receive $POOL2/rfs <$stream"
53 log_must eval "zfs recv $POOL2/rstride3 <$stream"
56 log_must eval "zfs recv $POOL2/rstride5 <$stream"
67 log_must eval "zfs recv $POOL2/rint <$stream"
75 log_must eval "zfs receive $POOL2/rrm <$stream"
86 log_mustnot eval "zfs recv $POOL2/rint <$stream"
89 log_mustnot eval "zfs recv $POOL2/rint <$stream"
125 log_must eval "zfs receive $POOL2/rfs <$stream"
130 log_must eval "zfs receive $POOL2/rfs <$stream"
[all …]
H A Dredacted_compressed.ksh36 typeset stream=$(mktemp $tmpdir/stream.XXXX)
49 log_must eval "zfs send -c --redact book1 $sendfs@snap >$stream"
50 log_must eval "zfs recv $recvfs <$stream"
51 log_must stream_has_features $stream compressed lz4 redacted
53 verify_stream_size $stream $sendfs
55 verify_stream_size $stream $recvfs
58 log_must eval "zfs send -c -i $sendfs@snap $clone@snap1 >$stream"
59 log_must eval "zfs recv $POOL2/inc1 <$stream"
60 log_must stream_has_features $stream compressed lz4
66 log_must eval "zfs recv $POOL2/inc2 <$stream"
[all …]
H A Dredacted_contents.ksh41 typeset stream=$(mktemp $tmpdir/stream.XXXX)
52 log_must eval "zfs send --redact book1 $sendfs@snap >$stream"
53 log_must eval "zfs recv $recvfs <$stream"
65 log_must eval "zfs recv $recvfs <$stream"
75 log_must eval "zfs recv $recvfs <$stream"
88 log_must eval "zfs recv $recvfs <$stream"
101 log_must eval "zfs recv $recvfs <$stream"
113 log_must eval "zfs recv $recvfs <$stream"
128 log_must eval "zfs recv $recvfs <$stream"
145 log_must eval "zfs recv $recvfs <$stream"
[all …]
H A Dredacted_largeblocks.ksh38 typeset stream=$(mktemp $tmpdir/stream.XXXX)
50 log_must eval "zfs send -L --redact book1 $sendfs@snap >$stream"
51 log_must stream_has_features $stream redacted large_blocks
52 log_must eval "zfs recv $recvfs <$stream"
58 log_must eval "zfs send -L -i $sendfs@snap $clone@snap1 >$stream"
59 log_must stream_has_features $stream large_blocks
60 log_must eval "zfs recv $recvfs/new <$stream"
H A Dredacted_embedded.ksh40 typeset stream=$(mktemp $tmpdir/stream.XXXX)
50 log_must eval "zfs send -e --redact book1 $sendfs@snap >$stream"
51 log_must eval "zfs recv $recvfs <$stream"
52 log_must stream_has_features $stream redacted embed_data
68 cat $stream | zstreamdump -v | log_must grep -q \
78 log_must eval "zfs send -e --redact book2 $sendfs@snap >$stream"
79 log_must eval "zfs recv $recvfs <$stream"
80 log_must stream_has_features $stream redacted embed_data
99 cat $stream | zstreamdump -v | log_must grep -q \
H A Dredacted_holes.ksh39 typeset stream=$(mktemp $tmpdir/stream.XXXX)
57 log_must eval "zfs send --redact book1 $sendfs@snap >$stream"
58 log_must eval "zfs recv $recvfs <$stream"
68 log_must eval "zfs send --redact book2 $sendfs@snap >$stream"
69 log_must eval "zfs recv $recvfs <$stream"
83 log_must eval "zfs send --redact book3 $sendfs@snap >$stream"
84 log_must eval "zfs recv $recvfs <$stream"
93 log_must eval "zfs send --redact book4 $sendfs@snap >$stream"
94 log_must eval "zfs recv $recvfs <$stream"
104 log_must eval "zfs send --redact book6 $sendfs/manyrm@snap >$stream"
[all …]
H A Dredacted_deleted.ksh38 typeset stream=$(mktemp $tmpdir/stream.XXXX)
62 log_must eval "zfs send --redact book1 $sendfs@snap >$stream"
63 log_must eval "zfs recv $recvfs <$stream"
86 log_must eval "zfs send --redact book2 $sendfs@snap >$stream"
87 log_must eval "zfs recv $recvfs <$stream"
96 log_must eval "zfs send -i $sendfs#book2 --redact book3 $sendfs@snap2 >$stream"
97 log_must eval "zfs recv $recvfs <$stream"
/f-stack/freebsd/contrib/zlib/
H A Duncompr.c33 z_stream stream; local
50 stream.avail_in = 0;
51 stream.zalloc = (alloc_func)0;
52 stream.zfree = (free_func)0;
53 stream.opaque = (voidpf)0;
55 err = inflateInit(&stream);
58 stream.next_out = dest;
59 stream.avail_out = 0;
66 if (stream.avail_in == 0) {
68 len -= stream.avail_in;
[all …]
H A Dcompress.c29 z_stream stream; local
37 stream.zalloc = (alloc_func)0;
38 stream.zfree = (free_func)0;
39 stream.opaque = (voidpf)0;
44 stream.next_out = dest;
45 stream.avail_out = 0;
47 stream.avail_in = 0;
50 if (stream.avail_out == 0) {
54 if (stream.avail_in == 0) {
61 *destLen = stream.total_out;
[all …]
/f-stack/app/nginx-1.16.1/src/http/v2/
H A Dngx_http_v2_filter_module.c164 stream = r->stream; in ngx_http_v2_header_filter()
916 stream = r->stream; in ngx_http_v2_push_resource()
1089 stream = r->stream; in ngx_http_v2_create_headers_frame()
1098 frame->stream = stream; in ngx_http_v2_create_headers_frame()
1194 stream = r->stream; in ngx_http_v2_create_push_frame()
1204 frame->stream = stream; in ngx_http_v2_create_push_frame()
1429 stream = r->stream; in ngx_http_v2_send_chain()
1741 frame->stream = stream; in ngx_http_v2_filter_get_data_frame()
1835 stream = frame->stream; in ngx_http_v2_headers_frame_handler()
1889 stream = frame->stream; in ngx_http_v2_push_frame_handler()
[all …]
H A Dngx_http_v2.c868 stream = node->stream; in ngx_http_v2_state_data()
920 h2c->state.stream = stream; in ngx_http_v2_state_data()
937 stream = h2c->state.stream; in ngx_http_v2_state_read_data()
1160 h2c->state.stream = stream; in ngx_http_v2_state_headers()
1170 node->stream = stream; in ngx_http_v2_state_headers()
1941 stream = node->stream; in ngx_http_v2_state_rst_stream()
2296 stream = node->stream; in ngx_http_v2_state_window_update()
2626 node->stream = stream; in ngx_http_v2_push_stream()
3114 r->stream = stream; in ngx_http_v2_create_stream()
3840 stream = r->stream; in ngx_http_v2_read_request_body()
[all …]
/f-stack/freebsd/kern/
H A Dsubr_compressor.c148 s = stream; in gz_reset()
176 s = stream; in gz_write()
240 s = stream; in gz_fini()
339 s = stream; in zstdio_reset()
438 s = stream; in zstdio_write()
478 s = stream; in zstdio_fini()
541 stream->methods->reset(stream->priv); in compressor_reset()
548 return (stream->methods->write(stream->priv, data, len, stream->cb, in compressor_write()
549 stream->arg)); in compressor_write()
556 return (stream->methods->write(stream->priv, NULL, 0, stream->cb, in compressor_flush()
[all …]
/f-stack/dpdk/drivers/compress/isal/
H A Disal_compress_pmd.c261 if (unlikely(!qp->stream->next_in || !qp->stream->next_out)) { in chained_mbuf_compression()
270 qp->stream->end_of_stream = 1; in chained_mbuf_compression()
273 ret = isal_deflate(qp->stream); in chained_mbuf_compression()
283 if (qp->stream->avail_in == 0 && in chained_mbuf_compression()
287 qp->stream->next_in = in chained_mbuf_compression()
289 qp->stream->avail_in = in chained_mbuf_compression()
299 if (qp->stream->avail_out == 0 && in chained_mbuf_compression()
303 qp->stream->next_out = in chained_mbuf_compression()
421 isal_deflate_init(qp->stream); in process_isal_deflate()
429 qp->stream->flush = NO_FLUSH; in process_isal_deflate()
[all …]
/f-stack/freebsd/contrib/libsodium/src/libsodium/randombytes/sysrandom/
H A Drandombytes_sysrandom.c99 static SysRandom stream = { variable
261 stream.getrandom_available = 0; in randombytes_sysrandom_init()
265 if ((stream.random_data_source_fd = in randombytes_sysrandom_init()
283 if (stream.initialized == 0) { in randombytes_sysrandom_stir()
285 stream.initialized = 1; in randombytes_sysrandom_stir()
292 if (stream.initialized == 0) { in randombytes_sysrandom_stir_if_needed()
305 stream.random_data_source_fd = -1; in randombytes_sysrandom_close()
306 stream.initialized = 0; in randombytes_sysrandom_close()
310 if (stream.getrandom_available != 0) { in randombytes_sysrandom_close()
315 if (stream.initialized != 0) { in randombytes_sysrandom_close()
[all …]
/f-stack/app/redis-5.0.5/src/
H A Dstream.h16 typedef struct stream { struct
21 } stream; typedef
30 stream *stream; /* The stream we are iterating. */ member
99 stream *streamNew(void);
100 void freeStream(stream *s);
101 size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end, size_t count, int…
102 void streamIteratorStart(streamIterator *si, stream *s, streamID *start, streamID *end, int rev);
106 streamCG *streamLookupCG(stream *s, sds groupname);
108 streamCG *streamCreateCG(stream *s, char *name, size_t namelen, streamID *id);
/f-stack/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()
567 stream = rx_op->stream; in qat_comp_process_response()
572 stream = NULL; in qat_comp_process_response()
685 if (stream) in qat_comp_process_response()
1086 if (stream) { in qat_comp_stream_reset()
[all …]
/f-stack/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 …]

123456789