| /toolchain/binutils/binutils-2.27/zlib/ |
| uncompr.c | 30 z_stream stream; local
33 stream.next_in = (z_const Bytef *)source;
34 stream.avail_in = (uInt)sourceLen;
36 if ((uLong)stream.avail_in != sourceLen) return Z_BUF_ERROR;
38 stream.next_out = dest;
39 stream.avail_out = (uInt)*destLen;
40 if ((uLong)stream.avail_out != *destLen) return Z_BUF_ERROR;
42 stream.zalloc = (alloc_func)0;
43 stream.zfree = (free_func)0;
45 err = inflateInit(&stream);
[all...] |
| /cts/tests/tests/net/src/android/net/rtp/cts/ |
| AudioStreamTest.java | 27 AudioStream stream = new AudioStream(address); local
28 assertEquals(stream.getLocalAddress(), address);
29 assertEquals(stream.getLocalPort() % 2, 0);
31 assertNull(stream.getRemoteAddress());
32 assertEquals(stream.getRemotePort(), -1);
33 stream.associate(address, 1000);
34 assertEquals(stream.getRemoteAddress(), address);
35 assertEquals(stream.getRemotePort(), 1000);
37 assertFalse(stream.isBusy());
38 stream.release()
50 AudioStream stream = new AudioStream(InetAddress.getByName("::1")); local
73 AudioStream stream = new AudioStream(InetAddress.getByName("::1")); local
90 AudioStream stream = new AudioStream(InetAddress.getByName("::1")); local
[all...] |
| /libcore/ojluni/src/main/java/java/util/stream/ |
| StreamSupport.java | 25 package java.util.stream;
34 * <p>This class is mostly for library writers presenting stream views
35 * of data structures; most static stream methods intended for end users are in
36 * the various {@code Stream} classes.
46 * Creates a new sequential or parallel {@code Stream} from a
50 * size after the terminal operation of the stream pipeline commences.
55 * {@link #stream(java.util.function.Supplier, int, boolean)} should be used
60 * @param <T> the type of stream elements
61 * @param spliterator a {@code Spliterator} describing the stream elements
62 * @param parallel if {@code true} then the returned stream is a paralle
67 public static <T> Stream<T> stream(Spliterator<T> spliterator, boolean parallel) { method in class:StreamSupport
107 public static <T> Stream<T> stream(Supplier<? extends Spliterator<T>> supplier, method in class:StreamSupport
[all...] |
| /external/nanopb-c/tests/alltypes/ |
| encode_alltypes.c | 130 pb_ostream_t stream = pb_ostream_from_buffer(buffer, sizeof(buffer)); local
133 if (pb_encode(&stream, AllTypes_fields, &alltypes))
136 fwrite(buffer, 1, stream.bytes_written, stdout);
141 fprintf(stderr, "Encoding failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/nanopb-c/tests/backwards_compatibility/ |
| encode_legacy.c | 120 pb_ostream_t stream = pb_ostream_from_buffer(buffer, sizeof(buffer)); local
123 if (pb_encode(&stream, AllTypes_fields, &alltypes))
126 fwrite(buffer, 1, stream.bytes_written, stdout);
|
| /external/nanopb-c/tests/basic_stream/ |
| encode_stream.c | 9 /* This binds the pb_ostream_t into the stdout stream */
10 bool streamcallback(pb_ostream_t *stream, const uint8_t *buf, size_t count)
12 FILE *file = (FILE*) stream->state;
25 /* Prepare the stream, output goes directly to stdout */
26 pb_ostream_t stream = {&streamcallback, NULL, SIZE_MAX, 0}; local
27 stream.state = stdout;
31 if (pb_encode(&stream, Person_fields, &person))
37 fprintf(stderr, "Encoding failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/nanopb-c/tests/missing_fields/ |
| missing_fields.c | 16 pb_ostream_t stream = pb_ostream_from_buffer(buffer, sizeof(buffer)); local
18 if (!pb_encode(&stream, MissingField_fields, &msg))
24 size = stream.bytes_written;
30 pb_istream_t stream = pb_istream_from_buffer(buffer, size); local
32 if (!pb_decode(&stream, MissingField_fields, &msg))
34 printf("Decode failed: %s\n", PB_GET_ERROR(&stream));
42 pb_istream_t stream = pb_istream_from_buffer(buffer, size); local
44 if (pb_decode(&stream, AllFields_fields, &msg))
|
| /external/pdfium/core/fxge/dib/ |
| cstretchengine_unittest.cpp | 25 std::unique_ptr<CPDF_Stream> stream = local
28 dib_source->Load(nullptr, stream.get());
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| IntermediateTestOp.java | 23 package java.util.stream;
|
| /packages/services/Car/tests/obd2_test/src/com/android/car/obd2/test/ |
| IntegerArrayStreamTest.java | 30 IntegerArrayStream stream = new IntegerArrayStream(DATA_SET); local
31 assertEquals(1, stream.peek());
32 assertEquals(1, stream.consume());
33 assertEquals(2, stream.peek());
34 assertEquals(2, stream.consume());
39 IntegerArrayStream stream = new IntegerArrayStream(DATA_SET); local
40 assertEquals(DATA_SET.length, stream.residualLength());
41 stream.consume();
42 assertEquals(DATA_SET.length - 1, stream.residualLength());
47 IntegerArrayStream stream = new IntegerArrayStream(DATA_SET) local
57 IntegerArrayStream stream = new IntegerArrayStream(DATA_SET); local
65 IntegerArrayStream stream = new IntegerArrayStream(DATA_SET); local
[all...] |
| /cts/apps/VpnApp/src/com/android/cts/vpnfirewall/ |
| IcmpMessage.java | 31 IcmpMessage(DataInputStream stream, int length) throws IOException {
32 type = stream.readUnsignedByte();
33 code = stream.readUnsignedByte();
34 int checksum = stream.readUnsignedShort();
35 quench = stream.readInt() & 0xFFFFFFFFL;
39 int len = stream.read(data, 0, dataLength);
45 stream.reset();
46 stream.readFully(original);
54 DataOutputStream stream = new DataOutputStream(output); local
56 stream.writeByte(type)
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.10/Modules/zlib/ |
| compress.c | 29 z_stream stream;
local
32 stream.next_in = (z_const Bytef *)source;
33 stream.avail_in = (uInt)sourceLen;
36 if ((uLong)stream.avail_in != sourceLen) return Z_BUF_ERROR;
38 stream.next_out = dest;
39 stream.avail_out = (uInt)*destLen;
40 if ((uLong)stream.avail_out != *destLen) return Z_BUF_ERROR;
42 stream.zalloc = (alloc_func)0;
43 stream.zfree = (free_func)0;
44 stream.opaque = (voidpf)0;
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Modules/zlib/ |
| compress.c | 29 z_stream stream;
local
32 stream.next_in = (Bytef*)source;
33 stream.avail_in = (uInt)sourceLen;
36 if ((uLong)stream.avail_in != sourceLen) return Z_BUF_ERROR;
38 stream.next_out = dest;
39 stream.avail_out = (uInt)*destLen;
40 if ((uLong)stream.avail_out != *destLen) return Z_BUF_ERROR;
42 stream.zalloc = (alloc_func)0;
43 stream.zfree = (free_func)0;
44 stream.opaque = (voidpf)0;
[all...] |
| /external/antlr/antlr-3.4/runtime/ObjC/Framework/test/runtime/TestRewriteRuleTokenStream/ |
| TestRewriteRuleTokenStream.h | 34 ANTLRRewriteRuleTokenStream *stream; variable
|
| /external/bsdiff/ |
| logging.h | 14 #define LOG(severity) LogMessage(__FILE__, __LINE__, #severity).stream()
17 #define PLOG(severity) LogMessage(__FILE__, __LINE__, #severity, errno).stream()
31 // Returns the stream associated with the message, the LogMessage performs
33 std::ostream& stream() { return stream_; } function in class:LogMessage
|
| /external/freetype/src/base/ |
| ftsnames.c | 66 FT_Stream stream = face->stream; local
122 FT_Stream stream = face->stream; local
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/model/stream/ |
| StreamModelLoader.java | 1 package com.bumptech.glide.load.model.stream;
|
| /external/libdrm/tests/etnaviv/ |
| etnaviv_cmd_stream_test.c | 36 struct etna_cmd_stream *stream; local
41 stream = etna_cmd_stream_new(NULL, 0, NULL, NULL);
42 assert(stream == NULL);
44 stream = etna_cmd_stream_new(NULL, 4, NULL, NULL);
45 assert(stream);
46 assert(etna_cmd_stream_avail(stream) == 2);
47 etna_cmd_stream_del(stream);
49 stream = etna_cmd_stream_new(NULL, 20, NULL, NULL);
50 assert(stream);
51 assert(etna_cmd_stream_avail(stream) == 18)
70 struct etna_cmd_stream *stream; local
94 struct etna_cmd_stream *stream; local
[all...] |
| /external/nanopb-c/examples/network_server/ |
| common.c | 11 static bool write_callback(pb_ostream_t *stream, const uint8_t *buf, size_t count)
13 int fd = (intptr_t)stream->state;
17 static bool read_callback(pb_istream_t *stream, uint8_t *buf, size_t count)
19 int fd = (intptr_t)stream->state;
25 stream->bytes_left = 0; /* EOF */
32 pb_ostream_t stream = {&write_callback, (void*)(intptr_t)fd, SIZE_MAX, 0}; local
33 return stream;
38 pb_istream_t stream = {&read_callback, (void*)(intptr_t)fd, SIZE_MAX}; local
39 return stream;
|
| /external/nanopb-c/examples/simple/ |
| simple.c | 21 /* Create a stream that will write to our buffer. */
22 pb_ostream_t stream = pb_ostream_from_buffer(buffer, sizeof(buffer)); local
28 status = pb_encode(&stream, SimpleMessage_fields, &message);
29 message_length = stream.bytes_written;
34 printf("Encoding failed: %s\n", PB_GET_ERROR(&stream));
49 /* Create a stream that reads from the buffer. */
50 pb_istream_t stream = pb_istream_from_buffer(buffer, message_length); local
53 status = pb_decode(&stream, SimpleMessage_fields, &message);
58 printf("Decoding failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/nanopb-c/examples/using_double_on_avr/ |
| decode_double.c | 14 pb_istream_t stream = pb_istream_from_buffer(buffer, count); local
17 pb_decode(&stream, AVRDoubleMessage_fields, &message);
|
| /external/python/cpython2/Modules/zlib/ |
| compress.c | 29 z_stream stream; local
32 stream.next_in = (z_const Bytef *)source;
33 stream.avail_in = (uInt)sourceLen;
36 if ((uLong)stream.avail_in != sourceLen) return Z_BUF_ERROR;
38 stream.next_out = dest;
39 stream.avail_out = (uInt)*destLen;
40 if ((uLong)stream.avail_out != *destLen) return Z_BUF_ERROR;
42 stream.zalloc = (alloc_func)0;
43 stream.zfree = (free_func)0;
44 stream.opaque = (voidpf)0
[all...] |
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/ |
| StringsTest.java | 13 InputStream stream = new ByteArrayInputStream("some random string".getBytes()); local
14 assertEquals("some random string", Strings.fromStream(stream));
|
| /external/selinux/libsepol/src/ |
| debug.c | 49 FILE *stream = NULL; local
55 stream = stderr;
59 stream = stdout;
63 fprintf(stream, "%s.%s: ",
68 vfprintf(stream, fmt, ap);
71 fprintf(stream, "\n");
|
| /external/skia/bench/ |
| StreamBench.cpp | 30 SkDynamicMemoryWStream stream; variable
33 stream.write32(j);
34 stream.write32(j+j);
36 stream.write(t3, 3);
37 stream.write(t5, 5);
|
