Home
last modified time | relevance | path

Searched refs:nbytes (Results 1 – 14 of 14) sorted by relevance

/rocksdb-6.9/env/
Dio_posix.cc1149 size_t nbytes = data.size(); in Append() local
1151 if (!PosixWrite(fd_, src, nbytes)) { in Append()
1155 filesize_ += nbytes; in Append()
1169 size_t nbytes = data.size(); in PositionedAppend() local
1170 if (!PosixPositionedWrite(fd_, src, nbytes, static_cast<off_t>(offset))) { in PositionedAppend()
1174 filesize_ = offset + nbytes; in PositionedAppend()
1335 IOStatus PosixWritableFile::RangeSync(uint64_t offset, uint64_t nbytes, in RangeSync() argument
1348 sync_file_range(fd_, 0, static_cast<off_t>(offset + nbytes), in RangeSync()
1361 return FSWritableFile::RangeSync(offset, nbytes, opts, dbg); in RangeSync()
1388 size_t nbytes = data.size(); in Write() local
[all …]
Dcomposite_env_wrapper.h187 Status RangeSync(uint64_t offset, uint64_t nbytes) override { in RangeSync() argument
190 return target_->RangeSync(offset, nbytes, io_opts, &dbg); in RangeSync()
776 IOStatus RangeSync(uint64_t offset, uint64_t nbytes, in RangeSync() argument
779 return status_to_io_status(target_->RangeSync(offset, nbytes)); in RangeSync()
Denv_encryption.cc287 Status RangeSync(uint64_t offset, uint64_t nbytes) override { in RangeSync() argument
288 return file_->RangeSync(offset + prefixLength_, nbytes); in RangeSync()
Dio_posix.h265 virtual IOStatus RangeSync(uint64_t offset, uint64_t nbytes,
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file.cc486 size_t nbytes = pending_nbytes > (buf->Used() - start_off) in ReadBuffer() local
489 memcpy(tmp, buf->Data() + start_off, nbytes); in ReadBuffer()
492 pending_nbytes -= nbytes; in ReadBuffer()
494 tmp += nbytes; in ReadBuffer()
/rocksdb-6.9/utilities/
Denv_mirror.cc187 Status RangeSync(uint64_t offset, uint64_t nbytes) override { in RangeSync() argument
188 Status as = a_->RangeSync(offset, nbytes); in RangeSync()
189 Status bs = b_->RangeSync(offset, nbytes); in RangeSync()
Denv_librados.cc512 Status RangeSync(off_t offset, off_t nbytes) { in RangeSync() argument
/rocksdb-6.9/db_stress_tool/
Ddb_stress_stat.h139 void AddBytesForWrites(long nwrites, size_t nbytes) { in AddBytesForWrites() argument
141 bytes_ += nbytes; in AddBytesForWrites()
/rocksdb-6.9/util/
Dfile_reader_writer_test.cc59 Status RangeSync(uint64_t offset, uint64_t nbytes) override { in TEST_F() argument
61 EXPECT_EQ(nbytes % 4096, 0u); in TEST_F()
64 last_synced_ = offset + nbytes; in TEST_F()
/rocksdb-6.9/file/
Dwritable_file_writer.cc284 IOStatus WritableFileWriter::RangeSync(uint64_t offset, uint64_t nbytes) { in RangeSync() argument
287 return writable_file_->RangeSync(offset, nbytes, IOOptions(), nullptr); in RangeSync()
Dwritable_file_writer.h177 IOStatus RangeSync(uint64_t offset, uint64_t nbytes);
/rocksdb-6.9/db/
Ddb_test_util.h251 Status RangeSync(uint64_t offset, uint64_t nbytes) override { in NewWritableFile()
252 Status s = base_->RangeSync(offset, nbytes); in NewWritableFile()
/rocksdb-6.9/include/rocksdb/
Dfile_system.h1328 IOStatus RangeSync(uint64_t offset, uint64_t nbytes, const IOOptions& options, in RangeSync() argument
1330 return target_->RangeSync(offset, nbytes, options, dbg); in RangeSync()
Denv.h1514 Status RangeSync(uint64_t offset, uint64_t nbytes) override { in RangeSync() argument
1515 return target_->RangeSync(offset, nbytes); in RangeSync()