/dports/www/trafficserver/trafficserver-9.1.1/src/traffic_server/ |
H A D | FetchSM.cc | 297 … 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 D | Data_Reader.h | 17 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 D | Data_Reader.cpp | 27 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 D | Data_Reader.h | 17 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 D | Data_Reader.cpp | 29 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 D | Data_Reader.h | 17 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 D | Data_Reader.cpp | 32 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 D | Data_Reader.h | 19 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 D | Data_Reader.cc | 27 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 D | pipe_stream.c | 70 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 D | Data_Reader.h | 21 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 D | Data_Reader.cpp | 39 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 D | s3c2410_sdi.c | 219 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 D | P_IOBuffer.h | 123 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 D | IOBuffer.cc | 111 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 D | Data_Reader.cpp | 42 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 D | QUICCryptoStream.cc | 87 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 D | test_IOBuffer.cc | 51 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 D | tsmemcache.cc | 279 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 D | request_buffer.c | 41 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 D | transfer.cc | 99 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 D | test_QUICIncomingFrameBuffer.cc | 40 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 D | HttpTunnel.cc | 126 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 D | stream_win.c | 37 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 D | stream_win.cpp | 70 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()
|