crypto/heimdal/appl/ftp/ftpd/ftpd_locl.h

163

int fclose(FILE *stream);

crypto/krb5/src/ccapi/lib/win/ccs_reply_proc.c

48

k5_ipc_stream stream;

crypto/krb5/src/ccapi/lib/win/ccs_reply_proc.c

53

status = krb5int_ipc_stream_new (&stream); /* Create a stream for the request data */

crypto/krb5/src/ccapi/lib/win/ccs_reply_proc.c

57

status = krb5int_ipc_stream_write (stream, chIn, cbIn);

crypto/krb5/src/ccapi/lib/win/ccs_reply_proc.c

61

tspdata_setStream(tsp, stream);

crypto/krb5/src/ccapi/server/win/WorkQueue.cpp

55

const k5_ipc_stream stream,

crypto/krb5/src/ccapi/server/win/WorkQueue.cpp

57

return worklist.add(new WorkItem(stream, pipe, rpcmsg, serverStartTime) );

crypto/krb5/src/ccapi/server/win/WorkQueue.cpp

62

k5_ipc_stream* stream,

crypto/krb5/src/ccapi/server/win/WorkQueue.cpp

69

*stream = item->take_payload();

crypto/krb5/src/ccapi/server/win/WorkQueue.h

43

const k5_ipc_stream stream,

crypto/krb5/src/ccapi/server/win/WorkQueue.h

48

k5_ipc_stream* stream,

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

242

k5_ipc_stream stream = NULL;

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

282

err = krb5int_ipc_stream_new (&stream);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

283

err = krb5int_ipc_stream_write(stream, "This is a test of the emergency broadcasting system", 52);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

284

err = ccs_os_server_send_reply(pipe, stream);

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

45

k5_ipc_stream stream;

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

52

status = krb5int_ipc_stream_new (&stream); /* Create a stream for the request data */

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

56

status = krb5int_ipc_stream_write (stream, pbRequest, lenRequest);

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

60

worklist_add(rpcmsg, pipe, stream, serverStartTime);

crypto/krb5/src/lib/crypto/krb/aead.c

106

iov[i].data = make_data(stream->data.data + stream->data.length -

crypto/krb5/src/lib/crypto/krb/aead.c

59

krb5_crypto_iov *stream;

crypto/krb5/src/lib/crypto/krb/aead.c

63

stream = krb5int_c_locate_iov(data, num_data, KRB5_CRYPTO_TYPE_STREAM);

crypto/krb5/src/lib/crypto/krb/aead.c

64

assert(stream != NULL);

crypto/krb5/src/lib/crypto/krb/aead.c

69

if (stream->data.length < header_len + trailer_len)

crypto/krb5/src/lib/crypto/krb/aead.c

79

iov[i].data = make_data(stream->data.data, header_len);

crypto/krb5/src/lib/crypto/krb/aead.c

91

data[j].data.data = stream->data.data + header_len;

crypto/krb5/src/lib/crypto/krb/aead.c

92

data[j].data.length = stream->data.length - header_len

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

376

gss_iov_buffer_t stream, data = NULL;

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

386

stream = kg_locate_iov(iov, iov_count, GSS_IOV_BUFFER_TYPE_STREAM);

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

387

assert(stream != NULL);

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

389

ptr = (unsigned char *)stream->buffer.value;

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

391

k5_input_init(&in, stream->buffer.value, stream->buffer.length);

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

411

theader->buffer.value = stream->buffer.value;

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

412

theader->buffer.length = ptr - (unsigned char *)stream->buffer.value;

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

414

stream->buffer.length != theader->buffer.length + bodysize) {

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

472

if (!gss_krb5int_rotate_left((unsigned char *)stream->buffer.value + 16,

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

473

stream->buffer.length - 16, rrc)) {

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

495

ttrailer->buffer.value = (unsigned char *)stream->buffer.value +

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

496

stream->buffer.length - ttrailer->buffer.length;

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

510

tpadding->buffer.value = (unsigned char *)stream->buffer.value + stream->buffer.length - 1;

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

530

if (stream->buffer.length < theader->buffer.length +

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

540

tdata->buffer.length = stream->buffer.length - ttrailer->buffer.length -

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

550

(unsigned char *)stream->buffer.value + theader->buffer.length, tdata->buffer.length);

crypto/krb5/src/lib/gssapi/krb5/k5unsealiov.c

552

tdata->buffer.value = (unsigned char *)stream->buffer.value + theader->buffer.length;

crypto/krb5/src/util/support/ipc_stream.c

108

k5_ipc_stream stream = NULL;

crypto/krb5/src/util/support/ipc_stream.c

113

stream = malloc (sizeof (*stream));

crypto/krb5/src/util/support/ipc_stream.c

114

if (stream) {

crypto/krb5/src/util/support/ipc_stream.c

115

*stream = k5_ipc_stream_initializer;

crypto/krb5/src/util/support/ipc_stream.c

122

*out_stream = stream;

crypto/krb5/src/util/support/ipc_stream.c

123

stream = NULL;

crypto/krb5/src/util/support/ipc_stream.c

126

krb5int_ipc_stream_release (stream);

crypto/libecc/src/sig/bip0340.c

658

ATTRIBUTE_WARN_UNUSED_RET static int _bip0340_chacha20_block(const u8 key[32], const u8 nonce[12], u32 block_counter, u8 *stream, u32 stream_len){

crypto/libecc/src/sig/bip0340.c

664

MUST_HAVE((stream != NULL), ret, err);

crypto/libecc/src/sig/bip0340.c

691

ret = local_memcpy(stream, &state[0], stream_len);

crypto/openssh/packet.c

704

z_streamp stream = &state->compression_out_stream;

crypto/openssh/packet.c

707

(unsigned long long)stream->total_in,

crypto/openssh/packet.c

708

(unsigned long long)stream->total_out,

crypto/openssh/packet.c

709

stream->total_in == 0 ? 0.0 :

crypto/openssh/packet.c

710

(double) stream->total_out / stream->total_in);

crypto/openssh/packet.c

712

deflateEnd(stream);

crypto/openssh/packet.c

715

z_streamp stream = &state->compression_in_stream;

crypto/openssh/packet.c

718

(unsigned long long)stream->total_out,

crypto/openssh/packet.c

719

(unsigned long long)stream->total_in,

crypto/openssh/packet.c

720

stream->total_out == 0 ? 0.0 :

crypto/openssh/packet.c

721

(double) stream->total_in / stream->total_out);

crypto/openssh/packet.c

723

inflateEnd(stream);

crypto/openssh/utf8.c

277

vfmprintf(FILE *stream, const char *fmt, va_list ap)

crypto/openssh/utf8.c

286

if (fputs(str, stream) == EOF)

crypto/openssh/utf8.c

293

fmprintf(FILE *stream, const char *fmt, ...)

crypto/openssh/utf8.c

299

ret = vfmprintf(stream, fmt, ap);

crypto/openssl/crypto/bio/bss_file.c

100

BIO_set_fp(ret, stream, close_flag);

crypto/openssl/crypto/bio/bss_file.c

91

BIO *BIO_new_fp(FILE *stream, int close_flag)

crypto/openssl/crypto/evp/e_aes.c

159

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)aesni_cbc_encrypt : NULL;

crypto/openssl/crypto/evp/e_aes.c

164

dat->stream.cbc = (cbc128_f)aesni_cbc_encrypt;

crypto/openssl/crypto/evp/e_aes.c

166

dat->stream.ctr = (ctr128_f)aesni_ctr32_encrypt_blocks;

crypto/openssl/crypto/evp/e_aes.c

168

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_aes.c

2434

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_aes.c

2437

dat->stream.cbc = (cbc128_f)HWAES_cbc_encrypt;

crypto/openssl/crypto/evp/e_aes.c

2445

dat->stream.cbc = (cbc128_f)ossl_bsaes_cbc_encrypt;

crypto/openssl/crypto/evp/e_aes.c

2452

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)vpaes_cbc_encrypt : NULL;

crypto/openssl/crypto/evp/e_aes.c

2458

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)AES_cbc_encrypt : NULL;

crypto/openssl/crypto/evp/e_aes.c

2465

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_aes.c

2468

dat->stream.cbc = (cbc128_f)HWAES_cbc_encrypt;

crypto/openssl/crypto/evp/e_aes.c

2473

dat->stream.ctr = (ctr128_f)HWAES_ctr32_encrypt_blocks;

crypto/openssl/crypto/evp/e_aes.c

2483

dat->stream.ctr = (ctr128_f)ossl_bsaes_ctr32_encrypt_blocks;

crypto/openssl/crypto/evp/e_aes.c

2490

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)vpaes_cbc_encrypt : NULL;

crypto/openssl/crypto/evp/e_aes.c

2496

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)AES_cbc_encrypt : NULL;

crypto/openssl/crypto/evp/e_aes.c

2499

dat->stream.ctr = (ctr128_f)AES_ctr32_encrypt;

crypto/openssl/crypto/evp/e_aes.c

2516

if (dat->stream.cbc)

crypto/openssl/crypto/evp/e_aes.c

2517

(*dat->stream.cbc)(in, out, len, &dat->ks, ctx->iv,

crypto/openssl/crypto/evp/e_aes.c

2629

if (dat->stream.ctr)

crypto/openssl/crypto/evp/e_aes.c

2633

&num, dat->stream.ctr);

crypto/openssl/crypto/evp/e_aes.c

300

xctx->stream = aesni_xts_encrypt;

crypto/openssl/crypto/evp/e_aes.c

304

xctx->stream = aesni_xts_decrypt;

crypto/openssl/crypto/evp/e_aes.c

3266

xctx->stream = enc ? AES_xts_encrypt : AES_xts_decrypt;

crypto/openssl/crypto/evp/e_aes.c

3268

xctx->stream = NULL;

crypto/openssl/crypto/evp/e_aes.c

3277

xctx->stream = HWAES_xts_encrypt;

crypto/openssl/crypto/evp/e_aes.c

3283

xctx->stream = HWAES_xts_decrypt;

crypto/openssl/crypto/evp/e_aes.c

3296

xctx->stream = enc ? ossl_bsaes_xts_encrypt : ossl_bsaes_xts_decrypt;

crypto/openssl/crypto/evp/e_aes.c

3364

if (xctx->stream)

crypto/openssl/crypto/evp/e_aes.c

3365

(*xctx->stream)(in, out, len,

crypto/openssl/crypto/evp/e_aes.c

41

} stream;

crypto/openssl/crypto/evp/e_aes.c

496

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)aes128_t4_cbc_decrypt : NULL;

crypto/openssl/crypto/evp/e_aes.c

499

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)aes192_t4_cbc_decrypt : NULL;

crypto/openssl/crypto/evp/e_aes.c

502

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)aes256_t4_cbc_decrypt : NULL;

crypto/openssl/crypto/evp/e_aes.c

514

dat->stream.cbc = (cbc128_f)aes128_t4_cbc_encrypt;

crypto/openssl/crypto/evp/e_aes.c

516

dat->stream.ctr = (ctr128_f)aes128_t4_ctr32_encrypt;

crypto/openssl/crypto/evp/e_aes.c

518

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_aes.c

522

dat->stream.cbc = (cbc128_f)aes192_t4_cbc_encrypt;

crypto/openssl/crypto/evp/e_aes.c

524

dat->stream.ctr = (ctr128_f)aes192_t4_ctr32_encrypt;

crypto/openssl/crypto/evp/e_aes.c

526

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_aes.c

530

dat->stream.cbc = (cbc128_f)aes256_t4_cbc_encrypt;

crypto/openssl/crypto/evp/e_aes.c

532

dat->stream.ctr = (ctr128_f)aes256_t4_ctr32_encrypt;

crypto/openssl/crypto/evp/e_aes.c

534

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_aes.c

663

xctx->stream = NULL;

crypto/openssl/crypto/evp/e_aes.c

670

xctx->stream = aes128_t4_xts_encrypt;

crypto/openssl/crypto/evp/e_aes.c

673

xctx->stream = aes256_t4_xts_encrypt;

crypto/openssl/crypto/evp/e_aes.c

68

void (*stream)(const unsigned char *in,

crypto/openssl/crypto/evp/e_aes.c

683

xctx->stream = aes128_t4_xts_decrypt;

crypto/openssl/crypto/evp/e_aes.c

686

xctx->stream = aes256_t4_xts_decrypt;

crypto/openssl/crypto/evp/e_camellia.c

213

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)Camellia_cbc_encrypt : NULL;

crypto/openssl/crypto/evp/e_camellia.c

216

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)Camellia_cbc_encrypt : NULL;

crypto/openssl/crypto/evp/e_camellia.c

227

if (dat->stream.cbc)

crypto/openssl/crypto/evp/e_camellia.c

228

(*dat->stream.cbc)(in, out, len, &dat->ks, ctx->iv,

crypto/openssl/crypto/evp/e_camellia.c

336

if (dat->stream.ctr)

crypto/openssl/crypto/evp/e_camellia.c

340

dat->stream.ctr);

crypto/openssl/crypto/evp/e_camellia.c

38

} stream;

crypto/openssl/crypto/evp/e_camellia.c

68

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)cmll128_t4_cbc_decrypt : NULL;

crypto/openssl/crypto/evp/e_camellia.c

72

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)cmll256_t4_cbc_decrypt : NULL;

crypto/openssl/crypto/evp/e_camellia.c

83

dat->stream.cbc = (cbc128_f)cmll128_t4_cbc_encrypt;

crypto/openssl/crypto/evp/e_camellia.c

85

dat->stream.ctr = (ctr128_f)cmll128_t4_ctr32_encrypt;

crypto/openssl/crypto/evp/e_camellia.c

87

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_camellia.c

92

dat->stream.cbc = (cbc128_f)cmll256_t4_cbc_encrypt;

crypto/openssl/crypto/evp/e_camellia.c

94

dat->stream.ctr = (ctr128_f)cmll256_t4_ctr32_encrypt;

crypto/openssl/crypto/evp/e_camellia.c

96

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_des.c

214

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_des.c

221

dat->stream.cbc = enc ? des_t4_cbc_encrypt : des_t4_cbc_decrypt;

crypto/openssl/crypto/evp/e_des.c

34

} stream;

crypto/openssl/crypto/evp/e_des.c

98

if (dat->stream.cbc != NULL) {

crypto/openssl/crypto/evp/e_des.c

99

(*dat->stream.cbc)(in, out, inl, &dat->ks.ks, ctx->iv);

crypto/openssl/crypto/evp/e_des3.c

112

if (dat->stream.cbc != NULL) {

crypto/openssl/crypto/evp/e_des3.c

113

(*dat->stream.cbc)(in, out, inl, dat->ks.ks,

crypto/openssl/crypto/evp/e_des3.c

231

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_des3.c

240

dat->stream.cbc = enc ? des_t4_ede3_cbc_encrypt : des_t4_ede3_cbc_decrypt;

crypto/openssl/crypto/evp/e_des3.c

257

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_des3.c

266

dat->stream.cbc = enc ? des_t4_ede3_cbc_encrypt : des_t4_ede3_cbc_decrypt;

crypto/openssl/crypto/evp/e_des3.c

34

} stream;

crypto/openssl/crypto/evp/e_sm4.c

103

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_sm4.c

106

dat->stream.cbc = (cbc128_f)HWSM4_cbc_encrypt;

crypto/openssl/crypto/evp/e_sm4.c

111

dat->stream.ecb = (ecb128_f)HWSM4_ecb_encrypt;

crypto/openssl/crypto/evp/e_sm4.c

116

dat->stream.ctr = (ctr128_f)HWSM4_ctr32_encrypt_blocks;

crypto/openssl/crypto/evp/e_sm4.c

126

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_sm4.c

128

dat->stream.cbc = (cbc128_f)vpsm4_cbc_encrypt;

crypto/openssl/crypto/evp/e_sm4.c

130

dat->stream.ecb = (ecb128_f)vpsm4_ecb_encrypt;

crypto/openssl/crypto/evp/e_sm4.c

132

dat->stream.ctr = (ctr128_f)vpsm4_ctr32_encrypt_blocks;

crypto/openssl/crypto/evp/e_sm4.c

147

if (dat->stream.cbc)

crypto/openssl/crypto/evp/e_sm4.c

148

(*dat->stream.cbc)(in, out, len, &dat->ks.ks, ctx->iv,

crypto/openssl/crypto/evp/e_sm4.c

182

if (dat->stream.ecb != NULL)

crypto/openssl/crypto/evp/e_sm4.c

183

(*dat->stream.ecb)(in, out, len, &dat->ks.ks,

crypto/openssl/crypto/evp/e_sm4.c

215

if (dat->stream.ctr)

crypto/openssl/crypto/evp/e_sm4.c

219

&num, dat->stream.ctr);

crypto/openssl/crypto/evp/e_sm4.c

33

} stream;

crypto/openssl/crypto/evp/e_sm4.c

72

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_sm4.c

75

dat->stream.cbc = (cbc128_f)HWSM4_cbc_encrypt;

crypto/openssl/crypto/evp/e_sm4.c

79

dat->stream.ecb = (ecb128_f)HWSM4_ecb_encrypt;

crypto/openssl/crypto/evp/e_sm4.c

87

dat->stream.cbc = NULL;

crypto/openssl/crypto/evp/e_sm4.c

89

dat->stream.cbc = (cbc128_f)vpsm4_cbc_encrypt;

crypto/openssl/crypto/evp/e_sm4.c

91

dat->stream.ecb = (ecb128_f)vpsm4_ecb_encrypt;

crypto/openssl/crypto/modes/ccm128.c

312

size_t len, ccm128_f stream)

crypto/openssl/crypto/modes/ccm128.c

344

(*stream)(inp, out, n, key, ctx->nonce.c, ctx->cmac.c);

crypto/openssl/crypto/modes/ccm128.c

376

size_t len, ccm128_f stream)

