Home
last modified time | relevance | path

Searched refs:stream (Results 126 - 150 of 2425) sorted by relevance

12345678910>>...97

/third_party/ltp/testcases/kernel/fs/doio/
H A Diogen.c116 void startup_info(FILE * stream, int seed);
125 int help(FILE * stream);
126 int usage(FILE * stream);
447 void startup_info(FILE * stream, int seed) in startup_info() argument
452 fprintf(stream, "\n"); in startup_info()
453 fprintf(stream, "iogen%s starting up with the following:\n", TagName); in startup_info()
454 fprintf(stream, "\n"); in startup_info()
456 fprintf(stream, "Out-pipe: %s\n", in startup_info()
460 fprintf(stream, "Iterations: %d", Iterations); in startup_info()
462 fprintf(stream, " second in startup_info()
1935 help(FILE * stream) help() argument
2093 usage(FILE * stream) usage() argument
[all...]
/third_party/curl/lib/vquic/
H A Dcurl_quiche.c66 /* The pool keeps spares around and half of a full stream windows
68 * The benefit of the pool is that stream buffer to not keep
138 * All about the H3 internals of a stream
141 int64_t id; /* HTTP/3 protocol stream identifier */
144 uint64_t error3; /* HTTP/3 stream error code */
146 bool closed; /* TRUE on stream close */
147 bool reset; /* TRUE on stream reset */
148 bool send_closed; /* stream is locally closed */
150 bool resp_got_header; /* TRUE when h3 stream has recvd some HEADER */
151 BIT(quic_flow_blocked); /* stream i
165 struct stream_ctx *stream; check_resumes() local
184 struct stream_ctx *stream = H3_STREAM_CTX(data); h3_data_setup() local
204 struct stream_ctx *stream = H3_STREAM_CTX(data); h3_data_done() local
229 struct stream_ctx *stream = H3_STREAM_CTX(data); drain_stream() local
272 struct stream_ctx *stream = H3_STREAM_CTX(data); write_resp_raw() local
302 struct stream_ctx *stream = H3_STREAM_CTX(x->data); cb_each_header() local
342 struct stream_ctx *stream = H3_STREAM_CTX(x->data); stream_resp_read() local
365 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_recv_body() local
426 struct stream_ctx *stream = H3_STREAM_CTX(data); h3_process_event() local
490 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_poll_events() local
728 struct stream_ctx *stream = H3_STREAM_CTX(data); recv_closed_stream() local
760 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_quiche_recv() local
841 struct stream_ctx *stream = H3_STREAM_CTX(data); h3_open_stream() local
959 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_quiche_send() local
1068 struct stream_ctx *stream = H3_STREAM_CTX(data); stream_is_writeable() local
1086 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_quiche_adjust_pollset() local
1108 const struct stream_ctx *stream = H3_STREAM_CTX(data); cf_quiche_data_pending() local
1147 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_quiche_data_event() local
1162 struct stream_ctx *stream = H3_STREAM_CTX(data); cf_quiche_data_event() local
[all...]
/third_party/ffmpeg/libavfilter/cuda/
H A Dload_helper.c40 z_stream stream = { 0 }; in ff_cuda_load_module() local
45 if (inflateInit2(&stream, 32 + 15) != Z_OK) { in ff_cuda_load_module()
46 av_log(avctx, AV_LOG_ERROR, "Error during zlib initialisation: %s\n", stream.msg); in ff_cuda_load_module()
53 inflateEnd(&stream); in ff_cuda_load_module()
57 stream.next_in = data; in ff_cuda_load_module()
58 stream.avail_in = length; in ff_cuda_load_module()
61 stream.avail_out = buf_size - stream.total_out; in ff_cuda_load_module()
62 stream.next_out = buf + stream in ff_cuda_load_module()
[all...]
/third_party/libdrm/etnaviv/
H A Detnaviv_drmif.h131 /* cmd stream functions:
141 void (*reset_notify)(struct etna_cmd_stream *stream, void *priv),
143 void etna_cmd_stream_del(struct etna_cmd_stream *stream);
144 uint32_t etna_cmd_stream_timestamp(struct etna_cmd_stream *stream);
145 void etna_cmd_stream_flush(struct etna_cmd_stream *stream);
146 void etna_cmd_stream_flush2(struct etna_cmd_stream *stream, int in_fence_fd,
148 void etna_cmd_stream_finish(struct etna_cmd_stream *stream);
150 static inline uint32_t etna_cmd_stream_avail(struct etna_cmd_stream *stream) in etna_cmd_stream_avail() argument
154 return stream->size - stream in etna_cmd_stream_avail()
157 etna_cmd_stream_reserve(struct etna_cmd_stream *stream, size_t n) etna_cmd_stream_reserve() argument
163 etna_cmd_stream_emit(struct etna_cmd_stream *stream, uint32_t data) etna_cmd_stream_emit() argument
168 etna_cmd_stream_get(struct etna_cmd_stream *stream, uint32_t offset) etna_cmd_stream_get() argument
173 etna_cmd_stream_set(struct etna_cmd_stream *stream, uint32_t offset, uint32_t data) etna_cmd_stream_set() argument
179 etna_cmd_stream_offset(struct etna_cmd_stream *stream) etna_cmd_stream_offset() argument
[all...]
/third_party/mbedtls/library/
H A Dpsa_its_file.c111 FILE *stream = NULL; in psa_its_get_info() local
112 status = psa_its_read_file(uid, p_info, &stream); in psa_its_get_info()
113 if (stream != NULL) { in psa_its_get_info()
114 fclose(stream); in psa_its_get_info()
126 FILE *stream = NULL; in psa_its_get() local
130 status = psa_its_read_file(uid, &info, &stream); in psa_its_get()
150 if (fseek(stream, LONG_MAX, SEEK_CUR) != 0) { in psa_its_get()
156 if (fseek(stream, data_offset, SEEK_CUR) != 0) { in psa_its_get()
159 n = fread(p_data, 1, data_length, stream); in psa_its_get()
169 if (stream ! in psa_its_get()
186 FILE *stream = NULL; psa_its_set() local
241 FILE *stream; psa_its_remove() local
[all...]
/third_party/libwebsockets/win32port/zlib/
H A Dcompress.c29 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
[all...]
/third_party/vk-gl-cts/framework/delibs/destream/
H A DdeOutStream.h23 * \brief Output stream abstraction.
32 /* Output stream struct, implemented as a wrapper to io stream */
38 DE_INLINE deStreamResult deOutStream_write (deOutStream* stream, const void* buf, deInt32 bufSize, deInt32* numWritten);
39 DE_INLINE deStreamResult deOutStream_flush (deOutStream* stream);
40 DE_INLINE deStreamResult deOutStream_deinit (deOutStream* stream);
41 DE_INLINE const char* deOutStream_getError (deOutStream* stream);
42 DE_INLINE deStreamStatus deOutStream_getStatus (deOutStream* stream);
45 DE_INLINE deStreamResult deOutStream_write (deOutStream* stream, const void* buf, deInt32 bufSize, deInt32* numWritten) in deOutStream_write() argument
47 return deIOStream_write(&(stream in deOutStream_write()
50 deOutStream_flush(deOutStream* stream) deOutStream_flush() argument
55 deOutStream_deinit(deOutStream* stream) deOutStream_deinit() argument
60 deOutStream_getError(deOutStream* stream) deOutStream_getError() argument
65 deOutStream_getStatus(deOutStream* stream) deOutStream_getStatus() argument
[all...]
H A DdeThreadStream.c83 static deStreamResult threadInStream_read (deStreamData* stream, void* buf, deInt32 bufSize, deInt32* numRead) in threadInStream_read() argument
85 deThreadInStream* threadStream = (deThreadInStream*)stream; in threadInStream_read()
89 static const char* threadInStream_getError (deStreamData* stream) in threadInStream_getError() argument
91 deThreadInStream* threadStream = (deThreadInStream*)stream; in threadInStream_getError()
93 /* \todo [mika] Add handling for errors on thread stream */ in threadInStream_getError()
97 static deStreamStatus threadInStream_getStatus (deStreamData* stream) in threadInStream_getStatus() argument
99 deThreadInStream* threadStream = (deThreadInStream*)stream; in threadInStream_getStatus()
101 /* \todo [mika] Add handling for status on thread stream */ in threadInStream_getStatus()
105 /* \note [mika] Used by both in and out stream */
106 static deStreamResult threadStream_deinit (deStreamData* stream) in threadStream_deinit() argument
132 deThreadInStream_init(deInStream* stream, deInStream* input, int ringbufferBlockSize, int ringbufferBlockCount) deThreadInStream_init() argument
152 threadOutStream_write(deStreamData* stream, const void* buf, deInt32 bufSize, deInt32* numWritten) threadOutStream_write() argument
158 threadOutStream_getError(deStreamData* stream) threadOutStream_getError() argument
166 threadOutStream_getStatus(deStreamData* stream) threadOutStream_getStatus() argument
174 threadOutStream_flush(deStreamData* stream) threadOutStream_flush() argument
190 deThreadOutStream_init(deOutStream* stream, deOutStream* output, int ringbufferBlockSize, int ringbufferBlockCount) deThreadOutStream_init() argument
[all...]
H A DdeRingbuffer.c113 static deStreamResult producerStream_write (deStreamData* stream, const void* buf, deInt32 bufSize, deInt32* written) in producerStream_write() argument
115 deRingbuffer* ringbuffer = (deRingbuffer*)stream; in producerStream_write()
117 DE_ASSERT(stream); in producerStream_write()
165 static deStreamResult producerStream_flush (deStreamData* stream) in producerStream_flush() argument
167 deRingbuffer* ringbuffer = (deRingbuffer*)stream; in producerStream_flush()
169 DE_ASSERT(stream); in producerStream_flush()
185 static deStreamResult producerStream_deinit (deStreamData* stream) in producerStream_deinit() argument
187 DE_ASSERT(stream); in producerStream_deinit()
189 producerStream_flush(stream); in producerStream_deinit()
195 static deStreamResult consumerStream_read (deStreamData* stream, voi argument
264 consumerStream_deinit(deStreamData* stream) consumerStream_deinit() argument
273 empty_getStatus(deStreamData* stream) empty_getStatus() argument
281 empty_getError(deStreamData* stream) empty_getError() argument
306 deProducerStream_init(deOutStream* stream, deRingbuffer* buffer) deProducerStream_init() argument
312 deConsumerStream_init(deInStream* stream, deRingbuffer* buffer) deConsumerStream_init() argument
[all...]
/third_party/skia/third_party/externals/freetype/src/lzw/
H A Dftlzw.c67 FT_Stream source; /* parent/source stream */
68 FT_Stream stream; /* embedding stream */ member
82 ft_lzw_check_header( FT_Stream stream ) in ft_lzw_check_header()
104 FT_Stream stream, in ft_lzw_file_init()
111 zip->stream = stream; in ft_lzw_file_init()
113 zip->memory = stream->memory; in ft_lzw_file_init()
140 zip->stream = NULL; in ft_lzw_file_done()
147 FT_Stream stream in ft_lzw_file_reset() local
103 ft_lzw_file_init( FT_LZWFile zip, FT_Stream stream, FT_Stream source ) ft_lzw_file_init() argument
329 ft_lzw_stream_io( FT_Stream stream, unsigned long offset, unsigned char* buffer, unsigned long count ) ft_lzw_stream_io() argument
[all...]
/third_party/node/test/parallel/
H A Dtest-stream-map.js6 } = require('stream');
32 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => x + x);
34 assert.deepStrictEqual(await stream.toArray(), [2, 4, 6, 8, 10]);
40 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
45 assert.deepStrictEqual(await stream.toArray(), [2, 4, 6, 8, 10]);
51 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
55 assert.deepStrictEqual(await stream.toArray(), [4, 8, 12, 16, 20]);
60 // Map works on an infinite stream
61 const stream = Readable.from(async function* () {
68 for await (const item of stream) {
[all...]
/third_party/gn/examples/ios/host/
H A Dmain.cc17 // Writes |string| to |stream| while escaping all C escape sequences.
18 void EscapeString(std::ostream* stream, const std::string& string) { in EscapeString() argument
22 *stream << "\\0"; in EscapeString()
25 *stream << "\\a"; in EscapeString()
28 *stream << "\\b"; in EscapeString()
31 *stream << "\\e"; in EscapeString()
34 *stream << "\\f"; in EscapeString()
37 *stream << "\\n"; in EscapeString()
40 *stream << "\\r"; in EscapeString()
43 *stream << "\\ in EscapeString()
[all...]
/third_party/skia/third_party/externals/zlib/contrib/tests/fuzzers/
H A Dinflate_fuzzer.cc22 z_stream stream; in LLVMFuzzerTestOneInput() local
23 stream.next_in = input_buffer.data(); in LLVMFuzzerTestOneInput()
24 stream.avail_in = size; in LLVMFuzzerTestOneInput()
25 stream.total_in = size; in LLVMFuzzerTestOneInput()
26 stream.next_out = buffer; in LLVMFuzzerTestOneInput()
27 stream.avail_out = buffer_length; in LLVMFuzzerTestOneInput()
28 stream.total_out = buffer_length; in LLVMFuzzerTestOneInput()
29 stream.zalloc = Z_NULL; in LLVMFuzzerTestOneInput()
30 stream.zfree = Z_NULL; in LLVMFuzzerTestOneInput()
32 if (Z_OK != inflateInit(&stream)) { in LLVMFuzzerTestOneInput()
[all...]
H A Ddeflate_set_dictionary_fuzzer.cc21 z_stream stream; in LLVMFuzzerTestOneInput() local
22 stream.next_in = input_buffer.data(); in LLVMFuzzerTestOneInput()
23 stream.avail_in = size; in LLVMFuzzerTestOneInput()
24 stream.total_in = size; in LLVMFuzzerTestOneInput()
25 stream.next_out = buffer; in LLVMFuzzerTestOneInput()
26 stream.avail_out = buffer_length; in LLVMFuzzerTestOneInput()
27 stream.total_out = buffer_length; in LLVMFuzzerTestOneInput()
28 stream.zalloc = Z_NULL; in LLVMFuzzerTestOneInput()
29 stream.zfree = Z_NULL; in LLVMFuzzerTestOneInput()
31 if (Z_OK != deflateInit(&stream, Z_DEFAULT_COMPRESSIO in LLVMFuzzerTestOneInput()
[all...]
/third_party/curl/src/
H A Dtool_writeout.c35 static int writeTime(FILE *stream, const struct writeoutvar *wovar,
39 static int writeString(FILE *stream, const struct writeoutvar *wovar,
43 static int writeLong(FILE *stream, const struct writeoutvar *wovar,
47 static int writeOffset(FILE *stream, const struct writeoutvar *wovar,
153 static int writeTime(FILE *stream, const struct writeoutvar *wovar, in writeTime() argument
177 fprintf(stream, "\"%s\":", wovar->name); in writeTime()
179 fprintf(stream, "%" CURL_FORMAT_CURL_OFF_TU in writeTime()
184 fprintf(stream, "\"%s\":null", wovar->name); in writeTime()
271 static int writeString(FILE *stream, const struct writeoutvar *wovar, in writeString() argument
405 fprintf(stream, "\" in writeString()
421 writeLong(FILE *stream, const struct writeoutvar *wovar, struct per_transfer *per, CURLcode per_result, bool use_json) writeLong() argument
478 writeOffset(FILE *stream, const struct writeoutvar *wovar, struct per_transfer *per, CURLcode per_result, bool use_json) writeOffset() argument
514 FILE *stream = stdout; ourWriteOut() local
[all...]
/third_party/ffmpeg/libavformat/
H A Drtpdec_rfc4175.c47 static int rfc4175_parse_format(AVStream *stream, PayloadContext *data) in rfc4175_parse_format() argument
60 stream->codecpar->codec_id = AV_CODEC_ID_RAWVIDEO; in rfc4175_parse_format()
64 stream->codecpar->codec_id = AV_CODEC_ID_BITPACKED; in rfc4175_parse_format()
75 stream->codecpar->codec_id = AV_CODEC_ID_RAWVIDEO; in rfc4175_parse_format()
85 stream->codecpar->codec_id = AV_CODEC_ID_RAWVIDEO; in rfc4175_parse_format()
95 stream->codecpar->codec_id = AV_CODEC_ID_RAWVIDEO; in rfc4175_parse_format()
104 stream->codecpar->format = pixfmt; in rfc4175_parse_format()
105 stream->codecpar->codec_tag = tag; in rfc4175_parse_format()
106 stream->codecpar->bits_per_coded_sample = av_get_bits_per_pixel(desc); in rfc4175_parse_format()
110 stream in rfc4175_parse_format()
122 rfc4175_parse_fmtp(AVFormatContext *s, AVStream *stream, PayloadContext *data, const char *attr, const char *value) rfc4175_parse_fmtp() argument
182 AVStream *stream = s->streams[st_index]; rfc4175_parse_sdp_line() local
[all...]
/third_party/node/test/fixtures/wpt/streams/readable-streams/
H A Dtemplated.any.js6 // Run the readable stream test templates against readable streams created directly using the constructor
29 const stream = new ReadableStream({
35 const result = streamAndDefaultReader(stream);
41 const stream = new ReadableStream({
46 const result = streamAndDefaultReader(stream);
52 const stream = new ReadableStream();
53 stream.cancel();
54 return stream;
58 const stream = new ReadableStream();
59 const result = streamAndDefaultReader(stream);
[all...]
/third_party/nghttp2/lib/
H A Dnghttp2_session.c95 nghttp2_stream *stream, in session_trailer_headers()
97 if (!stream || frame->hd.type != NGHTTP2_HEADERS) { in session_trailer_headers()
105 (stream->http_flags & NGHTTP2_HTTP_FLAG_EXPECT_FINAL_RESPONSE) == 0; in session_trailer_headers()
108 /* Returns nonzero if the |stream| is in reserved(remote) state */
110 nghttp2_stream *stream) { in state_reserved_remote()
111 return stream->state == NGHTTP2_STREAM_RESERVED && in state_reserved_remote()
112 !nghttp2_session_is_my_stream_id(session, stream->stream_id); in state_reserved_remote()
115 /* Returns nonzero if the |stream| is in reserved(local) state */
117 nghttp2_stream *stream) { in state_reserved_local()
118 return stream in state_reserved_local()
94 session_trailer_headers(nghttp2_session *session, nghttp2_stream *stream, nghttp2_frame *frame) session_trailer_headers() argument
109 state_reserved_remote(nghttp2_session *session, nghttp2_stream *stream) state_reserved_remote() argument
116 state_reserved_local(nghttp2_session *session, nghttp2_stream *stream) state_reserved_local() argument
288 nghttp2_stream *stream; nghttp2_session_get_stream() local
733 nghttp2_stream *stream; free_streams() local
836 nghttp2_session_reprioritize_stream( nghttp2_session *session, nghttp2_stream *stream, const nghttp2_priority_spec *pri_spec_in) nghttp2_session_reprioritize_stream() argument
914 nghttp2_stream *stream; pq_get_first_cycle() local
924 session_ob_data_push(nghttp2_session *session, nghttp2_stream *stream) session_ob_data_push() argument
956 session_ob_data_remove(nghttp2_session *session, nghttp2_stream *stream) session_ob_data_remove() argument
972 session_attach_stream_item(nghttp2_session *session, nghttp2_stream *stream, nghttp2_outbound_item *item) session_attach_stream_item() argument
989 session_detach_stream_item(nghttp2_session *session, nghttp2_stream *stream) session_detach_stream_item() argument
1001 session_defer_stream_item(nghttp2_session *session, nghttp2_stream *stream, uint8_t flags) session_defer_stream_item() argument
1013 session_resume_deferred_stream_item(nghttp2_session *session, nghttp2_stream *stream, uint8_t flags) session_resume_deferred_stream_item() argument
1035 nghttp2_stream *stream; session_sched_get_next_outbound_item() local
1062 session_sched_reschedule_stream(nghttp2_session *session, nghttp2_stream *stream) session_sched_reschedule_stream() argument
1089 session_update_stream_priority(nghttp2_session *session, nghttp2_stream *stream, uint8_t u8extpri) session_update_stream_priority() argument
1114 nghttp2_stream *stream; nghttp2_session_add_item() local
1217 nghttp2_stream *stream; nghttp2_session_add_rst_stream() local
1296 nghttp2_stream *stream; nghttp2_session_open_stream() local
1465 nghttp2_stream *stream; nghttp2_session_close_stream() local
1550 nghttp2_session_destroy_stream(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_destroy_stream() argument
1573 nghttp2_session_keep_closed_stream(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_keep_closed_stream() argument
1589 nghttp2_session_keep_idle_stream(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_keep_idle_stream() argument
1605 nghttp2_session_detach_idle_stream(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_detach_idle_stream() argument
1739 nghttp2_session_close_stream_if_shut_rdwr(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_close_stream_if_shut_rdwr() argument
1778 session_predicate_for_stream_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_for_stream_send() argument
1851 session_predicate_response_headers_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_response_headers_send() argument
1900 session_predicate_push_response_headers_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_push_response_headers_send() argument
1941 session_predicate_headers_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_headers_send() argument
1988 session_predicate_push_promise_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_push_promise_send() argument
2034 nghttp2_stream *stream; session_predicate_window_update_send() local
2059 nghttp2_stream *stream; session_predicate_altsvc_send() local
2089 nghttp2_stream *stream; session_predicate_priority_update_send() local
2112 nghttp2_session_enforce_flow_control_limits(nghttp2_session *session, nghttp2_stream *stream, ssize_t requested_window_size) nghttp2_session_enforce_flow_control_limits() argument
2132 nghttp2_session_next_data_read(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_next_data_read() argument
2163 nghttp2_session_predicate_data_send(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_predicate_data_send() argument
2316 nghttp2_stream *stream; session_prep_frame() local
2393 nghttp2_stream *stream; session_prep_frame() local
2416 nghttp2_stream *stream; session_prep_frame() local
2518 nghttp2_stream *stream; session_prep_frame() local
2747 nghttp2_stream *stream; find_stream_on_goaway_func() local
2787 nghttp2_stream *stream, *next_stream; session_close_stream_on_goaway() local
2819 session_reschedule_stream(nghttp2_session *session, nghttp2_stream *stream) session_reschedule_stream() argument
2862 nghttp2_stream *stream; session_after_frame_sent1() local
3121 nghttp2_stream *stream; session_after_frame_sent2() local
3436 nghttp2_stream *stream; nghttp2_session_mem_send_internal() local
3882 nghttp2_stream *stream; inflate_header_block() local
4027 session_end_stream_headers_received(nghttp2_session *session, nghttp2_frame *frame, nghttp2_stream *stream) session_end_stream_headers_received() argument
4062 nghttp2_stream *stream; session_after_header_block_received() local
4145 nghttp2_stream *stream; nghttp2_session_on_request_headers_received() local
4246 nghttp2_session_on_response_headers_received(nghttp2_session *session, nghttp2_frame *frame, nghttp2_stream *stream) nghttp2_session_on_response_headers_received() argument
4278 nghttp2_session_on_push_response_headers_received(nghttp2_session *session, nghttp2_frame *frame, nghttp2_stream *stream) nghttp2_session_on_push_response_headers_received() argument
4323 nghttp2_session_on_headers_received(nghttp2_session *session, nghttp2_frame *frame, nghttp2_stream *stream) nghttp2_session_on_headers_received() argument
4371 nghttp2_stream *stream; session_process_headers_frame() local
4400 nghttp2_stream *stream; nghttp2_session_on_priority_received() local
4488 nghttp2_stream *stream; nghttp2_session_on_rst_stream_received() local
4530 nghttp2_stream *stream; update_remote_initial_window_size_func() local
4583 nghttp2_stream *stream; update_local_initial_window_size_func() local
4971 nghttp2_stream *stream; nghttp2_session_on_push_promise_received() local
5161 nghttp2_stream *stream; session_on_stream_window_update_received() local
5223 nghttp2_stream *stream; nghttp2_session_on_altsvc_received() local
5266 nghttp2_stream *stream; nghttp2_session_on_priority_update_received() local
5402 nghttp2_stream *stream; nghttp2_session_on_data_received() local
5476 nghttp2_session_update_recv_stream_window_size(nghttp2_session *session, nghttp2_stream *stream, size_t delta_size, int send_window_update) nghttp2_session_update_recv_stream_window_size() argument
5572 session_update_stream_consumed_size(nghttp2_session *session, nghttp2_stream *stream, size_t delta_size) session_update_stream_consumed_size() argument
5607 nghttp2_stream *stream; session_on_data_received_fail_fast() local
5823 nghttp2_stream *stream; nghttp2_session_mem_recv() local
7650 nghttp2_session_pack_data(nghttp2_session *session, nghttp2_bufs *bufs, size_t datamax, nghttp2_frame *frame, nghttp2_data_aux_data *aux_data, nghttp2_stream *stream) nghttp2_session_pack_data() argument
7787 nghttp2_stream *stream; nghttp2_session_get_stream_user_data() local
7799 nghttp2_stream *stream; nghttp2_session_set_stream_user_data() local
7840 nghttp2_stream *stream; nghttp2_session_resume_data() local
7866 nghttp2_stream *stream; nghttp2_session_get_stream_effective_recv_data_length() local
7877 nghttp2_stream *stream; nghttp2_session_get_stream_effective_local_window_size() local
7887 nghttp2_stream *stream; nghttp2_session_get_stream_local_window_size() local
7921 nghttp2_stream *stream; nghttp2_session_get_stream_remote_window_size() local
7991 nghttp2_stream *stream; nghttp2_session_upgrade_internal() local
8062 nghttp2_stream *stream; nghttp2_session_upgrade() local
8091 nghttp2_stream *stream; nghttp2_session_upgrade2() local
8111 nghttp2_stream *stream; nghttp2_session_get_stream_local_close() local
8124 nghttp2_stream *stream; nghttp2_session_get_stream_remote_close() local
8138 nghttp2_stream *stream; nghttp2_session_consume() local
8188 nghttp2_stream *stream; nghttp2_session_consume_stream() local
8261 nghttp2_stream *stream; nghttp2_session_change_stream_priority() local
8297 nghttp2_stream *stream; nghttp2_session_create_idle_stream() local
8349 nghttp2_stream *stream; nghttp2_session_change_extpri_stream_priority() local
[all...]
/third_party/node/deps/nghttp2/lib/
H A Dnghttp2_session.c95 nghttp2_stream *stream, in session_trailer_headers()
97 if (!stream || frame->hd.type != NGHTTP2_HEADERS) { in session_trailer_headers()
105 (stream->http_flags & NGHTTP2_HTTP_FLAG_EXPECT_FINAL_RESPONSE) == 0; in session_trailer_headers()
108 /* Returns nonzero if the |stream| is in reserved(remote) state */
110 nghttp2_stream *stream) { in state_reserved_remote()
111 return stream->state == NGHTTP2_STREAM_RESERVED && in state_reserved_remote()
112 !nghttp2_session_is_my_stream_id(session, stream->stream_id); in state_reserved_remote()
115 /* Returns nonzero if the |stream| is in reserved(local) state */
117 nghttp2_stream *stream) { in state_reserved_local()
118 return stream in state_reserved_local()
94 session_trailer_headers(nghttp2_session *session, nghttp2_stream *stream, nghttp2_frame *frame) session_trailer_headers() argument
109 state_reserved_remote(nghttp2_session *session, nghttp2_stream *stream) state_reserved_remote() argument
116 state_reserved_local(nghttp2_session *session, nghttp2_stream *stream) state_reserved_local() argument
288 nghttp2_stream *stream; nghttp2_session_get_stream() local
728 nghttp2_stream *stream; free_streams() local
831 nghttp2_session_reprioritize_stream( nghttp2_session *session, nghttp2_stream *stream, const nghttp2_priority_spec *pri_spec_in) nghttp2_session_reprioritize_stream() argument
909 nghttp2_stream *stream; pq_get_first_cycle() local
919 session_ob_data_push(nghttp2_session *session, nghttp2_stream *stream) session_ob_data_push() argument
951 session_ob_data_remove(nghttp2_session *session, nghttp2_stream *stream) session_ob_data_remove() argument
967 session_attach_stream_item(nghttp2_session *session, nghttp2_stream *stream, nghttp2_outbound_item *item) session_attach_stream_item() argument
984 session_detach_stream_item(nghttp2_session *session, nghttp2_stream *stream) session_detach_stream_item() argument
996 session_defer_stream_item(nghttp2_session *session, nghttp2_stream *stream, uint8_t flags) session_defer_stream_item() argument
1008 session_resume_deferred_stream_item(nghttp2_session *session, nghttp2_stream *stream, uint8_t flags) session_resume_deferred_stream_item() argument
1030 nghttp2_stream *stream; session_sched_get_next_outbound_item() local
1057 session_sched_reschedule_stream(nghttp2_session *session, nghttp2_stream *stream) session_sched_reschedule_stream() argument
1084 session_update_stream_priority(nghttp2_session *session, nghttp2_stream *stream, uint8_t u8extpri) session_update_stream_priority() argument
1109 nghttp2_stream *stream; nghttp2_session_add_item() local
1212 nghttp2_stream *stream; nghttp2_session_add_rst_stream() local
1291 nghttp2_stream *stream; nghttp2_session_open_stream() local
1460 nghttp2_stream *stream; nghttp2_session_close_stream() local
1545 nghttp2_session_destroy_stream(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_destroy_stream() argument
1568 nghttp2_session_keep_closed_stream(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_keep_closed_stream() argument
1584 nghttp2_session_keep_idle_stream(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_keep_idle_stream() argument
1600 nghttp2_session_detach_idle_stream(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_detach_idle_stream() argument
1734 nghttp2_session_close_stream_if_shut_rdwr(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_close_stream_if_shut_rdwr() argument
1773 session_predicate_for_stream_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_for_stream_send() argument
1846 session_predicate_response_headers_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_response_headers_send() argument
1895 session_predicate_push_response_headers_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_push_response_headers_send() argument
1936 session_predicate_headers_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_headers_send() argument
1983 session_predicate_push_promise_send(nghttp2_session *session, nghttp2_stream *stream) session_predicate_push_promise_send() argument
2029 nghttp2_stream *stream; session_predicate_window_update_send() local
2054 nghttp2_stream *stream; session_predicate_altsvc_send() local
2084 nghttp2_stream *stream; session_predicate_priority_update_send() local
2107 nghttp2_session_enforce_flow_control_limits(nghttp2_session *session, nghttp2_stream *stream, ssize_t requested_window_size) nghttp2_session_enforce_flow_control_limits() argument
2127 nghttp2_session_next_data_read(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_next_data_read() argument
2158 nghttp2_session_predicate_data_send(nghttp2_session *session, nghttp2_stream *stream) nghttp2_session_predicate_data_send() argument
2311 nghttp2_stream *stream; session_prep_frame() local
2388 nghttp2_stream *stream; session_prep_frame() local
2411 nghttp2_stream *stream; session_prep_frame() local
2513 nghttp2_stream *stream; session_prep_frame() local
2742 nghttp2_stream *stream; find_stream_on_goaway_func() local
2782 nghttp2_stream *stream, *next_stream; session_close_stream_on_goaway() local
2814 session_reschedule_stream(nghttp2_session *session, nghttp2_stream *stream) session_reschedule_stream() argument
2857 nghttp2_stream *stream; session_after_frame_sent1() local
3116 nghttp2_stream *stream; session_after_frame_sent2() local
3431 nghttp2_stream *stream; nghttp2_session_mem_send_internal() local
3877 nghttp2_stream *stream; inflate_header_block() local
4022 session_end_stream_headers_received(nghttp2_session *session, nghttp2_frame *frame, nghttp2_stream *stream) session_end_stream_headers_received() argument
4057 nghttp2_stream *stream; session_after_header_block_received() local
4140 nghttp2_stream *stream; nghttp2_session_on_request_headers_received() local
4241 nghttp2_session_on_response_headers_received(nghttp2_session *session, nghttp2_frame *frame, nghttp2_stream *stream) nghttp2_session_on_response_headers_received() argument
4273 nghttp2_session_on_push_response_headers_received(nghttp2_session *session, nghttp2_frame *frame, nghttp2_stream *stream) nghttp2_session_on_push_response_headers_received() argument
4318 nghttp2_session_on_headers_received(nghttp2_session *session, nghttp2_frame *frame, nghttp2_stream *stream) nghttp2_session_on_headers_received() argument
4366 nghttp2_stream *stream; session_process_headers_frame() local
4395 nghttp2_stream *stream; nghttp2_session_on_priority_received() local
4483 nghttp2_stream *stream; nghttp2_session_on_rst_stream_received() local
4525 nghttp2_stream *stream; update_remote_initial_window_size_func() local
4578 nghttp2_stream *stream; update_local_initial_window_size_func() local
4966 nghttp2_stream *stream; nghttp2_session_on_push_promise_received() local
5156 nghttp2_stream *stream; session_on_stream_window_update_received() local
5218 nghttp2_stream *stream; nghttp2_session_on_altsvc_received() local
5261 nghttp2_stream *stream; nghttp2_session_on_priority_update_received() local
5397 nghttp2_stream *stream; nghttp2_session_on_data_received() local
5471 nghttp2_session_update_recv_stream_window_size(nghttp2_session *session, nghttp2_stream *stream, size_t delta_size, int send_window_update) nghttp2_session_update_recv_stream_window_size() argument
5567 session_update_stream_consumed_size(nghttp2_session *session, nghttp2_stream *stream, size_t delta_size) session_update_stream_consumed_size() argument
5602 nghttp2_stream *stream; session_on_data_received_fail_fast() local
5818 nghttp2_stream *stream; nghttp2_session_mem_recv() local
7639 nghttp2_session_pack_data(nghttp2_session *session, nghttp2_bufs *bufs, size_t datamax, nghttp2_frame *frame, nghttp2_data_aux_data *aux_data, nghttp2_stream *stream) nghttp2_session_pack_data() argument
7776 nghttp2_stream *stream; nghttp2_session_get_stream_user_data() local
7788 nghttp2_stream *stream; nghttp2_session_set_stream_user_data() local
7829 nghttp2_stream *stream; nghttp2_session_resume_data() local
7855 nghttp2_stream *stream; nghttp2_session_get_stream_effective_recv_data_length() local
7866 nghttp2_stream *stream; nghttp2_session_get_stream_effective_local_window_size() local
7876 nghttp2_stream *stream; nghttp2_session_get_stream_local_window_size() local
7910 nghttp2_stream *stream; nghttp2_session_get_stream_remote_window_size() local
7980 nghttp2_stream *stream; nghttp2_session_upgrade_internal() local
8051 nghttp2_stream *stream; nghttp2_session_upgrade() local
8080 nghttp2_stream *stream; nghttp2_session_upgrade2() local
8100 nghttp2_stream *stream; nghttp2_session_get_stream_local_close() local
8113 nghttp2_stream *stream; nghttp2_session_get_stream_remote_close() local
8127 nghttp2_stream *stream; nghttp2_session_consume() local
8177 nghttp2_stream *stream; nghttp2_session_consume_stream() local
8250 nghttp2_stream *stream; nghttp2_session_change_stream_priority() local
8286 nghttp2_stream *stream; nghttp2_session_create_idle_stream() local
8338 nghttp2_stream *stream; nghttp2_session_change_extpri_stream_priority() local
[all...]
/third_party/lzma/CPP/7zip/Common/
H A DStreamUtils.cpp12 HRESULT InStream_SeekToBegin(IInStream *stream) throw() in InStream_SeekToBegin() argument
14 return InStream_SeekSet(stream, 0); in InStream_SeekToBegin()
18 HRESULT InStream_AtBegin_GetSize(IInStream *stream, UInt64 &sizeRes) throw() in InStream_AtBegin_GetSize() argument
24 streamGetSize, stream) in InStream_AtBegin_GetSize()
29 const HRESULT hres = InStream_GetSize_SeekToEnd(stream, sizeRes); in InStream_AtBegin_GetSize()
30 const HRESULT hres2 = InStream_SeekToBegin(stream); in InStream_AtBegin_GetSize()
35 HRESULT InStream_GetPos_GetSize(IInStream *stream, UInt64 &curPosRes, UInt64 &sizeRes) throw() in InStream_GetPos_GetSize() argument
37 RINOK(InStream_GetPos(stream, curPosRes)) in InStream_GetPos_GetSize()
42 streamGetSize, stream) in InStream_GetPos_GetSize()
47 const HRESULT hres = InStream_GetSize_SeekToEnd(stream, sizeRe in InStream_GetPos_GetSize()
54 ReadStream(ISequentialInStream *stream, void *data, size_t *processedSize) ReadStream() argument
73 ReadStream_FALSE(ISequentialInStream *stream, void *data, size_t size) ReadStream_FALSE() argument
80 ReadStream_FAIL(ISequentialInStream *stream, void *data, size_t size) ReadStream_FAIL() argument
87 WriteStream(ISequentialOutStream *stream, const void *data, size_t size) WriteStream() argument
[all...]
/third_party/node/lib/internal/streams/
H A Dwritable.js77 function WritableState(options, stream, isDuplex) {
81 // values for the readable and the writable sides of the duplex stream,
84 isDuplex = stream instanceof Stream.Duplex;
86 // Object stream flag to indicate whether or not this stream
150 this.onwrite = onwrite.bind(undefined, stream);
187 // Indicates whether the stream has errored. When true all write() calls
189 // is disabled we need a way to tell whether the stream has failed.
192 // Indicates whether the stream has finished destroying.
286 function _write(stream, chun
[all...]
H A Dpipeline.js13 const eos = require('internal/streams/end-of-stream');
50 function destroyer(stream, reading, writing) {
52 stream.on('close', () => {
56 const cleanup = eos(stream, { readable: reading, writable: writing }, (err) => {
64 destroyImpl.destroyer(stream, err || new ERR_STREAM_DESTROYED('pipe'));
72 // a single stream. Therefore optimize for the average case instead of
74 validateFunction(streams[streams.length - 1], 'streams[stream.length - 1]');
201 // Need to cleanup event listeners if last stream is readable
253 const stream = streams[i];
259 if (isNodeStream(stream)) {
[all...]
/third_party/mesa3d/src/gallium/drivers/etnaviv/
H A Detnaviv_emit.c49 CMD_STALL(struct etna_cmd_stream *stream, uint32_t from, uint32_t to) in CMD_STALL() argument
51 etna_cmd_stream_emit(stream, VIV_FE_STALL_HEADER_OP_STALL); in CMD_STALL()
52 etna_cmd_stream_emit(stream, VIV_FE_STALL_TOKEN_FROM(from) | VIV_FE_STALL_TOKEN_TO(to)); in CMD_STALL()
56 etna_stall(struct etna_cmd_stream *stream, uint32_t from, uint32_t to) in etna_stall() argument
59 etna_cmd_stream_reserve(stream, blt ? 8 : 4); in etna_stall()
62 etna_emit_load_state(stream, VIVS_BLT_ENABLE >> 2, 1, 0); in etna_stall()
63 etna_cmd_stream_emit(stream, 1); in etna_stall()
67 etna_emit_load_state(stream, VIVS_GL_SEMAPHORE_TOKEN >> 2, 1, 0); in etna_stall()
68 etna_cmd_stream_emit(stream, VIVS_GL_SEMAPHORE_TOKEN_FROM(from) | VIVS_GL_SEMAPHORE_TOKEN_TO(to)); in etna_stall()
72 CMD_STALL(stream, fro in etna_stall()
128 struct etna_cmd_stream *stream = ctx->stream; emit_halti5_only_state() local
162 struct etna_cmd_stream *stream = ctx->stream; emit_pre_halti5_state() local
220 struct etna_cmd_stream *stream = ctx->stream; etna_emit_state() local
[all...]
/third_party/skia/third_party/externals/dng_sdk/source/
H A Ddng_misc_opcodes.cpp44 dng_opcode_TrimBounds::dng_opcode_TrimBounds (dng_stream &stream) in dng_opcode_TrimBounds() argument
47 stream, in dng_opcode_TrimBounds()
54 if (stream.Get_uint32 () != 16) in dng_opcode_TrimBounds()
59 fBounds.t = stream.Get_int32 (); in dng_opcode_TrimBounds()
60 fBounds.l = stream.Get_int32 (); in dng_opcode_TrimBounds()
61 fBounds.b = stream.Get_int32 (); in dng_opcode_TrimBounds()
62 fBounds.r = stream.Get_int32 (); in dng_opcode_TrimBounds()
88 void dng_opcode_TrimBounds::PutData (dng_stream &stream) const in PutData()
91 stream.Put_uint32 (16); in PutData()
93 stream in PutData()
118 GetData(dng_stream &stream) GetData() argument
277 dng_opcode_MapTable(dng_host &host, dng_stream &stream) dng_opcode_MapTable() argument
473 dng_opcode_MapPolynomial(dng_stream &stream) dng_opcode_MapPolynomial() argument
847 dng_opcode_DeltaPerRow(dng_host &host, dng_stream &stream) dng_opcode_DeltaPerRow() argument
1053 dng_opcode_DeltaPerColumn(dng_host &host, dng_stream &stream) dng_opcode_DeltaPerColumn() argument
1261 dng_opcode_ScalePerRow(dng_host &host, dng_stream &stream) dng_opcode_ScalePerRow() argument
1438 dng_opcode_ScalePerColumn(dng_host &host, dng_stream &stream) dng_opcode_ScalePerColumn() argument
[all...]
/third_party/skia/third_party/externals/angle2/src/tests/test_utils/
H A Dangle_test_configs.cpp113 std::ostream &operator<<(std::ostream &stream, const PlatformParameters &pp) in operator <<() argument
115 stream << "ES" << pp.majorVersion << "_"; in operator <<()
118 stream << pp.minorVersion << "_"; in operator <<()
124 stream << GetRendererName(pp.eglParameters.renderer); in operator <<()
127 stream << "WGL"; in operator <<()
130 stream << "EGL"; in operator <<()
133 stream << "Error"; in operator <<()
139 stream << "_" << pp.eglParameters.majorVersion; in operator <<()
144 stream << "_" << pp.eglParameters.minorVersion; in operator <<()
155 stream << "_Nul in operator <<()
[all...]

Completed in 18 milliseconds

12345678910>>...97