Home
last modified time | relevance | path

Searched refs:file_ (Results 1 – 25 of 34) sorted by relevance

12

/rocksdb-6.9/env/
Denv_encryption.cc26 std::unique_ptr<SequentialFile> file_; member in ROCKSDB_NAMESPACE::EncryptedSequentialFile
65 auto status = file_->Skip(n); in Skip()
80 return file_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
109 std::unique_ptr<RandomAccessFile> file_; member in ROCKSDB_NAMESPACE::EncryptedRandomAccessFile
161 return file_->GetUniqueId(id, max_size); in GetUniqueId()
173 return file_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
189 std::unique_ptr<WritableFile> file_; member in ROCKSDB_NAMESPACE::EncryptedWritableFile
217 status = file_->Append(dataToAppend); in Append()
255 return file_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
309 std::unique_ptr<RandomRWFile> file_; member in ROCKSDB_NAMESPACE::EncryptedRandomRWFile
[all …]
Dmock_env.cc183 file_->Ref(); in MockSequentialFile()
197 if (pos_ > file_->Size()) { in Skip()
209 MemFile* file_; member in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockSequentialFile
215 explicit MockRandomAccessFile(MemFile* file) : file_(file) { file_->Ref(); } in MockRandomAccessFile()
225 MemFile* file_; member in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockRandomAccessFile
230 explicit MockRandomRWFile(MemFile* file) : file_(file) { file_->Ref(); } in MockRandomRWFile()
235 return file_->Write(offset, data); in Write()
250 MemFile* file_; member in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockRandomRWFile
257 file_->Ref(); in MockWritableFile()
296 MemFile* file_; member in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockWritableFile
[all …]
Denv_hdfs.cc285 HdfsWritableFile* file_; member in ROCKSDB_NAMESPACE::__anone484b1950111::HdfsLogger
290 file_->getName().c_str()); in HdfsCloseHelper()
302 : file_(f), gettid_(gettid) { in HdfsLogger()
304 file_->getName().c_str()); in HdfsLogger()
373 file_->Append(base, p-base); in Logv()
374 file_->Flush(); in Logv()
Dio_posix.cc213 file_(file), in PosixSequentialFile()
222 assert(file_); in ~PosixSequentialFile()
223 fclose(file_); in ~PosixSequentialFile()
237 clearerr(file_); in Read()
238 r = fread_unlocked(scratch, 1, n, file_); in Read()
239 } while (r == 0 && ferror(file_) && errno == EINTR); in Read()
242 if (feof(file_)) { in Read()
246 clearerr(file_); in Read()
296 if (fseek(file_, static_cast<long int>(n), SEEK_CUR)) { in Skip()
/rocksdb-6.9/port/win/
Dwin_logger.cc34 file_(file), in WinLogger()
40 assert(file_ != NULL); in WinLogger()
41 assert(file_ != INVALID_HANDLE_VALUE); in WinLogger()
45 assert(file_ != INVALID_HANDLE_VALUE); in DebugWriter()
47 BOOL ret = WriteFile(file_, str, len, &bytesWritten, NULL); in DebugWriter()
64 if (INVALID_HANDLE_VALUE != file_) { in CloseInternal()
65 BOOL ret = FlushFileBuffers(file_); in CloseInternal()
71 ret = CloseHandle(file_); in CloseInternal()
78 file_ = INVALID_HANDLE_VALUE; in CloseInternal()
85 assert(file_ != INVALID_HANDLE_VALUE); in Flush()
[all …]
Dwin_logger.h53 HANDLE file_;
/rocksdb-6.9/file/
Dsequence_file_reader.cc30 size_t alignment = file_->GetRequiredBufferAlignment(); in Read()
39 s = file_->PositionedRead(aligned_offset, size, IOOptions(), &tmp, in Read()
49 s = file_->Read(n, IOOptions(), result, scratch, nullptr); in Read()
62 return file_->Skip(n); in Skip()
74 : file_(std::move(file)), in ReadaheadSequentialFile()
75 alignment_(file_->GetRequiredBufferAlignment()), in ReadaheadSequentialFile()
108 s = file_->Read(n, opts, result, scratch + cached_len, dbg); in Read()
145 s = file_->Skip(n); in Skip()
157 return file_->PositionedRead(offset, n, opts, result, scratch, dbg); in PositionedRead()
163 return file_->InvalidateCache(offset, length); in InvalidateCache()
[all …]
Dsequence_file_reader.h24 std::unique_ptr<FSSequentialFile> file_;
31 : file_(std::move(_file)), file_name_(_file_name) {} in SequentialFileReader()
36 : file_(NewReadaheadSequentialFile(std::move(_file), _readahead_size)), in SequentialFileReader()
44 file_ = std::move(o.file_);
55 FSSequentialFile* file() { return file_.get(); } in file()
59 bool use_direct_io() const { return file_->use_direct_io(); } in use_direct_io()
Dreadahead_raf.cc24 : file_(std::move(file)), in ReadaheadRandomAccessFile()
25 alignment_(file_->GetRequiredBufferAlignment()), in ReadaheadRandomAccessFile()
42 return file_->Read(offset, n, result, scratch); in Read()
93 return file_->GetUniqueId(id, max_size); in GetUniqueId()
96 void Hint(AccessPattern pattern) override { file_->Hint(pattern); } in Hint()
101 return file_->InvalidateCache(offset, length); in InvalidateCache()
104 bool use_direct_io() const override { return file_->use_direct_io(); } in use_direct_io()
135 Status s = file_->Read(offset, n, &result, buffer_.BufferStart()); in ReadIntoBuffer()
144 const std::unique_ptr<RandomAccessFile> file_; member in ROCKSDB_NAMESPACE::__anon832aeac60111::ReadaheadRandomAccessFile
Drandom_access_file_reader.h53 std::unique_ptr<FSRandomAccessFile> file_; variable
69 : file_(std::move(raf)), in file_() function
95 file_ = std::move(o.file_);
129 return file_->Prefetch(offset, n, IOOptions(), nullptr); in Prefetch()
132 FSRandomAccessFile* file() { return file_.get(); } in file()
136 bool use_direct_io() const { return file_->use_direct_io(); } in use_direct_io()
Drandom_access_file_reader.cc38 size_t alignment = file_->GetRequiredBufferAlignment(); in Read()
67 s = file_->Read(aligned_offset + buf.CurrentSize(), allowed, in Read()
121 s = file_->Read(offset + pos, allowed, IOOptions(), &tmp_result, in Read()
212 size_t alignment = file_->GetRequiredBufferAlignment(); in MultiRead()
249 s = file_->MultiRead(fs_reqs, num_fs_reqs, IOOptions(), nullptr); in MultiRead()
/rocksdb-6.9/table/plain/
Dplain_table_builder.cc71 file_(file), in PlainTableBuilder()
148 io_status_ = encoder_.AppendKey(key, file_, &offset_, meta_bytes_buf, in Add()
161 io_status_ = file_->Append(Slice(meta_bytes_buf, meta_bytes_buf_size)); in Add()
166 io_status_ = file_->Append(value); in Add()
261 IOStatus s = WriteBlock(property_block_builder.Finish(), file_, &offset_, in Finish()
270 io_status_ = WriteBlock(meta_index_builer.Finish(), file_, &offset_, in Finish()
284 io_status_ = file_->Append(footer_encoding); in Finish()
305 if (file_ != nullptr) { in GetFileChecksum()
306 return file_->GetFileChecksum(); in GetFileChecksum()
313 if (file_ != nullptr) { in GetFileChecksumFuncName()
[all …]
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder.cc58 file_(file), in CuckooTableBuilder()
304 io_status_ = file_->Append(Slice(unused_bucket)); in Finish()
307 io_status_ = file_->Append(GetKey(bucket.vector_idx)); in Finish()
368 io_status_ = file_->Append(property_block); in Finish()
381 io_status_ = file_->Append(meta_index_block); in Finish()
392 io_status_ = file_->Append(footer_encoding); in Finish()
408 return file_->GetFileSize(); in FileSize()
520 if (file_ != nullptr) { in GetFileChecksum()
521 return file_->GetFileChecksum(); in GetFileChecksum()
528 if (file_ != nullptr) { in GetFileChecksumFuncName()
[all …]
Dcuckoo_table_reader.cc40 : file_(std::move(file)), in CuckooTableReader()
60 status_ = ReadTableProperties(file_.get(), file_size, kCuckooTableMagicNumber, in CuckooTableReader()
140 status_ = file_->Read(0, static_cast<size_t>(file_size), &file_data_, nullptr, in CuckooTableReader()
/rocksdb-6.9/logging/
Denv_logger.h34 file_(std::move(writable_file), fname, options, env), in Logger()
51 file_.Flush(); in FlushLocked()
68 const auto close_status = file_.Close(); in CloseHelper()
137 file_.Append(Slice(base, p - base)); in Logv()
153 return file_.GetFileSize(); in GetLogFileSize()
157 WritableFileWriter file_;
Dposix_logger.h39 ret = fclose(file_); in PosixCloseHelper()
45 FILE* file_; variable
61 file_(f), in Logger()
79 fflush(file_); in Flush()
166 size_t sz = fwrite(base, 1, write_size, file_); in Logv()
/rocksdb-6.9/util/
Dfilelock_test.cc20 std::string file_; member in ROCKSDB_NAMESPACE::LockTest
24 : file_(test::PerThreadDBPath("db_testlock_file")), in LockTest()
32 return env_->LockFile(file_, db_lock); in LockFile()
65 int fd = open(file_.c_str(), O_RDWR | O_CREAT, 0644); in CheckFileLock()
68 fprintf( stderr, "Open on on file %s failed.\n",file_.c_str()); in CheckFileLock()
/rocksdb-6.9/table/
Dblock_fetcher.cc57 file_->file_name() + " offset " + ToString(handle_.offset()) + in CheckBlockChecksum()
63 ToString(value) + " in " + file_->file_name() + " offset " + in CheckBlockChecksum()
218 status_ = file_->Read(handle_.offset(), block_size_ + kBlockTrailerSize, in ReadBlockContents()
249 file_->file_name() + " offset " + in ReadBlockContents()
Dblock_fetcher.h49 : file_(file), in file_() function
71 RandomAccessFileReader* file_; variable
/rocksdb-6.9/utilities/blob_db/
Dblob_log_reader.cc21 : file_(std::move(file_reader)), in Reader()
30 file_->Read(next_byte_, static_cast<size_t>(size), slice, buf, nullptr); in ReadSlice()
43 assert(file_.get() != nullptr); in ReadHeader()
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file.cc278 if (file_) { in ~WriteableCacheFile()
304 s = NewWritableCacheFile(env_, Path(), &file_); in Create()
406 assert(file_); in DispatchBuffer()
420 writer_->Write(file_.get(), buf, file_off, in DispatchBuffer()
519 file_.reset(); in Close()
594 Status s = io.file_->Append(data); in DispatchIO()
Dblock_cache_tier_file.h240 std::unique_ptr<WritableFile> file_; // RocksDB Env file abstraction variable
263 : file_(file), buf_(buf), file_off_(file_off), callback_(callback) {} in IO()
269 WritableFile* file_ = nullptr; // File to write to member
/rocksdb-6.9/tools/
Dsst_dump_tool.cc95 file_.reset(new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(file), in GetTableReader()
99 s = ReadFooterFromFile(file_.get(), nullptr /* prefetch_buffer */, in GetTableReader()
111 file_.reset(new RandomAccessFileReader( in GetTableReader()
116 if (ReadTableProperties(magic_number, file_.get(), file_size).ok()) { in GetTableReader()
140 std::move(file_), file_size, &table_reader_, /*enable_prefetch=*/false); in NewTableReader()
147 std::move(file_), file_size, &table_reader_); in NewTableReader()
/rocksdb-6.9/db/
Dlog_reader.cc30 file_(std::move(_file)), in Reader()
237 Status status = file_->Read(remaining, &read_buffer, in UnmarkEOFInternal()
283 Status status = file_->Read(kBlockSize, &buffer_, backing_store_); in ReadMore()
513 Status status = file_->Read(kBlockSize, &buffer_, backing_store_); in TryReadMore()
Dlog_reader.h90 SequentialFileReader* file() { return file_.get(); } in file()
102 const std::unique_ptr<SequentialFileReader> file_; variable

12