Home
last modified time | relevance | path

Searched refs:TestStream (Results 1 – 23 of 23) sorted by relevance

/external/apache-commons-compress/src/test/java/org/apache/commons/compress/compressors/lz77support/
DAbstractLZ77CompressorInputStreamTest.java32 private static class TestStream extends AbstractLZ77CompressorInputStream { class in AbstractLZ77CompressorInputStreamTest
34 TestStream(InputStream in) throws IOException { in TestStream() method in AbstractLZ77CompressorInputStreamTest.TestStream
53 try (TestStream s = new TestStream(new ByteArrayInputStream(data))) { in cantPrefillAfterDataHasBeenRead()
63 try (TestStream s = new TestStream(new ByteArrayInputStream(new byte[0]))) { in prefillCanBeUsedForBackReferences()
77 try (TestStream s = new TestStream(new ByteArrayInputStream(new byte[0]))) { in ifPrefillExceedsWindowSizeTheLastBytesAreUsed()
/external/skia/tests/
DJpegGainmapTest.cpp99 class TestStream : public SkStream { class
106 TestStream(Type type, SkStream* stream) in TestStream() function in __anon241f09f40111::TestStream
110 ~TestStream() override {} in ~TestStream()
418 const TestStream::Type streamType; in DEF_TEST()
422 {TestStream::Type::kMemoryMapped, false, 1024}, in DEF_TEST()
423 {TestStream::Type::kMemoryMapped, true, 1024}, in DEF_TEST()
424 {TestStream::Type::kSeekable, false, 1024}, in DEF_TEST()
425 {TestStream::Type::kSeekable, true, 1024}, in DEF_TEST()
426 {TestStream::Type::kSeekable, false, 7}, in DEF_TEST()
427 {TestStream::Type::kSeekable, true, 13}, in DEF_TEST()
[all …]
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/
Dquic_session_test.cc218 class TestStream : public QuicStream { class
220 TestStream(QuicStreamId id, QuicSession* session, StreamType type) in TestStream() function in quic::test::__anon1d6b506e0111::TestStream
221 : TestStream(id, session, /*is_static=*/false, type) {} in TestStream()
223 TestStream(QuicStreamId id, QuicSession* session, bool is_static, in TestStream() function in quic::test::__anon1d6b506e0111::TestStream
227 TestStream(PendingStream* pending, QuicSession* session) in TestStream() function in quic::test::__anon1d6b506e0111::TestStream
274 TestStream* CreateOutgoingBidirectionalStream() { in CreateOutgoingBidirectionalStream()
280 TestStream* stream = new TestStream(id, this, BIDIRECTIONAL); in CreateOutgoingBidirectionalStream()
285 TestStream* CreateOutgoingUnidirectionalStream() { in CreateOutgoingUnidirectionalStream()
286 TestStream* stream = new TestStream(GetNextOutgoingUnidirectionalStreamId(), in CreateOutgoingUnidirectionalStream()
292 TestStream* CreateIncomingStream(QuicStreamId id) override { in CreateIncomingStream()
[all …]
Dquic_stream_test.cc60 class TestStream : public QuicStream { class
62 TestStream(QuicStreamId id, QuicSession* session, StreamType type) in TestStream() function in quic::test::__anon97d5b8f60111::TestStream
67 TestStream(PendingStream* pending, QuicSession* session, bool is_static) in TestStream() function in quic::test::__anon97d5b8f60111::TestStream
126 stream_ = new StrictMock<TestStream>(kTestStreamId, session_.get(), in Initialize()
175 StrictMock<TestStream>* stream_;
200 TestStream stream(&pending, session_.get(), false); in TEST_P()
204 TestStream stream2(&pending2, session_.get(), true); in TEST_P()
212 TestStream stream(&pending, session_.get(), false); in TEST_P()
223 TestStream stream(&pending, session_.get(), false); in TEST_P()
295 TestStream stream(&pending, session_.get(), false); in TEST_P()
[all …]
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/
Dquic_session_test.cc218 class TestStream : public QuicStream { class
220 TestStream(QuicStreamId id, QuicSession* session, StreamType type) in TestStream() function in quic::test::__anon4264190a0111::TestStream
221 : TestStream(id, session, /*is_static=*/false, type) {} in TestStream()
223 TestStream(QuicStreamId id, QuicSession* session, bool is_static, in TestStream() function in quic::test::__anon4264190a0111::TestStream
227 TestStream(PendingStream* pending, QuicSession* session) in TestStream() function in quic::test::__anon4264190a0111::TestStream
274 TestStream* CreateOutgoingBidirectionalStream() { in CreateOutgoingBidirectionalStream()
280 TestStream* stream = new TestStream(id, this, BIDIRECTIONAL); in CreateOutgoingBidirectionalStream()
285 TestStream* CreateOutgoingUnidirectionalStream() { in CreateOutgoingUnidirectionalStream()
286 TestStream* stream = new TestStream(GetNextOutgoingUnidirectionalStreamId(), in CreateOutgoingUnidirectionalStream()
292 TestStream* CreateIncomingStream(QuicStreamId id) override { in CreateIncomingStream()
[all …]
Dquic_stream_test.cc60 class TestStream : public QuicStream { class
62 TestStream(QuicStreamId id, QuicSession* session, StreamType type) in TestStream() function in quic::test::__anonee49de120111::TestStream
67 TestStream(PendingStream* pending, QuicSession* session, bool is_static) in TestStream() function in quic::test::__anonee49de120111::TestStream
126 stream_ = new StrictMock<TestStream>(kTestStreamId, session_.get(), in Initialize()
175 StrictMock<TestStream>* stream_;
200 TestStream stream(&pending, session_.get(), false); in TEST_P()
204 TestStream stream2(&pending2, session_.get(), true); in TEST_P()
212 TestStream stream(&pending, session_.get(), false); in TEST_P()
223 TestStream stream(&pending, session_.get(), false); in TEST_P()
295 TestStream stream(&pending, session_.get(), false); in TEST_P()
[all …]
/external/pytorch/aten/src/ATen/test/
Dcuda_stream_test.cpp34 TEST(TestStream, CopyAndMoveTest) { in TEST() argument
73 TEST(TestStream, GetAndSetTest) { in TEST() argument
100 TEST(TestStream, MultithreadGetAndSetTest) { in TEST() argument
119 TEST(TestStream, CUDAGuardTest) { in TEST() argument
173 TEST(TestStream, StreamPoolTest) { in TEST() argument
194 TEST(TestStream, MultiGPUTest) { in TEST() argument
212 TEST(TestStream, CUDAEventSyncTest) { in TEST() argument
232 TEST(TestStream, CrossDeviceTest) { in TEST() argument
258 TEST(TestStream, GenericInlineCUDAEventTest) { in TEST() argument
278 TEST(TestStream, GenericVirtualCUDAEventTest) { in TEST() argument
[all …]
/external/webrtc/net/dcsctp/tx/
Dstream_scheduler_test.cc72 class TestStream { class
74 TestStream(StreamScheduler& scheduler, in TestStream() function in dcsctp::__anone0093e9b0111::TestStream
337 TestStream stream1(scheduler, StreamID(1), StreamPriority(1)); in TEST()
338 TestStream stream2(scheduler, StreamID(2), StreamPriority(1)); in TEST()
350 TestStream stream1(scheduler, StreamID(1), StreamPriority(1)); in TEST()
351 TestStream stream2(scheduler, StreamID(2), StreamPriority(1)); in TEST()
359 TestStream stream3(scheduler, StreamID(3), StreamPriority(1)); in TEST()
360 TestStream stream4(scheduler, StreamID(4), StreamPriority(1)); in TEST()
590 TestStream stream1(scheduler, StreamID(1), StreamPriority(100), kPayloadSize); in TEST()
591 TestStream stream2(scheduler, StreamID(2), StreamPriority(200), kPayloadSize); in TEST()
[all …]
/external/pigweed/pw_rpc_transport/
Dstream_rpc_dispatcher_test.cc61 class TestStream : public stream::NonSeekableReader { class
63 TestStream() : position_(0) {} in TestStream() function in pw::rpc::__anonde8846ca0111::TestStream
122 TestStream test_stream; in TEST()
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/http/
Dquic_spdy_session_test.cc242 class TestStream : public QuicSpdyStream { class
244 TestStream(QuicStreamId id, QuicSpdySession* session, StreamType type) in TestStream() function in quic::test::__anon945e35bc0111::TestStream
247 TestStream(PendingStream* pending, QuicSpdySession* session) in TestStream() function in quic::test::__anon945e35bc0111::TestStream
292 TestStream* CreateOutgoingBidirectionalStream() override { in CreateOutgoingBidirectionalStream()
293 TestStream* stream = new TestStream(GetNextOutgoingBidirectionalStreamId(), in CreateOutgoingBidirectionalStream()
299 TestStream* CreateOutgoingUnidirectionalStream() override { in CreateOutgoingUnidirectionalStream()
300 TestStream* stream = new TestStream(GetNextOutgoingUnidirectionalStreamId(), in CreateOutgoingUnidirectionalStream()
306 TestStream* CreateIncomingStream(QuicStreamId id) override { in CreateIncomingStream()
316 TestStream* stream = new TestStream( in CreateIncomingStream()
325 TestStream* CreateIncomingStream(PendingStream* pending) override { in CreateIncomingStream()
[all …]
Dquic_receive_control_stream_test.cc77 class TestStream : public QuicSpdyStream { class
79 TestStream(QuicStreamId id, QuicSpdySession* session) in TestStream() function in quic::test::__anon205332e70111::TestStream
81 ~TestStream() override = default;
112 stream_ = new TestStream(GetNthClientInitiatedBidirectionalStreamId( in QuicReceiveControlStreamTest()
130 TestStream* stream_;
Dquic_spdy_stream_test.cc229 class TestStream : public QuicSpdyStream { class
231 TestStream(QuicStreamId id, QuicSpdySession* session, in TestStream() function in quic::test::__anonc23a2c840111::TestStream
236 ~TestStream() override = default;
432 new StrictMock<TestStream>(GetNthClientInitiatedBidirectionalId(0), in InitializeWithPerspective()
436 new StrictMock<TestStream>(GetNthClientInitiatedBidirectionalId(1), in InitializeWithPerspective()
537 TestStream* stream_;
538 TestStream* stream2_;
1831 new StrictMock<TestStream>(GetNthClientInitiatedBidirectionalStreamId( in TEST_P()
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/http/
Dquic_spdy_session_test.cc242 class TestStream : public QuicSpdyStream { class
244 TestStream(QuicStreamId id, QuicSpdySession* session, StreamType type) in TestStream() function in quic::test::__anon016f71580111::TestStream
247 TestStream(PendingStream* pending, QuicSpdySession* session) in TestStream() function in quic::test::__anon016f71580111::TestStream
292 TestStream* CreateOutgoingBidirectionalStream() override { in CreateOutgoingBidirectionalStream()
293 TestStream* stream = new TestStream(GetNextOutgoingBidirectionalStreamId(), in CreateOutgoingBidirectionalStream()
299 TestStream* CreateOutgoingUnidirectionalStream() override { in CreateOutgoingUnidirectionalStream()
300 TestStream* stream = new TestStream(GetNextOutgoingUnidirectionalStreamId(), in CreateOutgoingUnidirectionalStream()
306 TestStream* CreateIncomingStream(QuicStreamId id) override { in CreateIncomingStream()
316 TestStream* stream = new TestStream( in CreateIncomingStream()
325 TestStream* CreateIncomingStream(PendingStream* pending) override { in CreateIncomingStream()
[all …]
Dquic_receive_control_stream_test.cc77 class TestStream : public QuicSpdyStream { class
79 TestStream(QuicStreamId id, QuicSpdySession* session) in TestStream() function in quic::test::__anon78e8a1830111::TestStream
81 ~TestStream() override = default;
112 stream_ = new TestStream(GetNthClientInitiatedBidirectionalStreamId( in QuicReceiveControlStreamTest()
130 TestStream* stream_;
Dquic_spdy_stream_test.cc229 class TestStream : public QuicSpdyStream { class
231 TestStream(QuicStreamId id, QuicSpdySession* session, in TestStream() function in quic::test::__anonb60464a00111::TestStream
236 ~TestStream() override = default;
432 new StrictMock<TestStream>(GetNthClientInitiatedBidirectionalId(0), in InitializeWithPerspective()
436 new StrictMock<TestStream>(GetNthClientInitiatedBidirectionalId(1), in InitializeWithPerspective()
537 TestStream* stream_;
538 TestStream* stream2_;
1831 new StrictMock<TestStream>(GetNthClientInitiatedBidirectionalStreamId( in TEST_P()
/external/marisa-trie/tests/
Dio-test.cc204 void TestStream() { in TestStream() function
246 TestStream(); in main()
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/tools/
Dquic_simple_server_stream_test.cc57 class TestStream : public QuicSimpleServerStream { class
59 TestStream(QuicStreamId stream_id, QuicSpdySession* session, StreamType type, in TestStream() function in quic::test::TestStream
70 ~TestStream() override = default;
250 stream_ = new StrictMock<TestStream>( in QuicSimpleServerStreamTest()
295 StrictMock<TestStream>* stream_; // Owned by session_.
538 AlarmTestDelegate(TestStream* stream) : stream_(stream) {} in AlarmTestDelegate()
543 TestStream* stream_;
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/tools/
Dquic_simple_server_stream_test.cc57 class TestStream : public QuicSimpleServerStream { class
59 TestStream(QuicStreamId stream_id, QuicSpdySession* session, StreamType type, in TestStream() function in quic::test::TestStream
70 ~TestStream() override = default;
250 stream_ = new StrictMock<TestStream>( in QuicSimpleServerStreamTest()
295 StrictMock<TestStream>* stream_; // Owned by session_.
538 AlarmTestDelegate(TestStream* stream) : stream_(stream) {} in AlarmTestDelegate()
543 TestStream* stream_;
/external/cronet/stable/third_party/icu/source/test/iotest/
Dstream.cpp52 static void U_CALLCONV TestStream() in TestStream() function
321 addTest(root, &TestStream, "stream/TestStream"); in addStreamTests()
/external/icu/icu4c/source/test/iotest/
Dstream.cpp52 static void U_CALLCONV TestStream() in TestStream() function
321 addTest(root, &TestStream, "stream/TestStream"); in addStreamTests()
/external/cronet/tot/third_party/icu/source/test/iotest/
Dstream.cpp52 static void U_CALLCONV TestStream() in TestStream() function
321 addTest(root, &TestStream, "stream/TestStream"); in addStreamTests()
/external/golang-protobuf/internal/testprotos/test/
Dtest.proto372 rpc TestStream(stream FooRequest) returns (stream FooResponse); rpc
/external/tensorflow/tensorflow/c/
Dkernels_test.cc1033 TEST_F(DeviceKernelOpTest, TestStream) { in TEST_F() argument