Home
last modified time | relevance | path

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

12345678910>>...49

/aosp_15_r20/external/jazzer-api/src/test/java/com/code_intelligence/jazzer/mutation/mutator/lang/
H A 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 …]
/aosp_15_r20/external/grpc-grpc/test/core/xds/
H A 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 …]
/aosp_15_r20/external/nullaway/nullaway/src/test/resources/com/uber/nullaway/testdata/
H A 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 …]
H A 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 …]
/aosp_15_r20/external/libbrillo/brillo/streams/
H A 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 …]
/aosp_15_r20/external/cronet/net/quic/
H A Dquic_session_pool_test.cc2 // Use of this source code is governed by a BSD-style license that can be
115 HttpStream* stream) { in GetSessionHandle() argument
116 return static_cast<QuicHttpStream*>(stream)->quic_session(); in GetSessionHandle()
168 socket->set_source_host(IPAddress(192, 0, 2, next_source_host_num_++)); in CreateDatagramClientSocket()
195 socket->set_source_port(next_source_port_num_++); in CreateDatagramClientSocket()
270 // Verifies that the QUIC stream factory is initialized correctly.
279 // Migratable stream triggers write error.
281 // Non-migratable stream triggers write error.
329 while (!runner_->GetPostedTasks().empty()) { in RunTestLoopUntilIdle()
330 runner_->RunNextTask(); in RunTestLoopUntilIdle()
[all …]
/aosp_15_r20/external/dng_sdk/source/
H A 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 …]
H A 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 …]
/aosp_15_r20/external/puffin/src/
H A 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 …]
/aosp_15_r20/external/skia/tests/
H A 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 …]
/aosp_15_r20/hardware/google/gfxstream/host/magma/magma_dec/
Dmagma_dec.cpp1 // Generated Code - DO NOT EDIT !!
15 #include "host-common/logging.h"
21 typedef unsigned int tsize_t; // Target "size_t", which is 32-bit for now. It may or may not be the…
28 size_t magma_decoder_context_t::decode(void *buf, size_t len, IOStream *stream, ChecksumCalculator*… in decode() argument
35 const size_t checksumSize = checksumCalc->checksumByteSize(); in decode()
37 while (end - ptr >= 8) { in decode()
40 if (end - ptr < packetLen) return ptr - (unsigned char*)buf; in decode()
53 unsigned char *tmpBuf = stream->alloc(totalTmpSize); in decode()
55 …rt(device_channel:%u device_out:%p(%u) )", stream, var_device_channel, (magma_device_t*)(outptr_de… in decode()
56 …pBuf[0 + size_device_out]) = this->magma_device_import(var_device_channel, (magma_device_t*)(ou… in decode()
[all …]
/aosp_15_r20/external/angle/src/libANGLE/renderer/metal/
H A Dmtl_command_buffer.mm3 // Use of this source code is governed by a BSD-style license that can be
92 inline void InvalidCmd(id<MTLRenderCommandEncoder> encoder, IntermediateCommandStream *stream)
98 IntermediateCommandStream *stream)
100 id<MTLRenderPipelineState> state = stream->fetch<id<MTLRenderPipelineState>>();
106 IntermediateCommandStream *stream)
108 MTLTriangleFillMode mode = stream->fetch<MTLTriangleFillMode>();
113 IntermediateCommandStream *stream)
115 MTLWinding winding = stream->fetch<MTLWinding>();
119 inline void SetCullModeCmd(id<MTLRenderCommandEncoder> encoder, IntermediateCommandStream *stream)
121 MTLCullMode mode = stream->fetch<MTLCullMode>();
[all …]
/aosp_15_r20/external/intel-media-driver/media_softlet/agnostic/common/os/
H A Dmos_interface.h2 * Copyright (c) 2009-2023, Intel Corporation
29 //! Stream level: OsStreamState in Hal instances (Codec pipeline, VP pipeline, CM device, CP sessio…
30 //! Each Hal instance can have an OsStreamState to indicate that stream's state speci…
33 //! between device and stream in DDI
155 //! \brief Create Os Stream State
156 //! \details Create the Os Stream State in stream level.
158 …//! \details In DDI, one stream (Hal instance) can only create one Os Stream State corresponding …
159 …//! Os Stream state directly created by DDI is not corresponding any streams (Hal instan…
162 //! Handle of Os Stream State to create. If creation failed, it is INVALID_HANLE.
163 …//! OsStreamState is a stream level state which stores the flags, info specific to OS sp…
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/stream_executor/
H A 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 …]
/aosp_15_r20/external/cronet/net/base/
H A 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 …]
/aosp_15_r20/external/tensorflow/tensorflow/c/experimental/stream_executor/
H A 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 …]
/aosp_15_r20/external/cronet/components/cronet/android/test/javatests/src/org/chromium/net/
H A DBidirectionalStreamTest.java2 // Use of this source code is governed by a BSD-style license that can be
74 (builder) -> in setUp()
136 // Create stream. in runGetWithExpectedReceivedByteCount()
137 BidirectionalStream stream = in runGetWithExpectedReceivedByteCount() local
140 .setHttpMethod("GET") in runGetWithExpectedReceivedByteCount()
142 stream.start(); in runGetWithExpectedReceivedByteCount()
144 assertThat(stream.isDone()).isTrue(); in runGetWithExpectedReceivedByteCount()
147 // Default method is 'GET'. in runGetWithExpectedReceivedByteCount()
148 assertThat(callback.mResponseAsString).isEqualTo("GET"); in runGetWithExpectedReceivedByteCount()
177 () -> in runBuilderCheckNativeImpl()
[all …]
/aosp_15_r20/cts/tests/inputmethod/src/android/view/inputmethod/cts/
H A DFocusHandlingTest.java8 * http://www.apache.org/licenses/LICENSE-2.0
137 TestActivity.startSync(activity-> { in launchTestActivity()
150 return editTextRef.get(); in launchTestActivity()
156 editText.post(() -> { in launchTestActivity()
158 observerForEditText.addOnWindowFocusChangeListener((hasFocus) -> in launchTestActivity()
169 final ImeEventStream stream = imeSession.openEventStream(); in testOnStartInputCalledOnceIme() local
175 expectBindInput(stream, Process.myPid(), TIMEOUT); in testOnStartInputCalledOnceIme()
179 expectEvent(stream, editorMatcher("onStartInput", marker), TIMEOUT); in testOnStartInputCalledOnceIme()
181 assertFalse(stream.dump(), onStart.getEnterState().hasFallbackInputConnection()); in testOnStartInputCalledOnceIme()
182 assertFalse(stream.dump(), onStart.getArguments().getBoolean("restarting")); in testOnStartInputCalledOnceIme()
[all …]
/aosp_15_r20/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DMatchOpTest.java17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
28 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.OpTestCase;
30 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.TestData;
46 import java.util.stream.DoubleStream;
[all …]
/aosp_15_r20/external/cronet/net/spdy/
H A 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 …]
/aosp_15_r20/external/grpc-grpc/test/cpp/end2end/
H A Dhybrid_end2end_test.cc9 // http://www.apache.org/licenses/LICENSE-2.0
51 EXPECT_TRUE(cq->Next(&got_tag, &ok)); in VerifyReturnSuccess()
67 service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq, in HandleEcho()
72 send_response.mutable_message()->append("_dup"); in HandleEcho()
87 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, in HandleRawEcho()
105 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleClientStreaming()
110 send_response.mutable_message()->append(recv_request.message()); in HandleClientStreaming()
124 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleRawClientStreaming()
134 send_response.mutable_message()->append(recv_request.message()); in HandleRawClientStreaming()
147 service->RequestResponseStream(&srv_ctx, &recv_request, &srv_stream, cq, cq, in HandleServerStreaming()
[all …]
/aosp_15_r20/hardware/interfaces/audio/aidl/vts/
H A DVtsHalAudioCoreModuleTargetTest.cpp8 * http://www.apache.org/licenses/LICENSE-2.0
33 #include <android-base/logging.h>
47 #include <android-base/chrono_utils.h>
145 return includeZero ? std::vector<int32_t>{-1, 0, 1} : std::vector<int32_t>{-1, 1}; in GetNonExistentIds()
148 if (auto value = *std::min_element(allIds.begin(), allIds.end()) - 1; in GetNonExistentIds()
152 nonExistentIds.push_back(value - 1); in GetNonExistentIds()
182 // Point-to-point connections do not use addresses. in GenerateUniqueDeviceAddress()
189 const auto& deviceDescription = port.ext.get<AudioPortExt::Tag::device>().device.type; in GenerateUniqueDeviceAddress()
190 AudioDeviceAddress address = port.ext.get<AudioPortExt::Tag::device>().device.address; in GenerateUniqueDeviceAddress()
191 // If the address is already set, do not re-generate. in GenerateUniqueDeviceAddress()
[all …]
/aosp_15_r20/hardware/google/gfxstream/host/gl/gles2_dec/
Dgles2_dec.cpp1 // Generated Code - DO NOT EDIT !!
15 #include "host-common/logging.h"
21 typedef unsigned int tsize_t; // Target "size_t", which is 32-bit for now. It may or may not be the…
28 size_t gles2_decoder_context_t::decode(void *buf, size_t len, IOStream *stream, ChecksumCalculator*… in decode() argument
35 const size_t checksumSize = checksumCalc->checksumByteSize(); in decode()
37 while (end - ptr >= 8) { in decode()
40 if (end - ptr < packetLen) return ptr - (unsigned char*)buf; in decode()
50 GLint err = this->glGetError(); in decode()
51 if (err) fprintf(stderr, "gles2 Error (pre-call): 0x%X before glActiveTexture\n", err); in decode()
53 DECODER_DEBUG_LOG("gles2(%p): glActiveTexture(texture:0x%08x )", stream, var_texture); in decode()
[all …]
/aosp_15_r20/hardware/google/gfxstream/host/renderControl_dec/
DrenderControl_dec.cpp1 // Generated Code - DO NOT EDIT !!
15 #include "host-common/logging.h"
21 typedef unsigned int tsize_t; // Target "size_t", which is 32-bit for now. It may or may not be the…
28 size_t renderControl_decoder_context_t::decode(void *buf, size_t len, IOStream *stream, ChecksumCal… in decode() argument
35 while (end - ptr >= 8) { in decode()
38 if (end - ptr < packetLen) return ptr - (unsigned char*)buf; in decode()
41 const size_t checksumSize = checksumCalc->checksumByteSize(); in decode()
52 unsigned char *tmpBuf = stream->alloc(totalTmpSize); in decode()
53 DECODER_DEBUG_LOG("renderControl(%p): rcGetRendererVersion()", stream); in decode()
54 *(GLint *)(&tmpBuf[0]) = this->rcGetRendererVersion(); in decode()
[all …]
/aosp_15_r20/external/openscreen/osp/impl/presentation/
H A 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 …]

12345678910>>...49