crypto/openssl/crypto/modes/ccm128.c

404

(*stream)(inp, out, n, key, ctx->nonce.c, ctx->cmac.c);

crypto/openssl/crypto/modes/gcm128.c

1230

size_t len, ctr128_f stream)

crypto/openssl/crypto/modes/gcm128.c

1312

(*stream)(in, out, GHASH_CHUNK / 16, key, ctx->Yi.c);

crypto/openssl/crypto/modes/gcm128.c

1332

(*stream)(in, out, j, key, ctx->Yi.c);

crypto/openssl/crypto/modes/gcm128.c

1384

size_t len, ctr128_f stream)

crypto/openssl/crypto/modes/gcm128.c

1469

(*stream)(in, out, GHASH_CHUNK / 16, key, ctx->Yi.c);

crypto/openssl/crypto/modes/gcm128.c

1501

(*stream)(in, out, j, key, ctx->Yi.c);

crypto/openssl/crypto/modes/ocb128.c

132

ocb128_f stream)

crypto/openssl/crypto/modes/ocb128.c

139

stream);

crypto/openssl/crypto/modes/ocb128.c

153

ocb128_f stream)

crypto/openssl/crypto/modes/ocb128.c

168

ctx->stream = stream;

crypto/openssl/crypto/modes/ocb128.c

339

