| /third_party/protobuf/src/google/protobuf/ |
| H A D | struct.pb.cc | 296 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { in _InternalSerialize()
316 if (stream->IsSerializationDeterministic() && in _InternalSerialize()
329 target = Struct_FieldsEntry_DoNotUse::Funcs::InternalSerialize(1, items[static_cast<ptrdiff_t>(i)]->first, items[static_cast<ptrdiff_t>(i)]->second, target, stream); in _InternalSerialize()
336 target = Struct_FieldsEntry_DoNotUse::Funcs::InternalSerialize(1, it->first, it->second, target, stream); in _InternalSerialize()
344 _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); in _InternalSerialize()
687 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { in _InternalSerialize()
694 target = stream->EnsureSpace(target); in _InternalSerialize()
701 target = stream->EnsureSpace(target); in _InternalSerialize()
711 target = stream->WriteStringMaybeAliased( in _InternalSerialize()
717 target = stream in _InternalSerialize()
[all...] |
| /third_party/node/deps/uv/src/win/ |
| H A D | tcp.c | 28 #include "stream-inl.h"
208 void uv__process_tcp_shutdown_req(uv_loop_t* loop, uv_tcp_t* stream, uv_shutdown_t *req) { in uv__process_tcp_shutdown_req() argument
212 assert(stream->stream.conn.write_reqs_pending == 0); in uv__process_tcp_shutdown_req()
213 assert(!(stream->flags & UV_HANDLE_SHUT)); in uv__process_tcp_shutdown_req()
214 assert(stream->flags & UV_HANDLE_CONNECTION); in uv__process_tcp_shutdown_req()
216 stream->stream.conn.shutdown_req = NULL; in uv__process_tcp_shutdown_req()
217 stream->flags &= ~UV_HANDLE_SHUTTING; in uv__process_tcp_shutdown_req()
218 UNREGISTER_HANDLE_REQ(loop, stream, re in uv__process_tcp_shutdown_req()
[all...] |
| /third_party/glslang/gtests/ |
| H A D | Config.FromFile.cpp | 85 std::ostringstream stream; in TEST_P() local
86 outputResultToStream(&stream, result, testCase.controls); in TEST_P()
94 checkEqAndUpdateIfRequested(expectedOutput, stream.str(), expectedOutputFname); in TEST_P()
|
| H A D | Link.FromFile.cpp | 76 std::ostringstream stream; in TEST_P() local
77 outputResultToStream(&stream, result, controls); in TEST_P()
85 checkEqAndUpdateIfRequested(expectedOutput, stream.str(), expectedOutputFname); in TEST_P()
|
| /third_party/ffmpeg/tools/ |
| H A D | seek_print.c | 39 " seek:stream:min_ts:ts:max_ts:flags\n" in usage()
46 int opt, ret, stream, flags; in main() local
85 printf("read: %d size=%d stream=%d dts=%s (%s) pts=%s (%s)\n", in main()
92 &stream, &min_ts, &ts, &max_ts, &flags) == 5) { in main()
93 ret = avformat_seek_file(avf, stream, min_ts, ts, max_ts, flags); in main()
|
| /third_party/libuv/test/ |
| H A D | runner.h | 121 * Print tests in sorted order to `stream`. Used by `./run-tests --list`.
123 void print_tests(FILE* stream);
125 /* Print lines in |buffer| as TAP diagnostics to |stream|. */
126 void print_lines(const char* buffer, size_t size, FILE* stream);
149 /* Copy the contents of the stdio output buffer to `stream`. */
150 int process_copy_output(process_info_t* p, FILE* stream);
|
| H A D | test-ipc-send-recv.c | 37 uv_stream_t stream; member
131 r = uv_accept(handle, &recv->stream); in recv_cb()
153 &ctx.send.stream, in connect_cb()
164 &ctx.send2.stream, in connect_cb()
342 r = uv_accept(handle, &recv->stream); in read_cb()
350 &recv->stream, in read_cb()
|
| H A D | test-tcp-close-reset.c | 105 static void read_cb2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb2() argument
106 ASSERT_PTR_EQ((uv_tcp_t*)stream, &tcp_client); in read_cb2()
108 uv_close((uv_handle_t*) stream, NULL); in read_cb2()
148 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
149 ASSERT_PTR_EQ((uv_tcp_t*)stream, &tcp_accepted); in read_cb()
151 uv_close((uv_handle_t*) stream, NULL); in read_cb()
|
| /third_party/mesa3d/src/amd/llvm/ |
| H A D | ac_shader_abi.h | 57 void (*emit_vertex)(struct ac_shader_abi *abi, unsigned stream, LLVMValueRef *addrs);
59 void (*emit_primitive)(struct ac_shader_abi *abi, unsigned stream);
61 void (*emit_vertex_with_counter)(struct ac_shader_abi *abi, unsigned stream,
|
| /third_party/node/test/parallel/ |
| H A D | test-repl-use-global.js | 6 const stream = require('stream');
66 const inputStream = new stream.PassThrough();
67 const outputStream = new stream.PassThrough();
|
| /third_party/node/deps/ngtcp2/nghttp3/lib/ |
| H A D | nghttp3_http.h | 88 * of stream. Pass nonzero if this is request headers. Pass nonzero
127 * This function is called when read side stream is closed. This
134 int nghttp3_http_on_remote_end_stream(nghttp3_stream *stream);
144 int nghttp3_http_on_data_chunk(nghttp3_stream *stream, size_t n);
148 * records its method in stream->http_flags.
150 void nghttp3_http_record_request_method(nghttp3_stream *stream,
|
| /third_party/libphonenumber/metadata/src/test/java/com/google/i18n/phonenumbers/metadata/regex/ |
| H A D | SubgraphOptimizerTest.java | 44 PREGRAPH.asRangeSpecifications().stream()
45 .flatMap(a -> POSTGRAPH.asRangeSpecifications().stream().map(a::extendBy)));
78 return RangeTree.from(Arrays.stream(specs).map(RangeSpecification::parse)); in ranges()
|
| /third_party/python/Lib/importlib/resources/ |
| H A D | simple.py | 70 stream = self.parent.reader.open_binary(self.name)
72 stream = io.TextIOWrapper(*args, **kwargs)
73 return stream
|
| /third_party/skia/third_party/externals/angle2/src/libANGLE/ |
| H A D | InfoLog.h | 58 StreamHelper(std::stringstream *stream) : mStream(stream) { ASSERT(stream); } in StreamHelper() argument
|
| /third_party/skia/third_party/externals/oboe/src/aaudio/ |
| H A D | AudioStreamAAudio.h | 90 DataCallbackResult callOnAudioReady(AAudioStream *stream,
98 AAudioStream *stream,
112 // Must call under mLock. And stream must NOT be nullptr.
113 Result requestStop_l(AAudioStream *stream);
121 // pointer to the underlying AAudio stream, valid if open, null if closed
|
| /third_party/skia/include/docs/ |
| H A D | SkPDFDocument.h | 179 @param stream A PDF document will be written to this stream. The document may write
180 to the stream at anytime during its lifetime, until either close() is
186 SK_API sk_sp<SkDocument> MakeDocument(SkWStream* stream, const Metadata& metadata);
188 static inline sk_sp<SkDocument> MakeDocument(SkWStream* stream) { in MakeDocument() argument
189 return MakeDocument(stream, Metadata()); in MakeDocument()
|
| /third_party/skia/gm/ |
| H A D | encode.cpp | 69 auto stream = SkStream::MakeFromFile(path.c_str());
70 auto data = SkData::MakeFromStream(stream.get(), stream->getLength());
|
| /third_party/ffmpeg/libavformat/ |
| H A D | nut.c | 259 nut->stream[i].last_pts = in ff_nut_reset_ts()
261 time_base.num * (int64_t)nut->stream[i].time_base->den, in ff_nut_reset_ts()
262 time_base.den * (int64_t)nut->stream[i].time_base->num, in ff_nut_reset_ts()
266 int64_t ff_lsb2full(StreamContext *stream, int64_t lsb) in ff_lsb2full() argument
268 int64_t mask = (1ULL << stream->msb_pts_shift) - 1; in ff_lsb2full()
269 int64_t delta = stream->last_pts - mask / 2; in ff_lsb2full()
|
| H A D | rtpdec_h264.c | 145 AVStream *stream, in sdp_parse_fmtp_config_h264()
149 AVCodecParameters *par = stream->codecpar; in sdp_parse_fmtp_config_h264()
392 AVStream *stream; in parse_h264_sdp_line() local
398 stream = s->streams[st_index]; in parse_h264_sdp_line()
401 ff_h264_parse_framesize(stream->codecpar, p); in parse_h264_sdp_line()
403 return ff_parse_fmtp(s, stream, h264_data, p, sdp_parse_fmtp_config_h264); in parse_h264_sdp_line()
144 sdp_parse_fmtp_config_h264(AVFormatContext *s, AVStream *stream, PayloadContext *h264_data, const char *attr, const char *value) sdp_parse_fmtp_config_h264() argument
|
| H A D | segafilm.c | 42 int stream; member
227 film->sample_table[i].stream = film->audio_stream_index; in film_read_header()
237 film->sample_table[i].stream = film->video_stream_index; in film_read_header()
276 /* Find the next sample from the same stream, assuming there is one; in film_read_packet()
284 if (next_sample->stream != sample->stream) { in film_read_packet()
290 /* position the stream (will probably be there anyway) */ in film_read_packet()
297 pkt->stream_index = sample->stream; in film_read_packet()
|
| /third_party/gn/src/gn/ |
| H A D | rust_project_writer_helpers_unittest.cc | 43 std::ostringstream stream; in TEST_F() local
44 WriteCrates(setup.build_settings(), crates, sysroot, stream); in TEST_F()
45 std::string out = stream.str(); in TEST_F()
104 std::ostringstream stream; in TEST_F() local
105 WriteCrates(setup.build_settings(), crates, sysroot, stream); in TEST_F()
106 std::string out = stream.str(); in TEST_F()
|
| /third_party/lzma/CPP/7zip/Common/ |
| H A D | StreamObjects.cpp | 79 void Create_BufInStream_WithReference(const void *data, size_t size, IUnknown *ref, ISequentialInStream **stream)
in Create_BufInStream_WithReference() argument
81 *stream = NULL;
in Create_BufInStream_WithReference()
85 *stream = streamTemp.Detach();
in Create_BufInStream_WithReference()
88 void Create_BufInStream_WithNewBuffer(const void *data, size_t size, ISequentialInStream **stream)
in Create_BufInStream_WithNewBuffer() argument
90 *stream = NULL;
in Create_BufInStream_WithNewBuffer()
95 *stream = streamTemp.Detach();
in Create_BufInStream_WithNewBuffer()
|
| /third_party/mesa3d/src/gallium/drivers/svga/ |
| H A D | svga_pipe_draw.c | 206 * returned from the stream output statistics query for the specified stream.
211 unsigned stream) in get_vcount_from_stream_output()
214 primcount = svga_get_primcount_from_stream_output(svga, stream); in get_vcount_from_stream_output()
337 unsigned stream = 0; in svga_draw_vbo() local
340 /* If the vertex count is from the stream output of a non-zero stream in svga_draw_vbo()
342 * since the draw_auto command does not support stream instancing. in svga_draw_vbo()
344 * stream output statistics query for the specified stream an in svga_draw_vbo()
209 get_vcount_from_stream_output(struct svga_context *svga, const struct pipe_draw_info *info, unsigned stream) get_vcount_from_stream_output() argument
[all...] |
| /third_party/node/deps/npm/node_modules/cacache/lib/ |
| H A D | entry-index.js | 180 const stream = new Minipass({ objectMode: true })
182 // Set all this up to run on the stream and then just return the stream
207 stream.write(formatted)
219 stream.end()
220 return stream
221 }).catch(err => stream.emit('error', err))
223 return stream
|
| /third_party/node/deps/npm/node_modules/pacote/lib/ |
| H A D | git.js | 204 const stream = new Minipass()
205 stream.resolved = this.resolved
206 stream.from = this.from
223 dirStream.pipe(stream)
226 er => stream.emit('error', er)
228 return stream
236 // with cacache.put.stream(), using a key that's deterministic based on the
|