Home
last modified time | relevance | path

Searched refs:chunk_reader (Results 1 – 25 of 26) sorted by relevance

12

/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/src/trace_processor/
H A Dtrace_processor_storage_impl.cc65 if (!context_.chunk_reader) in Parse()
66 context_.chunk_reader.reset(new ForwardingTraceParser(&context_)); in Parse()
70 util::Status status = context_.chunk_reader->Parse(std::move(data), size); in Parse()
76 if (unrecoverable_parse_error_ || !context_.chunk_reader) in NotifyEndOfFile()
79 context_.chunk_reader->NotifyEndOfFile(); in NotifyEndOfFile()
H A Dtrace_processor_context.h59 std::unique_ptr<ChunkedTraceReader> chunk_reader; variable
/dports/games/stonesoup/crawl-0.27.1/crawl-ref/source/
H A Dpackage.h50 class chunk_reader
53 chunk_reader(package *parent, plen_t start);
65 chunk_reader(package *parent, const string &_name);
66 ~chunk_reader();
79 chunk_reader* reader(const string &name);
124 friend class chunk_reader; variable
H A Dpackage.cc287 chunk_reader* package::reader(const string &name) in reader()
290 return new chunk_reader(this, *ch); in reader()
526 chunk_reader rd(this, start); in read_directory()
805 void chunk_reader::init(plen_t start) in init()
828 chunk_reader::chunk_reader(package *parent, plen_t start) in chunk_reader() function in chunk_reader
836 chunk_reader::chunk_reader(package *parent, const string &_name) in chunk_reader() function in chunk_reader
846 chunk_reader::~chunk_reader() in ~chunk_reader()
861 plen_t chunk_reader::raw_read(void *data, plen_t len) in raw_read()
907 plen_t chunk_reader::read(void *data, plen_t len) in read()
945 void chunk_reader::read_all(vector<char> &data) in read_all()
H A Dtags.h143 chunk_reader *_chunk;
H A Dfiles.cc684 static bool _readln(chunk_reader &rd, char *buf) in _readln()
709 chunk_reader fdoll(save, "tdl"); in _fill_player_doll()
3049 chunk_reader inf(you.save, "lua"); in _restore_game()
H A Dinitfile.cc4297 chunk_reader inc(&save, chunk); in _edit_save()
4359 chunk_reader in(&save, chunk); in _edit_save()
4385 chunk_reader in(&save, chunk); in _edit_save()
H A Dtags.cc124 _chunk = new chunk_reader(save, chunkname); in reader()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/src/trace_processor/
H A Dtrace_processor_storage_impl.cc76 if (!context_.chunk_reader) in Parse()
77 context_.chunk_reader.reset(new ForwardingTraceParser(&context_)); in Parse()
81 util::Status status = context_.chunk_reader->Parse(std::move(data), size); in Parse()
87 if (unrecoverable_parse_error_ || !context_.chunk_reader) in NotifyEndOfFile()
90 context_.chunk_reader->NotifyEndOfFile(); in NotifyEndOfFile()
/dports/www/p5-Feersum/Feersum-1.410/t/
H A DUtils.pm147 my ($chunk_reader, $chunk_handler);
150 undef $chunk_reader;
156 $h->push_read(line => $CRLF, $chunk_reader);
158 $chunk_reader = sub {
163 undef $chunk_reader;
172 $h->push_read(line => $CRLF, $chunk_reader);
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/parquet/src/file/
H A Dfooter.rs46 pub fn parse_metadata<R: ChunkReader>(chunk_reader: &R) -> Result<ParquetMetaData> { in parse_metadata()
48 let file_size = chunk_reader.len(); in parse_metadata()
56 let default_end_len = min(DEFAULT_FOOTER_READ_SIZE, chunk_reader.len() as usize); in parse_metadata()
57 let mut default_end_reader = chunk_reader in parse_metadata()
58 .get_read(chunk_reader.len() - default_end_len as u64, default_end_len)?; in parse_metadata()
93 let complementary_end_read = chunk_reader.get_read( in parse_metadata()
H A Dserialized_reader.rs126 chunk_reader: Arc<R>, field
133 pub fn new(chunk_reader: R) -> Result<Self> { in new()
134 let metadata = footer::parse_metadata(&chunk_reader)?; in new()
136 chunk_reader: Arc::new(chunk_reader), in new()
172 let f = Arc::clone(&self.chunk_reader); in get_row_group()
186 chunk_reader: Arc<R>, field
192 fn new(chunk_reader: Arc<R>, metadata: &'a RowGroupMetaData) -> Self { in new()
194 chunk_reader, in new()
213 let file_chunk = self.chunk_reader.get_read(col_start, col_length as usize)?; in get_column_page_reader()
/dports/textproc/word2x/word2x-0.005/
H A Dreader.h51 class chunk_reader
63 inline chunk_reader(istream *f) in chunk_reader() function
68 inline ~chunk_reader(void) {}; /* Avoids compiler bug */ in ~chunk_reader()
76 class tok_seq: private chunk_reader
250 tok_seq(istream *in): chunk_reader(in) in tok_seq()
H A Dreader.cc107 void chunk_reader::read_chunk_raw(void) in read_chunk_raw()
180 struct chunk_rtn chunk_reader::read_chunk(void) in read_chunk()
H A DINTERNALS12 The output is fetched by chunk_reader::read_chunk_raw that assembles
/dports/net/p5-AnyEvent-Twitter-Stream/AnyEvent-Twitter-Stream-0.28/lib/AnyEvent/Twitter/
H A DStream.pm171 my $chunk_reader;
172 $chunk_reader = sub {
198 $handle->push_read(line => $chunk_reader);
221 $handle->push_read(line => $chunk_reader);
/dports/games/battletanks/btanks-0.9.8083/engine/luaxx/
H A Dstate.cpp45 static const char * chunk_reader(lua_State *L, void *data, size_t *size) { in chunk_reader() function
62 int err = lua_load(state, chunk_reader, &x, fname.c_str()); in load()
/dports/archivers/innoextract/innoextract-1.9/src/stream/
H A Dchunk.cpp120 chunk_reader::pointer chunk_reader::get(slice_reader & base, const chunk & chunk , const std::strin… in get()
H A Dchunk.hpp102 class chunk_reader { class
/dports/finance/beancount/beancount-2.3.3/experiments/v3/serialization/
H A DBUILD14 "@com_google_riegeli//riegeli/records:chunk_reader",
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/src/trace_processor/types/
H A Dtrace_processor_context.h62 std::unique_ptr<ChunkedTraceReader> chunk_reader; variable
/dports/net/py-eventlet/eventlet-0.33.0/tests/
H A Dwsgi_test.py1421 def chunk_reader(env, start_response): function
1431 self.site.application = chunk_reader
1451 def chunk_reader(env, start_response): function
1463 self.site.application = chunk_reader
1483 def chunk_reader(env, start_response): function
1495 self.site.application = chunk_reader
/dports/archivers/innoextract/innoextract-1.9/src/cli/
H A Dextract.cpp1149 stream::chunk_reader::pointer chunk_source; in process_file()
1151 chunk_source = stream::chunk_reader::get(*slice_reader, chunk.first, password); in process_file()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/src/trace_processor/importers/proto/
H A Dproto_trace_parser_unittest.cc238 context_.chunk_reader.reset(new ProtoTraceTokenizer(&context_)); in Tokenize()
240 context_.chunk_reader->Parse(std::move(raw_trace), trace_bytes.size()); in Tokenize()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/src/trace_processor/importers/proto/
H A Dproto_trace_parser_unittest.cc262 context_.chunk_reader.reset(new ProtoTraceReader(&context_)); in Tokenize()
264 context_.chunk_reader->Parse(std::move(raw_trace), trace_bytes.size()); in Tokenize()

12