/dports/ftp/filezilla/filezilla-3.55.1/src/engine/ |
H A D | string_reader.cpp | 91 buffer_reader::buffer_reader(std::wstring const& name, CFileZillaEnginePrivate & engine, fz::event_… in buffer_reader() function in buffer_reader 99 buffer_reader::buffer_reader(std::wstring const& name, CFileZillaEnginePrivate & engine, fz::event_… in buffer_reader() function in buffer_reader 107 std::unique_ptr<buffer_reader> buffer_reader::create(std::wstring const& name, CFileZillaEnginePriv… in create() 109 std::unique_ptr<buffer_reader> ret(new buffer_reader(name, engine, handler, data)); in create() 118 std::unique_ptr<buffer_reader> buffer_reader::create(std::wstring const& name, CFileZillaEnginePriv… in create() 120 std::unique_ptr<buffer_reader> ret(new buffer_reader(name, engine, handler, data)); in create() 129 read_result buffer_reader::read() in read() 147 aio_result buffer_reader::seek(uint64_t offset, uint64_t max_size) in seek()
|
H A D | string_reader.h | 30 class buffer_reader final : public reader_base 36 …static std::unique_ptr<buffer_reader> create(std::wstring const& name, CFileZillaEnginePrivate & e… 37 …static std::unique_ptr<buffer_reader> create(std::wstring const& name, CFileZillaEnginePrivate & e… 42 …explicit buffer_reader(std::wstring const& name, CFileZillaEnginePrivate & engine, fz::event_handl… 43 …explicit buffer_reader(std::wstring const& name, CFileZillaEnginePrivate & engine, fz::event_handl…
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/swig/ |
H A D | buffer.i | 32 class gr::buffer_reader; 33 typedef boost::shared_ptr<gr::buffer_reader> gr::buffer_reader_sptr; 34 %template(buffer_reader_sptr) boost::shared_ptr<gr::buffer_reader>; 35 %ignore gr::buffer_reader; 52 class gr::buffer_reader 55 ~buffer_reader(); 59 buffer_reader(gr::buffer_sptr buffer, unsigned int read_index, gr::block_sptr link);
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/ |
H A D | buffer.cc | 213 new buffer_reader(buf, buf->index_sub(buf->d_write_index, nzero_preload), link)); in buffer_add_reader() 220 void buffer::drop_reader(buffer_reader* reader) in drop_reader() 222 std::vector<buffer_reader*>::iterator result = in drop_reader() 293 buffer_reader::buffer_reader(buffer_sptr buffer, unsigned int read_index, block_sptr link) in buffer_reader() function in gr::buffer_reader 303 buffer_reader::~buffer_reader() in ~buffer_reader() 309 void buffer_reader::declare_sample_delay(unsigned delay) in declare_sample_delay() 315 unsigned buffer_reader::sample_delay() const { return d_attr_delay; } in sample_delay() 317 int buffer_reader::items_available() const in items_available() 322 const void* buffer_reader::read_pointer() in read_pointer() 327 void buffer_reader::update_read_pointer(int nitems) in update_read_pointer() [all …]
|
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/include/gnuradio/ |
H A D | buffer.h | 98 buffer_reader* reader(size_t index) { return d_readers[index]; } in reader() 153 friend class buffer_reader; 172 std::vector<buffer_reader*> d_readers; 228 void drop_reader(buffer_reader* reader); 253 class GR_RUNTIME_API buffer_reader 256 ~buffer_reader(); 354 buffer_reader(buffer_sptr buffer, unsigned int read_index, block_sptr link);
|
H A D | runtime_types.h | 38 class buffer_reader; variable 48 typedef boost::shared_ptr<buffer_reader> buffer_reader_sptr;
|
/dports/www/trafficserver/trafficserver-9.1.1/iocore/cache/ |
H A D | CacheTest.cc | 48 if (buffer_reader) { in ~CacheTestSM() 49 buffer->dealloc_reader(buffer_reader); in ~CacheTestSM() 99 buffer_reader = buffer->alloc_reader(); in event_handler() 113 buffer_reader->consume(buffer_reader->read_avail()); in event_handler() 133 buffer_reader = buffer->alloc_reader(); in event_handler() 198 if (buffer_reader) { in event_handler() 199 buffer->dealloc_reader(buffer_reader); in event_handler() 200 buffer_reader = nullptr; in event_handler() 246 int64_t avail = buffer_reader->read_avail(); in check_buffer() 263 buffer_reader->read(&b[0], l); in check_buffer() [all …]
|
H A D | CachePages.cc | 47 IOBufferReader *buffer_reader; member 74 buffer_reader(nullptr), in ShowCache() 321 if (buffer_reader) { in handleCacheEvent() 322 buffer->dealloc_reader(buffer_reader); in handleCacheEvent() 323 buffer_reader = nullptr; in handleCacheEvent() 431 buffer_reader = buffer->alloc_reader(); in handleCacheEvent() 435 buffer_reader->consume(buffer_reader->read_avail()); in handleCacheEvent()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/rtc_base/ |
H A D | swap_queue_unittest.cc | 179 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 198 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 200 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 201 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/net-im/tg_owt/tg_owt-d578c76/src/rtc_base/ |
H A D | swap_queue_unittest.cc | 179 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 198 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 200 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 201 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/base/ |
H A D | swap_queue_unittest.cc | 178 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 197 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 199 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 200 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/rtc_base/ |
H A D | swap_queue_unittest.cc | 179 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 198 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 200 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 201 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/rtc_base/ |
H A D | swap_queue_unittest.cc | 179 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 198 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 200 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 201 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/rtc_base/ |
H A D | swap_queue_unittest.cc | 178 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 197 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 199 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 200 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/rtc_base/ |
H A D | swap_queue_unittest.cc | 178 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 197 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 199 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 200 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/trunk/webrtc/rtc_base/ |
H A D | swap_queue_unittest.cc | 178 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 197 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 199 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 200 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/multimedia/mswebrtc/mswebrtc-1.1.1/webrtc/webrtc/common_audio/ |
H A D | swap_queue_unittest.cc | 178 std::vector<int16_t> buffer_reader(kFrameLength, 0); in TEST() local 197 EXPECT_TRUE(queue.Remove(&buffer_reader)); in TEST() 199 for (size_t j = 0; j < buffer_reader.size(); j++) { in TEST() 200 EXPECT_EQ(buffer_reader[j], samples[k * kFrameLength + j]); in TEST()
|
/dports/www/trafficserver/trafficserver-9.1.1/proxy/http/ |
H A D | HttpTunnel.cc | 833 c->buffer_reader = p->read_buffer->clone_reader(p->buffer_start); in producer_run() 845 c->buffer_reader = p->chunked_handler.chunked_buffer->clone_reader(chunked_buffer_start); in producer_run() 849 c->buffer_reader = p->read_buffer->clone_reader(p->buffer_start); in producer_run() 854 ink_assert(c->skip_bytes <= c->buffer_reader->read_avail()); in producer_run() 855 c->buffer_reader->consume(c->skip_bytes); in producer_run() 958 int tmp = c->buffer_reader->read_avail(); in producer_run() 967 c->write_vio = c->vc->do_io_write(this, c_write, c->buffer_reader); in producer_run() 1338 ink_assert(c->buffer_reader); in consumer_handler() 1368 if (c->buffer_reader) { in consumer_handler() 1369 c->buffer_reader->mbuf->dealloc_reader(c->buffer_reader); in consumer_handler() [all …]
|
H A D | RegressionHttpTransact.cc | 46 IOBufferReader *buffer_reader = read_buffer->alloc_reader(); in setup_client_request() local 52 …sm->t_state.hdr_info.client_request.parse_req(&httpParser, buffer_reader, &bytes_used, true /* eos… in setup_client_request()
|
/dports/databases/arrow/apache-arrow-6.0.1/python/pyarrow/tests/ |
H A D | test_orc.py | 180 buffer_reader = pa.BufferReader(buffer_output_stream.getvalue()) 181 orc_file = orc.ORCFile(buffer_reader) 189 buffer_reader = pa.BufferReader(buffer_output_stream.getvalue()) 190 orc_file = orc.ORCFile(buffer_reader)
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/python/pyarrow/ |
H A D | ipc.py | 222 buffer_reader = pa.BufferReader(buf) 223 with pa.RecordBatchStreamReader(buffer_reader) as reader:
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/io/ |
H A D | compressed_test.cc | 85 auto buffer_reader = std::make_shared<BufferReader>(compressed); in RunCompressedInputStream() local 86 ARROW_ASSIGN_OR_RAISE(auto stream, CompressedInputStream::Make(codec, buffer_reader)); in RunCompressedInputStream() 198 auto buffer_reader = std::make_shared<BufferReader>(Buffer::Wrap(compressed_data)); in TEST_P() local 200 CompressedInputStream::Make(codec.get(), buffer_reader)); in TEST_P()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/arrow/io/ |
H A D | compressed_test.cc | 85 auto buffer_reader = std::make_shared<BufferReader>(compressed); in RunCompressedInputStream() local 86 ARROW_ASSIGN_OR_RAISE(auto stream, CompressedInputStream::Make(codec, buffer_reader)); in RunCompressedInputStream() 198 auto buffer_reader = std::make_shared<BufferReader>(Buffer::Wrap(compressed_data)); in TEST_P() local 200 CompressedInputStream::Make(codec.get(), buffer_reader)); in TEST_P()
|
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/io/ |
H A D | compressed_test.cc | 85 auto buffer_reader = std::make_shared<BufferReader>(compressed); in RunCompressedInputStream() local 86 ARROW_ASSIGN_OR_RAISE(auto stream, CompressedInputStream::Make(codec, buffer_reader)); in RunCompressedInputStream() 198 auto buffer_reader = std::make_shared<BufferReader>(Buffer::Wrap(compressed_data)); in TEST_P() local 200 CompressedInputStream::Make(codec.get(), buffer_reader)); in TEST_P()
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/python/pyarrow/ |
H A D | ipc.py | 230 buffer_reader = pa.BufferReader(buf) 231 with pa.RecordBatchStreamReader(buffer_reader) as reader:
|