Home
last modified time | relevance | path

Searched +full:get +full:- +full:stream (Results 1 – 25 of 1258) sorted by relevance

12345678910>>...51

/external/nullaway/nullaway/src/test/resources/com/uber/nullaway/testdata/
DNullAwayStreamSupportNegativeCases.java30 import java.util.stream.DoubleStream;
31 import java.util.stream.IntStream;
32 import java.util.stream.LongStream;
33 import java.util.stream.Stream;
46 public T get() { in get() method in NullAwayStreamSupportNegativeCases.NullableContainer
59 private Stream<Integer> filterThenMap(Stream<String> stream) { in filterThenMap() argument
60 return stream in filterThenMap()
77 private Stream<Integer> filterWithIfThenMapNullableContainer(
78 Stream<NullableContainer<String>> stream) {
79 return stream
[all …]
DNullAwayStreamSupportPositiveCases.java29 import java.util.stream.DoubleStream;
30 import java.util.stream.IntStream;
31 import java.util.stream.LongStream;
32 import java.util.stream.Stream;
45 public T get() { in get() method in NullAwayStreamSupportPositiveCases.NullableContainer
54 private Stream<Integer> filterWithIfThenMapNullableContainerNullableOnSomeBranch( in filterWithIfThenMapNullableContainerNullableOnSomeBranch()
55 Stream<NullableContainer<String>> stream) { in filterWithIfThenMapNullableContainerNullableOnSomeBranch() argument
56 return stream in filterWithIfThenMapNullableContainerNullableOnSomeBranch()
61 if (container.get() != null) { in filterWithIfThenMapNullableContainerNullableOnSomeBranch()
73 return c.get().length(); in filterWithIfThenMapNullableContainerNullableOnSomeBranch()
[all …]
/external/libbrillo/brillo/streams/
Dmemory_stream_test.cc2 // Use of this source code is governed by a BSD-style license that can be
27 int ReadByte(Stream* stream, brillo::ErrorPtr* error) { in ReadByte() argument
29 return stream->ReadAllBlocking(&byte, sizeof(byte), error) ? byte : -1; in ReadByte()
62 return *static_cast<MockMemoryContainer*>(stream_->container_.get()); in container_mock()
75 // are delegated to the stream interface without a change.
86 EXPECT_TRUE(stream_->CanRead()); in TEST_F()
94 EXPECT_FALSE(stream_->CanWrite()); in TEST_F()
95 EXPECT_TRUE(stream_->CanWrite()); in TEST_F()
99 EXPECT_TRUE(stream_->CanSeek()); in TEST_F()
108 EXPECT_EQ(0, stream_->GetSize()); in TEST_F()
[all …]
/external/jazzer-api/src/test/java/com/code_intelligence/jazzer/mutation/mutator/lang/
DFloatingPointMutatorTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
33 import java.util.stream.Stream;
43 static Stream<Arguments> floatForceInRangeCases() { in floatForceInRangeCases()
49 return Stream.of( in floatForceInRangeCases()
55 arguments(1e30f, -Float.MAX_VALUE, Float.MAX_VALUE, true), in floatForceInRangeCases()
56 arguments(-1e30f, -Float.MAX_VALUE, Float.MAX_VALUE, true), in floatForceInRangeCases()
59 arguments(-Float.MAX_VALUE, -Float.MAX_VALUE, Float.MAX_VALUE, true), in floatForceInRangeCases()
60 arguments(Float.MAX_VALUE, -Float.MAX_VALUE, Float.MAX_VALUE, true), in floatForceInRangeCases()
61 arguments(-Float.MAX_VALUE, Float.MAX_VALUE - 3.4e30f, Float.MAX_VALUE, false), in floatForceInRangeCases()
62 arguments(Float.MAX_VALUE, -100.0f, Float.MAX_VALUE, true), in floatForceInRangeCases()
[all …]
/external/puffin/src/
Dstream_unittest.cc2 // Use of this source code is governed by a BSD-style license that can be
24 // |data| is the content of stream as a buffer.
25 void TestRead(StreamInterface* stream, const Buffer& data) { in TestRead() argument
29 ASSERT_TRUE(stream->Seek(0)); in TestRead()
30 ASSERT_TRUE(stream->Read(buf.data(), buf.size())); in TestRead()
38 ASSERT_TRUE(stream->GetSize(&size)); in TestRead()
39 ASSERT_TRUE(stream->Seek(size)); in TestRead()
40 ASSERT_TRUE(stream->Read(tmp.data(), 0)); in TestRead()
41 ASSERT_FALSE(stream->Read(tmp.data(), 1)); in TestRead()
42 ASSERT_FALSE(stream->Read(tmp.data(), 2)); in TestRead()
[all …]
/external/tensorflow/tensorflow/compiler/xla/stream_executor/
Dstream_test.cc7 http://www.apache.org/licenses/LICENSE-2.0
27 return platform->GetUncachedExecutor(config).value(); in NewStreamExecutor()
33 Stream stream(executor.get()); in TEST_F() local
34 EXPECT_FALSE(stream.ok()); in TEST_F()
39 Stream stream(executor.get()); in TEST_F() local
40 stream.Init(); in TEST_F()
41 EXPECT_TRUE(stream.ok()); in TEST_F()
46 Stream stream(executor.get()); in TEST_F() local
47 stream.Init(); in TEST_F()
48 EXPECT_TRUE(stream.ok()); in TEST_F()
[all …]
/external/grpc-grpc/test/core/xds/
Dxds_client_test.cc8 // http://www.apache.org/licenses/LICENSE-2.0
18 // - tests for DumpClientConfigBinary()
19 // - tests for load-reporting APIs? (or maybe move those out of XdsClient?)
178 node_->set_id(std::move(id)); in set_node_id()
191 bootstrap->servers_ = std::move(servers_); in Build()
192 bootstrap->node_ = std::move(node_); in Build()
193 bootstrap->authorities_ = std::move(authorities_); in Build()
220 return &it->second; in LookupAuthority()
233 // - a static JsonLoader() method, as described in json_object_loader.h
234 // - an AsJsonString() method that returns the object in JSON string form
[all …]
/external/sg3_utils/doc/
Dsg_stream_ctl.81 .TH SG_STREAM_CTL "8" "March 2018" "sg3_utils\-1.43" SG3_UTILS
3 sg_stream_ctl \- send SCSI STREAM CONTROL or GET STREAM STATUS command
6 [\fI\-\-brief\fR] [\fI\-\-close\fR] [\fI\-\-ctl=CTL\fR] [\fI\-\-get\fR]
7 [\fI\-\-help\fR] [\fI\-\-id=SID\fR] [\fI\-\-maxlen=LEN\fR] [\fI\-\-open\fR]
8 [\fI\-\-readonly\fR] [\fI\-\-verbose\fR] [\fI\-\-version\fR] \fIDEVICE\fR
12 Sends a SCSI STREAM CONTROL or GET STREAM STATUS command to the \fIDEVICE\fR.
13 These commands, together with WRITE STREAM(16 and 32) and several fields in
15 The stream commands were added in SBC\-4 draft 8 (September 2015).
17 Both STREAM CONTROL and GET STREAM STATUS commands expect data from the
18 \fIDEVICE\fR (referred to as 'data\-in'). In the case of STREAM CONTROL
[all …]
/external/skia/tests/
DStreamTest.cpp4 * Use of this source code is governed by a BSD-style license that can be
46 static void test_loop_stream(skiatest::Reporter* reporter, SkStream* stream, in test_loop_stream() argument
49 void* tmp = storage.get(); in test_loop_stream()
52 size_t bytes = stream->read(tmp, len); in test_loop_stream()
58 size_t bytes = stream->read(tmp, 1); in test_loop_stream()
61 REPORTER_ASSERT(reporter, stream->isAtEnd()); in test_loop_stream()
82 SkFILEStream stream(path.c_str()); in test_filestreams() local
83 REPORTER_ASSERT(reporter, stream.isValid()); in test_filestreams()
84 test_loop_stream(reporter, &stream, s, 26, 100); in test_filestreams()
86 std::unique_ptr<SkStreamAsset> stream2(stream.duplicate()); in test_filestreams()
[all …]
DFrontBufferedStreamTest.cpp4 * Use of this source code is governed by a BSD-style license that can be
25 const size_t bytesRead = bufferedStream->read(storage.get(), bytesToRead); in test_read()
26 REPORTER_ASSERT(reporter, bytesRead == bytesToRead || bufferedStream->isAtEnd()); in test_read()
27 REPORTER_ASSERT(reporter, memcmp(storage.get(), expectations, bytesRead) == 0); in test_read()
32 const bool success = bufferedStream->rewind(); in test_rewind()
36 // Test that hasLength() returns the correct value, based on the stream
37 // being wrapped. A length can only be known if the wrapped stream has a
55 // Tests reading the stream across boundaries of what has been buffered so far and what
59 // wrapped stream, but that's okay because we know the wrapping stream has not been in test_incremental_buffering()
69 test_read(reporter, bufferedStream.get(), gAbcs, bufferSize / 2); in test_incremental_buffering()
[all …]
/external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/
Dexternally_locked_stream.hpp24 template <typename Stream, typename RecursiveMutex=recursive_mutex>
27 template <class Stream, typename RecursiveMutex=recursive_mutex>
31 friend class externally_locked_stream<Stream, RecursiveMutex> ;
33 typedef typename externally_locked_stream<Stream, RecursiveMutex>::mutex_type mutex_type;
37 stream_guard(externally_locked_stream<Stream, RecursiveMutex>& mtx) : in stream_guard() argument
43 stream_guard(externally_locked_stream<Stream, RecursiveMutex>& mtx, adopt_lock_t) : in stream_guard() argument
56 if (mtx_ != 0) mtx_->unlock(); in ~stream_guard()
61 return l == mtx_->mutex(); in owns_lock()
67 Stream& get() const in get() function in boost::stream_guard
70 return mtx_->get(*this); in get()
[all …]
/external/tensorflow/tensorflow/core/lib/io/
Dzlib_inputstream.cc7 http://www.apache.org/licenses/LICENSE-2.0
30 stream(new z_stream) {} in ZStreamDef()
32 // Buffer for storing contents read from compressed stream.
42 // z_stream_def_->stream->next_in:
43 // Next byte to de-compress. Points to some byte in
44 // z_stream_def_->streamdef_.input buffer.
45 // z_stream_def_->stream->avail_in:
47 // z_stream_def_->stream->next_out:
48 // Next byte to write de-compressed data to. Points to some byte in
49 // z_stream_def_->streamdef_.output buffer.
[all …]
/external/dng_sdk/source/
Ddng_info.cpp2 // Copyright 2006-2007 Adobe Systems Incorporated
39 , fMainIndex (-1) in dng_info()
40 , fMaskIndex (-1) in dng_info()
96 dng_stream &stream, in ParseTag() argument
113 ifd->fUsesNewSubFileType && in ParseTag()
114 ifd->fNewSubFileType == sfMainImage; in ParseTag()
132 stream.SetReadPosition (tagOffset); in ParseTag()
134 if (ifd && ifd->ParseTag (stream, in ParseTag()
146 stream.SetReadPosition (tagOffset); in ParseTag()
148 if (exif && shared && exif->ParseTag (stream, in ParseTag()
[all …]
Ddng_stream.h2 // Copyright 2006-2007 Adobe Systems Incorporated
14 /** Data stream abstraction for serializing and deserializing sequences of
35 const uint64 kDNGStreamInvalidOffset = (uint64) (int64) -1;
39 /// Base stream abstraction. Has support for going between stream and pointer
103 /// Construct a stream with initial data.
104 /// \param data Pointer to initial contents of stream.
115 /// Getter for whether stream is swapping byte order on input/output.
123 /// Setter for whether stream is swapping byte order on input/output.
124 /// \param swapBytes If true, stream will swap byte order on input or
132 /// Getter for whether data in stream is big endian.
[all …]
/external/apache-commons-io/src/test/java/org/apache/commons/io/function/
DIOBaseStreamTest.java9 * http://www.apache.org/licenses/LICENSE-2.0
31 import java.util.stream.BaseStream;
32 import java.util.stream.Stream;
113 private IOBaseStreamFixture<Path, ?, Stream<Path>> createIOBaseStream() { in createIOBaseStream()
121 private IOBaseStreamPathFixture<Stream<Path>> createIOBaseStreamPath() { in createIOBaseStreamPath()
125 private Stream<Path> createStreamOfPaths() { in createStreamOfPaths()
126 return Stream.of(TestConstants.ABS_PATH_A, TestConstants.ABS_PATH_B); in createStreamOfPaths()
153 ioBaseStream.iterator().forEachRemaining(e -> ref.set(e.toRealPath())); in testIteratorPathIO()
154 assertEquals(TestConstants.ABS_PATH_B.toRealPath(), ref.get()); in testIteratorPathIO()
156 ioBaseStreamPath.asBaseStream().iterator().forEachRemaining(e -> ref.set(e.getFileName())); in testIteratorPathIO()
[all …]
DIOBinaryOperatorStreamTest.java9 * http://www.apache.org/licenses/LICENSE-2.0
30 import java.util.stream.Stream;
44 private static final IOBinaryOperator<Path> REAL_PATH_IO_BO = (t, u) -> t.toRealPath();
50 …() -> Stream.of(TestConstants.ABS_PATH_A, TestConstants.ABS_PATH_A).reduce(TestUtils.<Path>throwin… in testAsBinaryOperator()
51 …rtEquals(TestConstants.ABS_PATH_A, Stream.of(TestConstants.ABS_PATH_A, TestConstants.ABS_PATH_A).r… in testAsBinaryOperator()
52 …rtEquals(TestConstants.ABS_PATH_A, Stream.of(TestConstants.ABS_PATH_A, TestConstants.ABS_PATH_A).r… in testAsBinaryOperator()
59 …rtEquals(TestConstants.ABS_PATH_A, Stream.of(TestConstants.ABS_PATH_A, TestConstants.ABS_PATH_A).r… in testMaxBy()
60 // in-line lambda ok: in testMaxBy()
61 …final IOBinaryOperator<Path> binIoOp = IOBinaryOperator.maxBy((t, u) -> t.toRealPath().compareTo(u… in testMaxBy()
67 …uals(TestConstants.ABS_PATH_A, Stream.of(TestConstants.ABS_PATH_A, TestConstants.ABS_PATH_A).reduc… in testMaxBy()
[all …]
/external/cronet/net/spdy/
Dspdy_write_queue_unittest.cc2 // Use of this source code is governed by a BSD-style license that can be
37 std::memcpy(data.get(), s.data(), s.size()); in StringToProducer()
56 buffer_->AddConsumeCallback( in RequeingBufferProducer()
71 queue->Enqueue(MEDIUM, spdy::SpdyFrameType::RST_STREAM, in ConsumeCallback()
83 std::unique_ptr<SpdyBuffer> buffer = producer->ProduceBuffer(); in ProducerToString()
84 return std::string(buffer->GetRemainingData(), buffer->GetRemainingSize()); in ProducerToString()
96 // -- be careful to not call any functions that expect the session to
106 // should be dequeued in priority order with their associated stream.
119 // A NULL stream should still work. in TEST_F()
124 std::move(producer_medium), stream_medium->GetWeakPtr(), in TEST_F()
[all …]
/external/cronet/net/base/
Delements_upload_data_stream_unittest.cc2 // Use of this source code is governed by a BSD-style license that can be
49 const size_t kTestDataSize = std::size(kTestData) - 1;
52 // Reads data from the upload data stream, and returns the data as string.
53 std::string ReadFromUploadDataStream(UploadDataStream* stream) { in ReadFromUploadDataStream() argument
56 while (!stream->IsEOF()) { in ReadFromUploadDataStream()
59 stream->Read(buf.get(), kTestBufferSize, callback.callback()); in ReadFromUploadDataStream()
62 data_read.append(buf->data(), bytes_read); in ReadFromUploadDataStream()
79 // This is a back to get around Gmock's lack of support for move-only types. in Init()
113 base::SingleThreadTaskRunner::GetCurrentDefault()->PostTask( in OnInit()
119 bytes_remaining_ = std::max(0, bytes_remaining_ - read_result_); in OnRead()
[all …]
/external/tensorflow/tensorflow/c/experimental/stream_executor/
Dstream_executor.cc7 http://www.apache.org/licenses/LICENSE-2.0
15 // This file extends/implements core stream executor base classes in terms of
40 #include "tensorflow/stream_executor/stream.h"
182 device_memory_base.opaque = const_cast<void*>(mem->opaque()); in DeviceMemoryBaseToC()
183 device_memory_base.size = mem->size(); in DeviceMemoryBaseToC()
184 device_memory_base.payload = mem->payload(); in DeviceMemoryBaseToC()
204 port::Status s = host_ctx->callback(); in HostCallbackTrampoline()
226 platform_fns_->destroy_device(platform_, &device_); in ~CStreamExecutor()
235 stream_executor_->allocate(&device_, size, memory_space, &mem); in Allocate()
252 stream_executor_->deallocate(&device_, &device_memory_base); in Deallocate()
[all …]
/external/javaparser/javaparser-symbol-solver-testing/src/test/test_sourcecode/javasymbolsolver_0_6_0/expected_output/java-symbol-solver-core/
Dcom_github_javaparser_symbolsolver_javaparsermodel_declarations_JavaParserAnonymousClassDeclaration.txt2 …Line 44) JavaParserFactory.getContext(wrappedNode.getParentNode().get(), typeSolver).solveType(wra…
3 …Line 44) JavaParserFactory.getContext(wrappedNode.getParentNode().get(), typeSolver).solveType(wra…
4 …Line 44) JavaParserFactory.getContext(wrappedNode.getParentNode().get(), typeSolver) ==> com.githu…
5 Line 44) wrappedNode.getParentNode().get() ==> java.util.Optional.get()
10 …get().stream().filter(node -> memberClass.isAssignableFrom(node.getClass())).map(node -> (T) node)…
11 …sClassBody().get().stream().filter(node -> memberClass.isAssignableFrom(node.getClass())).map(node…
12 …getAnonymousClassBody().get().stream().filter(node -> memberClass.isAssignableFrom(node.getClass()…
13 Line 54) wrappedNode.getAnonymousClassBody().get().stream() ==> java.util.Collection.stream()
14 Line 54) wrappedNode.getAnonymousClassBody().get() ==> java.util.Optional.get()
18 Line 60) Collectors.toList() ==> java.util.stream.Collectors.toList()
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/
Dstream_pool_test.cc7 http://www.apache.org/licenses/LICENSE-2.0
32 return platform->GetUncachedExecutor(config).value(); in NewStreamExecutor()
42 // Borrow and return a stream. in TEST_F()
43 StreamPool::Ptr stream1 = pool.BorrowStream(executor.get()); in TEST_F()
44 se::Stream* stream1_ptr = stream1.get(); in TEST_F()
45 EXPECT_TRUE(stream1->ok()); in TEST_F()
48 // Borrow and return another stream. in TEST_F()
49 StreamPool::Ptr stream2 = pool.BorrowStream(executor.get()); in TEST_F()
50 se::Stream* stream2_ptr = stream2.get(); in TEST_F()
51 EXPECT_TRUE(stream2->ok()); in TEST_F()
[all …]
/external/openscreen/osp/impl/presentation/
Durl_availability_requester_unittest.cc2 // Use of this source code is governed by a BSD-style license that can be
51 task_runner_ = std::make_unique<FakeTaskRunner>(fake_clock_.get()); in UrlAvailabilityRequesterTest()
53 std::make_unique<FakeQuicBridge>(task_runner_.get(), FakeClock::now); in UrlAvailabilityRequesterTest()
54 info1_ = {service_id_, friendly_name_, 1, quic_bridge_->kReceiverEndpoint}; in UrlAvailabilityRequesterTest()
59 std::move(quic_bridge_->quic_client), in SetUp()
60 std::move(quic_bridge_->quic_server)); in SetUp()
62 quic_bridge_->receiver_demuxer->SetDefaultMessageTypeWatch( in SetUp()
73 std::unique_ptr<ProtocolConnection> stream; in ExpectIncomingConnection() local
75 EXPECT_CALL(quic_bridge_->mock_server_observer, OnIncomingConnectionMock(_)) in ExpectIncomingConnection()
77 Invoke([&stream](std::unique_ptr<ProtocolConnection>& connection) { in ExpectIncomingConnection()
[all …]
/external/angle/src/libANGLE/renderer/metal/
Dmtl_command_buffer.mm3 // Use of this source code is governed by a BSD-style license that can be
90 inline void InvalidCmd(id<MTLRenderCommandEncoder> encoder, IntermediateCommandStream *stream)
96 IntermediateCommandStream *stream)
98 id<MTLRenderPipelineState> state = stream->fetch<id<MTLRenderPipelineState>>();
104 IntermediateCommandStream *stream)
106 MTLTriangleFillMode mode = stream->fetch<MTLTriangleFillMode>();
111 IntermediateCommandStream *stream)
113 MTLWinding winding = stream->fetch<MTLWinding>();
117 inline void SetCullModeCmd(id<MTLRenderCommandEncoder> encoder, IntermediateCommandStream *stream)
119 MTLCullMode mode = stream->fetch<MTLCullMode>();
[all …]
/external/cronet/net/quic/
Dquic_stream_factory_test.cc2 // Use of this source code is governed by a BSD-style license that can be
105 HttpStream* stream) { in GetSessionHandle() argument
106 return static_cast<QuicHttpStream*>(stream)->quic_session(); in GetSessionHandle()
174 socket->set_source_host(IPAddress(192, 0, 2, next_source_host_num_++)); in CreateDatagramClientSocket()
201 socket->set_source_port(next_source_port_num_++); in CreateDatagramClientSocket()
297 net_log_.net_log(), host_resolver_.get(), &ssl_config_service_, in Initialize()
298 socket_factory_.get(), http_server_properties_.get(), in Initialize()
299 cert_verifier_.get(), &ct_policy_enforcer_, &transport_security_state_, in Initialize()
310 scoped_mock_network_change_notifier_->mock_network_change_notifier(); in InitializeConnectionMigrationV2Test()
311 mock_ncn->ForceNetworkHandlesSupported(); in InitializeConnectionMigrationV2Test()
[all …]
/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/hls/src/test/java/com/google/android/exoplayer2/source/hls/playlist/
DHlsMultivariantPlaylistParserTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
48 + "#EXT-X-STREAM-INF:BANDWIDTH=1280000,"
52 + "#EXT-X-STREAM-INF:BANDWIDTH=1280000,CODECS=\"mp4a.40.2 , avc1.66.30 \"\n"
55 + "#EXT-X-STREAM-INF:BANDWIDTH=2560000,FRAME-RATE=25,RESOLUTION=384x160\n"
58 + "#EXT-X-STREAM-INF:BANDWIDTH=7680000,FRAME-RATE=29.997\n"
61 + "#EXT-X-STREAM-INF:BANDWIDTH=65000,CODECS=\"mp4a.40.5\"\n"
62 + "http://example.com/audio-only.m3u8";
67 + "#EXT-X-STREAM-INF:BANDWIDTH=1280000,"
71 + "#EXT-X-STREAM-INF:BANDWIDTH=1280000,AVERAGE-BANDWIDTH=1270000,"
77 + "#EXT-X-STREAM-INF:BANDWIDTH=1280000,"
[all …]

12345678910>>...51