/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);
|