Home
last modified time | relevance | path

Searched refs:stream (Results 101 - 125 of 2595) sorted by relevance

12345678910>>...104

/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/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/curl/lib/vquic/
H A Dcurl_ngtcp2.c80 /* A stream window is the maximum amount we need to buffer for
86 /* The pool keeps spares around and half of a full stream windows
88 * The benefit of the pool is that stream buffer to not keep
132 size_t max_stream_window; /* max flow window for one stream */
143 * All about the H3 internals of a stream
153 uint64_t error3; /* HTTP/3 stream error code */
157 bool closed; /* TRUE on stream close */
158 bool reset; /* TRUE on stream reset */
159 bool send_closed; /* stream is local closed */
160 BIT(quic_flow_blocked); /* stream i
174 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); h3_data_setup() local
207 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); h3_data_done() local
253 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); h3_drain_stream() local
394 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); report_consumed_data() local
571 struct h3_stream_ctx *stream; cb_extend_max_stream_data() local
752 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cf_ngtcp2_adjust_pollset() local
776 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cb_h3_stream_close() local
809 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); write_resp_raw() local
840 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cb_h3_recv_data() local
881 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cb_h3_end_headers() local
914 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cb_h3_recv_header() local
1084 recv_closed_stream(struct Curl_cfilter *cf, struct Curl_easy *data, struct h3_stream_ctx *stream, CURLcode *err) recv_closed_stream() argument
1118 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cf_ngtcp2_recv() local
1204 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cb_h3_acked_req_body() local
1238 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cb_h3_read_req_body() local
1306 struct h3_stream_ctx *stream = NULL; h3_stream_open() local
1431 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cf_ngtcp2_send() local
1688 struct h3_stream_ctx *stream = H3_STREAM_CTX(x->data); read_pkt_to_send() local
1860 const struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cf_ngtcp2_data_pending() local
1902 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cf_ngtcp2_data_event() local
1911 struct h3_stream_ctx *stream = H3_STREAM_CTX(data); cf_ngtcp2_data_event() local
[all...]
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/skia/third_party/externals/oboe/src/aaudio/
H A DAudioStreamAAudio.cpp44 AAudioStream *stream, in oboe_aaudio_data_callback_proc()
52 oboeStream->callOnAudioReady(stream, audioData, numFrames)); in oboe_aaudio_data_callback_proc()
61 // It calls app error callbacks from a static function in case the stream gets deleted.
79 // Prevents deletion of the stream if the app is using AudioStreamBuilder::openSharedStream()
89 * Create a stream that uses Oboe Audio API.
106 // That other thread can safely stop, close and delete the stream.
108 AAudioStream *stream, in internalErrorCallback()
113 // Prevents deletion of the stream if the app is using AudioStreamBuilder::openStream(shared_ptr) in internalErrorCallback()
116 // These checks should be enough because we assume that the stream close() in internalErrorCallback()
120 } else if (stream ! in internalErrorCallback()
43 oboe_aaudio_data_callback_proc( AAudioStream *stream, void *userData, void *audioData, int32_t numFrames) oboe_aaudio_data_callback_proc() argument
107 internalErrorCallback( AAudioStream *stream, void *userData, aaudio_result_t error) internalErrorCallback() argument
237 AAudioStream *stream = nullptr; open() local
297 AAudioStream *stream = mAAudioStream.exchange(nullptr); close() local
316 callOnAudioReady(AAudioStream *stream, void *audioData, int32_t numFrames) callOnAudioReady() argument
345 AAudioStream *stream = mAAudioStream.load(); requestStart() local
366 AAudioStream *stream = mAAudioStream.load(); requestPause() local
383 AAudioStream *stream = mAAudioStream.load(); requestFlush() local
400 AAudioStream *stream = mAAudioStream.load(); requestStop() local
409 requestStop_l(AAudioStream *stream) requestStop_l() argument
423 AAudioStream *stream = mAAudioStream.load(); write() local
436 AAudioStream *stream = mAAudioStream.load(); read() local
464 AAudioStream *stream = mAAudioStream.load(); waitForStateChange() local
520 AAudioStream *stream = mAAudioStream.load(); setBufferSizeInFrames() local
542 AAudioStream *stream = mAAudioStream.load(); getState() local
558 AAudioStream *stream = mAAudioStream.load(); getBufferSizeInFrames() local
566 AAudioStream *stream = mAAudioStream.load(); getFramesPerBurst() local
574 AAudioStream *stream = mAAudioStream.load(); updateFramesRead() local
581 AAudioStream *stream = mAAudioStream.load(); updateFramesWritten() local
588 AAudioStream *stream = mAAudioStream.load(); getXRunCount() local
599 AAudioStream *stream = mAAudioStream.load(); getTimestamp() local
612 AAudioStream *stream = mAAudioStream.load(); calculateLatencyMillis() local
654 AAudioStream *stream = mAAudioStream.load(); isMMapUsed() local
[all...]
/third_party/skia/third_party/externals/dng_sdk/source/
H A Ddng_shared.cpp100 bool dng_camera_profile_info::ParseTag (dng_stream &stream, in ParseTag() argument
118 fCalibrationIlluminant1 = stream.TagValue_uint32 (tagType); in ParseTag()
143 fCalibrationIlluminant2 = stream.TagValue_uint32 (tagType); in ParseTag()
176 if (!ParseMatrixTag (stream, in ParseTag()
229 if (!ParseMatrixTag (stream, in ParseTag()
273 if (!ParseMatrixTag (stream, in ParseTag()
308 if (!ParseMatrixTag (stream, in ParseTag()
343 if (!ParseMatrixTag (stream, in ParseTag()
378 if (!ParseMatrixTag (stream, in ParseTag()
410 ParseStringTag (stream, in ParseTag()
1032 ParseExtended(dng_stream &stream) ParseExtended() argument
1247 ParseTag(dng_stream &stream, dng_exif &exif, uint32 parentCode, bool , uint32 tagCode, uint32 tagType, uint32 tagCount, uint64 tagOffset, int64 ) ParseTag() argument
1303 Parse_ifd0(dng_stream &stream, dng_exif & , uint32 parentCode, uint32 tagCode, uint32 tagType, uint32 tagCount, uint64 tagOffset) Parse_ifd0() argument
2743 Parse_ifd0_exif(dng_stream &stream, dng_exif & , uint32 parentCode, uint32 tagCode, uint32 tagType, uint32 tagCount, uint64 tagOffset) Parse_ifd0_exif() argument
[all...]
H A Ddng_opcode_list.cpp167 dng_memory_stream stream (host.Allocator ()); in Spool()
169 stream.SetBigEndian (); in Spool()
171 stream.Put_uint32 ((uint32) fList.size ()); in Spool()
176 stream.Put_uint32 (fList [index]->OpcodeID ()); in Spool()
177 stream.Put_uint32 (fList [index]->MinVersion ()); in Spool()
178 stream.Put_uint32 (fList [index]->Flags ()); in Spool()
180 fList [index]->PutData (stream); in Spool()
184 return stream.AsMemoryBlock (host.Allocator ()); in Spool()
190 void dng_opcode_list::FingerprintToStream (dng_stream &stream) const in FingerprintToStream()
198 stream in FingerprintToStream()
220 Parse(dng_host &host, dng_stream &stream, uint32 byteCount, uint64 streamOffset) Parse() argument
[all...]
/third_party/mesa3d/src/gallium/drivers/etnaviv/
H A Detnaviv_blt.c108 emit_blt_clearimage(struct etna_cmd_stream *stream, const struct blt_clear_op *op) in emit_blt_clearimage() argument
110 etna_cmd_stream_reserve(stream, 64*2); /* Make sure BLT op doesn't get broken up */ in emit_blt_clearimage()
112 etna_set_state(stream, VIVS_BLT_ENABLE, 0x00000001); in emit_blt_clearimage()
114 etna_set_state(stream, VIVS_BLT_CONFIG, VIVS_BLT_CONFIG_CLEAR_BPP(op->dest.bpp-1)); in emit_blt_clearimage()
119 etna_set_state(stream, VIVS_BLT_DEST_STRIDE, blt_compute_stride_bits(&op->dest)); in emit_blt_clearimage()
120 etna_set_state(stream, VIVS_BLT_DEST_CONFIG, blt_compute_img_config_bits(&op->dest, true)); in emit_blt_clearimage()
121 etna_set_state_reloc(stream, VIVS_BLT_DEST_ADDR, &op->dest.addr); in emit_blt_clearimage()
122 etna_set_state(stream, VIVS_BLT_SRC_STRIDE, blt_compute_stride_bits(&op->dest)); in emit_blt_clearimage()
123 etna_set_state(stream, VIVS_BLT_SRC_CONFIG, blt_compute_img_config_bits(&op->dest, false)); in emit_blt_clearimage()
124 etna_set_state_reloc(stream, VIVS_BLT_SRC_ADD in emit_blt_clearimage()
147 emit_blt_copyimage(struct etna_cmd_stream *stream, const struct blt_imgcopy_op *op) emit_blt_copyimage() argument
192 emit_blt_inplace(struct etna_cmd_stream *stream, const struct blt_inplace_op *op) emit_blt_inplace() argument
[all...]
/third_party/mesa3d/src/compiler/nir/
H A Dnir_lower_gs_intrinsics.c83 unsigned stream = nir_intrinsic_stream_id(intrin); in rewrite_emit_vertex() local
87 assert(state->vertex_count_vars[stream] != NULL); in rewrite_emit_vertex()
88 nir_ssa_def *count = nir_load_var(b, state->vertex_count_vars[stream]); in rewrite_emit_vertex()
92 count_per_primitive = nir_load_var(b, state->vtxcnt_per_prim_vars[stream]); in rewrite_emit_vertex()
108 nir_emit_vertex_with_counter(b, count, count_per_primitive, stream); in rewrite_emit_vertex()
111 nir_store_var(b, state->vertex_count_vars[stream], in rewrite_emit_vertex()
117 nir_variable *var = state->vtxcnt_per_prim_vars[stream]; in rewrite_emit_vertex()
148 overwrite_incomplete_primitives(struct state *state, unsigned stream) in overwrite_incomplete_primitives() argument
167 nir_load_var(b, state->vertex_count_vars[stream]); in overwrite_incomplete_primitives()
171 nir_load_var(b, state->vtxcnt_per_prim_vars[stream]); in overwrite_incomplete_primitives()
205 unsigned stream = nir_intrinsic_stream_id(intrin); rewrite_end_primitive() local
[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/skia/third_party/externals/zlib/contrib/tests/fuzzers/
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/node/test/parallel/
H A Dtest-whatwg-readablestream.js5 const { isDisturbed, isErrored, isReadable } = require('stream');
24 } = require('stream/web');
310 const stream = new ReadableStream();
311 const reader = stream.getReader();
313 assert(stream.locked);
314 assert.strictEqual(reader[kState].stream, stream);
315 assert.strictEqual(stream[kState].reader, reader);
317 assert.throws(() => stream.getReader(), {
340 assert(stream
[all...]
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/ltp/tools/sparse/sparse-src/
H A Dpre-process.c67 #define dirty_stream(stream) \
69 if (!stream->dirty) { \
70 stream->dirty = 1; \
71 if (!stream->ifndef) \
72 stream->protect = NULL; \
76 #define end_group(stream) \
78 if (stream->ifndef == stream->top_if) { \
79 stream->ifndef = NULL; \
80 if (!stream
260 struct stream *stream = input_streams + prev->pos.stream; collect_arg() local
811 int stream, next; already_tokenized() local
874 set_stream_include_path(struct stream *stream) set_stream_include_path() argument
945 handle_include_path(struct stream *stream, struct token **list, struct token *token, int how) handle_include_path() argument
997 handle_include(struct stream *stream, struct token **list, struct token *token) handle_include() argument
1002 handle_include_next(struct stream *stream, struct token **list, struct token *token) handle_include_next() argument
1007 handle_argv_include(struct stream *stream, struct token **list, struct token *token) handle_argv_include() argument
1470 do_handle_define(struct stream *stream, struct token **line, struct token *token, int attr) do_handle_define() argument
1500 handle_define(struct stream *stream, struct token **line, struct token *token) handle_define() argument
1505 handle_weak_define(struct stream *stream, struct token **line, struct token *token) handle_weak_define() argument
1510 handle_strong_define(struct stream *stream, struct token **line, struct token *token) handle_strong_define() argument
1515 do_handle_undef(struct stream *stream, struct token **line, struct token *token, int attr) do_handle_undef() argument
1546 handle_undef(struct stream *stream, struct token **line, struct token *token) handle_undef() argument
1551 handle_strong_undef(struct stream *stream, struct token **line, struct token *token) handle_strong_undef() argument
1556 preprocessor_if(struct stream *stream, struct token *token, int cond) preprocessor_if() argument
1567 handle_ifdef(struct stream *stream, struct token **line, struct token *token) handle_ifdef() argument
1582 handle_ifndef(struct stream *stream, struct token **line, struct token *token) handle_ifndef() argument
1669 handle_if(struct stream *stream, struct token **line, struct token *token) handle_if() argument
1679 handle_elif(struct stream * stream, struct token **line, struct token *token) handle_elif() argument
1712 handle_else(struct stream *stream, struct token **line, struct token *token) handle_else() argument
1737 handle_endif(struct stream *stream, struct token **line, struct token *token) handle_endif() argument
1753 handle_warning(struct stream *stream, struct token **line, struct token *token) handle_warning() argument
1759 handle_error(struct stream *stream, struct token **line, struct token *token) handle_error() argument
1765 handle_nostdinc(struct stream *stream, struct token **line, struct token *token) handle_nostdinc() argument
1842 handle_add_include(struct stream *stream, struct token **line, struct token *token) handle_add_include() argument
1856 handle_add_isystem(struct stream *stream, struct token **line, struct token *token) handle_add_isystem() argument
1870 handle_add_system(struct stream *stream, struct token **line, struct token *token) handle_add_system() argument
1901 handle_add_dirafter(struct stream *stream, struct token **line, struct token *token) handle_add_dirafter() argument
1915 handle_split_include(struct stream *stream, struct token **line, struct token *token) handle_split_include() argument
1946 handle_pragma(struct stream *stream, struct token **line, struct token *token) handle_pragma() argument
1966 handle_line(struct stream *stream, struct token **line, struct token *token) handle_line() argument
1971 handle_ident(struct stream *stream, struct token **line, struct token *token) handle_ident() argument
1976 handle_nondirective(struct stream *stream, struct token **line, struct token *token) handle_nondirective() argument
2096 int stream = init_stream(NULL, "preprocessor", -1, includepath); init_preprocessor() local
2171 handle_preprocessor_line(struct stream *stream, struct token **line, struct token *start) handle_preprocessor_line() argument
2213 preprocessor_line(struct stream *stream, struct token **line) preprocessor_line() argument
2234 struct stream *stream = input_streams + next->pos.stream; do_preprocess() 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/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/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/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/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/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/node/lib/internal/streams/
H A Dadd-abort-signal.js18 const eos = require('internal/streams/end-of-stream');
22 // This method is inlined here for readable-stream
23 // It also does not allow for signal to not exist on the stream
32 module.exports.addAbortSignal = function addAbortSignal(signal, stream) {
34 if (!isNodeStream(stream) && !isWebStream(stream)) {
35 throw new ERR_INVALID_ARG_TYPE('stream', ['ReadableStream', 'WritableStream', 'Stream'], stream);
37 return module.exports.addAbortSignalNoValidate(signal, stream);
40 module.exports.addAbortSignalNoValidate = function(signal, stream) {
[all...]

Completed in 14 milliseconds

12345678910>>...104