| /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/ |
| D | select.rs | 16 stream2: Fuse<St2>,
31 pub fn select<St1, St2>(stream1: St1, stream2: St2) -> Select<St1, St2> in select()
37 stream2: stream2.fuse(), in select()
46 (self.stream1.get_ref(), self.stream2.get_ref()) in get_ref()
55 (self.stream1.get_mut(), self.stream2.get_mut()) in get_mut()
65 (this.stream1.get_pin_mut(), this.stream2.get_pin_mut()) in get_pin_mut()
73 (self.stream1.into_inner(), self.stream2.into_inner()) in into_inner()
82 self.stream1.is_terminated() && self.stream2.is_terminated() in is_terminated()
98 poll_inner(this.flag, this.stream1, this.stream2, cx) in poll_next()
100 poll_inner(this.flag, this.stream2, this.stream1, cx) in poll_next()
|
| /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()
26 stream2: stream2.fuse(), in new()
35 (self.stream1.get_ref(), self.stream2.get_ref()) in get_ref()
44 (self.stream1.get_mut(), self.stream2.get_mut()) in get_mut()
54 (this.stream1.get_pin_mut(), this.stream2.get_pin_mut()) in get_pin_mut()
62 (self.stream1.into_inner(), self.stream2.into_inner()) in into_inner()
70 self.stream1.is_terminated() && self.stream2.is_terminated() in is_terminated()
92 match this.stream2.as_mut().poll_next(cx) { in poll_next()
101 } else if this.stream1.is_done() || this.stream2.is_done() { in poll_next()
[all …]
|
| D | chain.rs | 24 pub(super) fn new(stream1: St1, stream2: St2) -> Self { in new()
27 second: stream2, in new()
|
| /external/adhd/cras/src/tests/ |
| D | timing_unittest.cc | 212 StreamPtr stream2 = create_stream(1, 2, CRAS_STREAM_INPUT, 480, &format); in TEST_F() local
213 stream2->rstream->next_cb_ts = start; in TEST_F()
214 stream2->rstream->next_cb_ts.tv_sec += 5; in TEST_F()
215 rstream_stub_dev_offset(stream2->rstream.get(), 1, 200); in TEST_F()
219 streams.emplace_back(std::move(stream2)); in TEST_F()
243 StreamPtr stream2 = create_stream(1, 2, CRAS_STREAM_INPUT, 480, &format); in TEST_F() local
244 stream2->rstream->next_cb_ts = start; in TEST_F()
245 stream2->rstream->next_cb_ts.tv_sec += 5; in TEST_F()
249 streams.emplace_back(std::move(stream2)); in TEST_F()
614 StreamPtr stream2 = in TEST_F() local
[all …]
|
| D | iodev_unittest.cc | 1372 struct dev_stream stream1, stream2; in TEST() local
1387 stream2.stream = &rstream2; in TEST()
1388 stream2.is_running = 0; in TEST()
1403 cras_iodev_add_stream(&iodev, &stream2); in TEST()
1404 cras_iodev_start_stream(&iodev, &stream2); in TEST()
1423 struct dev_stream stream1, stream2, stream3; in TEST() local
1429 memset(&stream1, 0, sizeof(stream2)); in TEST()
1430 memset(&stream2, 0, sizeof(stream2)); in TEST()
1431 memset(&stream3, 0, sizeof(stream2)); in TEST()
1442 stream2.stream = &rstream2; in TEST()
[all …]
|
| /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 | 124 XLineBuilder stream2 = device_plane.GetOrCreateLine(/*line_id=*/20); in TEST() local
127 &device_plane, &stream2); in TEST()
130 &device_plane, &stream2); in TEST()
133 &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/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/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/skqp/src/compute/hs/cuda/bench/ |
| D | main.c | 61 cudaStream_t stream2);
255 cudaStream_t stream2, in hs_bench() argument
372 cuda(StreamWaitEvent(stream2,start,0)); in hs_bench()
382 stream2); in hs_bench()
515 cudaStream_t stream0,stream1,stream2; in main() local
519 cuda(StreamCreate(&stream2)); in main()
580 stream2, in main()
599 cuda(StreamDestroy(stream2)); in main()
|
| /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/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/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/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/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/skqp/tests/ |
| D | StreamTest.cpp | 70 std::unique_ptr<SkStreamAsset> stream2(stream.duplicate()); in test_filestreams() local
71 test_loop_stream(reporter, stream2.get(), s, 26, 100); in test_filestreams()
80 std::unique_ptr<SkStreamAsset> stream2(stream.duplicate()); in test_filestreams() local
81 test_loop_stream(reporter, stream2.get(), s, 26, 100); in test_filestreams()
108 std::unique_ptr<SkStreamAsset> stream2(stream->duplicate()); in TestWStream() local
109 test_loop_stream(reporter, stream2.get(), s, 26, 100); in TestWStream()
131 std::unique_ptr<SkStreamAsset> stream2(stream->duplicate()); in TestWStream() local
132 test_loop_stream(reporter, stream2.get(), s, 26, 100); in TestWStream()
514 SkFILEStream stream2(file); in DEF_TEST() local
637 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/skqp/src/compute/hs/cuda/sm_35/u64/ |
| D | hs_cuda.h | 62 cudaStream_t stream2); // for concurrency
|
| /external/skqp/src/compute/hs/cuda/sm_35/u32/ |
| D | hs_cuda.h | 62 cudaStream_t stream2); // for concurrency
|
| /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()
|