Home
last modified time | relevance | path

Searched refs:buffer_reader (Results 1 – 25 of 47) sorted by relevance

12

/dports/ftp/filezilla/filezilla-3.55.1/src/engine/
H A Dstring_reader.cpp91 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 Dstring_reader.h30 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 Dbuffer.i32 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 Dbuffer.cc213 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 Dbuffer.h98 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 Druntime_types.h38 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 DCacheTest.cc48 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 DCachePages.cc47 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 Dswap_queue_unittest.cc179 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 Dswap_queue_unittest.cc179 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 Dswap_queue_unittest.cc178 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 Dswap_queue_unittest.cc179 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 Dswap_queue_unittest.cc179 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 Dswap_queue_unittest.cc178 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 Dswap_queue_unittest.cc178 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 Dswap_queue_unittest.cc178 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 Dswap_queue_unittest.cc178 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 DHttpTunnel.cc833 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 DRegressionHttpTransact.cc46 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 Dtest_orc.py180 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 Dipc.py222 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 Dcompressed_test.cc85 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 Dcompressed_test.cc85 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 Dcompressed_test.cc85 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 Dipc.py230 buffer_reader = pa.BufferReader(buf)
231 with pa.RecordBatchStreamReader(buffer_reader) as reader:

12