| /src/crypto/openssl/test/ |
| H A D | quic_stream_test.c | 377 QUIC_RSTREAM *rstream = NULL; in test_rstream_simple() local
389 if (!TEST_ptr(rstream = ossl_quic_rstream_new(NULL, NULL, 0))) in test_rstream_simple()
392 if (!TEST_true(ossl_quic_rstream_queue_data(rstream, NULL, 5, in test_rstream_simple()
394 || !TEST_true(ossl_quic_rstream_queue_data(rstream, NULL, in test_rstream_simple()
398 || !TEST_true(ossl_quic_rstream_peek(rstream, buf, sizeof(buf), in test_rstream_simple()
402 || !TEST_true(ossl_quic_rstream_queue_data(rstream, NULL, in test_rstream_simple()
406 || !TEST_true(ossl_quic_rstream_queue_data(rstream, NULL, 0, in test_rstream_simple()
408 || !TEST_true(ossl_quic_rstream_peek(rstream, buf, sizeof(buf), in test_rstream_simple()
413 || (use_rbuf && !TEST_false(ossl_quic_rstream_move_to_rbuf(rstream))) in test_rstream_simple()
415 && !TEST_true(ossl_quic_rstream_resize_rbuf(rstream, in test_rstream_simple()
[all …]
|
| H A D | quic_txp_test.c | 1516 || !TEST_ptr(s->rstream = ossl_quic_rstream_new(&s->rxfc, in run_script()
|
| /src/contrib/llvm-project/openmp/runtime/src/ |
| H A D | extractExternal.cpp | 63 class rstream : public _rstream { class
65 template <class T> inline rstream &doRead(T &x) { in doRead()
85 rstream(const char *buf, streamsize size) in rstream() function in rstream
89 rstream(const char *fileName) : _rstream(getBuf(fileName)) {} in rstream() function in rstream
90 rstream &operator>>(int &x) { return doRead(x); } in operator >>()
91 rstream &operator>>(unsigned &x) { return doRead(x); } in operator >>()
92 rstream &operator>>(short &x) { return doRead(x); } in operator >>()
93 rstream &operator>>(unsigned short &x) { return doRead(x); } in operator >>()
94 rstream &operator>>(Symbol &e) { in operator >>()
136 StringTable(rstream &f) { in StringTable()
[all …]
|
| /src/crypto/openssl/ssl/quic/ |
| H A D | quic_stream_map.c | 188 ossl_quic_rstream_free(stream->rstream); in ossl_quic_stream_map_release()
189 stream->rstream = NULL; in ossl_quic_stream_map_release()
582 ossl_quic_rstream_free(qs->rstream); in ossl_quic_stream_map_notify_totally_read()
583 qs->rstream = NULL; in ossl_quic_stream_map_notify_totally_read()
616 ossl_quic_rstream_free(qs->rstream); in ossl_quic_stream_map_notify_reset_recv_part()
617 qs->rstream = NULL; in ossl_quic_stream_map_notify_reset_recv_part()
|
| H A D | quic_rx_depack.c | 269 QUIC_RSTREAM *rstream; in depack_do_frame_crypto() local
285 rstream = ch->crypto_recv[ackm_data->pkt_space]; in depack_do_frame_crypto()
286 if (!ossl_assert(rstream != NULL)) in depack_do_frame_crypto()
312 if (!ossl_quic_rstream_queue_data(rstream, parent_pkt, in depack_do_frame_crypto()
609 && !ossl_quic_rstream_queue_data(stream->rstream, parent_pkt, in depack_do_frame_stream()
628 && !ossl_quic_rstream_available(stream->rstream, &rs_avail, &rs_fin)) { in depack_do_frame_stream()
|
| H A D | quic_channel.c | 76 static int crypto_ensure_empty(QUIC_RSTREAM *rstream);
976 static int crypto_ensure_empty(QUIC_RSTREAM *rstream) in crypto_ensure_empty() argument
981 if (rstream == NULL) in crypto_ensure_empty()
984 if (!ossl_quic_rstream_available(rstream, &avail, &is_fin)) in crypto_ensure_empty()
994 QUIC_RSTREAM *rstream; in ch_on_crypto_recv_record() local
1020 rstream = ch->crypto_recv[ossl_quic_enc_level_to_pn_space(ch->rx_enc_level)]; in ch_on_crypto_recv_record()
1021 if (rstream == NULL) in ch_on_crypto_recv_record()
1024 return ossl_quic_rstream_get_record(rstream, buf, bytes_read, in ch_on_crypto_recv_record()
1031 QUIC_RSTREAM *rstream; in ch_on_crypto_release_record() local
1035 rstream = ch->crypto_recv[rx_pn_space]; in ch_on_crypto_release_record()
[all …]
|
| H A D | quic_tserver.c | 286 if (!ossl_quic_rstream_read(qs->rstream, buf, buf_len, in ossl_quic_tserver_read()
341 if (!ossl_quic_rstream_peek(qs->rstream, buf, sizeof(buf), in ossl_quic_tserver_has_read_ended()
348 if (!ossl_quic_rstream_read(qs->rstream, buf, sizeof(buf), in ossl_quic_tserver_has_read_ended()
|
| H A D | quic_impl.c | 991 if (xso->stream->rstream != NULL) in xso_update_options()
992 ossl_quic_rstream_set_cleanse(xso->stream->rstream, cleanse); in xso_update_options()
2953 if (!ossl_quic_rstream_peek(stream->rstream, buf, buf_len, in quic_read_actual()
2958 if (!ossl_quic_rstream_read(stream->rstream, buf, buf_len, in quic_read_actual()
5155 && ossl_quic_rstream_available(xso->stream->rstream, &avail, &fin) in test_poll_event_r()
|
| /src/crypto/openssl/demos/http3/ |
| H A D | ossl-nghttp3-demo-server.c | 397 SSL *rstream = NULL; in quic_server_h3streams() local
409 rstream = SSL_new_stream(conn, SSL_STREAM_FLAG_UNI); in quic_server_h3streams()
410 if (rstream != NULL) { in quic_server_h3streams()
412 (unsigned long long)SSL_get_stream_id(rstream)); in quic_server_h3streams()
434 r_streamid = SSL_get_stream_id(rstream); in quic_server_h3streams()
449 add_id(SSL_get_stream_id(rstream), rstream, h3ssl); in quic_server_h3streams()
456 SSL_free(rstream); in quic_server_h3streams()
|
| /src/contrib/ofed/librdmacm/man/ |
| H A D | CMakeLists.txt | 62 rstream.1
|
| /src/crypto/openssl/include/internal/ |
| H A D | quic_stream_map.h | 152 QUIC_RSTREAM *rstream; /* NULL if TX only */ member
526 if (!ossl_quic_rstream_available(s->rstream, &avail, &fin)) in ossl_quic_stream_recv_pending()
|
| /src/sys/contrib/openzfs/contrib/pyzfs/libzfs_core/test/ |
| H A D | test_libzfs_core.py | 2747 with tempfile.NamedTemporaryFile(suffix='.zstream') as rstream:
2749 src, None, rstream.fileno(), None, resumeobj, resumeoff)
2750 rstream.seek(0)
2751 lzc.lzc_receive_resumable(dst, rstream.fileno())
2803 with tempfile.NamedTemporaryFile(suffix='.zstream') as rstream:
2805 snap2, snap1, rstream.fileno(), None, resumeobj, resumeoff)
2806 rstream.seek(0)
2807 lzc.lzc_receive_resumable(dst2, rstream.fileno())
|