| /external/grpc-grpc/third_party/nanopb/tests/anonymous_oneof/ |
| decode_oneof.c | 12 int test_oneof_1(pb_istream_t *stream, int option)
20 if (!pb_decode(stream, AnonymousOneOfMessage_fields, &msg))
22 printf("Decoding failed: %s\n", PB_GET_ERROR(stream));
78 pb_istream_t stream; local
80 stream = pb_istream_from_buffer(buffer, count);
81 status = test_oneof_1(&stream, option);
|
| /external/grpc-grpc/third_party/nanopb/tests/backwards_compatibility/ |
| decode_legacy.c | 23 bool check_alltypes(pb_istream_t *stream, int mode)
27 if (!pb_decode(stream, AllTypes_fields, &alltypes))
179 pb_istream_t stream; local
189 stream = pb_istream_from_buffer(buffer, count);
192 if (!check_alltypes(&stream, mode))
194 printf("Parsing failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/grpc-grpc/third_party/nanopb/tests/basic_buffer/ |
| decode_buffer.c | 16 bool print_person(pb_istream_t *stream)
21 if (!pb_decode(stream, Person_fields, &person))
64 pb_istream_t stream; local
78 stream = pb_istream_from_buffer(buffer, count);
81 if (!print_person(&stream))
83 printf("Parsing failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/grpc-grpc/third_party/nanopb/tests/basic_stream/ |
| decode_stream.c | 12 bool print_person(pb_istream_t *stream)
17 if (!pb_decode(stream, Person_fields, &person))
58 bool callback(pb_istream_t *stream, uint8_t *buf, size_t count)
60 FILE *file = (FILE*)stream->state;
66 stream->bytes_left = 0;
73 pb_istream_t stream = {&callback, NULL, SIZE_MAX}; local
74 stream.state = stdin;
77 if (!print_person(&stream))
79 printf("Parsing failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/grpc-grpc/third_party/nanopb/tests/callbacks/ |
| decode_callbacks.c | 10 bool print_string(pb_istream_t *stream, const pb_field_t *field, void **arg)
15 if (stream->bytes_left > sizeof(buffer) - 1)
18 if (!pb_read(stream, buffer, stream->bytes_left))
28 bool print_int32(pb_istream_t *stream, const pb_field_t *field, void **arg)
31 if (!pb_decode_varint(stream, &value))
38 bool print_fixed32(pb_istream_t *stream, const pb_field_t *field, void **arg)
41 if (!pb_decode_fixed32(stream, &value))
48 bool print_fixed64(pb_istream_t *stream, const pb_field_t *field, void **arg)
51 if (!pb_decode_fixed64(stream, &value)
62 pb_istream_t stream; local
[all...] |
| /external/grpc-grpc/third_party/nanopb/tests/extensions/ |
| decode_extensions.c | 20 pb_istream_t stream; local
31 stream = pb_istream_from_buffer(buffer, count);
45 if (!pb_decode(&stream, AllTypes_fields, &alltypes))
47 printf("Parsing failed: %s\n", PB_GET_ERROR(&stream));
|
| encode_extensions.c | 15 pb_ostream_t stream; local
34 /* Set up the output stream */
35 stream = pb_ostream_from_buffer(buffer, sizeof(buffer));
38 if (pb_encode(&stream, AllTypes_fields, &alltypes))
41 fwrite(buffer, 1, stream.bytes_written, stdout);
46 fprintf(stderr, "Encoding failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/grpc-grpc/third_party/nanopb/tests/fuzztest/ |
| generate_message.c | 70 pb_ostream_t stream = {0}; local
73 if (stream.errmsg)
74 fprintf(stderr, "Encoder error: %s\n", stream.errmsg);
76 stream = pb_ostream_from_buffer(buf, sizeof(buf));
79 } while (!pb_encode(&stream, alltypes_static_AllTypes_fields, &msg));
81 fwrite(buf, 1, stream.bytes_written, stdout);
|
| /external/grpc-grpc/third_party/nanopb/tests/oneof/ |
| decode_oneof.c | 12 int test_oneof_1(pb_istream_t *stream, int option)
20 if (!pb_decode(stream, OneOfMessage_fields, &msg))
22 printf("Decoding failed: %s\n", PB_GET_ERROR(stream));
56 int test_oneof_2(pb_istream_t *stream, int option)
61 if (!pb_decode(stream, PlainOneOfMessage_fields, &msg))
63 printf("Decoding failed: %s\n", PB_GET_ERROR(stream));
115 pb_istream_t stream; local
117 stream = pb_istream_from_buffer(buffer, count);
118 status = test_oneof_1(&stream, option);
123 stream = pb_istream_from_buffer(buffer, count)
[all...] |
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| CancelClientStreamCommand.java | 24 * Command sent from a Netty client stream to the handler to cancel the stream.
27 private final NettyClientStream.TransportState stream; field in class:CancelClientStreamCommand
30 CancelClientStreamCommand(NettyClientStream.TransportState stream, Status reason) {
31 this.stream = Preconditions.checkNotNull(stream, "stream");
37 NettyClientStream.TransportState stream() { method in class:CancelClientStreamCommand
38 return stream;
|
| CancelServerStreamCommand.java | 25 * Command sent from a Netty server stream to the handler to cancel the stream.
28 private final NettyServerStream.TransportState stream; field in class:CancelServerStreamCommand
31 CancelServerStreamCommand(NettyServerStream.TransportState stream, Status reason) {
32 this.stream = Preconditions.checkNotNull(stream, "stream");
36 NettyServerStream.TransportState stream() { method in class:CancelServerStreamCommand
37 return stream;
55 return Objects.equal(this.stream, that.stream
[all...] |
| CreateStreamCommand.java | 23 * A command to create a new stream. This is created by {@link NettyClientStream} and passed to the
28 private final NettyClientStream.TransportState stream; field in class:CreateStreamCommand
32 NettyClientStream.TransportState stream) {
33 this(headers, stream, false);
37 NettyClientStream.TransportState stream, boolean get) {
38 this.stream = Preconditions.checkNotNull(stream, "stream");
43 NettyClientStream.TransportState stream() { method in class:CreateStreamCommand
44 return stream;
[all...] |
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| TestMethodDescriptors.java | 63 public InputStream stream(Void value) { method in class:TestMethodDescriptors.NoopMarshaller
68 public Void parse(InputStream stream) {
|
| /external/javaparser/javaparser-symbol-solver-testing/src/test/test_sourcecode/javaparser_new_src/javaparser-core/com/github/javaparser/ast/ |
| Example.java | 26 InputStream stream = new ByteArrayInputStream(code.getBytes("UTF-8")); local
27 CompilationUnit cu = JavaParser.parse(stream);
|
| /external/junit/src/main/java/org/junit/experimental/results/ |
| PrintableResult.java | 59 ByteArrayOutputStream stream = new ByteArrayOutputStream(); local
60 new TextListener(new PrintStream(stream)).testRunFinished(result);
61 return stream.toString();
|
| /external/libbrillo/brillo/streams/ |
| stream_errors.cc | 9 namespace stream { namespace in namespace:brillo::errors
11 const char kDomain[] = "stream.io";
19 } // namespace stream
|
| /external/libchrome/base/strings/ |
| string16_unittest.cc | 18 // Basic stream test.
20 std::ostringstream stream; local
21 stream << "Empty '" << string16() << "' standard '"
24 stream.str().c_str());
46 std::ostringstream stream; local
47 stream << initial_surrogate << "," << final_surrogate << ","
51 stream.str().c_str());
|
| /external/libtextclassifier/utils/strings/ |
| numbers.cc | 65 std::stringstream stream; local
66 stream << input;
67 return stream.str();
|
| /external/ltp/lib/ |
| safe_stdio.c | 76 FILE *stream; local
80 stream = popen(command, type);
82 if (stream == NULL) {
96 return stream;
|
| /external/nanopb-c/examples/using_union_messages/ |
| encode.c | 17 bool encode_unionmessage(pb_ostream_t *stream, const pb_field_t messagetype[], const void *message)
25 if (!pb_encode_tag_for_field(stream, field))
28 return pb_encode_submessage(stream, messagetype, message);
45 pb_ostream_t stream = pb_ostream_from_buffer(buffer, sizeof(buffer)); local
53 status = encode_unionmessage(&stream, MsgType1_fields, &msg);
59 status = encode_unionmessage(&stream, MsgType2_fields, &msg);
65 status = encode_unionmessage(&stream, MsgType3_fields, &msg);
80 fwrite(buffer, 1, stream.bytes_written, stdout);
|
| /external/nanopb-c/tests/alltypes/ |
| decode_alltypes.c | 20 bool check_alltypes(pb_istream_t *stream, int mode)
29 if (!pb_decode(stream, AllTypes_fields, &alltypes))
287 pb_istream_t stream; local
297 stream = pb_istream_from_buffer(buffer, count);
300 if (!check_alltypes(&stream, mode))
302 printf("Parsing failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/nanopb-c/tests/alltypes_pointer/ |
| decode_alltypes_pointer.c | 15 bool check_alltypes(pb_istream_t *stream, int mode)
24 if (!pb_decode(stream, AllTypes_fields, &alltypes))
164 pb_istream_t stream; local
174 stream = pb_istream_from_buffer(buffer, count);
177 if (!check_alltypes(&stream, mode))
179 fprintf(stderr, "Test failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/nanopb-c/tests/alltypes_proto3/ |
| decode_alltypes.c | 20 bool check_alltypes(pb_istream_t *stream, int mode)
27 if (!pb_decode(stream, AllTypes_fields, &alltypes))
147 pb_istream_t stream; local
157 stream = pb_istream_from_buffer(buffer, count);
160 if (!check_alltypes(&stream, mode))
162 printf("Parsing failed: %s\n", PB_GET_ERROR(&stream));
|
| /external/nanopb-c/tests/anonymous_oneof/ |
| decode_oneof.c | 12 int test_oneof_1(pb_istream_t *stream, int option)
20 if (!pb_decode(stream, AnonymousOneOfMessage_fields, &msg))
22 printf("Decoding failed: %s\n", PB_GET_ERROR(stream));
78 pb_istream_t stream; local
80 stream = pb_istream_from_buffer(buffer, count);
81 status = test_oneof_1(&stream, option);
|
| /external/nanopb-c/tests/backwards_compatibility/ |
| decode_legacy.c | 23 bool check_alltypes(pb_istream_t *stream, int mode)
27 if (!pb_decode(stream, AllTypes_fields, &alltypes))
179 pb_istream_t stream; local
189 stream = pb_istream_from_buffer(buffer, count);
192 if (!check_alltypes(&stream, mode))
194 printf("Parsing failed: %s\n", PB_GET_ERROR(&stream));
|
