Home
last modified time | relevance | path

Searched refs:read_end (Results 1 – 5 of 5) sorted by relevance

/third_party/libsoup/examples/
Dsimple-proxy.c74 TunnelEnd *write_end, *read_end; in tunnel_wrote_cb() local
93 read_end = &tunnel->server; in tunnel_wrote_cb()
96 read_end = &tunnel->client; in tunnel_wrote_cb()
100 if (write_end->nwrote < read_end->nread) { in tunnel_wrote_cb()
102 read_end->buffer + write_end->nwrote, in tunnel_wrote_cb()
103 read_end->nread - write_end->nwrote, in tunnel_wrote_cb()
107 g_input_stream_read_async (read_end->istream, in tunnel_wrote_cb()
108 read_end->buffer, BUFSIZE, in tunnel_wrote_cb()
120 TunnelEnd *read_end, *write_end; in tunnel_read_cb() local
138 read_end = &tunnel->client; in tunnel_read_cb()
[all …]
/third_party/ffmpeg/libavcodec/
Dflac_parser.c522 const uint8_t *read_end = buf; in flac_parse() local
594 while ((buf_size && read_end < buf + buf_size && in flac_parse()
602 read_end = read_start + MAX_FRAME_HEADER_SIZE; in flac_parse()
607 read_end = read_end + FFMIN(buf + buf_size - read_end, in flac_parse()
621 if ( av_fifo_space(fpc->fifo_buf) < read_end - read_start in flac_parse()
622 … && av_fifo_realloc2(fpc->fifo_buf, (read_end - read_start) + 2*av_fifo_size(fpc->fifo_buf)) < 0) { in flac_parse()
625 (read_end - read_start) + av_fifo_size(fpc->fifo_buf)); in flac_parse()
631 read_end - read_start, NULL); in flac_parse()
639 ((read_end - read_start) + (MAX_FRAME_HEADER_SIZE - 1)); in flac_parse()
652 if (read_end < buf + buf_size) { in flac_parse()
[all …]
/third_party/openssl/crypto/evp/
Dbio_enc.c34 unsigned char *read_start, *read_end; member
80 ctx->read_end = ctx->read_start = &(ctx->buf[BUF_OFFSET]); in enc_new()
149 if (ctx->read_start == ctx->read_end) { /* time to read more data */ in enc_read()
150 ctx->read_end = ctx->read_start = &(ctx->buf[BUF_OFFSET]); in enc_read()
153 ctx->read_end += i; in enc_read()
155 i = ctx->read_end - ctx->read_start; in enc_read()
190 ctx->read_start = ctx->read_end; in enc_read()
/third_party/libsoup/tests/
Dserver-test.c1180 TunnelEnd *write_end, *read_end; in tunnel_wrote_cb() local
1199 read_end = &tunnel->server; in tunnel_wrote_cb()
1202 read_end = &tunnel->client; in tunnel_wrote_cb()
1206 if (write_end->nwrote < read_end->nread) { in tunnel_wrote_cb()
1208 read_end->buffer + write_end->nwrote, in tunnel_wrote_cb()
1209 read_end->nread - write_end->nwrote, in tunnel_wrote_cb()
1213 g_input_stream_read_async (read_end->istream, in tunnel_wrote_cb()
1214 read_end->buffer, BUFSIZE, in tunnel_wrote_cb()
1226 TunnelEnd *read_end, *write_end; in tunnel_read_cb() local
1244 read_end = &tunnel->client; in tunnel_read_cb()
[all …]
/third_party/python/Modules/_io/
Dbufferedio.c225 Py_off_t read_end; member
350 (self->readable && self->read_end != -1)
358 if (VALID_READ_BUFFER(self) && self->read_end < self->pos) \
359 self->read_end = self->pos; \
364 ? (self->read_end - self->pos) : 0)
532 self->read_end = 0; in buffered_close()
1419 self->read_end = -1; in _bufferedreader_reset_buf()
1513 start = Py_SAFE_DOWNCAST(self->read_end, Py_off_t, Py_ssize_t); in _bufferedreader_fill_buffer()
1520 self->read_end = start + n; in _bufferedreader_fill_buffer()
1692 self->read_end = 0; in _bufferedreader_read_generic()
[all …]