/external/tensorflow/tensorflow/compiler/xla/service/ |
stream_pool_test.cc | 43 StreamPool::Ptr stream1 = pool.BorrowStream(executor.get()); local 44 se::Stream* stream1_ptr = stream1.get(); 45 EXPECT_TRUE(stream1->ok()); 46 stream1 = nullptr; 54 // The underlying streams should be the same, since stream1 was the 64 StreamPool::Ptr stream1 = pool.BorrowStream(executor.get()); local 65 se::Stream* stream1_ptr = stream1.get(); 66 EXPECT_TRUE(stream1->ok()); 75 // Return stream1 and borrow stream3. 76 stream1 = nullptr 101 StreamPool::Ptr stream1 = pool.BorrowStream(executor.get()); local 140 StreamPool::Ptr stream1 = pool.BorrowStream(executor.get()); local [all...] |
/external/webrtc/webrtc/base/ |
logging_unittest.cc | 65 LogSinkImpl<StringStream> stream1(&str1), stream2(&str2); 66 LogMessage::AddLogToStream(&stream1, LS_INFO); 68 EXPECT_EQ(LS_INFO, LogMessage::GetLogToStream(&stream1)); 80 LogMessage::RemoveLogToStream(&stream1); 82 EXPECT_EQ(LS_NONE, LogMessage::GetLogToStream(&stream1)); 110 LogSinkImpl<NullStream> stream1, stream2, stream3; local 112 LogMessage::AddLogToStream(&stream1, LS_INFO); 115 LogMessage::RemoveLogToStream(&stream1);
|
/external/pdfium/core/fxcrt/ |
cfx_seekablemultistream_unittest.cpp | 29 auto stream1 = pdfium::MakeUnique<CPDF_Stream>(); local 30 streams.push_back(stream1.get()); 41 auto stream1 = pdfium::MakeUnique<CPDF_Stream>(); local 46 stream1->InitStream(reinterpret_cast<const uint8_t*>("one t"), 5, 53 streams.push_back(stream1.get());
|
/external/skia/src/compute/hs/cuda/sm_35/u32/ |
hs_cuda.h | 61 cudaStream_t stream1, // auxilary streams
|
/external/skia/src/compute/hs/cuda/sm_35/u64/ |
hs_cuda.h | 61 cudaStream_t stream1, // auxilary streams
|
/external/skqp/src/compute/hs/cuda/sm_35/u32/ |
hs_cuda.h | 61 cudaStream_t stream1, // auxilary streams
|
/external/skqp/src/compute/hs/cuda/sm_35/u64/ |
hs_cuda.h | 61 cudaStream_t stream1, // auxilary streams
|
/external/adhd/cras/src/tests/ |
timing_unittest.cc | 199 // stream1's next callback is now and there is enough data to fill. 200 StreamPtr stream1 = local 204 stream1->rstream->next_cb_ts = start; 205 AddFakeDataToStream(stream1.get(), cb_threshold); 214 streams.emplace_back(std::move(stream1)); 235 // stream1's next callback is now and there is enough data to fill. 236 StreamPtr stream1 = local 240 stream1->rstream->next_cb_ts = start; 241 AddFakeDataToStream(stream1.get(), 441); 249 streams.emplace_back(std::move(stream1)); 274 StreamPtr stream1 = local [all...] |
/external/grpc-grpc/test/core/transport/ |
byte_stream_test.cc | 211 ByteStreamCache::CachingByteStream stream1(&cache); 216 // Read one slice from stream1. 217 EXPECT_TRUE(stream1.Next(~(size_t)0, &closure)); 219 grpc_error* error = stream1.Pull(&output); 231 // Now read the second slice from stream1. 232 EXPECT_TRUE(stream1.Next(~(size_t)0, &closure)); 233 error = stream1.Pull(&output); 238 stream1.Orphan();
|
/external/skia/src/compute/hs/cuda/bench/ |
main.c | 60 cudaStream_t stream1, 254 cudaStream_t stream1, 371 cuda(StreamWaitEvent(stream1,start,0)); 381 stream1, 515 cudaStream_t stream0,stream1,stream2; local 518 cuda(StreamCreate(&stream1)); 579 stream1, 598 cuda(StreamDestroy(stream1));
|
/external/skqp/src/compute/hs/cuda/bench/ |
main.c | 60 cudaStream_t stream1, 254 cudaStream_t stream1, 371 cuda(StreamWaitEvent(stream1,start,0)); 381 stream1, 515 cudaStream_t stream0,stream1,stream2; local 518 cuda(StreamCreate(&stream1)); 579 stream1, 598 cuda(StreamDestroy(stream1));
|
/external/pdfium/core/fxge/ |
cfx_font.cpp | 62 auto stream1 = pdfium::MakeUnique<FXFT_StreamRec>(); local 63 stream1->base = nullptr; 64 stream1->size = static_cast<unsigned long>(pFile->GetSize()); 65 stream1->pos = 0; 66 stream1->descriptor.pointer = static_cast<void*>(pFile.Get()); 67 stream1->close = FTStreamClose; 68 stream1->read = FTStreamRead; 71 args.stream = stream1.get(); 75 *stream = std::move(stream1);
|
/external/webrtc/talk/media/base/ |
rtpdataengine_unittest.cc | 207 cricket::StreamParams stream1; local 208 stream1.add_ssrc(41); 209 EXPECT_TRUE(dmc->AddSendStream(stream1)); 222 cricket::StreamParams stream1; local 223 stream1.add_ssrc(41); 224 EXPECT_TRUE(dmc->AddRecvStream(stream1)); 324 cricket::StreamParams stream1; local 325 stream1.add_ssrc(41); 326 ASSERT_TRUE(dmc1->AddSendStream(stream1));
|
streamparams_unittest.cc | 260 // stream1 has extra non-sim, non-fid ssrc. 261 cricket::StreamParams stream1 = local 265 stream1.add_ssrc(25); 266 EXPECT_FALSE(cricket::IsSimulcastStream(stream1));
|
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
CronetClientTransportTest.java | 92 CronetClientStream stream1 = local 105 stream1.start(mock(ClientStreamListener.class));
|
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
OkHttpClientTransportTest.java | 276 OkHttpClientStream stream1 = local 278 stream1.start(listener1); 279 stream1.request(1); 585 OkHttpClientStream stream1 = local 587 stream1.start(listener1); 588 stream1.request(2); 595 stream1 = getStream(3); 633 stream1.cancel(Status.CANCELLED); 802 OkHttpClientStream stream1 = local 804 stream1.start(listener1) 832 OkHttpClientStream stream1 = local 928 OkHttpClientStream stream1 = local 986 OkHttpClientStream stream1 = local 1040 OkHttpClientStream stream1 = local 1714 OkHttpClientStream stream1 = local 1754 OkHttpClientStream stream1 = local [all...] |
/external/tensorflow/tensorflow/core/common_runtime/gpu/ |
gpu_event_mgr_test.cc | 190 std::unique_ptr<se::Stream> stream1(new se::Stream(stream_exec)); 192 stream1->Init(); 196 em.ThenDeleteTensors(stream1.get(), v1);
|
/external/webrtc/talk/app/webrtc/ |
webrtcsessiondescriptionfactory.cc | 50 static bool CompareStream(const MediaSessionOptions::Stream& stream1, 52 return stream1.id < stream2.id; 55 static bool SameId(const MediaSessionOptions::Stream& stream1, 57 return stream1.id == stream2.id;
|
/external/skia/tests/ |
StreamTest.cpp | 485 SkFILEStream stream1(filename.c_str()); 486 if (!stream1.isValid()) { 490 REPORTER_ASSERT(r, stream1.hasLength()); 491 REPORTER_ASSERT(r, stream1.hasPosition()); 496 const size_t size = stream1.getLength(); 498 if (!stream1.seek(middle)) { 502 REPORTER_ASSERT(r, stream1.getPosition() == middle); 518 REPORTER_ASSERT(r, stream1.read(expected.get(), remaining) == remaining);
|
/external/skqp/tests/ |
StreamTest.cpp | 485 SkFILEStream stream1(filename.c_str()); 486 if (!stream1.isValid()) { 490 REPORTER_ASSERT(r, stream1.hasLength()); 491 REPORTER_ASSERT(r, stream1.hasPosition()); 496 const size_t size = stream1.getLength(); 498 if (!stream1.seek(middle)) { 502 REPORTER_ASSERT(r, stream1.getPosition() == middle); 518 REPORTER_ASSERT(r, stream1.read(expected.get(), remaining) == remaining);
|
/external/tensorflow/tensorflow/compiler/xla/tests/ |
transfer_manager_test.cc | 288 auto stream1 = stream_; local 295 ASSERT_IS_OK(transfer_manager_->TransferLiteralToDevice(stream1, literal1, 301 transfer_manager_->TransferLiteralFromDevice(stream1, device_buffer1));
|
/external/webrtc/talk/session/media/ |
channel_unittest.cc | 612 cricket::StreamParams stream1; local 613 stream1.groupid = "group1"; 614 stream1.id = "stream1"; 615 stream1.ssrcs.push_back(kSsrc1); 616 stream1.cname = "stream1_cname"; 633 content1.AddStream(stream1); 638 EXPECT_EQ(stream1, media_channel1_->send_streams()[0]); 648 EXPECT_EQ(stream1, media_channel1_->send_streams()[0]); 655 stream1.ssrcs.clear() 679 cricket::StreamParams stream1; local 746 cricket::StreamParams stream1; local [all...] |
/external/webrtc/webrtc/video/ |
video_loopback.cc | 154 DEFINE_string(stream1, 157 std::string Stream1() { 226 stream_descriptors.push_back(flags::Stream1());
|
/external/pdfium/core/fpdfapi/parser/ |
cpdf_object_unittest.cpp | 148 const CPDF_Stream* stream1 = obj1->AsStream(); local 150 if (!stream1->GetDict() && !stream2->GetDict()) 153 if (!Equal(stream1->GetDict(), stream2->GetDict())) 156 if (stream1->GetRawSize() != stream2->GetRawSize()) 161 if (!stream1->IsMemoryBased() || !stream2->IsMemoryBased()) 163 return memcmp(stream1->GetRawData(), stream2->GetRawData(), 164 stream1->GetRawSize()) == 0; [all...] |
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
Http2ConnectionTest.java | 190 FramedStream stream1 = connection.newStream(headerEntries("a", "android"), true, true); 193 BufferedSink sink1 = Okio.buffer(stream1.getSink()); 211 assertTrue(stream1.isOpen());
|