Home
last modified time | relevance | path

Searched refs:Streams (Results 1 – 25 of 98) sorted by relevance

1234

/external/swiftshader/third_party/llvm-7.0/llvm/tools/llvm-pdbutil/
DStreamUtil.cpp68 SmallVectorImpl<StreamInfo> &Streams) { in discoverStreamPurposes() argument
98 Streams.resize(StreamCount); in discoverStreamPurposes()
101 Streams[StreamIdx] = in discoverStreamPurposes()
104 Streams[StreamIdx] = stream(StreamPurpose::PDB, "PDB Stream", StreamIdx); in discoverStreamPurposes()
106 Streams[StreamIdx] = stream(StreamPurpose::DBI, "DBI Stream", StreamIdx); in discoverStreamPurposes()
108 Streams[StreamIdx] = stream(StreamPurpose::TPI, "TPI Stream", StreamIdx); in discoverStreamPurposes()
110 Streams[StreamIdx] = stream(StreamPurpose::IPI, "IPI Stream", StreamIdx); in discoverStreamPurposes()
112 Streams[StreamIdx] = in discoverStreamPurposes()
115 Streams[StreamIdx] = in discoverStreamPurposes()
118 Streams[StreamIdx] = in discoverStreamPurposes()
[all …]
/external/guava/guava-tests/test/com/google/common/collect/
DStreamsTest.java17 import static com.google.common.collect.Streams.stream;
79 assertThat(Streams.concat(Stream.of("a"), Stream.of("b"), Stream.empty(), Stream.of("c", "d"))) in testConcat_refStream()
84 Streams.concat(Stream.of("a"), Stream.of("b"), Stream.empty(), Stream.of("c", "d")) in testConcat_refStream()
93 Streams.concat(Stream.of("a"), streamB, Stream.empty(), Stream.of("c", "d")); in testConcat_refStream_closeIsPropagated()
126 Streams.concat(Stream.of("a"), Stream.of("b"), Stream.empty(), Stream.of("c", "d")) in testConcat_refStream_parallel()
136 Streams.concat(IntStream.of(1), IntStream.of(2), IntStream.empty(), IntStream.of(3, 4))) in testConcat_intStream()
143 Streams.concat( in testConcat_longStream()
151 Streams.concat( in testConcat_doubleStream()
178 Streams.mapWithIndex( in testMapWithIndex()
184 Streams.mapWithIndex( in testMapWithIndex()
[all …]
/external/swiftshader/third_party/llvm-7.0/llvm/unittests/Support/
DBinaryStreamTest.cpp116 Streams.clear(); in SetUp()
117 Streams.resize(NumStreams); in SetUp()
119 Streams[I].IsContiguous = (I % 2 == 0); in SetUp()
152 Streams[I * 2].Input = std::move(InByteStream); in initializeInput()
153 Streams[I * 2 + 1].Input = std::move(InBrokenStream); in initializeInput()
162 Streams[I * 2].Output = in initializeOutput()
164 Streams[I * 2 + 1].Output = llvm::make_unique<BrokenStream>( in initializeOutput()
171 Streams[I * 2].Output = in initializeOutputFromInput()
173 Streams[I * 2 + 1].Output = llvm::make_unique<BrokenStream>( in initializeOutputFromInput()
180 Streams[I * 2].Input = in initializeInputFromOutput()
[all …]
/external/lzma/CPP/7zip/Archive/Common/
DMultiStream.h31 CObjectVector<CSubStreamInfo> Streams; variable
36 FOR_VECTOR (i, Streams) in Init()
38 CSubStreamInfo &s = Streams[i]; in Init()
40 total += Streams[i].Size; in Init()
DMultiStream.cpp17 unsigned left = 0, mid = _streamIndex, right = Streams.Size(); in Read()
20 CSubStreamInfo &m = Streams[mid]; in Read()
35 CSubStreamInfo &s = Streams[_streamIndex]; in Read()
/external/swiftshader/third_party/llvm-7.0/llvm/unittests/DebugInfo/PDB/
DHashTableTest.cpp157 std::vector<StringRef> Streams = {"One", "Two", "Three", "Four", in TEST() local
160 for (uint32_t I = 0; I < Streams.size(); ++I) in TEST()
161 ExpectedIndices[Streams[I]] = I + 1; in TEST()
167 for (StringRef S : Streams) in TEST()
170 EXPECT_EQ(Streams.size(), NSM.size()); in TEST()
193 } while (std::next_permutation(Streams.begin(), Streams.end())); in TEST()
/external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/
DBEROctetStringParser.java6 import org.bouncycastle.util.io.Streams;
41 return new BEROctetString(Streams.readAll(getOctetStream())); in getLoadedObject()
DDefiniteLengthInputStream.java7 import org.bouncycastle.util.io.Streams;
101 if ((_remaining -= Streams.readFully(_in, bytes)) != 0) in toByteArray()
DASN1InputStream.java9 import org.bouncycastle.util.io.Streams;
119 if (Streams.readFully(this, bytes) != bytes.length) in readFully()
390 Streams.readFully(defIn, buf); in getBuffer()
DASN1BitString.java9 import org.bouncycastle.util.io.Streams;
258 if (Streams.readFully(stream, data) != data.length) in fromInputStream()
/external/bouncycastle/repackaged/bcprov/src/main/java/com/android/org/bouncycastle/asn1/
DBEROctetStringParser.java7 import com.android.org.bouncycastle.util.io.Streams;
43 return new BEROctetString(Streams.readAll(getOctetStream())); in getLoadedObject()
DDefiniteLengthInputStream.java8 import com.android.org.bouncycastle.util.io.Streams;
102 if ((_remaining -= Streams.readFully(_in, bytes)) != 0) in toByteArray()
DASN1InputStream.java10 import com.android.org.bouncycastle.util.io.Streams;
126 if (Streams.readFully(this, bytes) != bytes.length) in readFully()
399 Streams.readFully(defIn, buf); in getBuffer()
DASN1BitString.java10 import com.android.org.bouncycastle.util.io.Streams;
262 if (Streams.readFully(stream, data) != data.length) in fromInputStream()
/external/conscrypt/repackaged/testing/src/main/java/com/android/org/conscrypt/testing/
DStreams.java28 public final class Streams { class
29 private Streams() {} in Streams() method in Streams
/external/conscrypt/testing/src/main/java/org/conscrypt/testing/
DStreams.java24 public final class Streams { class
25 private Streams() {} in Streams() method in Streams
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorage_grpc.go44 …stream, err := grpc.NewClientStream(ctx, &_MonsterStorage_serviceDesc.Streams[0], c.cc, "/MyGame.E…
69 …stream, err := grpc.NewClientStream(ctx, &_MonsterStorage_serviceDesc.Streams[1], c.cc, "/MyGame.E…
98 …stream, err := grpc.NewClientStream(ctx, &_MonsterStorage_serviceDesc.Streams[2], c.cc, "/MyGame.E…
232 Streams: []grpc.StreamDesc{
/external/turbine/javatests/com/google/turbine/testing/
DTestClassPaths.java23 import com.google.common.collect.Streams;
42 Streams.stream(
/external/lzma/CPP/7zip/UI/Common/
DUpdate.cpp102 CObjectVector<CAltStreamInfo> Streams; member in COutMultiVolStream
134 FOR_VECTOR (i, Streams) in Close()
136 COutFileStream *s = Streams[i].StreamSpec; in Close()
150 FOR_VECTOR (i, Streams) in SetMTime()
152 COutFileStream *s = Streams[i].StreamSpec; in SetMTime()
166 if (_streamIndex >= Streams.Size()) in Write()
187 Streams.Add(altStream); in Write()
190 CAltStreamInfo &altStream = Streams[_streamIndex]; in Write()
257 while (i < Streams.Size()) in SetSize()
259 CAltStreamInfo &altStream = Streams[i++]; in SetSize()
[all …]
/external/libphonenumber/demo/src/com/google/phonenumbers/
DPhoneNumberParserServlet.java39 import org.apache.commons.fileupload.util.Streams;
80 phoneNumber = Streams.asString(in, UTF_8.name()); in doPost()
82 defaultCountry = Streams.asString(in).toUpperCase(); in doPost()
84 String languageEntered = Streams.asString(in).toLowerCase(); in doPost()
89 regionCode = Streams.asString(in).toUpperCase(); in doPost()
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/
DShadowMemoryMappedFile.java13 import libcore.io.Streams;
41 shadowMemoryMappedFile.bytes = Streams.readFully(is); in mmapRO()
/external/swiftshader/third_party/llvm-7.0/llvm/docs/PDB/
DHashStream.rst2 The TPI & IPI Hash Streams
/external/bouncycastle/bcpkix/src/main/java/org/bouncycastle/cms/
DCMSUtils.java43 import org.bouncycastle.util.io.Streams;
348 return Streams.readAll(in); in streamToByteArray()
356 return Streams.readAllLimited(in, limit); in streamToByteArray()
/external/golang-protobuf/protoc-gen-go/testdata/grpc/
Dgrpc.pb.go219 …stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[0], "/grpc.testing.Test/Downstream",…
251 …stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[1], "/grpc.testing.Test/Upstream", o…
285 …stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[2], "/grpc.testing.Test/Bidi", opts.…
447 Streams: []grpc.StreamDesc{
/external/turbine/javatests/com/google/turbine/bytecode/sig/
DSigIntegrationTest.java24 import com.google.common.collect.Streams;
60 Streams.stream( in forEachBootclass()

1234