| /third_party/boost/libs/asio/test/ssl/ |
| D | stream.cpp | 74 ssl::stream<ip::tcp::socket> stream1(ioc, context); in test() local
86 ssl::stream<ip::tcp::socket>::executor_type ex = stream1.get_executor(); in test()
91 SSL* ssl1 = stream1.native_handle(); in test()
95 = stream1.lowest_layer(); in test()
98 const ssl::stream<ip::tcp::socket>& stream5 = stream1; in test()
103 stream1.set_verify_mode(ssl::verify_none); in test()
104 stream1.set_verify_mode(ssl::verify_none, ec); in test()
106 stream1.set_verify_depth(1); in test()
107 stream1.set_verify_depth(1, ec); in test()
109 stream1.set_verify_callback(verify_callback); in test()
[all …]
|
| /third_party/boost/libs/asio/test/ |
| D | buffered_stream.cpp | 82 stream_type stream1(ioc); in test_compile() local
85 stream_type::executor_type ex = stream1.get_executor(); in test_compile()
88 stream_type::lowest_layer_type& lowest_layer = stream1.lowest_layer(); in test_compile()
91 stream1.write_some(buffer(mutable_char_buffer)); in test_compile()
92 stream1.write_some(buffer(const_char_buffer)); in test_compile()
93 stream1.write_some(mutable_buffers); in test_compile()
94 stream1.write_some(const_buffers); in test_compile()
95 stream1.write_some(null_buffers()); in test_compile()
96 stream1.write_some(buffer(mutable_char_buffer), ec); in test_compile()
97 stream1.write_some(buffer(const_char_buffer), ec); in test_compile()
[all …]
|
| D | buffered_read_stream.cpp | 78 stream_type stream1(ioc); in test_compile() local
81 stream_type::executor_type ex = stream1.get_executor(); in test_compile()
84 stream_type::lowest_layer_type& lowest_layer = stream1.lowest_layer(); in test_compile()
87 stream1.write_some(buffer(mutable_char_buffer)); in test_compile()
88 stream1.write_some(buffer(const_char_buffer)); in test_compile()
89 stream1.write_some(mutable_buffers); in test_compile()
90 stream1.write_some(const_buffers); in test_compile()
91 stream1.write_some(null_buffers()); in test_compile()
92 stream1.write_some(buffer(mutable_char_buffer), ec); in test_compile()
93 stream1.write_some(buffer(const_char_buffer), ec); in test_compile()
[all …]
|
| D | buffered_write_stream.cpp | 78 stream_type stream1(ioc); in test_compile() local
81 stream_type::executor_type ex = stream1.get_executor(); in test_compile()
84 stream_type::lowest_layer_type& lowest_layer = stream1.lowest_layer(); in test_compile()
87 stream1.write_some(buffer(mutable_char_buffer)); in test_compile()
88 stream1.write_some(buffer(const_char_buffer)); in test_compile()
89 stream1.write_some(mutable_buffers); in test_compile()
90 stream1.write_some(const_buffers); in test_compile()
91 stream1.write_some(null_buffers()); in test_compile()
92 stream1.write_some(buffer(mutable_char_buffer), ec); in test_compile()
93 stream1.write_some(buffer(const_char_buffer), ec); in test_compile()
[all …]
|
| /third_party/boost/libs/fiber/examples/cuda/ |
| D | multiple_streams.cu | 38 cudaStream_t stream0, stream1; in main() local
40 cudaStreamCreate( & stream1); in main()
63 … cudaMemcpyAsync( dev_a1, host_a + i + size, size * sizeof( int), cudaMemcpyHostToDevice, stream1); in main()
65 … cudaMemcpyAsync( dev_b1, host_b + i + size, size * sizeof( int), cudaMemcpyHostToDevice, stream1); in main()
67 … vector_add<<< size / 256, 256, 0, stream1 >>>( dev_a1, dev_b1, dev_c1, size); in main()
69 … cudaMemcpyAsync( host_c + i + size, dev_c1, size * sizeof( int), cudaMemcpyDeviceToHost, stream1); in main()
71 auto results = boost::fibers::cuda::waitfor_all( stream0, stream1); in main()
73 … BOOST_ASSERT( stream0 == std::get< 0 >( result) || stream1 == std::get< 0 >( result) ); in main()
87 cudaStreamDestroy( stream1); in main()
|
| /third_party/boost/libs/fiber/examples/hip/ |
| D | multiple_streams.cpp | 37 hipStream_t stream0, stream1; in main() local
39 hipStreamCreate( & stream1); in main()
62 … hipMemcpyAsync( dev_a1, host_a + i + size, size * sizeof( int), hipMemcpyHostToDevice, stream1); in main()
64 … hipMemcpyAsync( dev_b1, host_b + i + size, size * sizeof( int), hipMemcpyHostToDevice, stream1); in main()
66 …hipLaunchKernel( vector_add, dim3(size / 256), dim3(256), 0, stream1, dev_a1, dev_b1, dev_c1, size… in main()
68 … hipMemcpyAsync( host_c + i + size, dev_c1, size * sizeof( int), hipMemcpyDeviceToHost, stream1); in main()
70 auto results = boost::fibers::hip::waitfor_all( stream0, stream1); in main()
72 … BOOST_ASSERT( stream0 == std::get< 0 >( result) || stream1 == std::get< 0 >( result) ); in main()
86 hipStreamDestroy( stream1); in main()
|
| /third_party/grpc/test/core/transport/ |
| D | byte_stream_test.cc | 213 ByteStreamCache::CachingByteStream stream1(&cache); in TEST() local
219 EXPECT_TRUE(stream1.Next(~(size_t)0, &closure)); in TEST()
221 grpc_error* error = stream1.Pull(&output); in TEST()
234 EXPECT_TRUE(stream1.Next(~(size_t)0, &closure)); in TEST()
235 error = stream1.Pull(&output); in TEST()
240 stream1.Orphan(); in TEST()
|
| /third_party/glib/gio/ |
| D | giostream.c | 673 GIOStream *stream1; member
688 g_object_unref (ctx->stream1); in splice_context_free()
786 g_io_stream_close_async (ctx->stream1, in splice_cb()
844 g_io_stream_splice_async (GIOStream *stream1, in g_io_stream_splice_async() argument
867 ctx->stream1 = g_object_ref (stream1); in g_io_stream_splice_async()
886 istream = g_io_stream_get_input_stream (stream1); in g_io_stream_splice_async()
893 ostream = g_io_stream_get_output_stream (stream1); in g_io_stream_splice_async()
|
| D | giostream.h | 95 void g_io_stream_splice_async (GIOStream *stream1,
|
| /third_party/boost/libs/iostreams/test/ |
| D | tee_test.cpp | 249 std::ofstream stream1(dest1.name().c_str(), out_mode); in test_std_io() local
250 out.push(tee(stream1)); in test_std_io()
262 std::ofstream stream1(dest1.name().c_str(), out_mode); in test_std_io() local
263 out.push( tee ( stream1, in test_std_io()
288 std::ofstream stream1(dest1.name().c_str(), out_mode); in test_std_io() local
290 out.push(tee(stream1, stream2)); in test_std_io()
|
| /third_party/gstreamer/gstreamer/tests/check/gst/ |
| D | gstmessage.c | 435 GstStream *stream1, *stream2; in GST_START_TEST() local
442 stream1 = gst_stream_new ("stream-1", caps1, GST_STREAM_TYPE_AUDIO, 0); in GST_START_TEST()
446 fail_unless (gst_stream_collection_add_stream (collection, stream1)); in GST_START_TEST()
465 GstStream *stream1, *stream2, *stream3; in GST_START_TEST() local
472 stream1 = gst_stream_new ("stream-1", caps1, GST_STREAM_TYPE_AUDIO, 0); in GST_START_TEST()
476 fail_unless (gst_stream_collection_add_stream (collection, stream1)); in GST_START_TEST()
493 gst_message_streams_selected_add (message, stream1); in GST_START_TEST()
|
| D | gstevent.c | 286 GstStream *stream1, *stream2; in GST_START_TEST() local
293 stream1 = gst_stream_new ("stream-1", caps1, GST_STREAM_TYPE_AUDIO, 0); in GST_START_TEST()
297 fail_unless (gst_stream_collection_add_stream (collection, stream1)); in GST_START_TEST()
|
| /third_party/skia/tests/ |
| D | StreamTest.cpp | 495 SkFILEStream stream1(filename.c_str()); in DEF_TEST() local
496 if (!stream1.isValid()) { in DEF_TEST()
500 REPORTER_ASSERT(r, stream1.hasLength()); in DEF_TEST()
501 REPORTER_ASSERT(r, stream1.hasPosition()); in DEF_TEST()
506 const size_t size = stream1.getLength(); in DEF_TEST()
508 if (!stream1.seek(middle)) { in DEF_TEST()
512 REPORTER_ASSERT(r, stream1.getPosition() == middle); in DEF_TEST()
528 REPORTER_ASSERT(r, stream1.read(expected.get(), remaining) == remaining); in DEF_TEST()
|
| /third_party/flutter/skia/tests/ |
| D | StreamTest.cpp | 485 SkFILEStream stream1(filename.c_str()); in DEF_TEST() local
486 if (!stream1.isValid()) { in DEF_TEST()
490 REPORTER_ASSERT(r, stream1.hasLength()); in DEF_TEST()
491 REPORTER_ASSERT(r, stream1.hasPosition()); in DEF_TEST()
496 const size_t size = stream1.getLength(); in DEF_TEST()
498 if (!stream1.seek(middle)) { in DEF_TEST()
502 REPORTER_ASSERT(r, stream1.getPosition() == middle); in DEF_TEST()
518 REPORTER_ASSERT(r, stream1.read(expected.get(), remaining) == remaining); in DEF_TEST()
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/rtsp/ |
| D | gstrtspconnection.c | 158 GIOStream *stream1; member
924 conn->stream1 = G_IO_STREAM (connection); in setup_tunneling()
927 conn->output_stream = g_io_stream_get_output_stream (conn->stream1); in setup_tunneling()
2873 if (conn->stream1) { in gst_rtsp_connection_close()
2874 g_object_unref (conn->stream1); in gst_rtsp_connection_close()
2875 conn->stream1 = NULL; in gst_rtsp_connection_close()
3619 conn->stream1 = conn2->stream0; in gst_rtsp_connection_do_tunnel()
3627 conn->stream1 = conn->stream0; in gst_rtsp_connection_do_tunnel()
3640 conn2->stream1 = NULL; in gst_rtsp_connection_do_tunnel()
3843 if (conn->stream1) { in gst_rtsp_source_dispatch_read()
[all …]
|
| /third_party/flutter/skia/third_party/externals/angle2/src/tests/compiler_tests/ |
| D | CollectVariables_test.cpp | 1502 std::ostringstream stream1; in TEST_F() local
1503 stream1 << kHeader << kLayout << qualifier << " in vec4 texcoord[];\n" << kFunctionBody; in TEST_F()
1504 compile(stream1.str()); in TEST_F()
|
| /third_party/skia/third_party/externals/angle2/src/tests/compiler_tests/ |
| D | CollectVariables_test.cpp | 1535 std::ostringstream stream1; in TEST_F() local
1536 stream1 << kHeader << kLayout << qualifier << " in vec4 texcoord[];\n" << kFunctionBody; in TEST_F()
1537 compile(stream1.str()); in TEST_F()
|
| /third_party/node/deps/npm/node_modules/mississippi/ |
| D | readme.md | 28 ##### `miss.pipe(stream1, stream2, stream3, ..., cb)`
93 ##### `var pipeline = miss.pipeline(stream1, stream2, stream3, ...)`
|
| /third_party/vk-gl-cts/external/openglcts/modules/gl/ |
| D | gl3cTransformFeedbackOverflowQueryTests.cpp | 1173 …void verifyQueryResults(GLboolean any, GLboolean stream0, GLboolean stream1, GLboolean stream2 = G… in verifyQueryResults() argument
1186 result &= verifyQueryResult(m_stream_overflow_query[1], stream1); in verifyQueryResults()
|
| /third_party/nghttp2/tests/ |
| D | nghttp2_session_test.c | 3375 nghttp2_stream *stream1, *stream2; in test_nghttp2_session_on_settings_received() local
3407 stream1 = open_sent_stream(session, 1); in test_nghttp2_session_on_settings_received()
3412 stream1->remote_window_size = 16 * 1024; in test_nghttp2_session_on_settings_received()
3424 CU_ASSERT(64 * 1024 == stream1->remote_window_size); in test_nghttp2_session_on_settings_received()
3431 CU_ASSERT(16 * 1024 == stream1->remote_window_size); in test_nghttp2_session_on_settings_received()
3435 session, stream1->stream_id)); in test_nghttp2_session_on_settings_received()
3534 stream1 = open_recv_stream(session, 1); in test_nghttp2_session_on_settings_received()
3565 CU_ASSERT(NGHTTP2_STREAM_CLOSING == stream1->state); in test_nghttp2_session_on_settings_received()
10144 nghttp2_stream *stream1, *stream2, *stream3, *stream5; in test_nghttp2_session_change_stream_priority() local
10152 stream1 = open_recv_stream(session, 1); in test_nghttp2_session_change_stream_priority()
[all …]
|
| /third_party/skia/third_party/externals/angle2/src/tests/gl_tests/ |
| D | UniformBufferTest.cpp | 2534 std::ostringstream stream1; in TEST_P() local
2536 generateArraySizeAndDivisorsDeclaration(stream1, false, true, false); in TEST_P()
2542 stream1.str() + in TEST_P()
|
| /third_party/gstreamer/gstplugins_good/gst/isomp4/ |
| D | qtdemux.c | 10829 qtdemux_track_id_compare_func (QtDemuxStream ** stream1, in qtdemux_track_id_compare_func() argument
10832 return (gint) (*stream1)->track_id - (gint) (*stream2)->track_id; in qtdemux_track_id_compare_func()
|