| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | stream_pool_test.cc | 43 StreamPool::Ptr stream1 = pool.BorrowStream(executor.get()); in TEST_F() local
44 se::Stream* stream1_ptr = stream1.get(); in TEST_F()
45 EXPECT_TRUE(stream1->ok()); in TEST_F()
46 stream1 = nullptr; in TEST_F()
64 StreamPool::Ptr stream1 = pool.BorrowStream(executor.get()); in TEST_F() local
65 se::Stream* stream1_ptr = stream1.get(); in TEST_F()
66 EXPECT_TRUE(stream1->ok()); in TEST_F()
76 stream1 = nullptr; in TEST_F()
101 StreamPool::Ptr stream1 = pool.BorrowStream(executor.get()); in TEST_F() local
102 EXPECT_TRUE(stream1->ok()); in TEST_F()
[all …]
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | zip.rs | 14 stream1: Fuse<St1>,
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()
82 match this.stream1.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 | 42 stream1: Fuse<St1>,
112 stream1: St1, in select_with_strategy()
123 stream1: stream1.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/pdfium/core/fpdfapi/parser/ |
| D | cpdf_seekablemultistream_unittest.cpp | 27 auto stream1 = pdfium::MakeRetain<CPDF_Stream>(); in TEST() local
28 streams.push_back(stream1.Get()); in TEST()
39 auto stream1 = pdfium::MakeRetain<CPDF_Stream>(); in TEST() local
44 stream1->InitStream(ByteStringView("one t").raw_span(), in TEST()
51 streams.push_back(stream1.Get()); in TEST()
|
| /external/webrtc/rtc_base/ |
| D | logging_unittest.cc | 210 LogSinkImpl<StringStream> stream1(&str1), stream2(&str2); in TEST() local
211 LogMessage::AddLogToStream(&stream1, LS_INFO); in TEST()
213 EXPECT_EQ(LS_INFO, LogMessage::GetLogToStream(&stream1)); in TEST()
225 LogMessage::RemoveLogToStream(&stream1); in TEST()
227 EXPECT_EQ(LS_NONE, LogMessage::GetLogToStream(&stream1)); in TEST()
259 LogSinkImpl<StringStream> stream1(&s1), stream2(&s2), stream3(&s3); in TEST() local
261 LogMessage::AddLogToStream(&stream1, LS_WARNING); in TEST()
264 LogMessage::RemoveLogToStream(&stream1); in TEST()
|
| /external/grpc-grpc/test/core/transport/ |
| D | byte_stream_test.cc | 211 ByteStreamCache::CachingByteStream stream1(&cache); in TEST() local
217 EXPECT_TRUE(stream1.Next(~(size_t)0, &closure)); in TEST()
219 grpc_error* error = stream1.Pull(&output); in TEST()
232 EXPECT_TRUE(stream1.Next(~(size_t)0, &closure)); in TEST()
233 error = stream1.Pull(&output); in TEST()
238 stream1.Orphan(); in TEST()
|
| /external/rust/crates/tokio/tests/ |
| D | tcp_into_split.rs | 19 let (stream1, (mut stream2, _)) = try_join! { in split()
23 let (mut read_half, mut write_half) = stream1.into_split(); in split()
66 let stream1 = TcpStream::connect(&addr).await?; in reunite() localVariable
67 let (read1, write1) = stream1.into_split(); in reunite()
|
| /external/tensorflow/tensorflow/core/profiler/convert/ |
| D | xplane_to_trace_events_test.cc | 52 XLineBuilder stream1 = device_plane.GetOrCreateLine(30); in CreateXSpace() local
53 stream1.SetName("gpu stream 1"); in CreateXSpace()
55 stream1.AddEvent(*device_plane.GetOrCreateEventMetadata("kernel1")); in CreateXSpace()
|
| D | xplane_to_profile_response_test.cc | 55 XLineBuilder stream1 = device_plane.GetOrCreateLine(30); in CreateXSpace() local
56 stream1.SetName("gpu stream 1"); in CreateXSpace()
58 stream1.AddEvent(*device_plane.GetOrCreateEventMetadata("kernel1")); in CreateXSpace()
|
| D | op_stats_to_tf_stats_test.cc | 100 XLineBuilder stream1 = device_plane.GetOrCreateLine(/*line_id=*/10); in TEST() local
103 &device_plane, &stream1); in TEST()
106 &device_plane, &stream1); in TEST()
|
| D | xplane_to_op_metrics_db_test.cc | 121 XLineBuilder stream1 = device_plane.GetOrCreateLine(/*line_id=*/10); in TEST() local
124 &device_plane, &stream1); in TEST()
127 &device_plane, &stream1); in TEST()
|
| /external/webrtc/call/ |
| D | call_unittest.cc | 365 VideoSendStream* stream1 = in TEST() local
367 EXPECT_NE(stream1, nullptr); in TEST()
378 stream1->GetAdaptationResources(), fake_resource->Name()); in TEST()
407 call->DestroyVideoSendStream(stream1); in TEST()
430 VideoSendStream* stream1 = in TEST() local
432 EXPECT_NE(stream1, nullptr); in TEST()
440 stream1->GetAdaptationResources(), fake_resource->Name()); in TEST()
469 call->DestroyVideoSendStream(stream1); in TEST()
|
| /external/webrtc/media/base/ |
| D | rtp_data_engine_unittest.cc | 162 cricket::StreamParams stream1; in TEST_F() local
163 stream1.add_ssrc(41); in TEST_F()
164 EXPECT_TRUE(dmc->AddSendStream(stream1)); in TEST_F()
177 cricket::StreamParams stream1; in TEST_F() local
178 stream1.add_ssrc(41); in TEST_F()
179 EXPECT_TRUE(dmc->AddRecvStream(stream1)); in TEST_F()
|
| /external/pdfium/core/fxge/ |
| D | cfx_font.cpp | 62 auto stream1 = pdfium::MakeUnique<FXFT_StreamRec>(); in LoadFileImp() local
63 stream1->base = nullptr; in LoadFileImp()
64 stream1->size = static_cast<unsigned long>(pFile->GetSize()); in LoadFileImp()
65 stream1->pos = 0; in LoadFileImp()
66 stream1->descriptor.pointer = static_cast<void*>(pFile.Get()); in LoadFileImp()
67 stream1->close = FTStreamClose; in LoadFileImp()
68 stream1->read = FTStreamRead; in LoadFileImp()
72 args.stream = stream1.get(); in LoadFileImp()
78 *stream = std::move(stream1); in LoadFileImp()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 276 OkHttpClientStream stream1 = in nextFrameThrowIoException() local
278 stream1.start(listener1); in nextFrameThrowIoException()
279 stream1.request(1); in nextFrameThrowIoException()
585 OkHttpClientStream stream1 = in windowUpdate() local
587 stream1.start(listener1); in windowUpdate()
588 stream1.request(2); in windowUpdate()
595 stream1 = getStream(3); in windowUpdate()
633 stream1.cancel(Status.CANCELLED); in windowUpdate()
802 OkHttpClientStream stream1 = in stopNormally() local
804 stream1.start(listener1); in stopNormally()
[all …]
|
| /external/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()
|
| /external/OpenCL-CTS/test_conformance/gles/ |
| D | test_fence_sync.cpp | 242 cl_int run_cl_kernel( cl_kernel kernel, cl_command_queue queue, cl_mem stream0, cl_mem stream1, in run_cl_kernel() argument
254 … error = (*clEnqueueAcquireGLObjects_ptr)( queue, 1, &stream1, numEvents, fence_evt, &acqEvent2 ); in run_cl_kernel()
264 error = (*clEnqueueReleaseGLObjects_ptr)( queue, 1, &stream1, 1, &kernEvent, &relEvent2 ); in run_cl_kernel()
286 …RunThread( cl_kernel kernel, cl_command_queue queue, cl_mem stream0, cl_mem stream1, size_t numThr… in RunThread() argument
287 …: mKernel( kernel ), mQueue( queue ), mStream0( stream0 ), mStream1( stream1 ), mNumThreads( numTh… in RunThread()
|
| /external/webrtc/video/ |
| D | send_statistics_proxy_unittest.cc | 1422 VideoStream stream1; in TEST_F() local
1423 stream1.width = kWidth / 2; in TEST_F()
1424 stream1.height = kHeight / 2; in TEST_F()
1428 statistics_proxy_->OnEncoderReconfigured(config, {stream1, stream2}); in TEST_F()
1461 stream1.width = kWidth; in TEST_F()
1462 stream1.height = kHeight; in TEST_F()
1463 statistics_proxy_->OnEncoderReconfigured(config, {stream1, stream2}); in TEST_F()
1921 VideoStream stream1; in TEST_F() local
1922 stream1.width = kWidth; in TEST_F()
1923 stream1.height = kHeight; in TEST_F()
[all …]
|
| /external/OpenCL-CTS/test_conformance/gl/ |
| D | test_fence_sync.cpp | 231 cl_int run_cl_kernel( cl_kernel kernel, cl_command_queue queue, cl_mem stream0, cl_mem stream1, in run_cl_kernel() argument
243 … error = (*clEnqueueAcquireGLObjects_ptr)( queue, 1, &stream1, numEvents, fence_evt, &acqEvent2 ); in run_cl_kernel()
253 error = (*clEnqueueReleaseGLObjects_ptr)( queue, 1, &stream1, 1, &kernEvent, &relEvent2 ); in run_cl_kernel()
275 …RunThread( cl_kernel kernel, cl_command_queue queue, cl_mem stream0, cl_mem stream1, size_t numThr… in RunThread() argument
276 …: mKernel( kernel ), mQueue( queue ), mStream0( stream0 ), mStream1( stream1 ), mNumThreads( numTh… in RunThread()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientTransportTest.java | 92 CronetClientStream stream1 = in shutdownTransport() local
105 stream1.start(mock(ClientStreamListener.class)); in shutdownTransport()
|
| /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/tensorflow/tensorflow/compiler/xla/tests/ |
| D | transfer_manager_test.cc | 330 auto stream1 = stream_; in XLA_TEST_F() local
337 ASSERT_IS_OK(transfer_manager_->TransferLiteralToDevice(stream1, literal1, in XLA_TEST_F()
343 transfer_manager_->TransferLiteralFromDevice(stream1, device_buffer1)); in XLA_TEST_F()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | Http2ConnectionTest.java | 192 FramedStream stream1 = connection.newStream(headerEntries("a", "android"), true, true);
195 BufferedSink sink1 = Okio.buffer(stream1.getSink());
213 assertTrue(stream1.isOpen());
|