Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 265) sorted by relevance

1234567891011

/AliOS-Things-master/components/linkkit/external/nghttp2/
A Dnghttp2_stream.c320 for (; stream->sib_next; stream = stream->sib_next) in stream_last_sib()
348 stream, stream->stream_id); in ensure_inactive()
354 stream, stream->stream_id, nghttp2_pq_size(&stream->obq)); in ensure_inactive()
374 stream, stream->stream_id, stream_active(stream), in check_queued()
389 stream, stream->stream_id); in check_queued()
403 stream, stream->stream_id, stream_active(stream), in check_queued()
454 for (; stream->dep_prev; stream = stream->dep_prev) in validate_tree()
486 rv = stream_obq_push(stream->dep_prev, stream); in stream_update_dep_on_attach_item()
623 for (; stream; stream = stream->dep_prev) { in nghttp2_stream_dep_find_ancestor()
674 for (; stream; stream = stream->sib_next) { in set_dep_prev()
[all …]
A Dnghttp2_http.c92 if (stream->http_flags & flag) { in check_pseudo_header()
98 stream->http_flags = (uint16_t)(stream->http_flags | flag); in check_pseudo_header()
105 stream->status_code / 100 != 1 && stream->status_code != 304 && in expect_response_body()
258 stream->status_code = in http_response_on_header()
260 if (stream->status_code == -1 || stream->status_code == 101) { in http_response_on_header()
496 (stream->http_flags & in nghttp2_http_on_request_headers()
523 stream->http_flags = in nghttp2_http_on_response_headers()
531 stream->http_flags = (uint16_t)(stream->http_flags & in nghttp2_http_on_response_headers()
548 (void)stream; in nghttp2_http_on_trailer_headers()
564 stream->content_length != stream->recv_content_length) { in nghttp2_http_on_remote_end_stream()
[all …]
A Dnghttp2_stream.h230 void nghttp2_stream_free(nghttp2_stream *stream);
288 nghttp2_stream *stream, int32_t new_initial_window_size,
300 nghttp2_stream *stream, int32_t new_initial_window_size,
336 nghttp2_stream *stream);
348 int nghttp2_stream_dep_remove(nghttp2_stream *stream);
359 int nghttp2_stream_attach_item(nghttp2_stream *stream,
372 int nghttp2_stream_detach_item(nghttp2_stream *stream);
398 nghttp2_stream *stream);
415 int nghttp2_stream_in_dep_tree(nghttp2_stream *stream);
421 void nghttp2_stream_reschedule(nghttp2_stream *stream);
[all …]
A Dnghttp2_session.c300 return stream; in nghttp2_session_get_stream()
970 if (stream && stream->state == NGHTTP2_STREAM_CLOSING) { in nghttp2_session_add_rst_stream()
1045 if (stream) { in nghttp2_session_open_stream()
1282 stream->stream_id, stream->state); in nghttp2_session_keep_closed_stream()
1299 stream->stream_id, stream->state); in nghttp2_session_keep_idle_stream()
1318 stream->stream_id, stream->state); in nghttp2_session_detach_idle_stream()
2535 stream->last_writelen = stream->item->frame.hd.length; in reschedule_stream()
3847 if (!stream || stream->state == NGHTTP2_STREAM_CLOSING) { in session_after_header_block_received()
3974 if (stream && (stream->shut_flags & NGHTTP2_SHUT_RD)) { in nghttp2_session_on_request_headers_received()
4731 if (!stream || stream->state == NGHTTP2_STREAM_CLOSING || in nghttp2_session_on_push_promise_received()
[all …]
/AliOS-Things-master/components/freetype/src/base/
A Dftstream.c51 if ( stream && stream->close ) in FT_Stream_Close()
52 stream->close( stream ); in FT_Stream_Close()
175 read_bytes = stream->read( stream, stream->pos, buffer, count ); in FT_Stream_TryRead()
218 if ( stream && stream->read ) in FT_Stream_ReleaseFrame()
271 read_bytes = stream->read( stream, stream->pos, in FT_Stream_EnterFrame()
282 stream->cursor = stream->base; in FT_Stream_EnterFrame()
301 stream->cursor = stream->base + stream->pos; in FT_Stream_EnterFrame()
462 if ( stream->read( stream, stream->pos, &result, 1L ) != 1L ) in FT_Stream_ReadChar()
503 if ( stream->read( stream, stream->pos, reads, 2L ) != 2L ) in FT_Stream_ReadUShort()
550 if ( stream->read( stream, stream->pos, reads, 2L ) != 2L ) in FT_Stream_ReadUShortLE()
[all …]
A Dftsystem.c153 #define STREAM_FILE( stream ) ( (FT_FILE*)stream->descriptor.pointer ) argument
172 stream->descriptor.pointer = NULL; in ft_ansi_stream_close()
173 stream->size = 0; in ft_ansi_stream_close()
174 stream->base = 0; in ft_ansi_stream_close()
212 file = STREAM_FILE( stream ); in ft_ansi_stream_io()
214 if ( stream->pos != offset ) in ft_ansi_stream_io()
230 if ( !stream ) in FT_Stream_Open()
235 stream->base = 0; in FT_Stream_Open()
236 stream->pos = 0; in FT_Stream_Open()
250 stream->size = ft_ftell( file ); in FT_Stream_Open()
[all …]
A Dftapi.c47 FT_Stream stream ) in FT_New_Memory_Stream() argument
56 FT_Seek_Stream( FT_Stream stream, in FT_Seek_Stream() argument
59 return FT_Stream_Seek( stream, pos ); in FT_Seek_Stream()
64 FT_Skip_Stream( FT_Stream stream, in FT_Skip_Stream() argument
72 FT_Read_Stream( FT_Stream stream, in FT_Read_Stream() argument
81 FT_Read_Stream_At( FT_Stream stream, in FT_Read_Stream_At() argument
91 FT_Extract_Frame( FT_Stream stream, in FT_Extract_Frame() argument
100 FT_Release_Frame( FT_Stream stream, in FT_Release_Frame() argument
107 FT_Access_Frame( FT_Stream stream, in FT_Access_Frame() argument
115 FT_Forget_Frame( FT_Stream stream ) in FT_Forget_Frame() argument
[all …]
A Dftrfork.c389 if ( NULL != stream ) in FT_Raccess_Guess()
455 if ( NULL == stream ) in raccess_guess_apple_double()
477 if ( NULL == stream ) in raccess_guess_apple_single()
496 FT_UNUSED( stream ); in raccess_guess_darwin_ufs_export()
530 FT_UNUSED( stream ); in raccess_guess_darwin_hfsplus()
566 FT_UNUSED( stream ); in raccess_guess_darwin_newvfs()
597 FT_UNUSED( stream ); in raccess_guess_vfat()
624 FT_UNUSED( stream ); in raccess_guess_linux_cap()
651 FT_UNUSED( stream ); in raccess_guess_linux_double()
682 FT_UNUSED( stream ); in raccess_guess_linux_netatalk()
[all …]
/AliOS-Things-master/components/SDL2/src/image/external/zlib-1.2.11/
A Duncompr.c33 z_stream stream; local
50 stream.avail_in = 0;
51 stream.zalloc = (alloc_func)0;
52 stream.zfree = (free_func)0;
53 stream.opaque = (voidpf)0;
55 err = inflateInit(&stream);
58 stream.next_out = dest;
59 stream.avail_out = 0;
66 if (stream.avail_in == 0) {
68 len -= stream.avail_in;
[all …]
A Dcompress.c29 z_stream stream; local
37 stream.zalloc = (alloc_func)0;
38 stream.zfree = (free_func)0;
39 stream.opaque = (voidpf)0;
44 stream.next_out = dest;
45 stream.avail_out = 0;
47 stream.avail_in = 0;
50 if (stream.avail_out == 0) {
54 if (stream.avail_in == 0) {
61 *destLen = stream.total_out;
[all …]
/AliOS-Things-master/components/freetype/src/gzip/
A Dftgzip.c281 zip->stream = stream; in ft_gzip_file_init()
291 stream = source; in ft_gzip_file_init()
336 zip->stream = NULL; in ft_gzip_file_done()
378 size = stream->read( stream, stream->pos, zip->input, in ft_gzip_file_fill_input()
385 size = stream->size - stream->pos; in ft_gzip_file_fill_input()
392 FT_MEM_COPY( zip->input, stream->base + stream->pos, size ); in ft_gzip_file_fill_input()
586 if ( !FT_Stream_Seek( stream, stream->size - 4 ) ) in ft_gzip_get_uncompressed_size()
618 FT_ZERO( stream ); in FT_Stream_OpenGzip()
680 stream->pos = 0; in FT_Stream_OpenGzip()
681 stream->base = 0; in FT_Stream_OpenGzip()
[all …]
/AliOS-Things-master/components/py_engine/tests/unix/
A Dextra_coverage.py21 stream.set_error(uerrno.EAGAIN) # non-blocking error
22 print(stream.read()) # read all encounters non-blocking error
23 print(stream.read(1)) # read 1 byte encounters non-blocking error
26 print(stream.write(b"1")) # write encounters non-blocking error
28 stream.set_buf(b"123")
30 stream.set_buf(b"123")
32 stream.set_buf(b"123")
38 stream.set_error(0)
39 print(stream.ioctl(0, bytearray(10))) # successful ioctl call
45 stream.set_error(uerrno.EAGAIN)
[all …]
/AliOS-Things-master/components/SDL2/src/image/external/tiff-4.0.9/libtiff/
A Dtif_zip.c64 #define SAFE_MSG(sp) ((sp)->stream.msg == NULL ? "" : (sp)->stream.msg)
106 deflateEnd(&sp->stream); in ZIPSetupDecode()
165 sp->stream.next_out = op; in ZIPDecode()
215 inflateEnd(&sp->stream); in ZIPSetupEncode()
269 sp->stream.next_in = bp; in ZIPEncode()
308 sp->stream.avail_in = 0; in ZIPPostEncode()
344 deflateEnd(&sp->stream); in ZIPCleanup()
347 inflateEnd(&sp->stream); in ZIPCleanup()
424 sp->stream.zalloc = NULL; in TIFFInitZIP()
425 sp->stream.zfree = NULL; in TIFFInitZIP()
[all …]
A Dtif_lzma.c48 lzma_stream stream; member
118 lzma_end(&sp->stream); in LZMASetupDecode()
177 sp->stream.next_out = op; in LZMADecode()
205 sp->stream.next_in = next_in; in LZMADecode()
206 sp->stream.avail_in = avail_in; in LZMADecode()
216 if (sp->stream.avail_out != 0) { in LZMADecode()
236 lzma_end(&sp->stream); in LZMASetupEncode()
281 sp->stream.next_in = bp; in LZMAEncode()
296 if (sp->stream.avail_out == 0) { in LZMAEncode()
317 sp->stream.avail_in = 0; in LZMAPostEncode()
[all …]
/AliOS-Things-master/components/py_engine/external/unzip/src/
A Duncompr.c30 z_stream stream; local
33 stream.next_in = (Bytef*)source;
34 stream.avail_in = (uInt)sourceLen;
38 stream.next_out = dest;
42 stream.zalloc = (alloc_func)0;
43 stream.zfree = (free_func)0;
45 err = inflateInit(&stream);
48 err = inflate(&stream, Z_FINISH);
50 inflateEnd(&stream);
55 *destLen = stream.total_out;
[all …]
A Diowin32.c33 voidpf stream,
39 voidpf stream,
45 voidpf stream));
49 voidpf stream,
55 voidpf stream));
59 voidpf stream));
121 voidpf stream;
144 voidpf stream;
167 voidpf stream;
190 voidpf stream;
[all …]
A Dioapi.c37 voidpf stream,
43 voidpf stream,
49 voidpf stream));
53 voidpf stream,
59 voidpf stream));
86 voidpf stream;
97 voidpf stream;
108 voidpf stream;
117 voidpf stream;
143 voidpf stream;
[all …]
A Dcompress.c29 z_stream stream; local
32 stream.next_in = (Bytef*)source;
33 stream.avail_in = (uInt)sourceLen;
38 stream.next_out = dest;
42 stream.zalloc = (alloc_func)0;
43 stream.zfree = (free_func)0;
44 stream.opaque = (voidpf)0;
49 err = deflate(&stream, Z_FINISH);
51 deflateEnd(&stream);
54 *destLen = stream.total_out;
[all …]
/AliOS-Things-master/components/SDL2/src/audio/
A DSDL_audiocvt.c1407 if (stream->dst_rate != stream->src_rate) { in SDL_AudioStreamPutInternal()
1451 if (stream->dst_rate != stream->src_rate) { in SDL_AudioStreamPutInternal()
1521 if (!stream) { in SDL_AudioStreamPut()
1532 (stream->dst_rate == stream->src_rate) && in SDL_AudioStreamPut()
1562 …if (SDL_AudioStreamPutInternal(stream, stream->staging_buffer, stream->staging_buffer_size, NULL) … in SDL_AudioStreamPut()
1582 SDL_assert((stream->dst_rate != stream->src_rate) || (stream->staging_buffer_filled == 0)); in SDL_AudioStreamFlush()
1648 return stream ? (int) SDL_CountDataQueue(stream->queue) : 0; in SDL_AudioStreamAvailable()
1657 SDL_ClearDataQueue(stream->queue, stream->packetlen * 2); in SDL_AudioStreamClear()
1659 stream->reset_resampler_func(stream); in SDL_AudioStreamClear()
1670 if (stream) { in SDL_FreeAudioStream()
[all …]
/AliOS-Things-master/components/uvoice/stream/
A Duvoice_file.c24 os_file_t stream; member
32 os_file_t stream; member
58 if (!OS_FILE_OPENING(loader->stream)) { in file_get_format()
72 file_pos = os_ftell(loader->stream); in file_get_format()
221 if (loader->stream) { in file_loader_update()
313 if (os_feof(loader->stream) || in file_loader_read()
385 os_fclose(loader->stream); in file_loader_action()
386 loader->stream = NULL; in file_loader_action()
478 os_fclose(loader->stream); in file_loader_create()
516 os_fclose(loader->stream); in file_loader_release()
[all …]
/AliOS-Things-master/hardware/chip/haas1000/drivers/services/audioflinger/
A Daudioflinger.h64 uint32_t af_stream_start(enum AUD_STREAM_ID_T id, enum AUD_STREAM_T stream);
65 uint32_t af_stream_stop(enum AUD_STREAM_ID_T id, enum AUD_STREAM_T stream);
66 uint32_t af_stream_pause(enum AUD_STREAM_ID_T id, enum AUD_STREAM_T stream);
67 uint32_t af_stream_restart(enum AUD_STREAM_ID_T id, enum AUD_STREAM_T stream);
68 uint32_t af_stream_close(enum AUD_STREAM_ID_T id, enum AUD_STREAM_T stream);
71 int af_stream_get_cur_dma_pos(enum AUD_STREAM_ID_T id, enum AUD_STREAM_T stream);
72 int af_stream_buffer_error(enum AUD_STREAM_ID_T id, enum AUD_STREAM_T stream);
84 void af_codec_tune_resample_rate(enum AUD_STREAM_T stream, float ratio);
85 void af_codec_direct_tune_resample_rate(enum AUD_STREAM_T stream, float ratio);
89 void af_codec_tune(enum AUD_STREAM_T stream, float ratio);
[all …]
/AliOS-Things-master/components/freetype/src/bzip2/
A Dftbzip2.c155 zip->stream = stream; in ft_bzip2_file_init()
165 stream = source; in ft_bzip2_file_init()
211 zip->stream = NULL; in ft_bzip2_file_done()
253 if ( stream->read ) in ft_bzip2_file_fill_input()
255 size = stream->read( stream, stream->pos, zip->input, in ft_bzip2_file_fill_input()
262 size = stream->size - stream->pos; in ft_bzip2_file_fill_input()
269 FT_MEM_COPY( zip->input, stream->base + stream->pos, size ); in ft_bzip2_file_fill_input()
271 stream->pos += size; in ft_bzip2_file_fill_input()
471 FT_ZERO( stream ); in FT_Stream_OpenBzip2()
487 stream->pos = 0; in FT_Stream_OpenBzip2()
[all …]
/AliOS-Things-master/components/freetype/src/psaux/
A Dafmparse.c72 ( ( (stream)->cursor < (stream)->limit ) ? *(stream)->cursor++ \
81 #define AFM_STATUS_EOC( stream ) \ argument
84 #define AFM_STATUS_EOL( stream ) \ argument
374 AFM_Stream stream = parser->stream; in afm_parser_read_vals() local
448 AFM_Stream stream = parser->stream; in afm_parser_next_key() local
533 AFM_Stream stream = NULL; in afm_parser_init() local
537 if ( FT_NEW( stream ) ) in afm_parser_init()
540 stream->cursor = stream->base = base; in afm_parser_init()
541 stream->limit = limit; in afm_parser_init()
547 parser->stream = stream; in afm_parser_init()
[all …]
/AliOS-Things-master/components/freetype/src/lzw/
A Dftlzw.c110 FT_Stream stream, in ft_lzw_file_init() argument
117 zip->stream = stream; in ft_lzw_file_init()
119 zip->memory = stream->memory; in ft_lzw_file_init()
146 zip->stream = NULL; in ft_lzw_file_done()
153 FT_Stream stream = zip->source; in ft_lzw_file_reset() local
367 FT_ZERO( stream ); in FT_Stream_OpenLZW()
368 stream->memory = memory; in FT_Stream_OpenLZW()
383 stream->pos = 0; in FT_Stream_OpenLZW()
384 stream->base = 0; in FT_Stream_OpenLZW()
385 stream->read = ft_lzw_stream_io; in FT_Stream_OpenLZW()
[all …]
/AliOS-Things-master/components/SDL2/src/image/external/zlib-1.2.11/contrib/minizip/
A Dioapi.c20 #define FTELLO_FUNC(stream) ftello(stream) argument
21 #define FSEEKO_FUNC(stream, offset, origin) fseeko(stream, offset, origin) argument
24 #define FTELLO_FUNC(stream) ftello64(stream) argument
25 #define FSEEKO_FUNC(stream, offset, origin) fseeko64(stream, offset, origin) argument
135 ret = (uLong)fread(buf, 1, (size_t)size, (FILE *)stream); in fread_file_func()
142 ret = (uLong)fwrite(buf, 1, (size_t)size, (FILE *)stream); in fwrite_file_func()
149 ret = ftell((FILE *)stream); in ftell_file_func()
157 ret = FTELLO_FUNC((FILE *)stream); in ftell64_file_func()
179 if (fseek((FILE *)stream, offset, fseek_origin) != 0) in fseek_file_func()
213 ret = fclose((FILE *)stream); in fclose_file_func()
[all …]

Completed in 677 milliseconds

1234567891011