| /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/ |
| D | select.rs | 14 stream1: Fuse<St1>,
31 pub fn select<St1, St2>(stream1: St1, stream2: St2) -> Select<St1, St2> in select()
36 stream1: stream1.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 | 14 stream1: Fuse<St1>,
23 pub(super) fn new(stream1: St1, stream2: St2) -> Self { in new()
25 stream1: stream1.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()
86 match this.stream1.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()
26 first: Some(stream1), in new()
|
| /external/adhd/cras/src/tests/ |
| D | timing_unittest.cc | 209 StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_INPUT, 480, &format); in TEST_F() local
210 stream1->rstream->next_cb_ts = start; in TEST_F()
218 streams.emplace_back(std::move(stream1)); in TEST_F()
239 StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_INPUT, 480, &format); in TEST_F() local
240 stream1->rstream->next_cb_ts = start; in TEST_F()
241 stream1->rstream->next_cb_ts.tv_sec += 2; in TEST_F()
248 streams.emplace_back(std::move(stream1)); in TEST_F()
606 StreamPtr stream1 = in TEST_F() local
610 stream1->rstream->next_cb_ts = start; in TEST_F()
611 AddFakeDataToStream(stream1.get(), cb_threshold); in TEST_F()
[all …]
|
| D | iodev_unittest.cc | 1372 struct dev_stream stream1, stream2; in TEST() local
1384 stream1.stream = &rstream1; in TEST()
1385 stream1.is_running = 0; in TEST()
1397 cras_iodev_add_stream(&iodev, &stream1); in TEST()
1398 cras_iodev_start_stream(&iodev, &stream1); in TEST()
1423 struct dev_stream stream1, stream2, stream3; in TEST() local
1429 memset(&stream1, 0, sizeof(stream2)); in TEST()
1441 stream1.stream = &rstream1; in TEST()
1448 cras_iodev_add_stream(&iodev, &stream1); in TEST()
1449 cras_iodev_start_stream(&iodev, &stream1); in TEST()
[all …]
|
| /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/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/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/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 | 117 XLineBuilder stream1 = device_plane.GetOrCreateLine(/*line_id=*/10); in TEST() local
120 &device_plane, &stream1); in TEST()
123 &device_plane, &stream1); 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/skqp/src/compute/hs/cuda/bench/ |
| D | main.c | 60 cudaStream_t stream1,
254 cudaStream_t stream1, in hs_bench() argument
371 cuda(StreamWaitEvent(stream1,start,0)); in hs_bench()
381 stream1, in hs_bench()
515 cudaStream_t stream0,stream1,stream2; in main() local
518 cuda(StreamCreate(&stream1)); in main()
579 stream1, in main()
598 cuda(StreamDestroy(stream1)); in main()
|
| /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/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/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/skqp/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()
|
| /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/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/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/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 …]
|