&& ctx->stream != NULL) {

crypto/openssl/crypto/modes/ocb128.c

351

ctx->stream(in, out, num_blocks, ctx->keyenc,

crypto/openssl/crypto/modes/ocb128.c

434

&& ctx->stream != NULL) {

crypto/openssl/crypto/modes/ocb128.c

446

ctx->stream(in, out, num_blocks, ctx->keydec,

crypto/openssl/demos/guide/quic-multi-stream.c

111

static int write_a_request(SSL *stream, const char *request_start,

crypto/openssl/demos/guide/quic-multi-stream.c

117

if (!SSL_write_ex(stream, request_start, strlen(request_start),

crypto/openssl/demos/guide/quic-multi-stream.c

120

if (!SSL_write_ex(stream, hostname, strlen(hostname), &written))

crypto/openssl/demos/guide/quic-multi-stream.c

122

if (!SSL_write_ex(stream, request_end, strlen(request_end), &written))

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

342

static int quic_server_read(nghttp3_conn *h3conn, SSL *stream, uint64_t id, struct h3ssl *h3ssl)

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

348

if (!SSL_has_pending(stream))

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

351

ret = SSL_read(stream, msg2, l);

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

354

SSL_get_error(stream, ret),

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

356

switch (SSL_get_error(stream, ret)) {

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

577

SSL *stream = SSL_accept_stream(item->desc.value.ssl, 0);

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

581

if (stream == NULL) {

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

585

new_id = SSL_get_stream_id(stream);

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

587

SSL_get_stream_type(stream));

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

588

add_id(new_id, stream, h3ssl);

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

594

if (SSL_get_stream_type(stream) == SSL_STREAM_TYPE_BIDI) {

crypto/openssl/demos/http3/ossl-nghttp3-demo-server.c

607

r = quic_server_read(h3conn, stream, new_id, h3ssl);

crypto/openssl/demos/http3/ossl-nghttp3.c

168

OSSL_DEMO_H3_STREAM *stream = stream_user_data;

crypto/openssl/demos/http3/ossl-nghttp3.c

174

h3_conn_remove_stream(conn, stream);

crypto/openssl/demos/http3/ossl-nghttp3.c

184

OSSL_DEMO_H3_STREAM *stream = stream_user_data;

crypto/openssl/demos/http3/ossl-nghttp3.c

190

SSL_free(stream->s);

crypto/openssl/demos/http3/ossl-nghttp3.c

191

stream->s = NULL;

crypto/openssl/demos/http3/ossl-nghttp3.c

201

OSSL_DEMO_H3_STREAM *stream = stream_user_data;

crypto/openssl/demos/http3/ossl-nghttp3.c

208

if (stream->s != NULL) {

crypto/openssl/demos/http3/ossl-nghttp3.c

211

if (!SSL_stream_reset(stream->s, &args, sizeof(args)))

crypto/openssl/demos/http3/ossl-nghttp3.h

109

void *OSSL_DEMO_H3_STREAM_get_user_data(const OSSL_DEMO_H3_STREAM *stream);

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

152

conn->stream = (uv_stream_t *)&conn->tcp;

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

232

uv_close((uv_handle_t *)conn->stream, teardown_continued);

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

351

static void net_read_done(uv_udp_t *stream, ssize_t nr, const uv_buf_t *buf,

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

354

static void net_read_done(uv_stream_t *stream, ssize_t nr, const uv_buf_t *buf)

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

358

APP_CONN *conn = (APP_CONN *)stream->data;

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

397

uv_read_start(conn->stream, net_read_alloc, net_read_done);

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

399

uv_read_stop(conn->stream);

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

452

rc = uv_write(&op->w, conn->stream, &op->b, 1, net_write_done);

crypto/openssl/doc/designs/ddd/ddd-06-mem-uv.c

78

uv_stream_t *stream;

crypto/openssl/fuzz/quic-client.c

119

allstreams[0] = stream = client;

crypto/openssl/fuzz/quic-client.c

157

ret = SSL_do_handshake(stream);

crypto/openssl/fuzz/quic-client.c

163

ret = SSL_read(stream, tmp, sizeof(tmp));

crypto/openssl/fuzz/quic-client.c

172

ret = SSL_write(stream, tmp, writelen);

crypto/openssl/fuzz/quic-client.c

184

stream = allstreams[numstreams++]

crypto/openssl/fuzz/quic-client.c

186

if (stream == NULL)

crypto/openssl/fuzz/quic-client.c

195

stream = SSL_new_stream(client, 0);

crypto/openssl/fuzz/quic-client.c

196

if (stream == NULL) {

crypto/openssl/fuzz/quic-client.c

198

stream = allstreams[thisstream];

crypto/openssl/fuzz/quic-client.c

202

allstreams[numstreams++] = stream;

crypto/openssl/fuzz/quic-client.c

212

stream = allstreams[thisstream];

crypto/openssl/fuzz/quic-client.c

215

assert(stream != NULL);

crypto/openssl/fuzz/quic-client.c

218

switch (SSL_get_error(stream, ret)) {

crypto/openssl/fuzz/quic-client.c

55

SSL *client = NULL, *stream = NULL;

crypto/openssl/fuzz/quic-server.c

148

ret = SSL_accept_connection(stream, 0) != NULL;

crypto/openssl/fuzz/quic-server.c

154

ret = SSL_read(stream, tmp, sizeof(tmp));

crypto/openssl/fuzz/quic-server.c

163

ret = SSL_write(stream, tmp, writelen);

crypto/openssl/fuzz/quic-server.c

175

stream = allstreams[numstreams++] = SSL_accept_stream(server, 0);

crypto/openssl/fuzz/quic-server.c

176

if (stream == NULL)

crypto/openssl/fuzz/quic-server.c

185

stream = SSL_new_stream(server, 0);

crypto/openssl/fuzz/quic-server.c

186

if (stream == NULL) {

crypto/openssl/fuzz/quic-server.c

188

stream = allstreams[thisstream];

crypto/openssl/fuzz/quic-server.c

192

allstreams[numstreams++] = stream;

crypto/openssl/fuzz/quic-server.c

202

stream = allstreams[thisstream];

crypto/openssl/fuzz/quic-server.c

205

assert(stream != NULL);

crypto/openssl/fuzz/quic-server.c

208

switch (SSL_get_error(stream, ret)) {

crypto/openssl/fuzz/quic-server.c

66

SSL *server = NULL, *stream = NULL;

crypto/openssl/fuzz/quic-server.c

87

allstreams[0] = stream = server;

crypto/openssl/include/crypto/modes.h

191

ocb128_f stream; /* direction dependent */

crypto/openssl/include/internal/quic_ssl.h

111

__owur int ossl_quic_attach_stream(SSL *conn, SSL *stream);

crypto/openssl/include/internal/quic_stream_map.h

612

void ossl_quic_stream_map_release(QUIC_STREAM_MAP *qsm, QUIC_STREAM *stream);

crypto/openssl/include/internal/quic_stream_map.h

619

void (*visit_cb)(QUIC_STREAM *stream, void *arg),

crypto/openssl/include/internal/quic_stream_map.h

896

QUIC_STREAM *first_stream, *stream;

crypto/openssl/include/openssl/bio.h

729

BIO *BIO_new_fp(FILE *stream, int close_flag);

crypto/openssl/include/openssl/modes.h

130

size_t len, ctr128_f stream);

crypto/openssl/include/openssl/modes.h

133

size_t len, ctr128_f stream);

crypto/openssl/include/openssl/modes.h

154

ccm128_f stream);

crypto/openssl/include/openssl/modes.h

157

ccm128_f stream);

crypto/openssl/include/openssl/modes.h

195

ocb128_f stream);

crypto/openssl/include/openssl/modes.h

198

ocb128_f stream);

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

63

IMPLEMENT_generic_cipher(aes, AES, ofb, OFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

65

IMPLEMENT_generic_cipher(aes, AES, ofb, OFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

67

IMPLEMENT_generic_cipher(aes, AES, ofb, OFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

69

IMPLEMENT_generic_cipher(aes, AES, cfb, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

71

IMPLEMENT_generic_cipher(aes, AES, cfb, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

73

IMPLEMENT_generic_cipher(aes, AES, cfb, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

75

IMPLEMENT_generic_cipher(aes, AES, cfb1, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

77

IMPLEMENT_generic_cipher(aes, AES, cfb1, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

79

IMPLEMENT_generic_cipher(aes, AES, cfb1, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

81

IMPLEMENT_generic_cipher(aes, AES, cfb8, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

83

IMPLEMENT_generic_cipher(aes, AES, cfb8, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

85

IMPLEMENT_generic_cipher(aes, AES, cfb8, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

87

IMPLEMENT_generic_cipher(aes, AES, ctr, CTR, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

89

IMPLEMENT_generic_cipher(aes, AES, ctr, CTR, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes.c

91

IMPLEMENT_generic_cipher(aes, AES, ctr, CTR, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

103

dat->stream.cbc = (dat->mode == EVP_CIPH_CBC_MODE)

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

111

dat->stream.cbc = (dat->mode == EVP_CIPH_CBC_MODE)

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

116

dat->stream.ctr = (ctr128_f)AES_ctr32_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

34

dat->stream.cbc = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

37

dat->stream.cbc = (cbc128_f)HWAES_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

41

dat->stream.ecb = (ecb128_f)HWAES_ecb_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

49

dat->stream.cbc = (cbc128_f)ossl_bsaes_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

56

dat->stream.cbc = (dat->mode == EVP_CIPH_CBC_MODE)

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

64

dat->stream.cbc = (dat->mode == EVP_CIPH_CBC_MODE)

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

73

dat->stream.cbc = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

76

dat->stream.cbc = (cbc128_f)HWAES_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

81

dat->stream.ecb = (ecb128_f)HWAES_ecb_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

86

dat->stream.ctr = (ctr128_f)HWAES_ctr32_encrypt_blocks;

crypto/openssl/providers/implementations/ciphers/cipher_aes_hw.c

96

dat->stream.ctr = (ctr128_f)ossl_bsaes_ctr32_encrypt_blocks;

crypto/openssl/providers/implementations/ciphers/cipher_aes_xts.c

206

if (ctx->stream != NULL)

crypto/openssl/providers/implementations/ciphers/cipher_aes_xts.c

207

(*ctx->stream)(in, out, inl, ctx->xts.key1, ctx->xts.key2, ctx->base.iv);

crypto/openssl/providers/implementations/ciphers/cipher_aes_xts.h

40

OSSL_xts_stream_fn stream;

crypto/openssl/providers/implementations/ciphers/cipher_aes_xts_hw.c

36

xctx->stream = ctx->enc ? fn_stream_enc : fn_stream_dec; \

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

56

IMPLEMENT_generic_cipher(aria, ARIA, ofb, OFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

58

IMPLEMENT_generic_cipher(aria, ARIA, ofb, OFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

60

IMPLEMENT_generic_cipher(aria, ARIA, ofb, OFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

62

IMPLEMENT_generic_cipher(aria, ARIA, cfb, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

64

IMPLEMENT_generic_cipher(aria, ARIA, cfb, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

66

IMPLEMENT_generic_cipher(aria, ARIA, cfb, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

68

IMPLEMENT_generic_cipher(aria, ARIA, cfb1, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

70

IMPLEMENT_generic_cipher(aria, ARIA, cfb1, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

72

IMPLEMENT_generic_cipher(aria, ARIA, cfb1, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

74

IMPLEMENT_generic_cipher(aria, ARIA, cfb8, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

76

IMPLEMENT_generic_cipher(aria, ARIA, cfb8, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

78

IMPLEMENT_generic_cipher(aria, ARIA, cfb8, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

80

IMPLEMENT_generic_cipher(aria, ARIA, ctr, CTR, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

82

IMPLEMENT_generic_cipher(aria, ARIA, ctr, CTR, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_aria.c

84

IMPLEMENT_generic_cipher(aria, ARIA, ctr, CTR, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_blowfish.c

56

IMPLEMENT_var_keylen_cipher(blowfish, BLOWFISH, ofb64, OFB, BF_FLAGS, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_blowfish.c

58

IMPLEMENT_var_keylen_cipher(blowfish, BLOWFISH, cfb64, CFB, BF_FLAGS, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

62

IMPLEMENT_generic_cipher(camellia, CAMELLIA, ofb, OFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

64

IMPLEMENT_generic_cipher(camellia, CAMELLIA, ofb, OFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

66

IMPLEMENT_generic_cipher(camellia, CAMELLIA, ofb, OFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

68

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

70

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

72

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

74

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb1, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

76

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb1, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

78

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb1, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

80

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb8, CFB, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

82

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb8, CFB, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

84

IMPLEMENT_generic_cipher(camellia, CAMELLIA, cfb8, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

86

IMPLEMENT_generic_cipher(camellia, CAMELLIA, ctr, CTR, 0, 256, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

88

IMPLEMENT_generic_cipher(camellia, CAMELLIA, ctr, CTR, 0, 192, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia.c

90

IMPLEMENT_generic_cipher(camellia, CAMELLIA, ctr, CTR, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_camellia_hw.c

35

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)Camellia_cbc_encrypt : NULL;

crypto/openssl/providers/implementations/ciphers/cipher_camellia_hw.c

38

dat->stream.cbc = mode == EVP_CIPH_CBC_MODE ? (cbc128_f)Camellia_cbc_encrypt : NULL;

crypto/openssl/providers/implementations/ciphers/cipher_cast5.c

57

IMPLEMENT_var_keylen_cipher(cast5, CAST, ofb64, OFB, CAST5_FLAGS, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_cast5.c

59

IMPLEMENT_var_keylen_cipher(cast5, CAST, cfb64, CFB, CAST5_FLAGS, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_des.c

195

IMPLEMENT_des_cipher(des, ofb64, OFB, DES_FLAGS, 64, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_des.c

197

IMPLEMENT_des_cipher(des, cfb64, CFB, DES_FLAGS, 64, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_des.c

199

IMPLEMENT_des_cipher(des, cfb1, CFB, DES_FLAGS, 64, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_des.c

201

IMPLEMENT_des_cipher(des, cfb8, CFB, DES_FLAGS, 64, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_idea.c

55

IMPLEMENT_generic_cipher(idea, IDEA, ofb64, OFB, 0, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_idea.c

57

IMPLEMENT_generic_cipher(idea, IDEA, cfb64, CFB, 0, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_rc2.c

293

IMPLEMENT_cipher(rc2, RC2, ofb128, OFB, RC2_FLAGS, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_rc2.c

295

IMPLEMENT_cipher(rc2, RC2, cfb128, CFB, RC2_FLAGS, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_rc4.c

117

IMPLEMENT_cipher(rc4, RC4, RC4_FLAGS, 40, 8, 0, stream)

crypto/openssl/providers/implementations/ciphers/cipher_rc4.c

119

IMPLEMENT_cipher(rc4, RC4, RC4_FLAGS, 128, 8, 0, stream)

crypto/openssl/providers/implementations/ciphers/cipher_rc5.c

183

IMPLEMENT_cipher(rc5, RC5, ofb64, OFB, RC5_FLAGS, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_rc5.c

185

IMPLEMENT_cipher(rc5, RC5, cfb64, CFB, RC5_FLAGS, 128, 8, 64, stream)

crypto/openssl/providers/implementations/ciphers/cipher_seed.c

54

IMPLEMENT_generic_cipher(seed, SEED, ofb128, OFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_seed.c

56

IMPLEMENT_generic_cipher(seed, SEED, cfb128, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_sm4.c

48

IMPLEMENT_generic_cipher(sm4, SM4, ctr, CTR, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_sm4.c

50

IMPLEMENT_generic_cipher(sm4, SM4, ofb128, OFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_sm4.c

52

IMPLEMENT_generic_cipher(sm4, SM4, cfb128, CFB, 0, 128, 8, 128, stream)

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

106

ctx->stream.cbc = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

108

ctx->stream.cbc = (cbc128_f)vpsm4_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

110

ctx->stream.ecb = (ecb128_f)vpsm4_ecb_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

26

ctx->stream.cbc = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

29

ctx->stream.cbc = (cbc128_f)HWSM4_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

34

ctx->stream.ecb = (ecb128_f)HWSM4_ecb_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

39

ctx->stream.ctr = (ctr128_f)HWSM4_ctr32_encrypt_blocks;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

49

ctx->stream.cbc = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

51

ctx->stream.cbc = (cbc128_f)vpsm4_ex_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

53

ctx->stream.ecb = (ecb128_f)vpsm4_ex_ecb_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

55

ctx->stream.ctr = (ctr128_f)vpsm4_ex_ctr32_encrypt_blocks;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

62

ctx->stream.cbc = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

64

ctx->stream.cbc = (cbc128_f)vpsm4_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

66

ctx->stream.ecb = (ecb128_f)vpsm4_ecb_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

68

ctx->stream.ctr = (ctr128_f)vpsm4_ctr32_encrypt_blocks;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

80

ctx->stream.cbc = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

83

ctx->stream.cbc = (cbc128_f)HWSM4_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

87

ctx->stream.ecb = (ecb128_f)HWSM4_ecb_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

95

ctx->stream.cbc = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

97

ctx->stream.cbc = (cbc128_f)vpsm4_ex_cbc_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_hw.c

99

ctx->stream.ecb = (ecb128_f)vpsm4_ex_ecb_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts.c

146

if (ctx->stream != NULL)

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts.c

147

(*ctx->stream)(in, out, inl, ctx->xts.key1, ctx->xts.key2,

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts.h

43

OSSL_xts_stream_fn stream;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts_hw.c

29

xctx->stream = fn_stream; \

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts_hw.c

38

OSSL_xts_stream_fn stream = NULL;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts_hw.c

43

HWSM4_encrypt, HWSM4_decrypt, stream, stream_gb);

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts_hw.c

49

stream = vpsm4_ex_xts_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts_hw.c

52

vpsm4_ex_encrypt, vpsm4_ex_decrypt, stream, stream_gb);

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts_hw.c

58

stream = vpsm4_xts_encrypt;

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts_hw.c

61

vpsm4_encrypt, vpsm4_decrypt, stream, stream_gb);

crypto/openssl/providers/implementations/ciphers/cipher_sm4_xts_hw.c

70

ossl_sm4_decrypt, stream, stream_gb);

crypto/openssl/providers/implementations/ciphers/cipher_tdes_default.c

20

IMPLEMENT_tdes_cipher(ede3, EDE3, ofb, OFB, TDES_FLAGS, 64 * 3, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_tdes_default.c

22

IMPLEMENT_tdes_cipher(ede3, EDE3, cfb, CFB, TDES_FLAGS, 64 * 3, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_tdes_default.c

24

IMPLEMENT_tdes_cipher(ede3, EDE3, cfb1, CFB, TDES_FLAGS, 64 * 3, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_tdes_default.c

26

IMPLEMENT_tdes_cipher(ede3, EDE3, cfb8, CFB, TDES_FLAGS, 64 * 3, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_tdes_default.c

33

IMPLEMENT_tdes_cipher(ede2, EDE2, ofb, OFB, TDES_FLAGS, 64 * 2, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/cipher_tdes_default.c

35

IMPLEMENT_tdes_cipher(ede2, EDE2, cfb, CFB, TDES_FLAGS, 64 * 2, 8, 64, stream);

crypto/openssl/providers/implementations/ciphers/ciphercommon_hw.c

115

if (dat->stream.ctr)

crypto/openssl/providers/implementations/ciphers/ciphercommon_hw.c

117

&num, dat->stream.ctr);

crypto/openssl/providers/implementations/ciphers/ciphercommon_hw.c

19

if (dat->stream.cbc)

crypto/openssl/providers/implementations/ciphers/ciphercommon_hw.c

20

(*dat->stream.cbc)(in, out, len, dat->ks, dat->iv, dat->enc);

crypto/openssl/providers/implementations/ciphers/ciphercommon_hw.c

37

if (dat->stream.ecb) {

crypto/openssl/providers/implementations/ciphers/ciphercommon_hw.c

38

(*dat->stream.ecb)(in, out, len, dat->ks, dat->enc);

crypto/openssl/providers/implementations/include/prov/ciphercommon.h

61

} stream;

crypto/openssl/ssl/quic/quic_impl.c

2232

xso->stream = qs;

crypto/openssl/ssl/quic/quic_impl.c

2455

xso->stream);

crypto/openssl/ssl/quic/quic_impl.c

2458

ossl_quic_sstream_fin(xso->stream->sstream);

crypto/openssl/ssl/quic/quic_impl.c

2517

QUIC_SSTREAM *sstream = xso->stream->sstream;

crypto/openssl/ssl/quic/quic_impl.c

2519

uint64_t cwm = ossl_quic_txfc_get_cwm(&xso->stream->txfc);

crypto/openssl/ssl/quic/quic_impl.c

2766

if (xso == NULL || xso->stream == NULL) {

crypto/openssl/ssl/quic/quic_impl.c

2771

switch (xso->stream->send_state) {

crypto/openssl/ssl/quic/quic_impl.c

2780

if (!ossl_quic_stream_map_ensure_send_part_id(qsm, xso->stream)) {

crypto/openssl/ssl/quic/quic_impl.c

2788

if (ossl_quic_sstream_get_final_size(xso->stream->sstream, NULL)) {

crypto/openssl/ssl/quic/quic_impl.c

2888

QUIC_STREAM *stream;

crypto/openssl/ssl/quic/quic_impl.c

2902

if (xso == NULL || xso->stream == NULL) {

crypto/openssl/ssl/quic/quic_impl.c

2907

switch (xso->stream->recv_state) {

crypto/openssl/ssl/quic/quic_impl.c

2924

ossl_quic_stream_map_notify_app_read_reset_recv_part(qsm, xso->stream);

crypto/openssl/ssl/quic/quic_impl.c

2935

QUIC_STREAM *stream,

crypto/openssl/ssl/quic/quic_impl.c

2953

if (!ossl_quic_rstream_peek(stream->rstream, buf, buf_len,

crypto/openssl/ssl/quic/quic_impl.c

2958

if (!ossl_quic_rstream_read(stream->rstream, buf, buf_len,

crypto/openssl/ssl/quic/quic_impl.c

2975

if (!ossl_quic_rxfc_on_retire(&stream->rxfc, *bytes_read,

crypto/openssl/ssl/quic/quic_impl.c

2983

ossl_quic_stream_map_notify_totally_read(qsm, ctx->xso->stream);

crypto/openssl/ssl/quic/quic_impl.c

2988

stream);

crypto/openssl/ssl/quic/quic_impl.c

3010

if (!quic_read_actual(args->ctx, args->stream,

crypto/openssl/ssl/quic/quic_impl.c

3057

if (!quic_read_actual(&ctx, ctx.xso->stream, buf, len, bytes_read, peek)) {

crypto/openssl/ssl/quic/quic_impl.c

3081

args.stream = ctx.xso->stream;

crypto/openssl/ssl/quic/quic_impl.c

3105

if (!quic_read_actual(&ctx, ctx.xso->stream, buf, len, bytes_read, peek)) {

crypto/openssl/ssl/quic/quic_impl.c

3160

if (ctx.xso->stream == NULL) {

crypto/openssl/ssl/quic/quic_impl.c

3166

avail = ossl_quic_stream_recv_pending(ctx.xso->stream,

crypto/openssl/ssl/quic/quic_impl.c

3171

avail = ossl_quic_stream_recv_pending(ctx.xso->stream,

crypto/openssl/ssl/quic/quic_impl.c

3205

qs = ctx.xso->stream;

crypto/openssl/ssl/quic/quic_impl.c

3349

if (ossl_quic_stream_is_bidi(ctx.xso->stream))

crypto/openssl/ssl/quic/quic_impl.c

3352

if (ossl_quic_stream_is_server_init(ctx.xso->stream) != ctx.qc->as_server)

crypto/openssl/ssl/quic/quic_impl.c

3371

id = ctx.xso->stream->id;

crypto/openssl/ssl/quic/quic_impl.c

3390

is_local = ossl_quic_stream_is_local_init(ctx.xso->stream);

crypto/openssl/ssl/quic/quic_impl.c

3461

int ossl_quic_attach_stream(SSL *conn, SSL *stream)

crypto/openssl/ssl/quic/quic_impl.c

3470

if (stream == NULL || stream->type != SSL_TYPE_QUIC_XSO)

crypto/openssl/ssl/quic/quic_impl.c

3474

xso = (QUIC_XSO *)stream;

crypto/openssl/ssl/quic/quic_impl.c

3751

if (!ossl_quic_stream_has_send(ctx->xso->stream)) {

crypto/openssl/ssl/quic/quic_impl.c

3756

if (ossl_quic_stream_has_send_buffer(ctx->xso->stream))

crypto/openssl/ssl/quic/quic_impl.c

3757

value = getter(ctx->xso->stream->sstream);

crypto/openssl/ssl/quic/quic_impl.c

3983

qs = ctx.xso->stream;

crypto/openssl/ssl/quic/quic_impl.c

4071

quic_classify_stream(ctx.qc, ctx.xso->stream, is_write, &state, NULL);

crypto/openssl/ssl/quic/quic_impl.c

4103

quic_classify_stream(ctx.qc, ctx.xso->stream, is_write,

crypto/openssl/ssl/quic/quic_impl.c

4144

if (!ossl_quic_stream_has_send(ctx.xso->stream)) {

crypto/openssl/ssl/quic/quic_impl.c

4150

if (!ossl_quic_stream_has_send_buffer(ctx.xso->stream)) {

crypto/openssl/ssl/quic/quic_impl.c

4159

if (!ossl_quic_sstream_set_buffer_size(ctx.xso->stream->sstream, size)) {

crypto/openssl/ssl/quic/quic_impl.c

5166

if (xso->stream->recv_state == QUIC_RSTREAM_STATE_DATA_READ)

crypto/openssl/ssl/quic/quic_impl.c

5169

return ossl_quic_stream_has_recv_buffer(xso->stream)

crypto/openssl/ssl/quic/quic_impl.c

5170

&& ossl_quic_rstream_available(xso->stream->rstream, &avail, &fin)

crypto/openssl/ssl/quic/quic_impl.c

5178

return ossl_quic_stream_has_recv(xso->stream)

crypto/openssl/ssl/quic/quic_impl.c

5179

&& ossl_quic_stream_recv_is_reset(xso->stream)

crypto/openssl/ssl/quic/quic_impl.c

5188

&& ossl_quic_stream_has_send_buffer(xso->stream)

crypto/openssl/ssl/quic/quic_impl.c

5189

&& ossl_quic_sstream_get_buffer_avail(xso->stream->sstream)

crypto/openssl/ssl/quic/quic_impl.c

5190

&& !ossl_quic_sstream_get_final_size(xso->stream->sstream, NULL)

crypto/openssl/ssl/quic/quic_impl.c

5191

&& ossl_quic_txfc_get_cwm(&xso->stream->txfc)

crypto/openssl/ssl/quic/quic_impl.c

5192

> ossl_quic_sstream_get_cur_size(xso->stream->sstream)

crypto/openssl/ssl/quic/quic_impl.c

5200

return ossl_quic_stream_has_send(xso->stream)

crypto/openssl/ssl/quic/quic_impl.c

5201

&& xso->stream->peer_stop_sending

crypto/openssl/ssl/quic/quic_impl.c

781

if ((ctx.xso->stream->send_state == QUIC_SSTREAM_STATE_READY

crypto/openssl/ssl/quic/quic_impl.c

782

|| ctx.xso->stream->send_state == QUIC_SSTREAM_STATE_SEND)

crypto/openssl/ssl/quic/quic_impl.c

783

&& !ossl_quic_sstream_get_final_size(ctx.xso->stream->sstream, NULL))

crypto/openssl/ssl/quic/quic_impl.c

785

ctx.xso->stream, 0);

crypto/openssl/ssl/quic/quic_impl.c

788

if (ctx.xso->stream->recv_state == QUIC_RSTREAM_STATE_RECV

crypto/openssl/ssl/quic/quic_impl.c

789

|| ctx.xso->stream->recv_state == QUIC_RSTREAM_STATE_SIZE_KNOWN)

crypto/openssl/ssl/quic/quic_impl.c

791

ctx.xso->stream, 0);

crypto/openssl/ssl/quic/quic_impl.c

794

ctx.xso->stream->deleted = 1;

crypto/openssl/ssl/quic/quic_impl.c

796

ctx.xso->stream);

crypto/openssl/ssl/quic/quic_impl.c

991

if (xso->stream->rstream != NULL)

crypto/openssl/ssl/quic/quic_impl.c

992

ossl_quic_rstream_set_cleanse(xso->stream->rstream, cleanse);

crypto/openssl/ssl/quic/quic_impl.c

994

if (xso->stream->sstream != NULL)

crypto/openssl/ssl/quic/quic_impl.c

995

ossl_quic_sstream_set_cleanse(xso->stream->sstream, cleanse);

crypto/openssl/ssl/quic/quic_local.h

43

QUIC_STREAM *stream;

crypto/openssl/ssl/quic/quic_rx_depack.c

147

QUIC_STREAM *stream = NULL;

crypto/openssl/ssl/quic/quic_rx_depack.c

160

&stream))

crypto/openssl/ssl/quic/quic_rx_depack.c

163

if (stream == NULL)

crypto/openssl/ssl/quic/quic_rx_depack.c

166

if (!ossl_quic_stream_has_recv(stream)) {

crypto/openssl/ssl/quic/quic_rx_depack.c

185

if (!ossl_quic_rxfc_on_rx_stream_frame(&stream->rxfc,

crypto/openssl/ssl/quic/quic_rx_depack.c

195

fce = ossl_quic_rxfc_get_error(&stream->rxfc, 0);

crypto/openssl/ssl/quic/quic_rx_depack.c

210

ossl_quic_stream_map_notify_reset_recv_part(&ch->qsm, stream,

crypto/openssl/ssl/quic/quic_rx_depack.c

214

ossl_quic_stream_map_update_state(&ch->qsm, stream);

crypto/openssl/ssl/quic/quic_rx_depack.c

223

QUIC_STREAM *stream = NULL;

crypto/openssl/ssl/quic/quic_rx_depack.c

235

&stream))

crypto/openssl/ssl/quic/quic_rx_depack.c

238

if (stream == NULL)

crypto/openssl/ssl/quic/quic_rx_depack.c

241

if (!ossl_quic_stream_has_send(stream)) {

crypto/openssl/ssl/quic/quic_rx_depack.c

250

stream->peer_stop_sending = 1;

crypto/openssl/ssl/quic/quic_rx_depack.c

251

stream->peer_stop_sending_aec = frame_data.app_error_code;

crypto/openssl/ssl/quic/quic_rx_depack.c

258

ossl_quic_stream_map_reset_stream_send_part(&ch->qsm, stream,

crypto/openssl/ssl/quic/quic_rx_depack.c

372

QUIC_STREAM *stream;

crypto/openssl/ssl/quic/quic_rx_depack.c

378

stream = ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id);

crypto/openssl/ssl/quic/quic_rx_depack.c

379

if (stream != NULL) {

crypto/openssl/ssl/quic/quic_rx_depack.c

380

*result = stream;

crypto/openssl/ssl/quic/quic_rx_depack.c

452

stream = ossl_quic_channel_new_stream_remote(ch, cur_stream_id);

crypto/openssl/ssl/quic/quic_rx_depack.c

453

if (stream == NULL) {

crypto/openssl/ssl/quic/quic_rx_depack.c

464

*result = stream;

crypto/openssl/ssl/quic/quic_rx_depack.c

503

QUIC_STREAM *stream;

crypto/openssl/ssl/quic/quic_rx_depack.c

519

frame_type, &stream))

crypto/openssl/ssl/quic/quic_rx_depack.c

522

if (stream == NULL)

crypto/openssl/ssl/quic/quic_rx_depack.c

529

if (!ossl_quic_stream_has_recv(stream)) {

crypto/openssl/ssl/quic/quic_rx_depack.c

539

if (!ossl_quic_rxfc_on_rx_stream_frame(&stream->rxfc,

crypto/openssl/ssl/quic/quic_rx_depack.c

550

fce = ossl_quic_rxfc_get_error(&stream->rxfc, 0);

crypto/openssl/ssl/quic/quic_rx_depack.c

559

switch (stream->recv_state) {

crypto/openssl/ssl/quic/quic_rx_depack.c

582

&& !ossl_quic_stream_recv_get_final_size(stream, NULL)) {

crypto/openssl/ssl/quic/quic_rx_depack.c

585

ossl_quic_stream_map_notify_size_known_recv_part(&ch->qsm, stream,

crypto/openssl/ssl/quic/quic_rx_depack.c

595

if (stream->stop_sending)

crypto/openssl/ssl/quic/quic_rx_depack.c

609

&& !ossl_quic_rstream_queue_data(stream->rstream, parent_pkt,

crypto/openssl/ssl/quic/quic_rx_depack.c

627

if (stream->recv_state == QUIC_RSTREAM_STATE_SIZE_KNOWN

crypto/openssl/ssl/quic/quic_rx_depack.c

628

&& !ossl_quic_rstream_available(stream->rstream, &rs_avail, &rs_fin)) {

crypto/openssl/ssl/quic/quic_rx_depack.c

637

ossl_quic_stream_map_notify_totally_received(&ch->qsm, stream);

crypto/openssl/ssl/quic/quic_rx_depack.c

695

QUIC_STREAM *stream;

crypto/openssl/ssl/quic/quic_rx_depack.c

708

&stream))

crypto/openssl/ssl/quic/quic_rx_depack.c

711

if (stream == NULL)

crypto/openssl/ssl/quic/quic_rx_depack.c

714

if (!ossl_quic_stream_has_send(stream)) {

crypto/openssl/ssl/quic/quic_rx_depack.c

723

ossl_quic_txfc_bump_cwm(&stream->txfc, max_stream_data);

crypto/openssl/ssl/quic/quic_rx_depack.c

724

ossl_quic_stream_map_update_state(&ch->qsm, stream);

crypto/openssl/ssl/quic/quic_rx_depack.c

801

QUIC_STREAM *stream;

crypto/openssl/ssl/quic/quic_rx_depack.c

818

&stream))

crypto/openssl/ssl/quic/quic_rx_depack.c

821

if (stream == NULL)

crypto/openssl/ssl/quic/quic_rx_depack.c

824

if (!ossl_quic_stream_has_recv(stream)) {

crypto/openssl/ssl/quic/quic_stream_map.c

116

static void release_each(QUIC_STREAM *stream, void *arg)

crypto/openssl/ssl/quic/quic_stream_map.c

120

ossl_quic_stream_map_release(qsm, stream);

crypto/openssl/ssl/quic/quic_stream_map.c

133

void (*visit_cb)(QUIC_STREAM *stream, void *arg),

crypto/openssl/ssl/quic/quic_stream_map.c

174

void ossl_quic_stream_map_release(QUIC_STREAM_MAP *qsm, QUIC_STREAM *stream)

crypto/openssl/ssl/quic/quic_stream_map.c

176

if (stream == NULL)

crypto/openssl/ssl/quic/quic_stream_map.c

179

if (stream->active_node.next != NULL)

crypto/openssl/ssl/quic/quic_stream_map.c

180

list_remove(&qsm->active_list, &stream->active_node);

crypto/openssl/ssl/quic/quic_stream_map.c

181

if (stream->accept_node.next != NULL)

crypto/openssl/ssl/quic/quic_stream_map.c

182

list_remove(&qsm->accept_list, &stream->accept_node);

crypto/openssl/ssl/quic/quic_stream_map.c

183

if (stream->ready_for_gc_node.next != NULL)

crypto/openssl/ssl/quic/quic_stream_map.c

184

list_remove(&qsm->ready_for_gc_list, &stream->ready_for_gc_node);

crypto/openssl/ssl/quic/quic_stream_map.c

186

ossl_quic_sstream_free(stream->sstream);

crypto/openssl/ssl/quic/quic_stream_map.c

187

stream->sstream = NULL;

crypto/openssl/ssl/quic/quic_stream_map.c

189

ossl_quic_rstream_free(stream->rstream);

crypto/openssl/ssl/quic/quic_stream_map.c

190

stream->rstream = NULL;

crypto/openssl/ssl/quic/quic_stream_map.c

192

lh_QUIC_STREAM_delete(qsm->map, stream);

crypto/openssl/ssl/quic/quic_stream_map.c

193

OPENSSL_free(stream);

crypto/openssl/ssl/quic/quic_stream_map.c

838

it->stream = it->first_stream = qsm->rr_cur;

crypto/openssl/ssl/quic/quic_stream_map.c

839

if (advance_rr && it->stream != NULL

crypto/openssl/ssl/quic/quic_stream_map.c

848

if (it->stream == NULL)

crypto/openssl/ssl/quic/quic_stream_map.c

851

it->stream = active_next(&it->qsm->active_list, it->stream);

crypto/openssl/ssl/quic/quic_stream_map.c

852

if (it->stream == it->first_stream)

crypto/openssl/ssl/quic/quic_stream_map.c

853

it->stream = NULL;

crypto/openssl/ssl/quic/quic_txp.c

1573

if (it.stream != NULL)

crypto/openssl/ssl/quic/quic_txp.c

2479

static void txp_enlink_tmp(QUIC_STREAM **tmp_head, QUIC_STREAM *stream)

crypto/openssl/ssl/quic/quic_txp.c

2481

stream->txp_next = *tmp_head;

crypto/openssl/ssl/quic/quic_txp.c

2482

*tmp_head = stream;

crypto/openssl/ssl/quic/quic_txp.c

2493

QUIC_STREAM *stream, *snext;

crypto/openssl/ssl/quic/quic_txp.c

2498

it.stream != NULL;) {

crypto/openssl/ssl/quic/quic_txp.c

2500

stream = it.stream;

crypto/openssl/ssl/quic/quic_txp.c

2502

snext = it.stream;

crypto/openssl/ssl/quic/quic_txp.c

2504

stream->txp_sent_fc = 0;

crypto/openssl/ssl/quic/quic_txp.c

2505

stream->txp_sent_stop_sending = 0;

crypto/openssl/ssl/quic/quic_txp.c

2506

stream->txp_sent_reset_stream = 0;

crypto/openssl/ssl/quic/quic_txp.c

2507

stream->txp_blocked = 0;

crypto/openssl/ssl/quic/quic_txp.c

2508

stream->txp_txfc_new_credit_consumed = 0;

crypto/openssl/ssl/quic/quic_txp.c

2511

if (stream->want_stop_sending) {

crypto/openssl/ssl/quic/quic_txp.c

2518

f.stream_id = stream->id;

crypto/openssl/ssl/quic/quic_txp.c

2519

f.app_error_code = stream->stop_sending_aec;

crypto/openssl/ssl/quic/quic_txp.c

2522

txp_enlink_tmp(tmp_head, stream);

crypto/openssl/ssl/quic/quic_txp.c

2531

stream->txp_sent_stop_sending = 1;

crypto/openssl/ssl/quic/quic_txp.c

2534

if (stream->want_reset_stream) {

crypto/openssl/ssl/quic/quic_txp.c

2537

if (!ossl_assert(stream->send_state == QUIC_SSTREAM_STATE_RESET_SENT))

crypto/openssl/ssl/quic/quic_txp.c

2544

f.stream_id = stream->id;

crypto/openssl/ssl/quic/quic_txp.c

2545

f.app_error_code = stream->reset_stream_aec;

crypto/openssl/ssl/quic/quic_txp.c

2546

if (!ossl_quic_stream_send_get_final_size(stream, &f.final_size))

crypto/openssl/ssl/quic/quic_txp.c

2551

txp_enlink_tmp(tmp_head, stream);

crypto/openssl/ssl/quic/quic_txp.c

2560

stream->txp_sent_reset_stream = 1;

crypto/openssl/ssl/quic/quic_txp.c

2568

if (!ossl_assert(f.final_size <= ossl_quic_txfc_get_swm(&stream->txfc)))

crypto/openssl/ssl/quic/quic_txp.c

2571

stream->txp_txfc_new_credit_consumed

crypto/openssl/ssl/quic/quic_txp.c

2572

= f.final_size - ossl_quic_txfc_get_swm(&stream->txfc);

crypto/openssl/ssl/quic/quic_txp.c

2583

if (stream->recv_state == QUIC_RSTREAM_STATE_RECV

crypto/openssl/ssl/quic/quic_txp.c

2584

&& (stream->want_max_stream_data

crypto/openssl/ssl/quic/quic_txp.c

2585

|| ossl_quic_rxfc_has_cwm_changed(&stream->rxfc, 0))) {

crypto/openssl/ssl/quic/quic_txp.c

2591

cwm = ossl_quic_rxfc_get_cwm(&stream->rxfc);

crypto/openssl/ssl/quic/quic_txp.c

2593

if (!ossl_quic_wire_encode_frame_max_stream_data(wpkt, stream->id,

crypto/openssl/ssl/quic/quic_txp.c

2596

txp_enlink_tmp(tmp_head, stream);

crypto/openssl/ssl/quic/quic_txp.c

2605

stream->txp_sent_fc = 1;

crypto/openssl/ssl/quic/quic_txp.c

2618

if (ossl_quic_stream_has_send_buffer(stream)

crypto/openssl/ssl/quic/quic_txp.c

2619

&& !ossl_quic_stream_send_is_reset(stream)) {

crypto/openssl/ssl/quic/quic_txp.c

2622

if (!ossl_assert(!stream->want_reset_stream))

crypto/openssl/ssl/quic/quic_txp.c

2626

stream->id, stream->sstream,

crypto/openssl/ssl/quic/quic_txp.c

2627

&stream->txfc,

crypto/openssl/ssl/quic/quic_txp.c

2631

&stream->txp_txfc_new_credit_consumed,

crypto/openssl/ssl/quic/quic_txp.c

2634

txp_enlink_tmp(tmp_head, stream);

crypto/openssl/ssl/quic/quic_txp.c

2637

conn_consumed += stream->txp_txfc_new_credit_consumed;

crypto/openssl/ssl/quic/quic_txp.c

2640

txp_enlink_tmp(tmp_head, stream);

crypto/openssl/ssl/quic/quic_txp.c

2645

txp_enlink_tmp(tmp_head, stream);

crypto/openssl/ssl/quic/quic_txp.c

2978

QUIC_STREAM *stream;

crypto/openssl/ssl/quic/quic_txp.c

3003

for (stream = pkt->stream_head; stream != NULL; stream = stream->txp_next)

crypto/openssl/ssl/quic/quic_txp.c

3004

if (stream->txp_sent_stop_sending || stream->txp_sent_reset_stream) {

crypto/openssl/ssl/quic/quic_txp.c

3008

chunk.stream_id = stream->id;

crypto/openssl/ssl/quic/quic_txp.c

3012

chunk.has_stop_sending = stream->txp_sent_stop_sending;

crypto/openssl/ssl/quic/quic_txp.c

3013

chunk.has_reset_stream = stream->txp_sent_reset_stream;

crypto/openssl/ssl/quic/quic_txp.c

3044

for (stream = pkt->stream_head; stream != NULL; stream = stream->txp_next) {

crypto/openssl/ssl/quic/quic_txp.c

3045

if (stream->txp_sent_fc) {

crypto/openssl/ssl/quic/quic_txp.c

3046

stream->want_max_stream_data = 0;

crypto/openssl/ssl/quic/quic_txp.c

3047

ossl_quic_rxfc_has_cwm_changed(&stream->rxfc, 1);

crypto/openssl/ssl/quic/quic_txp.c

3050

if (stream->txp_sent_stop_sending)

crypto/openssl/ssl/quic/quic_txp.c

3051

stream->want_stop_sending = 0;

crypto/openssl/ssl/quic/quic_txp.c

3053

if (stream->txp_sent_reset_stream)

crypto/openssl/ssl/quic/quic_txp.c

3054

stream->want_reset_stream = 0;

crypto/openssl/ssl/quic/quic_txp.c

3056

if (stream->txp_txfc_new_credit_consumed > 0) {

crypto/openssl/ssl/quic/quic_txp.c

3057

if (!ossl_assert(ossl_quic_txfc_consume_credit(&stream->txfc,

crypto/openssl/ssl/quic/quic_txp.c

3058

stream->txp_txfc_new_credit_consumed)))

crypto/openssl/ssl/quic/quic_txp.c

3066

stream->txp_txfc_new_credit_consumed = 0;

crypto/openssl/ssl/quic/quic_txp.c

3075

ossl_quic_stream_map_update_state(txp->args.qsm, stream);

crypto/openssl/ssl/quic/quic_txp.c

3077

if (ossl_quic_stream_has_send_buffer(stream)

crypto/openssl/ssl/quic/quic_txp.c

3078

&& !ossl_quic_sstream_has_pending(stream->sstream)

crypto/openssl/ssl/quic/quic_txp.c

3079

&& ossl_quic_sstream_get_final_size(stream->sstream, NULL))

crypto/openssl/ssl/quic/quic_txp.c

3084

ossl_quic_stream_map_notify_all_data_sent(txp->args.qsm, stream);

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

459

static void process_new_stream(SSL *stream)

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

478

ret = SSL_read_ex(stream, &buf[total_read],

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

482

ret = handle_io_failure(stream, ret);

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

534

rc = SSL_write_ex(stream, &buf[offset], bytes_read, &bytes_written);

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

536

rc = SSL_get_error(stream, rc);

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

557

if (!SSL_stream_conclude(stream, 0))

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

604

SSL *listener, *conn, *stream;

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

672

stream = SSL_accept_stream(conn, 0);

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

673

if (stream == NULL) {

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

691

process_new_stream(stream);

crypto/openssl/test/quic-openssl-docker/hq-interop/quic-hq-interop-server.c

692

SSL_free(stream);

crypto/openssl/test/quic_txp_test.c

1437

if (!TEST_true(ossl_quic_wire_decode_frame_stream(&h.pkt, 0, &h.frame.stream)))

crypto/openssl/test/quic_txp_test.c

656

if (!TEST_mem_eq(h->frame.stream.data, (size_t)h->frame.stream.len,

crypto/openssl/test/quic_txp_test.c

85

OSSL_QUIC_FRAME_STREAM stream;

crypto/openssl/test/quic_txp_test.c

920

if (!TEST_uint64_t_ge(h->frame.stream.len, 1150)

crypto/openssl/test/quic_txp_test.c

921

|| !TEST_uint64_t_le(h->frame.stream.len, 1200))

crypto/openssl/test/quic_txp_test.c

924

if (!TEST_mem_eq(h->frame.stream.data, (size_t)h->frame.stream.len,

crypto/openssl/test/quic_txp_test.c

925

stream_10a, (size_t)h->frame.stream.len))

crypto/openssl/test/quic_txp_test.c

928

stream_10a_off = h->frame.stream.offset + h->frame.stream.len;

crypto/openssl/test/quic_txp_test.c

934

if (!TEST_uint64_t_ge(h->frame.stream.len, 1150)

crypto/openssl/test/quic_txp_test.c

935

|| !TEST_uint64_t_le(h->frame.stream.len, 1200))

crypto/openssl/test/quic_txp_test.c

938

if (!TEST_mem_eq(h->frame.stream.data, (size_t)h->frame.stream.len,

crypto/openssl/test/quic_txp_test.c

939

stream_10b, (size_t)h->frame.stream.len))

crypto/openssl/test/quic_txp_test.c

942

stream_10b_off = h->frame.stream.offset + h->frame.stream.len;

crypto/openssl/test/quic_txp_test.c

948

if (!TEST_uint64_t_ge(h->frame.stream.len, 5)

crypto/openssl/test/quic_txp_test.c

949

|| !TEST_uint64_t_le(h->frame.stream.len, 200))

crypto/openssl/test/quic_txp_test.c

952

if (!TEST_mem_eq(h->frame.stream.data, (size_t)h->frame.stream.len,

crypto/openssl/test/quic_txp_test.c

953

stream_10a + stream_10a_off, (size_t)h->frame.stream.len))

crypto/openssl/test/quic_txp_test.c

961

if (!TEST_uint64_t_ge(h->frame.stream.len, 5)

crypto/openssl/test/quic_txp_test.c

962

|| !TEST_uint64_t_le(h->frame.stream.len, 200))

crypto/openssl/test/quic_txp_test.c

965

if (!TEST_mem_eq(h->frame.stream.data, (size_t)h->frame.stream.len,

crypto/openssl/test/quic_txp_test.c

966

stream_10b + stream_10b_off, (size_t)h->frame.stream.len))

crypto/openssl/test/quicapitest.c

1000

stream = SSL_new_stream(clientquic, 0);

crypto/openssl/test/quicapitest.c

1001

if (!TEST_ptr(stream))

crypto/openssl/test/quicapitest.c

1004

if (!TEST_true(SSL_set_mode(stream, 0)))

crypto/openssl/test/quicapitest.c

1011

if (!TEST_int_eq(BIO_set_ssl(thisbio, stream, BIO_CLOSE), 1))

crypto/openssl/test/quicapitest.c

1013

stream = NULL;

crypto/openssl/test/quicapitest.c

1025

SSL_free(stream);

crypto/openssl/test/quicapitest.c

1491

static int unreliable_client_read(SSL *clientquic, SSL **stream, void *buf,

crypto/openssl/test/quicapitest.c

1499

if (*stream == NULL) {

crypto/openssl/test/quicapitest.c

1501

*stream = SSL_accept_stream(clientquic, 0);

crypto/openssl/test/quicapitest.c

1504

if (*stream != NULL) {

crypto/openssl/test/quicapitest.c

1505

if (SSL_read_ex(*stream, buf, buflen, readbytes))

crypto/openssl/test/quicapitest.c

1507

if (!TEST_int_eq(SSL_get_error(*stream, 0), SSL_ERROR_WANT_READ))

crypto/openssl/test/quicapitest.c

1552

SSL *clientquic = NULL, *stream[2] = { NULL, NULL };

crypto/openssl/test/quicapitest.c

1607

if (!TEST_true(unreliable_client_read(clientquic, &stream[j], buf,

crypto/openssl/test/quicapitest.c

1616

if (!TEST_true(SSL_write_ex(stream[j], (unsigned char *)msg,

crypto/openssl/test/quicapitest.c

1639

SSL_free(stream[0]);

crypto/openssl/test/quicapitest.c

1640

SSL_free(stream[1]);

crypto/openssl/test/quicapitest.c

902

SSL *clientquic = NULL, *stream = NULL;

crypto/openssl/test/radix/quic_ops.c

297

SSL *conn, *stream;

crypto/openssl/test/radix/quic_ops.c

308

stream = SSL_accept_stream(conn, flags);

crypto/openssl/test/radix/quic_ops.c

310

if (stream == NULL)

crypto/openssl/test/radix/quic_ops.c

313

stream = SSL_new_stream(conn, flags);

crypto/openssl/test/radix/quic_ops.c

316

if (!TEST_ptr(stream))

crypto/openssl/test/radix/quic_ops.c

321

if (stream != NULL

crypto/openssl/test/radix/quic_ops.c

322

&& !TEST_true(RADIX_PROCESS_set_ssl(RP(), stream_name, stream))) {

crypto/openssl/test/radix/quic_ops.c

323

SSL_free(stream);

crypto/openssl/test/radix/quic_ops.c

399

SSL *conn, *stream;

crypto/openssl/test/radix/quic_ops.c

406

stream = SSL_accept_stream(conn, flags);

crypto/openssl/test/radix/quic_ops.c

407

if (!TEST_ptr_null(stream)) {

crypto/openssl/test/radix/quic_ops.c

408

SSL_free(stream);

crypto/openssl/test/radix/quic_ops.c

754

SSL *conn, *stream;

crypto/openssl/test/radix/quic_ops.c

760

if (!TEST_ptr(stream = ossl_quic_detach_stream(conn)))

crypto/openssl/test/radix/quic_ops.c

763

if (!TEST_true(RADIX_PROCESS_set_ssl(RP(), stream_name, stream))) {

crypto/openssl/test/radix/quic_ops.c

764

SSL_free(stream);

crypto/openssl/test/radix/quic_ops.c

777

SSL *conn, *stream;

crypto/openssl/test/radix/quic_ops.c

784

if (!TEST_ptr(stream = RADIX_PROCESS_get_ssl(RP(), stream_name)))

crypto/openssl/test/radix/quic_ops.c

787

if (!TEST_true(ossl_quic_attach_stream(conn, stream)))

lib/clang/liblldb/LLDBWrapLua.cpp

3327

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3328

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3329

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3330

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3337

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3338

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3339

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3340

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3347

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3348

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3349

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3350

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3357

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3358

self->GetDescription (stream, lldb::eDescriptionLevelFull);

lib/clang/liblldb/LLDBWrapLua.cpp

3359

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3360

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3367

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3368

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3369

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3370

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3377

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3378

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3379

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3380

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3396

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3397

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3398

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3399

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3406

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3407

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3408

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3409

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3416

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3417

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3418

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3419

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3435

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3436

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3437

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3438

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3445

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3446

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3447

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3448

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3464

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3465

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3466

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3467

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3474

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3475

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3476

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3477

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3484

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3485

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3486

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3487

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3494

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3495

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3496

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3497

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3504

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3505

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3506

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3507

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3514

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3515

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3516

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3517

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3524

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3525

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3526

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3527

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3534

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3535

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3536

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3537

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3544

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3545

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3546

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3547

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3554

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3555

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3556

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3557

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3564

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3565

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3566

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3567

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3574

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3575

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3576

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3577

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3584

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3585

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3586

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3587

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3597

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3598

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3599

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3600

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3607

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3608

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3609

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3610

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3617

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3618

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3619

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3620

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3627

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3628

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3629

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3630

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3637

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3638

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3639

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3640

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3647

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3648

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3649

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3650

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3657

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3658

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3659

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3660

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3667

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3668

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3669

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3670

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3677

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3678

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3679

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3680

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3687

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3688

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3689

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3690

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3697

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3698

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3699

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3700

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3707

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3708

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3709

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3710

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3717

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3718

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3719

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3720

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3727

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3728

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3729

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3730

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3737

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3738

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3739

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3740

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3747

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3748

self->GetDescription (stream, lldb::eDescriptionLevelBrief);

lib/clang/liblldb/LLDBWrapLua.cpp

3749

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3750

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3757

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3758

self->GetDescription (stream);

lib/clang/liblldb/LLDBWrapLua.cpp

3759

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3760

size_t desc_len = stream.GetSize();

lib/clang/liblldb/LLDBWrapLua.cpp

3785

lldb::SBStream stream;

lib/clang/liblldb/LLDBWrapLua.cpp

3786

self->GetDescription (stream, lldb::eDescriptionLevelVerbose);

lib/clang/liblldb/LLDBWrapLua.cpp

3787

const char *desc = stream.GetData();

lib/clang/liblldb/LLDBWrapLua.cpp

3788

size_t desc_len = stream.GetSize();

lib/libc/isc/eventlib_p.h

175

struct { evStream *this; } stream;

lib/libc/tests/stdio/flushlbuf_test.c

102

static struct stream s;

lib/libc/tests/stdio/flushlbuf_test.c

28

struct stream *s = cookie;

lib/libc/tests/stdio/flushlbuf_test.c

47

static struct stream s;

lib/virtual_oss/bt/bt.c

673

cfg->handle.av.stream = avformat_new_stream(

lib/virtual_oss/bt/bt.c

676

if (cfg->handle.av.stream == NULL) {

lib/virtual_oss/bt/bt.h

78

AVStream *stream;

libexec/atrun/atrun.c

130

FILE *stream;

libexec/atrun/atrun.c

194

stream=fopen(filename, "r");

libexec/atrun/atrun.c

198

if (stream == NULL)

libexec/atrun/atrun.c

201

if ((fd_in = dup(fileno(stream))) <0)

libexec/atrun/atrun.c

231

if (fscanf(stream, fmt, &nuid, &ngid, mailbuf, &send_mail) != 4)

libexec/atrun/atrun.c

247

fclose(stream);

sbin/devd/tests/client_test.c

133

ATF_TC_WITHOUT_HEAD(stream);

sbin/devd/tests/client_test.c

134

ATF_TC_BODY(stream, tc)

sbin/devd/tests/client_test.c

191

ATF_TP_ADD_TC(tp, stream);

sbin/pfctl/parse.y

7304

c = getc(file->stream);

sbin/pfctl/parse.y

7611

nfile->stream = stdin;

sbin/pfctl/parse.y

7618

} else if ((nfile->stream = pfctl_fopen(nfile->name, "r")) == NULL) {

sbin/pfctl/parse.y

7624

check_file_secrecy(fileno(nfile->stream), nfile->name)) {

sbin/pfctl/parse.y

7625

fclose(nfile->stream);

sbin/pfctl/parse.y

7635

fclose(nfile->stream);

sbin/pfctl/parse.y

7653

fclose(file->stream);

sbin/pfctl/parse.y

92

FILE *stream;

sbin/ping/main.c

216

pr_summary(FILE * restrict stream)

sbin/ping/main.c

218

fprintf(stream, "\n--- %s ping statistics ---\n", hostname);

sbin/ping/main.c

219

fprintf(stream, "%ld packets transmitted, ", ntransmitted);

sbin/ping/main.c

220

fprintf(stream, "%ld packets received, ", nreceived);

sbin/ping/main.c

222

fprintf(stream, "+%ld duplicates, ", nrepeats);

sbin/ping/main.c

225

fprintf(stream, "-- somebody's duplicating packets!");

sbin/ping/main.c

227

fprintf(stream, "%.1f%% packet loss",

sbin/ping/main.c

232

fprintf(stream, ", %ld packets out of wait time", nrcvtimeout);

sbin/ping/main.c

233

fputc('\n', stream);

sbin/ping/main.c

239

fprintf(stream,

sbin/ping/main.c

243

fflush(stream);

stand/liblua/lstd.c

100

freopen(const char *filename, const char *mode, FILE *stream)

stand/liblua/lstd.c

102

fclose(stream);

stand/liblua/lstd.c

107

fread(void *ptr, size_t size, size_t count, FILE *stream)

stand/liblua/lstd.c

111

if (stream == NULL)

stand/liblua/lstd.c

113

r = (size_t)read(stream->fd, ptr, size * count);

stand/liblua/lstd.c

114

stream->offset += r;

stand/liblua/lstd.c

120

fwrite(const void *ptr, size_t size, size_t count, FILE *stream)

stand/liblua/lstd.c

124

if (stream == NULL || ptr == NULL)

stand/liblua/lstd.c

126

w = write(stream->fd, ptr, size * count);

stand/liblua/lstd.c

130

stream->offset += w;

stand/liblua/lstd.c

135

fclose(FILE *stream)

stand/liblua/lstd.c

137

if (stream == NULL)

stand/liblua/lstd.c

139

close(stream->fd);

stand/liblua/lstd.c

140

free(stream);

stand/liblua/lstd.c

146

ferror(FILE *stream)

stand/liblua/lstd.c

149

return (stream == NULL || stream->fd < 0);

stand/liblua/lstd.c

153

feof(FILE *stream)

stand/liblua/lstd.c

156

if (stream == NULL)

stand/liblua/lstd.c

159

return (stream->offset >= stream->size);

stand/liblua/lstd.c

163

getc(FILE *stream)

stand/liblua/lstd.c

168

if (stream == NULL)

stand/liblua/lstd.c

170

r = read(stream->fd, &ch, 1);

stand/liblua/lstd.h

71

FILE *freopen( const char *filename, const char *mode, FILE *stream);

stand/liblua/lstd.h

72

size_t fread(void *ptr, size_t size, size_t count, FILE *stream);

stand/liblua/lstd.h

73

size_t fwrite(const void *ptr, size_t size, size_t count, FILE *stream);

stand/liblua/lstd.h

74

int fclose(FILE *stream);

stand/liblua/lstd.h

75

int ferror(FILE *stream);

stand/liblua/lstd.h

76

int feof(FILE *stream);

stand/liblua/lstd.h

77

int getc(FILE * stream);

stand/libsa/zfs/nvlist.c

740

nvlist_import(const char *stream, size_t size)

stand/libsa/zfs/nvlist.c

750

if (stream[0] != NV_ENCODE_XDR ||

stand/libsa/zfs/nvlist.c

751

(stream[1] != '\0' && stream[1] != '\1') ||

stand/libsa/zfs/nvlist.c

752

stream[2] != '\0' || stream[3] != '\0' ||

stand/libsa/zfs/nvlist.c

753

be32toh(*(uint32_t *)(stream + 4)) != NV_VERSION ||

stand/libsa/zfs/nvlist.c

754

be32toh(*(uint32_t *)(stream + 8)) != NV_UNIQUE_NAME)

stand/libsa/zfs/nvlist.c

761

nvl->nv_header.nvh_encoding = stream[0];

stand/libsa/zfs/nvlist.c

762

nvl->nv_header.nvh_endian = stream[1];

stand/libsa/zfs/nvlist.c

763

nvl->nv_header.nvh_reserved1 = stream[2];

stand/libsa/zfs/nvlist.c

764

nvl->nv_header.nvh_reserved2 = stream[3];

stand/libsa/zfs/nvlist.c

766

xdr.xdr_buf = xdr.xdr_idx = (uint8_t *)stream + 4;

stand/libsa/zfs/nvlist.c

780

bcopy(stream + 4, nvl->nv_data, nvl->nv_asize);

sys/amd64/amd64/bpf_jit_machdep.c

158

bpf_bin_stream stream;

sys/amd64/amd64/bpf_jit_machdep.c

179

memset(&stream, 0, sizeof(stream));

sys/amd64/amd64/bpf_jit_machdep.c

184

stream.refs = malloc((nins + 1) * sizeof(u_int), M_BPFJIT,

sys/amd64/amd64/bpf_jit_machdep.c

187

stream.refs = calloc(nins + 1, sizeof(u_int));

sys/amd64/amd64/bpf_jit_machdep.c

189

if (stream.refs == NULL)

sys/amd64/amd64/bpf_jit_machdep.c

216

stream.bpf_pc++;

sys/amd64/amd64/bpf_jit_machdep.c

601

*size = stream.cur_ip;

sys/amd64/amd64/bpf_jit_machdep.c

603

stream.ibuf = malloc_exec(*size, M_BPFJIT, M_NOWAIT);

sys/amd64/amd64/bpf_jit_machdep.c

604

if (stream.ibuf == NULL)

sys/amd64/amd64/bpf_jit_machdep.c

607

stream.ibuf = mmap(NULL, *size, PROT_READ | PROT_WRITE,

sys/amd64/amd64/bpf_jit_machdep.c

609

if (stream.ibuf == MAP_FAILED) {

sys/amd64/amd64/bpf_jit_machdep.c

610

stream.ibuf = NULL;

sys/amd64/amd64/bpf_jit_machdep.c

621

stream.refs[i] += stream.refs[i - 1];

sys/amd64/amd64/bpf_jit_machdep.c

624

stream.cur_ip = 0;

sys/amd64/amd64/bpf_jit_machdep.c

625

stream.bpf_pc = 0;

sys/amd64/amd64/bpf_jit_machdep.c

63

emit_length(bpf_bin_stream *stream, __unused u_int value, u_int len)

sys/amd64/amd64/bpf_jit_machdep.c

637

free(stream.refs, M_BPFJIT);

sys/amd64/amd64/bpf_jit_machdep.c

639

free(stream.refs);

sys/amd64/amd64/bpf_jit_machdep.c

643

if (stream.ibuf != NULL &&

sys/amd64/amd64/bpf_jit_machdep.c

644

mprotect(stream.ibuf, *size, PROT_READ | PROT_EXEC) != 0) {

sys/amd64/amd64/bpf_jit_machdep.c

645

munmap(stream.ibuf, *size);

sys/amd64/amd64/bpf_jit_machdep.c

646

stream.ibuf = NULL;

sys/amd64/amd64/bpf_jit_machdep.c

650

return ((bpf_filter_func)(void *)stream.ibuf);

sys/amd64/amd64/bpf_jit_machdep.c

66

if (stream->refs != NULL)

sys/amd64/amd64/bpf_jit_machdep.c

67

(stream->refs)[stream->bpf_pc] += len;

sys/amd64/amd64/bpf_jit_machdep.c

68

stream->cur_ip += len;

sys/amd64/amd64/bpf_jit_machdep.c

75

emit_code(bpf_bin_stream *stream, u_int value, u_int len)

sys/amd64/amd64/bpf_jit_machdep.c

80

stream->ibuf[stream->cur_ip] = (u_char)value;

sys/amd64/amd64/bpf_jit_machdep.c

81

stream->cur_ip++;

sys/amd64/amd64/bpf_jit_machdep.c

85

*((u_short *)(void *)(stream->ibuf + stream->cur_ip)) =

sys/amd64/amd64/bpf_jit_machdep.c

87

stream->cur_ip += 2;

sys/amd64/amd64/bpf_jit_machdep.c

91

*((u_int *)(void *)(stream->ibuf + stream->cur_ip)) = value;

sys/amd64/amd64/bpf_jit_machdep.c

92

stream->cur_ip += 4;

sys/amd64/amd64/bpf_jit_machdep.h

127

typedef void (*emit_func)(bpf_bin_stream *stream, u_int value, u_int n);

sys/amd64/amd64/bpf_jit_machdep.h

135

emitm(&stream, (11 << 4) | (1 << 3) | (r32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

136

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

141

emitm(&stream, 0x48, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

142

emitm(&stream, (11 << 4) | (1 << 3) | (r64 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

143

emitm(&stream, i64, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

144

emitm(&stream, (i64 >> 32), 4); \

sys/amd64/amd64/bpf_jit_machdep.h

149

emitm(&stream, 0x89, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

150

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

156

emitm(&stream, 0x8941, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

157

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

163

emitm(&stream, 0x8944, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

164

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

170

emitm(&stream, 0x8948, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

171

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

177

emitm(&stream, 0x8949, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

178

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

184

emitm(&stream, 0x894c, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

185

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

191

emitm(&stream, 0x8b, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

192

emitm(&stream, ((dr32 & 0x7) << 3) | 4, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

193

emitm(&stream, ((or64 & 0x7) << 3) | (sr64 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

198

emitm(&stream, 0x8b66, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

199

emitm(&stream, ((dr16 & 0x7) << 3) | 4, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

200

emitm(&stream, ((or64 & 0x7) << 3) | (sr64 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

205

emitm(&stream, 0x8a, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

206

emitm(&stream, ((dr8 & 0x7) << 3) | 4, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

207

emitm(&stream, ((or64 & 0x7) << 3) | (sr64 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

212

emitm(&stream, 0x89, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

213

emitm(&stream, ((sr32 & 0x7) << 3) | 4, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

214

emitm(&stream, ((or64 & 0x7) << 3) | (dr64 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

219

emitm(&stream, 0xf, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

220

emitm(&stream, (0x19 << 3) | dr32, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

225

emitm(&stream, 0xc486, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

230

emitm(&stream, (5 << 4) | (0 << 3) | (r64 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

235

emitm(&stream, 0xc9, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

240

emitm(&stream, 0xc3, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

245

emitm(&stream, 0x01, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

246

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

252

emitm(&stream, 0x05, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

253

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

258

emitm(&stream, 0x83, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

259

emitm(&stream, (24 << 3) | r32, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

260

emitm(&stream, i8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

265

emitm(&stream, 0x29, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

266

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

272

emitm(&stream, 0x2d, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

273

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

278

emitm(&stream, 0x8348, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

279

emitm(&stream, (29 << 3) | (r64 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

280

emitm(&stream, i8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

285

emitm(&stream, 0xf7, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

286

emitm(&stream, (7 << 5) | (r32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

291

emitm(&stream, 0xf7, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

292

emitm(&stream, (15 << 4) | (r32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

298

emitm(&stream, 0x24, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

300

emitm(&stream, 0x80, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

301

emitm(&stream, (7 << 5) | r8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

303

emitm(&stream, i8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

309

emitm(&stream, 0x25, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

311

emitm(&stream, 0x81, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

312

emitm(&stream, (7 << 5) | r32, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

314

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

319

emitm(&stream, 0x21, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

320

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

327

emitm(&stream, 0xa9, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

329

emitm(&stream, 0xf7, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

330

emitm(&stream, (3 << 6) | r32, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

332

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

337

emitm(&stream, 0x85, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

338

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

344

emitm(&stream, 0x09, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

345

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

352

emitm(&stream, 0x0d, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

354

emitm(&stream, 0x81, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

355

emitm(&stream, (25 << 3) | r32, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

357

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

362

emitm(&stream, 0x31, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

363

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

370

emitm(&stream, 0x35, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

372

emitm(&stream, 0x81, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

373

emitm(&stream, (25 << 3) | r32, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

375

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

380

emitm(&stream, 0xc1, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

381

emitm(&stream, (7 << 5) | (r32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

382

emitm(&stream, i8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

387

emitm(&stream, 0xd3, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

388

emitm(&stream, (7 << 5) | (dr32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

393

emitm(&stream, 0xc1, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

394

emitm(&stream, (29 << 3) | (r32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

395

emitm(&stream, i8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

400

emitm(&stream, 0xd3, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

401

emitm(&stream, (29 << 3) | (dr32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

406

emitm(&stream, 0xf7, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

407

emitm(&stream, (27 << 3) | (r32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

412

emitm(&stream, 0x39, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

413

emitm(&stream, \

sys/amd64/amd64/bpf_jit_machdep.h

420

emitm(&stream, 0x3d, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

421

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

423

emitm(&stream, 0x81, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

424

emitm(&stream, (0x1f << 3) | (dr32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

425

emitm(&stream, i32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

431

emitm(&stream, 0x72, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

432

emitm(&stream, off8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

437

emitm(&stream, 0x73, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

438

emitm(&stream, off8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

443

emitm(&stream, 0x75, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

444

emitm(&stream, off8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

449

emitm(&stream, 0x77, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

450

emitm(&stream, off8, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

455

emitm(&stream, 0xe9, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

456

emitm(&stream, off32, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

461

emitm(&stream, 0x31, 1); \

sys/amd64/amd64/bpf_jit_machdep.h

462

emitm(&stream, (3 << 6) | ((r32 & 0x7) << 3) | (r32 & 0x7), 1); \

sys/amd64/amd64/bpf_jit_machdep.h

478

emitm(&stream, ((t) << 8) | 0x0f, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

479

emitm(&stream, stream.refs[stream.bpf_pc + ins->jt] - \

sys/amd64/amd64/bpf_jit_machdep.h

480

stream.refs[stream.bpf_pc] + 5, 4); \

sys/amd64/amd64/bpf_jit_machdep.h

481

JMP(stream.refs[stream.bpf_pc + ins->jf] - \

sys/amd64/amd64/bpf_jit_machdep.h

482

stream.refs[stream.bpf_pc]); \

sys/amd64/amd64/bpf_jit_machdep.h

484

emitm(&stream, ((t) << 8) | 0x0f, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

485

emitm(&stream, stream.refs[stream.bpf_pc + ins->jt] - \

sys/amd64/amd64/bpf_jit_machdep.h

486

stream.refs[stream.bpf_pc], 4); \

sys/amd64/amd64/bpf_jit_machdep.h

488

emitm(&stream, ((f) << 8) | 0x0f, 2); \

sys/amd64/amd64/bpf_jit_machdep.h

489

emitm(&stream, stream.refs[stream.bpf_pc + ins->jf] - \

sys/amd64/amd64/bpf_jit_machdep.h

490

stream.refs[stream.bpf_pc], 4); \

sys/amd64/amd64/bpf_jit_machdep.h

496

JMP(stream.refs[stream.bpf_pc + (off)] - \

sys/amd64/amd64/bpf_jit_machdep.h

497

stream.refs[stream.bpf_pc]); \

sys/cam/scsi/scsi_all.c

3964

struct scsi_sense_stream *stream = (void *)desc;

sys/cam/scsi/scsi_all.c

3966

if (len > sizeof(stream->byte3))

sys/cam/scsi/scsi_all.c

3968

if (space < sizeof(*stream)) {

sys/cam/scsi/scsi_all.c

3972

stream->desc_type = SSD_DESC_STREAM;

sys/cam/scsi/scsi_all.c

3973

stream->length = sizeof(*stream) -

sys/cam/scsi/scsi_all.c

3975

stream->byte3 = *data;

sys/cam/scsi/scsi_all.c

3976

desc += sizeof(*stream);

sys/cam/scsi/scsi_all.c

3977

space -= sizeof(*stream);

sys/cam/scsi/scsi_all.c

4412

struct scsi_sense_stream *stream;

sys/cam/scsi/scsi_all.c

4416

stream = (struct scsi_sense_stream *)scsi_find_desc(sense,

sys/cam/scsi/scsi_all.c

4418

if (stream == NULL)

sys/cam/scsi/scsi_all.c

4421

*stream_bits = stream->byte3;

sys/cam/scsi/scsi_all.c

4672

struct scsi_sense_stream *stream;

sys/cam/scsi/scsi_all.c

4674

stream = (struct scsi_sense_stream *)header;

sys/cam/scsi/scsi_all.c

4675

scsi_stream_sbuf(sb, stream->byte3);

sys/dev/firewire/firewire.c

227

len = fp->mode.stream.len;

sys/dev/firewire/firewire.h

149

} stream;

sys/dev/firewire/fwdev.c

367

if (fp->mode.stream.len == 0) {

sys/dev/firewire/fwdev.c

372

fp->mode.stream.len + sizeof(uint32_t), uio);

sys/dev/firewire/fwdev.c

498

err = uiomove((caddr_t)fp->mode.stream.payload,

sys/dev/firewire/fwdev.c

499

fp->mode.stream.len, uio);

sys/dev/firewire/fwohci.c

2527

ohcifp->mode.stream.len = fp->mode.stream.len;

sys/dev/firewire/fwohci.c

2528

ohcifp->mode.stream.chtag = chtag;

sys/dev/firewire/fwohci.c

2529

ohcifp->mode.stream.tcode = 0xa;

sys/dev/firewire/fwohci.c

2536

FWOHCI_DMA_SET(db[2].db.desc.cmd, fp->mode.stream.len);

sys/dev/firewire/fwohci.c

916

ohcifp->mode.stream.len = fp->mode.stream.len;

sys/dev/firewire/fwohcireg.h

396

} stream;

sys/dev/firewire/if_fwe.c

160

fwe->pkt_hdr.mode.stream.tcode = FWTCODE_STREAM;

sys/dev/firewire/if_fwe.c

161

fwe->pkt_hdr.mode.stream.sy = 0;

sys/dev/firewire/if_fwe.c

162

fwe->pkt_hdr.mode.stream.chtag = fwe->stream_ch;

sys/dev/firewire/if_fwe.c

292

fwe->pkt_hdr.mode.stream.chtag = fwe->stream_ch;

sys/dev/firewire/if_fwe.c

520

fp->mode.stream.len = m->m_pkthdr.len;

sys/dev/firewire/if_fwe.c

574

if (sxfer->resp != 0 || fp->mode.stream.len <

sys/dev/firewire/if_fwe.c

585

m->m_len = m->m_pkthdr.len = fp->mode.stream.len - ETHER_ALIGN;

sys/dev/firewire/if_fwip.c

606

fp->mode.stream.len = m->m_pkthdr.len;

sys/dev/firewire/if_fwip.c

607

fp->mode.stream.chtag = broadcast_channel;

sys/dev/firewire/if_fwip.c

608

fp->mode.stream.tcode = FWTCODE_STREAM;

sys/dev/firewire/if_fwip.c

609

fp->mode.stream.sy = 0;

sys/dev/firewire/if_fwip.c

740

if (sxfer->resp != 0 || fp->mode.stream.len <

sys/dev/firewire/if_fwip.c

746

m->m_len = m->m_pkthdr.len = fp->mode.stream.len

sys/dev/firewire/if_fwip.c

747

+ sizeof(fp->mode.stream);

sys/dev/firewire/if_fwip.c

754

if (fp->mode.stream.chtag == broadcast_channel)

sys/dev/mwl/mwlhal.c

116

uint8_t stream; /* stream # */

sys/dev/mwl/mwlhal.c

1487

pCmd->BaInfo.CreateParams.QueueId = sp->stream;

sys/dev/mwl/mwlhal.c

1524

if (sp->stream >= MWL_BASTREAMS_MAX) {

sys/dev/mwl/mwlhal.c

1533

htole32(sp->stream);

sys/dev/mwl/mwlhal.c

1539

mh->mh_bastreams |= 1<<sp->stream;

sys/dev/mwl/mwlhal.c

258

mh->mh_streams[i].stream = i;

sys/dev/sound/pci/hda/hdaa.c

6800

hdaa_stream_intr(device_t dev, int dir, int stream)

sys/dev/sound/pci/hda/hdaa.c

6811

ch->sid == stream) {

sys/dev/sound/pci/hda/hdac.c

1910

hdac_find_stream(struct hdac_softc *sc, int dir, int stream)

sys/dev/sound/pci/hda/hdac.c

1918

if (sc->streams[i].stream == stream) {

sys/dev/sound/pci/hda/hdac.c

1925

if (sc->streams[i + sc->num_iss].stream == stream) {

sys/dev/sound/pci/hda/hdac.c

1934

if (sc->streams[i + sc->num_iss + sc->num_oss].stream

sys/dev/sound/pci/hda/hdac.c

1935

== stream) {

sys/dev/sound/pci/hda/hdac.c

1950

int stream, ss, bw, maxbw, prevbw;

sys/dev/sound/pci/hda/hdac.c

1983

stream = 15 - (ss - sc->num_iss - sc->num_oss);

sys/dev/sound/pci/hda/hdac.c

1985

stream = ss - sc->num_iss + 1;

sys/dev/sound/pci/hda/hdac.c

1987

stream = ss + 1;

sys/dev/sound/pci/hda/hdac.c

1991

sc->streams[ss].stream = stream;

sys/dev/sound/pci/hda/hdac.c

2001

return (stream);

sys/dev/sound/pci/hda/hdac.c

2005

hdac_stream_free(device_t dev, device_t child, int dir, int stream)

sys/dev/sound/pci/hda/hdac.c

2011

ss = hdac_find_stream(sc, dir, stream);

sys/dev/sound/pci/hda/hdac.c

2013

("Free for not allocated stream (%d/%d)\n", dir, stream));

sys/dev/sound/pci/hda/hdac.c

2018

sc->streams[ss].stream = 0;

sys/dev/sound/pci/hda/hdac.c

2023

hdac_stream_start(device_t dev, device_t child, int dir, int stream,

sys/dev/sound/pci/hda/hdac.c

2032

ss = hdac_find_stream(sc, dir, stream);

sys/dev/sound/pci/hda/hdac.c

2034

("Start for not allocated stream (%d/%d)\n", dir, stream));

sys/dev/sound/pci/hda/hdac.c

2062

ctl |= stream << HDAC_SDCTL2_STRM_SHIFT;

sys/dev/sound/pci/hda/hdac.c

2087

hdac_stream_stop(device_t dev, device_t child, int dir, int stream)

sys/dev/sound/pci/hda/hdac.c

2093

ss = hdac_find_stream(sc, dir, stream);

sys/dev/sound/pci/hda/hdac.c

2095

("Stop for not allocated stream (%d/%d)\n", dir, stream));

sys/dev/sound/pci/hda/hdac.c

2115

hdac_stream_reset(device_t dev, device_t child, int dir, int stream)

sys/dev/sound/pci/hda/hdac.c

2123

ss = hdac_find_stream(sc, dir, stream);

sys/dev/sound/pci/hda/hdac.c

2125

("Reset for not allocated stream (%d/%d)\n", dir, stream));

sys/dev/sound/pci/hda/hdac.c

2153

hdac_stream_getptr(device_t dev, device_t child, int dir, int stream)

sys/dev/sound/pci/hda/hdac.c

2158

ss = hdac_find_stream(sc, dir, stream);

sys/dev/sound/pci/hda/hdac.c

2160

("Reset for not allocated stream (%d/%d)\n", dir, stream));

sys/dev/sound/pci/hda/hdac.c

373

sc->streams[i].dir, sc->streams[i].stream);

sys/dev/sound/pci/hda/hdac_private.h

155

int stream;

sys/dev/sound/pci/hda/hdacc.c

652

int stream;

sys/dev/sound/pci/hda/hdacc.c

654

stream = HDAC_STREAM_ALLOC(device_get_parent(dev), dev,

sys/dev/sound/pci/hda/hdacc.c

656

if (stream > 0)

sys/dev/sound/pci/hda/hdacc.c

657

codec->streams[dir][stream] = child;

sys/dev/sound/pci/hda/hdacc.c

658

return (stream);

sys/dev/sound/pci/hda/hdacc.c

662

hdacc_stream_free(device_t dev, device_t child, int dir, int stream)

sys/dev/sound/pci/hda/hdacc.c

666

codec->streams[dir][stream] = NULL;

sys/dev/sound/pci/hda/hdacc.c

667

HDAC_STREAM_FREE(device_get_parent(dev), dev, dir, stream);

sys/dev/sound/pci/hda/hdacc.c

671

hdacc_stream_start(device_t dev, device_t child, int dir, int stream,

sys/dev/sound/pci/hda/hdacc.c

676

dir, stream, buf, blksz, blkcnt));

sys/dev/sound/pci/hda/hdacc.c

680

hdacc_stream_stop(device_t dev, device_t child, int dir, int stream)

sys/dev/sound/pci/hda/hdacc.c

683

HDAC_STREAM_STOP(device_get_parent(dev), dev, dir, stream);

sys/dev/sound/pci/hda/hdacc.c

687

hdacc_stream_reset(device_t dev, device_t child, int dir, int stream)

sys/dev/sound/pci/hda/hdacc.c

690

HDAC_STREAM_RESET(device_get_parent(dev), dev, dir, stream);

sys/dev/sound/pci/hda/hdacc.c

694

hdacc_stream_getptr(device_t dev, device_t child, int dir, int stream)

sys/dev/sound/pci/hda/hdacc.c

697

return (HDAC_STREAM_GETPTR(device_get_parent(dev), dev, dir, stream));

sys/dev/sound/pci/hda/hdacc.c

701

hdacc_stream_intr(device_t dev, int dir, int stream)

sys/dev/sound/pci/hda/hdacc.c

706

if ((child = codec->streams[dir][stream]) != NULL)

sys/dev/sound/pci/hda/hdacc.c

707

HDAC_STREAM_INTR(child, dir, stream);

sys/i386/i386/bpf_jit_machdep.c

158

bpf_bin_stream stream;

sys/i386/i386/bpf_jit_machdep.c

181

memset(&stream, 0, sizeof(stream));

sys/i386/i386/bpf_jit_machdep.c

186

stream.refs = malloc((nins + 1) * sizeof(u_int), M_BPFJIT,

sys/i386/i386/bpf_jit_machdep.c

189

stream.refs = calloc(nins + 1, sizeof(u_int));

sys/i386/i386/bpf_jit_machdep.c

191

if (stream.refs == NULL)

sys/i386/i386/bpf_jit_machdep.c

221

stream.bpf_pc++;

sys/i386/i386/bpf_jit_machdep.c

63

emit_length(bpf_bin_stream *stream, __unused u_int value, u_int len)

sys/i386/i386/bpf_jit_machdep.c

631

*size = stream.cur_ip;

sys/i386/i386/bpf_jit_machdep.c

633

stream.ibuf = malloc_exec(*size, M_BPFJIT, M_NOWAIT);

sys/i386/i386/bpf_jit_machdep.c

634

if (stream.ibuf == NULL)

sys/i386/i386/bpf_jit_machdep.c

637

stream.ibuf = mmap(NULL, *size, PROT_READ | PROT_WRITE,

sys/i386/i386/bpf_jit_machdep.c

639

if (stream.ibuf == MAP_FAILED) {

sys/i386/i386/bpf_jit_machdep.c

640

stream.ibuf = NULL;

sys/i386/i386/bpf_jit_machdep.c

651

stream.refs[i] += stream.refs[i - 1];

sys/i386/i386/bpf_jit_machdep.c

654

stream.cur_ip = 0;

sys/i386/i386/bpf_jit_machdep.c

655

stream.bpf_pc = 0;

sys/i386/i386/bpf_jit_machdep.c

66

if (stream->refs != NULL)

sys/i386/i386/bpf_jit_machdep.c

667

free(stream.refs, M_BPFJIT);

sys/i386/i386/bpf_jit_machdep.c

669

free(stream.refs);

sys/i386/i386/bpf_jit_machdep.c

67

(stream->refs)[stream->bpf_pc] += len;

sys/i386/i386/bpf_jit_machdep.c

673

if (stream.ibuf != NULL &&

sys/i386/i386/bpf_jit_machdep.c

674

mprotect(stream.ibuf, *size, PROT_READ | PROT_EXEC) != 0) {

sys/i386/i386/bpf_jit_machdep.c

675

munmap(stream.ibuf, *size);

sys/i386/i386/bpf_jit_machdep.c

676

stream.ibuf = NULL;

sys/i386/i386/bpf_jit_machdep.c

68

stream->cur_ip += len;

sys/i386/i386/bpf_jit_machdep.c

680

return ((bpf_filter_func)(void *)stream.ibuf);

sys/i386/i386/bpf_jit_machdep.c

75

emit_code(bpf_bin_stream *stream, u_int value, u_int len)

sys/i386/i386/bpf_jit_machdep.c

80

stream->ibuf[stream->cur_ip] = (u_char)value;

sys/i386/i386/bpf_jit_machdep.c

81

stream->cur_ip++;

sys/i386/i386/bpf_jit_machdep.c

85

*((u_short *)(void *)(stream->ibuf + stream->cur_ip)) =

sys/i386/i386/bpf_jit_machdep.c

87

stream->cur_ip += 2;

sys/i386/i386/bpf_jit_machdep.c

91

*((u_int *)(void *)(stream->ibuf + stream->cur_ip)) = value;

sys/i386/i386/bpf_jit_machdep.c

92

stream->cur_ip += 4;

sys/i386/i386/bpf_jit_machdep.h

102

typedef void (*emit_func)(bpf_bin_stream *stream, u_int value, u_int n);

sys/i386/i386/bpf_jit_machdep.h

110

emitm(&stream, (11 << 4) | (1 << 3) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

111

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

116

emitm(&stream, 0x89, 1); \

sys/i386/i386/bpf_jit_machdep.h

117

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

123

emitm(&stream, 0x8b, 1); \

sys/i386/i386/bpf_jit_machdep.h

124

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

126

emitm(&stream, off, 1); \

sys/i386/i386/bpf_jit_machdep.h

131

emitm(&stream, 0x8b, 1); \

sys/i386/i386/bpf_jit_machdep.h

132

emitm(&stream, ((dr32 & 0x7) << 3) | 4, 1); \

sys/i386/i386/bpf_jit_machdep.h

133

emitm(&stream, ((or32 & 0x7) << 3) | (sr32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

138

emitm(&stream, 0x8b66, 2); \

sys/i386/i386/bpf_jit_machdep.h

139

emitm(&stream, ((dr16 & 0x7) << 3) | 4, 1); \

sys/i386/i386/bpf_jit_machdep.h

140

emitm(&stream, ((or32 & 0x7) << 3) | (sr32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

145

emitm(&stream, 0x8a, 1); \

sys/i386/i386/bpf_jit_machdep.h

146

emitm(&stream, ((dr8 & 0x7) << 3) | 4, 1); \

sys/i386/i386/bpf_jit_machdep.h

147

emitm(&stream, ((or32 & 0x7) << 3) | (sr32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

152

emitm(&stream, 0x89, 1); \

sys/i386/i386/bpf_jit_machdep.h

153

emitm(&stream, ((sr32 & 0x7) << 3) | 4, 1); \

sys/i386/i386/bpf_jit_machdep.h

154

emitm(&stream, ((or32 & 0x7) << 3) | (dr32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

159

emitm(&stream, 0xf, 1); \

sys/i386/i386/bpf_jit_machdep.h

160

emitm(&stream, (0x19 << 3) | dr32, 1); \

sys/i386/i386/bpf_jit_machdep.h

165

emitm(&stream, 0xc486, 2); \

sys/i386/i386/bpf_jit_machdep.h

170

emitm(&stream, (5 << 4) | (0 << 3) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

175

emitm(&stream, (5 << 4) | (1 << 3) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

180

emitm(&stream, 0xc9, 1); \

sys/i386/i386/bpf_jit_machdep.h

185

emitm(&stream, 0xc3, 1); \

sys/i386/i386/bpf_jit_machdep.h

190

emitm(&stream, 0x01, 1); \

sys/i386/i386/bpf_jit_machdep.h

191

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

197

emitm(&stream, 0x05, 1); \

sys/i386/i386/bpf_jit_machdep.h

198

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

203

emitm(&stream, 0x83, 1); \

sys/i386/i386/bpf_jit_machdep.h

204

emitm(&stream, (24 << 3) | r32, 1); \

sys/i386/i386/bpf_jit_machdep.h

205

emitm(&stream, i8, 1); \

sys/i386/i386/bpf_jit_machdep.h

210

emitm(&stream, 0x29, 1); \

sys/i386/i386/bpf_jit_machdep.h

211

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

217

emitm(&stream, 0x2d, 1); \

sys/i386/i386/bpf_jit_machdep.h

218

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

223

emitm(&stream, 0x83, 1); \

sys/i386/i386/bpf_jit_machdep.h

224

emitm(&stream, (29 << 3) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

225

emitm(&stream, i8, 1); \

sys/i386/i386/bpf_jit_machdep.h

230

emitm(&stream, 0xf7, 1); \

sys/i386/i386/bpf_jit_machdep.h

231

emitm(&stream, (7 << 5) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

236

emitm(&stream, 0xf7, 1); \

sys/i386/i386/bpf_jit_machdep.h

237

emitm(&stream, (15 << 4) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

243

emitm(&stream, 0x24, 1); \

sys/i386/i386/bpf_jit_machdep.h

245

emitm(&stream, 0x80, 1); \

sys/i386/i386/bpf_jit_machdep.h

246

emitm(&stream, (7 << 5) | r8, 1); \

sys/i386/i386/bpf_jit_machdep.h

248

emitm(&stream, i8, 1); \

sys/i386/i386/bpf_jit_machdep.h

254

emitm(&stream, 0x25, 1); \

sys/i386/i386/bpf_jit_machdep.h

256

emitm(&stream, 0x81, 1); \

sys/i386/i386/bpf_jit_machdep.h

257

emitm(&stream, (7 << 5) | r32, 1); \

sys/i386/i386/bpf_jit_machdep.h

259

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

264

emitm(&stream, 0x21, 1); \

sys/i386/i386/bpf_jit_machdep.h

265

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

272

emitm(&stream, 0xa9, 1); \

sys/i386/i386/bpf_jit_machdep.h

274

emitm(&stream, 0xf7, 1); \

sys/i386/i386/bpf_jit_machdep.h

275

emitm(&stream, (3 << 6) | r32, 1); \

sys/i386/i386/bpf_jit_machdep.h

277

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

282

emitm(&stream, 0x85, 1); \

sys/i386/i386/bpf_jit_machdep.h

283

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

289

emitm(&stream, 0x09, 1); \

sys/i386/i386/bpf_jit_machdep.h

290

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

297

emitm(&stream, 0x0d, 1); \

sys/i386/i386/bpf_jit_machdep.h

299

emitm(&stream, 0x81, 1); \

sys/i386/i386/bpf_jit_machdep.h

300

emitm(&stream, (25 << 3) | r32, 1); \

sys/i386/i386/bpf_jit_machdep.h

302

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

307

emitm(&stream, 0x31, 1); \

sys/i386/i386/bpf_jit_machdep.h

308

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

315

emitm(&stream, 0x35, 1); \

sys/i386/i386/bpf_jit_machdep.h

317

emitm(&stream, 0x81, 1); \

sys/i386/i386/bpf_jit_machdep.h

318

emitm(&stream, (25 << 3) | r32, 1); \

sys/i386/i386/bpf_jit_machdep.h

320

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

325

emitm(&stream, 0xc1, 1); \

sys/i386/i386/bpf_jit_machdep.h

326

emitm(&stream, (7 << 5) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

327

emitm(&stream, i8, 1); \

sys/i386/i386/bpf_jit_machdep.h

332

emitm(&stream, 0xd3, 1); \

sys/i386/i386/bpf_jit_machdep.h

333

emitm(&stream, (7 << 5) | (dr32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

338

emitm(&stream, 0xc1, 1); \

sys/i386/i386/bpf_jit_machdep.h

339

emitm(&stream, (29 << 3) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

340

emitm(&stream, i8, 1); \

sys/i386/i386/bpf_jit_machdep.h

345

emitm(&stream, 0xd3, 1); \

sys/i386/i386/bpf_jit_machdep.h

346

emitm(&stream, (29 << 3) | (dr32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

351

emitm(&stream, 0xf7, 1); \

sys/i386/i386/bpf_jit_machdep.h

352

emitm(&stream, (27 << 3) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

357

emitm(&stream, 0x39, 1); \

sys/i386/i386/bpf_jit_machdep.h

358

emitm(&stream, \

sys/i386/i386/bpf_jit_machdep.h

365

emitm(&stream, 0x3d, 1); \

sys/i386/i386/bpf_jit_machdep.h

366

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

368

emitm(&stream, 0x81, 1); \

sys/i386/i386/bpf_jit_machdep.h

369

emitm(&stream, (0x1f << 3) | (dr32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

370

emitm(&stream, i32, 4); \

sys/i386/i386/bpf_jit_machdep.h

376

emitm(&stream, 0x72, 1); \

sys/i386/i386/bpf_jit_machdep.h

377

emitm(&stream, off8, 1); \

sys/i386/i386/bpf_jit_machdep.h

382

emitm(&stream, 0x73, 1); \

sys/i386/i386/bpf_jit_machdep.h

383

emitm(&stream, off8, 1); \

sys/i386/i386/bpf_jit_machdep.h

388

emitm(&stream, 0x75, 1); \

sys/i386/i386/bpf_jit_machdep.h

389

emitm(&stream, off8, 1); \

sys/i386/i386/bpf_jit_machdep.h

394

emitm(&stream, 0x77, 1); \

sys/i386/i386/bpf_jit_machdep.h

395

emitm(&stream, off8, 1); \

sys/i386/i386/bpf_jit_machdep.h

400

emitm(&stream, 0xe9, 1); \

sys/i386/i386/bpf_jit_machdep.h

401

emitm(&stream, off32, 4); \

sys/i386/i386/bpf_jit_machdep.h

406

emitm(&stream, 0x31, 1); \

sys/i386/i386/bpf_jit_machdep.h

407

emitm(&stream, (3 << 6) | ((r32 & 0x7) << 3) | (r32 & 0x7), 1); \

sys/i386/i386/bpf_jit_machdep.h

423

emitm(&stream, ((t) << 8) | 0x0f, 2); \

sys/i386/i386/bpf_jit_machdep.h

424

emitm(&stream, stream.refs[stream.bpf_pc + ins->jt] - \

sys/i386/i386/bpf_jit_machdep.h

425

stream.refs[stream.bpf_pc] + 5, 4); \

sys/i386/i386/bpf_jit_machdep.h

426

JMP(stream.refs[stream.bpf_pc + ins->jf] - \

sys/i386/i386/bpf_jit_machdep.h

427

stream.refs[stream.bpf_pc]); \

sys/i386/i386/bpf_jit_machdep.h

429

emitm(&stream, ((t) << 8) | 0x0f, 2); \

sys/i386/i386/bpf_jit_machdep.h

430

emitm(&stream, stream.refs[stream.bpf_pc + ins->jt] - \

sys/i386/i386/bpf_jit_machdep.h

431

stream.refs[stream.bpf_pc], 4); \

sys/i386/i386/bpf_jit_machdep.h

433

emitm(&stream, ((f) << 8) | 0x0f, 2); \

sys/i386/i386/bpf_jit_machdep.h

434

emitm(&stream, stream.refs[stream.bpf_pc + ins->jf] - \

sys/i386/i386/bpf_jit_machdep.h

435

stream.refs[stream.bpf_pc], 4); \

sys/i386/i386/bpf_jit_machdep.h

441

JMP(stream.refs[stream.bpf_pc + (off)] - \

sys/i386/i386/bpf_jit_machdep.h

442

stream.refs[stream.bpf_pc]); \

sys/kern/subr_compressor.c

141

gz_reset(void *stream)

sys/kern/subr_compressor.c

147

s = stream;

sys/kern/subr_compressor.c

167

gz_write(void *stream, void *data, size_t len, compressor_cb_t cb,

sys/kern/subr_compressor.c

175

s = stream;

sys/kern/subr_compressor.c

235

gz_fini(void *stream)

sys/kern/subr_compressor.c

239

s = stream;

sys/kern/subr_compressor.c

272

static void zstdio_reset(void *stream);

sys/kern/subr_compressor.c

273

static int zstdio_write(void *stream, void *data, size_t len,

sys/kern/subr_compressor.c

275

static void zstdio_fini(void *stream);

sys/kern/subr_compressor.c

333

zstdio_reset(void *stream)

sys/kern/subr_compressor.c

338

s = stream;

sys/kern/subr_compressor.c

435

zstdio_write(void *stream, void *data, size_t len, compressor_cb_t cb,

sys/kern/subr_compressor.c

442

s = stream;

sys/kern/subr_compressor.c

478

zstdio_fini(void *stream)

sys/kern/subr_compressor.c

482

s = stream;

sys/kern/subr_compressor.c

542

compressor_format(const struct compressor *stream)

sys/kern/subr_compressor.c

544

return (stream->methods->format);

sys/kern/subr_compressor.c

548

compressor_reset(struct compressor *stream)

sys/kern/subr_compressor.c

551

stream->methods->reset(stream->priv);

sys/kern/subr_compressor.c

555

compressor_write(struct compressor *stream, void *data, size_t len)

sys/kern/subr_compressor.c

558

return (stream->methods->write(stream->priv, data, len, stream->cb,

sys/kern/subr_compressor.c

559

stream->arg));

sys/kern/subr_compressor.c

563

compressor_flush(struct compressor *stream)

sys/kern/subr_compressor.c

566

return (stream->methods->write(stream->priv, NULL, 0, stream->cb,

sys/kern/subr_compressor.c

567

stream->arg));

sys/kern/subr_compressor.c

571

compressor_fini(struct compressor *stream)

sys/kern/subr_compressor.c

574

stream->methods->fini(stream->priv);

sys/kern/subr_compressor.c

79

static void gz_reset(void *stream);

sys/kern/subr_compressor.c

80

static int gz_write(void *stream, void *data, size_t len, compressor_cb_t,

sys/kern/subr_compressor.c

82

static void gz_fini(void *stream);

sys/kern/uipc_usrreq.c

166

static SYSCTL_NODE(_net_local, SOCK_STREAM, stream,

sys/netgraph/bluetooth/socket/ng_btsocket_rfcomm.c

207

static SYSCTL_NODE(_net_bluetooth_rfcomm_sockets, OID_AUTO, stream,

sys/netinet/libalias/alias_db.c

145

AliasLog(FILE *stream, const char *format, ...)

sys/netinet/libalias/alias_db.c

150

vfprintf(stream, format, ap);

sys/netinet/libalias/alias_db.c

152

fflush(stream);

sys/netinet/libalias/alias_sctp.c

2727

SctpAliasLog(FILE *stream, const char *format, ...)

sys/netinet/libalias/alias_sctp.c

2732

vfprintf(stream, format, ap);

sys/netinet/libalias/alias_sctp.c

2734

fflush(stream);

sys/netinet/sctputil.c

138

sctp_log_strm_del_alt(struct sctp_tcb *stcb, uint32_t tsn, uint16_t sseq, uint16_t stream, int from)

sys/netinet/sctputil.c

148

sctp_clog.x.strlog.strm = stream;

sys/powerpc/include/dbdma.h

141

int stream, bus_addr_t data, size_t count, uint8_t interrupt,

sys/powerpc/powermac/dbdma.c

278

dbdma_insert_command(dbdma_channel_t *chan, int slot, int command, int stream,

sys/powerpc/powermac/dbdma.c

286

cmd.key = stream;

sys/sys/compressor.h

45

int compressor_format(const struct compressor *stream);

sys/sys/compressor.h

46

void compressor_reset(struct compressor *stream);

sys/sys/compressor.h

47

int compressor_write(struct compressor *stream, void *data,

sys/sys/compressor.h

49

int compressor_flush(struct compressor *stream);

sys/sys/compressor.h

50

void compressor_fini(struct compressor *stream);

tools/build/cross-build/fgetln_fallback.c

49

fgetln(FILE *stream, size_t *len)

tools/build/cross-build/fgetln_fallback.c

54

flockfile(stream);

tools/build/cross-build/fgetln_fallback.c

59

if (fb->fp != stream && fb->fp != NULL) {

tools/build/cross-build/fgetln_fallback.c

64

fb->fp = stream;

tools/build/cross-build/fgetln_fallback.c

66

nread = getline(&fb->buf, &fb->len, stream);

tools/build/cross-build/fgetln_fallback.c

68

funlockfile(stream);

tools/build/cross-build/fgetwln_fallback.c

48

fgetwln(FILE *stream, size_t *lenp)

tools/build/cross-build/fgetwln_fallback.c

57

if (fb->fp != stream && fb->fp != NULL) {

tools/build/cross-build/fgetwln_fallback.c

62

fb->fp = stream;

tools/build/cross-build/fgetwln_fallback.c

64

while ((wc = fgetwc(stream)) != WEOF) {

usr.bin/colrm/colrm.c

121

check(FILE *stream)

usr.bin/colrm/colrm.c

123

if (feof(stream))

usr.bin/colrm/colrm.c

125

if (ferror(stream))

usr.bin/colrm/colrm.c

126

err(EXIT_FAILURE, "%s", stream == stdin ? "stdin" : "stdout");

usr.bin/fmt/fmt.c

434

process_stream(FILE *stream, const char *name)

usr.bin/fmt/fmt.c

446

center_stream(stream, name);

usr.bin/fmt/fmt.c

449

while ((line = get_line(stream, &length)) != NULL) {

usr.bin/fmt/fmt.c

529

if (ferror(stream)) {

usr.bin/fmt/fmt.c

686

center_stream(FILE *stream, const char *name)

usr.bin/fmt/fmt.c

693

while ((line = get_line(stream, &length)) != NULL) {

usr.bin/fmt/fmt.c

710

if (ferror(stream)) {

usr.bin/fmt/fmt.c

728

get_line(FILE *stream, size_t *lengthp)

usr.bin/fmt/fmt.c

743

while ((ch = getwc(stream)) != '\n' && ch != WEOF) {

usr.bin/mail/def.h

269

#define trunc(stream) { \

usr.bin/mail/def.h

270

(void)fflush(stream); \

usr.bin/mail/def.h

271

(void)ftruncate(fileno(stream), ftello(stream)); \

usr.bin/morse/morse.c

592

fdecode(FILE *stream)

usr.bin/morse/morse.c

598

while (fgets(s, BUFSIZ - (s - buf), stream)) {

usr.bin/vtfontcvt/vtfontcvt.c

650

write_glyph_source(const void *ptr, size_t size, size_t nitems, FILE *stream)

usr.bin/vtfontcvt/vtfontcvt.c

658

if (fprintf(stream, "\n") < 0)

usr.bin/vtfontcvt/vtfontcvt.c

661

if (fprintf(stream, "0x%02x, ", data[i]) < 0)

usr.bin/vtfontcvt/vtfontcvt.c

664

if (fprintf(stream, "\n") < 0)

usr.bin/vtfontcvt/vtfontcvt.c

673

FILE *stream __unused)

usr.sbin/bhyve/hda_codec.c

178

uint8_t stream;

usr.sbin/bhyve/hda_codec.c

210

uint8_t stream, uint8_t dir);

usr.sbin/bhyve/hda_codec.c

580

uint8_t stream, uint8_t dir)

usr.sbin/bhyve/hda_codec.c

589

assert(stream);

usr.sbin/bhyve/hda_codec.c

598

run, stream, st->stream, dir);

usr.sbin/bhyve/hda_codec.c

600

if (stream != st->stream) {

usr.sbin/bhyve/hda_codec.c

697

err = hops->transfer(hci, st->stream, 1, st->buf, sizeof(st->buf));

usr.sbin/bhyve/hda_codec.c

761

hops->transfer(hci, st->stream, 0, st->buf, sizeof(st->buf));

usr.sbin/bhyve/hda_codec.c

831

res = (st->stream << 4) | st->channel;

usr.sbin/bhyve/hda_codec.c

835

st->stream = (payload >> 4) & 0x0f;

usr.sbin/bhyve/hda_codec.c

837

st->channel, st->stream);

usr.sbin/bhyve/hda_codec.c

838

if (!st->stream)

usr.sbin/bhyve/pci_hda.c

104

uint8_t stream;

usr.sbin/bhyve/pci_hda.c

1114

hda_transfer(struct hda_codec_inst *hci, uint8_t stream, uint8_t dir,

usr.sbin/bhyve/pci_hda.c

1132

if (!stream) {

usr.sbin/bhyve/pci_hda.c

1139

assert(stream < HDA_STREAM_TAGS_CNT);

usr.sbin/bhyve/pci_hda.c

1140

stream_ind = sc->stream_map[dir][stream];

usr.sbin/bhyve/pci_hda.c

1149

DPRINTF("Stream 0x%x stopped", stream);

usr.sbin/bhyve/pci_hda.c

1153

assert(st->stream == stream);

usr.sbin/bhyve/pci_hda.c

156

uint8_t stream, uint8_t dir);

usr.sbin/bhyve/pci_hda.c

199

static int hda_transfer(struct hda_codec_inst *hci, uint8_t stream,

usr.sbin/bhyve/pci_hda.c

495

hda_notify_codecs(struct hda_softc *sc, uint8_t run, uint8_t stream,

usr.sbin/bhyve/pci_hda.c

512

err = codec->notify(hci, run, stream, dir);

usr.sbin/bhyve/pci_hda.c

667

st->stream = strm;

usr.sbin/bhyve/pci_hda.c

685

uint8_t strm = st->stream;

usr.sbin/bhyve/pci_hda.h

78

int (*notify)(struct hda_codec_inst *hci, uint8_t run, uint8_t stream,

usr.sbin/bhyve/pci_hda.h

86

int (*transfer)(struct hda_codec_inst *hci, uint8_t stream,

usr.sbin/fwcontrol/fwdv.c

180

if (pkt->mode.stream.len <= sizeof(struct ciphdr))

usr.sbin/fwcontrol/fwdv.c

291

pkt->mode.stream.len = DSIZE + sizeof(struct ciphdr);

usr.sbin/fwcontrol/fwdv.c

292

pkt->mode.stream.sy = 0;

usr.sbin/fwcontrol/fwdv.c

293

pkt->mode.stream.tcode = FWTCODE_STREAM;

usr.sbin/fwcontrol/fwdv.c

294

pkt->mode.stream.chtag = ich;

usr.sbin/fwcontrol/fwdv.c

297

pkt->mode.stream.len = sizeof(struct ciphdr);

usr.sbin/fwcontrol/fwmpegts.c

220

if (pkt->mode.stream.len <= sizeof(struct ciphdr)) {

usr.sbin/fwcontrol/fwmpegts.c

229

pkt->mode.stream.len - sizeof(struct ciphdr));

usr.sbin/fwcontrol/fwmpegts.c

249

pkt->mode.stream.len - sizeof(struct ciphdr));

usr.sbin/fwcontrol/fwmpegts.c

259

pkt_size = pkt->mode.stream.len + 4;

usr.sbin/prometheus_sysctl_exporter/prometheus_sysctl_exporter.c

543

z_stream stream = {

usr.sbin/prometheus_sysctl_exporter/prometheus_sysctl_exporter.c

550

if (deflateInit2(&stream, Z_DEFAULT_COMPRESSION, Z_DEFLATED,

usr.sbin/prometheus_sysctl_exporter/prometheus_sysctl_exporter.c

552

deflate(&stream, Z_FINISH) != Z_STREAM_END) {

usr.sbin/prometheus_sysctl_exporter/prometheus_sysctl_exporter.c

555

*outlen = stream.total_out;

usr.sbin/prometheus_sysctl_exporter/prometheus_sysctl_exporter.c

556

return (deflateEnd(&stream) == Z_OK);

usr.sbin/spi/spi.c

162

int err, ch, hdev, finfo, stream, fdir;

usr.sbin/spi/spi.c

167

stream = 0;

usr.sbin/spi/spi.c

281

stream = 1;

usr.sbin/spi/spi.c

367

if (stream) {

usr.sbin/ypldap/parse.y

441

if ((c = getc(file->stream)) == EOF) {

usr.sbin/ypldap/parse.y

451

while ((c = getc(file->stream)) == '\\') {

usr.sbin/ypldap/parse.y

452

next = getc(file->stream);

usr.sbin/ypldap/parse.y

464

c = getc(file->stream);

usr.sbin/ypldap/parse.y

58

FILE *stream;

usr.sbin/ypldap/parse.y

691

if ((nfile->stream = fopen(nfile->name, "r")) == NULL) {

usr.sbin/ypldap/parse.y

697

check_file_secrecy(fileno(nfile->stream), nfile->name)) {

usr.sbin/ypldap/parse.y

698

fclose(nfile->stream);

usr.sbin/ypldap/parse.y

717

fclose(file->stream);