| /third_party/node/deps/nghttp2/lib/ |
| D | nghttp2_stream.c | 60 void nghttp2_stream_init(nghttp2_stream *stream, int32_t stream_id, in nghttp2_stream_init() argument
65 nghttp2_pq_init(&stream->obq, stream_less, mem); in nghttp2_stream_init()
67 stream->stream_id = stream_id; in nghttp2_stream_init()
68 stream->flags = flags; in nghttp2_stream_init()
69 stream->state = initial_state; in nghttp2_stream_init()
70 stream->shut_flags = NGHTTP2_SHUT_NONE; in nghttp2_stream_init()
71 stream->stream_user_data = stream_user_data; in nghttp2_stream_init()
72 stream->item = NULL; in nghttp2_stream_init()
73 stream->remote_window_size = remote_initial_window_size; in nghttp2_stream_init()
74 stream->local_window_size = local_initial_window_size; in nghttp2_stream_init()
[all …]
|
| D | nghttp2_http.c | 77 static int check_pseudo_header(nghttp2_stream *stream, const nghttp2_hd_nv *nv, in check_pseudo_header() argument
79 if ((stream->http_flags & flag) || nv->value->len == 0) { in check_pseudo_header()
82 stream->http_flags = stream->http_flags | flag; in check_pseudo_header()
86 static int expect_response_body(nghttp2_stream *stream) { in expect_response_body() argument
87 return (stream->http_flags & NGHTTP2_HTTP_FLAG_METH_HEAD) == 0 && in expect_response_body()
88 stream->status_code / 100 != 1 && stream->status_code != 304 && in expect_response_body()
89 stream->status_code != 204; in expect_response_body()
97 static int check_path(nghttp2_stream *stream) { in check_path() argument
98 return (stream->http_flags & NGHTTP2_HTTP_FLAG_SCHEME_HTTP) == 0 || in check_path()
99 ((stream->http_flags & NGHTTP2_HTTP_FLAG_PATH_REGULAR) || in check_path()
[all …]
|
| /third_party/nghttp2/lib/ |
| D | nghttp2_stream.c | 60 void nghttp2_stream_init(nghttp2_stream *stream, int32_t stream_id, in nghttp2_stream_init() argument
65 nghttp2_pq_init(&stream->obq, stream_less, mem); in nghttp2_stream_init()
67 stream->stream_id = stream_id; in nghttp2_stream_init()
68 stream->flags = flags; in nghttp2_stream_init()
69 stream->state = initial_state; in nghttp2_stream_init()
70 stream->shut_flags = NGHTTP2_SHUT_NONE; in nghttp2_stream_init()
71 stream->stream_user_data = stream_user_data; in nghttp2_stream_init()
72 stream->item = NULL; in nghttp2_stream_init()
73 stream->remote_window_size = remote_initial_window_size; in nghttp2_stream_init()
74 stream->local_window_size = local_initial_window_size; in nghttp2_stream_init()
[all …]
|
| D | nghttp2_http.c | 77 static int check_pseudo_header(nghttp2_stream *stream, const nghttp2_hd_nv *nv, in check_pseudo_header() argument
79 if ((stream->http_flags & flag) || nv->value->len == 0) { in check_pseudo_header()
82 stream->http_flags = stream->http_flags | flag; in check_pseudo_header()
86 static int expect_response_body(nghttp2_stream *stream) { in expect_response_body() argument
87 return (stream->http_flags & NGHTTP2_HTTP_FLAG_METH_HEAD) == 0 && in expect_response_body()
88 stream->status_code / 100 != 1 && stream->status_code != 304 && in expect_response_body()
89 stream->status_code != 204; in expect_response_body()
97 static int check_path(nghttp2_stream *stream) { in check_path() argument
98 return (stream->http_flags & NGHTTP2_HTTP_FLAG_SCHEME_HTTP) == 0 || in check_path()
99 ((stream->http_flags & NGHTTP2_HTTP_FLAG_PATH_REGULAR) || in check_path()
[all …]
|
| /third_party/pulseaudio/sonic/ |
| D | sonic.c | 89 sonicStream stream) in sonicGetSpeed() argument
91 return stream->speed; in sonicGetSpeed()
96 sonicStream stream, in sonicSetSpeed() argument
99 stream->speed = speed; in sonicSetSpeed()
104 sonicStream stream) in sonicGetPitch() argument
106 return stream->pitch; in sonicGetPitch()
111 sonicStream stream, in sonicSetPitch() argument
114 stream->pitch = pitch; in sonicSetPitch()
119 sonicStream stream) in sonicGetRate() argument
121 return stream->rate; in sonicGetRate()
[all …]
|
| /third_party/mesa3d/src/gallium/auxiliary/util/ |
| D | u_dump_state.c | 45 util_stream_writef(FILE *stream, const char *format, ...) in util_stream_writef() argument
53 fwrite(buf, len, 1, stream); in util_stream_writef()
57 util_dump_bool(FILE *stream, int value) in util_dump_bool() argument
59 util_stream_writef(stream, "%c", value ? '1' : '0'); in util_dump_bool()
63 util_dump_int(FILE *stream, long long int value) in util_dump_int() argument
65 util_stream_writef(stream, "%lli", value); in util_dump_int()
69 util_dump_uint(FILE *stream, long long unsigned value) in util_dump_uint() argument
71 util_stream_writef(stream, "%llu", value); in util_dump_uint()
75 util_dump_float(FILE *stream, double value) in util_dump_float() argument
77 util_stream_writef(stream, "%g", value); in util_dump_float()
[all …]
|
| /third_party/skia/third_party/externals/freetype/src/base/ |
| D | ftstream.c | 30 #define FT_COMPONENT stream
34 FT_Stream_OpenMemory( FT_Stream stream, in FT_Stream_OpenMemory() argument
38 stream->base = (FT_Byte*) base; in FT_Stream_OpenMemory()
39 stream->size = size; in FT_Stream_OpenMemory()
40 stream->pos = 0; in FT_Stream_OpenMemory()
41 stream->cursor = NULL; in FT_Stream_OpenMemory()
42 stream->read = NULL; in FT_Stream_OpenMemory()
43 stream->close = NULL; in FT_Stream_OpenMemory()
48 FT_Stream_Close( FT_Stream stream ) in FT_Stream_Close() argument
50 if ( stream && stream->close ) in FT_Stream_Close()
[all …]
|
| /third_party/mesa3d/src/gallium/drivers/i915/ |
| D | i915_debug.c | 68 debug(struct debug_stream *stream, const char *name, unsigned len) in debug() argument
71 unsigned *ptr = (unsigned *)(stream->ptr + stream->offset); in debug()
74 mesa_logi("Error - zero length packet (0x%08x)", stream->ptr[0]); in debug()
79 if (stream->print_addresses) in debug()
80 mesa_logi("%08x: ", stream->offset); in debug()
87 stream->offset += len * sizeof(unsigned); in debug()
139 debug_prim(struct debug_stream *stream, const char *name, bool dump_floats, in debug_prim() argument
142 unsigned *ptr = (unsigned *)(stream->ptr + stream->offset); in debug_prim()
157 stream->offset += len * sizeof(unsigned); in debug_prim()
163 debug_program(struct debug_stream *stream, const char *name, unsigned len) in debug_program() argument
[all …]
|
| D | i915_debug_fp.c | 74 print_reg_type_nr(char **stream, unsigned type, unsigned nr) in print_reg_type_nr() argument
80 PRINTF(stream, "T_DIFFUSE"); in print_reg_type_nr()
83 PRINTF(stream, "T_SPECULAR"); in print_reg_type_nr()
86 PRINTF(stream, "T_FOG_W"); in print_reg_type_nr()
89 PRINTF(stream, "T_TEX%d", nr); in print_reg_type_nr()
94 PRINTF(stream, "oC"); in print_reg_type_nr()
100 PRINTF(stream, "oD"); in print_reg_type_nr()
108 PRINTF(stream, "%s[%d]", regname[type], nr); in print_reg_type_nr()
119 print_reg_neg_swizzle(char **stream, unsigned reg) in print_reg_neg_swizzle() argument
127 PRINTF(stream, "."); in print_reg_neg_swizzle()
[all …]
|
| /third_party/node/lib/internal/streams/ |
| D | utils.js | 106 function isDestroyed(stream) { argument
107 if (!isNodeStream(stream)) return null;
108 const wState = stream._writableState;
109 const rState = stream._readableState;
111 return !!(stream.destroyed || stream[kIsDestroyed] || state?.destroyed);
115 function isWritableEnded(stream) { argument
116 if (!isWritableNodeStream(stream)) return null;
117 if (stream.writableEnded === true) return true;
118 const wState = stream._writableState;
125 function isWritableFinished(stream, strict) { argument
[all …]
|
| D | end-of-stream.js | 49 function isRequest(stream) { argument
50 return stream.setHeader && typeof stream.abort === 'function';
55 function eos(stream, options, callback) { argument
69 if (isReadableStream(stream) || isWritableStream(stream)) {
70 return eosWeb(stream, options, callback);
73 if (!isNodeStream(stream)) {
74 … throw new ERR_INVALID_ARG_TYPE('stream', ['ReadableStream', 'WritableStream', 'Stream'], stream);
77 const readable = options.readable ?? isReadableNodeStream(stream);
78 const writable = options.writable ?? isWritableNodeStream(stream);
80 const wState = stream._writableState;
[all …]
|
| /third_party/mesa3d/src/freedreno/ir3/ |
| D | ir3_print.c | 70 print_instr_name(struct log_stream *stream, struct ir3_instruction *instr, in print_instr_name() argument
76 mesa_log_stream_printf(stream, "%04u:", instr->serialno); in print_instr_name()
78 mesa_log_stream_printf(stream, "%04u:", instr->ip); in print_instr_name()
80 mesa_log_stream_printf(stream, "XXX: "); in print_instr_name()
82 mesa_log_stream_printf(stream, "%03u: ", instr->use_count); in print_instr_name()
86 mesa_log_stream_printf(stream, "\t"); in print_instr_name()
88 mesa_log_stream_printf(stream, "(sy)"); in print_instr_name()
90 mesa_log_stream_printf(stream, "(ss)"); in print_instr_name()
92 mesa_log_stream_printf(stream, "(jp)"); in print_instr_name()
94 mesa_log_stream_printf(stream, "(rpt%d)", instr->repeat); in print_instr_name()
[all …]
|
| /third_party/skia/tools/skdiff/ |
| D | skdiff_html.cpp | 28 static void print_table_header(SkFILEWStream* stream, in print_table_header() argument
35 stream->writeText("<table>\n"); in print_table_header()
36 stream->writeText("<tr><th>"); in print_table_header()
37 stream->writeText("select image</th>\n<th>"); in print_table_header()
41 stream->writeText("SkDiff run at "); in print_table_header()
42 stream->writeDecAsText(dt.fHour); in print_table_header()
43 stream->writeText(":"); in print_table_header()
45 stream->writeText("0"); in print_table_header()
47 stream->writeDecAsText(dt.fMinute); in print_table_header()
48 stream->writeText(":"); in print_table_header()
[all …]
|
| /third_party/libuv/src/unix/ |
| D | stream.c | 47 uv_stream_t* stream; member
64 static void uv__write(uv_stream_t* stream);
65 static void uv__read(uv_stream_t* stream);
67 static void uv__write_callbacks(uv_stream_t* stream);
69 static void uv__drain(uv_stream_t* stream);
73 uv_stream_t* stream, in uv__stream_init() argument
77 uv__handle_init(loop, (uv_handle_t*)stream, type); in uv__stream_init()
78 stream->read_cb = NULL; in uv__stream_init()
79 stream->alloc_cb = NULL; in uv__stream_init()
80 stream->close_cb = NULL; in uv__stream_init()
[all …]
|
| /third_party/node/deps/uv/src/unix/ |
| D | stream.c | 47 uv_stream_t* stream; member
64 static void uv__write(uv_stream_t* stream);
65 static void uv__read(uv_stream_t* stream);
67 static void uv__write_callbacks(uv_stream_t* stream);
69 static void uv__drain(uv_stream_t* stream);
73 uv_stream_t* stream, in uv__stream_init() argument
77 uv__handle_init(loop, (uv_handle_t*)stream, type); in uv__stream_init()
78 stream->read_cb = NULL; in uv__stream_init()
79 stream->alloc_cb = NULL; in uv__stream_init()
80 stream->close_cb = NULL; in uv__stream_init()
[all …]
|
| /third_party/skia/third_party/externals/angle2/src/tests/egl_tests/ |
| D | EGLPrintEGLinfoTest.cpp | 151 #define QUERY_HELPER(enumValue, enumString, stream) \ argument
156 stream << enumString + std::string(",") + std::to_string(result) << std::endl; \
159 #define QUERY_ARRAY_HELPER(enumValue, enumString, size, stream) \ argument
167 stream << enumString + std::string(",") + results.str() << std::endl; \
170 #define QUERY_INDEXED_HELPER(enumValue, enumString, index, stream) \ argument
175 stream << enumString + std::string(",") + std::to_string(result) << std::endl; \
178 #define QUERY_AND_LOG_CAPABILITY(enum, stream) QUERY_HELPER(enum, #enum, stream) argument
180 #define QUERY_AND_LOG_CAPABILITY_ARRAY(enum, size, stream) \ argument
181 QUERY_ARRAY_HELPER(enum, #enum, size, stream)
183 #define QUERY_AND_LOG_CAPABILITY_INDEXED(enum, index, stream) \ argument
[all …]
|
| /third_party/skia/third_party/externals/dng_sdk/source/ |
| D | dng_iptc.cpp | 183 void dng_iptc::ParseString (dng_stream &stream, in ParseString() argument
188 uint32 length = stream.Get_uint16 (); in ParseString()
194 stream.Get (c, length); in ParseString()
229 dng_stream stream (blockData, in Parse() local
233 stream.SetBigEndian (); in Parse()
244 uint64 firstOffset = stream.Position (); in Parse()
248 while (nextOffset + 5 < stream.Length ()) in Parse()
251 stream.SetReadPosition (nextOffset); in Parse()
253 uint8 firstByte = stream.Get_uint8 (); in Parse()
257 uint8 record = stream.Get_uint8 (); in Parse()
[all …]
|
| /third_party/node/lib/internal/webstreams/ |
| D | writablestream.js | 387 constructor(stream) { argument
388 if (!isWritableStream(stream))
389 throw new ERR_INVALID_ARG_TYPE('stream', 'WritableStream', stream);
391 stream: undefined,
403 setupWritableStreamDefaultWriter(this, stream);
423 if (this[kState].stream === undefined) {
447 if (this[kState].stream === undefined) {
462 stream,
464 if (stream === undefined) {
469 if (writableStreamCloseQueuedOrInFlight(stream)) {
[all …]
|
| /third_party/ltp/tools/sparse/sparse-src/ |
| D | tokenize.c | 43 struct stream *input_streams;
58 const char *stream_name(int stream) in stream_name() argument
60 if (stream < 0 || stream > input_stream_nr) in stream_name()
62 return input_streams[stream].name; in stream_name()
65 int stream_prev(int stream) in stream_prev() argument
67 if (stream < 0 || stream > input_stream_nr) in stream_prev()
69 stream = input_streams[stream].pos.stream; in stream_prev()
70 if (stream > input_stream_nr) in stream_prev()
72 return stream; in stream_prev()
75 static struct position stream_pos(stream_t *stream) in stream_pos() argument
[all …]
|
| /third_party/mesa3d/src/gallium/drivers/etnaviv/ |
| D | etnaviv_emit.h | 43 etna_emit_load_state(struct etna_cmd_stream *stream, const uint16_t offset, in etna_emit_load_state() argument
54 etna_cmd_stream_emit(stream, v); in etna_emit_load_state()
58 etna_set_state(struct etna_cmd_stream *stream, uint32_t address, uint32_t value) in etna_set_state() argument
60 etna_cmd_stream_reserve(stream, 2); in etna_set_state()
61 etna_emit_load_state(stream, address >> 2, 1, 0); in etna_set_state()
62 etna_cmd_stream_emit(stream, value); in etna_set_state()
66 etna_set_state_reloc(struct etna_cmd_stream *stream, uint32_t address, in etna_set_state_reloc() argument
69 etna_cmd_stream_reserve(stream, 2); in etna_set_state_reloc()
70 etna_emit_load_state(stream, address >> 2, 1, 0); in etna_set_state_reloc()
71 etna_cmd_stream_reloc(stream, reloc); in etna_set_state_reloc()
[all …]
|
| /third_party/mesa3d/src/etnaviv/drm/tests/ |
| D | etnaviv_cmd_stream_test.c | 36 struct etna_cmd_stream *stream; in test_avail() local
41 stream = etna_cmd_stream_new(NULL, 0, NULL, NULL); in test_avail()
42 assert(stream == NULL); in test_avail()
44 stream = etna_cmd_stream_new(NULL, 4, NULL, NULL); in test_avail()
45 assert(stream); in test_avail()
46 assert(etna_cmd_stream_avail(stream) == 2); in test_avail()
47 etna_cmd_stream_del(stream); in test_avail()
49 stream = etna_cmd_stream_new(NULL, 20, NULL, NULL); in test_avail()
50 assert(stream); in test_avail()
51 assert(etna_cmd_stream_avail(stream) == 18); in test_avail()
[all …]
|
| /third_party/libdrm/tests/etnaviv/ |
| D | etnaviv_cmd_stream_test.c | 36 struct etna_cmd_stream *stream; in test_avail() local
41 stream = etna_cmd_stream_new(NULL, 0, NULL, NULL); in test_avail()
42 assert(stream == NULL); in test_avail()
44 stream = etna_cmd_stream_new(NULL, 4, NULL, NULL); in test_avail()
45 assert(stream); in test_avail()
46 assert(etna_cmd_stream_avail(stream) == 2); in test_avail()
47 etna_cmd_stream_del(stream); in test_avail()
49 stream = etna_cmd_stream_new(NULL, 20, NULL, NULL); in test_avail()
50 assert(stream); in test_avail()
51 assert(etna_cmd_stream_avail(stream) == 18); in test_avail()
[all …]
|
| D | etnaviv_2d_test.c | 42 static inline void etna_emit_load_state(struct etna_cmd_stream *stream, in etna_emit_load_state() argument
50 etna_cmd_stream_emit(stream, v); in etna_emit_load_state()
53 static inline void etna_set_state(struct etna_cmd_stream *stream, uint32_t address, uint32_t value) in etna_set_state() argument
55 etna_cmd_stream_reserve(stream, 2); in etna_set_state()
56 etna_emit_load_state(stream, address >> 2, 1); in etna_set_state()
57 etna_cmd_stream_emit(stream, value); in etna_set_state()
60 static inline void etna_set_state_from_bo(struct etna_cmd_stream *stream, in etna_set_state_from_bo() argument
63 etna_cmd_stream_reserve(stream, 2); in etna_set_state_from_bo()
64 etna_emit_load_state(stream, address >> 2, 1); in etna_set_state_from_bo()
66 etna_cmd_stream_reloc(stream, &(struct etna_reloc){ in etna_set_state_from_bo()
[all …]
|
| /third_party/node/deps/ngtcp2/nghttp3/lib/ |
| D | nghttp3_stream.c | 51 nghttp3_stream *stream = nghttp3_objalloc_stream_get(stream_objalloc); in nghttp3_stream_new() local
54 if (stream == NULL) { in nghttp3_stream_new()
58 memset(stream, 0, sizeof(*stream)); in nghttp3_stream_new()
60 stream->out_chunk_objalloc = out_chunk_objalloc; in nghttp3_stream_new()
61 stream->stream_objalloc = stream_objalloc; in nghttp3_stream_new()
64 &stream->node, in nghttp3_stream_new()
68 nghttp3_ringbuf_init(&stream->frq, 0, sizeof(nghttp3_frame_entry), mem); in nghttp3_stream_new()
69 nghttp3_ringbuf_init(&stream->chunks, 0, sizeof(nghttp3_buf), mem); in nghttp3_stream_new()
70 nghttp3_ringbuf_init(&stream->outq, 0, sizeof(nghttp3_typed_buf), mem); in nghttp3_stream_new()
71 nghttp3_ringbuf_init(&stream->inq, 0, sizeof(nghttp3_buf), mem); in nghttp3_stream_new()
[all …]
|
| /third_party/vk-gl-cts/framework/delibs/destream/ |
| D | deIOStream.h | 52 typedef deStreamResult (*deIOStreamReadFunc) (deStreamData* stream, void* buf, deInt32 bufSize, de…
53 typedef deStreamResult (*deIOStreamWriteFunc) (deStreamData* stream, const void* buf, deInt32 bufS…
54 typedef const char* (*deIOStreamGetErrorFunc) (deStreamData* stream);
55 typedef deStreamResult (*deIOStreamFlushFunc) (deStreamData* stream);
56 typedef deStreamResult (*deIOStreamDeinitFunc) (deStreamData* stream);
57 typedef deStreamStatus (*deIOStreamStatusFunc) (deStreamData* stream);
77 DE_INLINE deStreamResult deIOStream_read (deIOStream* stream, void* buf, deInt32 bufSize, deInt32…
78 DE_INLINE deStreamResult deIOStream_write (deIOStream* stream, const void* buf, deInt32 bufSize, d…
79 DE_INLINE const char* deIOStream_getError (deIOStream* stream);
80 DE_INLINE deStreamStatus deIOStream_getStatus (deIOStream* stream);
[all …]
|