Home
last modified time | relevance | path

Searched refs:read_avail (Results 1 – 25 of 282) sorted by relevance

12345678910>>...12

/dports/www/trafficserver/trafficserver-9.1.1/src/traffic_server/
H A DFetchSM.cc297 … resp_is_chunked > 0 ? chunked_handler.chunked_reader->read_avail() : resp_reader->read_avail()); in InvokePluginExt()
363 int64_t read_avail, read_done; in get_info_from_buffer() local
374 read_avail = reader->read_avail(); in get_info_from_buffer()
376 if (!read_avail) { in get_info_from_buffer()
403 read_avail -= bytes_used; in get_info_from_buffer()
410 while (read_avail > 0) { in get_info_from_buffer()
424 read_avail -= read_done; in get_info_from_buffer()
444 read_avail = reader->read_avail(); in get_info_from_buffer()
445 while (read_avail > 0) { in get_info_from_buffer()
459 read_avail -= read_done; in get_info_from_buffer()
[all …]
/dports/audio/libgme/game-music-emu-0.6.1/gme/
H A DData_Reader.h17 virtual long read_avail( void*, long n ) = 0;
64 long read_avail( void*, long );
78 long read_avail( void*, long );
94 long read_avail( void*, long );
107 long read_avail( void*, long );
122 long read_avail( void*, long );
144 long read_avail( void*, long );
H A DData_Reader.cpp27 long result = read_avail( p, s ); in read()
75 long Subset_Reader::read_avail( void* p, long s ) in read_avail() function in Subset_Reader
80 return in->read_avail( p, s ); in read_avail()
108 long Remaining_Reader::read_avail( void* out, long count ) in read_avail() function in Remaining_Reader
114 second = in->read_avail( (char*) out + first, second ); in read_avail()
141 long Mem_File_Reader::read_avail( void* p, long s ) in read_avail() function in Mem_File_Reader
172 long Callback_Reader::read_avail( void* out, long count ) in read_avail() function in Callback_Reader
211 long Std_File_Reader::read_avail( void* p, long s ) in read_avail() function in Std_File_Reader
293 long Gzip_File_Reader::read_avail( void* p, long s ) { return gzread( file_, p, s ); } in read_avail() function in Gzip_File_Reader
/dports/games/zdoom/zdoom-2.8.1/game-music-emu/gme/
H A DData_Reader.h17 virtual long read_avail( void*, long n ) = 0;
64 long read_avail( void*, long );
78 long read_avail( void*, long );
94 long read_avail( void*, long );
107 long read_avail( void*, long );
122 long read_avail( void*, long );
142 long read_avail( void*, long );
H A DData_Reader.cpp29 long result = read_avail( p, s ); in read()
77 long Subset_Reader::read_avail( void* p, long s ) in read_avail() function in Subset_Reader
82 return in->read_avail( p, s ); in read_avail()
110 long Remaining_Reader::read_avail( void* out, long count ) in read_avail() function in Remaining_Reader
116 second = in->read_avail( (char*) out + first, second ); in read_avail()
143 long Mem_File_Reader::read_avail( void* p, long s ) in read_avail() function in Mem_File_Reader
174 long Callback_Reader::read_avail( void* out, long count ) in read_avail() function in Callback_Reader
213 long Std_File_Reader::read_avail( void* p, long s ) in read_avail() function in Std_File_Reader
295 long Gzip_File_Reader::read_avail( void* p, long s ) { return gzread( file_, p, s ); } in read_avail() function in Gzip_File_Reader
/dports/games/SRB2/SRB2-SRB2_release_2.2.9/libs/gme/gme/
H A DData_Reader.h17 virtual long read_avail( void*, long n ) = 0;
64 long read_avail( void*, long );
78 long read_avail( void*, long );
94 long read_avail( void*, long );
107 long read_avail( void*, long );
122 long read_avail( void*, long );
144 long read_avail( void*, long );
H A DData_Reader.cpp32 long result = read_avail( p, s ); in read()
83 long Subset_Reader::read_avail( void* p, long s ) in read_avail() function in Subset_Reader
89 return in->read_avail( p, s ); in read_avail()
118 long Remaining_Reader::read_avail( void* out, long count ) in read_avail() function in Remaining_Reader
125 second = in->read_avail( (char*) out + first, second ); in read_avail()
153 long Mem_File_Reader::read_avail( void* p, long s ) in read_avail() function in Mem_File_Reader
186 long Callback_Reader::read_avail( void* out, long count ) in read_avail() function in Callback_Reader
226 long Std_File_Reader::read_avail( void* p, long s ) in read_avail() function in Std_File_Reader
309 long Gzip_File_Reader::read_avail( void* p, long s ) { return gzread( file_, p, s ); } in read_avail() function in Gzip_File_Reader
/dports/multimedia/audacious-plugins/audacious-plugins-4.1/src/console/
H A DData_Reader.h19 virtual long read_avail( void*, long n ) = 0;
66 long read_avail( void*, long );
80 long read_avail( void*, long );
96 long read_avail( void*, long );
109 long read_avail( void*, long );
124 long read_avail( void*, long );
143 long read_avail( void*, long );
H A DData_Reader.cc27 long result = read_avail( p, s ); in read()
75 long Subset_Reader::read_avail( void* p, long s ) in read_avail() function in Subset_Reader
80 return in->read_avail( p, s ); in read_avail()
108 long Remaining_Reader::read_avail( void* out, long count ) in read_avail() function in Remaining_Reader
114 second = in->read_avail( (char*) out + first, second ); in read_avail()
141 long Mem_File_Reader::read_avail( void* p, long s ) in read_avail() function in Mem_File_Reader
172 long Callback_Reader::read_avail( void* out, long count ) in read_avail() function in Callback_Reader
211 long Std_File_Reader::read_avail( void* p, long s ) in read_avail() function in Std_File_Reader
295 long Gzip_File_Reader::read_avail( void* p, long s ) { return gzread( file_, p, s ); } in read_avail() function in Gzip_File_Reader
/dports/dns/yadifa/yadifa-2.5.3-10333/lib/dnscore/src/
H A Dpipe_stream.c70 u32 read_avail; member
110 data->read_avail += chunk_len; in pipe_stream_output_write()
179 while((remaining > 0) && (data->read_avail > 0)) in pipe_stream_input_read()
181 u32 chunk_len = MIN(data->buffer_size - data->read_offset, data->read_avail); in pipe_stream_input_read()
186 data->read_avail -= chunk_len; in pipe_stream_input_read()
213 while((remaining > 0) && (data->read_avail > 0)) in pipe_stream_input_skip()
215 u32 chunk_len = MIN(data->buffer_size - data->read_offset, data->read_avail); in pipe_stream_input_skip()
219 data->read_avail -= chunk_len; in pipe_stream_input_skip()
306 return data->read_avail; in pipe_stream_read_available()
/dports/audio/zmusic/ZMusic-1.1.8/thirdparty/game-music-emu/gme/
H A DData_Reader.h21 virtual long read_avail( void*, long n ) = 0;
68 long read_avail( void*, long );
88 long read_avail( void*, long );
112 long read_avail( void*, long );
125 long read_avail( void*, long );
140 long read_avail( void*, long );
H A DData_Reader.cpp39 long result = read_avail( p, s );
90 long Subset_Reader::read_avail( void* p, long s )
96 return in->read_avail( p, s );
125 long Remaining_Reader::read_avail( void* out, long count )
132 second = in->read_avail( (char*) out + first, second );
178 long Mem_File_Reader::read_avail( void* p, long s )
285 long Callback_Reader::read_avail( void* out, long count )
372 long Std_File_Reader::read_avail( void* p, long s )
/dports/emulators/x49gp/x49gp/x49gp-code/
H A Ds3c2410_sdi.c219 unsigned int read_avail, write_avail; in s3c2410_sdi_read() local
232 read_avail = sdi->nr_read_data - sdi->read_index; in s3c2410_sdi_read()
233 if (read_avail > 0) { in s3c2410_sdi_read()
263 sdi->sdidcnt = read_avail; in s3c2410_sdi_read()
270 read_avail = sdi->nr_read_data - sdi->read_index; in s3c2410_sdi_read()
271 if (read_avail > 63) in s3c2410_sdi_read()
273 else if (read_avail > 31) in s3c2410_sdi_read()
282 read_avail = sdi->nr_read_data - sdi->read_index; in s3c2410_sdi_read()
283 if (read_avail) { in s3c2410_sdi_read()
307 unsigned int read_avail, write_avail; in s3c2410_sdi_write() local
[all …]
/dports/www/trafficserver/trafficserver-9.1.1/iocore/eventsystem/
H A DP_IOBuffer.h123 int64_t max_bytes = b->read_avail(); in iobufferblock_skip()
517 IOBufferReader::read_avail() in read_avail() function
523 t += b->read_avail(); in read_avail()
542 t += b->read_avail(); in is_read_avail_more_than()
564 int64_t r = block->read_avail(); in consume()
570 r = block->read_avail(); in consume()
582 int64_t bytes = b->read_avail();
806 while (b->read_avail()) { in append_block_internal()
822 ink_assert(b->read_avail()); in append_block()
941 int64_t ss = reader.read_avail(); in max_read_avail()
[all …]
H A DIOBuffer.cc111 int64_t max_bytes = b->read_avail(); in write()
150 return (this->_writer->read_avail() > size); in is_max_read_avail_more_than()
190 int64_t max_bytes = b->read_avail(); in memchr()
225 int64_t max_bytes = b->read_avail(); in memcpy()
257 int64_t block_bytes = blocks->read_avail(); in write()
296 zret = b->read_avail(); in write()
320 while (_head != nullptr && size > 0 && (bytes = _head->read_avail()) > 0) { in consume()
/dports/games/libretro-quicknes/QuickNES_Core-901248a/nes_emu/
H A DData_Reader.cpp42 const char * Data_Reader::read_avail( void* p, int* n_ ) in read_avail() function in Data_Reader
63 const char * Data_Reader::read_avail( void* p, long* n ) in read_avail() function in Data_Reader
66 const char * err = read_avail( p, &i ); in read_avail()
/dports/www/trafficserver/trafficserver-9.1.1/iocore/net/quic/
H A DQUICCryptoStream.cc87 QUICCryptoStream::read_avail() in read_avail() function in QUICCryptoStream
89 return this->_read_buffer_reader->read_avail(); in read_avail()
135 uint64_t bytes_avail = this->_write_buffer_reader->read_avail(); in generate_frame()
144 ink_assert(static_cast<uint64_t>(block->read_avail()) == frame_payload_size); in generate_frame()
/dports/www/trafficserver/trafficserver-9.1.1/iocore/eventsystem/unit_tests/
H A Dtest_IOBuffer.cc51 read_avail_len1 += b1reader->read_avail();
57 read_avail_len2 += b2reader->read_avail();
84 CHECK(miob_r->read_avail() == 0);
106 CHECK(miob_r->read_avail() == sizeof(buf));
126 CHECK(miob_r->read_avail() == sizeof(buf));
146 CHECK(miob_r->read_avail() == sizeof(buf));
166 CHECK(miob_r->read_avail() == sizeof(buf));
/dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/memcache/
H A Dtsmemcache.cc279 int64_t avail = reader->read_avail(); in write_binary_error()
295 int64_t avail = reader->read_avail(); in swallow_then_read_event()
310 int64_t avail = reader->read_avail(); in swallow_cmd_then_read_from_client_event()
382 return writer->read_avail(); in write_binary_response()
702 int read_avail = reader->read_avail(); in get_ascii_input() local
703 if (block_read_avail == read_avail) { in get_ascii_input()
707 int e = read_avail; in get_ascii_input()
837 int64_t a = reader->read_avail(); in ascii_set_event()
876 int64_t a = reader->read_avail(); in ascii_set_event()
1487 if (reader->read_avail() < 1) { in read_from_client_event()
[all …]
/dports/www/trafficserver/trafficserver-9.1.1/example/plugins/c-api/request_buffer/
H A Drequest_buffer.c41 int64_t read_avail = TSIOBufferReaderAvail(post_buffer_reader); in request_body_get() local
42 if (read_avail == 0) { in request_body_get()
47 ret = (char *)TSmalloc(sizeof(char) * read_avail); in request_body_get()
/dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/slice/
H A Dtransfer.cc99 int64_t const read_avail = TSIOBufferReaderAvail(reader); in transfer_all_bytes() local
101 if (0 < read_avail) { in transfer_all_bytes()
102 int64_t const copied = TSIOBufferCopy(output_buf, reader, read_avail, 0); in transfer_all_bytes()
/dports/www/trafficserver/trafficserver-9.1.1/iocore/net/quic/test/
H A Dtest_QUICIncomingFrameBuffer.cc40 CHECK(block_1024->read_avail() == 1024);
44 CHECK(block_0->read_avail() == 0);
132 CHECK(block_1024->read_avail() == 1024);
136 CHECK(block_0->read_avail() == 0);
214 CHECK(block_1024->read_avail() == 1024);
218 CHECK(block_0->read_avail() == 0);
/dports/www/trafficserver/trafficserver-9.1.1/proxy/http/
H A DHttpTunnel.cc126 while (chunked_reader->read_avail() > 0 && !done) { in read_size()
200 moved = std::min(bytes_left, chunked_reader->read_avail()); in transfer_bytes()
403 n += static_cast<uint64_t>(r->read_avail()); in backlog()
622 p->init_bytes_done = reader_start->read_avail(); in add_producer()
796 p->chunked_handler.chunked_reader->read_avail()); in producer_run()
854 ink_assert(c->skip_bytes <= c->buffer_reader->read_avail()); in producer_run()
865 p->buffer_start->read_avail(), HttpConfig::m_master.post_copy_size); in producer_run()
868 if (p->buffer_start->read_avail() > HttpConfig::m_master.post_copy_size) { in producer_run()
897 p->chunked_handler.chunked_reader->read_avail()); in producer_run()
958 int tmp = c->buffer_reader->read_avail(); in producer_run()
[all …]
/dports/sysutils/watchman/watchman-4.5.0/
H A Dstream_win.c37 int read_avail; member
155 int nread = MIN(*size_ptr, h->read_avail); in move_from_read_buffer()
167 h->read_avail -= nread; in move_from_read_buffer()
174 memmove(h->read_buf, h->read_cursor, h->read_avail); in move_from_read_buffer()
201 h->read_avail += bytes; in win_read_handle_completion()
261 target = h->read_cursor + h->read_avail; in win_read_non_blocking()
268 if (h->read_avail == 0) { in win_read_non_blocking()
297 h->read_avail += bytes; in win_read_non_blocking()
/dports/sysutils/py-pywatchman/watchman-4.9.0/
H A Dstream_win.cpp70 int read_avail{0}; member in win_handle
228 int nread = std::min(*size_ptr, h->read_avail); in move_from_read_buffer()
240 h->read_avail -= nread; in move_from_read_buffer()
247 memmove(h->read_buf, h->read_cursor, h->read_avail); in move_from_read_buffer()
281 h->read_avail += bytes; in win_read_handle_completion()
349 target = h->read_cursor + h->read_avail; in win_read_non_blocking()
356 if (h->read_avail == 0) { in win_read_non_blocking()
388 h->read_avail += bytes; in win_read_non_blocking()

12345678910>>...12