| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | stream_pool_test.cc | 49 StreamPool::Ptr stream2 = pool.BorrowStream(executor.get()); in TEST_F() local
50 se::Stream* stream2_ptr = stream2.get(); in TEST_F()
51 EXPECT_TRUE(stream2->ok()); in TEST_F()
52 stream2 = nullptr; in TEST_F()
67 StreamPool::Ptr stream2 = pool.BorrowStream(executor.get()); in TEST_F() local
68 se::Stream* stream2_ptr = stream2.get(); in TEST_F()
69 EXPECT_TRUE(stream2->ok()); in TEST_F()
86 stream2 = nullptr; in TEST_F()
111 StreamPool::Ptr stream2 = pool.BorrowStream(executor.get()); in TEST_F() local
112 se::Stream* stream2_ptr = stream2.get(); in TEST_F()
[all …]
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | zip.rs | 16 stream2: Fuse<St2>,
23 pub(super) fn new(stream1: St1, stream2: St2) -> Self { in new()
24 Self { stream1: stream1.fuse(), stream2: stream2.fuse(), queued1: None, queued2: None } in new()
30 (self.stream1.get_ref(), self.stream2.get_ref()) in get_ref()
39 (self.stream1.get_mut(), self.stream2.get_mut()) in get_mut()
49 (this.stream1.get_pin_mut(), this.stream2.get_pin_mut()) in get_pin_mut()
57 (self.stream1.into_inner(), self.stream2.into_inner()) in into_inner()
67 self.stream1.is_terminated() && self.stream2.is_terminated() in is_terminated()
88 match this.stream2.as_mut().poll_next(cx) { in poll_next()
97 } else if this.stream1.is_done() || this.stream2.is_done() { in poll_next()
[all …]
|
| D | chain.rs | 25 pub(super) fn new(stream1: St1, stream2: St2) -> Self { in new()
26 Self { first: Some(stream1), second: stream2 } in new()
|
| /external/rust/crates/futures-util/src/stream/ |
| D | select_with_strategy.rs | 44 stream2: Fuse<St2>,
113 stream2: St2, in select_with_strategy()
124 stream2: stream2.fuse(), in select_with_strategy()
134 (self.stream1.get_ref(), self.stream2.get_ref()) in get_ref()
143 (self.stream1.get_mut(), self.stream2.get_mut()) in get_mut()
153 (this.stream1.get_pin_mut(), this.stream2.get_pin_mut()) in get_pin_mut()
161 (self.stream1.into_inner(), self.stream2.into_inner()) in into_inner()
172 self.stream1.is_terminated() && self.stream2.is_terminated() in is_terminated()
188 PollNext::Left => poll_inner(this.stream1, this.stream2, cx), in poll_next()
189 PollNext::Right => poll_inner(this.stream2, this.stream1, cx), in poll_next()
[all …]
|
| D | select.rs | 47 pub fn select<St1, St2>(stream1: St1, stream2: St2) -> Select<St1, St2> in select()
57 inner: select_with_strategy(stream1, stream2, round_robin), in select()
|
| /external/dng_sdk/source/ |
| D | dng_validate.cpp | 176 dng_file_stream stream2 (gDumpStage1.Get (), true); in dng_validate() local
183 stream2, in dng_validate()
216 dng_file_stream stream2 (gDumpStage2.Get (), true); in dng_validate() local
223 stream2, in dng_validate()
272 dng_file_stream stream2 (gDumpStage3.Get (), true); in dng_validate() local
279 stream2, in dng_validate()
399 dng_file_stream stream2 (gDumpDNG.Get (), true); in dng_validate() local
408 stream2, in dng_validate()
472 dng_file_stream stream2 (gDumpTIF.Get (), true); in dng_validate() local
481 stream2, in dng_validate()
|
| /external/tensorflow/tensorflow/core/profiler/convert/ |
| D | op_stats_to_tf_stats_test.cc | 107 XLineBuilder stream2 = device_plane.GetOrCreateLine(/*line_id=*/20); in TEST() local
110 &device_plane, &stream2); in TEST()
113 &device_plane, &stream2); in TEST()
116 &device_plane, &stream2); in TEST()
119 /*on_device=*/true, kKernel4, kKernelDetails, &device_plane, &stream2); in TEST()
122 /*on_device=*/true, kKernel5, kKernelDetails, &device_plane, &stream2); in TEST()
|
| D | xplane_to_op_metrics_db_test.cc | 128 XLineBuilder stream2 = device_plane.GetOrCreateLine(/*line_id=*/20); in TEST() local
131 &device_plane, &stream2); in TEST()
134 &device_plane, &stream2); in TEST()
137 &device_plane, &stream2); in TEST()
|
| /external/rust/crates/tokio/tests/ |
| D | tcp_into_split.rs | 19 let (stream1, (mut stream2, _)) = try_join! { in split()
27 let len = stream2.write(MSG).await?; in split()
31 let read_len = stream2.read(&mut read_buf).await?; in split()
69 let stream2 = TcpStream::connect(&addr).await?; in reunite() localVariable
70 let (_, write2) = stream2.into_split(); in reunite()
|
| /external/webrtc/rtc_base/ |
| D | logging_unittest.cc | 210 LogSinkImpl<StringStream> stream1(&str1), stream2(&str2); in TEST() local
212 LogMessage::AddLogToStream(&stream2, LS_VERBOSE); in TEST()
214 EXPECT_EQ(LS_VERBOSE, LogMessage::GetLogToStream(&stream2)); in TEST()
224 LogMessage::RemoveLogToStream(&stream2); in TEST()
226 EXPECT_EQ(LS_NONE, LogMessage::GetLogToStream(&stream2)); in TEST()
259 LogSinkImpl<StringStream> stream1(&s1), stream2(&s2), stream3(&s3); in TEST() local
262 LogMessage::AddLogToStream(&stream2, LS_INFO); in TEST()
265 LogMessage::RemoveLogToStream(&stream2); in TEST()
|
| /external/perfetto/src/trace_processor/importers/proto/ |
| D | perf_sample_tracker_unittest.cc | 52 auto stream2 = context.perf_sample_tracker->GetSamplingStreamInfo( in TEST_F() local
56 EXPECT_EQ(stream.perf_session_id, stream2.perf_session_id); in TEST_F()
57 EXPECT_NE(stream.timebase_track_id, stream2.timebase_track_id); in TEST_F()
63 EXPECT_EQ(stream2.perf_session_id, stream3.perf_session_id); in TEST_F()
64 EXPECT_EQ(stream2.timebase_track_id, stream3.timebase_track_id); in TEST_F()
|
| /external/webrtc/media/base/ |
| D | rtp_data_engine_unittest.cc | 165 cricket::StreamParams stream2; in TEST_F() local
166 stream2.add_ssrc(42); in TEST_F()
167 EXPECT_TRUE(dmc->AddSendStream(stream2)); in TEST_F()
180 cricket::StreamParams stream2; in TEST_F() local
181 stream2.add_ssrc(42); in TEST_F()
182 EXPECT_TRUE(dmc->AddRecvStream(stream2)); in TEST_F()
183 EXPECT_FALSE(dmc->AddRecvStream(stream2)); in TEST_F()
|
| /external/pdfium/core/fpdfapi/parser/ |
| D | cpdf_seekablemultistream_unittest.cpp | 40 auto stream2 = pdfium::MakeRetain<CPDF_Stream>(); in TEST() local
46 stream2->InitStream(ByteStringView("wo ").raw_span(), in TEST()
52 streams.push_back(stream2.Get()); in TEST()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 280 OkHttpClientStream stream2 = in nextFrameThrowIoException() local
282 stream2.start(listener2); in nextFrameThrowIoException()
283 stream2.request(1); in nextFrameThrowIoException()
590 OkHttpClientStream stream2 = in windowUpdate() local
592 stream2.start(listener2); in windowUpdate()
593 stream2.request(2); in windowUpdate()
596 stream2 = getStream(5); in windowUpdate()
639 stream2.cancel(Status.CANCELLED); in windowUpdate()
805 OkHttpClientStream stream2 = in stopNormally() local
807 stream2.start(listener2); in stopNormally()
[all …]
|
| /external/webrtc/call/ |
| D | call_unittest.cc | 369 VideoSendStream* stream2 = in TEST() local
371 EXPECT_NE(stream2, nullptr); in TEST()
381 stream2->GetAdaptationResources(), fake_resource->Name()); in TEST()
408 call->DestroyVideoSendStream(stream2); in TEST()
434 VideoSendStream* stream2 = in TEST() local
436 EXPECT_NE(stream2, nullptr); in TEST()
443 stream2->GetAdaptationResources(), fake_resource->Name()); in TEST()
470 call->DestroyVideoSendStream(stream2); in TEST()
|
| /external/skia/tests/ |
| D | StreamTest.cpp | 75 std::unique_ptr<SkStreamAsset> stream2(stream.duplicate()); in test_filestreams() local
76 test_loop_stream(reporter, stream2.get(), s, 26, 100); in test_filestreams()
85 std::unique_ptr<SkStreamAsset> stream2(stream.duplicate()); in test_filestreams() local
86 test_loop_stream(reporter, stream2.get(), s, 26, 100); in test_filestreams()
113 std::unique_ptr<SkStreamAsset> stream2(stream->duplicate()); in TestWStream() local
114 test_loop_stream(reporter, stream2.get(), s, 26, 100); in TestWStream()
136 std::unique_ptr<SkStreamAsset> stream2(stream->duplicate()); in TestWStream() local
137 test_loop_stream(reporter, stream2.get(), s, 26, 100); in TestWStream()
524 SkFILEStream stream2(file); in DEF_TEST() local
647 test_all(&stream2, true); in DEF_TEST()
|
| /external/grpc-grpc/test/core/transport/ |
| D | byte_stream_test.cc | 212 ByteStreamCache::CachingByteStream stream2(&cache); in TEST() local
225 EXPECT_TRUE(stream2.Next(~(size_t)0, &closure)); in TEST()
226 error = stream2.Pull(&output); in TEST()
239 stream2.Orphan(); in TEST()
|
| /external/python/pybind11/tests/ |
| D | test_iostream.py | 208 stream2 = StringIO()
210 with redirect_stderr(stream2):
218 assert stream2.getvalue() == msg2
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientTransportTest.java | 94 CronetClientStream stream2 = in shutdownTransport() local
110 stream2.start(mock(ClientStreamListener.class)); in shutdownTransport()
|
| /external/tensorflow/tensorflow/c/experimental/stream_executor/ |
| D | stream_executor_test.cc | 497 Stream stream2(executor); in TEST_F() local
498 stream2.Init(); in TEST_F()
500 stream2.InitTimer(&timer2); in TEST_F()
501 stream2.ThenStartTimer(&timer2); in TEST_F()
502 ASSERT_TRUE(stream2.ok()); in TEST_F()
503 stream2.ThenStopTimer(&timer2); in TEST_F()
504 ASSERT_FALSE(stream2.ok()); in TEST_F()
|
| /external/rust/crates/mio/src/net/uds/ |
| D | stream.rs | 44 sys::uds::stream::pair().map(|(stream1, stream2)| { in pair()
45 (UnixStream::from_std(stream1), UnixStream::from_std(stream2)) in pair()
|
| /external/freetype/src/base/ |
| D | ftrfork.c | 842 FT_Stream stream2; in raccess_guess_linux_double_from_file_name() local
849 error = FT_Stream_New( library, &args2, &stream2 ); in raccess_guess_linux_double_from_file_name()
853 error = raccess_guess_apple_double( library, stream2, file_name, in raccess_guess_linux_double_from_file_name()
856 FT_Stream_Free( stream2, 0 ); in raccess_guess_linux_double_from_file_name()
|
| /external/webrtc/video/ |
| D | send_statistics_proxy_unittest.cc | 1425 VideoStream stream2; in TEST_F() local
1426 stream2.width = kWidth; in TEST_F()
1427 stream2.height = kHeight; in TEST_F()
1428 statistics_proxy_->OnEncoderReconfigured(config, {stream1, stream2}); in TEST_F()
1463 statistics_proxy_->OnEncoderReconfigured(config, {stream1, stream2}); in TEST_F()
1959 VideoStream stream2; in TEST_F() local
1960 stream2.width = kWidth; in TEST_F()
1961 stream2.height = kHeight; in TEST_F()
1962 statistics_proxy_->OnEncoderReconfigured(config, {stream1, stream2}); in TEST_F()
2004 VideoStream stream2; in TEST_F() local
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/tests/ |
| D | transfer_manager_test.cc | 331 auto stream2 = stream_->GetOrCreateSubStream(); in XLA_TEST_F() local
339 ASSERT_IS_OK(transfer_manager_->TransferLiteralToDevice(stream2, literal2, in XLA_TEST_F()
346 transfer_manager_->TransferLiteralFromDevice(stream2, device_buffer2)); in XLA_TEST_F()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | Http2ConnectionTest.java | 193 FramedStream stream2 = connection.newStream(headerEntries("b", "banana"), true, true);
196 BufferedSink sink2 = Okio.buffer(stream2.getSink());
214 assertFalse(stream2.isOpen());
|